bbl

type AndCondition struct {
	Or    []*OrCondition `json:"or,omitempty"`
	Terms *TermsFilter   `json:"terms,omitempty"`
}

type Append struct {
	RecordType string `json:"record_type"`
	RecordID   ID     `json:"id"`
	Field      string `json:"field"`
	Val        any    `json:"val"` // single item, e.g. Keyword{Val: "polymer"}
}

type AuthProvider struct {
	Provider string `json:"provider"`
}

type Authorizer struct {
	// contains filtered or unexported fields
}

type BatchEditInput struct {
	ListID   ID        `json:"list_id"`
	UserID   ID        `json:"user_id"`
	Statuses []string  `json:"statuses"`
	Ops      []BatchOp `json:"ops"`
}

type BatchEditOutput struct {
	Updated   int    `json:"updated"`
	Skipped   int    `json:"skipped"`
	Conflicts int    `json:"conflicts"`
	Errors    int    `json:"errors"`
	Error     string `json:"error,omitempty"`
}

type BatchError struct {
	WorkID ID
	Err    error
}

type BatchOp struct {
	Op    string // "set", "hide", "unset", "append", "remove"
	Field string // "volume", "keywords", etc.
	Value string // raw value — empty for hide/unset
}

type BatchResult struct {
	Updated   int
	Skipped   int
	Conflicts []ID
	Errors    []BatchError
}

type ClaimWorkUploads struct {
	WorkID    ID   `json:"id"`
	UploadIDs []ID `json:"upload_ids"`
	// contains filtered or unexported fields
}

type Conference struct {
	Name      string    `json:"name,omitempty"`
	Organizer string    `json:"organizer,omitempty"`
	Location  string    `json:"location,omitempty"`
	StartDate time.Time `json:"start_date,omitzero"`
	EndDate   time.Time `json:"end_date,omitzero"`
}

type CreateOrganization struct {
	ID        ID         `json:"id"`
	Kind      string     `json:"kind"`
	StartDate *time.Time `json:"start_date"`
	EndDate   *time.Time `json:"end_date"`
}

type CreatePerson struct {
	ID ID `json:"id"`
}

type CreateProject struct {
	ID        ID         `json:"id"`
	Status    string     `json:"status"`
	StartDate *time.Time `json:"start_date"`
	EndDate   *time.Time `json:"end_date"`
}

type CreateWork struct {
	ID     ID     `json:"id"`
	Kind   string `json:"kind"`
	Status string `json:"status"` // defaults to WorkStatusPrivate
}

type DeleteOrganization struct {
	OrganizationID ID `json:"id"`
}

type DeletePerson struct {
	PersonID ID `json:"id"`
}

type DeleteProject struct {
	ProjectID ID `json:"id"`
}

type DeleteWork struct {
	WorkID     ID     `json:"id"`
	DeleteKind string `json:"delete_kind"`
}

type DownloadURLOpts struct {
	TTL         time.Duration
	Filename    string // sets Content-Disposition: attachment; filename="..."
	ContentType string // overrides Content-Type header
}

type Extent struct {
	Start string `json:"start,omitempty"`
	End   string `json:"end,omitempty"`
}

type Facet struct {
	Name string       `json:"name"`
	Vals []FacetValue `json:"vals"`
}

type FacetValue struct {
	Val   string `json:"val"`
	Count int    `json:"count"`
}

type FieldEdit struct {
	Val    json.RawMessage `json:"val,omitempty"`
	Hidden bool            `json:"hidden,omitempty"`
	Role   string          `json:"role"`
	Rev    int64           `json:"rev"`
}

type FieldStrategy int

type FieldType struct {
	Name string
	// contains filtered or unexported fields
}

type FieldVal struct {
	// contains filtered or unexported fields
}

type FileStore interface {
	Upload(ctx context.Context, r io.Reader) (id string, err error)
	Download(ctx context.Context, id string, w io.Writer) error
	Delete(ctx context.Context, id string) error
	Exists(ctx context.Context, id string) (bool, error)

	NewUploadURL(ctx context.Context, ttl time.Duration) (id string, url string, err error)
	NewDownloadURL(ctx context.Context, id string, opts DownloadURLOpts) (string, error)
}

type Grant struct {
	Capability string `json:"capability"`
	Scope      string `json:"scope"`
	Match      string `json:"match,omitempty"`
	MatchID    *ID    `json:"match_id,omitempty"`
}

