MongoDB/llmongodb
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

.

Browse source
This commit is contained in:
Michele Fadda 2015-07-10 15:19:29 +02:00
parent d494b2c5d2
commit 5da26af646
1 changed files with 9 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
llmongo.go
View file

@ -99,6 +99,9 @@ func main() {
// Estrae la lista degli utenti che hanno fatto login negli ultimi X min.
llindex := opts.rdb.Cmd("smembers", "llindex")
lista, err := llindex.List()
if err != nil {
log.Panicln("LLINDEX error: ", err.Error())
}
for _, user := range lista {
// cicla fino a che esistono righe di login
@ -108,13 +111,13 @@ func main() {
// Estrae l'ultimo login dell'utente 'user'
val, err = opts.rdb.Cmd("lindex", user, "-1").Str()
if err != nil {
log.Printf("lindex error: %+v\n", err)
log.Printf("LINDEX error: %+v\n", err)
// se ha trovato user e righe di login
if lastval != "" {
// reinserisce l'ultimo login e imposta il ttl su Redis
retval := opts.rdb.Cmd("lpush", user, lastval)
ttl := opts.rdb.Cmd("expire", user, opts.RedisTTL.Seconds())
log.Println("lpush retval: ", retval, ttl, user, lastval, opts.RedisTTL.Seconds())
log.Println("LPUSH retval: ", retval, ttl, user, lastval, opts.RedisTTL.Seconds())
}
break
}
@ -122,7 +125,7 @@ func main() {
if val == "" {
log.Println("Login empty: ", user)
retval := opts.rdb.Cmd("lrem", user, "-1", val)
log.Println("lrem retval: ", user, val, retval)
log.Println("LREM retval: ", user, val, retval)
continue
}
sval := strings.Split(val, ":")
@ -130,7 +133,7 @@ func main() {
if sval[1] == "" {
log.Println("Login format error: ", val, user)
retval := opts.rdb.Cmd("lrem", user, "-1", val)
log.Println("lrem retval: ", user, val, retval)
log.Println("LREM retval: ", user, val, retval)
continue
}
date, err = strconv.ParseInt(sval[1], 10, 64)
@ -155,7 +158,7 @@ func main() {
}
// cancella da Redis la riga di login inserita
retval := opts.rdb.Cmd("lrem", user, "-1", val)
log.Println("lrem retval: ", retval, user, val)
log.Println("LREM retval: ", retval, user, val)
lastval = val
}
// controlla se ci sono ancora line di login per l'utente 'user'
@ -163,7 +166,7 @@ func main() {
if llen <= 1 {
// elimina l'utente dalla lista di quelli che hanno fatto login
retval := opts.rdb.Cmd("srem", "llindex", user)
log.Println("srem retval: ", retval, user)
log.Println("SREM retval: ", retval, user)
}
}