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

Revert "ci(tmp): empty commit to trigger build."

Browse source 
This reverts commit d187636d8e.
This commit is contained in:
Rajesh Rajendran 2021-05-10 23:23:12 +05:30
parent fc8328629f
commit fa7717f869
1 changed files with 9 additions and 8 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(
@ -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() {
}
}
}
}
}