peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Use one more argument for leaseSeconds
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2021-10-31 19:16:49 +01:00
parent a38d2147bf
commit 198d18fe17
Signed by: peter
GPG Key ID: 374322D56E5209E8
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/eksterd/hubbackend.go
View File

@ -150,7 +150,12 @@ func (h *hubIncomingBackend) UpdateFeed(subscriptionID int64, contentType string
func (h *hubIncomingBackend) FeedSetLeaseSeconds(subscriptionID int64, leaseSeconds int64) error { func (h *hubIncomingBackend) FeedSetLeaseSeconds(subscriptionID int64, leaseSeconds int64) error {
db := h.backend.database db := h.backend.database
_, err := db.Exec("update subscriptions set lease_seconds = $1, resubscribe_at = now() + $1 * interval '1' second where id = $2", leaseSeconds, subscriptionID) _, err := db.Exec(`
update subscriptions
set lease_seconds = $1,
resubscribe_at = now() + $2 * interval '1' second
where id = $3
`, leaseSeconds, leaseSeconds, subscriptionID)
return err return err
} }

2
cmd/eksterd/incoming.go
View File

@ -49,11 +49,13 @@ func (h *incomingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
leaseSeconds, err := strconv.ParseInt(leaseStr, 10, 64) leaseSeconds, err := strconv.ParseInt(leaseStr, 10, 64)
if err != nil { if err != nil {
log.Printf("error in hub.lease_seconds format %q: %s", leaseSeconds, err)
http.Error(w, fmt.Sprintf("error in hub.lease_seconds format %q: %s", leaseSeconds, err), 400) http.Error(w, fmt.Sprintf("error in hub.lease_seconds format %q: %s", leaseSeconds, err), 400)
return return
} }
err = h.Backend.FeedSetLeaseSeconds(feed, leaseSeconds) err = h.Backend.FeedSetLeaseSeconds(feed, leaseSeconds)
if err != nil { if err != nil {
log.Printf("error in while setting hub.lease_seconds: %s", err)
http.Error(w, fmt.Sprintf("error in while setting hub.lease_seconds: %s", err), 400) http.Error(w, fmt.Sprintf("error in while setting hub.lease_seconds: %s", err), 400)
return return
} }