adding backend services

functions/.creds-sample.json

@@ -1,4 +1,5 @@
 {
-    "COUCH_URL": "",
-    "IAM_API_KEY": ""
+    "COUCH_URL": "https://28059ad8-d624-49da-9bc2-b47b4fe4f5cf-bluemix.cloudantnosqldb.appdomain.cloud",
+    "IAM_API_KEY": "TSgWbTjzq6jssiS84dyhno1-8Ndsegw233QlFv51JGLw",
+    "COUCH_USERNAME":"28059ad8-d624-49da-9bc2-b47b4fe4f5cf-bluemix"
 }

functions/get-dealerships.js

@@ -0,0 +1,106 @@
+function main(params) {
+    const { CloudantV1 } = require('@ibm-cloud/cloudant');
+    const { IamAuthenticator } = require('ibm-cloud-sdk-core');
+    const authenticator = new IamAuthenticator({ apikey: 'TSgWbTjzq6jssiS84dyhno1-8Ndsegw233QlFv51JGLw' });
+    const cloudant = CloudantV1.newInstance({
+      authenticator: authenticator,
+    });
+    cloudant.setServiceUrl('https://28059ad8-d624-49da-9bc2-b47b4fe4f5cf-bluemix.cloudantnosqldb.appdomain.cloud');
+
+    return new Promise((resolve, reject) => {
+      if (params.state) {
+        findDealershipByState(cloudant, params.state)
+          .then((result) => {
+            const code = result.length ? 200 : 404;
+            resolve({
+              statusCode: code,
+              headers: { 'Content-Type': 'application/json' },
+              body: result,
+            });
+          })
+          .catch((err) => {
+            console.error(err);
+            reject({
+              statusCode: 500,
+              headers: { 'Content-Type': 'application/json' },
+              body: { error: 'Internal Server Error' },
+            });
+          });
+      } else if (params.id) {
+        findDealershipById(cloudant, params.id)
+          .then((result) => {
+            const code = result.length ? 200 : 404;
+            resolve({
+              statusCode: code,
+              headers: { 'Content-Type': 'application/json' },
+              body: result,
+            });
+          })
+          .catch((err) => {
+            console.error(err);
+            reject({
+              statusCode: 500,
+              headers: { 'Content-Type': 'application/json' },
+              body: { error: 'Internal Server Error' },
+            });
+          });
+      } else {
+        findAllDealerships(cloudant)
+          .then((result) => {
+            const code = result.length ? 200 : 404;
+            resolve({
+              statusCode: code,
+              headers: { 'Content-Type': 'application/json' },
+              body: result,
+            });
+          })
+          .catch((err) => {
+            console.error(err);
+            reject({
+              statusCode: 500,
+              headers: { 'Content-Type': 'application/json' },
+              body: { error: 'Internal Server Error' },
+            });
+          });
+      }
+    });
+  }
+
+  function findDealershipByState(cloudant, state) {
+    return new Promise((resolve, reject) => {
+      cloudant
+        .postFind({ db: 'dealerships', selector: { state: state } })
+        .then((result) => {
+          resolve(result.result.docs);
+        })
+        .catch((err) => {
+          reject(err);
+        });
+    });
+  }
+
+  function findDealershipById(cloudant, id) {
+    return new Promise((resolve, reject) => {
+      cloudant
+        .postFind({ db: 'dealerships', selector: { id: parseInt(id) } })
+        .then((result) => {
+          resolve(result.result.docs);
+        })
+        .catch((err) => {
+          reject(err);
+        });
+    });
+  }
+
+  function findAllDealerships(cloudant) {
+    return new Promise((resolve, reject) => {
+      cloudant
+        .postAllDocs({ db: 'dealerships', includeDocs: true, limit: 10 })
+        .then((result) => {
+          resolve(result.result.rows);
+        })
+        .catch((err) => {
+          reject(err);
+        });
+    });
+  }

functions/get-review.py

@@ -0,0 +1,52 @@
+from ibm_cloud_sdk_core.authenticators import IAMAuthenticator
+from ibm_cloud_sdk_core import ApiException
+from ibmcloudant.cloudant_v1 import CloudantV1
+import json
+
+def main(params):
+    authenticator = IAMAuthenticator('TSgWbTjzq6jssiS84dyhno1-8Ndsegw233QlFv51JGLw')
+    cloudant = CloudantV1(authenticator=authenticator)
+    cloudant.set_service_url('https://28059ad8-d624-49da-9bc2-b47b4fe4f5cf-bluemix.cloudantnosqldb.appdomain.cloud')
+
+    if 'dealerId' in params:
+        dealership = int(params['dealerId'])
+        try:
+            response = cloudant.post_find(
+                db='reviews',
+                selector={'dealership': dealership}
+            )
+            result = response.result
+            code = 200 if len(result['docs']) > 0 else 404
+            return {
+                'statusCode': code,
+                'headers': {'Content-Type': 'application/json'},
+                'body': result['docs']
+            }
+        except ApiException as e:
+            print(f"Error: {e.code} - {e.message}")
+            return {
+                'statusCode': 500,
+                'headers': {'Content-Type': 'application/json'},
+                'body': {'error': 'Internal Server Error'}
+            }
+    else:
+        try:
+            response = cloudant.post_all_docs(
+                db='reviews',
+                include_docs=True
+            )
+            result = response.result
+            code = 200 if len(result['rows']) > 0 else 404
+            reviews = [row['doc'] for row in result['rows']]
+            return {
+                'statusCode': code,
+                'headers': {'Content-Type': 'application/json'},
+                'body': reviews
+            }
+        except ApiException as e:
+            print(f"Error: {e.code} - {e.message}")
+            return {
+                'statusCode': 500,
+                'headers': {'Content-Type': 'application/json'},
+                'body': {'error': 'Internal Server Error'}
+            }