( req toolspkg.CallRequest, scope toolspkg.Scope, )
| 5761 | } |
| 5762 | |
| 5763 | func decodeObserveSearchInput( |
| 5764 | req toolspkg.CallRequest, |
| 5765 | scope toolspkg.Scope, |
| 5766 | ) (observeSearchInput, store.EventSummaryQuery, error) { |
| 5767 | var input observeSearchInput |
| 5768 | if err := decodeNativeInput(req, &input); err != nil { |
| 5769 | return observeSearchInput{}, store.EventSummaryQuery{}, err |
| 5770 | } |
| 5771 | if _, err := requiredNativeString(req.ToolID, "query", input.Query); err != nil { |
| 5772 | return observeSearchInput{}, store.EventSummaryQuery{}, err |
| 5773 | } |
| 5774 | workspaceID, err := nativeCallerWorkspaceInput(req.ToolID, "workspace_id", input.WorkspaceID, scope) |
| 5775 | if err != nil { |
| 5776 | return observeSearchInput{}, store.EventSummaryQuery{}, err |
| 5777 | } |
| 5778 | input.WorkspaceID = workspaceID |
| 5779 | query, err := input.eventSummaryQuery(req.ToolID) |
| 5780 | if err != nil { |
| 5781 | return observeSearchInput{}, store.EventSummaryQuery{}, err |
| 5782 | } |
| 5783 | return input, query, nil |
| 5784 | } |
| 5785 | |
| 5786 | func parseNativeOptionalRFC3339(id toolspkg.ToolID, field string, raw string) (time.Time, error) { |
| 5787 | trimmed := strings.TrimSpace(raw) |
no test coverage detected