botsfwstoredalgo

Jul 25, 2026

Changes in this version

+ func NewWebhookUpdateKey(key botsfwstore.WebhookUpdateKey) *dalrecord.Key

type StateStore

+ func (s *StateStore) ClaimWebhookUpdate(ctx context.Context, key botsfwstore.WebhookUpdateKey, leaseUntil time.Time) (claim botsfwstore.WebhookUpdateClaim, err error)

+ func (s *StateStore) CompleteWebhookUpdate(ctx context.Context, key botsfwstore.WebhookUpdateKey, leaseID string) error

+ func (s *StateStore) FailWebhookUpdate(ctx context.Context, key botsfwstore.WebhookUpdateKey, leaseID string, ...) error

Jul 25, 2026

Changes in this version

+ type StateStoreOption func(*StateStore)

+ func WithClock(now func() time.Time) StateStoreOption

Jul 20, 2026

Changes in this version

+ func CreatePlatformUserRecord(ctx context.Context, tx dal.ReadwriteTransaction, platformID, userID string, ...) error

+ func NewBotChatKey[PlatformID ~string](platformID PlatformID, botID, chatID string) *dal.Key

+ func NewBotKey[PlatformID ~string](platformID PlatformID, botID string) *dal.Key

+ func NewPlatformKey[PlatformID ~string](platformID PlatformID) *dal.Key

+ func NewPlatformUserKey[PlatformID ~string](platformID PlatformID, userID string) *dal.Key

+ type AppUserStore interface

+ AppUser func(ctx context.Context, tx dal.ReadSession, botID, appUserID string) (botsfwstore.AppUser, error)

+ EnsureAppUser func(ctx context.Context, tx dal.ReadwriteTransaction, ...) (botsfwstore.AppUser, error)

+ PrepareAppUser func(ctx context.Context, identity botsfwstore.Identity) (botsfwstore.AppUser, error)

+ type BotUser = PlatformUserRecord

+ type DBProvider func(ctx context.Context) (dal.DB, error)

+ type PlatformUserRecord = record.DataWithID[string, botsfwmodels.PlatformUserData]

+ func GetPlatformUser(ctx context.Context, reader dal.ReadSession, platformID, userID string, ...) (PlatformUserRecord, error)

+ type StateStore struct

+ func NewStateStore(db dal.DB, appUsers AppUserStore) *StateStore

+ func NewStateStoreWithProvider(getDB DBProvider, appUsers AppUserStore) *StateStore

+ func (s *StateStore) AppUser(ctx context.Context, botID, appUserID string) (result botsfwstore.AppUser, err error)

+ func (s *StateStore) EnsureLinked(ctx context.Context, request botsfwstore.LinkRequest) (linked botsfwstore.LinkedIdentity, err error)

+ func (s *StateStore) PlatformUser(ctx context.Context, identity botsfwstore.Identity, ...) (result botsfwstore.PlatformUser, err error)

+ func (s *StateStore) SaveChat(ctx context.Context, identity botsfwstore.Identity, ...) error

+ func (s *StateStore) SetPlatformUserAccessGranted(ctx context.Context, identity botsfwstore.Identity, ...) (result botsfwstore.PlatformUser, err error)