type Hide struct {
	RecordType string `json:"record_type"`
	RecordID   ID     `json:"id"`
	Field      string `json:"field"`
}

type ID [16]byte

type Identifier struct {
	Scheme string `json:"scheme"`
	Val    string `json:"val"`
}

type ImportOrganizationInput struct {
	ID              *ID        `json:"id,omitempty"`
	SourceID        string     `json:"source_id"`
	Kind            string     `json:"kind"`
	StartDate       *time.Time `json:"start_date,omitempty"`
	EndDate         *time.Time `json:"end_date,omitempty"`
	SourceUpdatedAt *time.Time `json:"source_updated_at,omitempty"`
	SourceRecord    []byte     `json:"-"`
	// contains filtered or unexported fields
}

type ImportOrganizationRel struct {
	Ref       Ref        `json:"ref"`
	Kind      string     `json:"kind"`
	StartDate *time.Time `json:"start_date,omitempty"`
	EndDate   *time.Time `json:"end_date,omitempty"`
}

type ImportPersonAffiliation struct {
	Ref Ref `json:"ref"`
}

type ImportPersonInput struct {
	ID              *ID        `json:"id,omitempty"`
	SourceID        string     `json:"source_id"`
	SourceUpdatedAt *time.Time `json:"source_updated_at,omitempty"`
	SourceRecord    []byte     `json:"-"`
	// contains filtered or unexported fields
}

type ImportProjectInput struct {
	ID              *ID        `json:"id,omitempty"`
	SourceID        string     `json:"source_id"`
	Status          string     `json:"status,omitempty"`
	StartDate       *time.Time `json:"start_date,omitempty"`
	EndDate         *time.Time `json:"end_date,omitempty"`
	SourceUpdatedAt *time.Time `json:"source_updated_at,omitempty"`
	SourceRecord    []byte     `json:"-"`
	// contains filtered or unexported fields
}

type ImportProjectParticipant struct {
	Ref  Ref    `json:"ref"`
	Role string `json:"role,omitempty"`
}

type ImportUserInput struct {
	SourceName   string           `json:"source_name,omitempty"`
	SourceID     string           `json:"source_id"`
	ExpiresAt    *time.Time       `json:"expires_at,omitempty"` // nil = permanent; set for recurring directory sources
	Username     string           `json:"username"`
	Email        string           `json:"email"`
	Name         string           `json:"name"`
	Role         string           `json:"role,omitempty"`
	Identifiers  []UserIdentifier `json:"identifiers,omitempty"`
	AuthProvider string           `json:"auth_provider,omitempty"` // optional — name of the auth provider this source drives (e.g. "ugent_oidc")
}

type ImportWorkContributor struct {
	PersonRef  *Ref     `json:"person_ref,omitempty"`
	Kind       string   `json:"kind,omitempty"` // "person" (default) or "organization"
	Roles      []string `json:"roles,omitempty"`
	Name       string   `json:"name,omitempty"`
	GivenName  string   `json:"given_name,omitempty"`
	MiddleName string   `json:"middle_name,omitempty"`
	FamilyName string   `json:"family_name,omitempty"`
}

type ImportWorkInput struct {
	ID              *ID        `json:"id,omitempty"`
	SourceID        string     `json:"source_id"`
	Kind            string     `json:"kind"`
	Status          string     `json:"status,omitempty"`
	SourceUpdatedAt *time.Time `json:"source_updated_at,omitempty"`
	SourceRecord    []byte     `json:"-"`
	// contains filtered or unexported fields
}

type ImportWorkOrganization struct {
	Ref Ref `json:"ref"`
}

type ImportWorkProject struct {
	Ref Ref `json:"ref"`
}

type ImportWorkRel struct {
	Ref  Ref    `json:"ref"`
	Kind string `json:"kind"`
}

type Index interface {
	Works() WorkIndex
	People() PersonIndex
	Projects() ProjectIndex
	Organizations() OrganizationIndex
}

type Keyword struct {
	Val string `json:"val"`
}

