Function createLocalRuntimeClient

packages/cli/src/runtime-client.ts:131–170

(port: number)

}

export function createLocalRuntimeClient(port: number): RuntimeClient {
  const getHealth = async (): Promise<RuntimeHealth> => {
    const response = await fetch(`http://127.0.0.1:${port}/health`)
    if (!response.ok) throw new Error(`Health failed with status ${response.status}`)
    return await response.json() as RuntimeHealth
  }

  return {
    waitForHealth: timeoutMs => waitForHealthWith(getHealth, timeoutMs),
    getHealth,
    listTasks: async () => {
      const result = await localRpc<{ tasks: TaskInfo[] }>(port, 'task.list', {})
      return result.tasks
    },
    listInitiatives: async () => {
      const result = await localRpc<{ initiatives: RuntimeInitiative[] }>(port, 'initiative.list', {})
      return result.initiatives
    },
    listCapsules: async () => {
      const result = await localRpc<{ capsules: RuntimeCapsule[] }>(port, 'capsule.list', {})
      return result.capsules
    },
    listArtifacts: async () => {
      const result = await localRpc<{ artifacts: RuntimeArtifactRecord[] }>(port, 'artifact.list', {})
      return summarizeArtifacts(result.artifacts)
    },
    createInitiative: async input => {
      await localRpc(port, 'initiative.create', input)
    },
    sendMessage: async input => {
      await localRpc(port, 'agent.send', input)
    },
    spawnAgent: async (template, name) => {
      await localRpc(port, 'agent.spawn', { template, name })
    },
    updateTask: async input => {
      await localRpc(port, 'task.update', input)
    },
  }
}