#
# TCP listener socket
#
# by Andrew Hunter. All rights given away.
#

package tcpAccept;

use strict;
use Carp;
use Multiplex;
use Socket;

# Creates a new object. Call like this:
#
# tcpAccept->new(port => 5454), where port specifies the port you want to
# listen on
sub new
  {
    my $proto = shift;
    my $class = ref($proto) || $proto;
    my %args  = @_;
    my $self  = \%args;

    bless($self, $class);

    local *SOCKET;         # Filehandle for the socket we're going to create

    # Some error checking
    croak "You must give a port for the socket"
      if (!defined($self->{port}));

    # Create a TCP socket
    socket(SOCKET, PF_INET, SOCK_STREAM, getprotobyname('tcp'))
      or croak "socket: $!";
    # Set the 'REUSEADDR' option
    setsockopt(SOCKET, SOL_SOCKET, SO_REUSEADDR, pack("l", 1))
      or croak "setsockopt: $!";
    # Bind to the port specified
    bind(SOCKET, sockaddr_in($self->{port}, INADDR_ANY))
      or croak "bind: $!";
    # Listen to the socket
    listen(SOCKET, SOMAXCONN)
      or croak "listen: $!";

    # Store the socket filehandle away for future reference
    $self->{_FILE} = *SOCKET;
    
    return $self;
  }

# file() function, as defined by the Multiplex module
sub file
  {
    my ($self) = @_;

    return $self->{_FILE};
  }

# receive() function, as defined by the Multiplex module
sub receive
  {
    my ($self) = @_;
    my $client;

    {
      local(*CLIENT);          # The client socket we will create
      
      # Accept the connection that is waiting
      accept(CLIENT, $self->{_FILE})
	or die "accept: $!";

      $client = *CLIENT;
    }
      
    # Report the accepted socket
    $self->accepted($client);
  }

# Override this with your own function
sub accepted
  {
    my ($self, $client) = @_;

    # Display a silly message and close the socket
    syswrite $client, "Implement me\n", length("Implement me\n");
    close $client;
  }

# ==
return 1;