再開待機アクション ​

{
  actions: {
    wait_for_webhook: {
      config_fields: [
        {
          name: 'url',
          label: 'API endpoint',
          hint: 'We will send a POST request to this endpoint with the resume token',
          optional: false
        },
        {
          name: 'payload_schema',
          optional: true,
          sticky: true,
          schema_neutral: true,
          control_type: 'schema-designer',
          sample_data_type: 'json_input',
        }
      ],
      execute: lambda do |_connection, input, _input_schema, _output_schema, continue|
        if continue.blank?
          # Calling suspend will put the job to sleep, after the request in the proc is executed.
          # in this case we send a POST request to the URL provided by the recipe builder
          # expires_at is configurable and once the time is reached, the job is resumed
          suspend(continue: { "state" => "suspended", "url" => input['url']}, expires_at: 10.minutes.from_now)
        elsif continue["state"] == "resumed"
          { "result" => "resumed", "payload" =>  continue["payload"]}
        elsif continue["state"] == "suspend_timeout"
          { "result" => "suspend_timeout" }
        else
          { "result" => "Unexpected state" }
        end
      end,
      # When suspend is called, this lambda is executed to suspend the job
      # The lambda receives 3 arguments
      # The resume token is an opaque token that must be stored in the external system. This will be used to identify the job to resume
      # expires_at is the time when the job resumes with a timeout
      # continue is the argument passed
      before_suspend: lambda do |resume_token, expires_at, continue|
        response = post(continue['url'], { expires_at: expires_at, resume_token: resume_token } )
      end,
      # Allows you to manipulate or add data before the resume.
      # We change the state of the "continue" argument
      # We also add the payload data into the "continue" argument
      # After this lambda is called, the "execute" lambda is called with the "continue" argument
      before_resume: lambda do |data, input, continue|
        if continue["state"] == "suspended"
          continue["state"] = "resumed"
          continue["payload"] = data
        else
          { "result" => "Unexpected state" }
        end
      end,
      # Allows you to manipulate or add data before the resume due to a timeout
      # We change the state of the "continue" argument
      # After this lambda is called, the "execute" lambda is called with the "continue" argument
      before_timeout_resume: lambda do |input, continue|
        if continue["state"] == "suspended"
          continue["state"] = "suspend_timeout"
        else
          { "result" => "Unexpected state" }
        end
      end,
      output_fields: lambda do |object_definition|
        object_definition['output']
      end
    }
  }
}