db

type Connection struct {
	ApiUrl            string    `db:"api_url"`
	StoreId           string    `db:"store_id"`
	ContinuationToken string    `db:"continuation_token"`
	LastSync          time.Time `db:"last_sync"`
}

type Filter struct {
	Search     *string
	UserType   *string
	Relation   *string
	ObjectType *string
}

type LoadResult struct {

	// the tuple content itself
	Res []TuplePendingAction
	// whatever was the filter user, it's returned
	Filter *Filter
	// contains filtered or unexported fields
}

type PendingAction struct {
	Action string `db:"action"`
}

type SqlxRepository struct {
	TupleRepository
	// contains filtered or unexported fields
}

type Tuple struct {
	TupleKey   string    `db:"tuple_key"`
	UserType   string    `db:"user_type"`
	UserId     string    `db:"user_id"`
	Relation   string    `db:"relation"`
	ObjectType string    `db:"object_type"`
	ObjectId   string    `db:"object_id"`
	Timestamp  time.Time `db:"timestamp"`
	Row        int       `db:"row_number"`
}

type TuplePendingAction struct {
	*Tuple
	*PendingAction
}

type TupleRepository interface {
	CountTuples(filter *Filter) int
	GetMarkedForDeletion() []Tuple
	ApplyChange(change openfga.TupleChange)
	Prune() int
}