Merge branch 'main' into tower

Author: jayanthdeejay

producer/rediscon.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"log"
 
+	"github.com/go-redis/redis/v8"
 	"github.com/jayanthdeejay/mining/address"
 	_ "github.com/lib/pq"
     "github.com/go-redis/redis/v8"
@@ -16,11 +17,11 @@ var ctx context.Context
 var rdb *redis.Client
 
 const (
-    host     = "localhost"
-    port     = 5432
-    user     = "postgres"
-    password = "5te!nertRee"
-    dbname   = "nidhi"
+	host     = "172.18.0.2"
+	port     = 5432
+	user     = "postgres"
+	password = "VeryLongPassword"
+	dbname   = "nidhi"
 )
 
 func init() {
@@ -44,7 +45,6 @@ func init() {
     })
 }
 
-
 func main() {
 	// Read messages from the mining channel
 	count := 0
@@ -64,8 +64,6 @@ func main() {
 	}
 }
 
-
-
 func ProcessKey(key string) {
 	add := address.GetEthAddress(key)
 	Checkaddress(key, add)
@@ -80,6 +78,7 @@ func ProcessKey(key string) {
 	Checkaddress(key, p2sh_add)
 }
 
+
 //func Checkaddress(key, add string) {
 //	var exists bool
 //	row := db.QueryRow(`
@@ -100,6 +99,18 @@ func ProcessKey(key string) {
 //	}
 //}
 
+func Checkaddress(key, add string) {
+	var exists bool
+	row := db.QueryRow(`
+        SELECT EXISTS(SELECT 1 FROM ethereum WHERE address = $1)
+               OR EXISTS(SELECT 1 FROM bitcoin WHERE address = $1)`, add)
+	err := row.Scan(&exists)
+
+	if err != nil {
+		log.Fatalf("Failed to check if address exists: %v", err)
+	}
+
+
 
 func Checkaddress(key, add string) {
     exists, err := rdb.SIsMember(ctx, "addresses", add).Result()