brmlab/brmdoor
4
0
Fork 0
mirror of https://github.com/brmlab/brmdoor.git synced 2025-06-08 03:34:02 +02:00
Code Issues Projects Releases Packages Wiki Activity

brmd: Separate ssh interface to the brmd::Stream package

Browse source
This commit is contained in:
Petr Baudis 2011-05-07 01:00:57 +02:00
parent 77cd405f18
commit dbdd8e706b
1 changed files with 59 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

70
brmd/brmd.pl
View file

@ -13,13 +13,14 @@ our $serial;
my $irc = brmd::IRC->new(); my $irc = brmd::IRC->new();
my $web = brmd::WWW->new(); my $web = brmd::WWW->new();
my $door = brmd::Door->new(); my $door = brmd::Door->new();
my $stream = brmd::Stream->new();
POE::Session->create( POE::Session->create(
package_states => [ package_states => [
main => [ qw(_default _start) ], main => [ qw(_default _start) ],
], ],
heap => { irc => $irc, web => $web }, heap => { irc => $irc, web => $web, stream => $stream },
); );
$poe_kernel->run(); $poe_kernel->run();
@ -51,14 +52,6 @@ sub record_str {
$record ? 'ON AIR' : 'OFF AIR'; $record ? 'ON AIR' : 'OFF AIR';
} }
sub stream_switch {
my ($s) = @_;
system('ssh brmstream@brmvid "echo '.($s?'START':'STOP').' >/tmp/brmstream"');
}
sub record_start { stream_switch(1); }
sub record_stop { stream_switch(0); }
sub status_update { sub status_update {
my ($newstatus) = @_; my ($newstatus) = @_;
$status = $newstatus; $status = $newstatus;
@ -70,9 +63,9 @@ sub record_update {
my ($newrecord) = @_; my ($newrecord) = @_;
$record = $newrecord; $record = $newrecord;
if ($record) { if ($record) {
record_start(); $poe_kernel->post( $stream, 'stream_start' );
} else { } else {
record_stop(); $poe_kernel->post( $stream, 'stream_stop' );
} }
my $st = record_str(); my $st = record_str();
@ -516,3 +509,58 @@ sub notify_door_unlocked {
} }
1; 1;
## Live Stream
package brmd::Stream;
use POE;
sub new {
my $class = shift;
my $self = bless { }, $class;
POE::Session->create(
object_states => [
$self => [ qw(_start _default
stream_start stream_stop) ],
],
);
return $self;
}
sub _start {
$_[KERNEL]->alias_set("$_[OBJECT]");
}
sub _default {
my ($event, $args) = @_[ARG0 .. $#_];
my @output = ( (scalar localtime), "Stream $event: " );
for my $arg (@$args) {
if ( ref $arg eq 'ARRAY' ) {
push( @output, '[' . join(', ', @$arg ) . ']' );
}
else {
push( @output, "'$arg'" );
}
}
print join ' ', @output, "\n";
}
sub stream_switch {
my ($s) = @_;
system('ssh brmstream@brmvid "echo '.($s?'START':'STOP').' >/tmp/brmstream"');
}
sub stream_start {
stream_switch(1);
}
sub stream_stop {
stream_switch(0);
}
1;