jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

ci(tmp): empty commit to trigger build.

Browse source 
Signed-off-by: Rajesh Rajendran <rjshrjndrn@gmail.com>
This commit is contained in:
Rajesh Rajendran 2021-05-10 08:32:11 +05:30
parent f94610f623
commit d187636d8e
1 changed files with 8 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
backend/services/assets/main.go
View file

@ -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() {
}
}
}
}
}