4.3.3 通知の設計

（中省略）

tasks:
  ### fetch_context_id アクティビティの説明
  # 概要
  #   practice-contextの一覧から現在のワークフローのExecution IDを使用してコンテキストIDを取得する
  #
  # ラベルの説明
  # action: core.http
  #   現在実行しているワークフローの情報を取得するため、
  #   GET /api/v1/practice-contexts APIを実行します。
  #   REST APIを実行するためには、StackStorm部品のcore.http actionを使用します。
  #
  # input:
  #   actionに渡す引数を指定するセクションです。
  #   ここではcore.http actionを実行するための引数を指定します。
  #   "url"には実行するREST APIのURLを指定します。
  #       ポイント:
  #         <% ctx().oiapi_location %>は"Ops IのURL/api/v1"を定義したワークフローの変数を
  #         参照する場合の例です。実行環境に合わせて変更してください。
  #   "method"にはREST APIのメソッドを指定します。
  #   "headers"にはREST APIのヘッダー情報(REST APIの実行に必要な認証情報など)を指定します。
  #       ポイント:
  #         REST APIの実行に必要な認証情報(Ops IトークンまたはOps Iアクセストークンを指定します。
  #         例では、Ops I提供部品のoi.fetch_access_token actionで
  #         事前に取得したOps Iアクセストークンを設定した変数oi_access_tokenを参照しています。
  #
  # next:
  #   REST APIの実行結果に基づき、次に実行するタスクを選択します。
  #   また、publish属性を利用して、後続の処理で使用するコンテキストIDを保存しています。
  #   コンテキストIDはpractice-contextの一覧(GET /api/v1/practice-contexts APIのレスポンス)の
  #   1件目のレコードから取得できます。
  #   1件目のレコードを検索して変数contextに設定、次にcontextのidを取得して変数context_idに
  #   設定しています。
  fetch_context_id:
    action: core.http
    input:
      url: <% ctx().oiapi_location %>/practice-contexts?filterBy=executionId%3Aeq%3A<% ctx().parent_execution_id %>
      method: GET
      headers:
        Content-Type: application/json
        Authorization: Bearer <% ctx().oi_access_token %>
    next:
       - when: <% succeeded() %>
         publish:
          - context: <% result().body.data.content.first(null) %>
          - context_id: <% ctx().context.id %>
         do: fetch_context
       - when: <% failed() %>
         do: fail

  ### fetch_context アクティビティの説明
  # 概要
  #   ワークフローの詳細情報を取得し、親のscheduleオブジェクトのIDを取得する
  #
  # ラベルの説明
  # action: core.http
  #   ワークフローの詳細情報を取得するため、GET /api/v1/practice-contexts/{id} APIを実行します。
  #   REST APIの実行にはfetch_context_id taskと同様にcore.http actionを使用します。
  #   {id}にはfetch_context_id taskで取得したpractice-contextのIDを使用します。
  #
  # input:
  #   actionに渡す引数を指定するセクションです。
  #   ここではcore.http actionを実行するための引数を指定します。
  #   指定する情報についてはfetch_context_idアクティビティと同様です。
  #
  # next:
  #   ここではpublish属性を利用して、取得したワークフローの詳細情報から
  #   親のscheduleオブジェクトのIDを取得し、変数parent_schedule_idに値を設定します。
  fetch_context:
    action: core.http
    input:
      url: <% ctx().oiapi_location %>/practice-contexts/<% ctx().context_id %>
      method: GET
      headers:
        Content-Type: application/json
        Authorization: Bearer <% ctx().oi_access_token %>
    next:
       - when: <% succeeded() %>
         publish:
          - parent_schedule_id: <% result().body.data.schedule %>
         do: fetch_schedule
       - when: <% failed() %>
         do: fail

  ### fetch_schedule アクティビティの説明
  # 概要
  #   親のスケジュールの情報から更新対象のscheduleオブジェクトのIDを取得する
  #
  # ラベルの説明
  # action: core.http
  #   更新対象のscheduleオブジェクトを取得するため、
  #   GET /api/v1/schedules/{id} APIを用いて子のスケジュール一覧を取得します。
  #   REST APIの実行にはfetch_context_id taskと同様にcore.http actionを使用します。
  #   {id}にはfetch_context taskで取得した親のscheduleオブジェクトのIDを使用します。
  #
  # input:
  #   actionに渡す引数を指定するセクションです。
  #   ここではcore.http actionを実行するための引数を指定します。
  #   指定する情報についてはfetch_context_idアクティビティと同様です。
  #
  # next:
  #   子のスケジュール一覧から更新対象のscheduleオブジェクトを検索し、
  #   変数target_scheduleに値を設定します。
  #   子のスケジュール一覧は配列のため、where式で各要素のactivityを参照し、
  #   更新対象(例ではcreate_vm_wf_01)を検索しています。
  #   変数update_schedule_bodyには次のtaskで実行するREST APIのリクエストボディを設定しています。
  #   更新にはPUT /api/v1/schedules/{id} APIを使用するため、リクエストボディに必要な情報を
  #   このtaskで取得した変数target_scheduleを利用して作成しています。
  #   例では担当者を更新するため、変数target_scheduleのassignedToを担当者のユーザーIDにset式で
  #   設定してから変数update_schedule_bodyに値を設定しています。
  #   where式、set式またはその他の使用できる式についてはStackStormのマニュアルを参照してください。
  fetch_schedule:
    action: core.http
    input:
      url: <% ctx().oiapi_location %>/schedules/<% ctx().parent_schedule_id %>
      method: GET
      headers:
        Content-Type: application/json
        Authorization: Bearer <% ctx().oi_access_token %>
    next:
       - when: <% succeeded() %>
         publish:
          - target_schedule: <% result().body.data.children.where($.activity = "create_vm_wf_01").first(null) %>
          - target_schedule_id: <% ctx().target_schedule.id %>
          - update_schedule_body: <% ctx().target_schedule.set("assignedTo", ctx().user_id) %>
         do: update_schedule
       - when: <% failed() %>
         do: fail

  ### update_schedule アクティビティの説明
  # 概要
  #   更新対象のスケジュールの情報からワークフローの担当者を変更する
  #
  # ラベルの説明
  # action: core.http
  #   更新対象のscheduleオブジェクトを更新するため、
  #   PUT /api/v1/schedules/{id} APIを用いて行います。
  #   REST APIの実行にはfetch_context_id taskと同様にcore.http actionを使用します。
  #   {id}にはfetch_schedule taskで取得した更新対象のscheduleオブジェクトのIDを使用します。
  #
  # input:
  #   actionに渡す引数を指定するセクションです。
  #   ここではcore.http actionを実行するための引数を指定します。
  #   "body"にはREST APIのリクエストボディを設定します。
  #   core.http actionでは文字列での入力が必要ため、
  #   変数update_schedule_bodyの値をstr式で文字列に変換し、設定します。
  #
  # next:
  #   一度定義した変数は繰り返し使用することができます。
  #   繰り返し使いたい場合は使用済みの値を使用しないように
  #   変数にnullを設定することで初期化できます。
  update_schedule:
    action: core.http
    input:
      url: <% ctx().oiapi_location %>/schedules/<% ctx().target_schedule_id %>
      method: PUT
      headers:
        Content-Type: application/json
        Authorization: Bearer <% ctx().oi_access_token %>
      body:
        <% str(ctx().update_schedule_body) %>
    next:
       - when: <% succeeded() %>
        publish:
         - target_schedule: null
         - update_schedule_body: null
        do: create_vm_wf_01
       - when: <% failed() %>
         do: fail

（中省略）