package Net::OSCAR::Callbacks;
BEGIN {
  $Net::OSCAR::Callbacks::VERSION = '1.928';
}
use strict;
use warnings;
use vars qw($connection $snac $conntype $family $subtype $data $reqid $reqdata $session $protobit %data);
sub {

# It looks like we get a blank family if the server sends
# no migration families (full migration.)  Filter out
# this dummy entry.
my @migfamilies = grep { $_ != 0 } @{$data{families}};

$connection->log_print(OSCAR_DBG_WARN, "Migration families received: ", join(" ", @migfamilies));
$session->loglevel(10);

my $pause_queue;
if(@{$data{families}} == keys %{$connection->{families}} or @migfamilies == 0) {
	$connection->log_print(OSCAR_DBG_WARN, "Full migration, disconnecting...");
	$pause_queue = $connection->{pause_queue};

	# Don't let it think that we've lost the BOS connection
	my $conntype = $connection->{conntype};
	$connection->{conntype} = -1 if $connection->{conntype} == CONNTYPE_BOS;
	$session->delconn($connection);
	$connection->{conntype} = $conntype;

	$session->log_print(OSCAR_DBG_WARN, "Disconnected.");
} else {
	$connection->log_print(OSCAR_DBG_WARN, "Partial migration");

	# Get the list of families which aren't being migrated
	my @all_families = keys %{$connection->{families}};
	$connection->{families} = {};
	foreach my $fam (@all_families) {
		next if grep { $_ == $fam } @migfamilies;
		$connection->{families}->{$fam} = 1;
	}

	# Filter the pause queue according to the migration split
	my $all_pause_queue = $connection->{pause_queue};
	$connection->{pause_queue} = [];
	foreach my $item (@$all_pause_queue) {
		if(grep { $item->{family} == $_ } @migfamilies) {
			push @$pause_queue, $item;
		} else {
			push @{$connection->{pause_queue}}, $item;
		}
	}

	$connection->log_printf(OSCAR_DBG_WARN, "Migration pause queue: %d/%d", @{$pause_queue || []}, @{$connection->{pause_queue} || []});
}

$session->log_print(OSCAR_DBG_WARN, "Creating new connection");
my $newconn = $session->addconn(
	auth => $data{cookie},
	conntype => $connection->{conntype},
	description => $connection->{description},
	peer => $data{peer},
	paused => 1,
	pause_queue => $pause_queue
);
$session->log_print(OSCAR_DBG_WARN, "Created.");

};