src/mpdclient.c

   1 /* ncmpc (Ncurses MPD Client)
   2  * (c) 2004-2009 The Music Player Daemon Project
   3  * Project homepage: http://musicpd.org
   4
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9
  10  * This program is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13  * GNU General Public License for more details.
  14
  15  * You should have received a copy of the GNU General Public License along
  16  * with this program; if not, write to the Free Software Foundation, Inc.,
  17  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  18 */
  19
  20 #include "mpdclient.h"
  21 #include "screen_utils.h"
  22 #include "config.h"
  23 #include "options.h"
  24 #include "strfsong.h"
  25 #include "utils.h"
  26
  27 #include <stdlib.h>
  28 #include <unistd.h>
  29 #include <time.h>
  30 #include <string.h>
  31
  32 #undef  ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_ADD /* broken with song id's */
  33 #define ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_DELETE
  34 #define ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_MOVE
  35 #define ENABLE_SONG_ID
  36 #define ENABLE_PLCHANGES
  37
  38 #define BUFSIZE 1024
  39
  40 static bool
  41 MPD_ERROR(const struct mpdclient *client)
  42 {
  43         return client->connection == NULL;
  44 }
  45
  46 /* filelist sorting functions */
  47 static gint
  48 compare_filelistentry(gconstpointer filelist_entry1,
  49                           gconstpointer filelist_entry2)
  50 {
  51         const mpd_InfoEntity *e1, *e2;
  52         int n = 0;
  53
  54         e1 = ((const filelist_entry_t *)filelist_entry1)->entity;
  55         e2 = ((const filelist_entry_t *)filelist_entry2)->entity;
  56
  57         if (e1 && e2 && e1->type == e2->type) {
  58                 switch (e1->type) {
  59                 case MPD_INFO_ENTITY_TYPE_DIRECTORY:
  60                         n = g_utf8_collate(e1->info.directory->path,
  61                                         e2->info.directory->path);
  62                         break;
  63                 case MPD_INFO_ENTITY_TYPE_SONG:
  64                         break;
  65                 case MPD_INFO_ENTITY_TYPE_PLAYLISTFILE:
  66                         n = g_utf8_collate(e1->info.playlistFile->path,
  67                                         e2->info.playlistFile->path);
  68                 }
  69         }
  70         return n;
  71 }
  72
  73 /* sort by list-format */
  74 gint
  75 compare_filelistentry_format(gconstpointer filelist_entry1,
  76                              gconstpointer filelist_entry2)
  77 {
  78         const mpd_InfoEntity *e1, *e2;
  79         char key1[BUFSIZE], key2[BUFSIZE];
  80         int n = 0;
  81
  82         e1 = ((const filelist_entry_t *)filelist_entry1)->entity;
  83         e2 = ((const filelist_entry_t *)filelist_entry2)->entity;
  84
  85         if (e1 && e2 &&
  86             e1->type == MPD_INFO_ENTITY_TYPE_SONG &&
  87             e2->type == MPD_INFO_ENTITY_TYPE_SONG) {
  88                 strfsong(key1, BUFSIZE, options.list_format, e1->info.song);
  89                 strfsong(key2, BUFSIZE, options.list_format, e2->info.song);
  90                 n = strcmp(key1,key2);
  91         }
  92
  93         return n;
  94 }
  95
  96
  97 /* Error callbacks */
  98 static gint
  99 error_cb(mpdclient_t *c, gint error, const gchar *msg)
 100 {
 101         GList *list = c->error_callbacks;
 102
 103         if (list == NULL)
 104                 fprintf(stderr, "error [%d]: %s\n", (error & 0xFF), msg);
 105
 106         while (list) {
 107                 mpdc_error_cb_t cb = list->data;
 108                 if (cb)
 109                         cb(c, error, msg);
 110                 list = list->next;
 111         }
 112
 113         mpd_clearError(c->connection);
 114         return error;
 115 }
 116
 117
 118 /****************************************************************************/
 119 /*** mpdclient functions ****************************************************/
 120 /****************************************************************************/
 121
 122 static gint
 123 mpdclient_handle_error(mpdclient_t *c)
 124 {
 125         enum mpd_error error = c->connection->error;
 126         bool is_fatal = error != MPD_ERROR_ACK;
 127
 128         if (error == MPD_ERROR_SUCCESS)
 129                 return 0;
 130
 131         if (error == MPD_ERROR_ACK &&
 132             c->connection->errorCode == MPD_ACK_ERROR_PERMISSION &&
 133             screen_auth(c) == 0)
 134                 return 0;
 135
 136         if (error == MPD_ERROR_ACK)
 137                 error = error | (c->connection->errorCode << 8);
 138
 139         error_cb(c, error, c->connection->errorStr);
 140
 141         if (is_fatal)
 142                 mpdclient_disconnect(c);
 143
 144         return error;
 145 }
 146
 147 gint
 148 mpdclient_finish_command(mpdclient_t *c)
 149 {
 150         mpd_finishCommand(c->connection);
 151         return mpdclient_handle_error(c);
 152 }
 153
 154 mpdclient_t *
 155 mpdclient_new(void)
 156 {
 157         mpdclient_t *c;
 158
 159         c = g_malloc0(sizeof(mpdclient_t));
 160         playlist_init(&c->playlist);
 161         c->volume = MPD_STATUS_NO_VOLUME;
 162
 163         return c;
 164 }
 165
 166 void
 167 mpdclient_free(mpdclient_t *c)
 168 {
 169         mpdclient_disconnect(c);
 170
 171         mpdclient_playlist_free(&c->playlist);
 172
 173         g_list_free(c->error_callbacks);
 174         g_list_free(c->playlist_callbacks);
 175         g_list_free(c->browse_callbacks);
 176         g_free(c);
 177 }
 178
 179 gint
 180 mpdclient_disconnect(mpdclient_t *c)
 181 {
 182         if (c->connection)
 183                 mpd_closeConnection(c->connection);
 184         c->connection = NULL;
 185
 186         if (c->status)
 187                 mpd_freeStatus(c->status);
 188         c->status = NULL;
 189
 190         playlist_clear(&c->playlist);
 191
 192         if (c->song)
 193                 c->song = NULL;
 194
 195         return 0;
 196 }
 197
 198 gint
 199 mpdclient_connect(mpdclient_t *c,
 200                   const gchar *host,
 201                   gint port,
 202                   gfloat _timeout,
 203                   const gchar *password)
 204 {
 205         gint retval = 0;
 206
 207         /* close any open connection */
 208         if( c->connection )
 209                 mpdclient_disconnect(c);
 210
 211         /* connect to MPD */
 212         c->connection = mpd_newConnection(host, port, _timeout);
 213         if (c->connection->error) {
 214                 retval = error_cb(c, c->connection->error,
 215                                   c->connection->errorStr);
 216                 if (retval != 0) {
 217                         mpd_closeConnection(c->connection);
 218                         c->connection = NULL;
 219                 }
 220
 221                 return retval;
 222         }
 223
 224         /* send password */
 225         if( password ) {
 226                 mpd_sendPasswordCommand(c->connection, password);
 227                 retval = mpdclient_finish_command(c);
 228         }
 229         c->need_update = TRUE;
 230
 231         return retval;
 232 }
 233
 234 gint
 235 mpdclient_update(mpdclient_t *c)
 236 {
 237         gint retval = 0;
 238
 239         c->volume = MPD_STATUS_NO_VOLUME;
 240
 241         if (MPD_ERROR(c))
 242                 return -1;
 243
 244         /* free the old status */
 245         if (c->status)
 246                 mpd_freeStatus(c->status);
 247
 248         /* retrieve new status */
 249         mpd_sendStatusCommand(c->connection);
 250         c->status = mpd_getStatus(c->connection);
 251         if ((retval=mpdclient_finish_command(c)))
 252                 return retval;
 253
 254         if (c->updatingdb && c->updatingdb != c->status->updatingDb)
 255                 mpdclient_browse_callback(c, BROWSE_DB_UPDATED, NULL);
 256
 257         c->updatingdb = c->status->updatingDb;
 258         c->volume = c->status->volume;
 259
 260         /* check if the playlist needs an update */
 261         if (c->playlist.id != c->status->playlist) {
 262                 if (playlist_is_empty(&c->playlist))
 263                         retval = mpdclient_playlist_update_changes(c);
 264                 else
 265                         retval = mpdclient_playlist_update(c);
 266         }
 267
 268         /* update the current song */
 269         if (!c->song || c->status->songid != c->song->id) {
 270                 c->song = playlist_get_song(c, c->status->song);
 271         }
 272
 273         c->need_update = FALSE;
 274
 275         return retval;
 276 }
 277
 278
 279 /****************************************************************************/
 280 /*** MPD Commands  **********************************************************/
 281 /****************************************************************************/
 282
 283 gint
 284 mpdclient_cmd_play(mpdclient_t *c, gint idx)
 285 {
 286 #ifdef ENABLE_SONG_ID
 287         struct mpd_song *song = playlist_get_song(c, idx);
 288
 289         if (MPD_ERROR(c))
 290                 return -1;
 291
 292         if (song)
 293                 mpd_sendPlayIdCommand(c->connection, song->id);
 294         else
 295                 mpd_sendPlayIdCommand(c->connection, MPD_PLAY_AT_BEGINNING);
 296 #else
 297         if (MPD_ERROR(c))
 298                 return -1;
 299
 300         mpd_sendPlayCommand(c->connection, idx);
 301 #endif
 302         c->need_update = TRUE;
 303         return mpdclient_finish_command(c);
 304 }
 305
 306 gint
 307 mpdclient_cmd_pause(mpdclient_t *c, gint value)
 308 {
 309         if (MPD_ERROR(c))
 310                 return -1;
 311
 312         mpd_sendPauseCommand(c->connection, value);
 313         return mpdclient_finish_command(c);
 314 }
 315
 316 gint
 317 mpdclient_cmd_crop(mpdclient_t *c)
 318 {
 319         gint error;
 320         mpd_Status *status;
 321         bool playing;
 322         int length, current;
 323
 324         if (MPD_ERROR(c))
 325                 return -1;
 326
 327         mpd_sendStatusCommand(c->connection);
 328         status = mpd_getStatus(c->connection);
 329         error = mpdclient_finish_command(c);
 330         if (error)
 331                 return error;
 332
 333         playing = status->state == MPD_STATUS_STATE_PLAY ||
 334                 status->state == MPD_STATUS_STATE_PAUSE;
 335         length = status->playlistLength;
 336         current = status->song;
 337
 338         mpd_freeStatus(status);
 339
 340         if (!playing || length < 2)
 341                 return 0;
 342
 343         mpd_sendCommandListBegin( c->connection );
 344
 345         while (--length >= 0)
 346                 if (length != current)
 347                         mpd_sendDeleteCommand(c->connection, length);
 348
 349         mpd_sendCommandListEnd(c->connection);
 350
 351         return mpdclient_finish_command(c);
 352 }
 353
 354 gint
 355 mpdclient_cmd_stop(mpdclient_t *c)
 356 {
 357         if (MPD_ERROR(c))
 358                 return -1;
 359
 360         mpd_sendStopCommand(c->connection);
 361         return mpdclient_finish_command(c);
 362 }
 363
 364 gint
 365 mpdclient_cmd_next(mpdclient_t *c)
 366 {
 367         if (MPD_ERROR(c))
 368                 return -1;
 369
 370         mpd_sendNextCommand(c->connection);
 371         c->need_update = TRUE;
 372         return mpdclient_finish_command(c);
 373 }
 374
 375 gint
 376 mpdclient_cmd_prev(mpdclient_t *c)
 377 {
 378         if (MPD_ERROR(c))
 379                 return -1;
 380
 381         mpd_sendPrevCommand(c->connection);
 382         c->need_update = TRUE;
 383         return mpdclient_finish_command(c);
 384 }
 385
 386 gint
 387 mpdclient_cmd_seek(mpdclient_t *c, gint id, gint pos)
 388 {
 389         if (MPD_ERROR(c))
 390                 return -1;
 391
 392         mpd_sendSeekIdCommand(c->connection, id, pos);
 393         return mpdclient_finish_command(c);
 394 }
 395
 396 gint
 397 mpdclient_cmd_shuffle(mpdclient_t *c)
 398 {
 399         if (MPD_ERROR(c))
 400                 return -1;
 401
 402         mpd_sendShuffleCommand(c->connection);
 403         c->need_update = TRUE;
 404         return mpdclient_finish_command(c);
 405 }
 406
 407 gint
 408 mpdclient_cmd_shuffle_range(mpdclient_t *c, guint start, guint end)
 409 {
 410         mpd_sendShuffleRangeCommand(c->connection, start, end);
 411         c->need_update = TRUE;
 412         return mpdclient_finish_command(c);
 413 }
 414
 415 gint
 416 mpdclient_cmd_clear(mpdclient_t *c)
 417 {
 418         gint retval = 0;
 419
 420         if (MPD_ERROR(c))
 421                 return -1;
 422
 423         mpd_sendClearCommand(c->connection);
 424         retval = mpdclient_finish_command(c);
 425         /* call playlist updated callback */
 426         mpdclient_playlist_callback(c, PLAYLIST_EVENT_CLEAR, NULL);
 427         c->need_update = TRUE;
 428         return retval;
 429 }
 430
 431 gint
 432 mpdclient_cmd_repeat(mpdclient_t *c, gint value)
 433 {
 434         if (MPD_ERROR(c))
 435                 return -1;
 436
 437         mpd_sendRepeatCommand(c->connection, value);
 438         return mpdclient_finish_command(c);
 439 }
 440
 441 gint
 442 mpdclient_cmd_random(mpdclient_t *c, gint value)
 443 {
 444         if (MPD_ERROR(c))
 445                 return -1;
 446
 447         mpd_sendRandomCommand(c->connection, value);
 448         return mpdclient_finish_command(c);
 449 }
 450
 451 gint
 452 mpdclient_cmd_single(mpdclient_t *c, gint value)
 453 {
 454         if (MPD_ERROR(c))
 455                 return -1;
 456
 457         mpd_sendSingleCommand(c->connection, value);
 458         return mpdclient_finish_command(c);
 459 }
 460
 461 gint
 462 mpdclient_cmd_consume(mpdclient_t *c, gint value)
 463 {
 464         if (MPD_ERROR(c))
 465                 return -1;
 466
 467         mpd_sendConsumeCommand(c->connection, value);
 468         return mpdclient_finish_command(c);
 469 }
 470
 471 gint
 472 mpdclient_cmd_crossfade(mpdclient_t *c, gint value)
 473 {
 474         if (MPD_ERROR(c))
 475                 return -1;
 476
 477         mpd_sendCrossfadeCommand(c->connection, value);
 478         return mpdclient_finish_command(c);
 479 }
 480
 481 gint
 482 mpdclient_cmd_db_update(mpdclient_t *c, const gchar *path)
 483 {
 484         gint ret;
 485
 486         if (MPD_ERROR(c))
 487                 return -1;
 488
 489         mpd_sendUpdateCommand(c->connection, path ? path : "");
 490         ret = mpdclient_finish_command(c);
 491
 492         if (ret == 0)
 493                 /* set updatingDb to make sure the browse callback
 494                    gets called even if the update has finished before
 495                    status is updated */
 496                 c->updatingdb = 1;
 497
 498         return ret;
 499 }
 500
 501 gint
 502 mpdclient_cmd_volume(mpdclient_t *c, gint value)
 503 {
 504         if (MPD_ERROR(c))
 505                 return -1;
 506
 507         mpd_sendSetvolCommand(c->connection, value);
 508         return mpdclient_finish_command(c);
 509 }
 510
 511 gint mpdclient_cmd_volume_up(struct mpdclient *c)
 512 {
 513         if (MPD_ERROR(c))
 514                 return -1;
 515
 516         if (c->status == NULL || c->status->volume == MPD_STATUS_NO_VOLUME)
 517                 return 0;
 518
 519         if (c->volume == MPD_STATUS_NO_VOLUME)
 520                 c->volume = c->status->volume;
 521
 522         if (c->volume >= 100)
 523                 return 0;
 524
 525         return mpdclient_cmd_volume(c, ++c->volume);
 526 }
 527
 528 gint mpdclient_cmd_volume_down(struct mpdclient *c)
 529 {
 530         if (MPD_ERROR(c))
 531                 return -1;
 532
 533         if (c->status == NULL || c->status->volume == MPD_STATUS_NO_VOLUME)
 534                 return 0;
 535
 536         if (c->volume == MPD_STATUS_NO_VOLUME)
 537                 c->volume = c->status->volume;
 538
 539         if (c->volume <= 0)
 540                 return 0;
 541
 542         return mpdclient_cmd_volume(c, --c->volume);
 543 }
 544
 545 gint
 546 mpdclient_cmd_add_path(mpdclient_t *c, const gchar *path_utf8)
 547 {
 548         if (MPD_ERROR(c))
 549                 return -1;
 550
 551         mpd_sendAddCommand(c->connection, path_utf8);
 552         return mpdclient_finish_command(c);
 553 }
 554
 555 gint
 556 mpdclient_cmd_add(mpdclient_t *c, const struct mpd_song *song)
 557 {
 558         gint retval = 0;
 559
 560         if (MPD_ERROR(c))
 561                 return -1;
 562
 563         if( !song || !song->file )
 564                 return -1;
 565
 566         /* send the add command to mpd */
 567         mpd_sendAddCommand(c->connection, song->file);
 568         if( (retval=mpdclient_finish_command(c)) )
 569                 return retval;
 570
 571 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_ADD
 572         /* add the song to playlist */
 573         playlist_append(&c->playlist, song);
 574
 575         /* increment the playlist id, so we don't retrieve a new playlist */
 576         c->playlist.id++;
 577
 578         /* call playlist updated callback */
 579         mpdclient_playlist_callback(c, PLAYLIST_EVENT_ADD, (gpointer) song);
 580 #else
 581         c->need_update = TRUE;
 582 #endif
 583
 584         return 0;
 585 }
 586
 587 gint
 588 mpdclient_cmd_delete(mpdclient_t *c, gint idx)
 589 {
 590         gint retval = 0;
 591         struct mpd_song *song;
 592
 593         if (MPD_ERROR(c))
 594                 return -1;
 595
 596         if (idx < 0 || (guint)idx >= playlist_length(&c->playlist))
 597                 return -1;
 598
 599         song = playlist_get(&c->playlist, idx);
 600
 601         /* send the delete command to mpd */
 602 #ifdef ENABLE_SONG_ID
 603         mpd_sendDeleteIdCommand(c->connection, song->id);
 604 #else
 605         mpd_sendDeleteCommand(c->connection, idx);
 606 #endif
 607         if( (retval=mpdclient_finish_command(c)) )
 608                 return retval;
 609
 610 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_DELETE
 611         /* increment the playlist id, so we don't retrieve a new playlist */
 612         c->playlist.id++;
 613
 614         /* remove the song from the playlist */
 615         playlist_remove_reuse(&c->playlist, idx);
 616
 617         /* call playlist updated callback */
 618         mpdclient_playlist_callback(c, PLAYLIST_EVENT_DELETE, (gpointer) song);
 619
 620         /* remove references to the song */
 621         if (c->song == song) {
 622                 c->song = NULL;
 623                 c->need_update = TRUE;
 624         }
 625
 626         mpd_freeSong(song);
 627
 628 #else
 629         c->need_update = TRUE;
 630 #endif
 631
 632         return 0;
 633 }
 634
 635 gint
 636 mpdclient_cmd_move(mpdclient_t *c, gint old_index, gint new_index)
 637 {
 638         gint n;
 639         struct mpd_song *song1, *song2;
 640
 641         if (MPD_ERROR(c))
 642                 return -1;
 643
 644         if (old_index == new_index || new_index < 0 ||
 645             (guint)new_index >= c->playlist.list->len)
 646                 return -1;
 647
 648         song1 = playlist_get(&c->playlist, old_index);
 649         song2 = playlist_get(&c->playlist, new_index);
 650
 651         /* send the move command to mpd */
 652 #ifdef ENABLE_SONG_ID
 653         mpd_sendSwapIdCommand(c->connection, song1->id, song2->id);
 654 #else
 655         mpd_sendMoveCommand(c->connection, old_index, new_index);
 656 #endif
 657         if( (n=mpdclient_finish_command(c)) )
 658                 return n;
 659
 660 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_MOVE
 661         /* update the playlist */
 662         playlist_swap(&c->playlist, old_index, new_index);
 663
 664         /* increment the playlist id, so we don't retrieve a new playlist */
 665         c->playlist.id++;
 666
 667 #else
 668         c->need_update = TRUE;
 669 #endif
 670
 671         /* call playlist updated callback */
 672         mpdclient_playlist_callback(c, PLAYLIST_EVENT_MOVE, (gpointer) &new_index);
 673
 674         return 0;
 675 }
 676
 677 gint
 678 mpdclient_cmd_save_playlist(mpdclient_t *c, const gchar *filename_utf8)
 679 {
 680         gint retval = 0;
 681
 682         if (MPD_ERROR(c))
 683                 return -1;
 684
 685         mpd_sendSaveCommand(c->connection, filename_utf8);
 686         if ((retval = mpdclient_finish_command(c)) == 0)
 687                 mpdclient_browse_callback(c, BROWSE_PLAYLIST_SAVED, NULL);
 688         return retval;
 689 }
 690
 691 gint
 692 mpdclient_cmd_load_playlist(mpdclient_t *c, const gchar *filename_utf8)
 693 {
 694         if (MPD_ERROR(c))
 695                 return -1;
 696
 697         mpd_sendLoadCommand(c->connection, filename_utf8);
 698         c->need_update = TRUE;
 699         return mpdclient_finish_command(c);
 700 }
 701
 702 gint
 703 mpdclient_cmd_delete_playlist(mpdclient_t *c, const gchar *filename_utf8)
 704 {
 705         gint retval = 0;
 706
 707         if (MPD_ERROR(c))
 708                 return -1;
 709
 710         mpd_sendRmCommand(c->connection, filename_utf8);
 711         if ((retval = mpdclient_finish_command(c)) == 0)
 712                 mpdclient_browse_callback(c, BROWSE_PLAYLIST_DELETED, NULL);
 713         return retval;
 714 }
 715
 716
 717 /****************************************************************************/
 718 /*** Callback management functions ******************************************/
 719 /****************************************************************************/
 720
 721 static void
 722 do_list_callbacks(mpdclient_t *c, GList *list, gint event, gpointer data)
 723 {
 724         while (list) {
 725                 mpdc_list_cb_t fn = list->data;
 726
 727                 fn(c, event, data);
 728                 list = list->next;
 729         }
 730 }
 731
 732 void
 733 mpdclient_playlist_callback(mpdclient_t *c, int event, gpointer data)
 734 {
 735         do_list_callbacks(c, c->playlist_callbacks, event, data);
 736 }
 737
 738 void
 739 mpdclient_install_playlist_callback(mpdclient_t *c,mpdc_list_cb_t cb)
 740 {
 741         c->playlist_callbacks = g_list_append(c->playlist_callbacks, cb);
 742 }
 743
 744 void
 745 mpdclient_remove_playlist_callback(mpdclient_t *c, mpdc_list_cb_t cb)
 746 {
 747         c->playlist_callbacks = g_list_remove(c->playlist_callbacks, cb);
 748 }
 749
 750 void
 751 mpdclient_browse_callback(mpdclient_t *c, int event, gpointer data)
 752 {
 753         do_list_callbacks(c, c->browse_callbacks, event, data);
 754 }
 755
 756
 757 void
 758 mpdclient_install_browse_callback(mpdclient_t *c,mpdc_list_cb_t cb)
 759 {
 760         c->browse_callbacks = g_list_append(c->browse_callbacks, cb);
 761 }
 762
 763 void
 764 mpdclient_remove_browse_callback(mpdclient_t *c, mpdc_list_cb_t cb)
 765 {
 766         c->browse_callbacks = g_list_remove(c->browse_callbacks, cb);
 767 }
 768
 769 void
 770 mpdclient_install_error_callback(mpdclient_t *c, mpdc_error_cb_t cb)
 771 {
 772         c->error_callbacks = g_list_append(c->error_callbacks, cb);
 773 }
 774
 775 void
 776 mpdclient_remove_error_callback(mpdclient_t *c, mpdc_error_cb_t cb)
 777 {
 778         c->error_callbacks = g_list_remove(c->error_callbacks, cb);
 779 }
 780
 781
 782 /****************************************************************************/
 783 /*** Playlist management functions ******************************************/
 784 /****************************************************************************/
 785
 786 /* update playlist */
 787 gint
 788 mpdclient_playlist_update(mpdclient_t *c)
 789 {
 790         mpd_InfoEntity *entity;
 791
 792         if (MPD_ERROR(c))
 793                 return -1;
 794
 795         playlist_clear(&c->playlist);
 796
 797         mpd_sendPlaylistInfoCommand(c->connection,-1);
 798         while ((entity = mpd_getNextInfoEntity(c->connection))) {
 799                 if (entity->type == MPD_INFO_ENTITY_TYPE_SONG)
 800                         playlist_append(&c->playlist, entity->info.song);
 801
 802                 mpd_freeInfoEntity(entity);
 803         }
 804
 805         c->playlist.id = c->status->playlist;
 806         c->song = NULL;
 807
 808         /* call playlist updated callbacks */
 809         mpdclient_playlist_callback(c, PLAYLIST_EVENT_UPDATED, NULL);
 810
 811         return mpdclient_finish_command(c);
 812 }
 813
 814 #ifdef ENABLE_PLCHANGES
 815
 816 /* update playlist (plchanges) */
 817 gint
 818 mpdclient_playlist_update_changes(mpdclient_t *c)
 819 {
 820         mpd_InfoEntity *entity;
 821
 822         if (MPD_ERROR(c))
 823                 return -1;
 824
 825         mpd_sendPlChangesCommand(c->connection, c->playlist.id);
 826
 827         while ((entity = mpd_getNextInfoEntity(c->connection)) != NULL) {
 828                 struct mpd_song *song = entity->info.song;
 829
 830                 if (song->pos >= 0 && (guint)song->pos < c->playlist.list->len) {
 831                         /* update song */
 832                         playlist_replace(&c->playlist, song->pos, song);
 833                 } else {
 834                         /* add a new song */
 835                         playlist_append(&c->playlist, song);
 836                 }
 837
 838                 mpd_freeInfoEntity(entity);
 839         }
 840
 841         /* remove trailing songs */
 842         while ((guint)c->status->playlistLength < c->playlist.list->len) {
 843                 guint pos = c->playlist.list->len - 1;
 844
 845                 /* Remove the last playlist entry */
 846                 playlist_remove(&c->playlist, pos);
 847         }
 848
 849         c->song = NULL;
 850         c->playlist.id = c->status->playlist;
 851
 852         mpdclient_playlist_callback(c, PLAYLIST_EVENT_UPDATED, NULL);
 853
 854         return 0;
 855 }
 856
 857 #else
 858 gint
 859 mpdclient_playlist_update_changes(mpdclient_t *c)
 860 {
 861         return mpdclient_playlist_update(c);
 862 }
 863 #endif
 864
 865
 866 /****************************************************************************/
 867 /*** Filelist functions *****************************************************/
 868 /****************************************************************************/
 869
 870 mpdclient_filelist_t *
 871 mpdclient_filelist_get(mpdclient_t *c, const gchar *path)
 872 {
 873         mpdclient_filelist_t *filelist;
 874         mpd_InfoEntity *entity;
 875
 876         if (MPD_ERROR(c))
 877                 return NULL;
 878
 879         mpd_sendLsInfoCommand(c->connection, path);
 880         filelist = filelist_new();
 881         if (path && path[0] && strcmp(path, "/"))
 882                 /* add a dummy entry for ./.. */
 883                 filelist_append(filelist, NULL);
 884
 885         while ((entity=mpd_getNextInfoEntity(c->connection))) {
 886                 filelist_append(filelist, entity);
 887         }
 888
 889         /* If there's an error, ignore it.  We'll return an empty filelist. */
 890         mpdclient_finish_command(c);
 891
 892         filelist_sort_dir_play(filelist, compare_filelistentry);
 893
 894         return filelist;
 895 }
 896
 897 mpdclient_filelist_t *
 898 mpdclient_filelist_search(mpdclient_t *c,
 899                           int exact_match,
 900                           int table,
 901                           gchar *filter_utf8)
 902 {
 903         mpdclient_filelist_t *filelist;
 904         mpd_InfoEntity *entity;
 905
 906         if (MPD_ERROR(c))
 907                 return NULL;
 908
 909         if (exact_match)
 910                 mpd_sendFindCommand(c->connection, table, filter_utf8);
 911         else
 912                 mpd_sendSearchCommand(c->connection, table, filter_utf8);
 913         filelist = filelist_new();
 914
 915         while ((entity=mpd_getNextInfoEntity(c->connection)))
 916                 filelist_append(filelist, entity);
 917
 918         if (mpdclient_finish_command(c)) {
 919                 filelist_free(filelist);
 920                 return NULL;
 921         }
 922
 923         return filelist;
 924 }
 925
 926 int
 927 mpdclient_filelist_add_all(mpdclient_t *c, mpdclient_filelist_t *fl)
 928 {
 929         guint i;
 930
 931         if (MPD_ERROR(c))
 932                 return -1;
 933
 934         if (filelist_is_empty(fl))
 935                 return 0;
 936
 937         mpd_sendCommandListBegin(c->connection);
 938
 939         for (i = 0; i < filelist_length(fl); ++i) {
 940                 filelist_entry_t *entry = filelist_get(fl, i);
 941                 mpd_InfoEntity *entity  = entry->entity;
 942
 943                 if (entity && entity->type == MPD_INFO_ENTITY_TYPE_SONG) {
 944                         struct mpd_song *song = entity->info.song;
 945
 946                         mpd_sendAddCommand(c->connection, song->file);
 947                 }
 948         }
 949
 950         mpd_sendCommandListEnd(c->connection);
 951         return mpdclient_finish_command(c);
 952 }
 953
 954 GList *
 955 mpdclient_get_artists(mpdclient_t *c)
 956 {
 957         gchar *str = NULL;
 958         GList *list = NULL;
 959
 960         if (MPD_ERROR(c))
 961                return NULL;
 962
 963         mpd_sendListCommand(c->connection, MPD_TABLE_ARTIST, NULL);
 964         while ((str = mpd_getNextArtist(c->connection)))
 965                 list = g_list_append(list, (gpointer) str);
 966
 967         if (mpdclient_finish_command(c))
 968                 return string_list_free(list);
 969
 970         return list;
 971 }
 972
 973 GList *
 974 mpdclient_get_albums(mpdclient_t *c, const gchar *artist_utf8)
 975 {
 976         gchar *str = NULL;
 977         GList *list = NULL;
 978
 979         if (MPD_ERROR(c))
 980                return NULL;
 981
 982         mpd_sendListCommand(c->connection, MPD_TABLE_ALBUM, artist_utf8);
 983         while ((str = mpd_getNextAlbum(c->connection)))
 984                 list = g_list_append(list, (gpointer) str);
 985
 986         if (mpdclient_finish_command(c))
 987                 return string_list_free(list);
 988
 989         return list;
 990 }