#!/usr/bin/perl

# Andrew Daviel, TRIUMF, November 1997
# record_session for use with sdr, wrtp
# based on an idea by  Christoph Fleck which used rtpdump
# This version uses CERN wrtp by Miguel.Chamochin
# See http://csvod1.cern.ch/cgi-bin/nph-MBone-VCR

# For use with sdr; this script must be called "record_session" and
# must be on the user's PATH
unless ($0 =~ /record_session$/) {
  print STDERR "For correct operation, this script must be named \"record_session\" not \"$0\"\n";
  exit ;
}
if (!$ARGV[0]) {
print <<EOT ;
 \"record_session\" for use with sdr, wrtp

 Usage:
 To record a session:
 In sdr, from the Session Information menu, click "Record".
 In the Record Session menu, check "now", enter a filename prefix,
 and click "Record". For immediate recording, 
 append " record" to the filename prefix, e.g. "/usr/joe/Radio record".
 Otherwise,  execute the resulting record script "Radio.record". 
 A conference name is created from the title.

 To play a session:
 In sdr, create a new session in the normal way.
 Then select the session and proceed as for recording.
 For immediate playback, append " play" to the filename prefix.
 Execute the resulting playback script.
 The playback script takes two optional arguments; a conference name
 and an offset in seconds. The conference name defaults to
 one derived from the title; the offset defaults to zero.
EOT
 exit ;
}
require "ctime.pl";
require "timelocal.pl" ;
package sd;

@month = ('Jan','Feb','Mar','Apr','May','Jun','Jul','Aug','Sep','Oct','Nov','Dec') ;

$sd_time = 2208988800 ;


open (REC,">$ARGV[0].record") || die "Cannot create record script $ARGV[0].record" ;
open (PLAY,">$ARGV[0].play") || die "Cannot create playbackscript $ARGV[0].play";

while (<STDIN>) { $in .= $_ ; }
$_ = $in ;
#print $_ ;


