Production Pulse · 5 / 8

Require a monitoring connection

Declare the HTTP device the installer must bind, and scope the device policy to that logical requirement.

This lesson starts with the previous working solution. Build and connect the next capability. Your earlier drafts are kept separately.

integration_document "monitor" {
  integrationId = "com.academy.monitor"
  sdkVersion = "2.0"
  version = "1.0.0"
  description = "A small heartbeat integration"
  actor = integration_actor.monitor
}

integration_actor "monitor" {
  subscriptions = [integration_actor_subscription.job_updates]
  actions = [integration_actor_action.status]
  timers = [integration_actor_timer.heartbeat, integration_actor_timer.daily_review]
}

integration_actor_timer "heartbeat" {
  name = "heartbeat"
  schedule = { every = "5m" }
  jitter = "15s"
  source = "return { alive = true }"
}

integration_actor_subscription "job_updates" {
  topic = "job.updated"
  source = file("scripts/job-updated.lua")
}

integration_actor_action "status" {
  name = "status"
  label = "Check production pulse"
  inputSchema = { type = "object", properties = {} }
  outputSchema = {
    type = "object"
    properties = { alive = { type = "boolean" } }
    required = ["alive"]
  }
  source = file("scripts/status.lua")
}

integration_actor_timer "daily_review" {
  name = "daily_review"
  schedule = { cron = "0 6 * * *" }
  source = "return { review = true }"
}

integration_resource_requirement "monitor_service" {
  id = "monitor_service"
  type = "protocol/http"
  # TODO: add optional — see the task above.
  # TODO: add description — see the task above.
}

integration_policy_statement "devices" {
  # TODO: add effect — see the task above.
  # TODO: add actions — see the task above.
  # TODO: add resources — see the task above.
}

integration_policy "monitor" {
  # TODO: add statements — see the task above.
}

return { alive = true }

local event, config = ...
return { reason = "job.updated" }

local input, actionConfig = ...
return { alive = true }