store

type AlreadyExistsError struct {
	Err error
}

type Config struct {
	Log *zap.Logger
	DB  *bun.DB
	// contains filtered or unexported fields
}

type IdentityStore interface {
	PublishIdentityUpdate(
		ctx context.Context,
		req *identity.PublishIdentityUpdateRequest,
		validationService mlsvalidate.MLSValidationService,
	) (*identity.PublishIdentityUpdateResponse, error)
	GetInboxLogs(
		ctx context.Context,
		req *identity.GetIdentityUpdatesRequest,
	) (*identity.GetIdentityUpdatesResponse, error)
	GetInboxIds(
		ctx context.Context,
		req *identity.GetInboxIdsRequest,
	) (*identity.GetInboxIdsResponse, error)
}

type IdentityUpdate struct {
	Kind               IdentityUpdateKind
	InstallationKey    []byte
	CredentialIdentity []byte
	TimestampNs        uint64
}

type IdentityUpdateKind int

type IdentityUpdateList []IdentityUpdate

type MlsStore interface {
	IdentityStore

	CreateOrUpdateInstallation(ctx context.Context, installationId []byte, keyPackage []byte) error
	FetchKeyPackages(
		ctx context.Context,
		installationIds [][]byte,
	) ([]queries.FetchKeyPackagesRow, error)
	InsertGroupMessage(
		ctx context.Context,
		groupId []byte,
		data []byte,
	) (*queries.GroupMessage, error)
	InsertWelcomeMessage(
		ctx context.Context,
		installationId []byte,
		data []byte,
		hpkePublicKey []byte,
		algorithm types.WrapperAlgorithm,
		welcomeMetadata []byte,
	) (*queries.WelcomeMessage, error)
	QueryGroupMessagesV1(
		ctx context.Context,
		query *mlsv1.QueryGroupMessagesRequest,
	) (*mlsv1.QueryGroupMessagesResponse, error)
	QueryWelcomeMessagesV1(
		ctx context.Context,
		query *mlsv1.QueryWelcomeMessagesRequest,
	) (*mlsv1.QueryWelcomeMessagesResponse, error)
	QueryCommitLog(
		ctx context.Context,
		query *mlsv1.QueryCommitLogRequest,
	) (*mlsv1.QueryCommitLogResponse, error)
	InsertCommitLog(
		ctx context.Context,
		groupId []byte,
		encrypted_entry []byte,
	) (queries.CommitLog, error)
}

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

type StoreOptions struct {
	DbConnectionString string        `long:"db-connection-string" description:"Connection string for MLS DB"`
	ReadTimeout        time.Duration `long:"read-timeout"         description:"Timeout for reading from the database" default:"10s"`
	WriteTimeout       time.Duration `long:"write-timeout"        description:"Timeout for writing to the database"   default:"10s"`
	MaxOpenConns       int           `long:"max-open-conns"       description:"Maximum number of open connections"    default:"80"`
}