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

Improved: send push in background

Browse Source
This commit is contained in:
Aleksandr Soloshenko 2023-08-16 22:23:22 +07:00
parent 467f208ba3
commit ddc0fe54c0
3 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/requests.http
View File

@ -1,4 +1,4 @@
@baseUrl=https://sms.capcom.me
@baseUrl=http://sms.capcom.me
###
POST {{baseUrl}}/api/mobile/v1/device HTTP/1.1

2
internal/smsgateway/handlers/3rdparty.go
View File

@ -39,7 +39,7 @@ func (h *thirdPartyHandler) postMessage(user models.User, c *fiber.Ctx) error {
}
device := user.Devices[0]
if err := h.messagesSvc.Enqeue(c.Context(), device, req); err != nil {
if err := h.messagesSvc.Enqeue(device, req); err != nil {
return err
}

14
internal/smsgateway/services/messages.go
View File

@ -4,6 +4,7 @@ import (
"context"
"fmt"
"log"
"time"
"bitbucket.org/capcom6/smsgatewaybackend/internal/smsgateway/models"
"bitbucket.org/capcom6/smsgatewaybackend/internal/smsgateway/repositories"
@ -59,7 +60,7 @@ func (s *MessagesService) UpdateState(deviceID string, message smsgateway.Messag
return s.Messages.UpdateState(&existing)
}
func (s *MessagesService) Enqeue(ctx context.Context, device models.Device, message smsgateway.Message) error {
func (s *MessagesService) Enqeue(device models.Device, message smsgateway.Message) error {
for i, v := range message.PhoneNumbers {
phone, err := filters.FilterPhone(v, false)
if err != nil {
@ -86,9 +87,14 @@ func (s *MessagesService) Enqeue(ctx context.Context, device models.Device, mess
return nil
}
if err := s.PushSvc.Send(ctx, *device.PushToken, map[string]string{}); err != nil {
log.Printf("failed to send message to %s: %v", *device.PushToken, err)
}
go func(token string) {
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err := s.PushSvc.Send(ctx, token, map[string]string{}); err != nil {
log.Printf("failed to send push to %s: %v", *device.PushToken, err)
}
}(*device.PushToken)
return nil
}