D4
/
analyzer-d4-balboa
mirror of https://github.com/D4-project/analyzer-d4-balboa
2
0
Fork 0
Code Issues Releases Wiki Activity

fix: [dev] first working version

master
Jean-Louis Huynen 2019-06-05 11:22:44 +02:00
parent b50fac4c19
commit fd242d6d9d
No known key found for this signature in database
GPG Key ID: 64799157F4BD6B93
2 changed files with 8 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
balboa.go
View File

@ -84,39 +84,33 @@ func main() {
}
c.redisQueue = string(config.ReadConfigFile(*confdir, "redis_queue"))
c.balboaSocket = string(config.ReadConfigFile(*confdir, "balboa_socket"))
//TODO: handle empty ...
initRedis(c.redisHost, c.redisPort, c.redisDB)
defer cr.Close()
addr, err := net.ResolveUnixAddr("unix", c.balboaSocket)
if err != nil {
fmt.Printf("Failed to resolve: %v\n", err)
os.Exit(1)
log.Fatalf("Failed to resolve: %v\n", err)
}
cs, err := net.DialUnix("unix", nil, addr)
if err != nil {
fmt.Printf("Failed to dial: %v\n", err)
os.Exit(1)
log.Fatalf("Failed to dial: %v\n", err)
}
defer cs.Close()
//defer cs.Close()
if err != nil {
panic(err)
}
// pop redis queue
for {
dnsLine, err := redis.String(cr.Do("LPOP", "analyzer:8:"+c.redisQueue))
dnsLine = fmt.Sprintf("%s%s", dnsLine, "\n")
if err != nil {
fmt.Println("Queue processed.")
os.Exit(0)
}
// Write in Balboa socket
if i, err := cs.Write([]byte(dnsLine)); err != nil {
fmt.Printf("DIAL: Error: %v\n", err)
if _, err := cs.Write([]byte(dnsLine)); err != nil {
fmt.Printf("Write Error: %v\n", err)
} else {
fmt.Printf("Sent %v bytes\n", i)
fmt.Printf("Write: %v", dnsLine)
}
// Exit Signal Handle

4
go.mod
View File

@ -3,6 +3,6 @@ module github.com/D4-project/analyzer-d4-balboa
go 1.12
require (
github.com/D4-project/d4-golang-utils v0.0.0-20190603131519-c10ee092655c // indirect
github.com/gomodule/redigo v2.0.0+incompatible // indirect
github.com/D4-project/d4-golang-utils v0.0.0-20190603131519-c10ee092655c
github.com/gomodule/redigo v2.0.0+incompatible
)