Workato Event Streams Public API — Messages

naftiko: 1.0.0-alpha2
info:
  label: Workato Event Streams Public API — Messages
  description: 'Workato Event Streams Public API — Messages. 3 operations. Lead operation: Workato Publish a Batch of Messages
    to a Topic. Self-contained Naftiko capability covering one Workato business surface.'
  tags:
  - Workato
  - Messages
  created: '2026-05-19'
  modified: '2026-05-19'
binds:
- namespace: env
  keys:
    WORKATO_API_KEY: WORKATO_API_KEY
capability:
  consumes:
  - type: http
    namespace: event-streams-messages
    baseUri: https://event-streams.workato.com
    description: Workato Event Streams Public API — Messages business capability. Self-contained, no shared references.
    resources:
    - name: api-v1-batch-topics-topic_id-publish
      path: /api/v1/batch/topics/{topic_id}/publish
      operations:
      - name: publishbatchmessages
        method: POST
        description: Workato Publish a Batch of Messages to a Topic
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: true
    - name: api-v1-topics-topic_id-consume
      path: /api/v1/topics/{topic_id}/consume
      operations:
      - name: consumemessages
        method: POST
        description: Workato Consume Messages from a Topic
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: false
    - name: api-v1-topics-topic_id-publish
      path: /api/v1/topics/{topic_id}/publish
      operations:
      - name: publishmessage
        method: POST
        description: Workato Publish a Message to a Topic
        outputRawFormat: json
        outputParameters:
        - name: result
          type: object
          value: $.
        inputParameters:
        - name: body
          in: body
          type: object
          description: Request body (JSON).
          required: true
    authentication:
      type: bearer
      token: '{{env.WORKATO_API_KEY}}'
  exposes:
  - type: rest
    namespace: event-streams-messages-rest
    port: 8080
    description: REST adapter for Workato Event Streams Public API — Messages. One Spectral-compliant resource per consumed
      operation, prefixed with /v1.
    resources:
    - path: /v1/api/v1/batch/topics/{topic-id}/publish
      name: api-v1-batch-topics-topic-id-publish
      description: REST surface for api-v1-batch-topics-topic_id-publish.
      operations:
      - method: POST
        name: publishbatchmessages
        description: Workato Publish a Batch of Messages to a Topic
        call: event-streams-messages.publishbatchmessages
        with:
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/api/v1/topics/{topic-id}/consume
      name: api-v1-topics-topic-id-consume
      description: REST surface for api-v1-topics-topic_id-consume.
      operations:
      - method: POST
        name: consumemessages
        description: Workato Consume Messages from a Topic
        call: event-streams-messages.consumemessages
        with:
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
    - path: /v1/api/v1/topics/{topic-id}/publish
      name: api-v1-topics-topic-id-publish
      description: REST surface for api-v1-topics-topic_id-publish.
      operations:
      - method: POST
        name: publishmessage
        description: Workato Publish a Message to a Topic
        call: event-streams-messages.publishmessage
        with:
          body: rest.body
        outputParameters:
        - type: object
          mapping: $.
  - type: mcp
    namespace: event-streams-messages-mcp
    port: 9090
    transport: http
    description: MCP adapter for Workato Event Streams Public API — Messages. One tool per consumed operation, routed inline
      through this capability's consumes block.
    tools:
    - name: workato-publish-batch-messages-topic
      description: Workato Publish a Batch of Messages to a Topic
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: event-streams-messages.publishbatchmessages
      with:
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: workato-consume-messages-topic
      description: Workato Consume Messages from a Topic
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: event-streams-messages.consumemessages
      with:
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.
    - name: workato-publish-message-topic
      description: Workato Publish a Message to a Topic
      hints:
        readOnly: false
        destructive: false
        idempotent: false
      call: event-streams-messages.publishmessage
      with:
        body: tools.body
      outputParameters:
      - type: object
        mapping: $.