From fa7717f869f223b313c06daca30268d6fdb6d6be Mon Sep 17 00:00:00 2001 From: Rajesh Rajendran Date: Mon, 10 May 2021 23:23:12 +0530 Subject: [PATCH] Revert "ci(tmp): empty commit to trigger build." This reverts commit d187636d8e07d1b7a3513ef5867d8504b7aa0e1a. --- backend/services/assets/main.go | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/backend/services/assets/main.go b/backend/services/assets/main.go index 9b0703ef2..0193be7bb 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( @@ -30,10 +30,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: @@ -48,14 +48,15 @@ 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 +72,4 @@ func main() { } } } -} +} \ No newline at end of file