--- /dev/null
+# Copyright (c) 2010 Mathieu Parent <math.parent@gmail.com>.
+# All rights reserved. This program is free software; you can redistribute it
+# and/or modify it under the same terms as Perl itself.
+
+package Net::Skinny;
+
+use strict;
+use warnings;
+use IO::Socket;
+use Net::Skinny::Protocol qw/:all/;
+
+our(@ISA);
+@ISA = qw(IO::Socket::INET);
+
+sub new {
+ shift->SUPER::new(PeerPort => 2000, @_);
+}
+
+sub send_message
+{
+ my $self = shift;
+ my $type = shift;
+ my $data = shift;
+ my $len = length($data)+4;
+ printf "Sending message (length=%d, type=%s (%X))", $len, Net::Skinny::Protocol::skinny_message_type2str($type), $type;
+ $self->send(
+ pack("VVV", $len, 0, $type).
+ $data);
+ printf ".\n";
+}
+
+sub receive_message
+{
+ my $self = shift;
+ my $buf;
+ $self->recv($buf, 4);
+ my $len = unpack("V", $buf);
+ printf "Receiving message (length=%d,", $len;
+ if($len < 4) {
+ printf "type=?).\n";
+ printf "Problem! Length is < 4.\n";
+ exit 1;
+ }
+ $self->recv($buf, 4); #reserved
+ $self->recv($buf, 4); #type
+ my $type = unpack("V", $buf);
+ printf "type=%s (%X))", Net::Skinny::Protocol::skinny_message_type2str($type), $type;
+ if($len > 4) {
+ $self->recv($buf, $len-4);
+ }
+ printf ".\n";
+}
+
+sub sleep
+{
+ my $self = shift;
+ my $t = shift;
+
+ printf "Sleeping %d seconds", $t;
+ while(--$t){
+ sleep(1);
+ printf "." if $t % 10;
+ printf "_" unless $t % 10;
+ }
+ printf ".\n";
+}
+
+1;
--- /dev/null
+# Copyright (c) 2010 Mathieu Parent <math.parent@gmail.com>.
+# All rights reserved. This program is free software; you can redistribute it
+# and/or modify it under the same terms as Perl itself.
+
+package Net::Skinny::Protocol;
+
+use strict;
+no strict "refs";
+use warnings;
+use Carp;
+
+require Exporter;
+our @ISA = qw(Exporter);
+our @EXPORT = qw(skinny_message_type2str);
+
+my %const;
+my %sub;
+my $skinny_protocol_h = 'src/mod/endpoints/mod_skinny/skinny_protocol.h';
+
+sub import {
+ shift;
+ my $callpkg = caller(0);
+ _find(@_);
+ my $oops;
+ my $all = grep /:all/, @_;
+ foreach my $sym ($all ? keys %sub : @_) {
+ if (my $sub = $sub{$sym}) {
+ *{$callpkg . "::$sym"} = $sub;
+ }
+ else {
+ ++$oops;
+ carp(qq["$sym" is not exported by the Net::Skinny::Protocol module]);
+ }
+ }
+ croak("Can't continue after import errors") if $oops;
+}
+
+sub _find {
+ my $fh;
+ unless (open($fh, $skinny_protocol_h)) {
+ print STDERR "Can't open $skinny_protocol_h: $!\n";
+ return;
+ }
+ while(<$fh>) {
+ if( /^#define\s+([\w_]+)\s+(0x[0-9a-f]+)\s*$/i) {
+ my ($name, $value) = ($1,hex($2));
+ $sub{$name} = sub () { $value };
+ $const{$name} = $value;
+ }
+ }
+ @sub{@_};
+}
+
+sub skinny_message_type2str {
+ my $message_type = shift;
+
+ keys %const;
+ while (my ($key, $value) = each %const) {
+ if($value == $message_type) {
+ return $key;
+ }
+ }
+ return "UnknownMessage";
+}
#!/usr/bin/perl
+# Copyright (c) 2010 Mathieu Parent <math.parent@gmail.com>.
+# All rights reserved. This program is free software; you can redistribute it
+# and/or modify it under the same terms as Perl itself.
+
+BEGIN {
+ push @INC, 'src/mod/endpoints/mod_skinny';
+}
+
use strict;
use warnings;
-use IO::Socket;
+
+use Data::Dumper;
+use Net::Skinny;
+use Net::Skinny::Protocol qw/:all/;
#Config
my $skinny_server = '127.0.0.1';
#======
$| = 1;
-my $socket;
-
-sub skinny_connect
-{
- $socket = IO::Socket::INET->new(
+my $socket = Net::Skinny->new(
PeerAddr => $skinny_server,
PeerPort => 2000,
);
-}
-
-sub skinny_send
-{
- my $type = shift;
- my $data = shift;
- my $len = length($data)+4;
- printf "Sending message (length=%d, type=%X)", $len, $type;
- $socket->send(
- pack("VVV", $len, 0, $type).
- $data);
- printf ".\n";
-}
-sub skinny_recv
-{
- my $buf;
- $socket->recv($buf, 4);
- my $len = unpack("V", $buf);
- printf "Receiving message (length=%d,", $len;
- if($len < 4) {
- printf "type=?).\n";
- printf "Problem! Length is < 4.\n";
- exit 1;
- }
- $socket->recv($buf, 4); #reserved
- $socket->recv($buf, 4); #type
- my $type = unpack("V", $buf);
- printf "type=%X)", $type;
- if($len > 4) {
- $socket->recv($buf, $len-4);
- }
- printf ".\n";
+if(!$socket) {
+ print "Unable to connect to server\n";
+ exit 1;
}
-
-sub skinny_sleep
-{
- my $t = shift;
-
- printf "Sleeping %d seconds", $t;
- while(--$t){
- sleep(1);
- printf "." if $t % 10;
- printf "_" unless $t % 10;
- }
- printf ".\n";
-}
-
-# =============================================================================
-#
# =============================================================================
-skinny_connect();
-
-# =============================================================================
-skinny_send(0x0001, # Register
+$socket->send_message(REGISTER_MESSAGE, # Register
pack("a16VVVVV",
$device_name,
0, # userId;
7, # deviceType;
0, # maxStreams;
));
-skinny_recv(); # RegisterAck
+$socket->receive_message(); # RegisterAck
-skinny_send(0x0002, # Port
+$socket->send_message(0x0002, # Port
pack("n", 2000
));
-skinny_send(0x002b, # HeadSetStatus
+$socket->send_message(HEADSET_STATUS_MESSAGE,
pack("V",
2, # Off
));
-skinny_recv(); # CapabilitiesReq
-skinny_send(0x0010, # CapabilitiesRes
+$socket->receive_message(); # CapabilitiesReq
+$socket->send_message(CAPABILITIES_RES_MESSAGE,
pack("V"."Vva10"."Vva10",
2, # count
2, 8, "", # codec, frames, res
4, 16, "", # codec, frames, res
));
-skinny_send(0x000e, # ButtonTemplateReqMessage
- "");
-skinny_recv(); # ButtonTemplateMessage
+$socket->send_message(BUTTON_TEMPLATE_REQ_MESSAGE, "");
+$socket->receive_message(); # ButtonTemplateMessage
-skinny_send(0x0028, # SoftKeyTemplateReq
- "");
-skinny_recv(); # SoftKeyTemplateRes
+$socket->send_message(SOFT_KEY_TEMPLATE_REQ_MESSAGE, "");
+$socket->receive_message(); # SoftKeyTemplateRes
-skinny_send(0x0025, # SoftKeySetReq
- "");
-skinny_recv(); # SoftKeySetRes
+$socket->send_message(SOFT_KEY_SET_REQ_MESSAGE, "");
+$socket->receive_message(); # SoftKeySetRes
-skinny_send(0x000B, # LineStatReq
- pack("V", 1));
-skinny_recv(); # LineStat
+$socket->send_message(LINE_STAT_REQ_MESSAGE, pack("V", 1));
+$socket->receive_message(); # LineStat
-skinny_send(0x002D, # RegisterAvailableLines
- pack("V", 2
- ));
+$socket->send_message(REGISTER_AVAILABLE_LINES_MESSAGE, pack("V", 2));
while(1) {
- skinny_sleep(20);
- skinny_send(0x0000, # keepalive
- "");
- skinny_recv(); # keepaliveack
+ $socket->sleep(20);
+ $socket->send_message(KEEP_ALIVE_MESSAGE, "");
+ $socket->receive_message(); # keepaliveack
}
projects / thirdparty / freeswitch.git / commitdiff
