asyncapi_base.yaml

asyncapi: 3.0.0
info:
  title: Mindwm API
  version: 3.0.0
  description: |
    Desktop event processing
  license:
    name: Apache 2.0
    url: 'https://www.apache.org/licenses/LICENSE-2.0'
servers:
  asciinema: 
    host: "/tmp/mindwm-asciinema-{MINDWM_UUID}.socket"
    protocol: unixsocket
    description: Asciinema
    variables:
      USER_HOST:
        default: localhost
    externalDocs:
      url: https://github.com/mindwm/mindwm-manager/blob/dc926f637bb8d31f21ecbd28479ab9b0a1ece23c/src/mindwm/modules/tmux_session.py
    tags: 
      - name: client
  mindwm-client:
    host: "/tmp/mindwm-asciinema-{MINDWM_UUID}.socket"
    protocol: unixsocket
    description: |
      Mindwm Client      
    variables:
      USER_HOSTNAME: 
        default: localhost 
    externalDocs:
      url: "https://github.com/mindwm/mindwm-manager/blob/dc926f637bb8d31f21ecbd28479ab9b0a1ece23c/src/mindwm/modules/pipe_listener.py"
    tags: 
      - name: client
      - name: docker
  knative-eventing:
    protocol: http
    host: "broker-ingress.{KNATIVE_EVENTING_NS}.svc.cluster.local"
    variables:
      KNATIVE_EVENTING_NS:
        description: Namespace where Knative Eventing is deployed
        default: knative-eventing
    description: |
      Knative eventing
    externalDocs:
      url: https://knative.dev/docs/eventing/
    tags:
      - name: kubernetes
  knative-serving:
    protocol: http
    host: "webhook.{KNATIVE_SERVING_NS}.svc.cluster.local:8008"
    variables:
      KNATIVE_SERVING_NS:
        description: Namespace where Knative Serving is deployed
        default: knative-eventing
    externalDocs:
      url: https://knative.dev/docs/serving/
    description: |
      Knative serving
    tags:
      - name: kubernetes
  kafka:
    protocol: kafka
    host: "neo4j-cdc.${KAFKA_NS}:9093"
    variables:
      KAFKA_NS:
        description: Namespace where kafka broker is deployed
        default: redpanda
    description:
      Kafka cluster
    tags:
      - name: kubernetes
  neo4j-cdc-plugin:
    protocol: bolt
    host: "{CONTEXT_NAME}-neo4j.context-{CONTEXT_NAME}:7687"
    variables:
      CONTEXT_NAME:
        description: |
          context name
    description: |
      Neo4j Change data capture plugin
    externalDocs:
      url: https://neo4j.com/docs/cdc/current/
    tags:
      - name: kubernetes
  vector: 
    protocol: http
    host: "{CONTEXT_NAME}-vector-headless.{CONTEXT_NAME}:80"
    variables:
      CONTEXT_NAME:
        description: |
          context name
    description: |
      Vector.dev
    externalDocs:
      url: https://vector.dev
    tags:
      - name: kubernetes
  nats:
    host: '{address}:{port}'
    protocol: nats
    description: |
      Nats Server
    security:
      - type: userPassword
    variables:
      address:
        enum:
          - "10.20.30.211" 
          - "nats.nats"
        default: nats.nats
      port:
        enum:
          - "31101"
          - "4222"
        default: "4222"
    tags:
      - name: kubernetes
           
channels:
  UserHostBroker:
    address: "http://broker-ingress.knative-eventing.svc.cluster.local/user-{USERNAME}/{HOSTNAME}-broker"
    externalDocs:
      url: https://knative.dev/docs/eventing/brokers/
    servers:
      - $ref: '#/servers/knative-eventing'
    messages:
      TouchEvent:
        $ref: '#/components/messages/TouchEvent'
      IoDocument:
        $ref: '#/components/messages/IoDocumentEvent'
    tags:
      - name: kubernetes
      - name: knative-eventing
  UserBroker:
    address: "http://broker-ingress.knative-eventing.svc.cluster.local/user-{{.USERNAME}/user-{USERNAME}-broker"
    externalDocs:
      url: https://knative.dev/docs/eventing/brokers/
    servers:
      - $ref: '#/servers/knative-eventing'
    messages:
      TouchEvent:
        $ref: '#/components/messages/TouchEvent'
      IoDocument:
        $ref: '#/components/messages/IoDocumentEvent'
    tags:
      - name: kubernetes
      - name: knative-eventing
  ContextBroker:
    address: "http://broker-ingress.knative-eventing.svc.cluster.local/context-{CONTEXT_NAME}/context-broker-{CONTEXT_NAME}"
    externalDocs:
      url: https://knative.dev/docs/eventing/brokers/
    servers:
      - $ref: '#/servers/knative-eventing'
    messages:
      TouchEvent:
        $ref: '#/components/messages/TouchEvent'
      IoDocument:
        $ref: '#/components/messages/IoDocumentEvent'

  TmuxPane:
    address: /tmp/mindwm-asciinema-{MINDWM_UUID}.socket
    externalDocs:
      url: https://github.com/mindwm/mindwm-manager/blob/dc926f637bb8d31f21ecbd28479ab9b0a1ece23c/src/mindwm/modules/tmux_session.py#L33
    servers:
      - $ref: '#/servers/asciinema'
      - $ref: '#/servers/mindwm-client'
    messages:
      IoDocument: 
        $ref: '#/components/messages/IoDocument'

  HostJetStreamChannel:
    address: "KN_USER_{USERNAME}__{HOSTNAME}_BROKER_KNE_TRIGGER"
    servers: 
      - $ref: '#/servers/nats'
    externalDocs: 
      url: https://github.com/knative-extensions/eventing-natss
