data

Documentation

Index

• func Close(dbctx database.DatabaseContext[database.Record]) error
• func OpenLeaksDB() (database.DatabaseContext[database.Record], error)
• func OpenSubscriptionsDB() (database.DatabaseContext[database.Record], error)
• func StoreSubscriptionDB(dbctx database.DatabaseContext[database.Record], ...) error
• type AffectedInfo
• type AllAffectedsInfo
• type EmailInfo
• type LeakInfo
• type QueryAffectedByLeakResult
  • func QueryAffectedLeaksDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey, ...) ([]QueryAffectedByLeakResult, error)
• type QueryLeakByIdResult
  • func QueryLeakByIdDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey) ([]QueryLeakByIdResult, error)
• type QuerySubscriptionResult
• type QuerySubscriptionWithoutAffectedResult
• type QuerySubscriptionsResult
  • func QuerySubscriptionsDB(dbctx database.DatabaseContext[database.Record]) (QuerySubscriptionsResult, error)
  • func (qsr QuerySubscriptionsResult) GetAffectUsers() []subscribe.Affected
  • func (qsr QuerySubscriptionsResult) GetAffectedsInfo(usersAffectedByLeak []QueryAffectedByLeakResult) AllAffectedsInfo

Functions

func Close

func Close(dbctx database.DatabaseContext[database.Record]) error

func OpenLeaksDB

func OpenLeaksDB() (database.DatabaseContext[database.Record], error)

func OpenSubscriptionsDB

func OpenSubscriptionsDB() (database.DatabaseContext[database.Record], error)

func StoreSubscriptionDB

func StoreSubscriptionDB(dbctx database.DatabaseContext[database.Record], subscription subscribe.Subscription) error

Types

type AffectedInfo

type AffectedInfo struct {
	DestinationB64Email entity.Base64
	AffectedsEmail      []string
}

type AllAffectedsInfo

type AllAffectedsInfo []AffectedInfo

type EmailInfo

type EmailInfo struct {
	UsersAffected AllAffectedsInfo
	LeakInfo      LeakInfo
}

type LeakInfo

type LeakInfo struct {
	PlatformsAffected []query.Platform
	Leak              query.Leak
}

type QueryAffectedByLeakResult

type QueryAffectedByLeakResult struct {
	entity.HSHA256
	Email string
}

func QueryAffectedLeaksDB

func QueryAffectedLeaksDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey, affected []subscribe.Affected) ([]QueryAffectedByLeakResult, error)

type QueryLeakByIdResult

type QueryLeakByIdResult struct {
	query.Platform
	query.Leak
}

func QueryLeakByIdDB

func QueryLeakByIdDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey) ([]QueryLeakByIdResult, error)

type QuerySubscriptionResult

type QuerySubscriptionResult struct {
	subscribe.Subscriber
	subscribe.Affected
}

type QuerySubscriptionWithoutAffectedResult

type QuerySubscriptionWithoutAffectedResult struct {
	subscribe.Subscriber
	subscribe.Affected
}

type QuerySubscriptionsResult

type QuerySubscriptionsResult []QuerySubscriptionResult

func QuerySubscriptionsDB

func QuerySubscriptionsDB(dbctx database.DatabaseContext[database.Record]) (QuerySubscriptionsResult, error)

func (QuerySubscriptionsResult) GetAffectUsers

func (qsr QuerySubscriptionsResult) GetAffectUsers() []subscribe.Affected

func (QuerySubscriptionsResult) GetAffectedsInfo

func (qsr QuerySubscriptionsResult) GetAffectedsInfo(usersAffectedByLeak []QueryAffectedByLeakResult) AllAffectedsInfo