diff options
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5srvWeb.go | 12 | ||||
| -rw-r--r-- | src/hub/src/spreadspace.org/sfive/s5store.go | 12 |
2 files changed, 24 insertions, 0 deletions
diff --git a/src/hub/src/spreadspace.org/sfive/s5srvWeb.go b/src/hub/src/spreadspace.org/sfive/s5srvWeb.go index 31964ad..fd9876b 100644 --- a/src/hub/src/spreadspace.org/sfive/s5srvWeb.go +++ b/src/hub/src/spreadspace.org/sfive/s5srvWeb.go @@ -165,6 +165,17 @@ func (self StatsSinkServer) postUpdate(c web.C, w http.ResponseWriter, r *http.R // TODO send response channel, wait for OK } +func (self StatsSinkServer) getLastUpdateIdForUuid(c web.C, w http.ResponseWriter, r *http.Request) { + const resourceName = "lastupdateid" + id := c.URLParams["id"] + value, err := self.store.GetLastUpdateForUuid(id) + if err != nil { + http.Error(w, fmt.Sprintf("failed to retrieve %s: %v", resourceName, err), http.StatusInternalServerError) + return + } + fmt.Fprintf(w, "%s", value) +} + func (self StatsSinkServer) getStats(c web.C, w http.ResponseWriter, r *http.Request) { const resourceName = "stats" filter := getFilter(r) @@ -197,6 +208,7 @@ func (self StatsSinkServer) ServeWeb(vizAppLocation string) { goji.Get("/updates", self.getUpdateList) goji.Get("/updates/:id", self.getUpdate) goji.Post("/updates", self.postUpdate) + goji.Get("/lastupdate/:id", self.getLastUpdateIdForUuid) goji.Get("/stats", self.getStats) goji.Handle("/viz/*", http.StripPrefix("/viz/", http.FileServer(http.Dir(vizAppLocation)))) diff --git a/src/hub/src/spreadspace.org/sfive/s5store.go b/src/hub/src/spreadspace.org/sfive/s5store.go index 14d259f..49b70de 100644 --- a/src/hub/src/spreadspace.org/sfive/s5store.go +++ b/src/hub/src/spreadspace.org/sfive/s5store.go @@ -361,6 +361,18 @@ func (s sqliteStore) GetUpdates(filter *StatsFilter) (res []StatisticsData, err return } +func (s sqliteStore) GetLastUpdateForUuid(uuid string) (updateId int, err error) { + res, err := s.db.SelectInt( + "select max(SourceHubDataUpdateId) from "+dataUpdatesTn+" where SourceHubUuid = ?", + uuid) + if err == nil { + updateId = int(res) + } else { + s5l.Printf("db: failed to find max SourceHubDataUpdateId for %s: %v", uuid, err) + } + return +} + func getCountEntriesSql() string { return "count(*) as UpdateCount" } |