1 /*
2 * Container / Playlist database adapter class for DMAP sharing
3 *
4 * Copyright (C) 2008 W. Michael Petullo <mike@flyn.org>
5 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * The Rhythmbox authors hereby grant permission for non-GPL compatible
12 * GStreamer plugins to be used and distributed together with GStreamer
13 * and Rhythmbox. This permission is above and beyond the permissions granted
14 * by the GPL license by which Rhythmbox is covered. If you modify this code
15 * you may extend this exception to your version of the code, but you are not
16 * obligated to do so. If you do not wish to do so, delete this exception
17 * statement from your version.
18 *
19 * This program is distributed in the hope that it will be useful,
20 * but WITHOUT ANY WARRANTY; without even the implied warranty of
21 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
22 * GNU General Public License for more details.
23 *
24 * You should have received a copy of the GNU General Public License
25 * along with this program; if not, write to the Free Software
26 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
27 *
28 */
29
30 #include "config.h"
31
32 #include "rb-playlist-manager.h"
33 #include "rb-playlist-source.h"
34 #include "rb-dmap-container-db-adapter.h"
35 #include "rb-daap-container-record.h"
36
37 #include <libdmapsharing/dmap.h>
38
39 static guint next_playlist_id = 2;
40
41 struct RBDMAPContainerDbAdapterPrivate {
42 RBPlaylistManager *playlist_manager;
43 };
44
45 typedef struct ForeachAdapterData {
46 gpointer data;
47 GHFunc func;
48 } ForeachAdapterData;
49
find_by_id(gconstpointer a,gconstpointer b)50 static guint find_by_id (gconstpointer a, gconstpointer b)
51 {
52 return GPOINTER_TO_UINT (g_object_get_data (G_OBJECT (a), "daap_id")) != GPOINTER_TO_UINT (b);
53 }
54
55 static DMAPContainerRecord *
rb_dmap_container_db_adapter_lookup_by_id(DMAPContainerDb * db,guint id)56 rb_dmap_container_db_adapter_lookup_by_id (DMAPContainerDb *db, guint id)
57 {
58 gchar *name;
59 GList *playlists;
60 DMAPContainerRecord *fnval = NULL;
61
62 playlists = rb_playlist_manager_get_playlists (RB_DMAP_CONTAINER_DB_ADAPTER (db)->priv->playlist_manager);
63
64 if (playlists != NULL && playlists->data != NULL) {
65 GList *result;
66 result = g_list_find_custom (playlists, GINT_TO_POINTER (id), (GCompareFunc) find_by_id);
67 if (result != NULL && result->data != NULL) {
68 RBPlaylistSource *source;
69 source = RB_PLAYLIST_SOURCE (result->data);
70 g_object_get (source, "name", &name, NULL);
71 fnval = DMAP_CONTAINER_RECORD (rb_daap_container_record_new (name, source));
72 }
73 }
74
75 g_list_free (playlists);
76
77 return fnval;
78 }
79
80 static void
foreach_adapter(RBPlaylistSource * entry,gpointer data)81 foreach_adapter (RBPlaylistSource *entry, gpointer data)
82 {
83 gchar *name;
84 DMAPContainerRecord *record;
85 ForeachAdapterData *foreach_adapter_data;
86
87 foreach_adapter_data = data;
88 g_object_get (entry, "name", &name, NULL);
89 record = DMAP_CONTAINER_RECORD (rb_daap_container_record_new (name, entry));
90
91 foreach_adapter_data->func (GINT_TO_POINTER (rb_daap_container_record_get_id (record)),
92 record,
93 foreach_adapter_data->data);
94
95 g_object_unref (record);
96 }
97
98 static void
rb_dmap_container_db_adapter_foreach(DMAPContainerDb * db,GHFunc func,gpointer data)99 rb_dmap_container_db_adapter_foreach (DMAPContainerDb *db,
100 GHFunc func,
101 gpointer data)
102 {
103 ForeachAdapterData *foreach_adapter_data;
104 GList *playlists;
105
106 playlists = rb_playlist_manager_get_playlists (RB_DMAP_CONTAINER_DB_ADAPTER (db)->priv->playlist_manager);
107
108 foreach_adapter_data = g_new (ForeachAdapterData, 1);
109 foreach_adapter_data->data = data;
110 foreach_adapter_data->func = func;
111 g_list_foreach (playlists, (GFunc) foreach_adapter, foreach_adapter_data);
112
113 g_list_free (playlists);
114 g_free (foreach_adapter_data);
115 }
116
117 static gint64
rb_dmap_container_db_adapter_count(DMAPContainerDb * db)118 rb_dmap_container_db_adapter_count (DMAPContainerDb *db)
119 {
120 gint64 count = 0;
121 GList *playlists = rb_playlist_manager_get_playlists (
122 RB_DMAP_CONTAINER_DB_ADAPTER (db)->priv->playlist_manager);
123 count = g_list_length (playlists);
124 g_list_free (playlists);
125 return count;
126 }
127
128 static void
rb_dmap_container_db_adapter_init(RBDMAPContainerDbAdapter * db)129 rb_dmap_container_db_adapter_init (RBDMAPContainerDbAdapter *db)
130 {
131 db->priv = RB_DMAP_CONTAINER_DB_ADAPTER_GET_PRIVATE (db);
132 }
133
134 static void
rb_dmap_container_db_adapter_class_init(RBDMAPContainerDbAdapterClass * klass)135 rb_dmap_container_db_adapter_class_init (RBDMAPContainerDbAdapterClass *klass)
136 {
137 g_type_class_add_private (klass, sizeof (RBDMAPContainerDbAdapterPrivate));
138 }
139
140 static void
rb_dmap_container_db_adapter_class_finalize(RBDMAPContainerDbAdapterClass * klass)141 rb_dmap_container_db_adapter_class_finalize (RBDMAPContainerDbAdapterClass *klass)
142 {
143 }
144
145 static void
rb_dmap_container_db_adapter_interface_init(gpointer iface,gpointer data)146 rb_dmap_container_db_adapter_interface_init (gpointer iface, gpointer data)
147 {
148 DMAPContainerDbIface *dmap_db = iface;
149
150 g_assert (G_TYPE_FROM_INTERFACE (dmap_db) == DMAP_TYPE_CONTAINER_DB);
151
152 dmap_db->lookup_by_id = rb_dmap_container_db_adapter_lookup_by_id;
153 dmap_db->foreach = rb_dmap_container_db_adapter_foreach;
154 dmap_db->count = rb_dmap_container_db_adapter_count;
155 }
156
157 G_DEFINE_DYNAMIC_TYPE_EXTENDED (RBDMAPContainerDbAdapter,
158 rb_dmap_container_db_adapter,
159 G_TYPE_OBJECT,
160 0,
161 G_IMPLEMENT_INTERFACE_DYNAMIC (DMAP_TYPE_CONTAINER_DB,
162 rb_dmap_container_db_adapter_interface_init))
163
164 static void
assign_id(RBPlaylistManager * mgr,RBSource * source)165 assign_id (RBPlaylistManager *mgr,
166 RBSource *source)
167 {
168 if (g_object_get_data (G_OBJECT (source), "daap_id") == NULL)
169 g_object_set_data (G_OBJECT (source), "daap_id", GUINT_TO_POINTER (next_playlist_id++));
170 }
171
172 RBDMAPContainerDbAdapter *
rb_dmap_container_db_adapter_new(RBPlaylistManager * playlist_manager)173 rb_dmap_container_db_adapter_new (RBPlaylistManager *playlist_manager)
174 {
175 RBDMAPContainerDbAdapter *db;
176 GList *playlists;
177
178 playlists = rb_playlist_manager_get_playlists (playlist_manager);
179
180 /* These IDs are DAAP-specific, so they are not a part of the
181 * general-purpose RBPlaylistSource class:
182 */
183 if (playlists != NULL && playlists->data != NULL) {
184 GList *l;
185 for (l = playlists; l != NULL; l = l->next) {
186 assign_id (playlist_manager, RB_SOURCE (l->data));
187 }
188 }
189
190 g_signal_connect (G_OBJECT (playlist_manager),
191 "playlist_created",
192 G_CALLBACK (assign_id),
193 NULL);
194
195 g_signal_connect (G_OBJECT (playlist_manager),
196 "playlist_added",
197 G_CALLBACK (assign_id),
198 NULL);
199
200 db = RB_DMAP_CONTAINER_DB_ADAPTER (g_object_new (RB_TYPE_DMAP_CONTAINER_DB_ADAPTER,
201 NULL));
202
203 db->priv->playlist_manager = playlist_manager;
204
205 return db;
206 }
207
208 void
_rb_dmap_container_db_adapter_register_type(GTypeModule * module)209 _rb_dmap_container_db_adapter_register_type (GTypeModule *module)
210 {
211 rb_dmap_container_db_adapter_register_type (module);
212 }
213