#!/usr/bin/perl

use Socket;
use MIME::Base64 qw(encode_base64 decode_base64);
use Digest::SHA qw(sha1);
use Time::Piece;

# Ruslan Mayorov <MaR>

$command = $ARGV[0];
$host = $ARGV[1];
$stream = $ARGV[2];
$lp = $ARGV[3];

$com1 = "info";
$com2 = "profiles";
$com3 = "play";
$hr = "-----------------------------------------------------\n";

if ($command eq $com1) { ($login, $pwd) = split(":", $stream) }
if ($command eq $com2) { ($login, $pwd) = split(":", $stream) }
if ($command eq $com3) { ($login, $pwd) = split(":", $lp) }
if ($pwd eq "" and $login eq "") { $pwd = "admin" }
if ($login eq "") { $login = "admin" }
$passwd = $pwd;
$pref = "";

if ($command ne $com1 and $command ne $com2 and $command ne $com3) { print "ONVIF Camera Info Ver. 1.0\nUsage:\nonvif $com1 host[:port] [user:password]\nonvif $com3 host[:port] [profile] [user:password]\nonvif $com2 host[:port] [user:password]\nDefault user:password = admin:admin\n"; exit(0); }

$date = time();
$tz = 3;
$date = $date - ($tz * 3600);
$date=Time::Piece -> new($date);
$date = $date -> strftime ( "%Y-%m-%dT%H:%M:%SZ" ),"\n";

@set = ('0' .. '9', 'A' .. 'Z', 'a' .. 'z');
$non = join '' => map $set[rand @set], 1 .. 32;
substr($digest = encode_base64(sha1(sprintf("%s%s%s", decode_base64($non), $date, $pwd))), -1) = "";
($host, $port) = split(":", $host);
if ($port eq "") {$port = "80"}
$iaddr = inet_aton($host);
$paddr = sockaddr_in($port, $iaddr);

$upwd = "<Password Type=\"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordDigest\">$digest</Password>";

@onvr[0] = "http://www.onvif.org/ver10/device/wsdl/GetSystemDateAndTime";
@onvr[1] = "<GetSystemDateAndTime xmlns=\"http://www.onvif.org/ver10/device/wsdl\"/>";
@onvr[2] = "onvif/device_service";
onvif();
if ($onv eq "") { print "Error: Not ONVIF port\n"; exit(0); }

if ($subcode eq "wsse:InvalidSecurity") 
    {
    print "Error: $reason\n";
    exit(0);
    }


($n, $udt2) = split("<tt:TZ>", $onv, 2); ($tz, $udt2) = split("</tt:TZ>", $udt2, 2);
($n, $udt2) = split("<tt:UTCDateTime>", $onv, 2); ($udt, $udt2) = split("</tt:UTCDateTime>", $udt2, 2);
($n, $ldt2) = split("<tt:LocalDateTime>", $onv, 2); ($ldt, $ldt2) = split("</tt:LocalDateTime>", $ldt2, 2);
($n, $udt1) = split("<tt:Hour>", $udt, 2); ($uh, $udt1) = split("</tt:Hour>", $udt1, 2);
($n, $udt1) = split("<tt:Minute>", $udt, 2); ($um, $udt1) = split("</tt:Minute>", $udt1, 2);
($n, $udt1) = split("<tt:Second>", $udt, 2); ($us, $udt1) = split("</tt:Second>", $udt1, 2);
($n, $udt1) = split("<tt:Year>", $udt, 2); ($uy, $udt1) = split("</tt:Year>", $udt1, 2);
($n, $udt1) = split("<tt:Month>", $udt, 2); ($umo, $udt1) = split("</tt:Month>", $udt1, 2);
($n, $udt1) = split("<tt:Day>", $udt, 2); ($ud, $udt1) = split("</tt:Day>", $udt1, 2);
($n, $ldt1) = split("<tt:Hour>", $ldt, 2); ($lh, $ldt1) = split("</tt:Hour>", $ldt1, 2);
($n, $ldt1) = split("<tt:Minute>", $ldt, 2); ($lm, $ldt1) = split("</tt:Minute>", $ldt1, 2);
($n, $ldt1) = split("<tt:Second>", $ldt, 2); ($ls, $ldt1) = split("</tt:Second>", $ldt1, 2);
($n, $ldt1) = split("<tt:Year>", $ldt, 2); ($ly, $ldt1) = split("</tt:Year>", $ldt1, 2);
($n, $ldt1) = split("<tt:Month>", $ldt, 2); ($lmo, $ldt1) = split("</tt:Month>", $ldt1, 2);
($n, $ldt1) = split("<tt:Day>", $ldt, 2); ($ld, $ldt1) = split("</tt:Day>", $ldt1, 2);
$udtime = sprintf("%02i:%02i:%02i  %02i.%02i.%04i", $uh, $um, $us, $ud, $umo, $uy);
$ldtime = sprintf("%02i:%02i:%02i  %02i.%02i.%04i", $lh, $lm, $ls, $ld, $lmo, $ly);

