JavaScript SDK Reference

import {
  BaseNode,
  NodeInput,
  NodeOutput,
  NodeError,
  ErrorCode,
  NodeServer,
} from '@flowdsl/sdk'

abstract class BaseNode {
  abstract operationId: string

  async init(settings: Record<string, unknown>): Promise<void> {}

  abstract handle(input: NodeInput): Promise<NodeOutput>
}

interface NodeInput {
  packet(portName: string): Promise<Packet>
  context: ExecutionContext
}

interface Packet {
  data: Record<string, unknown>
  get(key: string, defaultValue?: unknown): unknown
  getString(key: string, defaultValue?: string): string
  getNumber(key: string, defaultValue?: number): number
  getBoolean(key: string, defaultValue?: boolean): boolean
  has(key: string): boolean
}

class NodeOutput {
  send(portName: string, data: Record<string, unknown> | Packet): NodeOutput
}

import { BaseNode, NodeInput, NodeOutput, NodeError, ErrorCode, NodeServer } from '@flowdsl/sdk'

class FilterNode extends BaseNode {
  operationId = 'filter_by_priority'
  private urgentPriorities = new Set(['P0', 'P1'])

  async init(settings: Record<string, unknown>): Promise<void> {
    const priorities = settings.urgentPriorities as string[] | undefined
    if (priorities) {
      this.urgentPriorities = new Set(priorities)
    }
  }

  async handle(input: NodeInput): Promise<NodeOutput> {
    const payload = await input.packet('in')
    const priority = payload.getString('priority', 'P2')

    if (this.urgentPriorities.has(priority)) {
      return new NodeOutput().send('urgent_out', payload.data)
    }
    return new NodeOutput().send('normal_out', payload.data)
  }
}

const server = new NodeServer({
  port: 8080,
  manifestFile: 'flowdsl-node.json',
})
server.register(new FilterNode())
server.listen()