Method Call

internal/computerapi/service.go:176–212

(sessionID, module, function string, args map[string]string, toolCallID string, stream bool)

}

func (s Service) Call(sessionID, module, function string, args map[string]string, toolCallID string, stream bool) (string, security.DecisionRecord, error) {
	meta, err := s.sessionMeta(sessionID)
	if err != nil {
		return "", security.DecisionRecord{}, err
	}
	if module != "shell" || function != "exec" {
		return "", security.DecisionRecord{}, fmt.Errorf("unsupported call target %s/%s; v1 supports shell/exec", module, function)
	}
	command := strings.TrimSpace(args["command"])
	if command == "" {
		return "", security.DecisionRecord{}, fmt.Errorf("call arg command is required")
	}
	driver, err := runtimeplane.NewDriver("docker", s.Paths)
	if err != nil {
		return "", security.DecisionRecord{}, err
	}
	processID, err := control.Service{DB: s.DB, Paths: s.Paths, Driver: driver}.Exec(sessionID, []string{"sh", "-lc", command}, stream)
	if err != nil {
		return "", security.DecisionRecord{}, err
	}
	record, err := s.recordEvent(security.Event{
		Source:     "computer_api",
		EventType:  "call",
		RunID:      meta.RunID,
		SessionID:  sessionID,
		ToolCallID: ensureToolCallID(toolCallID),
		ProcessID:  processID,
		Args:       []string{module, function, command},
	}, map[string]any{
		"module":     module,
		"function":   function,
		"command":    command,
		"process_id": processID,
		"result_ref": "process:" + processID,
	})
	return processID, record, err
}

func (s Service) sessionMeta(sessionID string) (SessionMeta, error) {
	var meta SessionMeta