use single mongo session for all requests

README.md

@@ -6,4 +6,6 @@ Cloud Hosted Real Time Retail Application.
 
 Cumulative Flow Diagram: [https://tinyurl.com/cmpe281starks-cfd](https://tinyurl.com/cmpe281starks-cfd) 
 
-Sprint Burndown Chart: [https://tinyurl.com/cmpe281starks-sbc](https://tinyurl.com/cmpe281starks-sbc)
+Sprint Burndown Chart: [https://tinyurl.com/cmpe281starks-sbc](https://tinyurl.com/cmpe281starks-sbc)
+
+

shopping_cart/cart/.env

@@ -1,4 +1,4 @@
-MONGODB_SERVER=localhost
+MONGODB_SERVER=localhost/?maxPoolSize=10
 MONGODB_NAME=shoppingcart
 SERVER_ADDRESS=http://localhost
 SERVER_PORT=80

shopping_cart/cart/src/carts/models/models.go

@@ -1,7 +1,9 @@
 package models
 
 import (
+	"fmt"
 	"github.com/joho/godotenv"
+	"gopkg.in/mgo.v2"
 	"gopkg.in/mgo.v2/bson"
 	"os"
 	"time"
@@ -20,6 +22,8 @@ var LinkSharedCart = ""
 var ActivityLogServerURL = ""
 var RecommendationServerURL = ""
 
+var MongoSession *mgo.Session
+
 func init() {
 
 	err := godotenv.Load()
@@ -40,7 +44,20 @@ func init() {
 	ActivityLogServerURL = os.Getenv("ACTIVITY_LOG_SERVER_URL")
 	RecommendationServerURL = os.Getenv("RECOMMENDATION_SERVER_URL")
 
-	println("LinkSharedCart:", LinkSharedCart)
+}
+
+func GetMongoSession() *mgo.Session {
+	if MongoSession == nil {
+		var err error
+		MongoSession, err = mgo.Dial(MongodbServer)
+		if err != nil {
+			fmt.Println("mongodb connection failed: ", err)
+			panic("mongodb connection failed:")
+		}
+		MongoSession.SetMode(mgo.SecondaryPreferred, true)
+		fmt.Println("New Mongo Session Created")
+	}
+	return MongoSession.Clone()
 }
 
 const (

shopping_cart/cart/src/carts/sharedcart/controller.go

@@ -348,17 +348,20 @@ func getMongoConnection() (mgo.Session, mgo.Collection, error) {
 
 	var collection *mgo.Collection
 
-	session, err := mgo.Dial(models.MongodbServer)
-	if err != nil {
-		fmt.Println("mongodb connection failed", err)
-		//c.String(http.StatusInternalServerError, "")
-		return *session, *collection, err
-	}
-	//defer session.Close()
-	session.SetMode(mgo.Monotonic, true)
-	collection = session.DB(models.MongodbDatabase).C(models.MongodbCollectionSharedCarts)
+	var mgoSession *mgo.Session = models.GetMongoSession()
+
+	// session, err := mgo.Dial(models.MongodbServer)
+	// if err != nil {
+	// 	fmt.Println("mongodb connection failed", err)
+	// 	//c.String(http.StatusInternalServerError, "")
+	// 	return *session, *collection, err
+	// }
+	// defer models.MongoSession.Close()
+	// session.SetMode(mgo.SecondaryPreferred, true)
+
+	collection = mgoSession.DB(models.MongodbDatabase).C(models.MongodbCollectionSharedCarts)
 
-	return *session, *collection, nil
+	return *mgoSession, *collection, nil
 }
 
 // --- Activity Log Events --- //

shopping_cart/cart/src/carts/usercart/controller.go

@@ -279,17 +279,18 @@ func getMongoConnection() (mgo.Session, mgo.Collection, error) {
 
 	var collection *mgo.Collection
 
-	session, err := mgo.Dial(models.MongodbServer)
-	if err != nil {
-		fmt.Println("mongodb connection failed", err)
-		//c.String(http.StatusInternalServerError, "")
-		return *session, *collection, err
-	}
-	//defer session.Close()
-	session.SetMode(mgo.Monotonic, true)
-	collection = session.DB(models.MongodbDatabase).C(models.MongodbCollectionUserCarts)
+	var mgoSession *mgo.Session = models.GetMongoSession()
+	// session, err := mgo.Dial(models.MongodbServer)
+	// if err != nil {
+	// 	fmt.Println("mongodb connection failed", err)
+	// 	//c.String(http.StatusInternalServerError, "")
+	// 	return *session, *collection, err
+	// }
+	// //defer session.Close()
+	// session.SetMode(mgo.SecondaryPreferred, true)
+	collection = mgoSession.DB(models.MongodbDatabase).C(models.MongodbCollectionUserCarts)
 
-	return *session, *collection, nil
+	return *mgoSession, *collection, nil
 }
 
 // --- Activity Log Events --- //

shopping_cart/mongodb_cluster/service.sh

@@ -0,0 +1,16 @@
+#!/bin/bash
+case $1 in
+    start)
+        echo "Starting hello web app."
+        /root/go/bin/hello &
+        ;;
+    stop)
+        echo "Stopping hello web app."
+        sudo kill $(sudo lsof -t -i:8001)
+        ;;
+    *)
+        echo "Hello web app service."
+        echo $"Usage $0 {start|stop}"
+        exit 1
+esac
+exit 0

web-app/js/shoppingCart.js

@@ -1,5 +1,5 @@
-var scShoppingCartServerURL = "http://54.183.237.157/carts";
-//var scShoppingCartServerURL = "http://localhost/carts";
+//var scShoppingCartServerURL = "http://54.183.237.157/carts";
+var scShoppingCartServerURL = "http://localhost/carts";
 var scTempUserId = "anuj";
 
 var scSelectedCartIndex = 0;