CI/CD pipeline

Author: jiten4064

server/database/docker-compose.yml

@@ -12,25 +12,7 @@ services:
       - mongo_data:/data/db
 
   #Postgres service
-  postgres_db:
-    container_name: postgres_container
-    image: postgres:latest
-    environment:
-      POSTGRES_USER: postgres
-      POSTGRES_PASSWORD: postgres
-      POSTGRES_DB: postgres_db 
-      PGDATA: /var/lib/postgresql/data
-    ports:
-       - 5432:5432
-    restart: always
-    volumes:
-      - postgres_data:/var/lib/postgresql/data
-    healthcheck:
-      test: ["CMD", "pg_isready"]
-      interval: 10s
-      timeout: 5s
-      retries: 5
-      start_period: 30s  
+  
 
 
   # Node api service
@@ -40,11 +22,8 @@ services:
       - 3030:3030
     depends_on: 
       - mongo_db
-      - postgres_db
-
-
-
+     
 volumes:
   mongo_data: {}
-  postgres_data: {}
+
 

server/djangoapp/.env

@@ -1,2 +1,2 @@
-backend_url =http://127.0.0.1:3030/ 
-sentiment_analyzer_url=your code engine deployment url
+backend_url =http://127.0.0.1:3030 
+sentiment_analyzer_url=http://localhost:5000/

server/djangoapp/restapis.py

@@ -10,7 +10,7 @@
     'backend_url', default="http://localhost:3030")
 sentiment_analyzer_url = os.getenv(
     'sentiment_analyzer_url',
-    default="http://localhost:5050/")
+    default="http://localhost:5000/")
 
 # def get_request(endpoint, **kwargs):
 def get_request(endpoint, **kwargs):
@@ -27,7 +27,29 @@ def get_request(endpoint, **kwargs):
     except:
         print("Network exception occurred")
 
-        
+def analyze_review_sentiments(text):
+    request_url = sentiment_analyzer_url+"analyze/"+text
+    try:
+        # Call get method of requests library with URL and parameters
+        response = requests.get(request_url)
+        return response.json()
+    except Exception as err:
+        print(f"Unexpected {err=}, {type(err)=}")
+        print("Network exception occurred") 
+
+def post_review(data_dict):
+    request_url = backend_url + "/insert_review"
+    try:
+        # Call post method of requests library with URL and parameters
+        response = requests.post(request_url, json=data_dict)
+        print(response.json())
+        return response.json()
+    except Exception as err:
+        print(f"Unexpected {err=}, {type(err)=}")
+        print("Network exception occurred")
+    # print("POST to {}".format(request_url))
+
+             
 
 
 

server/djangoapp/urls.py

@@ -14,6 +14,18 @@
     path(route='registration', view=views.registration, name='registration'),
     # path for car makes view
     path(route='get_cars', view=views.get_cars, name='getcars'),
+    #get_dealerships
+    path(route='get_dealers', view=views.get_dealerships, name='get_dealers'),
+    path(route='get_dealers/<str:state>', view=views.get_dealerships, name='get_dealers_by_state'),
+    path(route='dealer/<int:dealer_id>', view=views.get_dealer_details, name='dealer_details'),
+    
+    #dealer review
+    path(route='reviews/dealer/<int:dealer_id>', view=views.get_dealer_reviews, name='dealer_reviews'),
+    
+    #add review
+    path(route='add_review', view=views.add_review, name='add_review'),
+
+
     # path for home view
 
 

server/djangoapp/views.py

@@ -15,6 +15,11 @@
 from django.views.decorators.csrf import csrf_exempt
 from .models import CarModel, CarMake
 from .populate import initiate
+from .restapis import get_request
+from .restapis import analyze_review_sentiments
+from .restapis import post_review
+
+
 
 
 # Get an instance of a logger
@@ -78,20 +83,57 @@ def registration(request):
 
 # # Update the `get_dealerships` view to render the index page with
 # a list of dealerships
-# def get_dealerships(request):
-# ...
+def get_dealerships(request, state="All"):
+    # Get dealers from the URL
+    if(state == "All"):
+        endpoint = "/fetchDealers"
+    else:
+        endpoint = "/fetchDealers/" + state
+    dealerships = get_request(endpoint)   
+    # Render the index page with the list of dealerships
+    return JsonResponse({"status": "200", "dealers": dealerships})
 
 # Create a `get_dealer_reviews` view to render the reviews of a dealer
-# def get_dealer_reviews(request,dealer_id):
-# ...
+def get_dealer_reviews(request,dealer_id):
+    if(dealer_id):
+        endpoint = "/fetchReviews/" + str(dealer_id)
+        reviews = get_request(endpoint)
+        return JsonResponse({"status": "200", "reviews": reviews})
+    else:
+        return JsonResponse({"status": "404", "message": "Bad Request"})
 
 # Create a `get_dealer_details` view to render the dealer details
