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_playlist.h>
35 #include <vlc_services_discovery.h>
37 #include <vlc_network.h>
44 /************************************************************************
45 * Macros and definitions
46 ************************************************************************/
48 /*****************************************************************************
50 *****************************************************************************/
53 static int Open ( vlc_object_t
* );
54 static void Close( vlc_object_t
* );
56 VLC_SD_PROBE_HELPER("podcast", "Podcasts", SD_CAT_INTERNET
)
58 #define URLS_TEXT N_("Podcast URLs list")
59 #define URLS_LONGTEXT N_("Enter the list of podcasts to retrieve, " \
60 "separated by '|' (pipe)." )
63 set_shortname( "Podcast")
64 set_description( N_("Podcasts") )
65 set_category( CAT_PLAYLIST
)
66 set_subcategory( SUBCAT_PLAYLIST_SD
)
68 add_string( "podcast-urls", NULL
, NULL
,
69 URLS_TEXT
, URLS_LONGTEXT
, false )
72 set_capability( "services_discovery", 0 )
73 set_callbacks( Open
, Close
)
75 VLC_SD_PROBE_SUBMODULE
80 /*****************************************************************************
82 *****************************************************************************/
87 }; /* FIXME Temporary. Updating by compound urls string to be removed later. */
89 struct services_discovery_sys_t
92 input_thread_t
**pp_input
;
98 input_item_t
**pp_items
;
109 /*****************************************************************************
111 *****************************************************************************/
112 static void *Run( void * );
113 static int UrlsChange( vlc_object_t
*, char const *, vlc_value_t
,
114 vlc_value_t
, void * );
115 static int Request( vlc_object_t
*, char const *, vlc_value_t
,
116 vlc_value_t
, void * );
117 static void ParseRequest( services_discovery_t
*p_sd
);
118 static void ParseUrls( services_discovery_t
*p_sd
, char *psz_urls
);
119 static void SaveUrls( services_discovery_t
*p_sd
);
121 /*****************************************************************************
122 * Open: initialize and create stuff
123 *****************************************************************************/
124 static int Open( vlc_object_t
*p_this
)
126 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
127 services_discovery_sys_t
*p_sys
= malloc(
128 sizeof( services_discovery_sys_t
) );
133 p_sys
->ppsz_urls
= NULL
;
135 p_sys
->pp_input
= NULL
;
136 p_sys
->pp_items
= NULL
;
138 vlc_mutex_init( &p_sys
->lock
);
139 vlc_cond_init( &p_sys
->wait
);
140 p_sys
->b_update
= true;
141 p_sys
->psz_request
= NULL
;
142 p_sys
->update_type
= UPDATE_URLS
;
146 /* Launch the callback associated with this variable */
147 var_Create( p_sd
, "podcast-urls", VLC_VAR_STRING
| VLC_VAR_DOINHERIT
);
148 var_AddCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
150 var_Create( p_sd
, "podcast-request", VLC_VAR_STRING
);
151 var_AddCallback( p_sd
, "podcast-request", Request
, p_sys
);
153 if (vlc_clone (&p_sys
->thread
, Run
, p_sd
, VLC_THREAD_PRIORITY_LOW
))
155 var_DelCallback( p_sd
, "podcast-request", Request
, p_sys
);
156 var_DelCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
157 vlc_cond_destroy( &p_sys
->wait
);
158 vlc_mutex_destroy( &p_sys
->lock
);
165 /*****************************************************************************
167 *****************************************************************************/
168 static void Close( vlc_object_t
*p_this
)
170 services_discovery_t
*p_sd
= ( services_discovery_t
* )p_this
;
171 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
174 vlc_cancel (p_sys
->thread
);
175 vlc_join (p_sys
->thread
, NULL
);
177 var_DelCallback( p_sd
, "podcast-urls", UrlsChange
, p_sys
);
178 var_DelCallback( p_sd
, "podcast-request", Request
, p_sys
);
179 vlc_cond_destroy( &p_sys
->wait
);
180 vlc_mutex_destroy( &p_sys
->lock
);
182 for( i
= 0; i
< p_sys
->i_input
; i
++ )
184 input_thread_t
*p_input
= p_sd
->p_sys
->pp_input
[i
];
188 input_Stop( p_input
, true );
189 vlc_thread_join( p_input
);
190 vlc_object_release( p_input
);
192 p_sd
->p_sys
->pp_input
[i
] = NULL
;
194 free( p_sd
->p_sys
->pp_input
);
195 for( i
= 0; i
< p_sys
->i_urls
; i
++ ) free( p_sys
->ppsz_urls
[i
] );
196 free( p_sys
->ppsz_urls
);
197 for( i
= 0; i
< p_sys
->i_items
; i
++ ) vlc_gc_decref( p_sys
->pp_items
[i
] );
198 free( p_sys
->pp_items
);
199 free( p_sys
->psz_request
);
203 /*****************************************************************************
205 *****************************************************************************/
206 static void *Run( void *data
)
208 services_discovery_t
*p_sd
= data
;
209 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
211 vlc_mutex_lock( &p_sys
->lock
);
212 mutex_cleanup_push( &p_sys
->lock
);
215 while( !p_sys
->b_update
)
216 vlc_cond_wait( &p_sys
->wait
, &p_sys
->lock
);
218 int canc
= vlc_savecancel ();
219 msg_Dbg( p_sd
, "Update required" );
221 if( p_sys
->update_type
== UPDATE_URLS
)
223 char* psz_urls
= var_GetNonEmptyString( p_sd
, "podcast-urls" );
224 ParseUrls( p_sd
, psz_urls
);
227 else if( p_sys
->update_type
== UPDATE_REQUEST
)
229 ParseRequest( p_sd
);
232 p_sys
->b_update
= false;
234 for( int i
= 0; i
< p_sd
->p_sys
->i_input
; i
++ )
236 input_thread_t
*p_input
= p_sd
->p_sys
->pp_input
[i
];
238 if( p_input
->b_eof
|| p_input
->b_error
)
240 input_Stop( p_input
, false );
241 vlc_thread_join( p_input
);
242 vlc_object_release( p_input
);
244 p_sd
->p_sys
->pp_input
[i
] = NULL
;
245 REMOVE_ELEM( p_sys
->pp_input
, p_sys
->i_input
, i
);
249 vlc_restorecancel (canc
);
252 assert(0); /* dead code */
255 static int UrlsChange( vlc_object_t
*p_this
, char const *psz_var
,
256 vlc_value_t oldval
, vlc_value_t newval
,
259 VLC_UNUSED(p_this
); VLC_UNUSED(psz_var
); VLC_UNUSED(oldval
);
261 services_discovery_sys_t
*p_sys
= (services_discovery_sys_t
*)p_data
;
263 vlc_mutex_lock( &p_sys
->lock
);
264 p_sys
->b_update
= true;
265 p_sys
->update_type
= UPDATE_URLS
;
266 vlc_cond_signal( &p_sys
->wait
);
267 vlc_mutex_unlock( &p_sys
->lock
);
271 static int Request( vlc_object_t
*p_this
, char const *psz_var
,
272 vlc_value_t oldval
, vlc_value_t newval
,
275 VLC_UNUSED(p_this
); VLC_UNUSED(psz_var
); VLC_UNUSED(oldval
);
276 services_discovery_sys_t
*p_sys
= (services_discovery_sys_t
*)p_data
;
278 vlc_mutex_lock( &p_sys
->lock
);
279 free( p_sys
->psz_request
);
280 p_sys
->psz_request
= NULL
;
281 if( newval
.psz_string
&& *newval
.psz_string
) {
282 p_sys
->psz_request
= strdup( newval
.psz_string
);
283 p_sys
->b_update
= true;
284 p_sys
->update_type
= UPDATE_REQUEST
;
285 vlc_cond_signal( &p_sys
->wait
);
287 vlc_mutex_unlock( &p_sys
->lock
);
291 static void ParseUrls( services_discovery_t
*p_sd
, char *psz_urls
)
293 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
295 input_item_t
**pp_new_items
= NULL
;
298 char **ppsz_new_urls
= NULL
;
304 if( !psz_urls
) break;
306 char *psz_tok
= strchr( psz_urls
, '|' );
307 if( psz_tok
) *psz_tok
= '\0';
309 for( i
= 0; i
< p_sys
->i_urls
; i
++ )
310 if( !strcmp( psz_urls
, p_sys
->ppsz_urls
[i
] ) )
312 if( i
== p_sys
->i_urls
)
314 INSERT_ELEM( ppsz_new_urls
, i_new_urls
, i_new_urls
,
315 strdup( psz_urls
) );
317 input_item_t
*p_input
;
318 p_input
= input_item_New( p_sd
, psz_urls
, psz_urls
);
319 input_item_AddOption( p_input
, "demux=podcast", VLC_INPUT_OPTION_TRUSTED
);
321 INSERT_ELEM( pp_new_items
, i_new_items
, i_new_items
, p_input
);
322 services_discovery_AddItem( p_sd
, p_input
, NULL
/* no cat */ );
324 INSERT_ELEM( p_sys
->pp_input
, p_sys
->i_input
, p_sys
->i_input
,
325 input_CreateAndStart( p_sd
, p_input
, NULL
) );
329 INSERT_ELEM( ppsz_new_urls
, i_new_urls
, i_new_urls
,
330 strdup( p_sys
->ppsz_urls
[i
]) );
331 INSERT_ELEM( pp_new_items
, i_new_items
, i_new_items
, p_sys
->pp_items
[i
] );
333 if( psz_tok
) psz_urls
= psz_tok
+1;
337 /* delete removed items and signal the removal */
338 for( i
= 0; i
<p_sys
->i_items
; ++i
)
340 for( j
= 0; j
< i_new_items
; ++j
)
341 if( pp_new_items
[j
] == p_sys
->pp_items
[i
] ) break;
342 if( j
== i_new_items
)
344 services_discovery_RemoveItem( p_sd
, p_sys
->pp_items
[i
] );
345 vlc_gc_decref( p_sys
->pp_items
[i
] );
348 free( p_sys
->pp_items
);
349 for( int i
= 0; i
< p_sys
->i_urls
; i
++ ) free( p_sys
->ppsz_urls
[i
] );
350 free( p_sys
->ppsz_urls
);
352 p_sys
->ppsz_urls
= ppsz_new_urls
;
353 p_sys
->i_urls
= i_new_urls
;
354 p_sys
->pp_items
= pp_new_items
;
355 p_sys
->i_items
= i_new_items
;
358 static void ParseRequest( services_discovery_t
*p_sd
)
360 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
362 char *psz_request
= p_sys
->psz_request
;
366 char *psz_tok
= strchr( psz_request
, ':' );
367 if( !psz_tok
) return;
369 if( !strcmp( psz_request
, "ADD" ) )
371 psz_request
= psz_tok
+ 1;
372 for( i
= 0; i
<p_sys
->i_urls
; i
++ )
373 if( !strcmp(p_sys
->ppsz_urls
[i
],psz_request
) )
375 if( i
== p_sys
->i_urls
)
377 INSERT_ELEM( p_sys
->ppsz_urls
, p_sys
->i_urls
, p_sys
->i_urls
,
378 strdup( psz_request
) );
380 input_item_t
*p_input
;
381 p_input
= input_item_New( p_sd
, psz_request
, psz_request
);
382 input_item_AddOption( p_input
, "demux=podcast", VLC_INPUT_OPTION_TRUSTED
);
384 INSERT_ELEM( p_sys
->pp_items
, p_sys
->i_items
, p_sys
->i_items
, p_input
);
385 services_discovery_AddItem( p_sd
, p_input
, NULL
/* no cat */ );
387 INSERT_ELEM( p_sys
->pp_input
, p_sys
->i_input
, p_sys
->i_input
,
388 input_CreateAndStart( p_sd
, p_input
, NULL
) );
392 else if ( !strcmp( psz_request
, "RM" ) )
394 psz_request
= psz_tok
+ 1;
395 for( i
= 0; i
<p_sys
->i_urls
; i
++ )
396 if( !strcmp(p_sys
->ppsz_urls
[i
],psz_request
) )
398 if( i
!= p_sys
->i_urls
)
400 services_discovery_RemoveItem( p_sd
, p_sys
->pp_items
[i
] );
401 vlc_gc_decref( p_sys
->pp_items
[i
] );
402 REMOVE_ELEM( p_sys
->ppsz_urls
, p_sys
->i_urls
, i
);
403 REMOVE_ELEM( p_sys
->pp_items
, p_sys
->i_items
, i
);
408 free( p_sys
->psz_request
);
409 p_sys
->psz_request
= NULL
;
412 static void SaveUrls( services_discovery_t
*p_sd
)
414 services_discovery_sys_t
*p_sys
= p_sd
->p_sys
;
419 for( i
=0; i
< p_sys
->i_urls
; i
++ )
420 len
+= strlen( p_sys
->ppsz_urls
[i
] ) + 1;
422 psz_urls
= (char*) calloc( len
, sizeof(char) );
424 for( i
=0; i
< p_sys
->i_urls
; i
++ )
426 strcat( psz_urls
, p_sys
->ppsz_urls
[i
] );
427 if( i
< p_sys
->i_urls
- 1 ) strcat( psz_urls
, "|" );
430 config_PutPsz( p_sd
, "podcast-urls", psz_urls
);
431 config_SaveConfigFile( p_sd
, "podcast" );