From 3d7d3e4c91fefa03a9da096ee81532e903687834 Mon Sep 17 00:00:00 2001 From: Rajesh Rajendran Date: Mon, 10 May 2021 08:32:11 +0530 Subject: [PATCH] ci(tmp): empty commit to trigger build. Signed-off-by: Rajesh Rajendran --- backend/services/assets/main.go | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/backend/services/assets/main.go b/backend/services/assets/main.go index e62c277de..0b25b253b 100644 --- a/backend/services/assets/main.go +++ b/backend/services/assets/main.go @@ -15,11 +15,11 @@ import ( "openreplay/backend/services/assets/cacher" ) - +// empty commit to trigger build. func main() { log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile) - GROUP_CACHE := env.String("GROUP_CACHE") + GROUP_CACHE := env.String("GROUP_CACHE") TOPIC_TRIGGER := env.String("TOPIC_TRIGGER") cacher := cacher.NewCacher( @@ -29,10 +29,10 @@ func main() { ) consumer := queue.NewMessageConsumer( - GROUP_CACHE, - []string{ TOPIC_TRIGGER }, + GROUP_CACHE, + []string{TOPIC_TRIGGER}, func(sessionID uint64, message messages.Message, e *types.Meta) { - switch msg := message.(type) { + switch msg := message.(type) { case *messages.AssetCache: cacher.CacheURL(sessionID, msg.URL) case *messages.ErrorEvent: @@ -47,15 +47,14 @@ func main() { for _, source := range sourceList { cacher.CacheJSFile(source) } - } + } }, ) - tick := time.Tick(20 * time.Minute) sigchan := make(chan os.Signal, 1) - signal.Notify(sigchan, syscall.SIGINT, syscall.SIGTERM) + signal.Notify(sigchan, syscall.SIGINT, syscall.SIGTERM) for { select { @@ -71,4 +70,4 @@ func main() { } } } -} \ No newline at end of file +}