@onvr[0] = "http://www.onvif.org/ver10/device/wsdl/GetDeviceInformation";
@onvr[1] = "<GetDeviceInformation xmlns=\"http://www.onvif.org/ver10/device/wsdl\"/>";
@onvr[2] = "onvif/device_service";
onvif();
($n, $inf) = split("<tds:Manufacturer>", $onv, 2); ($man, $inf) = split("</tds:Manufacturer>", $inf, 2);
($n, $inf) = split("<tds:Model>", $onv, 2); ($mod, $inf) = split("</tds:Model>", $inf, 2);
($n, $inf) = split("<tds:FirmwareVersion>", $onv, 2); ($fw, $inf) = split("</tds:FirmwareVersion>", $inf, 2);
($n, $inf) = split("<tds:SerialNumber>", $onv, 2); ($sn, $inf) = split("</tds:SerialNumber>", $inf, 2);
($n, $inf) = split("<tds:HardwareId>", $onv, 2); ($hw, $inf) = split("</tds:HardwareId>", $inf, 2);

if ($subcode eq "ter:NotAuthorized") { print "Error: $reason\n"; exit(0); }

print "Camera Info:\n";
print "$hr";
if ($man ne "" ) { print "Manufacer                     :  $man\n"; }
if ($mod ne "" ) { print "Model                         :  $mod\n"; }
if ($fw ne "" ) { print "Firmware Ver.                 :  $fw\n"; }
if ($sn ne "" ) { print "Serial Number                 :  $sn\n"; }
if ($hw ne "" ) { print "Hardware                      :  $hw\n"; }
if ($udtime ne "00:00:00  00.00.0000" ) { print "UTC Time/Date                 :  $udtime\n"; }
if ($ldtime ne "00:00:00  00.00.0000" ) { print "Local Time/Date               :  $ldtime\n"; }
if ($tz ne "" ) { print "Timezone                      :  $tz\n"; }


$onv = "";
@onvr[0] = "http://www.onvif.org/ver10/device/wsdl/GetCapabilities";
@onvr[1] = "<GetCapabilities xmlns=\"http://www.onvif.org/ver10/device/wsdl\"/>";
@onvr[2] = "onvif/device_service";
onvif();
($n, $device) = split ("<tt:Device>", $onv, 2); ($device) = split ("</tt:Device>", $device);
($n, $daddr) = split ("<tt:XAddr>", $device, 2); ($daddr) = split ("</tt:XAddr>", $daddr);
($n, $media) = split ("<tt:Media>", $onv, 2); ($media) = split ("</tt:Media>", $media);
($n, $maddr) = split ("<tt:XAddr>", $media, 2); ($maddr) = split ("</tt:XAddr>", $maddr);
($n, $img) = split ("<tt:Imaging>", $onv, 2); ($img) = split ("</tt:Imaging>", $img);
($n, $iaddr) = split ("<tt:XAddr>", $img, 2); ($iaddr) = split ("</tt:XAddr>", $iaddr);
($n, $io) = split ("<tt:DeviceIO>", $onv, 2); ($io) = split ("</tt:DeviceIO>", $io);
($n, $ioaddr) = split ("<tt:XAddr>", $io, 2); ($ioaddr) = split ("</tt:XAddr>", $ioaddr);
($n, $n, $n, $daddr) = split("/", $daddr, 4);
($n, $n, $n, $maddr) = split("/", $maddr, 4);
($n, $n, $n, $iaddr) = split("/", $iaddr, 4);
($n, $n, $n, $ioaddr) = split("/", $ioaddr, 4);

