push

type BadgeCounts map[string]uint64

type BadgeResolver func(ctx context.Context, users []*commonpb.UserId) (BadgeCounts, error)

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

type ChatRecipients struct {
	Unmuted []*commonpb.UserId
	Muted   []*commonpb.UserId
}

type CurrencyState struct {
	Mint              *commonpb.PublicKey
	AllTimeHighSupply uint64
	AllTimeHighSlot   uint64
	LastGainPushAt    *time.Time // nil if a gain push has never been granted for the mint
}

type CurrencyStateStore interface {
	// ClaimGainPush atomically gates a "currency gain" push wave for a mint.
	//
	// granted is true only when both conditions hold against the currently stored
	// state: (1) supply is strictly greater than the stored all-time high, and
	// (2) at least cooldown has elapsed since the last granted gain push (or none
	// has ever been granted). When granted, the stored all-time high (supply,
	// slot) and last-gain-push timestamp are advanced to the provided values / now.
	// When not granted, the stored state is left unchanged — in particular a new
	// high observed during cooldown is NOT recorded.
	//
	// Whenever err is nil, the returned CurrencyState reflects the resulting stored
	// state — the freshly written values when granted, or the existing values when
	// not — so callers can populate a local cache regardless of the outcome.
	ClaimGainPush(ctx context.Context, mint *commonpb.PublicKey, supply, slot uint64, cooldown time.Duration) (granted bool, state *CurrencyState, err error)

	// GetCurrencyState returns the stored push state for a mint, or
	// ErrCurrencyStateNotFound if none has been recorded yet.
	GetCurrencyState(ctx context.Context, mint *commonpb.PublicKey) (*CurrencyState, error)
}

type FCMClient interface {
	SendEach(ctx context.Context, messages []*messaging.Message) (*messaging.BatchResponse, error)
}

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

type NoOpPusher struct{}

type Pusher interface {
	// SendPushes sends the same notification to every device of the given users.
	SendPushes(ctx context.Context, title, body string, customPayload *pushpb.Payload, users ...*commonpb.UserId) error

	// SendPushesWithBadges is SendPushes with a per-user app-icon badge carried
	// on the notification itself, resolved on demand for the recipients whose
	// devices can display one (see BadgeResolver).
	SendPushesWithBadges(ctx context.Context, title, body string, customPayload *pushpb.Payload, resolveBadges BadgeResolver, users ...*commonpb.UserId) error
}

type Server struct {
	pushpb.UnimplementedPushServer
	// contains filtered or unexported fields
}

type Store interface {
	TokenStore
	CurrencyStateStore
}

type Token struct {
	UserID       *commonpb.UserId
	Type         pushpb.TokenType
	Token        string
	AppInstallID string
}

type TokenStore interface {
	// GetTokens returns all tokens for a user.
	GetTokens(ctx context.Context, userID *commonpb.UserId) ([]Token, error)

	// GetTokensBatch returns all tokens for a batch of users.
	GetTokensBatch(ctx context.Context, userIDs ...*commonpb.UserId) ([]Token, error)

	// AddToken adds a token for a user.
	//
	// If the token already exists for the same user and device, it will be updated.
	AddToken(ctx context.Context, userID *commonpb.UserId, appInstallID *commonpb.AppInstallId, tokenType pushpb.TokenType, token string) error

	// DeleteToken deletes a token for a user.
	DeleteToken(ctx context.Context, tokenType pushpb.TokenType, token string) error

	// DeleteTokens deletes every given (type, token) pair in one operation. It
	// exists for the pusher's cleanup of tokens FCM reports as unregistered,
	// which a large send can surface many of at once. A pair that no longer
	// exists is skipped, not an error.
	DeleteTokens(ctx context.Context, tokens ...Token) error

	// FilterUsersWithTokens returns the subset of user IDs that have at least one push token.
	FilterUsersWithTokens(ctx context.Context, userIDs ...*commonpb.UserId) ([]*commonpb.UserId, error)
}