wire

type DiffEntryWire struct {
	URI         string `json:"uri"`
	Status      string `json:"status"`
	SnapshotIDA string `json:"snapshot_id_a,omitempty"`
	SnapshotIDB string `json:"snapshot_id_b,omitempty"`
	// Per-side provenance: why the resolved bytes differ. Only populated for
	// a side whose manifest actually contains the URI (omitzero drops the
	// other side's zero timestamp rather than emitting year 1).
	SourceRevisionA string    `json:"source_revision_a,omitempty"`
	SourceRevisionB string    `json:"source_revision_b,omitempty"`
	ObservedAtA     time.Time `json:"observed_at_a,omitzero"`
	ObservedAtB     time.Time `json:"observed_at_b,omitzero"`
	RefA            string    `json:"ref_a,omitempty"`
	RefB            string    `json:"ref_b,omitempty"`
	UnifiedDiff     string    `json:"unified_diff,omitempty"`
}

type DiffResponse struct {
	ManifestA ManifestWire    `json:"manifest_a"`
	ManifestB ManifestWire    `json:"manifest_b"`
	Entries   []DiffEntryWire `json:"entries"`
}

type ErrorResponse struct {
	Error string `json:"error"`
}

type FilesystemConfigWire struct {
	Path string `json:"path"`
}

type FreshnessWire struct {
	// Status matches policy.Decision.String(): "fetch" | "use_current" |
	// "use_pinned" | "use_tag".
	Status     string  `json:"status"`
	AgeSeconds float64 `json:"age_seconds"`
}

type GitHubConfigWire struct {
	Owner string `json:"owner"`
	Repo  string `json:"repo"`
	Path  string `json:"path"`
	Ref   string `json:"ref"`
}

type HTTPConfigWire struct {
	URL     string            `json:"url"`
	Headers map[string]string `json:"headers,omitempty"`
}

type HistoryResponse struct {
	Snapshots []SnapshotWire `json:"snapshots"`
}

type ManifestEntryWire struct {
	Position int    `json:"position"`
	URI      string `json:"uri"`
	// Ref is the "@<tag>" this entry was mounted by, absent for a plain URI.
	Ref               string `json:"ref,omitempty"`
	SnapshotID        string `json:"snapshot_id"`
	MaterializationID string `json:"materialization_id"`
	ContentHash       string `json:"content_hash"`
}

type ManifestWire struct {
	ManifestID string              `json:"manifest_id"`
	RunID      string              `json:"run_id"`
	CreatedAt  time.Time           `json:"created_at"`
	Entries    []ManifestEntryWire `json:"entries"`
}

type MaterializationWire struct {
	ID          string    `json:"id"`
	SnapshotID  string    `json:"snapshot_id"`
	Strategy    string    `json:"strategy"`
	ContentHash string    `json:"content_hash"`
	Bytes       int64     `json:"bytes"`
	CreatedAt   time.Time `json:"created_at"`
}

type PolicyWire struct {
	Strategy         string `json:"strategy"`
	MaxAgeSeconds    int64  `json:"max_age_seconds,omitempty"`
	PinnedSnapshotID string `json:"pinned_snapshot_id,omitempty"`
}

type RegisterResourceRequest struct {
	URI    string     `json:"uri"`
	Source SourceWire `json:"source"`
	Policy PolicyWire `json:"policy"`
}

type ReplayEntryWire struct {
	Position          int    `json:"position"`
	URI               string `json:"uri"`
	MaterializationID string `json:"materialization_id"`
	RecordedHash      string `json:"recorded_hash"`
	ReplayedHash      string `json:"replayed_hash"`
	Content           []byte `json:"content"`
	Match             bool   `json:"match"`
}

type ReplayResponse struct {
	Manifest ManifestWire      `json:"manifest"`
	Entries  []ReplayEntryWire `json:"entries"`
}

type ResolveRequest struct {
	// URI may carry a trailing "@<tag>" (readproof://ns/path@prod), which
	// resolves to exactly that tagged snapshot with no source fetch and no
	// policy evaluation.
	URI string `json:"uri"`
}

type ResolveResourceWire struct {
	URI    string     `json:"uri"`
	Ref    string     `json:"ref,omitempty"`
	Policy PolicyWire `json:"policy"`
}

type ResolveResponse struct {
	Resource        ResolveResourceWire `json:"resource"`
	Snapshot        SnapshotWire        `json:"snapshot"`
	Materialization MaterializationWire `json:"materialization"`
	Freshness       FreshnessWire       `json:"freshness"`
	// Content is base64-encoded automatically by encoding/json for []byte.
	Content []byte `json:"content"`
}

type ResourceListResponse struct {
	Resources []ResourceWire `json:"resources"`
}

type ResourceWire struct {
	URI               string     `json:"uri"`
	Namespace         string     `json:"namespace"`
	Path              string     `json:"path"`
	Source            SourceWire `json:"source"`
	Policy            PolicyWire `json:"policy"`
	CurrentSnapshotID string     `json:"current_snapshot_id,omitempty"`
	CreatedAt         time.Time  `json:"created_at"`
	UpdatedAt         time.Time  `json:"updated_at"`
}

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

type RunMountRequest struct {
	RunID string `json:"run_id"`
	// URI may carry a trailing "@<tag>", exactly as in ResolveRequest.
	URI string `json:"uri"`
}

type RunMountResponse struct {
	Position int `json:"position"`
	// Resolve.resource.ref carries the tag this mount was pinned to, and is
	// what the manifest entry's "ref" will hold after commit.
	Resolve ResolveResponse `json:"resolve"`
}

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

type SetTagRequest struct {
	URI        string `json:"uri"`
	Tag        string `json:"tag"`
	SnapshotID string `json:"snapshot_id"`
}

type SnapshotWire struct {
	ID             string            `json:"id"`
	ResourceURI    string            `json:"resource_uri"`
	SourceRevision string            `json:"source_revision"`
	ContentHash    string            `json:"content_hash"`
	ObservedAt     time.Time         `json:"observed_at"`
	CreatedAt      time.Time         `json:"created_at"`
	ContentType    string            `json:"content_type"`
	Bytes          int64             `json:"bytes"`
	Provenance     map[string]string `json:"provenance"`
}

type SourceWire struct {
	Kind       string                `json:"kind"`
	Filesystem *FilesystemConfigWire `json:"filesystem,omitempty"`
	GitHub     *GitHubConfigWire     `json:"github,omitempty"`
	HTTP       *HTTPConfigWire       `json:"http,omitempty"`
}

type TagListResponse struct {
	Tags []TagWire `json:"tags"`
}

type TagWire struct {
	URI        string    `json:"uri"`
	Tag        string    `json:"tag"`
	SnapshotID string    `json:"snapshot_id"`
	UpdatedAt  time.Time `json:"updated_at"`
}