import log from '../dxmodules/dxLogger.js'
import bus from '../dxmodules/dxEventBus.js'
import pool from '../dxmodules/dxWorkerPool.js'
import config from '../dxmodules/dxConfig.js'
import faceService from './service/faceService.js'
import mqttService from './service/mqttService.js'
import accessService from './service/accessService.js'
import nfcService from './service/nfcService.js'
import gpiokeyService from './service/gpiokeyService.js'
import configService from './service/configService.js'
import uartBleService from './service/uartBleService.js'
import uartCodeService from './service/uartCodeService.js'
import fingerService from './service/fingerService.js'
import driver from './driver.js'
import codeService from './service/codeService.js'


pool.callback((data) => {
    try {
        let topic = data.topic
        let msg = data.data
        switch (topic) {
            case "bleCallback":
                uartBleService.receiveMsg(msg)
                break;
            case "recognition":
                faceService.receiveMsg(msg)
                break;
            case driver.gpiokey.RECEIVE_MSG:
                gpiokeyService.receiveMsg(msg)
                break;
            case "setConfig":
                configService.configVerifyAndSave(msg)
                break;
            case "access":
                accessService.access(msg.data, msg.fileName, msg.similarity)
                break;
            case driver.nfc.NFC_CARD_RECEIVE:
            case driver.nfc.EID_RECEIVE:
                if (config.get('sys.nfc')) {
                    bus.fire("resetTimers")
                    nfcService.receiveMsg(msg)
                }
                break;
            case driver.mqtt.CONNECTED_CHANGED:
                // TODO 最好不要在services内直接bus.fire,尝试简化链路
                bus.fire("mqttStatus", msg)
                if (msg == "connected") {
                    mqttService.report()
                }
                break;
            case driver.mqtt.RECEIVE_MSG:
                mqttService.receiveMsg(msg)
                break;
            case driver.uartCode.RECEIVE_MSG:
                bus.fire("resetTimers")
                uartCodeService.receiveMsg(msg)
                break;
            case "code":
                codeService.code(msg)
                break;
            case driver.finger.RECEIVE_MSG:
                bus.fire("resetTimers")
                fingerService.receiveMsg(msg)
                break;
            default:
                log.error("No such topic ", topic)
                break;
        }
    } catch (error) {
        log.error(error)
    }
})