Pipedream Route Trigger Events to Workflows

arazzo: 1.0.1
info:
  title: Pipedream Route Trigger Events to Workflows
  summary: Confirm a deployed trigger, bind it to Pipedream workflows, then read them back.
  description: >-
    A routing-configuration flow for a Pipedream Connect event source. The
    workflow retrieves a deployed trigger to confirm it exists, sets the list of
    Pipedream workflow IDs that should receive its events, and then reads the
    bound workflows back to confirm the change took effect. Every step spells
    out its request inline so the flow can be read and executed without opening
    the underlying OpenAPI description.
  version: 1.0.0
sourceDescriptions:
- name: pipedreamApi
  url: ../openapi/pipedream-openapi.yml
  type: openapi
workflows:
- workflowId: set-trigger-workflows
  summary: Bind and verify the workflow listeners for a deployed trigger.
  description: >-
    Retrieves the deployed trigger, replaces its workflow ID listeners with the
    supplied list, and reads the listeners back to verify.
  inputs:
    type: object
    required:
    - projectId
    - environment
    - externalUserId
    - triggerId
    - workflowIds
    properties:
      projectId:
        type: string
        description: The project ID, which starts with proj_.
      environment:
        type: string
        description: The Connect environment (development or production).
      externalUserId:
        type: string
        description: The end user identifier who owns the deployed trigger.
      triggerId:
        type: string
        description: The deployed trigger ID to configure.
      workflowIds:
        type: array
        items:
          type: string
        description: The set of Pipedream workflow IDs (p_...) that should receive the trigger's events.
  steps:
  - stepId: retrieveDeployedTrigger
    description: >-
      Retrieve the deployed trigger by ID to confirm it exists before changing
      its routing configuration.
    operationId: retrieveDeployedTrigger
    parameters:
    - name: project_id
      in: path
      value: $inputs.projectId
    - name: x-pd-environment
      in: header
      value: $inputs.environment
    - name: trigger_id
      in: path
      value: $inputs.triggerId
    - name: external_user_id
      in: query
      value: $inputs.externalUserId
    successCriteria:
    - condition: $statusCode == 200
    outputs:
      trigger: $response.body#/data
  - stepId: setTriggerWorkflows
    description: >-
      Replace the trigger's workflow listeners with the supplied list of
      Pipedream workflow IDs.
    operationId: updateDeployedTriggerWorkflows
    parameters:
    - name: project_id
      in: path
      value: $inputs.projectId
    - name: x-pd-environment
      in: header
      value: $inputs.environment
    - name: trigger_id
      in: path
      value: $inputs.triggerId
    - name: external_user_id
      in: query
      value: $inputs.externalUserId
    requestBody:
      contentType: application/json
      payload:
        workflow_ids: $inputs.workflowIds
    successCriteria:
    - condition: $statusCode == 200
    outputs:
      workflowIds: $response.body#/workflow_ids
  - stepId: verifyTriggerWorkflows
    description: >-
      Read the trigger's workflow listeners back to confirm the supplied IDs are
      now bound.
    operationId: listDeployedTriggerWorkflows
    parameters:
    - name: project_id
      in: path
      value: $inputs.projectId
    - name: x-pd-environment
      in: header
      value: $inputs.environment
    - name: trigger_id
      in: path
      value: $inputs.triggerId
    - name: external_user_id
      in: query
      value: $inputs.externalUserId
    successCriteria:
    - condition: $statusCode == 200
    outputs:
      workflowIds: $response.body#/workflow_ids
  outputs:
    appliedWorkflowIds: $steps.setTriggerWorkflows.outputs.workflowIds
    verifiedWorkflowIds: $steps.verifyTriggerWorkflows.outputs.workflowIds