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 "filelist.h"
  22 #include "screen_client.h"
  23 #include "config.h"
  24 #include "options.h"
  25 #include "strfsong.h"
  26 #include "utils.h"
  27
  28 #include <mpd/client.h>
  29
  30 #include <stdlib.h>
  31 #include <unistd.h>
  32 #include <time.h>
  33 #include <string.h>
  34
  35 #undef  ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_ADD /* broken with song id's */
  36 #define ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_DELETE
  37 #define ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_MOVE
  38
  39 #define BUFSIZE 1024
  40
  41 static bool
  42 MPD_ERROR(const struct mpdclient *client)
  43 {
  44         return client->connection == NULL ||
  45                 mpd_connection_get_error(client->connection) != MPD_ERROR_SUCCESS;
  46 }
  47
  48 /* filelist sorting functions */
  49 static gint
  50 compare_filelistentry(gconstpointer filelist_entry1,
  51                           gconstpointer filelist_entry2)
  52 {
  53         const struct mpd_entity *e1, *e2;
  54         int n = 0;
  55
  56         e1 = ((const struct filelist_entry *)filelist_entry1)->entity;
  57         e2 = ((const struct filelist_entry *)filelist_entry2)->entity;
  58
  59         if (e1 != NULL && e2 != NULL &&
  60             mpd_entity_get_type(e1) == mpd_entity_get_type(e2)) {
  61                 switch (mpd_entity_get_type(e1)) {
  62                 case MPD_ENTITY_TYPE_UNKNOWN:
  63                         break;
  64                 case MPD_ENTITY_TYPE_DIRECTORY:
  65                         n = g_utf8_collate(mpd_directory_get_path(mpd_entity_get_directory(e1)),
  66                                            mpd_directory_get_path(mpd_entity_get_directory(e2)));
  67                         break;
  68                 case MPD_ENTITY_TYPE_SONG:
  69                         break;
  70                 case MPD_ENTITY_TYPE_PLAYLIST:
  71                         n = g_utf8_collate(mpd_playlist_get_path(mpd_entity_get_playlist(e1)),
  72                                            mpd_playlist_get_path(mpd_entity_get_playlist(e2)));
  73                 }
  74         }
  75         return n;
  76 }
  77
  78 /* sort by list-format */
  79 gint
  80 compare_filelistentry_format(gconstpointer filelist_entry1,
  81                              gconstpointer filelist_entry2)
  82 {
  83         const struct mpd_entity *e1, *e2;
  84         char key1[BUFSIZE], key2[BUFSIZE];
  85         int n = 0;
  86
  87         e1 = ((const struct filelist_entry *)filelist_entry1)->entity;
  88         e2 = ((const struct filelist_entry *)filelist_entry2)->entity;
  89
  90         if (e1 && e2 &&
  91             mpd_entity_get_type(e1) == MPD_ENTITY_TYPE_SONG &&
  92             mpd_entity_get_type(e2) == MPD_ENTITY_TYPE_SONG) {
  93                 strfsong(key1, BUFSIZE, options.list_format, mpd_entity_get_song(e1));
  94                 strfsong(key2, BUFSIZE, options.list_format, mpd_entity_get_song(e2));
  95                 n = strcmp(key1,key2);
  96         }
  97
  98         return n;
  99 }
 100
 101
 102 /****************************************************************************/
 103 /*** mpdclient functions ****************************************************/
 104 /****************************************************************************/
 105
 106 gint
 107 mpdclient_handle_error(struct mpdclient *c)
 108 {
 109         enum mpd_error error = mpd_connection_get_error(c->connection);
 110
 111         assert(error != MPD_ERROR_SUCCESS);
 112
 113         if (error == MPD_ERROR_SERVER &&
 114             mpd_connection_get_server_error(c->connection) == MPD_SERVER_ERROR_PERMISSION &&
 115             screen_auth(c))
 116                 return 0;
 117
 118         if (error == MPD_ERROR_SERVER)
 119                 error = error | (mpd_connection_get_server_error(c->connection) << 8);
 120
 121         for (GList *list = c->error_callbacks; list != NULL;
 122              list = list->next) {
 123                 mpdc_error_cb_t cb = list->data;
 124                 cb(c, error, mpd_connection_get_error_message(c->connection));
 125         }
 126
 127         if (!mpd_connection_clear_error(c->connection))
 128                 mpdclient_disconnect(c);
 129
 130         return error;
 131 }
 132
 133 static gint
 134 mpdclient_finish_command(struct mpdclient *c)
 135 {
 136         return mpd_response_finish(c->connection)
 137                 ? 0 : mpdclient_handle_error(c);
 138 }
 139
 140 struct mpdclient *
 141 mpdclient_new(void)
 142 {
 143         struct mpdclient *c;
 144
 145         c = g_new0(struct mpdclient, 1);
 146         playlist_init(&c->playlist);
 147         c->volume = -1;
 148
 149         return c;
 150 }
 151
 152 void
 153 mpdclient_free(struct mpdclient *c)
 154 {
 155         mpdclient_disconnect(c);
 156
 157         mpdclient_playlist_free(&c->playlist);
 158
 159         g_list_free(c->error_callbacks);
 160         g_list_free(c->playlist_callbacks);
 161         g_list_free(c->browse_callbacks);
 162         g_free(c);
 163 }
 164
 165 void
 166 mpdclient_disconnect(struct mpdclient *c)
 167 {
 168         if (c->connection)
 169                 mpd_connection_free(c->connection);
 170         c->connection = NULL;
 171
 172         if (c->status)
 173                 mpd_status_free(c->status);
 174         c->status = NULL;
 175
 176         playlist_clear(&c->playlist);
 177
 178         if (c->song)
 179                 c->song = NULL;
 180 }
 181
 182 bool
 183 mpdclient_connect(struct mpdclient *c,
 184                   const gchar *host,
 185                   gint port,
 186                   gfloat _timeout,
 187                   const gchar *password)
 188 {
 189         /* close any open connection */
 190         if( c->connection )
 191                 mpdclient_disconnect(c);
 192
 193         /* connect to MPD */
 194         c->connection = mpd_connection_new(host, port, _timeout * 1000);
 195         if (c->connection == NULL)
 196                 g_error("Out of memory");
 197
 198         if (mpd_connection_get_error(c->connection) != MPD_ERROR_SUCCESS) {
 199                 mpdclient_handle_error(c);
 200                 mpdclient_disconnect(c);
 201                 return false;
 202         }
 203
 204         /* send password */
 205         if (password != NULL && !mpd_run_password(c->connection, password)) {
 206                 mpdclient_handle_error(c);
 207                 mpdclient_disconnect(c);
 208                 return false;
 209         }
 210
 211         return true;
 212 }
 213
 214 bool
 215 mpdclient_update(struct mpdclient *c)
 216 {
 217         bool retval;
 218
 219         c->volume = -1;
 220
 221         if (MPD_ERROR(c))
 222                 return false;
 223
 224         /* free the old status */
 225         if (c->status)
 226                 mpd_status_free(c->status);
 227
 228         /* retrieve new status */
 229         c->status = mpd_run_status(c->connection);
 230         if (c->status == NULL)
 231                 return mpdclient_handle_error(c) == 0;
 232
 233         if (c->updatingdb &&
 234             c->updatingdb != mpd_status_get_update_id(c->status))
 235                 mpdclient_browse_callback(c, BROWSE_DB_UPDATED, NULL);
 236
 237         c->updatingdb = mpd_status_get_update_id(c->status);
 238         c->volume = mpd_status_get_volume(c->status);
 239
 240         /* check if the playlist needs an update */
 241         if (c->playlist.id != mpd_status_get_queue_version(c->status)) {
 242                 if (!playlist_is_empty(&c->playlist))
 243                         retval = mpdclient_playlist_update_changes(c);
 244                 else
 245                         retval = mpdclient_playlist_update(c);
 246         }
 247
 248         /* update the current song */
 249         if (!c->song || mpd_status_get_song_id(c->status)) {
 250                 c->song = playlist_get_song(&c->playlist,
 251                                             mpd_status_get_song_pos(c->status));
 252         }
 253
 254         return retval;
 255 }
 256
 257
 258 /****************************************************************************/
 259 /*** MPD Commands  **********************************************************/
 260 /****************************************************************************/
 261
 262 gint
 263 mpdclient_cmd_play(struct mpdclient *c, gint idx)
 264 {
 265         const struct mpd_song *song = playlist_get_song(&c->playlist, idx);
 266
 267         if (MPD_ERROR(c))
 268                 return -1;
 269
 270         if (song)
 271                 mpd_send_play_id(c->connection, mpd_song_get_id(song));
 272         else
 273                 mpd_send_play(c->connection);
 274
 275         return mpdclient_finish_command(c);
 276 }
 277
 278 gint
 279 mpdclient_cmd_pause(struct mpdclient *c, gint value)
 280 {
 281         if (MPD_ERROR(c))
 282                 return -1;
 283
 284         mpd_send_pause(c->connection, value);
 285         return mpdclient_finish_command(c);
 286 }
 287
 288 gint
 289 mpdclient_cmd_crop(struct mpdclient *c)
 290 {
 291         struct mpd_status *status;
 292         bool playing;
 293         int length, current;
 294
 295         if (MPD_ERROR(c))
 296                 return -1;
 297
 298         status = mpd_run_status(c->connection);
 299         if (status == NULL)
 300                 return mpdclient_handle_error(c);
 301
 302         playing = mpd_status_get_state(status) == MPD_STATE_PLAY ||
 303                 mpd_status_get_state(status) == MPD_STATE_PAUSE;
 304         length = mpd_status_get_queue_length(status);
 305         current = mpd_status_get_song_pos(status);
 306
 307         mpd_status_free(status);
 308
 309         if (!playing || length < 2)
 310                 return 0;
 311
 312         mpd_command_list_begin(c->connection, false);
 313
 314         while (--length >= 0)
 315                 if (length != current)
 316                         mpd_send_delete(c->connection, length);
 317
 318         mpd_command_list_end(c->connection);
 319
 320         return mpdclient_finish_command(c);
 321 }
 322
 323 gint
 324 mpdclient_cmd_stop(struct mpdclient *c)
 325 {
 326         if (MPD_ERROR(c))
 327                 return -1;
 328
 329         mpd_send_stop(c->connection);
 330         return mpdclient_finish_command(c);
 331 }
 332
 333 gint
 334 mpdclient_cmd_next(struct mpdclient *c)
 335 {
 336         if (MPD_ERROR(c))
 337                 return -1;
 338
 339         mpd_send_next(c->connection);
 340         return mpdclient_finish_command(c);
 341 }
 342
 343 gint
 344 mpdclient_cmd_prev(struct mpdclient *c)
 345 {
 346         if (MPD_ERROR(c))
 347                 return -1;
 348
 349         mpd_send_previous(c->connection);
 350         return mpdclient_finish_command(c);
 351 }
 352
 353 gint
 354 mpdclient_cmd_seek(struct mpdclient *c, gint id, gint pos)
 355 {
 356         if (MPD_ERROR(c))
 357                 return -1;
 358
 359         mpd_send_seek_id(c->connection, id, pos);
 360         return mpdclient_finish_command(c);
 361 }
 362
 363 gint
 364 mpdclient_cmd_shuffle(struct mpdclient *c)
 365 {
 366         if (MPD_ERROR(c))
 367                 return -1;
 368
 369         mpd_send_shuffle(c->connection);
 370         return mpdclient_finish_command(c);
 371 }
 372
 373 gint
 374 mpdclient_cmd_shuffle_range(struct mpdclient *c, guint start, guint end)
 375 {
 376         mpd_send_shuffle_range(c->connection, start, end);
 377         return mpdclient_finish_command(c);
 378 }
 379
 380 gint
 381 mpdclient_cmd_clear(struct mpdclient *c)
 382 {
 383         gint retval = 0;
 384
 385         if (MPD_ERROR(c))
 386                 return -1;
 387
 388         mpd_send_clear(c->connection);
 389         retval = mpdclient_finish_command(c);
 390         /* call playlist updated callback */
 391         mpdclient_playlist_callback(c, PLAYLIST_EVENT_CLEAR, NULL);
 392         return retval;
 393 }
 394
 395 gint
 396 mpdclient_cmd_repeat(struct mpdclient *c, gint value)
 397 {
 398         if (MPD_ERROR(c))
 399                 return -1;
 400
 401         mpd_send_repeat(c->connection, value);
 402         return mpdclient_finish_command(c);
 403 }
 404
 405 gint
 406 mpdclient_cmd_random(struct mpdclient *c, gint value)
 407 {
 408         if (MPD_ERROR(c))
 409                 return -1;
 410
 411         mpd_send_random(c->connection, value);
 412         return mpdclient_finish_command(c);
 413 }
 414
 415 gint
 416 mpdclient_cmd_single(struct mpdclient *c, gint value)
 417 {
 418         if (MPD_ERROR(c))
 419                 return -1;
 420
 421         mpd_send_single(c->connection, value);
 422         return mpdclient_finish_command(c);
 423 }
 424
 425 gint
 426 mpdclient_cmd_consume(struct mpdclient *c, gint value)
 427 {
 428         if (MPD_ERROR(c))
 429                 return -1;
 430
 431         mpd_send_consume(c->connection, value);
 432         return mpdclient_finish_command(c);
 433 }
 434
 435 gint
 436 mpdclient_cmd_crossfade(struct mpdclient *c, gint value)
 437 {
 438         if (MPD_ERROR(c))
 439                 return -1;
 440
 441         mpd_send_crossfade(c->connection, value);
 442         return mpdclient_finish_command(c);
 443 }
 444
 445 gint
 446 mpdclient_cmd_volume(struct mpdclient *c, gint value)
 447 {
 448         if (MPD_ERROR(c))
 449                 return -1;
 450
 451         mpd_send_set_volume(c->connection, value);
 452         return mpdclient_finish_command(c);
 453 }
 454
 455 gint mpdclient_cmd_volume_up(struct mpdclient *c)
 456 {
 457         if (MPD_ERROR(c))
 458                 return -1;
 459
 460         if (c->status == NULL ||
 461             mpd_status_get_volume(c->status) == -1)
 462                 return 0;
 463
 464         if (c->volume < 0)
 465                 c->volume = mpd_status_get_volume(c->status);
 466
 467         if (c->volume >= 100)
 468                 return 0;
 469
 470         return mpdclient_cmd_volume(c, ++c->volume);
 471 }
 472
 473 gint mpdclient_cmd_volume_down(struct mpdclient *c)
 474 {
 475         if (MPD_ERROR(c))
 476                 return -1;
 477
 478         if (c->status == NULL || mpd_status_get_volume(c->status) < 0)
 479                 return 0;
 480
 481         if (c->volume < 0)
 482                 c->volume = mpd_status_get_volume(c->status);
 483
 484         if (c->volume <= 0)
 485                 return 0;
 486
 487         return mpdclient_cmd_volume(c, --c->volume);
 488 }
 489
 490 gint
 491 mpdclient_cmd_add_path(struct mpdclient *c, const gchar *path_utf8)
 492 {
 493         if (MPD_ERROR(c))
 494                 return -1;
 495
 496         mpd_send_add(c->connection, path_utf8);
 497         return mpdclient_finish_command(c);
 498 }
 499
 500 gint
 501 mpdclient_cmd_add(struct mpdclient *c, const struct mpd_song *song)
 502 {
 503         gint retval = 0;
 504
 505         if (MPD_ERROR(c))
 506                 return -1;
 507
 508         if (song == NULL)
 509                 return -1;
 510
 511         /* send the add command to mpd */
 512         mpd_send_add(c->connection, mpd_song_get_uri(song));
 513         if( (retval=mpdclient_finish_command(c)) )
 514                 return retval;
 515
 516 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_ADD
 517         /* add the song to playlist */
 518         playlist_append(&c->playlist, song);
 519
 520         /* increment the playlist id, so we don't retrieve a new playlist */
 521         c->playlist.id++;
 522
 523         /* call playlist updated callback */
 524         mpdclient_playlist_callback(c, PLAYLIST_EVENT_ADD, (gpointer) song);
 525 #endif
 526
 527         return 0;
 528 }
 529
 530 gint
 531 mpdclient_cmd_delete(struct mpdclient *c, gint idx)
 532 {
 533         gint retval = 0;
 534         struct mpd_song *song;
 535
 536         if (MPD_ERROR(c))
 537                 return -1;
 538
 539         if (idx < 0 || (guint)idx >= playlist_length(&c->playlist))
 540                 return -1;
 541
 542         song = playlist_get(&c->playlist, idx);
 543
 544         /* send the delete command to mpd */
 545         mpd_send_delete_id(c->connection, mpd_song_get_id(song));
 546         if( (retval=mpdclient_finish_command(c)) )
 547                 return retval;
 548
 549 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_DELETE
 550         /* increment the playlist id, so we don't retrieve a new playlist */
 551         c->playlist.id++;
 552
 553         /* remove the song from the playlist */
 554         playlist_remove_reuse(&c->playlist, idx);
 555
 556         /* call playlist updated callback */
 557         mpdclient_playlist_callback(c, PLAYLIST_EVENT_DELETE, (gpointer) song);
 558
 559         /* remove references to the song */
 560         if (c->song == song)
 561                 c->song = NULL;
 562
 563         mpd_song_free(song);
 564 #endif
 565
 566         return 0;
 567 }
 568
 569 gint
 570 mpdclient_cmd_move(struct mpdclient *c, gint old_index, gint new_index)
 571 {
 572         gint n;
 573         struct mpd_song *song1, *song2;
 574
 575         if (MPD_ERROR(c))
 576                 return -1;
 577
 578         if (old_index == new_index || new_index < 0 ||
 579             (guint)new_index >= c->playlist.list->len)
 580                 return -1;
 581
 582         song1 = playlist_get(&c->playlist, old_index);
 583         song2 = playlist_get(&c->playlist, new_index);
 584
 585         /* send the move command to mpd */
 586         mpd_send_swap_id(c->connection,
 587                          mpd_song_get_id(song1), mpd_song_get_id(song2));
 588         if( (n=mpdclient_finish_command(c)) )
 589                 return n;
 590
 591 #ifdef ENABLE_FANCY_PLAYLIST_MANAGMENT_CMD_MOVE
 592         /* update the playlist */
 593         playlist_swap(&c->playlist, old_index, new_index);
 594
 595         /* increment the playlist id, so we don't retrieve a new playlist */
 596         c->playlist.id++;
 597 #endif
 598
 599         /* call playlist updated callback */
 600         mpdclient_playlist_callback(c, PLAYLIST_EVENT_MOVE, (gpointer) &new_index);
 601
 602         return 0;
 603 }
 604
 605 gint
 606 mpdclient_cmd_save_playlist(struct mpdclient *c, const gchar *filename_utf8)
 607 {
 608         gint retval = 0;
 609
 610         if (MPD_ERROR(c))
 611                 return -1;
 612
 613         mpd_send_save(c->connection, filename_utf8);
 614         if ((retval = mpdclient_finish_command(c)) == 0)
 615                 mpdclient_browse_callback(c, BROWSE_PLAYLIST_SAVED, NULL);
 616         return retval;
 617 }
 618
 619 gint
 620 mpdclient_cmd_load_playlist(struct mpdclient *c, const gchar *filename_utf8)
 621 {
 622         if (MPD_ERROR(c))
 623                 return -1;
 624
 625         mpd_send_load(c->connection, filename_utf8);
 626         return mpdclient_finish_command(c);
 627 }
 628
 629 gint
 630 mpdclient_cmd_delete_playlist(struct mpdclient *c, const gchar *filename_utf8)
 631 {
 632         gint retval = 0;
 633
 634         if (MPD_ERROR(c))
 635                 return -1;
 636
 637         mpd_send_rm(c->connection, filename_utf8);
 638         if ((retval = mpdclient_finish_command(c)) == 0)
 639                 mpdclient_browse_callback(c, BROWSE_PLAYLIST_DELETED, NULL);
 640         return retval;
 641 }
 642
 643
 644 /****************************************************************************/
 645 /*** Callback management functions ******************************************/
 646 /****************************************************************************/
 647
 648 static void
 649 do_list_callbacks(struct mpdclient *c, GList *list, gint event, gpointer data)
 650 {
 651         while (list) {
 652                 mpdc_list_cb_t fn = list->data;
 653
 654                 fn(c, event, data);
 655                 list = list->next;
 656         }
 657 }
 658
 659 void
 660 mpdclient_playlist_callback(struct mpdclient *c, int event, gpointer data)
 661 {
 662         do_list_callbacks(c, c->playlist_callbacks, event, data);
 663 }
 664
 665 void
 666 mpdclient_install_playlist_callback(struct mpdclient *c,mpdc_list_cb_t cb)
 667 {
 668         c->playlist_callbacks = g_list_append(c->playlist_callbacks, cb);
 669 }
 670
 671 void
 672 mpdclient_remove_playlist_callback(struct mpdclient *c, mpdc_list_cb_t cb)
 673 {
 674         c->playlist_callbacks = g_list_remove(c->playlist_callbacks, cb);
 675 }
 676
 677 void
 678 mpdclient_browse_callback(struct mpdclient *c, int event, gpointer data)
 679 {
 680         do_list_callbacks(c, c->browse_callbacks, event, data);
 681 }
 682
 683
 684 void
 685 mpdclient_install_browse_callback(struct mpdclient *c,mpdc_list_cb_t cb)
 686 {
 687         c->browse_callbacks = g_list_append(c->browse_callbacks, cb);
 688 }
 689
 690 void
 691 mpdclient_remove_browse_callback(struct mpdclient *c, mpdc_list_cb_t cb)
 692 {
 693         c->browse_callbacks = g_list_remove(c->browse_callbacks, cb);
 694 }
 695
 696 void
 697 mpdclient_install_error_callback(struct mpdclient *c, mpdc_error_cb_t cb)
 698 {
 699         c->error_callbacks = g_list_append(c->error_callbacks, cb);
 700 }
 701
 702 void
 703 mpdclient_remove_error_callback(struct mpdclient *c, mpdc_error_cb_t cb)
 704 {
 705         c->error_callbacks = g_list_remove(c->error_callbacks, cb);
 706 }
 707
 708
 709 /****************************************************************************/
 710 /*** Playlist management functions ******************************************/
 711 /****************************************************************************/
 712
 713 /* update playlist */
 714 bool
 715 mpdclient_playlist_update(struct mpdclient *c)
 716 {
 717         struct mpd_entity *entity;
 718
 719         if (MPD_ERROR(c))
 720                 return false;
 721
 722         playlist_clear(&c->playlist);
 723
 724         mpd_send_list_queue_meta(c->connection);
 725         while ((entity = mpd_recv_entity(c->connection))) {
 726                 if (mpd_entity_get_type(entity) == MPD_ENTITY_TYPE_SONG)
 727                         playlist_append(&c->playlist, mpd_entity_get_song(entity));
 728
 729                 mpd_entity_free(entity);
 730         }
 731
 732         c->playlist.id = mpd_status_get_queue_version(c->status);
 733         c->song = NULL;
 734
 735         /* call playlist updated callbacks */
 736         mpdclient_playlist_callback(c, PLAYLIST_EVENT_UPDATED, NULL);
 737
 738         return mpdclient_finish_command(c) == 0;
 739 }
 740
 741 /* update playlist (plchanges) */
 742 bool
 743 mpdclient_playlist_update_changes(struct mpdclient *c)
 744 {
 745         struct mpd_song *song;
 746         guint length;
 747
 748         if (MPD_ERROR(c))
 749                 return false;
 750
 751         mpd_send_queue_changes_meta(c->connection, c->playlist.id);
 752
 753         while ((song = mpd_recv_song(c->connection)) != NULL) {
 754                 int pos = mpd_song_get_pos(song);
 755
 756                 if (pos >= 0 && (guint)pos < c->playlist.list->len) {
 757                         /* update song */
 758                         playlist_replace(&c->playlist, pos, song);
 759                 } else {
 760                         /* add a new song */
 761                         playlist_append(&c->playlist, song);
 762                 }
 763
 764                 mpd_song_free(song);
 765         }
 766
 767         /* remove trailing songs */
 768
 769         length = mpd_status_get_queue_length(c->status);
 770         while (length < c->playlist.list->len) {
 771                 guint pos = c->playlist.list->len - 1;
 772
 773                 /* Remove the last playlist entry */
 774                 playlist_remove(&c->playlist, pos);
 775         }
 776
 777         c->song = NULL;
 778         c->playlist.id = mpd_status_get_queue_version(c->status);
 779
 780         mpdclient_playlist_callback(c, PLAYLIST_EVENT_UPDATED, NULL);
 781
 782         return mpdclient_finish_command(c) == 0;
 783 }
 784
 785
 786 /****************************************************************************/
 787 /*** Filelist functions *****************************************************/
 788 /****************************************************************************/
 789
 790 struct filelist *
 791 mpdclient_filelist_get(struct mpdclient *c, const gchar *path)
 792 {
 793         struct filelist *filelist;
 794         struct mpd_entity *entity;
 795
 796         if (MPD_ERROR(c))
 797                 return NULL;
 798
 799         mpd_send_list_meta(c->connection, path);
 800         filelist = filelist_new();
 801         if (path && path[0] && strcmp(path, "/"))
 802                 /* add a dummy entry for ./.. */
 803                 filelist_append(filelist, NULL);
 804
 805         while ((entity = mpd_recv_entity(c->connection)) != NULL)
 806                 filelist_append(filelist, entity);
 807
 808         /* If there's an error, ignore it.  We'll return an empty filelist. */
 809         mpdclient_finish_command(c);
 810
 811         filelist_sort_dir_play(filelist, compare_filelistentry);
 812
 813         return filelist;
 814 }
 815
 816 static struct filelist *
 817 mpdclient_recv_filelist_response(struct mpdclient *c)
 818 {
 819         struct filelist *filelist;
 820         struct mpd_entity *entity;
 821
 822         filelist = filelist_new();
 823
 824         while ((entity = mpd_recv_entity(c->connection)) != NULL)
 825                 filelist_append(filelist, entity);
 826
 827         if (mpdclient_finish_command(c)) {
 828                 filelist_free(filelist);
 829                 return NULL;
 830         }
 831
 832         return filelist;
 833 }
 834
 835 struct filelist *
 836 mpdclient_filelist_search(struct mpdclient *c,
 837                           int exact_match,
 838                           enum mpd_tag_type tag,
 839                           gchar *filter_utf8)
 840 {
 841         if (MPD_ERROR(c))
 842                 return NULL;
 843
 844         mpd_search_db_songs(c->connection, exact_match);
 845         mpd_search_add_tag_constraint(c->connection, MPD_OPERATOR_DEFAULT,
 846                                       tag, filter_utf8);
 847         mpd_search_commit(c->connection);
 848
 849         return mpdclient_recv_filelist_response(c);
 850 }
 851
 852 int
 853 mpdclient_filelist_add_all(struct mpdclient *c, struct filelist *fl)
 854 {
 855         guint i;
 856
 857         if (MPD_ERROR(c))
 858                 return -1;
 859
 860         if (filelist_is_empty(fl))
 861                 return 0;
 862
 863         mpd_command_list_begin(c->connection, false);
 864
 865         for (i = 0; i < filelist_length(fl); ++i) {
 866                 struct filelist_entry *entry = filelist_get(fl, i);
 867                 struct mpd_entity *entity  = entry->entity;
 868
 869                 if (entity != NULL &&
 870                     mpd_entity_get_type(entity) == MPD_ENTITY_TYPE_SONG) {
 871                         const struct mpd_song *song =
 872                                 mpd_entity_get_song(entity);
 873                         const char *uri = mpd_song_get_uri(song);
 874
 875                         if (uri != NULL)
 876                                 mpd_send_add(c->connection, uri);
 877                 }
 878         }
 879
 880         mpd_command_list_end(c->connection);
 881         return mpdclient_finish_command(c);
 882 }
 883
 884 GList *
 885 mpdclient_get_artists(struct mpdclient *c)
 886 {
 887         GList *list = NULL;
 888         struct mpd_pair *pair;
 889
 890         if (MPD_ERROR(c))
 891                return NULL;
 892
 893         mpd_search_db_tags(c->connection, MPD_TAG_ARTIST);
 894         mpd_search_commit(c->connection);
 895
 896         while ((pair = mpd_recv_pair_tag(c->connection,
 897                                          MPD_TAG_ARTIST)) != NULL) {
 898                 list = g_list_append(list, g_strdup(pair->value));
 899                 mpd_return_pair(c->connection, pair);
 900         }
 901
 902         if (mpdclient_finish_command(c))
 903                 return string_list_free(list);
 904
 905         return list;
 906 }
 907
 908 GList *
 909 mpdclient_get_albums(struct mpdclient *c, const gchar *artist_utf8)
 910 {
 911         GList *list = NULL;
 912         struct mpd_pair *pair;
 913
 914         if (MPD_ERROR(c))
 915                return NULL;
 916
 917         mpd_search_db_tags(c->connection, MPD_TAG_ALBUM);
 918         if (artist_utf8 != NULL)
 919                 mpd_search_add_tag_constraint(c->connection,
 920                                               MPD_OPERATOR_DEFAULT,
 921                                               MPD_TAG_ARTIST, artist_utf8);
 922         mpd_search_commit(c->connection);
 923
 924         while ((pair = mpd_recv_pair_tag(c->connection,
 925                                          MPD_TAG_ALBUM)) != NULL) {
 926                 list = g_list_append(list, g_strdup(pair->value));
 927                 mpd_return_pair(c->connection, pair);
 928         }
 929
 930         if (mpdclient_finish_command(c))
 931                 return string_list_free(list);
 932
 933         return list;
 934 }