our $contacts;
our $muc_rooms;
-our $redis = MQR::Redis->redis;
-
sub publish;
-MQR::Redis->redis->psubscribe( "MSG $subscribe", sub {
+sub redis { MQR::Redis->redis }
+
+redis->psubscribe( "MSG $subscribe", sub {
my ( $body, $channel ) = @_;
warn "<<<< ", dump( $channel, $body );
Encode::_utf8_on($body);
}
}) if $subscribe;
-MQR::Redis->redis->psubscribe( "SEND $jid *", sub {
+redis->psubscribe( "SEND $jid *", sub {
my ( $body, $channel ) = @_;
warn "<<<< ",dump( $channel, $body );
Encode::_utf8_on($body);
my ($cl, $room, $msg, $is_echo) = @_;
my $room_jid = $room->nick_jid;
$muc_rooms->{ $room_jid }++;
- $redis->sadd( "presence/xmpp/muc $jid" => $room_jid );
+ redis->sadd( "presence/rooms $jid" => $room_jid );
warn "# MUC message ",dump( $room_jid, $msg->any_body, $is_echo );
return if $is_echo;
my ($con,$account,$roster) = @_;
warn "XXXXX", ref($account), " | ", ref($roster);
foreach my $contact ( $roster->get_contacts ) {
- $contacts->{ $contact->{jid} }++;
- $redis->sadd( "presence/xmpp/contacts $jid" => $contact->{jid} );
+ $contacts->{ $contact->jid }++;
+ redis->sadd( "presence/contacts $jid" => $contact->jid );
warn "# contacts ",dump($contacts);
}
warn "# contacts ",dump($contacts);