$am = "Digest";
@onvr[0] = "http://www.onvif.org/ver10/media/wsdl/GetProfiles";
@onvr[1] = "<GetProfiles xmlns=\"http://www.onvif.org/ver10/media/wsdl\"/>";
@onvr[2] = "$maddr";
onvif();

if ($subcode eq "ter:NotAuthorized") 
    {
    $upwd = "<Password Type=\"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#UserPassword\">$pwd</Password>";
    @onvr[0] = "http://www.onvif.org/ver10/media/wsdl/GetProfiles";
    @onvr[1] = "<GetProfiles xmlns=\"http://www.onvif.org/ver10/media/wsdl\"/>";
    @onvr[2] = "$maddr";
    onvif();
    if ($subcode eq "ter:NotAuthorized") { print "Error: $reason\n"; exit(0); }
    $am = "UserPassword";
    }
$c1 = "0";
$onv1 = $onv;

while ($onv1 ne "")
{
    ($n, $onv1) = split ("<tt:VideoEncoderConfiguration", $onv1, 2); ($ve, $onv1) = split ("</tt:VideoEncoderConfiguration>", $onv1, 2);
    ($n, $tok) = split ("token=\"", $ve, 2); ($tok) = split ("\"", $tok);
    ($n, $enc) = split ("<tt:Encoding>", $ve, 2); ($enc) = split ("</tt:Encoding>", $enc);
    ($n, $wd) = split ("<tt:Width>", $ve, 2); ($wd) = split ("</tt:Width>", $wd);
    ($n, $he) = split ("<tt:Height>", $ve, 2); ($he) = split ("</tt:Height>", $he);
    ($n, $brate) = split ("<tt:BitrateLimit>", $ve, 2); ($brate) = split ("</tt:BitrateLimit>", $brate);
    ($n, $frate) = split ("<tt:FrameRateLimit>", $ve, 2); ($frate) = split ("</tt:FrameRateLimit>", $frate);
    ($n, $frame) = split ("<tt:EncodingInterval>", $ve, 2); ($frame) = split ("</tt:EncodingInterval>", $frame);
    ($n, $frame1) = split ("<tt:GovLength>", $ve, 2); ($frame1) = split ("</tt:GovLength>", $frame1);
    if ($frame < "3" and $frame1 > "1") { $frame = $frame1; }
    $enc = sprintf(" %-29s:  Resolution: %sx%s; Bitrate: %s kbit/s; Framerate: %s fps; I-Frame: %s", $enc, $wd, $he, $brate, $frate, $frame);
    @pp2[$c1] = $enc;
    $c1++;
}

print "Auth Method                   :  $am\n";
print "$hr";

$c1 = "0";
while ($onv ne "")
{
    ($n, $onv) = split ("<trt:Profiles", $onv, 2); ($trt, $onv) = split ("</trt:Profiles>", $onv, 2);
    ($n, $tok) = split ("token=\"", $trt, 2); ($tok) = split ("\"", $tok);
    ($n, $tname) = split ("<tt:Name>", $trt, 2); ($tname) = split ("</tt:Name>", $tname);
    @pp[$c1] = $tok; @pp1[$c1] = $tname;
    $c1++;
}

if ($command eq $com3 and $stream eq "") { $stream = @pp1[0]; }

$c = "0";
if ($command eq $com1) {
    while ($c ne $c1-1) {
        @onvr[0] = "http://www.onvif.org/ver10/media/wsdl/GetSnapshotUri";
        @onvr[1] = "<GetSnapshotUri xmlns=\"http://www.onvif.org/ver10/media/wsdl\"><ProfileToken>@pp[$c]</ProfileToken></GetSnapshotUri>";
        @onvr[2] = "$iaddr";
        onvif();
        ($n, $onv) = split("<tt:Uri>", $onv, 2); ($snap, $onv) = split("</tt:Uri>", $onv, 2);
        $snap =~ s/&amp;/&/g;
        if ($command eq $com1 and $snap ne "") { $ss = sprintf("Snapshot: %-20s:  %s", @pp1[$c], $snap); print "$ss\n"; }
        $c++;
    }
}

