import { TestWorkflowData } from './test-workflow-data'
import { injectable, inject } from 'inversify'
import { BUS_SYMBOLS, Bus } from '@node-ts/bus-core'
import { TestCommand } from './test-command'
import { RunTask } from './run-task'
import { TaskRan } from './task-ran'
import { Workflow, StartedBy, Handles } from '@node-ts/bus-workflow'

@injectable()
export class TestWorkflow extends Workflow<TestWorkflowData> {

  constructor (
    @inject(BUS_SYMBOLS.Bus) private readonly bus: Bus
  ) {
    super()
  }

  @StartedBy<TestCommand, TestWorkflowData, 'handleTestCommand'>(TestCommand)
  async handleTestCommand (command: TestCommand): Promise<TestWorkflowData> {
    await this.bus.send(new RunTask(command.property1!))
    return Object.assign(
      new TestWorkflowData(),
      { property1: command.property1! }
    )
  }

  @Handles<TaskRan, TestWorkflowData, 'handleTaskRan'>(TaskRan, event => event.value, 'property1')
  async handleTaskRan (event: TaskRan): Promise<Partial<TestWorkflowData>> {
    return this.complete({
      eventValue: event.value
    })
  }

}