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

Remember callbackURL to make it easier to resubscribe

Browse Source
This commit is contained in:
Peter Stuifzand 2018-07-07 17:30:51 +02:00
parent c9ca63b7fa
commit b8ec0f3700
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cmd/eksterd/main.go
View File

@ -98,13 +98,15 @@ func (h *hubIncomingBackend) CreateFeed(topic string, channel string) (int64, er
log.Printf("WebSub Hub URL found for topic=%s hub=%s\n", topic, hubURL) log.Printf("WebSub Hub URL found for topic=%s hub=%s\n", topic, hubURL)
} }
callbackURL := fmt.Sprintf("%s/incoming/%d", os.Getenv("EKSTER_BASEURL"), id)
if err == nil && hubURL != "" { if err == nil && hubURL != "" {
conn.Do("HSET", fmt.Sprintf("feed:%d", id), "hub", hubURL) args := redis.Args{}.Add(fmt.Sprintf("feed:%d", id), "hub", hubURL, "callback", callbackURL)
conn.Do("HMSET", args...)
} else { } else {
return id, nil return id, nil
} }
callbackURL := fmt.Sprintf("%s/incoming/%d", os.Getenv("EKSTER_BASEURL"), id)
websub.Subscribe(client, hubURL, topic, callbackURL, secret, 24*3600) websub.Subscribe(client, hubURL, topic, callbackURL, secret, 24*3600)
return id, nil return id, nil