bluesky websocket firehose client for perl

bsky_wss.pl

#!/usr/bin/perl -w
use 5.12.0;
use strict;
use warnings;
use utf8;

use AnyEvent::WebSocket::Client;
use CBOR::XS;

my $derp = AE::cv;
my $cbor = CBOR::XS->new;
my $bsky_wss = "wss://bsky.network/xrpc/com.atproto.sync.subscribeRepos";

my $client = AnyEvent::WebSocket::Client->new;

$client->connect($bsky_wss)->cb(sub {
  our $input = eval { shift->recv };
    if($@) {
     warn $@;
    }

$input->on(each_message => sub {
  my ($con,$message) = (@_);
  my $body = $message->{'body'};
    if ( my $got = $cbor->incr_parse_multiple($body) ) {
          if ($got->{'blocks'}) {
                print $got->{'blocks'};
                
          }
      }
      });
});

$derp->recv;