store

type AppKVStore interface {
	Set(r *incoming.Request, appID apps.AppID, actingUserID, prefix, id string, data []byte) (bool, error)
	Get(r *incoming.Request, appID apps.AppID, actingUserID, prefix, id string) ([]byte, error)
	Delete(r *incoming.Request, appID apps.AppID, actingUserID, prefix, id string) error
	List(r *incoming.Request, appID apps.AppID, actingUserID, namespace string, processf func(key string) error) error
}

type AppStore interface {
	config.Configurable

	InitBuiltin(...apps.App)

	Get(r *incoming.Request, appID apps.AppID) (*apps.App, error)
	AsMap(r *incoming.Request) map[apps.AppID]apps.App
	Save(r *incoming.Request, app apps.App) error
	Delete(r *incoming.Request, appID apps.AppID) error
}

type ManifestStore interface {
	config.Configurable

	StoreLocal(r *incoming.Request, m apps.Manifest) error
	Get(r *incoming.Request, appID apps.AppID) (*apps.Manifest, error)
	GetFromS3(r *incoming.Request, appID apps.AppID, version apps.AppVersion) (*apps.Manifest, error)
	AsMap(r *incoming.Request) map[apps.AppID]apps.Manifest
	DeleteLocal(r *incoming.Request, appID apps.AppID) error
}

type OAuth2Store interface {
	CreateState(r *incoming.Request, actingUserID string) (string, error)
	ValidateStateOnce(r *incoming.Request, urlState, actingUserID string) error
	SaveUser(r *incoming.Request, appID apps.AppID, actingUserID string, data []byte) error
	GetUser(r *incoming.Request, appID apps.AppID, actingUserID string) ([]byte, error)
}

type Service struct {
	App          AppStore
	Subscription SubscriptionStore
	Manifest     ManifestStore
	AppKV        AppKVStore
	OAuth2       OAuth2Store
	Session      SessionStore
	// contains filtered or unexported fields
}

type SessionStore interface {
	Get(r *incoming.Request, appID apps.AppID, userID string) (*model.Session, error)
	ListForApp(r *incoming.Request, appID apps.AppID) ([]*model.Session, error)
	ListForUser(r *incoming.Request, userID string) ([]*model.Session, error)
	Save(r *incoming.Request, appID apps.AppID, userID string, session *model.Session) error
	Delete(r *incoming.Request, appID apps.AppID, userID string) error
	DeleteAllForApp(r *incoming.Request, appID apps.AppID) error
	DeleteAllForUser(r *incoming.Request, userID string) error
}

type SubscriptionStore interface {
	Get(r *incoming.Request, subject apps.Subject, teamID, channelID string) ([]apps.Subscription, error)
	List(r *incoming.Request) ([]apps.Subscription, error)
	ListByUserID(r *incoming.Request, appID apps.AppID, userID string) ([]apps.Subscription, error)
	Save(r *incoming.Request, sub apps.Subscription) error
	Delete(r *incoming.Request, sub apps.Subscription) error
}