Stitch an anonymous visitor to a known user

arazzo: 1.0.1
info:
  title: Stitch an anonymous visitor to a known user
  version: 1.0.0
  summary: Track anonymously, identify on login, tag subsequent events, then read the user's history.
sourceDescriptions:
- name: identityApi
  url: ../openapi/millimetric-identity-api-openapi.yml
  type: openapi
- name: ingestApi
  url: ../openapi/millimetric-ingest-api-openapi.yml
  type: openapi
- name: readApi
  url: ../openapi/millimetric-read-api-openapi.yml
  type: openapi
workflows:
- workflowId: anonymous-to-known
  summary: track (anon) -> identify -> track (known) -> query by user_id.
  inputs:
    type: object
    required: [sk_key, rk_key, anonymous_id, user_id, from, to]
    properties:
      sk_key: {type: string}
      rk_key: {type: string}
      anonymous_id: {type: string, default: u_demo}
      user_id: {type: string, default: user_42}
      from: {type: string}
      to: {type: string}
  steps:
  - stepId: track-anon
    operationId: trackEvent
    parameters:
    - {name: Authorization, in: header, value: "Bearer $inputs.sk_key"}
    requestBody:
      contentType: application/json
      payload:
        event: "$pageview"
        anonymous_id: $inputs.anonymous_id
    successCriteria:
    - condition: $statusCode == 202
  - stepId: identify
    operationId: identify
    parameters:
    - {name: Authorization, in: header, value: "Bearer $inputs.sk_key"}
    requestBody:
      contentType: application/json
      payload:
        anonymous_id: $inputs.anonymous_id
        user_id: $inputs.user_id
    successCriteria:
    - condition: $statusCode == 200
  - stepId: track-known
    operationId: trackEvent
    parameters:
    - {name: Authorization, in: header, value: "Bearer $inputs.sk_key"}
    requestBody:
      contentType: application/json
      payload:
        event: activated
        anonymous_id: $inputs.anonymous_id
        user_id: $inputs.user_id
    successCriteria:
    - condition: $statusCode == 202
  - stepId: query-user
    operationId: queryEvents
    parameters:
    - {name: Authorization, in: header, value: "Bearer $inputs.rk_key"}
    - {name: from, in: query, value: $inputs.from}
    - {name: to, in: query, value: $inputs.to}
    - {name: user_id, in: query, value: $inputs.user_id}
    successCriteria:
    - condition: $statusCode == 200
    outputs:
      rows: $response.body#/rows
  outputs:
    user_events: $steps.query-user.outputs.rows