type List struct {
	ID          ID         `json:"id"`
	Version     int        `json:"version"`
	Slug        string     `json:"slug"`
	Name        string     `json:"name"`
	Description string     `json:"description,omitempty"`
	RecordType  string     `json:"record_type,omitempty"`
	Query       *ListQuery `json:"query,omitempty"`
	AccessLevel string     `json:"access_level"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
	CreatedByID ID         `json:"created_by_id"`
}

type ListItem struct {
	RecordType string
	RecordID   ID
	Position   string
}

type ListPublicWorksOpts struct {
	From   time.Time
	Until  time.Time
	Cursor string // opaque, from previous result
	Limit  int
}

type ListPublicWorksResult struct {
	Works  []*Work
	Cursor string // empty = last page
}

type ListQuery struct {
	Query  string       `json:"query,omitempty"`
	Filter *QueryFilter `json:"filter,omitempty"`
}

type ListRepresentationOpts struct {
	Scheme string
	From   *time.Time
	Until  *time.Time
	Cursor string
	Limit  int
}

type ListRepresentationResult struct {
	Representations []*Representation
	Cursor          string
}

type LogEntry struct {
	Op   string          `json:"op"`             // "create", "delete", "set", "hide", "unset"
	Data json.RawMessage `json:"data,omitempty"` // op-specific: {"field":"volume","prev_val":...}
}

type Note struct {
	Kind string `json:"kind,omitempty"`
	Val  string `json:"val"`
}

type Op interface {
	// contains filtered or unexported methods
}

type OrCondition struct {
	And   []*AndCondition `json:"and,omitempty"`
	Terms *TermsFilter    `json:"terms,omitempty"`
}

type Organization struct {
	ID          ID         `json:"id"`
	RevID       int64      `json:"rev_id"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
	CreatedByID *ID        `json:"created_by_id,omitempty"`
	UpdatedByID *ID        `json:"updated_by_id,omitempty"`
	Kind        string     `json:"kind"`
	Status      string     `json:"status"`
	StartDate   *time.Time `json:"start_date,omitempty"`
	EndDate     *time.Time `json:"end_date,omitempty"`
	DeletedAt   *time.Time `json:"deleted_at,omitempty"`
	DeletedByID *ID        `json:"deleted_by_id,omitempty"`
	// contains filtered or unexported fields
}

type OrganizationHit struct {
	ID   ID     `json:"id"`
	Kind string `json:"kind"`
	Name string `json:"name"`
}

type OrganizationHits struct {
	Hits   []OrganizationHit `json:"hits"`
	Total  int               `json:"total"`
	Cursor string            `json:"cursor,omitempty"`
	Facets []Facet           `json:"facets,omitempty"`
}

type OrganizationIndex interface {
	Add(ctx context.Context, org *Organization) error
	Delete(ctx context.Context, id ID) error
	DeleteAll(ctx context.Context) error
	Search(ctx context.Context, opts *SearchOpts) (*OrganizationHits, error)
	Reindex(ctx context.Context, all iter.Seq2[*Organization, error], changed func(since time.Time) iter.Seq2[*Organization, error]) error
}

type OrganizationRel struct {
	RelOrganizationID ID         `json:"rel_organization_id"`
	Kind              string     `json:"kind"`
	StartDate         *time.Time `json:"start_date,omitempty"`
	EndDate           *time.Time `json:"end_date,omitempty"`
}

type OrganizationSource interface {
	Iter(ctx context.Context) (iter.Seq2[*ImportOrganizationInput, error], error)
}

