( ctx context.Context, scope toolspkg.Scope, req toolspkg.CallRequest, )
| 2165 | } |
| 2166 | |
| 2167 | func (n *daemonNativeTools) sessionEvents( |
| 2168 | ctx context.Context, |
| 2169 | scope toolspkg.Scope, |
| 2170 | req toolspkg.CallRequest, |
| 2171 | ) (toolspkg.ToolResult, error) { |
| 2172 | input, query, err := decodeSessionEventQueryInput(req) |
| 2173 | if err != nil { |
| 2174 | return toolspkg.ToolResult{}, err |
| 2175 | } |
| 2176 | resolved, err := n.nativeResolvedWorkspace(ctx, req.ToolID, input.WorkspaceID, scope) |
| 2177 | if err != nil { |
| 2178 | return toolspkg.ToolResult{}, err |
| 2179 | } |
| 2180 | sessionWorkspaceID, err := nativeResolvedRegistryWorkspaceID(&resolved) |
| 2181 | if err != nil { |
| 2182 | return toolspkg.ToolResult{}, nativeNetworkInputError(req.ToolID, err) |
| 2183 | } |
| 2184 | info, err := n.nativeSessionInWorkspace(ctx, req.ToolID, sessionWorkspaceID, input.SessionID) |
| 2185 | if err != nil { |
| 2186 | return toolspkg.ToolResult{}, err |
| 2187 | } |
| 2188 | events, err := n.deps.Sessions.Events(ctx, input.SessionID, query) |
| 2189 | if err != nil { |
| 2190 | return toolspkg.ToolResult{}, err |
| 2191 | } |
| 2192 | payload := make([]any, 0, len(events)) |
| 2193 | for _, event := range events { |
| 2194 | payload = append(payload, core.SessionEventPayloadFromEvent(event, info)) |
| 2195 | } |
| 2196 | return structuredResult(map[string]any{nativeToolsEventsKey: payload}, fmt.Sprintf("%d events", len(payload))) |
| 2197 | } |
| 2198 | |
| 2199 | func (n *daemonNativeTools) sessionHistory( |
| 2200 | ctx context.Context, |
nothing calls this directly
no test coverage detected