db

type CredentialSubjectDoc struct {
	Identifier string `bson:"identifier"`
	Section    int64  `bson:"section"`
	Index      int64  `bson:"index"`
}

type CredentialSubjectsColl struct {
	Service *Service
	Coll    *mongo.Collection
	// contains filtered or unexported fields
}

type Service struct {
	MongoClient *mongo.Client

	// Token Status List collections (MongoDB)
	TokenStatusListColl     *TokenStatusListColl
	TokenStatusListMetadata *TokenStatusListMetadataColl
	CredentialSubjects      *CredentialSubjectsColl
	// contains filtered or unexported fields
}

type TokenStatusListColl struct {
	Service *Service
	Coll    *mongo.Collection
	// contains filtered or unexported fields
}

type TokenStatusListDoc struct {
	Index   int64 `bson:"index"`
	Status  uint8 `bson:"status"`
	Decoy   bool  `bson:"decoy"`
	Section int64 `bson:"section"`
}

type TokenStatusListMetadataColl struct {
	Service *Service
	Coll    *mongo.Collection
	// contains filtered or unexported fields
}

type TokenStatusListMetadataDoc struct {
	CurrentSection int64   `bson:"current_section"`
	Sections       []int64 `bson:"sections"`
}

type TokenStatusListMetadataStore interface {
	GetCurrentSection(ctx context.Context) (int64, error)
	UpdateCurrentSection(ctx context.Context, newSection int64) error
	GetAllSections(ctx context.Context) ([]int64, error)
}

type TokenStatusListStore interface {
	CountDocs(ctx context.Context, filter bson.M) (int64, error)
	CreateNewSection(ctx context.Context, section int64, sectionSize int64) error
	Add(ctx context.Context, section int64, status uint8) (int64, error)
	UpdateStatus(ctx context.Context, section int64, index int64, status uint8) error
	GetAllStatusesForSection(ctx context.Context, section int64) ([]uint8, error)
	InitializeIfEmpty(ctx context.Context) error
	FindOne(ctx context.Context, section, index int64) (*TokenStatusListDoc, error)
}