CPAN::Groonga

package Mojo::Webqq::Plugin::RikkaGCM;
our $AUTHOR = 'shizuku@shizuku.moe';
our $SITE = '';
our $DESC = '';
our $PRIORITY = 97;
use List::Util qw(first);
sub call {
    my $client = shift;
    my $data  = shift;
    $client->load("UploadQRcode") if !$client->is_load_plugin('UploadQRcode');
    my $api_url = $data->{api_url};
    my $api_key = $data->{api_key} or $client->die("[".__PACKAGE__."]必须指定api_key");
    my $collapse_key = $data->{collapse_key};
    my $registration_ids = $data->{registration_ids} // [];
    if(ref $registration_ids ne 'ARRAY' or @{$registration_ids} == 0){
        $client->die("[".__PACKAGE__."]registration_ids无效");
    }
    $client->on(receive_message=>sub{
        my($client,$msg) = @_;
        my $type = 'Mojo-Webqq';
        my $msgId;
        my $senderId;
        my $title;
        my $sender;
        my $content;
        my $senderType;
        my $isAt = 0;
        my $seuid = 0;
        if($msg->is_at) {
            $isAt=1;
        }
        if($msg->type eq 'friend_message'){
            $senderId = $msg->sender->id;
            $uid = $msg->sender->uid;
            $msgId = $msg->id;
            $title = $msg->sender->displayname;
            $sender = $msg->sender->displayname;
            $content = $msg->content;
            $senderType = '1';
        }
        elsif($msg->type eq 'group_message'){
            if(!$isAt) {
                return if ref $data->{ban_group} eq "ARRAY" and @{$data->{ban_group}} and first {$_=~/^\d+$/?$msg->group->uid eq $_:$msg->group->displayname eq $_} @{$data->{ban_group}};
                return if ref $data->{allow_group} eq "ARRAY" and  @{$data->{allow_group}} and !first {$_=~/^\d+$/?$msg->group->uid eq $_:$msg->group->displayname eq $_} @{$data->{allow_group}};
            }
            $senderId = $msg->group->id;
            $uid = $msg->group->uid;
            $msgId = $msg->id;
            $title = $msg->group->displayname;
            $sender = $msg->sender->displayname;
            $content = $msg->content;
            $senderType = '2';
        }
        elsif($msg->type eq 'discuss_message'){
            return if ref $data->{ban_discuss} eq "ARRAY" and @{$data->{ban_discuss}} and first {$_=~/^\d+$/?$msg->discuss->uid eq $_:$msg->discuss->displayname eq $_} @{$data->{ban_discuss}};
            return if ref $data->{allow_discuss} eq "ARRAY" and @{$data->{allow_discuss}} and !first {$_=~/^\d+$/?$msg->discuss->uid eq $_:$msg->discuss->displayname eq $_} @{$data->{allow_discuss}};
            $senderId = $msg->discuss->id;
            $uid = $msg->discuss->id;
            $msgId= $msg->id;
            $title = $msg->discuss->displayname;
            $sender = $msg->sender->displayname;
            $content = $msg->content;
            $senderType = '3';
        }
        elsif($msg->type eq 'sess_message'){
            
        }
        return if !$title or !$content;
        $client->http_post($api_url, 
            {'Authorization'=>"key=$api_key",json=>1},
            json=>{
                registration_ids=> $registration_ids,
                $collapse_key?(collapse_key=> $collapse_key):(),
                priority=> $data->{priority} // 'high',
                data=>{isAt=>$isAt,type=>$type,title=>$title,sender=>$sender,content=>$content,uid=>$uid,senderId=>$senderId,msgId=>$msgId,senderType=>$senderType},
            },
            sub{
                #"{"multicast_id":9016211065189210367,"success":1,"failure":0,"canonical_ids":0,"results":[{"message_id":"0:1484103730761325%9b9e6c13f9fd7ecd"}]}"
                my $json = shift;
                if(not defined $json){
                    $client->debug("[".__PACKAGE__."]GCM消息推送失败: 返回结果异常");
                    return;
                }
                else{
                    $client->debug("[".__PACKAGE__."]GCM消息推送完成：$json->{multicast_id}/$json->{success}/$json->{failure}");
                }
            }
        );
    });

    $client->on(all_event => sub{
        my($client,$event,@args) =@_;
        my $type = 'Mojo-Sys';
        my $content;
        my $senderId = -1;
        my $title;
        if($event eq 'login'){
            $senderId = -1;
            $content = "登录成功";
            $title = "登录事件";
        }
        elsif($event eq 'input_qrcode'){
            $senderId = -2;
            $content = $client->qrcode_upload_url // '获取二维码url失败';
            $title = "扫描二维码事件";
        }
        elsif($event eq 'stop'){
            $senderId = -3;
            $content = "Mojo-Webqq已停止";
            $title = "停止事件";
        }
        else{return}
        $client->http_post($api_url,
            {
                'Authorization'=>"key=$api_key",
                json=>1,
                blocking=>1,
                ua_connect_timeout=>5,
                ua_request_timeout=>5,
                ua_inactivity_timeout=>5,
                ua_retry_times=>1
            },
            json=>{
                registration_ids=> $registration_ids,
                $collapse_key?(collapse_key=> $collapse_key):(),
                priority=> $data->{priority} // 'high',
                data=>{type=>$type,title=>$title,content=>$content,senderId=>$senderId},
            },
            sub{
                my $json = shift;
                if(not defined $json){
                    $client->debug("[".__PACKAGE__."]GCM消息推送失败: 返回结果异常");
                    return;
                }
                else{
                    $client->debug("[".__PACKAGE__."]GCM消息推送完成：$json->{multicast_id}/$json->{success}/$json->{failure}");
                }
            }
        ); 
    });
}
1;