#  HostNatsTopicIn:
#    address: user-{USERNAME}.{HOSTNAME}-broker-kne-trigger._knative
#    servers: 
#      - $ref: '#/servers/nats'
#    messages:
#      GraphEvent:
#        $ref: '#/components/messages/GraphEvent'
  HostNatsTopicIoDocument:
    address: 'mindwm.{USER}.{HOSTNAME}.tmux.{TMUX_SOCKET}.{MINDWM_UUID}.{TMUX_ID}.{TMUX_PANE_ID}.iodocument'
    servers: 
      - $ref: '#/servers/nats'
    messages:
      IoDocumentEvent:
        $ref: '#/components/messages/IoDocumentEvent'
  HostNatsTopicClipboard:
    address: 'mindwm.{USER}.{HOSTNAME}.clipboard'
    servers: 
      - $ref: '#/servers/nats'
    messages:
      ClipboardEvent:
        $ref: '#/components/messages/ClipboardEvent'

  TouchChannel:
    address: 'mindwm.{USER}.{HOSTNAME}.touch'
    servers: 
      - $ref: '#/servers/nats'
    messages:
      TouchEvent:
        $ref: '#/components/messages/TouchEvent'

  ChangeDataCapture:
    address: '{CONTEXT_NAME}-cdc-topic'
    servers: 
      - $ref: '#/servers/kafka'
      - $ref: '#/servers/knative-eventing'
 
 
operations:
  IoDocument:
    action: send
    channel: 
      $ref: '#/channels/TmuxPane'
    messages:
      - $ref: '#/channels/TmuxPane/messages/IoDocument'

  IoDocumentEvent:
    action: send
    channel:
      $ref: '#/channels/HostNatsTopicIoDocument'
    messages:
      - $ref: '#/channels/HostNatsTopicIoDocument/messages/IoDocumentEvent'

#  GraphEvent:
#    action: send
#    channel:
#      $ref: '#/channels/HostNatsTopicIn'
#    messages:
#      - $ref: '#/channels/HostNatsTopicIn/messages/GraphEvent'

#  GraphEvent:
#    action: send
#    channel:
#      $ref: '#/channels/HostNatsTopicIn'
#    messages:
#      - $ref: '#/channels/HostNatsTopicIn/messages/GraphEvent'

  ClipboardEvent:
    action: send
    channel:
      $ref: '#/channels/HostNatsTopicClipboard'
    messages:
      - $ref: '#/channels/HostNatsTopicClipboard/messages/ClipboardEvent'

  TouchEvent:
    action: send
    channel:
      $ref: '#/channels/TouchChannel'
    messages:
      - $ref: '#/channels/TouchChannel/messages/TouchEvent'
    

components:
  messages:
    IoDocument:
      summary: "Basic IoDocument produced by mindwm-client"
      payload:
        $ref: '#/components/schemas/IoDocument'
    IoDocumentEvent:
      summary: "TmuxPaneIoDocument in cloudevent"
      payload:
        $ref: "#/components/schemas/IoDocumentEvent"
    Clipboard:
      summary: "Clipboard data"
      payload:
        $ref: '#/components/schemas/Clipboard'
    ClipboardEvent:
      summary: "Clipboard"
      payload:
        $ref: "#/components/schemas/ClipboardEvent"
    TouchEvent:
      summary: "update atime"
      payload:
        $ref: "#/components/schemas/TouchEvent"
    ChangeDataCapture:
      summary: Change Data Capture
      payload:
        $ref: "#/components/schemas/Neo4jChangeDataCapture"