import _ from 'lodash';
import { MikudosSocketIoClient } from 'mikudos-socketio-client';

const client = new MikudosSocketIoClient(
    {
        uri: 'ws://localhost:3000'
    },
    { rpcEventName: 'rpc-call' }
);
client.chatEventEmitter.on('chat', data => {
    console.log('chat data:', data);
});
setTimeout(() => {
    client
        .authentication({
            strategy: 'local',
            email: '18534572861',
            password: 'qiushanyu666'
        })
        .then(res => {
            // console.log('TCL: res', res);
        })
        .catch(err => {
            console.log('TCL: err', err);
        });
}, 3000);
setInterval(() => {
    client
        .rpcCall({
            jsonrpc: '2.0',
            method: 'rpc_1.add',
            params: [1, 6],
            id: 4
        })
        .then(res => {
            console.log('TCL: res', res);
        })
        .catch(err => {
            console.log('TCL: err', err);
        });
}, 3000);

setInterval(() => {
    client
        .sendChat()
        .then(res => {
            console.log('TCL: res', res);
        })
        .catch(err => {
            console.log('TCL: err', err);
        });
}, 1000);
setTimeout(() => {
    client.joinChat();
}, 5000);

setTimeout(() => {
    client.leaveChat();
}, 15000);

client.socket.on('stream-call grpc1.test', (data: any) => {
    console.log('TCL: stream-call data', data);
});
setTimeout(() => {
    client.socket.emit(
        'stream-call',
        {
            method: 'grpc1.test',
            data: { test: 'test' }
        },
        (res: any) => {
            console.log('TCL: stream-call res', res);
        }
    );
}, 3000);