makayabou/asg-server
1
0
Fork 0
mirror of https://github.com/makayabou/asg-server.git synced 2026-05-02 17:43:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

Fixed: push client init retry

Browse Source
This commit is contained in:
Aleksandr Soloshenko 2023-12-04 11:01:22 +07:00
parent f17a2135eb
commit ef9de0588d
1 changed files with 16 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
internal/sms-gateway/services/push.go
View File

@ -13,8 +13,7 @@ type PushService struct {
CredentialsJSON string
client *messaging.Client
once sync.Once
mux sync.Mutex
}
type PushServiceConfig struct {
@ -29,20 +28,25 @@ func NewPushService(config PushServiceConfig) *PushService {
// init
func (s *PushService) init(ctx context.Context) (err error) {
s.once.Do(func() {
opt := option.WithCredentialsJSON([]byte(s.CredentialsJSON))
s.mux.Lock()
defer s.mux.Unlock()
var app *firebase.App
app, err = firebase.NewApp(ctx, nil, opt)
if s.client != nil {
return
}
if err != nil {
return
}
opt := option.WithCredentialsJSON([]byte(s.CredentialsJSON))
s.client, err = app.Messaging(ctx)
})
var app *firebase.App
app, err = firebase.NewApp(ctx, nil, opt)
return err
if err != nil {
return
}
s.client, err = app.Messaging(ctx)
return
}
// send