@line = (split("\012")) ;
for ($i=0;$i<@line;$i++) {
  $_ = $line[$i] ;
  ($letter,$rest)=(/^(.)=(.+)/);
  if ($letter eq 'i') {
# Info 
    $description=$rest ;
  } elsif ($letter eq 's') {
# Title
    $title=$rest ;
  } elsif ($letter eq 'u') {
# URL
    $url=$rest;
  } elsif ($letter eq 'n') {
# Announce
# n=2358119139 2358119139 879461852 224.2.127.254 9875
    ($ip1,$ip2,$annt,$anni,$nn) = split(/\s/,$rest);
    $ip1a = join(".",unpack("C4",pack("N",$ip1))) ;
    $ip2a = join(".",unpack("C4",pack("N",$ip2))) ;
    #print "ip1 $ip1a ip2 $ip2a\n" ;
    chop($annta = &main'ctime($annt)); 
  } elsif ($letter eq 'o') {
# Originator
# o=kannan 3077640111 3078385359 IN IP4 128.9.160.67
    #print "Created by $rest \n\n";
    #print join(".",unpack("C4",pack("N",$ip1))),")\n\n";
  } elsif ($letter eq 't') {
# Time 
# t=3090267000 3090272400
  ($tm1,$tm2) = split(/\s/,$rest);
  if ($tm1 && $tm2) {
    if ($tm1 > 0xffffffff) {    # Probably got
      require 'bigint.pl';    # sign-extended by an
        # alpha running a buggy
        # version of sd.
      $tm1=&main'bmod($tm1,"4294967296");
      $tm2=&main'bmod($tm2,"4294967296");
    }
    $tm1 -= $sd_time;
    $tm2 -= $sd_time;
    $now = time ;
    if ($tm1 < $now) {
      $startnow++ ;
      $tm1 = $now ;
    }
    if ($tm2 < $now) {
      print STDERR "Too Late!\n" ;
    }
    chop($tm1a = &main'ctime($tm1));
    chop($tm2a = &main'ctime($tm2));
    $duration = $tm2 - $tm1 ;

    ($sec,$min,$hour,$mday,$mon,$year,$wday,$yday,$isdst) =
     localtime($tm1) ;
  }
  } elsif ($letter eq 'a') {
    if ($media) {
 #     print "$rest\n";
    } else {
 #     print "Session options: ",$rest,"\n\n";
    }
  } elsif ($letter eq 'm') {
# Media
    ($media,$port,$proto)=split(/\s/,$rest);
    $port{$media} = $port;
    $proto{$media} = $proto ;
    $_ = $line[$i+1] ;
    ($letter,$rest)=(/^(.)=(.+)/);
    if ($letter eq 'c') {
# expect address info
# c=IN IP4 224.2.253.119/191
      ($in,$ip,$adrt) =split(/\s/,$rest);
      ($adrs{$media},$ttl{$media}) = split(/\//,$adrt) ;
    } else {
      print STDERR "ERROR - expect \"c=\" got $_\n";
    }
  }
}
$name = $title ; $name =~ tr/A-Za-z0-9//cd ;

print REC<<EOT ;
#!/bin/sh
# exec this script to record Mbone session
#
echo "Record Mbone session '"'$title'"'"
# Title: $title
# Description:\n#$description
# URL: $url
# Announced by $ip1a at $annta on $anni
EOT
if ($proto{'audio'} ) {
  print REC "#audio $adrs{'audio'}/$port{'audio'} ttl $ttl{'audio'} $proto{'audio'} \n";
}
if ($proto{'video'} ) {
  print REC "#video $adrs{'video'}/$port{'video'} ttl $ttl{'video'} $proto{'video'}\n";
}
print PLAY<<EOT ;
#!/bin/sh
# exec this script to play Mbone session
# Usage: $ARGV[0].play [file prefix] [offset]
# file prefix  defaults to $name
# offset in seconds, default 0
# For an archived recording, use supplied name
#
echo "Replay Mbone session '"'$title'"'"
# Title: $title
echo "Description:"
echo "$description"
echo "URL: $url"
# Announced by $ip1a at $annta on $anni
EOT

if ($startnow) {
  $now = chop($annta = &main'ctime(time));
  print PLAY "echo \"Missed beginning; record script created $now\"\n";
  print REC "echo \"Missed beginning; will record now\"\n";
} elsif ($tm1 && $tm2) {
  print REC "echo \"Will record from $tm1a to $tm2a\"\n";
  print PLAY "echo \"Recorded from $tm1a to $tm2a\"\n";
  printf REC ("at %2.2d:%2.2d %s %s $d<<!\n",$hour,$min,$month[$mon],$mday) ;
} else {
  $now = chop($annta = &main'ctime(time));
  print PLAY "echo \"Permanent session; record script created $now\"\n";
  print REC "echo \"Permanent session; will record now\"\n";
  print REC "echo \"'\"'killall wrtpdump'\"' or Ctl-C to stop\"\n";
}
  
if ($proto{'audio'} =~ /RTP/) {
  $recaudio = "$adrs{'audio'}/$port{'audio'}" ;
}
if ($proto{'video'} =~ /RTP/) {
  $recvideo = "$adrs{'video'}/$port{'video'}" ;
}
print PLAY <<EOT ;
if ( test -z \"\$2\" ) ; then 
  O='0'  
else 
  O=\$2
  echo "Offset \$O seconds"  
fi
EOT
if ($duration) { 
  $duration /= 60 ; $duration = int($duration) ; $duration = "-t $duration" ; 
}
$name = $title ; $name =~ tr/A-Za-z0-9//cd ;
print PLAY <<EOT ;
if ( test -z \"\$1" ) ; then
  name="$name"
else
  name=\$1
fi
EOT
print REC "#wrtp -r -c $name $duration -a $recaudio -v $recvideo\n";
print PLAY "#wrtp -p -o \$O -c \$name -a $recaudio -v $recvideo\n";
if ($proto{'audio'} ) {
  print REC "wrtpdump $duration -d \$name.a.rtp $recaudio &\n" ;
  print PLAY "wrtpplay -o \$O -f \$name.a.rtp $recaudio &\n" ;
}
if ($proto{'video'} ) {
  print REC "wrtpdump $duration -d \$name.v.rtp $recvideo &\n" ;
  print PLAY "wrtpplay -o \$O -f \$name.v.rtp $recvideo &\n" ;
}
print PLAY "echo \'killall wrtpplay\' to stop playback\n" ;

if (!$startnow && $tm1 && $tm2) { print REC "!\n" ; }
close (REC) ; close (PLAY) ;
system("chmod +x $ARGV[0].record $ARGV[0].play") ;
print "Created $ARGV[0].record, $ARGV[0].play\n" ;
if ($ARGV[1]) {
  print "Executing ARGV[0].$ARGV[1] ...\n";
  if (!$tm1 || !$tm2) {
    print "\"killall wrtpdump\" to stop recording\n" ;
  }
  exec ("$ARGV[0].$ARGV[1]") ;
} else {
  print "You must execute the script \"$ARGV[0].record\" to start/schedule recording\n";
}