Llewellyn
/
conky
mirror of https://github.com/Llewellynvdm/conky.git
1
0
Fork 0
Code Issues Releases Activity
conky/src/libmpdclient.cc

2026 lines
62 KiB
C++
Raw Permalink Blame History

/*
*
* libmpdclient
* (c)2003-2006 by Warren Dukes (warren.dukes@gmail.com)
* This project's homepage is: http://www.musicpd.org
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* - Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* - Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* - Neither the name of the Music Player Daemon nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
* PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
*/
#include "libmpdclient.h"
#include "conky.h"
#include <fcntl.h>
#include <sys/param.h>
#include <sys/types.h>
#include <unistd.h>
#include <cctype>
#include <cerrno>
#include <climits>
#ifdef WIN32
#include <winsock.h>
#include <ws2tcpip.h>
#else
#include <arpa/inet.h>
#include <netdb.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <sys/un.h>
#endif
#ifndef SUN_LEN
#define SUN_LEN(a) sizeof(a)
#endif
#ifndef SOCK_CLOEXEC
#define SOCK_CLOEXEC O_CLOEXEC
#endif /* SOCK_CLOEXEC */
/* (bits + 1) / 3 (plus the sign character) */
#define INTLEN ((sizeof(int) * CHAR_BIT + 1) / 3 + 1)
#define LONGLONGLEN ((sizeof(long long) * CHAR_BIT + 1) / 3 + 1)
#define COMMAND_LIST 1
#define COMMAND_LIST_OK 2
#ifndef MPD_NO_GAI
#ifdef AI_ADDRCONFIG
#define MPD_HAVE_GAI
#endif
#endif
#ifndef MSG_DONTWAIT
#define MSG_DONTWAIT 0
#endif
#ifdef WIN32
#define SELECT_ERRNO_IGNORE (errno == WSAEINTR || errno == WSAEINPROGRESS)
#define SENDRECV_ERRNO_IGNORE SELECT_ERRNO_IGNORE
#else
#define SELECT_ERRNO_IGNORE (errno == EINTR)
#define SENDRECV_ERRNO_IGNORE (errno == EINTR || errno == EAGAIN)
#define winsock_dll_error(c) 0
#define closesocket(s) close(s)
#define WSACleanup() \
do { /* nothing */ \
} while (0)
#endif
#ifdef WIN32
static int winsock_dll_error(mpd_Connection *connection) {
WSADATA wsaData;
if ((WSAStartup(MAKEWORD(2, 2), &wsaData)) != 0 ||
LOBYTE(wsaData.wVersion) != 2 || HIBYTE(wsaData.wVersion) != 2) {
strncpy(connection->errorStr, "Could not find usable WinSock DLL.",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_SYSTEM;
return 1;
}
return 0;
}
static int do_connect_fail(mpd_Connection *connection,
const struct sockaddr *serv_addr, int addrlen) {
int iMode = 1; /* 0 = blocking, else non-blocking */
ioctlsocket(connection->sock, FIONBIO, (u_long FAR *)&iMode);
return (connect(connection->sock, serv_addr, addrlen) == SOCKET_ERROR &&
WSAGetLastError() != WSAEWOULDBLOCK);
}
#else /* !WIN32 (sane operating systems) */
static int do_connect_fail(mpd_Connection *connection,
const struct sockaddr *serv_addr, int addrlen) {
int flags = fcntl(connection->sock, F_GETFL, 0);
fcntl(connection->sock, F_SETFL, flags | O_NONBLOCK);
return static_cast<int>(connect(connection->sock, serv_addr, addrlen) < 0 &&
errno != EINPROGRESS);
}
#endif /* !WIN32 */
static int uds_connect(mpd_Connection *connection, const char *host,
float timeout) {
struct sockaddr_un addr {};
strncpy(addr.sun_path, host, sizeof(addr.sun_path) - 1);
addr.sun_family = AF_UNIX;
addr.sun_path[sizeof(addr.sun_path) - 1] = 0;
connection->sock = socket(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0);
if (connection->sock < 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems creating socket: %s", strerror(errno));
connection->error = MPD_ERROR_SYSTEM;
return -1;
}
mpd_setConnectionTimeout(connection, timeout);
/* connect stuff */
if (do_connect_fail(connection, reinterpret_cast<struct sockaddr *>(&addr),
SUN_LEN(&addr)) != 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems connecting socket: %s", strerror(errno));
closesocket(connection->sock);
connection->sock = -1;
connection->error = MPD_ERROR_SYSTEM;
return -1;
}
return 0;
}
#ifdef MPD_HAVE_GAI
static int mpd_connect(mpd_Connection *connection, const char *host, int port,
float timeout) {
int error;
char service[INTLEN + 1];
struct addrinfo hints {};
struct addrinfo *res = nullptr;
struct addrinfo *addrinfo = nullptr;
if (*host == '/') { return uds_connect(connection, host, timeout); }
/* Setup hints */
hints.ai_flags = AI_ADDRCONFIG;
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
hints.ai_protocol = IPPROTO_TCP;
hints.ai_addrlen = 0;
hints.ai_addr = nullptr;
hints.ai_canonname = nullptr;
hints.ai_next = nullptr;
snprintf(service, sizeof(service), "%i", port);
error = getaddrinfo(host, service, &hints, &addrinfo);
if (error != 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"host \"%s\" not found: %s", host, gai_strerror(error));
connection->error = MPD_ERROR_UNKHOST;
return -1;
}
for (res = addrinfo; res != nullptr; res = res->ai_next) {
/* create socket */
if (connection->sock > -1) { closesocket(connection->sock); }
connection->sock =
socket(res->ai_family, SOCK_STREAM | SOCK_CLOEXEC, res->ai_protocol);
if (connection->sock < 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems creating socket: %s", strerror(errno));
connection->error = MPD_ERROR_SYSTEM;
freeaddrinfo(addrinfo);
return -1;
}
mpd_setConnectionTimeout(connection, timeout);
/* connect stuff */
if (do_connect_fail(connection, res->ai_addr, res->ai_addrlen) != 0) {
/* try the next address family */
closesocket(connection->sock);
connection->sock = -1;
continue;
}
}
freeaddrinfo(addrinfo);
if (connection->sock < 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems connecting to \"%s\" on port %i: %s", host, port,
strerror(errno));
connection->error = MPD_ERROR_CONNPORT;
return -1;
}
return 0;
}
#else /* !MPD_HAVE_GAI */
static int mpd_connect(mpd_Connection *connection, const char *host, int port,
float timeout) {
struct hostent he, *he_res = 0;
int he_errno;
char hostbuff[2048];
struct sockaddr *dest;
int destlen;
struct sockaddr_in sin;
if (*host == '/') return uds_connect(connection, host, timeout);
#ifdef HAVE_GETHOSTBYNAME_R
if (gethostbyname_r(host, &he, hostbuff, sizeof(hostbuff), &he_res,
&he_errno)) { // get the host info
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH, "%s ('%s')",
hstrerror(h_errno), host);
connection->error = MPD_ERROR_UNKHOST;
return -1;
}
#else /* HAVE_GETHOSTBYNAME_R */
if (!(he_res = gethostbyname(host))) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"host \"%s\" not found", host);
connection->error = MPD_ERROR_UNKHOST;
return -1;
}
#endif /* HAVE_GETHOSTBYNAME_R */
memset(&sin, 0, sizeof(struct sockaddr_in));
/* dest.sin_family = he_res->h_addrtype; */
sin.sin_family = AF_INET;
sin.sin_port = htons(port);
switch (he_res->h_addrtype) {
case AF_INET:
memcpy((char *)&sin.sin_addr.s_addr, (char *)he_res->h_addr,
he_res->h_length);
dest = (struct sockaddr *)&sin;
destlen = sizeof(struct sockaddr_in);
break;
default:
strncpy(connection->errorStr, "address type is not IPv4",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_SYSTEM;
return -1;
break;
}
if (connection->sock > -1) { closesocket(connection->sock); }
if ((connection->sock = socket(dest->sa_family, SOCK_STREAM, 0)) < 0) {
strncpy(connection->errorStr, "problems creating socket",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_SYSTEM;
return -1;
}
mpd_setConnectionTimeout(connection, timeout);
/* connect stuff */
if (do_connect_fail(connection, dest, destlen)) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems connecting to \"%s\" on port %i", host, port);
connection->error = MPD_ERROR_CONNPORT;
return -1;
}
return 0;
}
#endif /* !MPD_HAVE_GAI */
const char *mpdTagItemKeys[MPD_TAG_NUM_OF_ITEM_TYPES] = {
"Artist", "Album", "Title", "Track", "Name", "Genre", "Date",
"Composer", "Performer", "Comment", "Disc", "Filename", "Any"};
static char *mpd_sanitizeArg(const char *arg) {
size_t i;
char *ret;
const char *c;
char *rc;
/* instead of counting in that loop above,
* just use a bit more memory and halve running time */
ret = static_cast<char *>(malloc(strlen(arg) * 2 + 1));
c = arg;
rc = ret;
for (i = strlen(arg) + 1; i != 0; --i) {
if (*c == '"' || *c == '\\') { *rc++ = '\\'; }
*(rc++) = *(c++);
}
return ret;
}
static mpd_ReturnElement *mpd_newReturnElement(const char *name,
const char *value) {
auto *ret =
static_cast<mpd_ReturnElement *>(malloc(sizeof(mpd_ReturnElement)));
ret->name = strndup(name, text_buffer_size.get(*state));
ret->value = strndup(value, text_buffer_size.get(*state));
return ret;
}
static void mpd_freeReturnElement(mpd_ReturnElement *re) {
free(re->name);
free(re->value);
free(re);
}
void mpd_setConnectionTimeout(mpd_Connection *connection, float timeout) {
connection->timeout.tv_sec = static_cast<int>(timeout);
connection->timeout.tv_usec =
static_cast<int>((timeout - connection->timeout.tv_sec) * 1e6 + 0.5);
}
static int mpd_parseWelcome(mpd_Connection *connection, const char *host,
int port, /* char *rt, */ char *output) {
char *tmp;
char *test;
int i;
if (static_cast<int>(strncmp(output, MPD_WELCOME_MESSAGE,
strlen(MPD_WELCOME_MESSAGE)) != 0) != 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"mpd not running on port %i on host \"%s\"", port, host);
connection->error = MPD_ERROR_NOTMPD;
return 1;
}
tmp = &output[strlen(MPD_WELCOME_MESSAGE)];
for (i = 0; i < 3; i++) {
if (tmp != nullptr) { connection->version[i] = strtol(tmp, &test, 10); }
if ((tmp == nullptr) || (test[0] != '.' && test[0] != '\0')) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"error parsing version number at \"%s\"",
&output[strlen(MPD_WELCOME_MESSAGE)]);
connection->error = MPD_ERROR_NOTMPD;
return 1;
}
tmp = ++test;
}
return 0;
}
mpd_Connection *mpd_newConnection(const char *host, int port, float timeout) {
int err;
char *rt;
char *output = nullptr;
auto *connection =
static_cast<mpd_Connection *>(malloc(sizeof(mpd_Connection)));
struct timeval tv {};
fd_set fds;
strncpy(connection->buffer, "", 1);
connection->buflen = 0;
connection->bufstart = 0;
strncpy(connection->errorStr, "", MPD_ERRORSTR_MAX_LENGTH);
connection->error = 0;
connection->doneProcessing = 0;
connection->commandList = 0;
connection->listOks = 0;
connection->doneListOk = 0;
connection->sock = -1;
connection->returnElement = nullptr;
connection->request = nullptr;
if (winsock_dll_error(connection)) { return connection; }
if (mpd_connect(connection, host, port, timeout) < 0) { return connection; }
while ((rt = strstr(connection->buffer, "\n")) == nullptr) {
tv.tv_sec = connection->timeout.tv_sec;
tv.tv_usec = connection->timeout.tv_usec;
FD_ZERO(&fds);
FD_SET(connection->sock, &fds);
if ((err = select(connection->sock + 1, &fds, nullptr, nullptr, &tv)) ==
1) {
int readed;
readed = recv(connection->sock, &(connection->buffer[connection->buflen]),
MPD_BUFFER_MAX_LENGTH - connection->buflen, 0);
if (readed <= 0) {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems getting a response from \"%s\" on port %i : %s",
host, port, strerror(errno));
connection->error = MPD_ERROR_NORESPONSE;
return connection;
}
connection->buflen += readed;
connection->buffer[connection->buflen] = '\0';
} else if (err < 0) {
if SELECT_ERRNO_IGNORE { continue; }
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems connecting to \"%s\" on port %i", host, port);
connection->error = MPD_ERROR_CONNPORT;
return connection;
} else {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"timeout in attempting to get a response from \"%s\" on "
"port %i",
host, port);
connection->error = MPD_ERROR_NORESPONSE;
return connection;
}
}
*rt = '\0';
output = strndup(connection->buffer, text_buffer_size.get(*state));
strncpy(connection->buffer, rt + 1, MPD_BUFFER_MAX_LENGTH);
connection->buflen = strlen(connection->buffer);
if (mpd_parseWelcome(connection, host, port, /* rt, */ output) == 0) {
connection->doneProcessing = 1;
}
free(output);
return connection;
}
void mpd_clearError(mpd_Connection *connection) {
connection->error = 0;
connection->errorStr[0] = '\0';
}
void mpd_closeConnection(mpd_Connection *connection) {
if (connection != nullptr) {
closesocket(connection->sock);
free_and_zero(connection->returnElement);
free_and_zero(connection->request);
free(connection);
}
WSACleanup();
}
static void mpd_executeCommand(mpd_Connection *connection,
const char *command) {
int ret;
struct timeval tv {};
fd_set fds;
const char *commandPtr = command;
int commandLen = strlen(command);
if ((connection->doneProcessing == 0) && (connection->commandList == 0)) {
strncpy(connection->errorStr, "not done processing current command",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
mpd_clearError(connection);
FD_ZERO(&fds);
FD_SET(connection->sock, &fds);
tv.tv_sec = connection->timeout.tv_sec;
tv.tv_usec = connection->timeout.tv_usec;
do {
ret = static_cast<int>(
select(connection->sock + 1, nullptr, &fds, nullptr, &tv));
if (ret != 1 && !SELECT_ERRNO_IGNORE) { break; }
ret = send(connection->sock, commandPtr, commandLen, MSG_DONTWAIT);
if (ret <= 0) {
if SENDRECV_ERRNO_IGNORE { continue; }
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"problems giving command \"%s\"", command);
connection->error = MPD_ERROR_SENDING;
return;
}
commandPtr += ret;
commandLen -= ret;
} while (commandLen > 0);
if (commandLen > 0) {
perror("");
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"timeout sending command \"%s\"", command);
connection->error = MPD_ERROR_TIMEOUT;
return;
}
if (connection->commandList == 0) {
connection->doneProcessing = 0;
} else if (connection->commandList == COMMAND_LIST_OK) {
connection->listOks++;
}
}
static void mpd_getNextReturnElement(mpd_Connection *connection) {
char *output = nullptr;
char *rt = nullptr;
char *name = nullptr;
char *value = nullptr;
fd_set fds;
struct timeval tv {};
char *tok = nullptr;
int readed;
char *bufferCheck = nullptr;
int err;
int pos;
if (connection->returnElement != nullptr) {
mpd_freeReturnElement(connection->returnElement);
}
connection->returnElement = nullptr;
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
strncpy(connection->errorStr, "already done processing current command",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
bufferCheck = connection->buffer + connection->bufstart;
while (connection->bufstart >= connection->buflen ||
((rt = strchr(bufferCheck, '\n')) == nullptr)) {
if (connection->buflen >= MPD_BUFFER_MAX_LENGTH) {
memmove(connection->buffer, connection->buffer + connection->bufstart,
connection->buflen - connection->bufstart + 1);
connection->buflen -= connection->bufstart;
connection->bufstart = 0;
}
if (connection->buflen >= MPD_BUFFER_MAX_LENGTH) {
strncpy(connection->errorStr, "buffer overrun", MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_BUFFEROVERRUN;
connection->doneProcessing = 1;
connection->doneListOk = 0;
return;
}
bufferCheck = connection->buffer + connection->buflen;
tv.tv_sec = connection->timeout.tv_sec;
tv.tv_usec = connection->timeout.tv_usec;
FD_ZERO(&fds);
FD_SET(connection->sock, &fds);
if ((err = static_cast<int>(select(connection->sock + 1, &fds, nullptr,
nullptr, &tv) == 1)) != 0) {
readed = recv(connection->sock, connection->buffer + connection->buflen,
MPD_BUFFER_MAX_LENGTH - connection->buflen, MSG_DONTWAIT);
if (readed < 0 && SENDRECV_ERRNO_IGNORE) { continue; }
if (readed <= 0) {
strncpy(connection->errorStr, "connection closed",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_CONNCLOSED;
connection->doneProcessing = 1;
connection->doneListOk = 0;
return;
}
connection->buflen += readed;
connection->buffer[connection->buflen] = '\0';
} else {
strncpy(connection->errorStr, "connection timeout",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_TIMEOUT;
connection->doneProcessing = 1;
connection->doneListOk = 0;
return;
}
}
*rt = '\0';
output = connection->buffer + connection->bufstart;
connection->bufstart = rt - connection->buffer + 1;
if (strcmp(output, "OK") == 0) {
if (connection->listOks > 0) {
strncpy(connection->errorStr, "expected more list_OK's",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
}
connection->listOks = 0;
connection->doneProcessing = 1;
connection->doneListOk = 0;
return;
}
if (strcmp(output, "list_OK") == 0) {
if (connection->listOks == 0) {
strncpy(connection->errorStr, "got an unexpected list_OK",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
} else {
connection->doneListOk = 1;
connection->listOks--;
}
return;
}
if (strncmp(output, "ACK", strlen("ACK")) == 0) {
char *test;
char *needle;
int val;
strncpy(connection->errorStr, output, MPD_ERRORSTR_MAX_LENGTH);
connection->error = MPD_ERROR_ACK;
connection->errorCode = MPD_ACK_ERROR_UNK;
connection->errorAt = MPD_ERROR_AT_UNK;
connection->doneProcessing = 1;
connection->doneListOk = 0;
needle = strchr(output, '[');
if (needle == nullptr) { return; }
val = strtol(needle + 1, &test, 10);
if (*test != '@') { return; }
connection->errorCode = val;
val = strtol(test + 1, &test, 10);
if (*test != ']') { return; }
connection->errorAt = val;
return;
}
tok = strchr(output, ':');
if (tok == nullptr) { return; }
pos = tok - output;
value = ++tok;
name = output;
name[pos] = '\0';
if (value[0] == ' ') {
connection->returnElement = mpd_newReturnElement(name, &(value[1]));
} else {
snprintf(connection->errorStr, MPD_ERRORSTR_MAX_LENGTH,
"error parsing: %s:%s", name, value);
connection->error = 1;
}
}
void mpd_finishCommand(mpd_Connection *connection) {
while ((connection != nullptr) && (connection->doneProcessing == 0)) {
if (connection->doneListOk != 0) { connection->doneListOk = 0; }
mpd_getNextReturnElement(connection);
}
}
static void mpd_finishListOkCommand(mpd_Connection *connection) {
while ((connection->doneProcessing == 0) && (connection->listOks != 0) &&
(connection->doneListOk == 0)) {
mpd_getNextReturnElement(connection);
}
}
int mpd_nextListOkCommand(mpd_Connection *connection) {
mpd_finishListOkCommand(connection);
if (connection->doneProcessing == 0) { connection->doneListOk = 0; }
if (connection->listOks == 0 || (connection->doneProcessing != 0)) {
return -1;
}
return 0;
}
void mpd_sendStatusCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "status\n");
}
mpd_Status *mpd_getStatus(mpd_Connection *connection) {
mpd_Status *status;
/* mpd_executeCommand(connection, "status\n");
if (connection->error) {
return nullptr;
} */
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
if (connection->returnElement == nullptr) {
mpd_getNextReturnElement(connection);
}
status = static_cast<mpd_Status *>(malloc(sizeof(mpd_Status)));
status->volume = -1;
status->repeat = 0;
status->random = 0;
status->playlist = -1;
status->playlistLength = -1;
status->state = -1;
status->song = 0;
status->songid = 0;
status->elapsedTime = 0;
status->totalTime = 0;
status->bitRate = 0;
status->sampleRate = 0;
status->bits = 0;
status->channels = 0;
status->crossfade = -1;
status->error = nullptr;
status->updatingDb = 0;
if (connection->error != 0) {
free(status);
return nullptr;
}
while (connection->returnElement != nullptr) {
mpd_ReturnElement *re = connection->returnElement;
if (strcmp(re->name, "volume") == 0) {
status->volume = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "repeat") == 0) {
status->repeat = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "random") == 0) {
status->random = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "playlist") == 0) {
status->playlist = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "playlistlength") == 0) {
status->playlistLength = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "bitrate") == 0) {
status->bitRate = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "state") == 0) {
if (strcmp(re->value, "play") == 0) {
status->state = MPD_STATUS_STATE_PLAY;
} else if (strcmp(re->value, "stop") == 0) {
status->state = MPD_STATUS_STATE_STOP;
} else if (strcmp(re->value, "pause") == 0) {
status->state = MPD_STATUS_STATE_PAUSE;
} else {
status->state = MPD_STATUS_STATE_UNKNOWN;
}
} else if (strcmp(re->name, "song") == 0) {
status->song = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "songid") == 0) {
status->songid = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "time") == 0) {
char *tok = strchr(re->value, ':');
/* the second strchr below is a safety check */
if ((tok != nullptr) && (strchr(tok, 0) > (tok + 1))) {
/* strtol stops at the first non-[0-9] char: */
status->elapsedTime = strtol(re->value, nullptr, 10);
status->totalTime = strtol(tok + 1, nullptr, 10);
}
} else if (strcmp(re->name, "error") == 0) {
status->error = strndup(re->value, text_buffer_size.get(*state));
} else if (strcmp(re->name, "xfade") == 0) {
status->crossfade = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "updating_db") == 0) {
status->updatingDb = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "audio") == 0) {
char *tok = strchr(re->value, ':');
if ((tok != nullptr) && (strchr(tok, 0) > (tok + 1))) {
status->sampleRate = strtol(re->value, nullptr, 10);
status->bits = strtol(++tok, nullptr, 10);
tok = strchr(tok, ':');
if ((tok != nullptr) && (strchr(tok, 0) > (tok + 1))) {
status->channels = strtol(tok + 1, nullptr, 10);
}
}
}
mpd_getNextReturnElement(connection);
if (connection->error != 0) {
free(status);
return nullptr;
}
}
if (connection->error != 0) {
free(status);
return nullptr;
}
if (status->state < 0) {
strncpy(connection->errorStr, "state not found", MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
free(status);
return nullptr;
}
return status;
}
void mpd_freeStatus(mpd_Status *status) {
free_and_zero(status->error);
free(status);
}
void mpd_sendStatsCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "stats\n");
}
mpd_Stats *mpd_getStats(mpd_Connection *connection) {
mpd_Stats *stats;
/* mpd_executeCommand(connection, "stats\n");
if (connection->error) {
return nullptr;
} */
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
if (connection->returnElement == nullptr) {
mpd_getNextReturnElement(connection);
}
stats = static_cast<mpd_Stats *>(malloc(sizeof(mpd_Stats)));
stats->numberOfArtists = 0;
stats->numberOfAlbums = 0;
stats->numberOfSongs = 0;
stats->uptime = 0;
stats->dbUpdateTime = 0;
stats->playTime = 0;
stats->dbPlayTime = 0;
if (connection->error != 0) {
free(stats);
return nullptr;
}
while (connection->returnElement != nullptr) {
mpd_ReturnElement *re = connection->returnElement;
if (strcmp(re->name, "artists") == 0) {
stats->numberOfArtists = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "albums") == 0) {
stats->numberOfAlbums = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "songs") == 0) {
stats->numberOfSongs = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "uptime") == 0) {
stats->uptime = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "db_update") == 0) {
stats->dbUpdateTime = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "playtime") == 0) {
stats->playTime = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "db_playtime") == 0) {
stats->dbPlayTime = strtol(re->value, nullptr, 10);
}
mpd_getNextReturnElement(connection);
if (connection->error != 0) {
free(stats);
return nullptr;
}
}
if (connection->error != 0) {
free(stats);
return nullptr;
}
return stats;
}
void mpd_freeStats(mpd_Stats *stats) { free(stats); }
mpd_SearchStats *mpd_getSearchStats(mpd_Connection *connection) {
mpd_SearchStats *stats;
mpd_ReturnElement *re;
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
if (connection->returnElement == nullptr) {
mpd_getNextReturnElement(connection);
}
if (connection->error != 0) { return nullptr; }
stats = static_cast<mpd_SearchStats *>(malloc(sizeof(mpd_SearchStats)));
stats->numberOfSongs = 0;
stats->playTime = 0;
while (connection->returnElement != nullptr) {
re = connection->returnElement;
if (strcmp(re->name, "songs") == 0) {
stats->numberOfSongs = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "playtime") == 0) {
stats->playTime = strtol(re->value, nullptr, 10);
}
mpd_getNextReturnElement(connection);
if (connection->error != 0) {
free(stats);
return nullptr;
}
}
if (connection->error != 0) {
free(stats);
return nullptr;
}
return stats;
}
void mpd_freeSearchStats(mpd_SearchStats *stats) { free(stats); }
static void mpd_initSong(mpd_Song *song) {
song->file = nullptr;
song->artist = nullptr;
song->albumartist = nullptr;
song->album = nullptr;
song->track = nullptr;
song->title = nullptr;
song->name = nullptr;
song->date = nullptr;
/* added by Qball */
song->genre = nullptr;
song->composer = nullptr;
song->performer = nullptr;
song->disc = nullptr;
song->comment = nullptr;
song->time = MPD_SONG_NO_TIME;
song->pos = MPD_SONG_NO_NUM;
song->id = MPD_SONG_NO_ID;
}
static void mpd_finishSong(mpd_Song *song) {
free_and_zero(song->file);
free_and_zero(song->artist);
free_and_zero(song->albumartist);
free_and_zero(song->album);
free_and_zero(song->title);
free_and_zero(song->track);
free_and_zero(song->name);
free_and_zero(song->date);
free_and_zero(song->genre);
free_and_zero(song->composer);
free_and_zero(song->disc);
free_and_zero(song->comment);
}
mpd_Song *mpd_newSong() {
auto *ret = static_cast<mpd_Song *>(malloc(sizeof(mpd_Song)));
mpd_initSong(ret);
return ret;
}
void mpd_freeSong(mpd_Song *song) {
mpd_finishSong(song);
free(song);
}
mpd_Song *mpd_songDup(mpd_Song *song) {
mpd_Song *ret = mpd_newSong();
if (song->file != nullptr) {
ret->file = strndup(song->file, text_buffer_size.get(*state));
}
if (song->artist != nullptr) {
ret->artist = strndup(song->artist, text_buffer_size.get(*state));
}
if (song->albumartist != nullptr) {
ret->artist = strndup(song->albumartist, text_buffer_size.get(*state));
}
if (song->album != nullptr) {
ret->album = strndup(song->album, text_buffer_size.get(*state));
}
if (song->title != nullptr) {
ret->title = strndup(song->title, text_buffer_size.get(*state));
}
if (song->track != nullptr) {
ret->track = strndup(song->track, text_buffer_size.get(*state));
}
if (song->name != nullptr) {
ret->name = strndup(song->name, text_buffer_size.get(*state));
}
if (song->date != nullptr) {
ret->date = strndup(song->date, text_buffer_size.get(*state));
}
if (song->genre != nullptr) {
ret->genre = strndup(song->genre, text_buffer_size.get(*state));
}
if (song->composer != nullptr) {
ret->composer = strndup(song->composer, text_buffer_size.get(*state));
}
if (song->disc != nullptr) {
ret->disc = strndup(song->disc, text_buffer_size.get(*state));
}
if (song->comment != nullptr) {
ret->comment = strndup(song->comment, text_buffer_size.get(*state));
}
ret->time = song->time;
ret->pos = song->pos;
ret->id = song->id;
return ret;
}
static void mpd_initDirectory(mpd_Directory *directory) {
directory->path = nullptr;
}
static void mpd_finishDirectory(mpd_Directory *directory) {
free_and_zero(directory->path);
}
mpd_Directory *mpd_newDirectory() {
auto *directory = static_cast<mpd_Directory *>(malloc(sizeof(mpd_Directory)));
mpd_initDirectory(directory);
return directory;
}
void mpd_freeDirectory(mpd_Directory *directory) {
mpd_finishDirectory(directory);
free(directory);
}
mpd_Directory *mpd_directoryDup(mpd_Directory *directory) {
mpd_Directory *ret = mpd_newDirectory();
if (directory->path != nullptr) {
ret->path = strndup(directory->path, text_buffer_size.get(*state));
}
return ret;
}
static void mpd_initPlaylistFile(mpd_PlaylistFile *playlist) {
playlist->path = nullptr;
}
static void mpd_finishPlaylistFile(mpd_PlaylistFile *playlist) {
free_and_zero(playlist->path);
}
mpd_PlaylistFile *mpd_newPlaylistFile() {
auto *playlist =
static_cast<mpd_PlaylistFile *>(malloc(sizeof(mpd_PlaylistFile)));
mpd_initPlaylistFile(playlist);
return playlist;
}
void mpd_freePlaylistFile(mpd_PlaylistFile *playlist) {
mpd_finishPlaylistFile(playlist);
free(playlist);
}
mpd_PlaylistFile *mpd_playlistFileDup(mpd_PlaylistFile *playlist) {
mpd_PlaylistFile *ret = mpd_newPlaylistFile();
if (playlist->path != nullptr) {
ret->path = strndup(playlist->path, text_buffer_size.get(*state));
}
return ret;
}
static void mpd_initInfoEntity(mpd_InfoEntity *entity) {
entity->info.directory = nullptr;
}
static void mpd_finishInfoEntity(mpd_InfoEntity *entity) {
if (entity->info.directory != nullptr) {
if (entity->type == MPD_INFO_ENTITY_TYPE_DIRECTORY) {
mpd_freeDirectory(entity->info.directory);
} else if (entity->type == MPD_INFO_ENTITY_TYPE_SONG) {
mpd_freeSong(entity->info.song);
} else if (entity->type == MPD_INFO_ENTITY_TYPE_PLAYLISTFILE) {
mpd_freePlaylistFile(entity->info.playlistFile);
}
}
}
mpd_InfoEntity *mpd_newInfoEntity() {
auto *entity = static_cast<mpd_InfoEntity *>(malloc(sizeof(mpd_InfoEntity)));
mpd_initInfoEntity(entity);
return entity;
}
void mpd_freeInfoEntity(mpd_InfoEntity *entity) {
mpd_finishInfoEntity(entity);
free(entity);
}
static void mpd_sendInfoCommand(mpd_Connection *connection, char *command) {
mpd_executeCommand(connection, command);
}
mpd_InfoEntity *mpd_getNextInfoEntity(mpd_Connection *connection) {
mpd_InfoEntity *entity = nullptr;
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
if (connection->returnElement == nullptr) {
mpd_getNextReturnElement(connection);
}
if (connection->returnElement != nullptr) {
if (strcmp(connection->returnElement->name, "file") == 0) {
entity = mpd_newInfoEntity();
entity->type = MPD_INFO_ENTITY_TYPE_SONG;
entity->info.song = mpd_newSong();
entity->info.song->file = strndup(connection->returnElement->value,
text_buffer_size.get(*state));
} else if (strcmp(connection->returnElement->name, "directory") == 0) {
entity = mpd_newInfoEntity();
entity->type = MPD_INFO_ENTITY_TYPE_DIRECTORY;
entity->info.directory = mpd_newDirectory();
entity->info.directory->path = strndup(connection->returnElement->value,
text_buffer_size.get(*state));
} else if (strcmp(connection->returnElement->name, "playlist") == 0) {
entity = mpd_newInfoEntity();
entity->type = MPD_INFO_ENTITY_TYPE_PLAYLISTFILE;
entity->info.playlistFile = mpd_newPlaylistFile();
entity->info.playlistFile->path = strndup(
connection->returnElement->value, text_buffer_size.get(*state));
} else if (strcmp(connection->returnElement->name, "cpos") == 0) {
entity = mpd_newInfoEntity();
entity->type = MPD_INFO_ENTITY_TYPE_SONG;
entity->info.song = mpd_newSong();
entity->info.song->pos =
strtol(connection->returnElement->value, nullptr, 10);
} else {
connection->error = 1;
strncpy(connection->errorStr, "problem parsing song info",
MPD_ERRORSTR_MAX_LENGTH);
return nullptr;
}
} else {
return nullptr;
}
mpd_getNextReturnElement(connection);
while (connection->returnElement != nullptr) {
mpd_ReturnElement *re = connection->returnElement;
if (strcmp(re->name, "file") == 0) { return entity; }
if (strcmp(re->name, "directory") == 0) { return entity; }
if (strcmp(re->name, "playlist") == 0) { return entity; }
if (strcmp(re->name, "cpos") == 0) { return entity; }
if (entity->type == MPD_INFO_ENTITY_TYPE_SONG &&
(strlen(re->value) != 0u)) {
if ((entity->info.song->artist == nullptr) &&
strcmp(re->name, "Artist") == 0) {
entity->info.song->artist =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->albumartist == nullptr) &&
strcmp(re->name, "AlbumArtist") == 0) {
entity->info.song->albumartist =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->album == nullptr) &&
strcmp(re->name, "Album") == 0) {
entity->info.song->album =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->title == nullptr) &&
strcmp(re->name, "Title") == 0) {
entity->info.song->title =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->track == nullptr) &&
strcmp(re->name, "Track") == 0) {
entity->info.song->track =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->name == nullptr) &&
strcmp(re->name, "Name") == 0) {
entity->info.song->name =
strndup(re->value, text_buffer_size.get(*state));
} else if (entity->info.song->time == MPD_SONG_NO_TIME &&
strcmp(re->name, "Time") == 0) {
entity->info.song->time = strtol(re->value, nullptr, 10);
} else if (entity->info.song->pos == MPD_SONG_NO_NUM &&
strcmp(re->name, "Pos") == 0) {
entity->info.song->pos = strtol(re->value, nullptr, 10);
} else if (entity->info.song->id == MPD_SONG_NO_ID &&
strcmp(re->name, "Id") == 0) {
entity->info.song->id = strtol(re->value, nullptr, 10);
} else if ((entity->info.song->date == nullptr) &&
strcmp(re->name, "Date") == 0) {
entity->info.song->date =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->genre == nullptr) &&
strcmp(re->name, "Genre") == 0) {
entity->info.song->genre =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->composer == nullptr) &&
strcmp(re->name, "Composer") == 0) {
entity->info.song->composer =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->performer == nullptr) &&
strcmp(re->name, "Performer") == 0) {
entity->info.song->performer =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->disc == nullptr) &&
strcmp(re->name, "Disc") == 0) {
entity->info.song->disc =
strndup(re->value, text_buffer_size.get(*state));
} else if ((entity->info.song->comment == nullptr) &&
strcmp(re->name, "Comment") == 0) {
entity->info.song->comment =
strndup(re->value, text_buffer_size.get(*state));
}
} else if (entity->type == MPD_INFO_ENTITY_TYPE_DIRECTORY) {
} else if (entity->type == MPD_INFO_ENTITY_TYPE_PLAYLISTFILE) {
}
mpd_getNextReturnElement(connection);
}
return entity;
}
static char *mpd_getNextReturnElementNamed(mpd_Connection *connection,
const char *name) {
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
mpd_getNextReturnElement(connection);
while (connection->returnElement != nullptr) {
mpd_ReturnElement *re = connection->returnElement;
if (strcmp(re->name, name) == 0) {
return strndup(re->value, text_buffer_size.get(*state));
}
mpd_getNextReturnElement(connection);
}
return nullptr;
}
char *mpd_getNextTag(mpd_Connection *connection, int type) {
if (type < 0 || type >= MPD_TAG_NUM_OF_ITEM_TYPES ||
type == MPD_TAG_ITEM_ANY) {
return nullptr;
}
if (type == MPD_TAG_ITEM_FILENAME) {
return mpd_getNextReturnElementNamed(connection, "file");
}
return mpd_getNextReturnElementNamed(connection, mpdTagItemKeys[type]);
}
char *mpd_getNextArtist(mpd_Connection *connection) {
return mpd_getNextReturnElementNamed(connection, "Artist");
}
char *mpd_getNextAlbum(mpd_Connection *connection) {
return mpd_getNextReturnElementNamed(connection, "Album");
}
void mpd_sendPlaylistInfoCommand(mpd_Connection *connection, int songPos) {
int len = strlen("playlistinfo") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistinfo \"%i\"\n", songPos);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendPlaylistIdCommand(mpd_Connection *connection, int id) {
int len = strlen("playlistid") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistid \"%i\"\n", id);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendPlChangesCommand(mpd_Connection *connection, long long playlist) {
int len = strlen("plchanges") + 2 + LONGLONGLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "plchanges \"%lld\"\n", playlist);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendPlChangesPosIdCommand(mpd_Connection *connection,
long long playlist) {
int len = strlen("plchangesposid") + 2 + LONGLONGLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "plchangesposid \"%lld\"\n", playlist);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendListallCommand(mpd_Connection *connection, const char *dir) {
char *sDir = mpd_sanitizeArg(dir);
int len = strlen("listall") + 2 + strlen(sDir) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "listall \"%s\"\n", sDir);
mpd_sendInfoCommand(connection, string);
free(string);
free(sDir);
}
void mpd_sendListallInfoCommand(mpd_Connection *connection, const char *dir) {
char *sDir = mpd_sanitizeArg(dir);
int len = strlen("listallinfo") + 2 + strlen(sDir) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "listallinfo \"%s\"\n", sDir);
mpd_sendInfoCommand(connection, string);
free(string);
free(sDir);
}
void mpd_sendLsInfoCommand(mpd_Connection *connection, const char *dir) {
char *sDir = mpd_sanitizeArg(dir);
int len = strlen("lsinfo") + 2 + strlen(sDir) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "lsinfo \"%s\"\n", sDir);
mpd_sendInfoCommand(connection, string);
free(string);
free(sDir);
}
void mpd_sendCurrentSongCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "currentsong\n");
}
void mpd_sendSearchCommand(mpd_Connection *connection, int table,
const char *str) {
mpd_startSearch(connection, 0);
mpd_addConstraintSearch(connection, table, str);
mpd_commitSearch(connection);
}
void mpd_sendFindCommand(mpd_Connection *connection, int table,
const char *str) {
mpd_startSearch(connection, 1);
mpd_addConstraintSearch(connection, table, str);
mpd_commitSearch(connection);
}
void mpd_sendListCommand(mpd_Connection *connection, int table,
const char *arg1) {
char st[7];
int len;
char *string;
if (table == MPD_TABLE_ARTIST) {
strncpy(st, "artist", strlen("artist") + 1);
} else if (table == MPD_TABLE_ALBUM) {
strncpy(st, "album", strlen("album") + 1);
} else {
connection->error = 1;
strncpy(connection->errorStr, "unknown table for list",
MPD_ERRORSTR_MAX_LENGTH);
return;
}
if (arg1 != nullptr) {
char *sanitArg1 = mpd_sanitizeArg(arg1);
len = strlen("list") + 1 + strlen(sanitArg1) + 2 + strlen(st) + 3;
string = static_cast<char *>(malloc(len));
snprintf(string, len, "list %s \"%s\"\n", st, sanitArg1);
free(sanitArg1);
} else {
len = strlen("list") + 1 + strlen(st) + 2;
string = static_cast<char *>(malloc(len));
snprintf(string, len, "list %s\n", st);
}
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendAddCommand(mpd_Connection *connection, const char *file) {
char *sFile = mpd_sanitizeArg(file);
int len = strlen("add") + 2 + strlen(sFile) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "add \"%s\"\n", sFile);
mpd_executeCommand(connection, string);
free(string);
free(sFile);
}
int mpd_sendAddIdCommand(mpd_Connection *connection, const char *file) {
int retval = -1;
char *sFile = mpd_sanitizeArg(file);
int len = strlen("addid") + 2 + strlen(sFile) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "addid \"%s\"\n", sFile);
mpd_sendInfoCommand(connection, string);
free(string);
free(sFile);
string = mpd_getNextReturnElementNamed(connection, "Id");
if (string != nullptr) {
retval = strtol(string, nullptr, 10);
free(string);
}
return retval;
}
void mpd_sendDeleteCommand(mpd_Connection *connection, int songPos) {
int len = strlen("delete") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "delete \"%i\"\n", songPos);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendDeleteIdCommand(mpd_Connection *connection, int id) {
int len = strlen("deleteid") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "deleteid \"%i\"\n", id);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendSaveCommand(mpd_Connection *connection, const char *name) {
char *sName = mpd_sanitizeArg(name);
int len = strlen("save") + 2 + strlen(sName) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "save \"%s\"\n", sName);
mpd_executeCommand(connection, string);
free(string);
free(sName);
}
void mpd_sendLoadCommand(mpd_Connection *connection, const char *name) {
char *sName = mpd_sanitizeArg(name);
int len = strlen("load") + 2 + strlen(sName) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "load \"%s\"\n", sName);
mpd_executeCommand(connection, string);
free(string);
free(sName);
}
void mpd_sendRmCommand(mpd_Connection *connection, const char *name) {
char *sName = mpd_sanitizeArg(name);
int len = strlen("rm") + 2 + strlen(sName) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "rm \"%s\"\n", sName);
mpd_executeCommand(connection, string);
free(string);
free(sName);
}
void mpd_sendRenameCommand(mpd_Connection *connection, const char *from,
const char *to) {
char *sFrom = mpd_sanitizeArg(from);
char *sTo = mpd_sanitizeArg(to);
int len = strlen("rename") + 2 + strlen(sFrom) + 3 + strlen(sTo) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "rename \"%s\" \"%s\"\n", sFrom, sTo);
mpd_executeCommand(connection, string);
free(string);
free(sFrom);
free(sTo);
}
void mpd_sendShuffleCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "shuffle\n");
}
void mpd_sendClearCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "clear\n");
}
void mpd_sendPlayCommand(mpd_Connection *connection, int songPos) {
int len = strlen("play") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "play \"%i\"\n", songPos);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendPlayIdCommand(mpd_Connection *connection, int id) {
int len = strlen("playid") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playid \"%i\"\n", id);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendStopCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "stop\n");
}
void mpd_sendPauseCommand(mpd_Connection *connection, int pauseMode) {
int len = strlen("pause") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "pause \"%i\"\n", pauseMode);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendNextCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "next\n");
}
void mpd_sendMoveCommand(mpd_Connection *connection, int from, int to) {
int len = strlen("move") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "move \"%i\" \"%i\"\n", from, to);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendMoveIdCommand(mpd_Connection *connection, int id, int to) {
int len = strlen("moveid") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "moveid \"%i\" \"%i\"\n", id, to);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendSwapCommand(mpd_Connection *connection, int song1, int song2) {
int len = strlen("swap") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "swap \"%i\" \"%i\"\n", song1, song2);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendSwapIdCommand(mpd_Connection *connection, int id1, int id2) {
int len = strlen("swapid") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "swapid \"%i\" \"%i\"\n", id1, id2);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendSeekCommand(mpd_Connection *connection, int song, int seek_time) {
int len = strlen("seek") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "seek \"%i\" \"%i\"\n", song, seek_time);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendSeekIdCommand(mpd_Connection *connection, int id, int seek_time) {
int len = strlen("seekid") + 2 + INTLEN + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "seekid \"%i\" \"%i\"\n", id, seek_time);
mpd_sendInfoCommand(connection, string);
free(string);
}
void mpd_sendUpdateCommand(mpd_Connection *connection, char *path) {
char *sPath = mpd_sanitizeArg(path);
int len = strlen("update") + 2 + strlen(sPath) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "update \"%s\"\n", sPath);
mpd_sendInfoCommand(connection, string);
free(string);
free(sPath);
}
int mpd_getUpdateId(mpd_Connection *connection) {
char *jobid;
int ret = 0;
jobid = mpd_getNextReturnElementNamed(connection, "updating_db");
if (jobid != nullptr) {
ret = strtol(jobid, nullptr, 10);
free(jobid);
}
return ret;
}
void mpd_sendPrevCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "previous\n");
}
void mpd_sendRepeatCommand(mpd_Connection *connection, int repeatMode) {
int len = strlen("repeat") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "repeat \"%i\"\n", repeatMode);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendRandomCommand(mpd_Connection *connection, int randomMode) {
int len = strlen("random") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "random \"%i\"\n", randomMode);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendSetvolCommand(mpd_Connection *connection, int volumeChange) {
int len = strlen("setvol") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "setvol \"%i\"\n", volumeChange);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendVolumeCommand(mpd_Connection *connection, int volumeChange) {
int len = strlen("volume") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "volume \"%i\"\n", volumeChange);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendCrossfadeCommand(mpd_Connection *connection, int seconds) {
int len = strlen("crossfade") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "crossfade \"%i\"\n", seconds);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendPasswordCommand(mpd_Connection *connection, const char *pass) {
char *sPass = mpd_sanitizeArg(pass);
int len = strlen("password") + 2 + strlen(sPass) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "password \"%s\"\n", sPass);
mpd_executeCommand(connection, string);
free(string);
free(sPass);
}
void mpd_sendCommandListBegin(mpd_Connection *connection) {
if (connection->commandList != 0) {
strncpy(connection->errorStr, "already in command list mode",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
connection->commandList = COMMAND_LIST;
mpd_executeCommand(connection, "command_list_begin\n");
}
void mpd_sendCommandListOkBegin(mpd_Connection *connection) {
if (connection->commandList != 0) {
strncpy(connection->errorStr, "already in command list mode",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
connection->commandList = COMMAND_LIST_OK;
mpd_executeCommand(connection, "command_list_ok_begin\n");
connection->listOks = 0;
}
void mpd_sendCommandListEnd(mpd_Connection *connection) {
if (connection->commandList == 0) {
strncpy(connection->errorStr, "not in command list mode",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
connection->commandList = 0;
mpd_executeCommand(connection, "command_list_end\n");
}
void mpd_sendOutputsCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "outputs\n");
}
mpd_OutputEntity *mpd_getNextOutput(mpd_Connection *connection) {
mpd_OutputEntity *output = nullptr;
if ((connection->doneProcessing != 0) ||
((connection->listOks != 0) && (connection->doneListOk != 0))) {
return nullptr;
}
if (connection->error != 0) { return nullptr; }
output = static_cast<mpd_OutputEntity *>(malloc(sizeof(mpd_OutputEntity)));
output->id = -10;
output->name = nullptr;
output->enabled = 0;
if (connection->returnElement == nullptr) {
mpd_getNextReturnElement(connection);
}
while (connection->returnElement != nullptr) {
mpd_ReturnElement *re = connection->returnElement;
if (strcmp(re->name, "outputid") == 0) {
if (output != nullptr && output->id >= 0) { return output; }
output->id = strtol(re->value, nullptr, 10);
} else if (strcmp(re->name, "outputname") == 0) {
output->name = strndup(re->value, text_buffer_size.get(*state));
} else if (strcmp(re->name, "outputenabled") == 0) {
output->enabled = strtol(re->value, nullptr, 10);
}
mpd_getNextReturnElement(connection);
if (connection->error != 0) {
free(output);
return nullptr;
}
}
return output;
}
void mpd_sendEnableOutputCommand(mpd_Connection *connection, int outputId) {
int len = strlen("enableoutput") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "enableoutput \"%i\"\n", outputId);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_sendDisableOutputCommand(mpd_Connection *connection, int outputId) {
int len = strlen("disableoutput") + 2 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "disableoutput \"%i\"\n", outputId);
mpd_executeCommand(connection, string);
free(string);
}
void mpd_freeOutputElement(mpd_OutputEntity *output) {
free(output->name);
free(output);
}
/** odd naming, but it gets the not allowed commands */
void mpd_sendNotCommandsCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "notcommands\n");
}
/** odd naming, but it gets the allowed commands */
void mpd_sendCommandsCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "commands\n");
}
/** Get the next returned command */
char *mpd_getNextCommand(mpd_Connection *connection) {
return mpd_getNextReturnElementNamed(connection, "command");
}
void mpd_sendUrlHandlersCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "urlhandlers\n");
}
char *mpd_getNextHandler(mpd_Connection *connection) {
return mpd_getNextReturnElementNamed(connection, "handler");
}
void mpd_sendTagTypesCommand(mpd_Connection *connection) {
mpd_executeCommand(connection, "tagtypes\n");
}
char *mpd_getNextTagType(mpd_Connection *connection) {
return mpd_getNextReturnElementNamed(connection, "tagtype");
}
void mpd_startSearch(mpd_Connection *connection, int exact) {
if (connection->request != nullptr) {
strncpy(connection->errorStr, "search already in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
if (exact != 0) {
connection->request = strndup("find", text_buffer_size.get(*state));
} else {
connection->request = strndup("search", text_buffer_size.get(*state));
}
}
void mpd_startStatsSearch(mpd_Connection *connection) {
if (connection->request != nullptr) {
strncpy(connection->errorStr, "search already in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
connection->request = strndup("count", text_buffer_size.get(*state));
}
void mpd_startPlaylistSearch(mpd_Connection *connection, int exact) {
if (connection->request != nullptr) {
strncpy(connection->errorStr, "search already in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
if (exact != 0) {
connection->request = strndup("playlistfind", text_buffer_size.get(*state));
} else {
connection->request =
strndup("playlistsearch", text_buffer_size.get(*state));
}
}
void mpd_startFieldSearch(mpd_Connection *connection, int type) {
const char *strtype;
int len;
if (connection->request != nullptr) {
strncpy(connection->errorStr, "search already in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
if (type < 0 || type >= MPD_TAG_NUM_OF_ITEM_TYPES) {
strncpy(connection->errorStr, "invalid type specified",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
strtype = mpdTagItemKeys[type];
len = 5 + strlen(strtype) + 1;
connection->request = static_cast<char *>(malloc(len));
snprintf(connection->request, len, "list %c%s",
tolower(static_cast<unsigned char>(strtype[0])), strtype + 1);
}
void mpd_addConstraintSearch(mpd_Connection *connection, int type,
const char *name) {
const char *strtype;
char *arg;
int len;
char *string;
if (connection->request == nullptr) {
strncpy(connection->errorStr, "no search in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
if (type < 0 || type >= MPD_TAG_NUM_OF_ITEM_TYPES) {
strncpy(connection->errorStr, "invalid type specified",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
if (name == nullptr) {
strncpy(connection->errorStr, "no name specified", MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
string = strndup(connection->request, text_buffer_size.get(*state));
strtype = mpdTagItemKeys[type];
arg = mpd_sanitizeArg(name);
len = strlen(string) + 1 + strlen(strtype) + 2 + strlen(arg) + 2;
connection->request = static_cast<char *>(realloc(connection->request, len));
snprintf(connection->request, len, "%s %c%s \"%s\"", string,
tolower(static_cast<unsigned char>(strtype[0])), strtype + 1, arg);
free(string);
free(arg);
}
void mpd_commitSearch(mpd_Connection *connection) {
int len;
if (connection->request == nullptr) {
strncpy(connection->errorStr, "no search in progress",
MPD_ERRORSTR_MAX_LENGTH);
connection->error = 1;
return;
}
len = strlen(connection->request) + 2;
connection->request = static_cast<char *>(realloc(connection->request, len));
connection->request[len - 2] = '\n';
connection->request[len - 1] = '\0';
mpd_sendInfoCommand(connection, connection->request);
free_and_zero(connection->request);
}
/**
* @param connection a MpdConnection
* @param path the path to the playlist.
*
* List the content, with full metadata, of a stored playlist. */
void mpd_sendListPlaylistInfoCommand(mpd_Connection *connection, char *path) {
char *arg = mpd_sanitizeArg(path);
int len = strlen("listplaylistinfo") + 2 + strlen(arg) + 3;
auto *query = static_cast<char *>(malloc(len));
snprintf(query, len, "listplaylistinfo \"%s\"\n", arg);
mpd_sendInfoCommand(connection, query);
free(arg);
free(query);
}
/**
* @param connection a MpdConnection
* @param path the path to the playlist.
*
* List the content of a stored playlist. */
void mpd_sendListPlaylistCommand(mpd_Connection *connection, char *path) {
char *arg = mpd_sanitizeArg(path);
int len = strlen("listplaylist") + 2 + strlen(arg) + 3;
auto *query = static_cast<char *>(malloc(len));
snprintf(query, len, "listplaylist \"%s\"\n", arg);
mpd_sendInfoCommand(connection, query);
free(arg);
free(query);
}
void mpd_sendPlaylistClearCommand(mpd_Connection *connection, char *path) {
char *sPath = mpd_sanitizeArg(path);
int len = strlen("playlistclear") + 2 + strlen(sPath) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistclear \"%s\"\n", sPath);
mpd_executeCommand(connection, string);
free(sPath);
free(string);
}
void mpd_sendPlaylistAddCommand(mpd_Connection *connection, char *playlist,
char *path) {
char *sPlaylist = mpd_sanitizeArg(playlist);
char *sPath = mpd_sanitizeArg(path);
int len =
strlen("playlistadd") + 2 + strlen(sPlaylist) + 3 + strlen(sPath) + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistadd \"%s\" \"%s\"\n", sPlaylist, sPath);
mpd_executeCommand(connection, string);
free(sPlaylist);
free(sPath);
free(string);
}
void mpd_sendPlaylistMoveCommand(mpd_Connection *connection, char *playlist,
int from, int to) {
char *sPlaylist = mpd_sanitizeArg(playlist);
int len = strlen("playlistmove") + 2 + strlen(sPlaylist) + 3 + INTLEN + 3 +
INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistmove \"%s\" \"%i\" \"%i\"\n", sPlaylist, from,
to);
mpd_executeCommand(connection, string);
free(sPlaylist);
free(string);
}
void mpd_sendPlaylistDeleteCommand(mpd_Connection *connection, char *playlist,
int pos) {
char *sPlaylist = mpd_sanitizeArg(playlist);
int len = strlen("playlistdelete") + 2 + strlen(sPlaylist) + 3 + INTLEN + 3;
auto *string = static_cast<char *>(malloc(len));
snprintf(string, len, "playlistdelete \"%s\" \"%i\"\n", sPlaylist, pos);
mpd_executeCommand(connection, string);
free(sPlaylist);
free(string);
}
View Git Blame Copy Permalink