p3xr.ng.factory('p3xrSocket', function ($rootScope, p3xrCommon, $state) {

    // socket.io now auto-configures its connection when we ommit a connection url
    const ioOptions = {
        rejectUnauthorized: false,
        path: '/socket.io',
       // transports: ['websocket'],
        secure: true,
    }

    if (global.p3xrDevMode === true ) {
        ioOptions.transports = ['websocket']
    }

    /*
    // on reconnection, reset the transports option, as the Websocket
    // connection may have failed (caused by proxy, firewall, browser, ...)
    // https://socket.io/docs/client-api/
    ioClient.on('reconnect_attempt', () => {
      ioClient.io.opts.transports = ['polling', 'websocket'];
    });
     */

    const ioClient = io.connect(p3xr.api.host, ioOptions);
//console.warn(p3xr.api.host, ioOptions)
    let reconnect = false;
    ioClient.on('connect', async function () {
        if (reconnect) {
            console.log('p3xr-socket (socket) RE-connected', ioClient.id)
            //return;
        } else {
            console.log('p3xr-socket (socket) connected', ioClient.id)
        }
        reconnect = true;

    })

    ioClient.on('disconnect', function () {

        location.reload()
    })

    let donated = undefined
    ioClient.on('info-interval', (data) => {
        $rootScope.p3xr.state.donated = data.donated

        if (data.donated !== donated) {
            if (!global.p3xr.isBot()) {
                window['gtag']('config', p3xr.settings.googleAnalytics,
                    {
                        'page_path': p3xr.state.donated ? '/donated' : '/free'
                    }
                );
            }

            donated = data.donated
            $rootScope.$digest();
        }
    })

    let connectErrorWas = false
    const socketError = async function (error) {
        if (!connectErrorWas) {
            connectErrorWas = true;
            try {
                p3xrCommon.generalHandleError(error)

                $state.go('socketio-error', {
                    error: error
                })

                /*
                await p3xrCommon.confirm({
                    disableCancel: false,
                    message: p3xr.strings.confirm.socketioConnectError
                })
                location.reload()
                */
            } catch (e) {
                p3xrCommon.generalHandleError(e)
            }
        }
    }

    ioClient.on('error', socketError)

    ioClient.on('connect_error', socketError)

    ioClient.on('connections', (data) => {
        //console.log(data)
        if (!p3xrCommon.generalHandleError(data)) {
            p3xr.connectionsReset()
            return;
        }
        p3xr.state.connections = data.connections
        $rootScope.$digest()
    })

    ioClient.on('redis-disconnected', async (data) => {
        if ($rootScope.p3xr.state.connection !== undefined && $rootScope.p3xr.state.connection.id === data.connectionId) {
            $rootScope.p3xr.state.connection = undefined;

            if (data.status === 'error') {
                p3xrCommon.toast({
                    message: p3xr.strings.status.redisDisconnected(data)
                })
            } else if (data.status === 'code') {
                if (!p3xr.strings.code.hasOwnProperty(data.code)) {
                    p3xrCommon.toast({
                        message: `unknown redis disconnect code: ${data.code}`
                    })

                } else {
                    p3xrCommon.toast({
                        message: p3xr.strings.code[data.code]
                    })
                }
            }
            $state.go('main')

            try {
                await request({
                    action: 'trigger-redis-disconnect',
                    enableResponse: false,
                })
            } catch (e) {
                p3xrCommon.generalHandleError(e)
            }

            //$rootScope.$digest();
        }
    })

    ioClient.on('redis-status', (data) => {
        $rootScope.p3xr.state.redisConnections = data.redisConnections
        setTimeout(() => {
            $rootScope.$digest()
        })
    })


    let receivedVersion = false
    ioClient.on('configuration', (data) => {
        $rootScope.p3xr.state.cfg = data;
        if (p3xr.state.cfg.snapshot === true) {
            p3xr.state.version = 'SNAPSHOT'
        } else {
            p3xr.state.version = 'v' + p3xr.state.cfg.version
            if (!receivedVersion) {
                receivedVersion = true
                window['gtag']('config', p3xr.settings.googleAnalytics,
                    {
                        'page_path':  '/version/' + p3xr.state.version}
                );
            }
        }
        $rootScope.$digest();
    })

    ioClient.on('error', p3xrCommon.generalHandleError)

    const request = (options) => {

        if (!options.payload) {
            options.payload = {}
        }

        if (typeof $rootScope.p3xr.state.search === 'string' && $rootScope.p3xr.state.search.length > 0) {
            if ($rootScope.p3xr.settings.searchStartsWith) {
                options.payload.match = $rootScope.p3xr.state.search + '*';
            } else {
                options.payload.match = '*' + $rootScope.p3xr.state.search + '*';
            }
        }
        options.payload.maxKeys = parseInt(p3xr.settings.maxKeys)
        let {enableResponse} = options
        if (enableResponse !== false) {
            enableResponse = true
        }
        if (enableResponse) {
            return new Promise((resolve, reject) => {
                options.requestId = p3xr.nextId();
                const responseEvent = `p3xr-response-${options.requestId}`
                let timeout
                const response = (data) => {
                    clearTimeout(timeout)
                    //console.warn('data', data)
                    //console.trace('data', data)
                    ioClient.off(responseEvent)
                    if (data.status === 'ok') {
                        resolve(data)
                    } else {
                        const error = new Error(data.error)
                        //error.code = data.error.code
                        reject(error)
                    }
                    $rootScope.$digest()
                }

                timeout = setTimeout(() => {
                    ioClient.off(responseEvent, response)
                    reject(new Error(p3xr.strings.label.socketIoTimeout({
                        timeout: p3xr.settings.socket.timeout
                    })));
                    $rootScope.$digest()
                }, p3xr.settings.socket.timeout)

                ioClient.on(responseEvent, response)
                ioClient.emit('p3xr-request', options)
            })
        } else {
            ioClient.emit('p3xr-request', options)
        }
    }

    return {
        ioClient: ioClient,
        request: request,
    };
});