public async createDigitalHuman(
  request: CreateDigitalHumanRequest
): Promise<CreateDigitalHumanResult> {
  const id = request.id?.trim() || randomUUID();
  const template = buildTemplate(request);

  const workspace = resolveDefaultWorkspace(id);

  await this.openClawAgentsAdapter.createAgent({
    name: id,
    workspace
  });

  await this.writeTemplateViaOpenClawFilesRpc(id, template);

  const skills = normalizeCreateDigitalHumanSkills(request.skills);
  await this.agentSkillsLogic.updateAgentSkills(id, skills);

export function createApp(options: AppOptions = {}): Express {
  const app = express();

  app.disable("x-powered-by");
  app.use(express.json());
  app.use(createHydraAuthMiddleware());
  app.use(createHealthRouter());
  app.use(createGuideRouter());
  app.use(createBknRouter());
  app.use(createCronRouter());
  app.use(createChatRouter());
  app.use(createSessionsRouter());
  app.use(createSkillsRouter());
  app.use(createChannelUserRouter());
  app.use(createDigitalHumanRouter());
  app.use(createChatUploadRouter());
  app.use(createChatAgentRouter());

func (l *GetStatusLogic) GetStatus(req *types.GetStatusReq) (resp *types.GetStatusResp, err error) {
	logx.Infof("GetStatus called with id: %s", req.Id)

	// 调用 Model 层查询 form_view 状态
	formViewModel := form_view.NewFormViewModel(l.svcCtx.DB)
	formViewData, err := formViewModel.FindOneById(l.ctx, req.Id)
	if err != nil {
		return nil, errorx.Detail(errorx.QueryFailed, err, "库表视图")
	}

	resp = &types.GetStatusResp{
		UnderstandStatus: formViewData.UnderstandStatus,
	}

	logx.Infof("GetStatus success: form_view_id=%s, status=%d",
		req.Id, formViewData.UnderstandStatus)

	return resp, nil
}

router.post(
  "/api/dip-studio/v1/chat/agent",
  async (request, response, next) => {
    const abortController = new AbortController();
    attachDownstreamAbortHandlers(request, response, abortController);
    try {
      const requestBody = readChatAgentRequestBody(request.body);
      const sessionKey = readRequiredSessionKeyHeader(request.headers);
      const agentId = readAgentIdFromSessionKey(sessionKey);
      const sessionLabel = await resolveChatAgentSessionLabel(
        sessionsLogic, sessionKey, requestBody.message);
      const message = appendAttachmentHintsToMessage(
        requestBody.message, requestBody.attachments);
      const upstreamResponse = await chatAgentClient.createResponseStream({
          sessionKey, message,
          attachments: requestBody.attachments,
          idempotencyKey: randomUUID(),
          sessionLabel
        }, agentId, abortController.signal);
      writeEventStreamHeaders(response, upstreamResponse.status, upstreamResponse.headers);
      await pipeEventStream(upstreamResponse.body, response);

export function writeEventStreamHeaders(
  response: Response,
  statusCode: number,
  headers: Headers
): void {
  response.status(statusCode);
  response.setHeader(
    "content-type",
    headers.get("content-type") ?? "text/event-stream; charset=utf-8"
  );
  response.setHeader(
    "cache-control",
    headers.get("cache-control") ?? "no-cache, no-transform"
  );
  response.setHeader("connection", headers.get("connection") ?? "keep-alive");
  response.setHeader("x-accel-buffering", "no");
  response.flushHeaders?.();
}

func (l *GenerateUnderstandingLogic) GenerateUnderstanding(req *types.GenerateUnderstandingReq) (resp *types.GenerateUnderstandingResp, err error) {
	logx.Infof("GenerateUnderstanding called with id: %s, fields count: %d", req.Id, len(req.Fields))

	// 1. 状态校验：只有状态 0（未理解）或 3（已完成）才允许生成
	formViewModel := form_view.NewFormViewModel(l.svcCtx.DB)
	formViewData, err := formViewModel.FindOneById(l.ctx, req.Id)
	if err != nil {
		return nil, fmt.Errorf("查询库表视图失败: %w", err)
	}

	currentStatus := formViewData.UnderstandStatus
	if currentStatus != form_view.StatusNotUnderstanding && currentStatus != form_view.StatusCompleted && currentStatus != form_view.StatusFailed {
		return nil, fmt.Errorf("当前状态不允许生成理解数据，当前状态: %d", currentStatus)
	}

	// 2. 限流检查（1秒窗口，防止重复点击）
	if !l.svcCtx.AllowRequest(req.Id) {
		return nil, fmt.Errorf("操作过于频繁，请稍后再试")
	}

	// 3. 更新状态为 1（理解中）
	err = formViewModel.UpdateUnderstandStatus(l.ctx, req.Id, form_view.StatusUnderstanding)
	if err != nil {
		return nil, fmt.Errorf("更新理解状态失败: %w", err)
	}

// 5. 调用 AI 服务 HTTP API（同步调用）
if err := l.callAIService(req.Id, formViewData, fields, len(req.Fields) > 0); err != nil {
    // 调用失败，回退状态
    _ = formViewModel.UpdateUnderstandStatus(l.ctx, req.Id, currentStatus)
    return nil, fmt.Errorf("调用 AI 服务失败: %w", err)
}

POST   /api/workflow-rest/v1/process-definitions
PUT    /api/workflow-rest/v1/process-definitions/{id}
POST   /api/workflow-rest/v1/process-definitions/{id}/deploy
POST   /api/workflow-rest/v1/process-instances
POST   /api/workflow-rest/v1/tasks/{id}/complete

# Studio（TypeScript）
src/app.ts        # 组装 Express 应用、中间件和路由
src/server.ts     # 读环境变量并启动服务
src/utils/        # 通用工具与运行时配置
src/infra/        # 基础设施适配层（OpenClaw 客户端）
src/adapters/     # 外部资源适配器
src/routes/       # HTTP 路由定义
src/logic/        # 核心业务逻辑
src/middleware/   # 通用中间件（404、错误处理）
src/errors/       # 领域内可复用的错误类型

# Hub Backend（Python）
src/
├── domains/         # 领域层：核心业务逻辑和领域模型
├── ports/           # 端口层：接口定义
├── application/     # 应用层：用例和业务编排
├── adapters/        # 适配器层：端口的具体实现
├── routers/         # 路由层（入站适配器）
├── infrastructure/  # 基础设施层：配置、日志、容器
└── main.py

{
  "code": "DipStudio.SkillBadLayout",
  "description": "SKILL.md is missing required front matter metadata",
  "solution": "补充合法的 front matter，并确保包含 name 字段",
  "detail": {
    "upstream": {
      "service": "openclaw",
      "operation": "skills.install",
      "httpStatus": 400,
      "code": "BAD_LAYOUT"
    }
  },
  "link": "https://example.internal/docs/errors#DipStudio.SkillBadLayout"
}