connectorstore

type ExpandableGrantDef struct {
	RowID                   int64
	GrantExternalID         string
	TargetEntitlementID     string
	PrincipalResourceTypeID string
	PrincipalResourceID     string
	SourceEntitlementIDs    []string
	Shallow                 bool
	ResourceTypeIDs         []string
	NeedsExpansion          bool
}

type GrantListMode int

type GrantListOptions struct {
	// Mode controls which row shape/filter is returned.
	Mode GrantListMode

	// Resource filters payload modes to grants on a specific resource.
	Resource *v2.Resource

	// ExpandableOnly filters rows to grants with expansion metadata.
	// Used by payload+expansion mode.
	ExpandableOnly bool
	// NeedsExpansionOnly filters rows to needs_expansion=1.
	// Used by expansion-only modes.
	NeedsExpansionOnly bool

	// PageToken and PageSize are used for pagination in all modes.
	// SyncID is used for expansion-only modes.
	SyncID    string
	PageToken string
	PageSize  uint32
}

type GrantUpsertMode int

type GrantUpsertOptions struct {
	Mode GrantUpsertMode
}

type InternalGrantListResponse struct {
	Rows          []*InternalGrantRow
	NextPageToken string
}

type InternalGrantRow struct {
	Grant     *v2.Grant
	Expansion *ExpandableGrantDef
}

type InternalWriter interface {
	Writer
	// UpsertGrants writes grants with explicit conflict handling semantics.
	// This is for internal sync workflows that need control over if-newer behavior
	// and whether expansion columns are preserved.
	UpsertGrants(ctx context.Context, opts GrantUpsertOptions, grants ...*v2.Grant) error
	// ListGrantsInternal is the preferred internal listing API for grants.
	// It returns a single list of rows with optional grant payload and expansion metadata.
	ListGrantsInternal(ctx context.Context, opts GrantListOptions) (*InternalGrantListResponse, error)
	// SetSupportsDiff marks the sync as supporting diff operations.
	SetSupportsDiff(ctx context.Context, syncID string) error
}

type Reader interface {
	v2.ResourceTypesServiceServer
	reader_v2.ResourceTypesReaderServiceServer

	v2.ResourcesServiceServer
	reader_v2.ResourcesReaderServiceServer

	v2.EntitlementsServiceServer
	reader_v2.EntitlementsReaderServiceServer

	v2.GrantsServiceServer
	reader_v2.GrantsReaderServiceServer

	reader_v2.SyncsReaderServiceServer

	// GetAsset does not implement the AssetServer on the reader here. In other situations we were able to easily 'fake'
	// the GRPC api, but because this is defined as a streaming RPC, it isn't trivial to implement grpc streaming as part of the c1z format.
	GetAsset(ctx context.Context, req *v2.AssetServiceGetAssetRequest) (string, io.Reader, error)

	Close(ctx context.Context) error
}

type SyncType string

type Writer interface {
	Reader
	ResumeSync(ctx context.Context, syncType SyncType, syncID string) (string, error)
	StartOrResumeSync(ctx context.Context, syncType SyncType, syncID string) (string, bool, error)
	StartNewSync(ctx context.Context, syncType SyncType, parentSyncID string) (string, error)
	SetCurrentSync(ctx context.Context, syncID string) error
	CurrentSyncStep(ctx context.Context) (string, error)
	CheckpointSync(ctx context.Context, syncToken string) error
	EndSync(ctx context.Context) error
	PutAsset(ctx context.Context, assetRef *v2.AssetRef, contentType string, data []byte) error
	Cleanup(ctx context.Context) error

	PutGrants(ctx context.Context, grants ...*v2.Grant) error
	PutResourceTypes(ctx context.Context, resourceTypes ...*v2.ResourceType) error
	PutResources(ctx context.Context, resources ...*v2.Resource) error
	PutEntitlements(ctx context.Context, entitlements ...*v2.Entitlement) error
	DeleteGrant(ctx context.Context, grantId string) error
}