Function main

client-sdks/client-js/examples/session-workflow.ts:7–295

()

import { SessionResource, WorkflowResource, ParallelWorkflowDefinition, SequentialWorkflowDefinition, LoopWorkflowDefinition } from "@aster/client-js";

async function main() {
  console.log("=".repeat(60));
  console.log("AsterClient Session + Workflow 演示");
  console.log("=".repeat(60));

  // 创建资源实例
  const session = new SessionResource({
    baseUrl: "http://localhost:8080",
    apiKey: process.env.ASTER_API_KEY,
  });

  const workflow = new WorkflowResource({
    baseUrl: "http://localhost:8080",
    apiKey: process.env.ASTER_API_KEY,
  });

  // ========================================================================
  // 1. Session 管理演示
  // ========================================================================
  console.log("\n📝 1. Session 管理");
  console.log("-".repeat(60));

  // 创建 Session
  const newSession = await session.create({
    agentId: "agent-123",
    templateId: "assistant",
    userId: "user-456",
    metadata: {
      project: "demo",
      environment: "development",
    },
    enableCheckpoints: true,
    checkpointInterval: 5, // 每5条消息创建一个断点
  });
  console.log("✅ 创建 Session:", newSession.id);

  // 添加消息
  await session.addMessage(newSession.id, {
    role: "user",
    content: "Hello! Can you help me with something?",
  });
  console.log("✅ 添加用户消息");

  await session.addMessage(newSession.id, {
    role: "assistant",
    content: "Of course! I'd be happy to help. What do you need assistance with?",
  });
  console.log("✅ 添加助手消息");

  // 获取消息列表
  const messages = await session.getMessages(newSession.id, {
    page: 1,
    pageSize: 10,
    sort: "asc",
  });
  console.log(`📋 获取消息列表: ${messages.items.length} 条消息`);

  // ========================================================================