type Person struct {
	ID          ID         `json:"id"`
	RevID       int64      `json:"rev_id"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
	CreatedByID *ID        `json:"created_by_id,omitempty"`
	UpdatedByID *ID        `json:"updated_by_id,omitempty"`
	Status      string     `json:"status"`
	DeletedAt   *time.Time `json:"deleted_at,omitempty"`
	DeletedByID *ID        `json:"deleted_by_id,omitempty"`
	// contains filtered or unexported fields
}

type PersonAffiliation struct {
	OrganizationID ID `json:"organization_id"`
}

type PersonHit struct {
	ID   ID     `json:"id"`
	Name string `json:"name"`
}

type PersonHits struct {
	Hits   []PersonHit `json:"hits"`
	Total  int         `json:"total"`
	Cursor string      `json:"cursor,omitempty"`
	Facets []Facet     `json:"facets,omitempty"`
}

type PersonIndex interface {
	Add(ctx context.Context, person *Person) error
	Delete(ctx context.Context, id ID) error
	DeleteAll(ctx context.Context) error
	Search(ctx context.Context, opts *SearchOpts) (*PersonHits, error)
	Reindex(ctx context.Context, all iter.Seq2[*Person, error], changed func(since time.Time) iter.Seq2[*Person, error]) error
}

type PersonSource interface {
	Iter(ctx context.Context) (iter.Seq2[*ImportPersonInput, error], error)
}

type ProfileField struct {
	Name     string
	Type     *FieldType
	Required string   // "", "always", "public"
	Schemes  []string // for identifier, classification
}

type Profiles struct {
	Work         map[string][]ProfileField
	Organization map[string][]ProfileField
	Person       []ProfileField
	Project      []ProfileField
	// contains filtered or unexported fields
}

type Project struct {
	ID          ID         `json:"id"`
	RevID       int64      `json:"rev_id"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
	CreatedByID *ID        `json:"created_by_id,omitempty"`
	UpdatedByID *ID        `json:"updated_by_id,omitempty"`
	Status      string     `json:"status"`
	StartDate   *time.Time `json:"start_date,omitempty"`
	EndDate     *time.Time `json:"end_date,omitempty"`
	DeletedAt   *time.Time `json:"deleted_at,omitempty"`
	DeletedByID *ID        `json:"deleted_by_id,omitempty"`
	// contains filtered or unexported fields
}

type ProjectHit struct {
	ID     ID     `json:"id"`
	Status string `json:"status"`
	Title  string `json:"title"`
}

type ProjectHits struct {
	Hits   []ProjectHit `json:"hits"`
	Total  int          `json:"total"`
	Cursor string       `json:"cursor,omitempty"`
	Facets []Facet      `json:"facets,omitempty"`
}

type ProjectIndex interface {
	Add(ctx context.Context, project *Project) error
	Delete(ctx context.Context, id ID) error
	DeleteAll(ctx context.Context) error
	Search(ctx context.Context, opts *SearchOpts) (*ProjectHits, error)
	Reindex(ctx context.Context, all iter.Seq2[*Project, error], changed func(since time.Time) iter.Seq2[*Project, error]) error
}

type ProjectParticipant struct {
	PersonID ID     `json:"person_id"`
	Role     string `json:"role,omitempty"`
}

type ProjectSource interface {
	Iter(ctx context.Context) (iter.Seq2[*ImportProjectInput, error], error)
}

type QueryFilter struct {
	And []*AndCondition `json:"and"`
}

type RecordEvent struct {
	RecordID     ID         `json:"record_id"`
	RevID        int64      `json:"rev_id"`
	Status       string     `json:"status"`
	MadePublicAt *time.Time `json:"made_public_at,omitempty"`
}

type RecordOp struct {
	RecordID   ID
	RecordType string
	IsCreate   bool // if true, gather skips loading (record doesn't exist yet)
	Apply      func(rec *RecordState, user *User) ([]LogEntry, error)
	// Write is optional lifecycle SQL (create/delete). If non-nil, called during
	// the write phase. Field ops leave this nil.
	Write lifecycleWriteFn
}

type RecordState struct {
	RecordType   string
	RecordID     ID
	RevID        int64
	Kind         string
	Status       string
	MadePublicAt *time.Time

	// All source assertions (scalar + relational fields JSONB per source).
	Sources []sourceAssertion

	// Human field edits (scalar + relational field values).
	FieldEdits map[string]FieldEdit

	// Current resolved fields JSONB (for noop detection in prune).
	Fields map[string]json.RawMessage

	// Source priorities (for resolving winning asserter in noop detection).
	Priorities map[string]int

	// Work files (not assertions — loaded and written directly).
	Files []WorkFile

	// Lifecycle flags (set by apply).
	IsNew     bool
	IsDeleted bool
	// contains filtered or unexported fields
}

type Ref struct {
	ID         *ID         `json:"id,omitempty"`
	SourceID   string      `json:"source_id,omitempty"`
	Identifier *Identifier `json:"identifier,omitempty"`
}

type Remove struct {
	RecordType string `json:"record_type"`
	RecordID   ID     `json:"id"`
	Field      string `json:"field"`
	Val        any    `json:"val"` // item to match, e.g. Keyword{Val: "draft"}
}

type RemoveWorkFiles struct {
	WorkID  ID   `json:"id"`
	FileIDs []ID `json:"file_ids"`
	// contains filtered or unexported fields
}

