1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
package svc // import "github.com/getwtxt/getwtxt/svc"
import (
"net"
"strings"
"time"
"github.com/getwtxt/registry"
"github.com/syndtr/goleveldb/leveldb"
)
type dbLevel struct {
db *leveldb.DB
}
func (lvl *dbLevel) push() error {
twtxtCache.Mu.RLock()
defer twtxtCache.Mu.RUnlock()
var dbBasket = &leveldb.Batch{}
for k, v := range twtxtCache.Users {
dbBasket.Put([]byte(k+"*Nick"), []byte(v.Nick))
dbBasket.Put([]byte(k+"*URL"), []byte(v.URL))
dbBasket.Put([]byte(k+"*IP"), []byte(v.IP.String()))
dbBasket.Put([]byte(k+"*Date"), []byte(v.Date))
dbBasket.Put([]byte(k+"*RLen"), []byte(v.RLen))
for i, e := range v.Status {
rfc := i.Format(time.RFC3339)
dbBasket.Put([]byte(k+"*Status*"+rfc), []byte(e))
}
}
for k, v := range remoteRegistries.List {
dbBasket.Put([]byte("remote*"+string(k)), []byte(v))
}
return lvl.db.Write(dbBasket, nil)
}
func (lvl *dbLevel) pull() {
iter := lvl.db.NewIterator(nil, nil)
twtxtCache.Mu.Lock()
defer twtxtCache.Mu.Unlock()
for iter.Next() {
key := string(iter.Key())
val := string(iter.Value())
split := strings.Split(key, "*")
urls := split[0]
field := split[1]
if urls == "remote" {
remoteRegistries.List = append(remoteRegistries.List, val)
continue
}
data := registry.NewUser()
if _, ok := twtxtCache.Users[urls]; ok {
data = twtxtCache.Users[urls]
}
data.Mu.Lock()
switch field {
case "IP":
data.IP = net.ParseIP(val)
case "Nick":
data.Nick = val
case "URL":
data.URL = val
case "RLen":
data.RLen = val
case "Date":
data.Date = val
case "Status":
thetime, err := time.Parse(time.RFC3339, split[2])
errLog("", err)
data.Status[thetime] = val
}
twtxtCache.Users[urls] = data
data.Mu.Unlock()
}
remoteRegistries.List = dedupe(remoteRegistries.List)
iter.Release()
errLog("Error while pulling DB into registry cache: ", iter.Error())
}
|