diff --git a/server/channels/app/notification_push.go b/server/channels/app/notification_push.go index 7acc161852..98ed6403db 100644 --- a/server/channels/app/notification_push.go +++ b/server/channels/app/notification_push.go @@ -490,6 +490,10 @@ func (a *App) rawSendToPushProxy(msg *model.PushNotification) (model.PushRespons } defer resp.Body.Close() + if resp.StatusCode != http.StatusOK { + return nil, fmt.Errorf("response returned error code: %d", resp.StatusCode) + } + var pushResponse model.PushResponse if err := json.NewDecoder(resp.Body).Decode(&pushResponse); err != nil { return nil, fmt.Errorf("failed to decode from JSON: %w", err) @@ -562,6 +566,10 @@ func (a *App) SendAckToPushProxy(ack *model.PushNotificationAck) error { } defer resp.Body.Close() + if resp.StatusCode != http.StatusOK { + return fmt.Errorf("response returned error code: %d", resp.StatusCode) + } + // Reading the body to completion. _, err = io.Copy(io.Discard, resp.Body) return err