type Repo struct {
	Profiles *Profiles // nil = no profile validation
	// contains filtered or unexported fields
}

type Representation struct {
	RecordID  ID
	Scheme    string
	Record    []byte
	DeletedAt *time.Time
	RevID     int64
	UpdatedAt time.Time
}

type ResolvedRecord struct {
	*RecordState

	// Resolved fields (output of resolveFields).
	ResolvedFields map[string]json.RawMessage

	// Log entries collected from apply.
	LogEntries []LogEntry

	// Set by prune — if true, nothing changed for this record.
	Noop bool
	// contains filtered or unexported fields
}

type RevEffect struct {
	RecordType string
	RecordID   ID
	RevID      int64
}

type RevState struct {
	Records    map[ID]*RecordState
	Priorities map[string]int
}

type RoleConfig struct {
	Priority int
	Grants   []Grant
}

type SearchOpts struct {
	Query  string       `json:"query,omitempty"`
	Filter *QueryFilter `json:"filter,omitempty"`
	Facets []string     `json:"facets,omitempty"`
	Size   int          `json:"size"`
	Cursor string       `json:"cursor,omitempty"` // base64-encoded search_after; mutually exclusive with Offset
	Offset int          `json:"offset,omitempty"` // for UI pagination; hard max enforced by implementation
}

type Services struct {
	Repo            *Repo
	Index           Index
	FileStore       FileStore
	Catbird         *catbird.Client
	Authorizer      *Authorizer
	UserSources     map[string]UserSource
	WorkIterSources map[string]WorkSourceIter
	WorkGetSources  map[string]WorkSourceGetter
	WorkEncoders    map[string]WorkEncoder
}

type Set struct {
	RecordType string `json:"record_type"`
	RecordID   ID     `json:"id"`
	Field      string `json:"field"`
	Val        any    `json:"val"`
}

type SetWorkReviewStatus struct {
	WorkID       ID      `json:"id"`
	ReviewStatus *string `json:"review_status"`
}

type SetWorkStatus struct {
	WorkID ID     `json:"id"`
	Status string `json:"status"`
}

type TermsFilter struct {
	Field string   `json:"field"`
	Terms []string `json:"terms"`
}

type Text struct {
	Lang string `json:"lang"`
	Val  string `json:"val"`
}

type Title struct {
	Lang string `json:"lang"`
	Val  string `json:"val"`
}

type Unset struct {
	RecordType string `json:"record_type"`
	RecordID   ID     `json:"id"`
	Field      string `json:"field"`
}

type UpdateOpts struct {
	User *User // who is making the change (nil for system jobs)
	Rev  int64 // if non-zero, reject if any affected record has rev_id > this
}

type Upload struct {
	ID          ID        `json:"id"`
	UserID      ID        `json:"user_id"`
	BlobID      string    `json:"blob_id"`
	Name        string    `json:"name"`
	ContentType string    `json:"content_type"`
	Size        int       `json:"size"`
	SHA256      string    `json:"sha256,omitempty"`
	Status      string    `json:"status"`
	CreatedAt   time.Time `json:"created_at"`
}

type User struct {
	ID            ID
	CreatedAt     time.Time
	Username      string
	Email         string
	Name          string
	Role          string
	DeactivateAt  *time.Time
	PersonID      *ID
	AuthProviders []AuthProvider
	Grants        *UserGrants // populated by Authorizer.Resolve; nil for imports/CLI
}

type UserAttrs struct {
	Username string
	Email    string
	Name     string
	Role     string
}

type UserGrants struct {
	// contains filtered or unexported fields
}

type UserHit struct {
	ID   ID
	Name string
	Role string
}

type UserHits struct {
	Hits  []*UserHit
	Total int
}

type UserIdentifier struct {
	Scheme string `json:"scheme"`
	Val    string `json:"val"`
}

type UserSource interface {
	Iter(ctx context.Context) (iter.Seq2[*ImportUserInput, error], error)
}

