viewvc.cgi/mdap/mdap-server.pl

#!/usr/bin/perl

use strict;
use IO::Socket::Multicast;
use Data::Dump qw/dump/;

use constant GROUP => '224.0.0.103';
use constant PORT  => '3235';

my $local_port = 1000;

my $resend_search_delay = 3;

my $sock = IO::Socket::Multicast->new(LocalPort=>PORT,ReuseAddr=>1);
$sock->mcast_add(GROUP) || die "Couldn't set group: $!\n";
$sock->mcast_ttl(1);

sub ant2hash {
        my $data = shift;
        my $hash;
        map {
                if ( m/:/ ) {
                        my ($n,$v) = split(/:/,$_,2);
                        $hash->{$n} = $v;
                }
        } split(/[\n\r]/, $data);
        return $hash;
}

sub mdap_send {
        my $data = shift;
        warn ">> $data\n>>----------\n";
        my $null = chr(0);
        $sock->mcast_send( "${data}", GROUP . ':' . PORT );
}

local $SIG{ALRM} = sub {
        mdap_send("ANT-SEARCH MDAP/1.1\r\n46");
        alarm( $resend_search_delay );
};

alarm( $resend_search_delay );

while (1) {
        my $data;
        next unless $sock->recv($data,1024);

        if ( $data =~ m#^(REPLY-\S+)\s(MDAP/\d+\.\d+)# ) {

                my ($type,$proto) = ($1,$2);

                my $h = ant2hash($data);

                print "# $type $proto ", dump( $h ), $/;

                if ($type eq 'REPLY-ANT-SEARCH') {
                        mdap_send("INFO MDAP/1.2
SEQ-NR:1
TO-ANT:0644JTHJ4
USER-ID:Administrator
USER-PWD:\r\n22");
                } elsif ($type eq 'REPLY-INFO') {
                        if (
                                $h->{'_BUILD'} eq '6.1.7.2' &&
                                $h->{'_BUILDNAME'} eq 'ZZO9AA6.172' &&
                                $h->{'_BUILDVARIANT'} eq 'AA' &&
                                1
                        ) {
                                mdap_send("EXEC-CLI MDAP/1.2
CLI-CMD:software upgrade
SEQ-NR:1
TO-ANT:0644JTHJ4
USER-ID:Administrator
USER-PWD:\r\n1F");
                        } else {

                        }

                        
                } else {
                        print "!! reply ignored\n";
                }

        } else {
                print $data, "\n", "-" x 30, "\n";
        }
}
1	#!/usr/bin/perl
2
3	use strict;
4	use IO::Socket::Multicast;
5	use Data::Dump qw/dump/;
6
7	use constant GROUP => '224.0.0.103';
8	use constant PORT => '3235';
9
10	my $local_port = 1000;
11
12	my $resend_search_delay = 3;
13
14	my $sock = IO::Socket::Multicast->new(LocalPort=>PORT,ReuseAddr=>1);
15	$sock->mcast_add(GROUP) \|\| die "Couldn't set group: $!\n";
16	$sock->mcast_ttl(1);
17
18	sub ant2hash {
19	my $data = shift;
20	my $hash;
21	map {
22	if ( m/:/ ) {
23	my ($n,$v) = split(/:/,$_,2);
24	$hash->{$n} = $v;
25	}
26	} split(/[\n\r]/, $data);
27	return $hash;
28	}
29
30	sub mdap_send {
31	my $data = shift;
32	warn ">> $data\n>>----------\n";
33	my $null = chr(0);
34	$sock->mcast_send( "${data}", GROUP . ':' . PORT );
35	}
36
37	local $SIG{ALRM} = sub {
38	mdap_send("ANT-SEARCH MDAP/1.1\r\n46");
39	alarm( $resend_search_delay );
40	};
41
42	alarm( $resend_search_delay );
43
44	while (1) {
45	my $data;
46	next unless $sock->recv($data,1024);
47
48	if ( $data =~ m#^(REPLY-\S+)\s(MDAP/\d+\.\d+)# ) {
49
50	my ($type,$proto) = ($1,$2);
51
52	my $h = ant2hash($data);
53
54	print "# $type $proto ", dump( $h ), $/;
55
56	if ($type eq 'REPLY-ANT-SEARCH') {
57	mdap_send("INFO MDAP/1.2
58	SEQ-NR:1
59	TO-ANT:0644JTHJ4
60	USER-ID:Administrator
61	USER-PWD:\r\n22");
62	} elsif ($type eq 'REPLY-INFO') {
63	if (
64	$h->{'_BUILD'} eq '6.1.7.2' &&
65	$h->{'_BUILDNAME'} eq 'ZZO9AA6.172' &&
66	$h->{'_BUILDVARIANT'} eq 'AA' &&
67	1
68	) {
69	mdap_send("EXEC-CLI MDAP/1.2
70	CLI-CMD:software upgrade
71	SEQ-NR:1
72	TO-ANT:0644JTHJ4
73	USER-ID:Administrator
74	USER-PWD:\r\n1F");
75	} else {
76
77	}
78
79
80	} else {
81	print "!! reply ignored\n";
82	}
83
84	} else {
85	print $data, "\n", "-" x 30, "\n";
86	}
87	}