$c = "0";
while ($c ne $c1-1) {
    @onvr[0] = "http://www.onvif.org/ver10/device/wsdl/GetStreamUri";
    @onvr[1] = "<media:GetStreamUri><media:StreamSetup><tt:Stream>RTP-Unicast</tt:Stream><tt:Transport><tt:Protocol>RTSP</tt:Protocol></tt:Transport></media:StreamSetup><media:ProfileToken>@pp[$c]</media:ProfileToken></media:GetStreamUri>";
    @onvr[2] = "$maddr";
    onvif();
    ($n, $p) = split ("<tt:Uri>", $onv); ($p, $n) = split ("</tt:Uri>", $p);
    $p =~ s/&amp;/&/g;
    $p =~ s/\?ptype\=tcp/\?/;
    if ($command eq $com2) { print "@pp1[$c]\n"; }
    if ($p ne "" and $command eq $com1) 
	{
        $pp1 = sprintf("%-30s", @pp1[$c]);
	print "$pp1:  $p\n@pp2[$c]\n";
	}
    if (@pp1[$c] eq $stream and $command eq $com3) 
	{ 
	if ($p eq "") { print "No stream found for $stream\n"; exit(0); }
	($n, $p) = split("//", $p);
	$p = sprintf("rtsp://%s:%s@%s", $login, $passwd, $p);
	print "Playing stream                :  $stream\n@pp2[$c]\n";
	system ("ffplay -hide_banner -loglevel error \"$p\""); exit(0); 
	}
    $c++;
}
if ($command eq $com3) { print "No stream found for $stream\n"; exit(0); }

sub onvif {
    $reason = "";
    $str0 = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>
  <s:Envelope xmlns:s=\"http://www.w3.org/2003/05/soap-envelope\" xmlns:tt=\"http://www.onvif.org/ver10/schema\" xmlns:media=\"http://www.onvif.org/ver10/media/wsdl\">
    <s:Header>
      <Security s:mustUnderstand=\"1\" xmlns=\"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd\">
        <UsernameToken>
          <Username>$login</Username>
          $upwd
          <Nonce EncodingType=\"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-soap-message-security-1.0#Base64Binary\">$non</Nonce>
          <Created xmlns=\"http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd\">$date</Created>
        </UsernameToken>
      </Security>
    </s:Header>
    <s:Body xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www.w3.org/2001/XMLSchema\">
      @onvr[1]
    </s:Body>
  </s:Envelope>";
    my $l = length($str0);
    $str1 = "POST /@onvr[2] HTTP/1.1\r\nHost: $host:$port\r\nUser-Agent: IpcamInfo/Utils\r\nAccept: */*\r\nConnection: Close\r\nContent-Type: application/soap+xml; charset=utf-8; action=\"@onvr[0]\"\r\nContent-Length: $l\r\n\r\n";
    my @data;
    socket(SOCK, PF_INET, SOCK_STREAM, getprotobyname('tcp'));
    connect(SOCK, $paddr) or die "Error: $!\n";
    send (SOCK, $str1, 0);
    send (SOCK, $str0, 0);
    @data=<SOCK>;
    close (SOCK);
    $onv = "";
    $c0 = "0";
    ($n, $httpcode) = split(" ", @data[0]);
#    if ($httpcode eq "404") {print "ONVIF Error 404: http://$host:$port/@onvr[2]\n";}
    while (@data[$c0] ne "") { $onv = sprintf ("%s%s", $onv, @data[$c0]); $c0++; }
    ($n, $onv) = split(/<\S+:Envelope/, $onv, 2); #($onv) = split(/<\/\S+:Envelope>/, $onv, 1);
    ($n, $re) = split("<*:Reason>", $onv, 2); ($re) = split(/<\/\S+:Reason/, $re);
    ($n, $reason) = split (">", $re, 2); ($reason) = split("<", $reason);
    ($n, $re) = split("<*:Subcode>", $onv, 2); ($re) = split(/<\/\S+:Subcode/, $re);
    ($n, $subcode) = split ("<*:Value>", $re, 2); ($subcode) = split(/<\/\S+:Value/, $subcode);
    if ($subcode eq "wsse:InvalidSecurity") {$subcode = "ter:NotAuthorized"; }
}