type Work struct {
	ID           ID         `json:"id"`
	RevID        int64      `json:"rev_id"`
	CreatedAt    time.Time  `json:"created_at"`
	UpdatedAt    time.Time  `json:"updated_at"`
	CreatedByID  *ID        `json:"created_by_id,omitempty"`
	UpdatedByID  *ID        `json:"updated_by_id,omitempty"`
	Kind         string     `json:"kind"`
	Status       string     `json:"status"`
	ReviewStatus string     `json:"review_status,omitempty"` // empty = not in review
	DeleteKind   string     `json:"delete_kind,omitempty"`
	DeletedAt    *time.Time `json:"deleted_at,omitempty"`
	DeletedByID  *ID        `json:"deleted_by_id,omitempty"`
	MadePublicAt *time.Time `json:"made_public_at,omitempty"`
	Files        []WorkFile `json:"files,omitempty"`
	// contains filtered or unexported fields
}

type WorkCollection struct {
	ID          ID         `json:"id"`
	Version     int        `json:"version"`
	Slug        string     `json:"slug"`
	Name        string     `json:"name"`
	Description string     `json:"description,omitempty"`
	Query       *ListQuery `json:"query,omitempty"`
	CreatedAt   time.Time  `json:"created_at"`
	UpdatedAt   time.Time  `json:"updated_at"`
}

type WorkContributor struct {
	Kind       string   `json:"kind,omitempty"` // "person" (default) or "organization"
	PersonID   *ID      `json:"person_id,omitempty"`
	Name       string   `json:"name,omitempty"`
	GivenName  string   `json:"given_name,omitempty"`
	FamilyName string   `json:"family_name,omitempty"`
	Roles      []string `json:"roles,omitempty"`
}

type WorkDecoder interface {
	Decode(data []byte) (*ImportWorkInput, error)
}

type WorkEncoder interface {
	Encode(work *Work) ([]byte, error)
}

type WorkFile struct {
	ID                 ID         `json:"id"`
	WorkID             ID         `json:"work_id,omitempty"`
	Position           int        `json:"position,omitempty"`
	BlobID             string     `json:"blob_id"`
	Name               string     `json:"name"`
	ContentType        string     `json:"content_type"`
	Size               int        `json:"size"`
	SHA256             string     `json:"sha256,omitempty"`
	AccessLevel        string     `json:"access_level"`
	EmbargoUntil       *time.Time `json:"embargo_until,omitempty"`
	EmbargoAccessLevel string     `json:"embargo_access_level,omitempty"`
	EmbargoLiftedAt    *time.Time `json:"embargo_lifted_at,omitempty"`
}

type WorkHistoryEntry struct {
	RevID     int64
	RevAt     time.Time
	Field     string
	Op        string // 'set', 'hide', 'unset'
	Val       json.RawMessage
	By        string // user name or source name
	IsHistory bool   // true = previous value, false = current
}

type WorkHit struct {
	ID     ID     `json:"id"`
	Kind   string `json:"kind"`
	Status string `json:"status"`
	Title  string `json:"title"`
}

type WorkHits struct {
	Hits   []WorkHit `json:"hits"`
	Total  int       `json:"total"`
	Cursor string    `json:"cursor,omitempty"`
	Facets []Facet   `json:"facets,omitempty"`
}

type WorkIndex interface {
	Add(ctx context.Context, work *Work) error
	Delete(ctx context.Context, id ID) error
	DeleteAll(ctx context.Context) error
	Search(ctx context.Context, opts *SearchOpts) (*WorkHits, error)
	Reindex(ctx context.Context, all iter.Seq2[*Work, error], changed func(since time.Time) iter.Seq2[*Work, error]) error
}

type WorkReader interface {
	Read(r io.Reader) iter.Seq2[*ImportWorkInput, error]
}

type WorkRecordHit struct {
	Work *Work `json:"work"`
}

type WorkRecordHits struct {
	Hits   []WorkRecordHit `json:"hits"`
	Total  int             `json:"total"`
	Cursor string          `json:"cursor,omitempty"`
	Facets []Facet         `json:"facets,omitempty"`
}

type WorkRel struct {
	RelatedWorkID ID     `json:"related_work_id"`
	Kind          string `json:"kind"`
}

type WorkSourceGetter interface {
	Get(ctx context.Context, id string) (*ImportWorkInput, error)
}

type WorkSourceIter interface {
	Iter(ctx context.Context) (iter.Seq2[*ImportWorkInput, error], error)
}

type WorkWriter interface {
	Begin(w io.Writer) error
	Encode(w io.Writer, work *Work) error
	End(w io.Writer) error
}