push

Jan 28, 2026

Changes in this version

type FCMPusher

+ func (p *FCMPusher) SendPushes(ctx context.Context, title, body string, customPayload *pushpb.Payload, ...) error

type NoOpPusher

+ func (n *NoOpPusher) SendPushes(_ context.Context, _, _ string, _ *pushpb.Payload, _ ...*commonpb.UserId) error

type Pusher

+ SendPushes func(ctx context.Context, title, body string, customPayload *pushpb.Payload, ...) error

Jan 6, 2026

Changes in this version

+ func SendFlipcashCurrencyBoughtPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, currencyName string, ...) error

+ func SendFlipcashCurrencyDepositedPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, currencyName string, ...) error

+ func SendFlipcashCurrencySoldPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, currencyName string, ...) error

+ func SendUsdfDepositedPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, ...) error

Dec 11, 2025

Changes in this version

+ func SendUsdfReceivedFromDepositPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, ...) error

+ func SendUsdfReceivedFromSwapPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, ...) error

Nov 28, 2025

Changes in this version

+ func SendFlipcashCurrencyReceivedFromDepositPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, currencyName string, ...) error

+ func SendFlipcashCurrencyReceivedFromSwapPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, currencyName string, ...) error

+ func SendUsdcReceivedFromDepositPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, ...) error

+ func SendUsdcReceivedFromSwapPush(ctx context.Context, pusher Pusher, user *commonpb.UserId, ...) error

+ type FCMClient interface

+ SendEachForMulticast func(ctx context.Context, message *messaging.MulticastMessage) (*messaging.BatchResponse, error)

+ type FCMPusher struct

+ func NewFCMPusher(log *zap.Logger, tokens TokenStore, client FCMClient) *FCMPusher

+ func (p *FCMPusher) SendBasicPushes(ctx context.Context, title, body string, users ...*commonpb.UserId) error

+ type NoOpPusher struct

+ func (n *NoOpPusher) SendBasicPushes(_ context.Context, _, _ string, _ ...*commonpb.UserId) error

+ type Pusher interface

+ SendBasicPushes func(ctx context.Context, title, body string, users ...*commonpb.UserId) error

+ func NewNoOpPusher() Pusher

+ type Server struct

+ func NewServer(log *zap.Logger, authz auth.Authorizer, tokens TokenStore) *Server

+ func (s *Server) AddToken(ctx context.Context, req *pushpb.AddTokenRequest) (*pushpb.AddTokenResponse, error)

+ func (s *Server) DeleteTokens(ctx context.Context, req *pushpb.DeleteTokensRequest) (*pushpb.DeleteTokensResponse, error)

+ type Token struct

+ AppInstallID string

+ Token string

+ Type pushpb.TokenType

+ type TokenStore interface

+ AddToken func(ctx context.Context, userID *commonpb.UserId, ...) error

+ DeleteToken func(ctx context.Context, tokenType pushpb.TokenType, token string) error

+ GetTokens func(ctx context.Context, userID *commonpb.UserId) ([]Token, error)

+ GetTokensBatch func(ctx context.Context, userIDs ...*commonpb.UserId) ([]Token, error)