1 /*****************************************************************************
2 * podcast.c: Podcast services discovery module
3 *****************************************************************************
4 * Copyright (C) 2005-2009 the VideoLAN team
7 * Authors: Antoine Cellerier <dionoea -at- videolan -dot- org>
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
32 #include <vlc_common.h>
33 #include <vlc_plugin.h>
34 #include <vlc_services_discovery.h>
36 #include <vlc_network.h>
43 /************************************************************************
44 * Macros and definitions
45 ************************************************************************/
47 /*****************************************************************************
49 *****************************************************************************/
52 static int Open ( vlc_object_t
* );
53 static void Close( vlc_object_t
* );
55 VLC_SD_PROBE_HELPER("podcast", "Podcasts", SD_CAT_INTERNET
)
57 #define URLS_TEXT N_("Podcast URLs list")
58 #define URLS_LONGTEXT N_("Enter the list of podcasts to retrieve, " \
59 "separated by '|' (pipe)." )
62 set_shortname( "Podcast")
63 set_description( N_("Podcasts") )
64 set_category( CAT_PLAYLIST
)
65 set_subcategory( SUBCAT_PLAYLIST_SD
)
67 add_string( "podcast-urls", NULL
,
68 URLS_TEXT
, URLS_LONGTEXT
, false )
71 set_capability( "services_discovery", 0 )
72 set_callbacks( Open
, Close
)
74 VLC_SD_PROBE_SUBMODULE
79 /*****************************************************************************
81 *****************************************************************************/
86 }; /* FIXME Temporary. Updating by compound urls string to be removed later. */
88 struct services_discovery_sys_t
91 input_thread_t
**pp_input
;
97 input_item_t
**pp_items
;
108 /*****************************************************************************
110 *****************************************************************************/
111 static void *Run( void * );
112 static int UrlsChange( vlc_object_t
*, char const *, vlc_value_t
,
113 vlc_value_t
, void * );
114 static int Request( vlc_object_t
*, char const *, vlc_value_t
,
115 vlc_value_t
, void * );
116 static void ParseRequest( services_discovery_t
*p_sd
);
117 static void ParseUrls( services_discovery_t
*p_sd
, char *psz_urls
);
118 static void SaveUrls( services_discovery_t
*p_sd
);
120 /*****************************************************************************
121 * Open: initialize and create stuff
122 *****************************************************************************/
123 static int Open( vlc_object_t
*p_this
)
125 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
126 services_discovery_sys_t
*p_sys
= malloc(
127 sizeof( services_discovery_sys_t
) );
132 p_sys
->ppsz_urls
= NULL
;
134 p_sys
->pp_input
= NULL
;
135 p_sys
->pp_items
= NULL
;
137 vlc_mutex_init( &p_sys
->lock
);
138 vlc_cond_init( &p_sys
->wait
);
139 p_sys
->b_update
= true;
140 p_sys
->psz_request
= NULL
;
141 p_sys
->update_type
= UPDATE_URLS
;
145 /* Launch the callback associated with this variable */
146 var_Create( p_sd
, "podcast-urls", VLC_VAR_STRING
| VLC_VAR_DOINHERIT
);
147 var_AddCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
149 var_Create( p_sd
, "podcast-request", VLC_VAR_STRING
);
150 var_AddCallback( p_sd
, "podcast-request", Request
, p_sys
);
152 if (vlc_clone (&p_sys
->thread
, Run
, p_sd
, VLC_THREAD_PRIORITY_LOW
))
154 var_DelCallback( p_sd
, "podcast-request", Request
, p_sys
);
155 var_DelCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
156 vlc_cond_destroy( &p_sys
->wait
);
157 vlc_mutex_destroy( &p_sys
->lock
);
164 /*****************************************************************************
166 *****************************************************************************/
167 static void Close( vlc_object_t
*p_this
)
169 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
170 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
173 vlc_cancel (p_sys
->thread
);
174 vlc_join (p_sys
->thread
, NULL
);
176 var_DelCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
177 var_DelCallback( p_sd
, "podcast-request", Request
, p_sys
);
178 vlc_cond_destroy( &p_sys
->wait
);
179 vlc_mutex_destroy( &p_sys
->lock
);
181 for( i
= 0; i
< p_sys
->i_input
; i
++ )
183 input_thread_t
*p_input
= p_sd
->p_sys
->pp_input
[i
];
187 input_Stop( p_input
, true );
188 vlc_thread_join( p_input
);
189 vlc_object_release( p_input
);
191 p_sd
->p_sys
->pp_input
[i
] = NULL
;
193 free( p_sd
->p_sys
->pp_input
);
194 for( i
= 0; i
< p_sys
->i_urls
; i
++ ) free( p_sys
->ppsz_urls
[i
] );
195 free( p_sys
->ppsz_urls
);
196 for( i
= 0; i
< p_sys
->i_items
; i
++ ) vlc_gc_decref( p_sys
->pp_items
[i
] );
197 free( p_sys
->pp_items
);
198 free( p_sys
->psz_request
);
202 /*****************************************************************************
204 *****************************************************************************/
205 static void *Run( void *data
)
207 services_discovery_t
*p_sd
= data
;
208 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
210 vlc_mutex_lock( &p_sys
->lock
);
211 mutex_cleanup_push( &p_sys
->lock
);
214 while( !p_sys
->b_update
)
215 vlc_cond_wait( &p_sys
->wait
, &p_sys
->lock
);
217 int canc
= vlc_savecancel ();
218 msg_Dbg( p_sd
, "Update required" );
220 if( p_sys
->update_type
== UPDATE_URLS
)
222 char* psz_urls
= var_GetNonEmptyString( p_sd
, "podcast-urls" );
223 ParseUrls( p_sd
, psz_urls
);
226 else if( p_sys
->update_type
== UPDATE_REQUEST
)
228 ParseRequest( p_sd
);
231 p_sys
->b_update
= false;
233 for( int i
= 0; i
< p_sd
->p_sys
->i_input
; i
++ )
235 input_thread_t
*p_input
= p_sd
->p_sys
->pp_input
[i
];
237 if( p_input
->b_eof
|| p_input
->b_error
)
239 input_Stop( p_input
, false );
240 vlc_thread_join( p_input
);
241 vlc_object_release( p_input
);
243 p_sd
->p_sys
->pp_input
[i
] = NULL
;
244 REMOVE_ELEM( p_sys
->pp_input
, p_sys
->i_input
, i
);
248 vlc_restorecancel (canc
);
251 assert(0); /* dead code */
254 static int UrlsChange( vlc_object_t
*p_this
, char const *psz_var
,
255 vlc_value_t oldval
, vlc_value_t newval
,
258 VLC_UNUSED(p_this
); VLC_UNUSED(psz_var
); VLC_UNUSED(oldval
);
260 services_discovery_sys_t
*p_sys
= (services_discovery_sys_t
*)p_data
;
262 vlc_mutex_lock( &p_sys
->lock
);
263 p_sys
->b_update
= true;
264 p_sys
->update_type
= UPDATE_URLS
;
265 vlc_cond_signal( &p_sys
->wait
);
266 vlc_mutex_unlock( &p_sys
->lock
);
270 static int Request( vlc_object_t
*p_this
, char const *psz_var
,
271 vlc_value_t oldval
, vlc_value_t newval
,
274 VLC_UNUSED(p_this
); VLC_UNUSED(psz_var
); VLC_UNUSED(oldval
);
275 services_discovery_sys_t
*p_sys
= (services_discovery_sys_t
*)p_data
;
277 vlc_mutex_lock( &p_sys
->lock
);
278 free( p_sys
->psz_request
);
279 p_sys
->psz_request
= NULL
;
280 if( newval
.psz_string
&& *newval
.psz_string
) {
281 p_sys
->psz_request
= strdup( newval
.psz_string
);
282 p_sys
->b_update
= true;
283 p_sys
->update_type
= UPDATE_REQUEST
;
284 vlc_cond_signal( &p_sys
->wait
);
286 vlc_mutex_unlock( &p_sys
->lock
);
290 static void ParseUrls( services_discovery_t
*p_sd
, char *psz_urls
)
292 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
294 input_item_t
**pp_new_items
= NULL
;
297 char **ppsz_new_urls
= NULL
;
303 if( !psz_urls
) break;
305 char *psz_tok
= strchr( psz_urls
, '|' );
306 if( psz_tok
) *psz_tok
= '\0';
308 for( i
= 0; i
< p_sys
->i_urls
; i
++ )
309 if( !strcmp( psz_urls
, p_sys
->ppsz_urls
[i
] ) )
311 if( i
== p_sys
->i_urls
)
313 INSERT_ELEM( ppsz_new_urls
, i_new_urls
, i_new_urls
,
314 strdup( psz_urls
) );
316 input_item_t
*p_input
;
317 p_input
= input_item_New( p_sd
, psz_urls
, psz_urls
);
318 input_item_AddOption( p_input
, "demux=podcast", VLC_INPUT_OPTION_TRUSTED
);
320 INSERT_ELEM( pp_new_items
, i_new_items
, i_new_items
, p_input
);
321 services_discovery_AddItem( p_sd
, p_input
, NULL
/* no cat */ );
323 INSERT_ELEM( p_sys
->pp_input
, p_sys
->i_input
, p_sys
->i_input
,
324 input_CreateAndStart( p_sd
, p_input
, NULL
) );
328 INSERT_ELEM( ppsz_new_urls
, i_new_urls
, i_new_urls
,
329 strdup( p_sys
->ppsz_urls
[i
]) );
330 INSERT_ELEM( pp_new_items
, i_new_items
, i_new_items
, p_sys
->pp_items
[i
] );
332 if( psz_tok
) psz_urls
= psz_tok
+1;
336 /* delete removed items and signal the removal */
337 for( i
= 0; i
<p_sys
->i_items
; ++i
)
339 for( j
= 0; j
< i_new_items
; ++j
)
340 if( pp_new_items
[j
] == p_sys
->pp_items
[i
] ) break;
341 if( j
== i_new_items
)
343 services_discovery_RemoveItem( p_sd
, p_sys
->pp_items
[i
] );
344 vlc_gc_decref( p_sys
->pp_items
[i
] );
347 free( p_sys
->pp_items
);
348 for( int i
= 0; i
< p_sys
->i_urls
; i
++ ) free( p_sys
->ppsz_urls
[i
] );
349 free( p_sys
->ppsz_urls
);
351 p_sys
->ppsz_urls
= ppsz_new_urls
;
352 p_sys
->i_urls
= i_new_urls
;
353 p_sys
->pp_items
= pp_new_items
;
354 p_sys
->i_items
= i_new_items
;
357 static void ParseRequest( services_discovery_t
*p_sd
)
359 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
361 char *psz_request
= p_sys
->psz_request
;
365 char *psz_tok
= strchr( psz_request
, ':' );
366 if( !psz_tok
) return;
368 if( !strcmp( psz_request
, "ADD" ) )
370 psz_request
= psz_tok
+ 1;
371 for( i
= 0; i
<p_sys
->i_urls
; i
++ )
372 if( !strcmp(p_sys
->ppsz_urls
[i
],psz_request
) )
374 if( i
== p_sys
->i_urls
)
376 INSERT_ELEM( p_sys
->ppsz_urls
, p_sys
->i_urls
, p_sys
->i_urls
,
377 strdup( psz_request
) );
379 input_item_t
*p_input
;
380 p_input
= input_item_New( p_sd
, psz_request
, psz_request
);
381 input_item_AddOption( p_input
, "demux=podcast", VLC_INPUT_OPTION_TRUSTED
);
383 INSERT_ELEM( p_sys
->pp_items
, p_sys
->i_items
, p_sys
->i_items
, p_input
);
384 services_discovery_AddItem( p_sd
, p_input
, NULL
/* no cat */ );
386 INSERT_ELEM( p_sys
->pp_input
, p_sys
->i_input
, p_sys
->i_input
,
387 input_CreateAndStart( p_sd
, p_input
, NULL
) );
391 else if ( !strcmp( psz_request
, "RM" ) )
393 psz_request
= psz_tok
+ 1;
394 for( i
= 0; i
<p_sys
->i_urls
; i
++ )
395 if( !strcmp(p_sys
->ppsz_urls
[i
],psz_request
) )
397 if( i
!= p_sys
->i_urls
)
399 services_discovery_RemoveItem( p_sd
, p_sys
->pp_items
[i
] );
400 vlc_gc_decref( p_sys
->pp_items
[i
] );
401 REMOVE_ELEM( p_sys
->ppsz_urls
, p_sys
->i_urls
, i
);
402 REMOVE_ELEM( p_sys
->pp_items
, p_sys
->i_items
, i
);
407 free( p_sys
->psz_request
);
408 p_sys
->psz_request
= NULL
;
411 static void SaveUrls( services_discovery_t
*p_sd
)
413 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
418 for( i
=0; i
< p_sys
->i_urls
; i
++ )
419 len
+= strlen( p_sys
->ppsz_urls
[i
] ) + 1;
421 psz_urls
= (char*) calloc( len
, sizeof(char) );
423 for( i
=0; i
< p_sys
->i_urls
; i
++ )
425 strcat( psz_urls
, p_sys
->ppsz_urls
[i
] );
426 if( i
< p_sys
->i_urls
- 1 ) strcat( psz_urls
, "|" );
429 config_PutPsz( p_sd
, "podcast-urls", psz_urls
);
430 config_SaveConfigFile( p_sd
, "podcast" );