@casual-simulation/causal-tree-server-socketio/SocketIOConnectionServer.js

import { deviceInfo, } from '@casual-simulation/causal-trees';
import { fromEventPattern } from 'rxjs';
import { map, shareReplay, flatMap, first, tap } from 'rxjs/operators';
export class SocketIOConnectionServer {
    get connection() {
        return this._connection;
    }
    constructor(socketServer) {
        // socketServer.on('connection', socket => {
        //     let listener = (token: DeviceToken) => {
        //         console.log(`[SocketIOConnectionServer] On Login!`);
        //         const info = deviceInfo(token.username, token.username, token.id);
        //         const conn = new SocketIOConnection(socket, info);
        //         socket.off('login', listener);
        //         socket.emi
        //         this._connection.next(conn);
        //     };
        //     socket.on('login', listener);
        // });
        const onConnection = fromEventPattern(h => socketServer.on('connection', h));
        const connections = onConnection.pipe(flatMap(s => this._login(s), (socket, info) => ({ info, socket })), map(({ info, socket }) => new SocketIOConnection(socket, info)), shareReplay());
        this._connection = connections;
    }
    _login(socket) {
        console.log(`[SocketIOConnectionServer] Waiting for login...`);
        const onLogin = fromEventPattern(h => socket.on('login', h), h => socket.off('login', h));
        return onLogin.pipe(tap(() => { }), map(token => deviceInfo(token.username, token.username, token.id)), tap(info => socket.emit('login_result', info)), first());
    }
}
export class SocketIOConnection {
    get device() {
        return this._device;
    }
    get disconnect() {
        return this._socketEvent('disconnect');
    }
    event(name) {
        return this._socketEvent(name);
    }
    send(name, data) {
        this._socket.emit(name, data);
    }
    constructor(socket, device) {
        this._socket = socket;
        this._device = device;
    }
    _socketEvent(name) {
        return fromEventPattern(h => this._socket.on(name, h), h => this._socket.off(name, h));
    }
}
//# sourceMappingURL=SocketIOConnectionServer.js.map