pquery

type AuthProvider interface {
	AuthFilter(ctx context.Context) (map[string]string, error)
}

type AuthProviderFunc func(ctx context.Context) (map[string]string, error)

type Column struct {
	Name string

	// The point within the root element which is stored in the column. An empty
	// path means this stores the root element,
	MountPoint *pgstore.Path
}

type GetJoinSpec struct {
	TableName     string
	DataColumn    string
	On            JoinFields
	FieldInParent protoreflect.Name
}

type GetRequest interface {
	proto.Message
}

type GetResponse interface {
	proto.Message
}

type GetSpec[
	REQ GetRequest,
	RES GetResponse,
] struct {
	TableName  string
	DataColumn string
	Auth       AuthProvider
	AuthJoin   []*LeftJoin

	PrimaryKey func(REQ) (map[string]any, error)

	StateResponseField protoreflect.Name

	Join *GetJoinSpec
}

type Getter[
	REQ GetRequest,
	RES proto.Message,
] struct {
	// contains filtered or unexported fields
}

type JoinField struct {
	JoinColumn string // The name of the column in the table being introduced
	RootColumn string // The name of the column in the root table
}

type JoinFields []JoinField

type LeftJoin struct {
	TableName string
	On        JoinFields
}

type ListReflectionSet struct {
	RequestFilterFields []protoreflect.FieldDescriptor
	// contains filtered or unexported fields
}

type ListRequest interface {
	proto.Message
}

type ListResponse interface {
	proto.Message
}

type ListSpec[REQ ListRequest, RES ListResponse] struct {
	TableSpec
	RequestFilter func(REQ) (map[string]any, error)
}

type Lister[REQ ListRequest, RES ListResponse] struct {
	ListReflectionSet
	// contains filtered or unexported fields
}

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

type QueryLogger func(sqrlx.Sqlizer)

type TableSpec struct {
	TableName string

	Auth     AuthProvider
	AuthJoin []*LeftJoin

	DataColumn string // TODO: Replace with array Columns []Column

	// List of fields to sort by if no other unique sort is found.
	FallbackSortColumns []ProtoField
}

type Transactor interface {
	Transact(ctx context.Context, opts *sqrlx.TxOptions, callback sqrlx.Callback) error
}