mirrors/apollo-backend
2
0
Fork 0
mirror of https://github.com/christianselig/apollo-backend synced 2024-11-10 22:17:44 +00:00
Code Issues Projects Releases Packages Wiki Activity

Set device pinged at

Browse source
This commit is contained in:
Andre Medeiros 2021-08-14 11:51:27 -04:00
parent 50cdc3aafa
commit 905235a8ff
3 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
internal/api/api.go
View file

@ -83,8 +83,8 @@ func (a *api) Routes() *mux.Router {
r.HandleFunc("/v1/device/{apns}/accounts", a.upsertAccountsHandler).Methods("POST") r.HandleFunc("/v1/device/{apns}/accounts", a.upsertAccountsHandler).Methods("POST")
r.HandleFunc("/v1/device/{apns}/account/{redditID}", a.disassociateAccountHandler).Methods("DELETE") r.HandleFunc("/v1/device/{apns}/account/{redditID}", a.disassociateAccountHandler).Methods("DELETE")
r.HandleFunc("/v1/receipt", a.checkReceiptHandler) r.HandleFunc("/v1/receipt", a.checkReceiptHandler).Methods("POST")
r.HandleFunc("/v1/receipt/{apns}", a.checkReceiptHandler) r.HandleFunc("/v1/receipt/{apns}", a.checkReceiptHandler).Methods("POST")
r.Use(a.loggingMiddleware) r.Use(a.loggingMiddleware)

3
internal/api/devices.go
View file

@ -6,6 +6,7 @@ import (
"fmt" "fmt"
"net/http" "net/http"
"strings" "strings"
"time"
"github.com/christianselig/apollo-backend/internal/domain" "github.com/christianselig/apollo-backend/internal/domain"
"github.com/dustin/go-humanize/english" "github.com/dustin/go-humanize/english"
@ -26,6 +27,8 @@ func (a *api) upsertDeviceHandler(w http.ResponseWriter, r *http.Request) {
return return
} }
d.LastPingedAt = time.Now().Unix()
if err := a.deviceRepo.CreateOrUpdate(ctx, d); err != nil { if err := a.deviceRepo.CreateOrUpdate(ctx, d); err != nil {
a.errorResponse(w, r, 500, err.Error()) a.errorResponse(w, r, 500, err.Error())
return return

1
internal/repository/postgres_device.go
View file

@ -58,7 +58,6 @@ func (p *postgresDeviceRepository) GetByAPNSToken(ctx context.Context, token str
} }
func (p *postgresDeviceRepository) CreateOrUpdate(ctx context.Context, dev *domain.Device) error { func (p *postgresDeviceRepository) CreateOrUpdate(ctx context.Context, dev *domain.Device) error {
fmt.Println(dev)
query := ` query := `
INSERT INTO devices (apns_token, sandbox, last_pinged_at) INSERT INTO devices (apns_token, sandbox, last_pinged_at)
VALUES ($1, $2, $3) VALUES ($1, $2, $3)