Successfully insert message into Cassandra db

Author: Leo7Deng

backend/cassandra/client.go

@@ -23,7 +23,6 @@ func CassandraSession() *gocql.Session {
 	if err != nil {
 		log.Fatal(err)
 	}
-	defer session.Close()
 	fmt.Println("Connected to Cassandra Nodes:")
 	for _, host := range cluster.Hosts {
 		fmt.Println("- Node:", host)

backend/cassandra/service.go

@@ -2,18 +2,26 @@ package cassandra
 
 import (
 	"fmt"
+	"time"
+
 	"github.com/Leo7Deng/ChatApp/models"
 	"github.com/gocql/gocql"
 	"github.com/google/uuid"
 )
 
 func InsertMessage(session *gocql.Session, message models.Message) error {
 	messageID := uuid.New().String()
+	// convert time string to cassandra timestamp
+	parsedTime, err := time.Parse(time.RFC3339, message.CreatedAt)
+	if err != nil {
+		fmt.Println("Error parsing time:", err)
+		return err
+	}
 	query := session.Query(`
 		INSERT INTO chat_app.messages (circle_id, created_at, message_id, author_id, content)
 		VALUES (?, ?, ?, ?, ?)`,
-		message.CircleID, message.CreatedAt, messageID, message.AuthorID, message.Content)
-	err := query.Exec()
+		message.CircleID, parsedTime, messageID, message.AuthorID, message.Content)
+	err = query.Exec()
 	if err != nil {
 		fmt.Println("Error inserting message into Cassandra:", err)
 		return err

backend/docker-compose.yml

@@ -70,7 +70,7 @@ services:
       CASSANDRA_LISTEN_ADDRESS: "cassandra-node1"
       CASSANDRA_ENDPOINT_SNITCH: "GossipingPropertyFileSnitch"
       CASSANDRA_CLUSTER_NAME: "cassandra-cluster"
-      # CASSANDRA_SEEDS: "cassandra-node1,cassandra-node2"
+      CASSANDRA_SEEDS: "cassandra-node1"
       CASSANDRA_NUM_TOKENS: 8
       CASSANDRA_DC: "dc1"
     ports:
@@ -102,6 +102,8 @@ services:
       CASSANDRA_SEEDS: "cassandra-node1"
       CASSANDRA_NUM_TOKENS: 8
       CASSANDRA_DC: "dc1"
+    ports:
+      - "9043:9042"
     volumes:
       - cassandra-data-node2:/var/lib/cassandra
     healthcheck:
@@ -129,6 +131,8 @@ services:
       CASSANDRA_SEEDS: "cassandra-node1"
       CASSANDRA_NUM_TOKENS: 8
       CASSANDRA_DC: "dc1"
+    ports:
+      - "9044:9042"
     volumes:
       - cassandra-data-node3:/var/lib/cassandra
     healthcheck: