[CHORE]

Some useless lines removed and edits

src/GoServices/Business/SendMailBusiness.go

@@ -4,6 +4,7 @@ import(
 	//Local Packages
 	"net/http"
 	"encoding/json"
+	
 	//ThisProject Packages
 	models "bulkmail/packages/Data/Models"
 	myLog "bulkmail/packages/Utils/Logger"
@@ -19,7 +20,5 @@ func AddToQueue(w http.ResponseWriter, r *http.Request){
 		myLog.FailOnError(err, "Failed data can't converting")
 	}
 
-	//go rabbit.GetInstance()
-	//rabbit.AddToQueue(body)
 	rabbit.AddToQueue(body)
 }
\ No newline at end of file

src/GoServices/DataAccess/MongoDb/Connections.go

@@ -3,8 +3,10 @@ package MongoDb
 import(
 	//Local Packages
 	"context"
+
 	//This Project Packages
 	myLogger "bulkmail/packages/Utils/Logger"
+	
 	//Online Packages
 	//bson "go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/mongo"
@@ -31,28 +33,5 @@ func InsertOne(data string){
 	if er != nil {
 		myLogger.FailOnError(err, "INSERT ONE FAILED")
 	}
-	myLogger.Print("inserted")
-}
-
-// func GetConnection() **mongo.Client{
-// 	client, err = mongo.NewClient(options.Client().ApplyURI("mongodb://localhost:27017"))
-// 	if err!= nil{
-// 		log.Fatal(err)
-// 	}
-// 	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
-// 	err = client.Connect(ctx)
-// 	if err!= nil{
-// 		log.Fatal(err)
-// 	}
-// 	defer client.Disconnect(ctx)
-
-// 	return &client
-// }
-
-// func GetDatabase(clnt *mongo.Client) *mongo.Database{
-// 	return clnt.Database("test") 
-// }
-
-// func GetCollection(db *mongo.Database) *mongo.Collection{
-// 	return db.Collection("testcollect")
-// }
\ No newline at end of file
+	myLogger.Print("inserted")//!!
+}
\ No newline at end of file

src/GoServices/Presentation/Consumer/Consumer.go

@@ -4,29 +4,26 @@ import(
 	//Local Packages
 	"log"
 	"sync"
+
 	//This Project Packages
 	myMongo "bulkmail/packages/DataAccess/MongoDb"
 	//"bulkmail/packages/Data/Models"
+	myLogger "bulkmail/packages/Utils/Looger"
+
 	//Git Packages
 	amqp "github.com/rabbitmq/amqp091-go"
 	//"go.mongodb.org/mongo-driver/mongo"
 )
 
-func failOnError(err error, msg string) {
-	if err != nil {
-		log.Panicf("%s: %s", msg, err)
-	}
-}
-
 func Consumer(wg *sync.WaitGroup) {
 	defer wg.Done()
 	//Rabbit Connection
 	conn, err := amqp.Dial("amqp://root:root@localhost:5672/")
-	failOnError(err, "Failed to connect to RabbitMQ")
+	myLogger.FailOnError(err, "Failed to connect to RabbitMQ")
 	defer conn.Close()
 	//Rabbit Channel
 	ch, err := conn.Channel()
-	failOnError(err, "Failed to open a channel")
+	myLogger.FailOnError(err, "Failed to open a channel")
 	defer ch.Close()
 	//Rabbit Queue
 	q, err := ch.QueueDeclare(
@@ -37,7 +34,7 @@ func Consumer(wg *sync.WaitGroup) {
 		false,   // no-wait
 		nil,     // arguments
 	)
-	failOnError(err, "Failed to declare a queue")
+	myLogger.FailOnError(err, "Failed to declare a queue")
 
 	msgs, err := ch.Consume(
 		q.Name, // queue
@@ -48,26 +45,19 @@ func Consumer(wg *sync.WaitGroup) {
 		false,  // no-wait
 		nil,    // args
 	)
-	failOnError(err, "Failed to register a consumer")
+	myLogger.FailOnError(err, "Failed to register a consumer")
 
 	var forever chan struct{}
-	// //var clnt *mongo.Client
-	// clnt:= myMongo.GetConnection()
-	// db:=myMongo.GetDatabase(*clnt)
-	// col:=myMongo.GetCollection(db)
-	// col.InsertOne()
-
 	
-
-	//var mail Models.Mail
 	go func() {
 		for d := range msgs {
-			log.Printf("Received a message: %s", d.Body)
+			myLogger.PrintData("Received a message => ", d.Body)
+
 			myMongo.GetClient("test","testcol")
 			myMongo.InsertOne("test")
 		}
 	}()
 
-	log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
+	myLogger.Print("Waiting for messages. To exit press CTRL+C")
 	<-forever
 }
\ No newline at end of file

src/GoServices/Presentation/WebAPI/Controllers/SendMailController.go

@@ -3,6 +3,7 @@ package Controllers
 import(
 	//Local Packages
 	"net/http"
+	
 	//This Project Packages
 	bsns "bulkmail/packages/Business"
 )

src/GoServices/Presentation/WebAPI/Service.go

@@ -5,14 +5,15 @@ import(
     "net/http"
     "log"
     "sync"
+
     //This Project Packages
 	"bulkmail/packages/Presentation/WebAPI/Controllers"
-    "bulkmail/packages/Utils/Logger"
+    myLogger "bulkmail/packages/Utils/Logger"
 )
 
 func WebAPI(wg *sync.WaitGroup) {
     defer wg.Done()
     Controllers.SendMail()
-    Logger.Print("Server Started")
+    myLogger.Print("Server Started")
     log.Fatal(http.ListenAndServe(":10000", nil))
 }
\ No newline at end of file

src/GoServices/Utils/RabbitMQ/Connection.go

@@ -3,6 +3,7 @@ package RabbitMQ
 import(
 	//This Project Packages
 	myLog "bulkmail/packages/Utils/Logger"
+
 	//Git Packages
 	amqp "github.com/rabbitmq/amqp091-go"
 )
@@ -37,5 +38,5 @@ func AddToQueue(body []byte){
 			Body: body,
 		})
 	myLog.FailOnError(er, "Failed to publish a message")
-	myLog.PrintData("Sended this data =>", body)//Logger
+	myLog.PrintData("Sended this data => ", body)//Logger
 }
\ No newline at end of file

src/GoServices/main.go

@@ -3,6 +3,7 @@ package main
 import(
     //Local Packages
     "sync"
+    
     //This Project Packages
 	"bulkmail/packages/Presentation/WebAPI"
     "bulkmail/packages/Presentation/Consumer"