Method agentHeartbeatWake

internal/daemon/native_tools.go:2122–2165

(
	ctx context.Context,
	_ toolspkg.Scope,
	req toolspkg.CallRequest,
)

}

func (n *daemonNativeTools) agentHeartbeatWake(
	ctx context.Context,
	_ toolspkg.Scope,
	req toolspkg.CallRequest,
) (toolspkg.ToolResult, error) {
	var input agentHeartbeatWakeInput
	if err := decodeNativeInput(req, &input); err != nil {
		return toolspkg.ToolResult{}, err
	}
	target, err := n.authoredAgentTarget(ctx, req.ToolID, input.WorkspaceID, input.AgentName)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	sessionID, err := requiredNativeString(req.ToolID, "session_id", input.SessionID)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	if _, err := n.nativeSessionInWorkspace(ctx, req.ToolID, target.workspaceID, sessionID); err != nil {
		return toolspkg.ToolResult{}, err
	}
	source := heartbeat.WakeSource(strings.TrimSpace(input.Source))
	if source == "" {
		source = heartbeat.WakeSourceManual
	}
	decision, err := n.deps.HeartbeatWake.Wake(ctx, heartbeat.WakeRequest{
		WorkspaceID: target.workspaceID,
		AgentName:   target.agentName,
		SessionID:   sessionID,
		Source:      source,
		DryRun:      input.DryRun,
	})
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	payload, err := contract.HeartbeatWakeDecisionPayloadFromDomain(decision)
	if err != nil {
		return toolspkg.ToolResult{}, err
	}
	response := contract.HeartbeatWakeResponse{Decision: payload}
	if err := contract.ValidateAuthoredContextRedacted(response); err != nil {
		return toolspkg.ToolResult{}, err
	}
	return structuredResult(map[string]any{"wake": response}, string(payload.Result))
}

func (n *daemonNativeTools) sessionEvents(
	ctx context.Context,