api

type CreateNodeEndpoint struct{}

type CreateRunEndpoint struct{}

type CreateRunReq struct {
	WorkerConfigID string `json:"worker_config_id"`
}

type CreateRunResp struct {
	RunID string `json:"run_id"`
}

type EdgeProvenanceResp struct {
	Edge             EdgeResponse  `json:"edge"`
	RunID            string        `json:"run_id,omitempty"`
	WorkerConfigNode *NodeResponse `json:"worker_config_node,omitempty"`
}

type EdgeResponse struct {
	ID           string   `json:"id"`
	SourceNodeID string   `json:"source_node_id"`
	TargetNodeID string   `json:"target_node_id"`
	Type         string   `json:"type"`
	Confidence   *float64 `json:"confidence,omitempty"`
	RunID        *string  `json:"run_id,omitempty"`
	CreatedAt    string   `json:"created_at"`
}

type GetEdgeEndpoint struct{}

type GetEdgeProvenanceEndpoint struct{}

type GetEdgeProvenanceReq struct {
	ID string `path:"id"`
}

type GetEdgeReq struct {
	ID string `path:"id"`
}

type GetEntityEndpoint struct{}

type GetEntityReq struct {
	ID            string   `path:"id"`
	MinConfidence *float64 `query:"min_confidence"`
}

type GetEntityResp struct {
	Entity    NodeResponse       `json:"entity"`
	Relations []RelationResponse `json:"relations"`
}

type GetEntityTimelineEndpoint struct{}

type GetEntityTimelineReq struct {
	ID string `path:"id"`
}

type GetEntityTimelineResp struct {
	Relations []RelationResponse `json:"relations"`
}

type GetNodeContentEndpoint struct{}

type GetNodeEdgesEndpoint struct{}

type GetNodeEdgesReq struct {
	ID        string  `path:"id"`
	Direction *string `query:"direction"` // incoming, outgoing, both
	Type      *string `query:"type"`      // provenance/input, provenance/worker, relation/head, relation/tail
	Limit     int     `query:"limit"`
	Offset    int     `query:"offset"`
}

type GetNodeEdgesResp struct {
	Edges []EdgeResponse `json:"edges"`
}

type GetNodeEndpoint struct{}

type GetNodeProvenanceEndpoint struct{}

type GetNodeProvenanceReq struct {
	ID string `path:"id"`
}

type GetNodeReq struct {
	ID string `path:"id"`
}

type GetQueueEndpoint struct{}

type GetQueueReq struct {
	ContentClass  string  `query:"content_class"`
	ContentType   string  `query:"content_type"`
	NotConsumedBy *string `query:"not_consumed_by"`
	Limit         int     `query:"limit"`
}

type GetQueueResp struct {
	Nodes []NodeResponse `json:"nodes"`
}

type ListNodesEndpoint struct{}

type ListNodesReq struct {
	Level        *int    `query:"level"`
	ContentClass *string `query:"content_class"`
	ContentType  *string `query:"content_type"`
	Limit        int     `query:"limit"`
	Offset       int     `query:"offset"`
}

type ListNodesResp struct {
	Nodes []NodeResponse `json:"nodes"`
}

type ListRelationsEndpoint struct{}

type ListRelationsReq struct {
	Unresolved *bool   `query:"unresolved"`
	Type       *string `query:"type"` // e.g. alias, has_role
	Limit      int     `query:"limit"`
	Offset     int     `query:"offset"`
}

type ListRelationsResp struct {
	Relations []RelationResponse `json:"relations"`
}

type NodeResponse struct {
	ID                    string   `json:"id"`
	Level                 int      `json:"level"`
	ContentClass          string   `json:"content_class"`
	ContentType           string   `json:"content_type"`
	EncodingClass         string   `json:"encoding_class"`
	EncodingFormat        string   `json:"encoding_format"`
	ContentSha256         string   `json:"content_sha256"`
	ContentLen            int64    `json:"content_len"`
	Content               *string  `json:"content,omitempty"`
	CreatedAt             string   `json:"created_at"`
	ArtifactCreatedAt     *string  `json:"artifact_created_at,omitempty"`
	ArtifactCreatedAtBlur *string  `json:"artifact_created_at_blur,omitempty"`
	Origin                *string  `json:"origin,omitempty"`
	OriginalName          *string  `json:"original_name,omitempty"`
	ValidFrom             *string  `json:"valid_from,omitempty"`
	ValidFromBlur         *string  `json:"valid_from_blur,omitempty"`
	ValidUntil            *string  `json:"valid_until,omitempty"`
	ValidUntilBlur        *string  `json:"valid_until_blur,omitempty"`
	Confidence            *float64 `json:"confidence,omitempty"`
}

type PaginationParams struct {
	Limit  int `query:"limit"`
	Offset int `query:"offset"`
}

type ProvenanceSubgraph struct {
	Nodes []NodeResponse `json:"nodes"`
	Edges []EdgeResponse `json:"edges"`
}

type RelationResponse struct {
	Node      NodeResponse   `json:"node"`
	HeadEdges []EdgeResponse `json:"head_edges"`
	TailEdges []EdgeResponse `json:"tail_edges"`
}

type SearchEntitiesEndpoint struct{}

type SearchEntitiesReq struct {
	Q      *string `query:"q"`
	Type   *string `query:"type"` // e.g. person, organization
	Limit  int     `query:"limit"`
	Offset int     `query:"offset"`
}

type SearchEntitiesResp struct {
	Entities []NodeResponse `json:"entities"`
}