#!/usr/bin/perl

use strict;
use warnings;
use Async::Tiny;
use Path::Tiny;

use constant PORT1 => 5000;
my $connID;

my $t = Async::Tiny->new;
$t->addListenCallback( PORT1, sub
  {
  my $sock = shift;
  $t->addReadCallback($sock, \&process_message, $sock->peerhost, ++$connID);
  $t->changeReadMode($sock, 'full');
  });
$t->eventloop;

sub process_message
  {
  my ($data, $peerhost, $id) = @_;
  my $filename = "rcv_${id}_$peerhost.txt";
  path($filename)->spew_raw($data);
  print "[save process_message] wrote $filename\n";
  }