AsyncWgetFileGetter: create files with wallclock timestamp
[videosite.git] / videosite.pl
1 # autodownload flash videos
2 #
3 # (c) 2007-2008 by Ralf Ertzinger <ralf@camperquake.de>
4 # licensed under GNU GPL v2
5 #
6 # Based on youtube.pl by Christian Garbs <mitch@cgarbs.de>
7 # which in turn is
8 # based on trigger.pl by Wouter Coekaerts <wouter@coekaerts.be>
9
10
11 BEGIN {
12     # Get rid of a (possibly old) version of BettIrssi
13     # This is a hack to prevent having to reload irssi just
14     # because BettIrssi.pm changed
15
16     delete($INC{'BettIrssi.pm'});
17 }
18
19 use strict;
20 use Irssi 20020324 qw (command_bind command_runsub signal_add_first signal_add_last);
21 use vars qw($VERSION %IRSSI);
22 use XML::Simple;
23 use Data::Dumper;
24 use File::Spec;
25 use BettIrssi 101 qw(_bcb _bcs);
26
27 my @grabbers;
28 my @getters;
29 my $getter;
30 my $conf;
31 my $conffile = File::Spec->catfile(Irssi::get_irssi_dir(), 'videosite.xml');
32 my $scriptdir = File::Spec->catfile(Irssi::get_irssi_dir(), 'scripts');
33 my $plugindir = File::Spec->catfile($scriptdir, 'videosite');
34 my @outputstack = (undef);
35
36 my $PARAMS = {
37     'getter' => '',
38     'mode' => 'download'
39 };
40
41
42 # activate debug here
43 my $debug = 0;
44
45 # "message public", SERVER_REC, char *msg, char *nick, char *address, char *target
46 signal_add_last(_bcs("message public" => sub {check_for_link(@_)}));
47 # "message own_public", SERVER_REC, char *msg, char *target
48 signal_add_last(_bcs("message own_public" => sub {check_for_link(@_)}));
49
50 # "message private", SERVER_REC, char *msg, char *nick, char *address
51 signal_add_last(_bcs("message private" => sub {check_for_link(@_)}));
52 # "message own_private", SERVER_REC, char *msg, char *target, char *orig_target
53 signal_add_last(_bcs("message own_private" => sub {check_for_link(@_)}));
54
55 # "message irc action", SERVER_REC, char *msg, char *nick, char *address, char *target
56 signal_add_last(_bcs("message irc action" => sub {check_for_link(@_)}));
57 # "message irc own_action", SERVER_REC, char *msg, char *target
58 signal_add_last(_bcs("message irc own_action" => sub {check_for_link(@_)}));
59
60 # For tab completion
61 # This does not use BettIrssi (yet)
62 signal_add_first('complete word', \&sig_complete);
63
64 sub push_output {
65     unshift(@outputstack, shift);
66 }
67
68 sub pop_output {
69     shift(@outputstack);
70
71     @outputstack = (undef) unless (@outputstack);
72 }
73
74 my $videosite_commands = {
75     'save' => sub {
76         cmd_save();
77     },
78
79     'set' => sub {
80         cmd_set(@_);
81     },
82     
83     'show' => sub {
84         cmd_show(@_);
85     },
86
87     'help' => sub {
88         cmd_help(@_);
89     },
90
91     'getter' => sub {
92         cmd_getter(@_);
93     },
94
95     'enable' => sub {
96         cmd_enable(@_);
97     },
98
99     'disable' => sub {
100         cmd_disable(@_);
101     },
102
103     'reload' => sub {
104         init_videosite(0);
105     },
106
107     'mode' => sub {
108         cmd_mode(@_);
109     },
110
111     'debug' => sub {
112         $debug = 1;
113         foreach (@grabbers, @getters) {
114             $_->setdebug(1);
115         }
116         write_irssi('Enabled debugging');
117     },
118
119     'nodebug' => sub {
120         $debug = 0;
121         foreach (@grabbers, @getters) {
122             $_->setdebug(0);
123         }
124         write_irssi('Disabled debugging');
125     },
126 };
127
128 sub write_irssi {
129     my @text = @_;
130     my $output = $outputstack[0];
131
132     my $format = "%%mvideosite: %%n" . shift(@text);
133
134     # escape % in parameters from irssi
135     s/%/%%/g foreach @text;
136
137     if (defined $output) {
138         $output->(sprintf($format, @text), MSGLEVEL_CLIENTCRAP);
139     } else {
140         Irssi::print(sprintf($format, @text));
141     }
142
143 }
144
145 sub write_debug {
146     if ($debug) {
147         write_irssi(@_);
148     }
149 }
150
151 sub check_for_link {
152     my $event = shift;
153     my $message = $event->message();
154     my $witem = $event->channel();
155     my $g;
156     my $m;
157     my $p;
158
159
160     # Look if we should ignore this line
161     if ($message =~ m,(?:\s|^)/nosave(?:\s|$),) {
162         return;
163     }
164
165     push_output($event->ewpf);
166
167     study($message);
168
169     # Offer the message to all Grabbers in turn
170     foreach $g (@grabbers) {
171         ($m, $p) = $g->get($message);
172         while (defined($m)) {
173             write_debug('Metadata: %s', Dumper($m));
174             if ('download' eq ($conf->{'videosite'}->{'mode'})) {
175                 write_irssi('%%R>>> %%NSaving %%Y%s%%N %%G%s', $m->{'SOURCE'}, $m->{'TITLE'});
176                 unless($getter->get($m)) {
177                     write_irssi('%%R>>> FAILED');
178                 }
179             } elsif ('display' eq ($conf->{'videosite'}->{'mode'})) {
180                 write_irssi('%%M>>> %%NSaw %%Y%s%%N %%G%s', $m->{'SOURCE'}, $m->{'TITLE'});
181             } else {
182                 write_irssi('%%R>>> Invalid operation mode');
183             }
184
185             # Remove the matched part from the message and try again (there may be
186             # more!)
187             $message =~ s/$p//;
188             study($message);
189
190             ($m, $p) = $g->get($message);
191         }
192     }
193
194     pop_output();
195 }
196
197 sub cmd_save {
198
199     eval {
200         open(CONF, '>'.$conffile) or die 'Could not open config file';
201         print CONF XML::Simple::XMLout($conf, KeepRoot => 1, KeyAttr => {'config' => 'module', 'option' => 'key'});
202         close(CONF);
203     };
204     if ($@) {
205         write_irssi('Could not save config to %s: %s', ($conffile, $@));
206     } else {
207         write_irssi('configuration saved to %s', $conffile);
208     }
209 }
210
211 sub cmd_set {
212     my $target = shift;
213     my $key = shift;
214     my $val = shift;
215     my $p;
216
217     foreach $p (@getters, @grabbers) {
218         if ($p->{'NAME'} eq $target) {
219             $p->setval($key, $val);
220             return;
221         }
222     }
223     write_irssi('No such module');
224 }
225
226
227 sub cmd_enable {
228     my $target = shift;
229     my $p;
230
231     foreach $p (@grabbers) {
232         if ($p->{'NAME'} eq $target) {
233             $p->enable();
234             return;
235         }
236     }
237     write_irssi('No such module');
238 }
239
240
241 sub cmd_disable {
242     my $target = shift;
243     my $p;
244
245     foreach $p (@grabbers) {
246         if ($p->{'NAME'} eq $target) {
247             $p->disable();
248             return;
249         }
250     }
251     write_irssi('No such module');
252 }
253
254
255 sub cmd_show {
256     my $target = shift;
257     my $p;
258     my $e;
259
260     if (defined($target)) {
261         foreach $p (@getters, @grabbers) {
262             if ($p->{'NAME'} eq $target) {
263                 write_irssi($p->getconfstr());
264                 return;
265             }
266         }
267         write_irssi('No such module');
268     } else {
269         write_irssi('Loaded grabbers (* denotes enabled modules):');
270         foreach $p (@grabbers) {
271             $e = $p->_getval('enabled');
272             write_irssi(' %s%s', $p->{'NAME'}, $e?'*':'');
273         };
274
275         write_irssi('Loaded getters:');
276         foreach $p (@getters) {
277             write_irssi(' %s', $p->{'NAME'});
278         };
279     }
280 }
281
282 sub cmd_help {
283     my $target = shift;
284     my $p;
285
286     if (defined($target)) {
287         foreach $p (@getters, @grabbers) {
288             if ($p->{'NAME'} eq $target) {
289                 write_irssi($p->gethelpstr());
290                 return;
291             }
292         }
293         write_irssi('No such module');
294     } else {
295         write_irssi(<<'EOT');
296 Supported commands:
297  save: save the current configuration
298  help [modulename]: display this help, or module specific help
299  show [modulename]: show loaded modules, or the current parameters of a module
300  set modulename parameter value: set a module parameter to a new value
301  getter [modulename]: display or set the getter to use
302  enable [modulename]: enable the usage of this module (grabbers only)
303  disable [modulename]: disable the usage of this module (grabbers only)
304  reload: reload all modules (this is somewhat experimental)
305  mode [modename]: display or set the operation mode (download/display)
306  debug: enable debugging messages
307  nodebug: disable debugging messages
308 EOT
309     }
310 }
311
312 sub cmd_getter {
313     my $target = shift;
314     my $p;
315
316     if (defined($target)) {
317         foreach $p (@getters) {
318             if ($p->{'NAME'} eq $target) {
319                 $getter = $p;
320                 $conf->{'videosite'}->{'getter'} = $target;
321                 write_irssi("Getter changed to %s", $target);
322                 return;
323             }
324         }
325         write_irssi('No such getter');
326     } else {
327         write_irssi('Current getter: %s', $conf->{'videosite'}->{'getter'});
328     }
329 }
330
331 sub cmd_mode {
332     my $mode = shift;
333
334     if (defined($mode)) {
335         $mode = lc($mode);
336         if (('download' eq $mode) or ('display' eq $mode)) {
337             $conf->{'videosite'}->{'mode'} = $mode;
338             write_irssi('Now using %s mode', $mode);
339         } else {
340             write_irssi('Invalid mode: %s', $mode);
341         }
342     } else {
343         write_irssi('Current mode: %s', $conf->{'videosite'}->{'mode'});
344     }
345 }
346
347
348 # save on unload
349 sub sig_command_script_unload {
350     my $script = shift;
351     if ($script =~ /(.*\/)?videosite(\.pl)?$/) {
352         cmd_save();
353     }
354 }
355
356 sub ploader {
357
358     my $dir = shift;
359     my $pattern = shift;
360     my $type = shift;
361     my @list;
362     my $p;
363     my $g;
364     my @g = ();
365
366     opendir(D, $dir) || return ();
367     @list = grep {/$pattern/ && -f File::Spec->catfile($dir, $_) } readdir(D);
368     closedir(D);
369
370     foreach $p (@list) {
371         write_debug("Trying to load $p:");
372         $p =~ s/\.pm$//;
373         eval qq{ require videosite::$p; };
374         if ($@) {
375             write_irssi("Failed to load plugin: $@");
376             next;
377         }
378
379         $g = eval qq{ videosite::$p->new(); };
380         if ($@) {
381             write_irssi("Failed to instanciate: $@");
382             delete($INC{$p});
383             next;
384         }
385
386         write_debug("found $g->{'TYPE'} $g->{'NAME'}");
387         if ($type eq $g->{'TYPE'}) {
388             push(@g, $g);
389             $g->setio(\&write_irssi);
390         } else {
391             write_irssi('%s has wrong type (got %s, expected %s)', $p, $g->{'TYPE'}, $type);
392             delete($INC{$p});
393         }
394     }
395
396     write_debug("Loaded %d plugins", $#g+1);
397     
398     return @g;
399 }
400
401 sub _load_modules($) {
402
403     my $path = shift;
404
405     foreach (keys(%INC)) {
406         if ($INC{$_} =~ m|^$path|) {
407             write_debug("Removing %s from \$INC", $_);
408             delete($INC{$_});
409         }
410     }
411     @grabbers = ploader($path, '.*Grabber\.pm$', 'grabber');
412     @getters = ploader($path, '.*Getter\.pm$', 'getter');
413 }
414
415
416 sub init_videosite {
417
418     my $bindings = shift;
419     my $p;
420
421     unless(-r $conffile && defined($conf = XML::Simple::XMLin($conffile, ForceArray => ['config', 'option'], KeepRoot => 1, KeyAttr => {'config' => 'module', 'option' => 'key'}))) {
422         # No config, start with an empty one
423         write_debug('No config found, using defaults');
424         $conf = { 'videosite' => { }};
425     }
426     foreach (keys(%{$PARAMS})) {
427         unless (exists($conf->{'videosite'}->{$_})) {
428             $conf->{'videosite'}->{$_} = $PARAMS->{$_};
429         }
430     }
431
432     _load_modules($plugindir);
433
434     unless (defined(@grabbers) && defined(@getters)) {
435         write_irssi('No grabbers or no getters found, can not proceed.');
436         return;
437     }
438
439     $getter = $getters[0];
440     foreach $p (@getters) {
441         if ($conf->{'videosite'}->{'getter'} eq $p->{'NAME'}) {
442             $getter = $p;
443         }
444     }
445     write_debug('Selected %s as getter', $getter->{'NAME'});
446     $conf->{'videosite'}->{'getter'} = $getter->{'NAME'};
447
448     # Loop through all plugins and load the config
449     foreach $p (@grabbers, @getters) {
450         $conf->{'videosite'}->{'config'}->{$p->{'NAME'}} = $p->mergeconfig($conf->{'videosite'}->{'config'}->{$p->{'NAME'}});
451     }
452
453     if ($bindings) {
454
455         Irssi::signal_add_first('command script load', 'sig_command_script_unload');
456         Irssi::signal_add_first('command script unload', 'sig_command_script_unload');
457         Irssi::signal_add('setup saved', 'cmd_save');
458
459
460         Irssi::command_bind(_bcb('videosite' => \&cmdhandler));
461     }
462
463     write_irssi('initialized successfully');
464 }
465
466 sub sig_complete {
467     my ($complist, $window, $word, $linestart, $want_space) = @_;
468     my @matches;
469
470     if ($linestart !~ m|^/videosite\b|) {
471         return;
472     }
473
474     if ('/videosite' eq $linestart) {
475         # No command enterd so far. Produce a list of possible follow-ups
476         @matches = grep {/^$word/} keys (%{$videosite_commands});
477     } elsif ('/videosite set' eq $linestart) {
478         # 'set' command entered. Produce a list of modules
479         foreach (@grabbers, @getters) {
480             push(@matches, $_->{'NAME'}) if $_->{'NAME'} =~ m|^$word|;
481         };
482     } elsif ($linestart =~ m|^/videosite set (\w+)$|) {
483         my $module = $1;
484
485         foreach my $p (@getters, @grabbers) {
486             if ($p->{'NAME'} eq $module) {
487                 @matches = $p->getparamlist($word);
488                 last;
489             }
490         }
491     } elsif ($linestart =~ m|/videosite set (\w+) (\w+)$|) {
492         my $module = $1;
493         my $param = $2;
494
495         foreach my $p (@getters, @grabbers) {
496             if ($p->{'NAME'} eq $module) {
497                 @matches = $p->getparamvalues($param, $word);
498                 last;
499             }
500         }
501     }
502
503
504     push(@{$complist}, sort @matches);
505     ${$want_space} = 0;
506
507     Irssi::signal_stop();
508 }
509
510 sub cmdhandler {
511     my $event = shift;
512     my ($cmd, @params) = split(/\s+/, $event->message());
513
514     push_output($event->ewpf);
515
516     if (exists($videosite_commands->{$cmd})) {
517         $videosite_commands->{$cmd}->(@params);
518     }
519
520     pop_output();
521 }
522
523 unshift(@INC, $scriptdir);
524 init_videosite(1);