import { cloneDeep } from 'lodash-es'
import { LineConfig } from '.'
import { ModeEnum } from '@/enums/modeEnum'
import type { ComponentConfigModuleType, CreateComponentParamsType, CreateComponentType } from '@/core/Library/types'
import type { HistorySubscriptionCmd } from '@/core/websocket/telemetry'
import { TelemetrySubscriber } from '@/core/websocket/telemetry'
import { EntityType } from '@/core/websocket/enum'
import { DataSourceTypeEnum, SocketSubscriberEnum } from '@/enums/datasource'

export const options = {

}

export default class Config implements CreateComponentType {
  public key: string = LineConfig.key

  public presetOption = cloneDeep(options)

  public mode = ModeEnum.EDIT

  public category = LineConfig.category

  constructor(params: CreateComponentParamsType = {} as CreateComponentParamsType) {
    type Keys = keyof CreateComponentParamsType
    const keys = Object.keys(params) as Keys[]

    for (const key of keys)
      ((this as CreateComponentParamsType)[key] as CreateComponentParamsType[typeof key]) = params[key]
  }
}

export const dataSubscribers: ComponentConfigModuleType['dataSubscribers'] = (telemetryService, nodeData) => {
  const { dataSourceJson, configurationNodeId } = nodeData
  const { deviceId, attr, chartOption } = dataSourceJson
  const { agg, interval, effectScope = 0, queryType } = chartOption!

  let subscribe
  if (queryType === SocketSubscriberEnum.HISTORY_CMDS)
    subscribe = TelemetrySubscriber.createHistorySubscription(telemetryService, { id: deviceId, entityType: EntityType.DEVICE }, attr, telemetryService.getCommandSource(configurationNodeId, DataSourceTypeEnum.DATASOURCE, dataSourceJson))
  else
    subscribe = TelemetrySubscriber.createTimeseriesSubscription(telemetryService, { id: deviceId, entityType: EntityType.DEVICE }, attr, telemetryService.getCommandSource(configurationNodeId, DataSourceTypeEnum.DATASOURCE, dataSourceJson))

  const subscriptionCommand = subscribe.subscriptionCommand as HistorySubscriptionCmd
  subscriptionCommand.agg = agg
  subscriptionCommand.interval = interval

  if (queryType === SocketSubscriberEnum.HISTORY_CMDS) {
    subscriptionCommand.startTs = Date.now() - effectScope
    subscriptionCommand.endTs = Date.now()
  }

  return [subscribe]
}