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