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

export const options = {

}

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

  public presetOption = cloneDeep(options)

  public mode = ModeEnum.EDIT

  public category = HistogramConfig.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 } = chartOption!
  const subscribe = TelemetrySubscriber.createHistorySubscription(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
  subscriptionCommand.startTs = Date.now() - effectScope
  subscriptionCommand.endTs = Date.now()

  return [subscribe]
}