ExpressRequestProcessor | @atomist/automation-client

RequestProcessor implementation used by the Express infrastructure to process inbound events via HTTP REST apis.

Hierarchy

AbstractRequestProcessor
- ExpressRequestProcessor

Implements

RequestProcessor

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

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

Overrides AbstractRequestProcessor.constructor
- Defined in lib/internal/transport/express/ExpressRequestProcessor.ts:37
Parameters
- automations: AutomationServer
- configuration: Configuration
- Default value listeners: AutomationEventListener[] = []
Returns ExpressRequestProcessor

Properties

Protected automations

automations: AutomationServer

Protected configuration

configuration: Configuration

Private Readonly graphClientFactory

graphClientFactory: GraphClientFactory

Protected listeners

listeners: AutomationEventListener[]

Methods

Protected clearNamespace

clearNamespace(): void

Inherited from AbstractRequestProcessor.clearNamespace
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:327
Returns void

Protected invokeCommand

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

Inherited from AbstractRequestProcessor.invokeCommand
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:189
Parameters
- ci: CommandInvocation
- ctx: HandlerContext & AutomationContextAware
- command: CommandIncoming
- callback: (result: Promise<HandlerResult>) => void
  - - (result: Promise<HandlerResult>): void
    - Parameters
      - result: Promise<HandlerResult>
      Returns void
Returns void

Protected invokeEvent

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

Inherited from AbstractRequestProcessor.invokeEvent
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:247
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

Inherited from AbstractRequestProcessor.processCommand
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:51
Parameters
- command: CommandIncoming
- Default value callback: (result: Promise<HandlerResult>) => void = () => {}
  - - (result: Promise<HandlerResult>): void
    - Parameters
      - result: Promise<HandlerResult>
      Returns void
Returns void

processEvent

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

Inherited from AbstractRequestProcessor.processEvent
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:95
Parameters
- event: EventIncoming
- Default value 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>

Inherited from AbstractRequestProcessor.sendCommandStatus
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:139
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>

Inherited from AbstractRequestProcessor.sendEventStatus
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:168
Parameters
- success: boolean
- request: EventFired<any>
- event: EventIncoming
- ctx: HandlerContext & AutomationContextAware
Returns Promise<any>

Protected sendStatusMessage

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

Overrides AbstractRequestProcessor.sendStatusMessage
- Defined in lib/internal/transport/express/ExpressRequestProcessor.ts:46
Parameters
- payload: any
- ctx: HandlerContext & AutomationContextAware
Returns 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 }

Inherited from AbstractRequestProcessor.setupNamespace
- Defined in lib/internal/transport/AbstractRequestProcessor.ts:311
Parameters
- request: any
- automations: AutomationServer
- Default value invocationId: string = guid()
- Default value ts: number = Date.now()
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

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

automations: AutomationServer

configuration: Configuration

Default value listeners: AutomationEventListener[] = []

Returns ExpressRequestProcessor

Properties

Protected automations

Protected configuration

Private Readonly graphClientFactory

Protected listeners

Methods

Protected clearNamespace

Returns void

Protected createAndWrapMessageClient

Parameters

event: EventIncoming | CommandIncoming

context: HandlerContext & AutomationContextAware

Returns MessageClient & SlackMessageClient

Protected createGraphClient

Parameters

event: EventIncoming | CommandIncoming

context: AutomationContextAware

Returns GraphClient

Protected createMessageClient

Parameters

event: EventIncoming | CommandIncoming

context: AutomationContextAware

Returns MessageClient

Protected invokeCommand

Parameters

ci: CommandInvocation

ctx: HandlerContext & AutomationContextAware

command: CommandIncoming

callback: (result: Promise<HandlerResult>) => void

Parameters

result: Promise<HandlerResult>

Returns void

Returns void

Protected invokeEvent

Parameters

ef: EventFired<any>

ctx: HandlerContext & AutomationContextAware

event: EventIncoming

callback: (results: Promise<HandlerResult[]>) => void

Parameters

results: Promise<HandlerResult[]>

Returns void

Returns void

processCommand

Parameters

command: CommandIncoming

Default value callback: (result: Promise<HandlerResult>) => void = () => {}

Parameters

result: Promise<HandlerResult>

Returns void

Returns void

processEvent

Parameters

event: EventIncoming

Default value callback: (results: Promise<HandlerResult[]>) => void = () => {}

Parameters

results: Promise<HandlerResult[]>

Returns void

Returns void

sendCommandStatus

Parameters

success: boolean

code: number

request: CommandIncoming

ctx: HandlerContext & AutomationContextAware

Returns Promise<any>

sendEventStatus