Update

.gitignore

@@ -20,4 +20,8 @@ go.work
 .DS_Store
 .idea/
 .env
-a
+a
+
+*.json
+*.js
+node_modules/

src/cmd/server/main.go

@@ -41,16 +41,16 @@ func main() {
 	if err != nil {
 		log.Fatalf("Failed to consume messages: %s", err)
 	}
-	fmt.Printf("Consuming messages with msgs %v", msgs)
+	fmt.Printf("Consuming messages with msgs %v\n", msgs)
 
 	omap := orderedmap.NewOrderedMap()
-	fmt.Printf("Created ordered map %v", omap)
+	fmt.Printf("Created ordered map %v\n", omap)
 
 	processor := consumerService.NewConsumerService(omap)
-	fmt.Printf("Created consumer service %v", processor)
+	fmt.Printf("Created consumer service %v\n", processor)
 
 	for msg := range msgs {
-		fmt.Printf("Processing message %v", msg)
+		fmt.Printf("Processing message %v\n", msg)
 		processor.ProcessMessage(msg)
 	}
 }

src/pkg/services/consumerService/consumerService.go

@@ -45,17 +45,18 @@ func (cs *ConsumerService) ProcessMessage(d amqp091.Delivery) {
 }
 
 func (cs *ConsumerService) handleAdd(command []string) {
+	fmt.Printf("Add key: %s value: %s\n", command[1], command[2])
 	if len(command) != 3 {
 		log.Println("Add command requires 2 arguments: key and value")
 		return
 	}
 	cs.rwmu.Lock()
 	cs.omap.Add(command[1], command[2])
 	cs.rwmu.Unlock()
-	fmt.Println("Added key:", command[1], "value:", command[2])
 }
 
 func (cs *ConsumerService) handleGet(command []string) {
+	fmt.Printf("Get key: %s\n", command[1])
 	if len(command) != 2 {
 		log.Println("Get command requires 1 argument: key")
 		return
@@ -71,6 +72,7 @@ func (cs *ConsumerService) handleGet(command []string) {
 }
 
 func (cs *ConsumerService) handleDelete(command []string) {
+	fmt.Printf("Delete key: %s\n", command[1])
 	if len(command) != 2 {
 		fmt.Println("Delete command requires 1 argument: key")
 		return
@@ -81,6 +83,7 @@ func (cs *ConsumerService) handleDelete(command []string) {
 }
 
 func (cs *ConsumerService) handleGetAll() {
+	fmt.Println("Get all keys and values")
 	cs.rwmu.RLock()
 	allItems := cs.omap.GetAll()
 	cs.rwmu.RUnlock()