internal/gaby: enable groups sync in cron endpoint
Fixes golang/oscar#27
Change-Id: I48cfbe6e423a699b4da6b62230cd5f08dbfee38a
Reviewed-on: https://go-review.googlesource.com/c/oscar/+/625395
Reviewed-by: Hyang-Ah Hana Kim <hyangah@gmail.com>
LUCI-TryBot-Result: Go LUCI <golang-scoped@luci-project-accounts.iam.gserviceaccount.com>
Reviewed-by: Tatiana Bradley <tatianabradley@google.com>
diff --git a/internal/gaby/main.go b/internal/gaby/main.go
index fce8cef..66abeb2 100644
--- a/internal/gaby/main.go
+++ b/internal/gaby/main.go
@@ -171,10 +171,11 @@
// Named functions to retrieve latest Watcher times.
watcherLatests := map[string]func() timed.DBTime{
- github.DocWatcherID: docs.LatestFunc(g.github),
- gerrit.DocWatcherID: docs.LatestFunc(g.gerrit),
- discussion.DocWatcherID: docs.LatestFunc(g.disc),
- crawl.DocWatcherID: docs.LatestFunc(cr),
+ github.DocWatcherID: docs.LatestFunc(g.github),
+ gerrit.DocWatcherID: docs.LatestFunc(g.gerrit),
+ discussion.DocWatcherID: docs.LatestFunc(g.disc),
+ crawl.DocWatcherID: docs.LatestFunc(cr),
+ googlegroups.DocWatcherID: docs.LatestFunc(g.ggroups),
"embeddocs": func() timed.DBTime { return embeddocs.Latest(g.docs) },
@@ -534,6 +535,7 @@
check(g.syncGitHubIssues(ctx))
check(g.syncGitHubDiscussions(ctx))
check(g.syncGerrit(ctx))
+ check(g.syncGroups(ctx))
// Embed must happen last.
check(g.embedAll(ctx))
@@ -609,11 +611,12 @@
g.db.Lock(gabyGroupsSyncLock)
defer g.db.Unlock(gabyGroupsSyncLock)
- // Download new events from all google groups.
+ // Download updated conversations from all google groups.
if err := g.ggroups.Sync(ctx); err != nil {
return err
}
- // TODO: add docs
+ // Store newly downloaded conversations in the document database.
+ docs.Sync(g.docs, g.ggroups)
return nil
}
