import { createInterface } from 'readline'
import { Client, createClient } from 'minecraft-protocol'

import { attachForge } from './forge'
import { attachEvents } from './event'

let readUserInfo = process.argv[2] || 'Mr_jtb'
let realUserInfo = readUserInfo.split(":")
let username = realUserInfo[0]
let password = realUserInfo[1] || ''
let version = process.argv[3] || '1.12.2'
let readAddress = process.argv[4] || '192.168.2.25:25565'
let realAddress = readAddress.split(":")
let address = realAddress[0]
let port = parseInt(realAddress[1] || "25565")
let client = commandLineCreateClient()

function commandLineCreateClient() {
    return createConnection(address, port, username, password)
}

function createConnection(host: string, port: number, username: string, password: string) {
    let clientOptions: any = {
        version,
        host,
        port,
        username,
        password,
        // clientToken: 'd02c7f39-2376-45da-a5a5-50e24fa8b185',
        //@ts-ignore
        // authServer: 'https://skin.yumc.pw/api/yggdrasil/authserver',
        // sessionServer: 'https://skin.yumc.pw/api/yggdrasil/sessionserver'
    }
    if (clientOptions.password) {
        clientOptions.clientToken = 'd02c7f39-2376-45da-a5a5-50e24fa8b185'
        clientOptions.authServer = 'https://skin.yumc.pw/api/yggdrasil/authserver'
        clientOptions.sessionServer = 'https://skin.yumc.pw/api/yggdrasil/sessionserver'
    }
    let client = createClient(clientOptions)

    attachCommon(client)
    attachForge(client)
    attachEvents(client)
    return client
}

function attachCommon(client: Client) {
    client.on('login', () => {
        // client.registerChannel('updater', ['string', []])
        // client.registerChannel('updater-enabled', ['string', []])
        // client.registerChannel('dragoncore', ['string', []])
        // client.registerChannel('dragoncore:main', ['string', []])
        client.on('REGISTER', (array) => {
            for (const channel of array) {
                client.on('channel', console.log)
            }
        })
        // client.on('dragoncore:main', (data) => {
        //     console.log(data)
        // })
    })
    client.on('custom_payload', (data) => {
        console.log('custom_payload' + JSON.stringify(data))
    })
    client.on('error', (error) => {
        console.log("Client Error", error)
    })
    client.on('end', (resone) => {
        console.log("Client End Resone:", resone)
        if (`${resone}` != "SocketClosed") {
            setTimeout(() => {
                client = commandLineCreateClient()
            }, 500)
        } else {
            process.exit(0)
        }
    })
}

const rl = createInterface({
    input: process.stdin,
    output: process.stdout,
    completer: (line, func) => {
        let args = line.split(' ')
        let comp = args[args.length - 1]
        client.once('tab_complete', (msg) => {
            let mcts = msg.matches.filter(s => s)
            func(null, [mcts, comp])
        })
        client.write('tab_complete', {
            text: line
        })
    },
    terminal: true,
    prompt: ''
})

rl.on('line', function (line) {
    switch (line) {
        case "":
            break
        case "eval":
            break
        case "write":
            break
        case "/respawn":
            client.write('client_command', { payload: 0 })
            break
        case "//reco":
            client.end("")
            client = commandLineCreateClient()
            break
        case "//quit":
            console.info('Disconnected')
            client.end("")
            break
        case "//end":
            console.info('Forcibly ended client')
            process.exit(0)
        default:
            client.write('chat', { message: line })
    }
    rl.prompt()
})