aljaz/crawler_v2
1
0
Fork 0
mirror of https://github.com/aljazceru/crawler_v2.git synced 2025-12-17 07:24:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

renamed variables for more clarity

Browse Source
This commit is contained in:
pippellia-btc
2025-09-12 15:19:22 +02:00
parent b25b77c159
commit 06e24ccad7
2 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
cmd/crawl/main.go
View File

@@ -51,20 +51,21 @@ func main() {
} }
db := redb.New(&redis.Options{Addr: config.RedisAddress}) db := redb.New(&redis.Options{Addr: config.RedisAddress})
count, err := db.NodeCount(ctx) nodes, err := db.NodeCount(ctx)
if err != nil { if err != nil {
panic(err) panic(err)
} }
if count == 0 { if nodes == 0 {
if len(config.InitPubkeys) == 0 { if len(config.InitPubkeys) == 0 {
panic("init pubkeys are empty: impossible to initialize") panic("init pubkeys are empty: impossible to initialize")
} }
log.Println("initialize from empty database...") log.Println("initialize from empty database...")
nodes := make([]graph.ID, len(config.InitPubkeys)) initNodes := make([]graph.ID, len(config.InitPubkeys))
for i, pk := range config.InitPubkeys { for i, pk := range config.InitPubkeys {
nodes[i], err = db.AddNode(ctx, pk) initNodes[i], err = db.AddNode(ctx, pk)
if err != nil { if err != nil {
panic(err) panic(err)
} }
@@ -72,7 +73,7 @@ func main() {
pubkeys <- pk // add to queue pubkeys <- pk // add to queue
} }
for _, node := range nodes { for _, node := range initNodes {
if err := pipe.Promote(db, node); err != nil { if err := pipe.Promote(db, node); err != nil {
panic(err) panic(err)
} }

10
cmd/sync/main.go
View File

@@ -48,12 +48,12 @@ func main() {
} }
db := redb.New(&redis.Options{Addr: config.RedisAddress}) db := redb.New(&redis.Options{Addr: config.RedisAddress})
count, err := db.NodeCount(ctx) nodes, err := db.NodeCount(ctx)
if err != nil { if err != nil {
panic(err) panic(err)
} }
if count != 0 { if nodes != 0 {
panic("refuse to run sync when redis is not empty") panic("refuse to run sync when redis is not empty")
} }
@@ -62,9 +62,9 @@ func main() {
} }
log.Println("initialize from empty database...") log.Println("initialize from empty database...")
nodes := make([]graph.ID, len(config.InitPubkeys)) initNodes := make([]graph.ID, len(config.InitPubkeys))
for i, pk := range config.InitPubkeys { for i, pk := range config.InitPubkeys {
nodes[i], err = db.AddNode(ctx, pk) initNodes[i], err = db.AddNode(ctx, pk)
if err != nil { if err != nil {
panic(err) panic(err)
} }
@@ -72,7 +72,7 @@ func main() {
pubkeys <- pk // add to queue pubkeys <- pk // add to queue
} }
for _, node := range nodes { for _, node := range initNodes {
if err := pipe.Promote(db, node); err != nil { if err := pipe.Promote(db, node); err != nil {
panic(err) panic(err)
} }