From a3d1f84271068f439d904354e9e2f232ef454d3c Mon Sep 17 00:00:00 2001
From: Paul Lecuq <paul@paulbsd.com>
Date: Sun, 18 Sep 2022 10:24:55 +0200
Subject: [PATCH] updated ipbl

---
 src/zmqrouter/main.go   | 7 +++++++
 src/zmqrouter/pubsub.go | 6 +++++-
 src/zmqrouter/reqrep.go | 6 +++++-
 3 files changed, 17 insertions(+), 2 deletions(-)

diff --git a/src/zmqrouter/main.go b/src/zmqrouter/main.go
index c4feda0..de2c92d 100644
--- a/src/zmqrouter/main.go
+++ b/src/zmqrouter/main.go
@@ -38,9 +38,11 @@ func Handle(cfg *config.Config, reqsock *goczmq.Sock, pubsock *goczmq.Sock, chan
 			log.Println("unable to receive message from req socket")
 			continue
 		}
+		var lastip string
 
 		var topub [][]byte
 		for _, val := range req {
+
 			var apiip = models.APIIP{}
 			var ip = models.IP{}
 
@@ -49,6 +51,11 @@ func Handle(cfg *config.Config, reqsock *goczmq.Sock, pubsock *goczmq.Sock, chan
 				log.Println("unable to parse ip address", err)
 				continue
 			}
+			if apiip.IP == lastip {
+				lastip = apiip.IP
+				continue
+			}
+
 			if apiip.Mode != "init" {
 				ip = *apiip.APIConvert()
 
diff --git a/src/zmqrouter/pubsub.go b/src/zmqrouter/pubsub.go
index 3982d5f..bd50025 100644
--- a/src/zmqrouter/pubsub.go
+++ b/src/zmqrouter/pubsub.go
@@ -1,10 +1,14 @@
 package zmqrouter
 
 import (
+	"fmt"
+
 	"gopkg.in/zeromq/goczmq.v4"
 )
 
+const pubsubport int = 9999
+
 func InitPub() (sock *goczmq.Sock, err error) {
-	sock, err = goczmq.NewPub("tcp://*:9999")
+	sock, err = goczmq.NewPub(fmt.Sprintf("tcp://*:%d", pubsubport))
 	return
 }
diff --git a/src/zmqrouter/reqrep.go b/src/zmqrouter/reqrep.go
index 3a1a556..e1ad473 100644
--- a/src/zmqrouter/reqrep.go
+++ b/src/zmqrouter/reqrep.go
@@ -1,10 +1,14 @@
 package zmqrouter
 
 import (
+	"fmt"
+
 	"gopkg.in/zeromq/goczmq.v4"
 )
 
+const repreqport int = 9998
+
 func InitRep() (sock *goczmq.Sock, err error) {
-	sock, err = goczmq.NewRep("tcp://*:9998")
+	sock, err = goczmq.NewRep(fmt.Sprintf("tcp://*:%d", repreqport))
 	return
 }