Options
All
  • Public
  • Public/Protected
  • All
Menu

Class GoalExecutionRequestProcessor

Hierarchy

  • AbstractRequestProcessor
    • GoalExecutionRequestProcessor

Implements

  • RequestProcessor

Index

Constructors

Properties

Methods

Constructors

constructor

  • new GoalExecutionRequestProcessor(automations: AutomationServer, configuration: Configuration, listeners?: AutomationEventListener[]): GoalExecutionRequestProcessor

Properties

Protected automations

automations: AutomationServer

Protected configuration

configuration: Configuration

Private Readonly graphClients

graphClients: GraphClientFactory

Protected listeners

listeners: AutomationEventListener[]

Methods

Protected clearNamespace

  • clearNamespace(): void

Protected createAndWrapMessageClient

  • createAndWrapMessageClient(event: EventIncoming | CommandIncoming, context: HandlerContext & AutomationContextAware): MessageClient & SlackMessageClient

  • Parameters

    • event: EventIncoming | CommandIncoming
    • context: HandlerContext & AutomationContextAware

    Returns MessageClient & SlackMessageClient

Protected createGraphClient

  • createGraphClient(event: CommandIncoming | EventIncoming): GraphClient

Protected createMessageClient

  • createMessageClient(event: EventIncoming | CommandIncoming, context: AutomationContextAware): MessageClient

Protected invokeCommand

  • invokeCommand(ci: CommandInvocation, ctx: HandlerContext & AutomationContextAware, command: CommandIncoming, callback: (result: Promise<HandlerResult>) => void): void

  • Parameters

    • ci: CommandInvocation
    • ctx: HandlerContext & AutomationContextAware
    • command: CommandIncoming
    • callback: (result: Promise<HandlerResult>) => void
        • (result: Promise<HandlerResult>): void

        • Parameters

          Returns void

    Returns void

Protected invokeEvent

  • invokeEvent(ef: EventFired<any>, ctx: HandlerContext & AutomationContextAware, event: EventIncoming, callback: (results: Promise<HandlerResult[]>) => void): void

  • Parameters

    • ef: EventFired<any>
    • ctx: HandlerContext & AutomationContextAware
    • event: EventIncoming
    • callback: (results: Promise<HandlerResult[]>) => void
        • (results: Promise<HandlerResult[]>): void

        • Parameters

          • results: Promise<HandlerResult[]>

          Returns void

    Returns void

processCommand

  • processCommand(command: CommandIncoming, callback?: (result: Promise<HandlerResult>) => void): void

  • Parameters

    • command: CommandIncoming
    • Optional callback: (result: Promise<HandlerResult>) => void
        • (result: Promise<HandlerResult>): void

        • Parameters

          Returns void

    Returns void

processEvent

  • processEvent(event: EventIncoming, callback?: (results: Promise<HandlerResult[]>) => void): void

  • Parameters

    • event: EventIncoming
    • Optional callback: (results: Promise<HandlerResult[]>) => void
        • (results: Promise<HandlerResult[]>): void

        • Parameters

          • results: Promise<HandlerResult[]>

          Returns void

    Returns void

sendCommandStatus

  • sendCommandStatus(success: boolean, code: number, request: CommandIncoming, ctx: HandlerContext & AutomationContextAware): Promise<any>

  • Parameters

    • success: boolean
    • code: number
    • request: CommandIncoming
    • ctx: HandlerContext & AutomationContextAware

    Returns Promise<any>

sendEventStatus

  • sendEventStatus(success: boolean, request: EventFired<any>, event: EventIncoming, ctx: HandlerContext & AutomationContextAware): Promise<any>

  • Parameters

    • success: boolean
    • request: EventFired<any>
    • event: EventIncoming
    • ctx: HandlerContext & AutomationContextAware

    Returns Promise<any>

Protected sendStatusMessage

  • sendStatusMessage(payload: any, ctx: HandlerContext & AutomationContextAware): Promise<any>

Protected setupNamespace

  • setupNamespace(request: any, automations: AutomationServer, invocationId?: string, ts?: number): { correlationId: any; invocationId: string; name: string; operation: any; ts: number; version: string; workspaceId: any; workspaceName: any }

  • Parameters

    • request: any
    • automations: AutomationServer
    • Optional invocationId: string
    • Optional ts: number

    Returns { correlationId: any; invocationId: string; name: string; operation: any; ts: number; version: string; workspaceId: any; workspaceName: any }

    • correlationId: any
    • invocationId: string
    • name: string
    • operation: any
    • ts: number
    • version: string
    • workspaceId: any
    • workspaceName: any

Generated using TypeDoc