import { BaseContext } from './base-context.js'
import { ExportResult } from '@sentio/protos'
import { NamedResultDescriptor } from './metadata.js'
import { MapStateStorage } from '@sentio/runtime'

export type Export = Record<string, any>

export class ExporterState extends MapStateStorage<Exporter> {
  static INSTANCE = new ExporterState()
}

export class Exporter extends NamedResultDescriptor {
  static register(name: string, channel: string) {
    const exporter = new Exporter(name, channel)
    return ExporterState.INSTANCE.getOrSetValue(name, exporter)
  }

  channel: string
  protected constructor(name: string, channel: string) {
    super(name)
    this.channel = channel
  }

  emit(ctx: BaseContext, data: Export) {
    const res: ExportResult = {
      metadata: ctx.getMetaData(this.name, {}),
      payload: JSON.stringify(data),
      runtimeInfo: undefined,
    }
    ctx.update({ exports: [res] })
  }
}