martin/databag
1
0
Fork 0
mirror of https://github.com/balzack/databag.git synced 2025-02-14 20:49:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

insuring single push sent per device

Browse Source
This commit is contained in:
Roland Osborne 2023-04-22 15:59:33 -07:00
parent 047f524824
commit 3bfce5e40c
1 changed files with 30 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
net/server/internal/api_setPushEvent.go
View File

@ -52,36 +52,43 @@ func SendPushEvent(account store.Account, event string) {
ErrMsg(err); ErrMsg(err);
return return
} }
tokens := make(map[string]bool)
for rows.Next() { for rows.Next() {
var pushToken string var pushToken string
var messageTitle string var messageTitle string
var messageBody string var messageBody string
rows.Scan(&pushToken, &messageTitle, &messageBody) rows.Scan(&pushToken, &messageTitle, &messageBody)
url := "https://fcm.googleapis.com/fcm/send" if _, exists := tokens[pushToken]; !exists {
payload := Payload{ Title: messageTitle, Body: messageBody, Sound: "default" }; tokens[pushToken] = true;
message := Message{ Notification: payload, To: pushToken };
body, err := json.Marshal(message) url := "https://fcm.googleapis.com/fcm/send"
if err != nil { payload := Payload{ Title: messageTitle, Body: messageBody, Sound: "default" };
ErrMsg(err) message := Message{ Notification: payload, To: pushToken };
continue
} body, err := json.Marshal(message)
req, err := http.NewRequest(http.MethodPost, url, bytes.NewBuffer(body)) if err != nil {
if err != nil { ErrMsg(err)
ErrMsg(err) continue
continue }
} req, err := http.NewRequest(http.MethodPost, url, bytes.NewBuffer(body))
req.Header.Set("Content-Type", "application/json; charset=utf-8") if err != nil {
req.Header.Set("Authorization", "key=AAAAkgDXt8c:APA91bEjH67QpUWU6uAfCIXLqm0kf6AdPNVICZPCcWbmgW9NGYIErAxMDTy4LEbe4ik93Ho4Z-AJNIhr6nXXKC9qKmyKkkYHJWAEVH47_FXBQV6rsoi9ZB_oiuV66XKKAy1V40GmvfaX") ErrMsg(err)
client := &http.Client{} continue
resp, err := client.Do(req) }
if err != nil { req.Header.Set("Content-Type", "application/json; charset=utf-8")
ErrMsg(err) req.Header.Set("Authorization", "key=AAAAkgDXt8c:APA91bEjH67QpUWU6uAfCIXLqm0kf6AdPNVICZPCcWbmgW9NGYIErAxMDTy4LEbe4ik93Ho4Z-AJNIhr6nXXKC9qKmyKkkYHJWAEVH47_FXBQV6rsoi9ZB_oiuV66XKKAy1V40GmvfaX")
continue client := &http.Client{}
} resp, err := client.Do(req)
if resp.StatusCode != 200 { if err != nil {
ErrMsg(errors.New("failed to push notification")); ErrMsg(err)
continue
}
if resp.StatusCode != 200 {
ErrMsg(errors.New("failed to push notification"));
}
} }
} }
} }