persistence

type Page struct {
	// Limit is the maximum number of results per page.
	Limit int

	// Offset is the ordinal position, relative to the start of the unfiltered
	// set, of the first result of the page.
	Offset int

	// Total is the total number of search results before paging.
	Total int
}

type SIPFilter struct {
	// Name filters for SIPs whose names contain the given string.
	Name *string

	AIPID      *uuid.UUID
	Status     *enums.SIPStatus
	CreatedAt  *timerange.Range
	UploaderID *uuid.UUID

	entfilter.Sort
	Page
}

type SIPUpdater func(*datatypes.SIP) (*datatypes.SIP, error)

type Service interface {
	// CreateSIP persists the given SIP to the data store then updates
	// the SIP from the data store, adding auto-generated data
	// (e.g. ID, CreatedAt).
	CreateSIP(context.Context, *datatypes.SIP) error
	UpdateSIP(context.Context, uuid.UUID, SIPUpdater) (*datatypes.SIP, error)
	DeleteSIP(context.Context, int) error
	ReadSIP(context.Context, uuid.UUID) (*datatypes.SIP, error)
	ListSIPs(context.Context, *SIPFilter) ([]*datatypes.SIP, *Page, error)

	CreateWorkflow(context.Context, *datatypes.Workflow) error

	CreateTask(context.Context, *datatypes.Task) error
	UpdateTask(ctx context.Context, id int, updater TaskUpdater) (*datatypes.Task, error)

	// CreateUser persists a new user to the data store then updates the user
	// to add auto-generated data (e.g. ID, CreatedAt).
	CreateUser(context.Context, *datatypes.User) error

	// ReadUser retrieves a user by UUID.
	ReadUser(context.Context, uuid.UUID) (*datatypes.User, error)

	// ReadOIDCUser retrieves a user by OIDC issuer and subject.
	ReadOIDCUser(ctx context.Context, iss, sub string) (*datatypes.User, error)

	// ListUsers retrieves a list of users based on the provided filter.
	ListUsers(context.Context, *UserFilter) ([]*datatypes.User, *Page, error)
}

type TaskUpdater func(*datatypes.Task) (*datatypes.Task, error)

type UserFilter struct {
	CreatedAt *timerange.Range
	Email     *string
	Name      *string

	entfilter.Sort
	Page
}