-# def get_dealer_details(request, dealer_id):
-# ...
-
+def get_dealer_details(request, dealer_id):
+    if(dealer_id):
+        endpoint = "/fetchDealer/"+str(dealer_id)
+        dealership = get_request(endpoint)
+        return JsonResponse({"status":200,"dealer":dealership})
+    else:
+        return JsonResponse({"status":400,"message":"Bad Request"})
+def get_dealer_reviews(request, dealer_id):
+    # if dealer id has been provided
+    if(dealer_id):
+        endpoint = "/fetchReviews/dealer/"+str(dealer_id)
+        reviews = get_request(endpoint)
+        print(reviews)
+        for review_detail in reviews:
+            response = analyze_review_sentiments(review_detail['review'])
+            print(response)
+            review_detail['sentiment'] = response['sentiment']
+        return JsonResponse({"status":200,"reviews":reviews})
+    else:
+        return JsonResponse({"status":400,"message":"Bad Request"})
 # Create a `add_review` view to submit a review
-# def add_review(request):
-# ...
+def add_review(request):
+    if(request.user.is_anonymous == False):
+        data =json.loads(request.body)
+        try:
+            response = post_review(data)
+            return JsonResponse({"status":200,"message":"Review Submitted"})
+        except:
+            return JsonResponse({"status":401,"message":"Error in posting review"})
+    else:
+        return JsonResponse({"status":403,"message":"unauthorized"}) 
 
 def get_cars(request):
     count = CarMake.objects.filter().count()

server/djangoproj/urls.py

@@ -28,4 +28,8 @@
     path('login/', TemplateView.as_view(template_name="index.html")),
     path('register/', TemplateView.as_view(template_name="index.html")),
     path('logout/', TemplateView.as_view(template_name="index.html")),
+    path('dealers/', TemplateView.as_view(template_name="index.html")),
+    path('dealer/<int:dealer_id>',TemplateView.as_view(template_name="index.html")),
+    path('postreview/<int:dealer_id>',TemplateView.as_view(template_name="index.html")),
+    
 ] + static(settings.STATIC_URL, document_root=settings.STATIC_ROOT)

server/frontend/src/App.js

@@ -1,12 +1,19 @@
 import LoginPanel from "./components/Login/Login"
 import Register from "./components/Register/Register";
 import { Routes, Route } from "react-router-dom";
+import Dealers from "./components/Dealers/Dealers";
+import Dealer from "./components/Dealers/Dealer";
+import PostReview from "./components/Dealers/PostReview";
 
 function App() {
   return (
     <Routes>
       <Route path="/login" element={<LoginPanel />} />
       <Route path="/register" element={<Register />} />
+      <Route path="/dealers" element={<Dealers />} />
+      <Route path="/dealer/:id" element={<Dealer />} />
+      <Route path="/postreview/:id" element={<PostReview />} />
+      
     </Routes>
   );
 }

server/frontend/src/components/Dealers/Dealer.jsx

@@ -75,9 +75,9 @@ return(
       <h4  style={{color:"grey"}}>{dealer['city']},{dealer['address']}, Zip - {dealer['zip']}, {dealer['state']} </h4>
       </div>
       <div class="reviews_panel">
-      {reviews.length === 0 && unreviewed === false ? (
-        <text>Loading Reviews....</text>
-      ):  unreviewed === true? <div>No reviews yet! </div> :
+      {reviews.length === '0' ? (
+        <span>Loading Reviews....</span>
+      ):  unreviewed ? <div>No reviews yet! </div> :
       reviews.map(review => (
         <div className='review_panel'>
           <img src={senti_icon(review.sentiment)} className="emotion_icon" alt='Sentiment'/>

server/frontend/src/components/Dealers/Dealers.jsx

@@ -20,7 +20,7 @@ const Dealers = () => {
       method: "GET"
     });
     const retobj = await res.json();
-    if(retobj.status === 200) {
+    if(retobj.status === '200') {
       let state_dealers = Array.from(retobj.dealers)
       setDealersList(state_dealers)
     }
@@ -30,20 +30,27 @@ const Dealers = () => {
     const res = await fetch(dealer_url, {
       method: "GET"
     });
+    console.log(res)
+   
     const retobj = await res.json();
-    if(retobj.status === 200) {
+    console.log('retobj',retobj)
+    console.log('retobj.status',retobj.status)
+    if(retobj.status === '200') {
       let all_dealers = Array.from(retobj.dealers)
       let states = [];
       all_dealers.forEach((dealer)=>{
         states.push(dealer.state)
       });
 
+      console.log('all_dealers', all_dealers)
+
       setStates(Array.from(new Set(states)))
       setDealersList(all_dealers)
     }
   }
   useEffect(() => {
     get_dealers();
+    console.log("dealersList",dealersList)
   },[]);