Subversion Repositories HomeAutomation

use IO::Select;

use IO::Socket;

sub atomd_connect

{

    ($host, $port) = @_;

    $socket = IO::Socket::INET->new(

            Proto    => "tcp",

            PeerAddr => $host,

            PeerPort => $port,

            Blocking => 1,

        )

        or die "Error: Cannot connect to port $port at $host\n";

    return $socket;

}

sub atomd_disconnect

{

    ($socket) = @_;

    close($socket);

}

# ----------------- Atom JS functions -----------------

sub atomjs_read_line

{

    ($socket) = @_;

    # read line

    defined( $result = <$socket> ) or die "Readline failed: $! \n";

    return $result;

}

sub atomjs_write

{

    ($socket, $command) = @_;

    print $socket $command;

}

#function atomjs_data_available($socket)

#{

#   $read   = array($socket);

#   $write  = NULL;

#   $except = NULL;

#   if (false === ($num_changed_streams = stream_select($read, $write, $except, 0)))

#   {

#       throw new Exception("could not do select on socket");

#   }

#   return $num_changed_streams > 0;

#}

# ----------------- Atomic functions -----------------

sub atomd_read_packet

{

    ($socket) = @_;

    $command="";

    read($socket, $command, 4);

    $payload_length="";

    read($socket, $payload_length, 4);

    $payload_length = int($payload_length);

    $payload="";

    if ($payload_length > 0)

    {

        read($socket, $payload, $payload_length-1);

    }

    #Pad payload length with 0s

    $payload_length = sprintf("%04d", $payload_length-1);

    #print "areadpacket ".$command . $payload_length . $payload."\n";

    return $command . $payload_length . $payload;

}

sub atomd_write_packet

{

    ($socket, $command, $payload) = @_;

    #Pad payload length with 0s

#   $payload_length = sprintf("%04d", length($payload)+1);

#   $packet = $command.$payload_length.$payload.chr(0);

    $payload_length = sprintf("%04d", length($payload));

    $packet = $command.$payload_length.$payload;

    #print "awritepacket ".$packet."\n";

    print $socket $packet;

}

sub atomd_data_available

{

    ($socket) = @_;

    $s = IO::Select->new();

    $s->add($socket);

    @handles = $s->can_read(0.005);

    $has_data = 0;

    if (@handles)

    {

        $has_data = 1;

    }

    return $has_data;

}

sub atomd_kill_promt

{

    ($socket) = @_;

    while (atomd_data_available($socket))

    {

        $packet = atomd_read_packet($socket); # Read prompt

    }

}

sub atomd_initialize

{

    ($host, $port) = @_;

    $socket = atomd_connect($host, $port);

    atomd_kill_promt($socket);

    return $socket;

}

sub atomd_send_command

{

    ($socket, $command) = @_;

    atomd_write_packet($socket, "RESP", $command);

}

sub atomd_read_command_response

{

    ($socket) = @_;

    $response = "";

    while (1)

    {

        $packet = atomd_read_packet($socket);

        if (substr($packet, 0, 4) ne "TEXT")

        {

            last;

        }

        $packet =~ s/\n//g;

#       $response .= substr($packet, 8, -1); 

        $response .= substr($packet, 8);

        $response .= "\n";

    }

    return $response;

}

# Perl trim function to remove whitespace from the start and end of the string

sub trim($)

{

    my $string = shift;

    $string =~ s/^\s+//;

    $string =~ s/\s+$//;

    return $string;

}

# Left trim function to remove leading whitespace

sub ltrim($)

{

    my $string = shift;

    $string =~ s/^\s+//;

    return $string;

}

# Right trim function to remove trailing whitespace

sub rtrim($)

{

    my $string = shift;

    $string =~ s/\s+$//;

    return $string;

}

# "return" 1 to not generate an error when loading file

1;