fix: fixed and migrated analytics to mongodb (#20)

* deps: mongodb

* fix: updated the traits action to save data to mongo

* fix: updated the locators action to save data to mongo

* deps: removed airtable dependency

Author: The24thDS

netlify/functions/save_locators_interaction.ts

@@ -1,41 +1,30 @@
-import { Handler } from "@netlify/functions";
-import { Response } from "@netlify/functions/dist/function/response";
-import Airtable from "airtable";
+import { Handler, HandlerResponse } from "@netlify/functions";
+import { MongoClient } from "mongodb";
 import invariant from "tiny-invariant";
 
+invariant(process.env.MONGODB_URI, "MongoDB URI is not defined.");
+const mongoClient = new MongoClient(process.env.MONGODB_URI);
+const clientPromise = mongoClient.connect();
+
 const saveLocatorsInteraction = async (
   type: "generate" | "copy",
   amount: number,
   stateTime: number
 ) => {
-  const { AIRTABLE_API_KEY, AIRTABLE_BASE, AIRTABLE_LOCATORS_TABLE } =
+  const { MONGODB_DATABASE, MONGODB_LOCATORS_COLLECTION } =
     process.env;
 
-  invariant(AIRTABLE_API_KEY, "Airtable API key is not defined.");
-  invariant(AIRTABLE_BASE, "Airtable base is not defined.");
-  invariant(AIRTABLE_LOCATORS_TABLE, "Airtable table id is not defined.");
+  invariant(MONGODB_DATABASE, "Mongo DB name is not defined.");
+  invariant(MONGODB_LOCATORS_COLLECTION, "Mongo DB collection is not defined.");
 
-  Airtable.configure({
-    apiKey: AIRTABLE_API_KEY,
-    endpointUrl: "https://api.airtable.com",
-  });
-  const base = Airtable.base(AIRTABLE_BASE);
+  const database = (await clientPromise).db(MONGODB_DATABASE);
+  const collection = database.collection(MONGODB_LOCATORS_COLLECTION);
 
-  return new Promise((resolve, reject) => {
-    base(AIRTABLE_LOCATORS_TABLE).create(
-      {
-        action_type: type,
-        locators_number: amount,
-        state_time: stateTime,
-        created_at: new Date().toISOString(),
-      },
-      (err) => {
-        if (err) {
-          reject(err);
-        }
-        resolve(true);
-      }
-    );
+  await collection.insertOne({
+    action_type: type,
+    locators_number: amount,
+    state_time: stateTime,
+    created_at: new Date(),
   });
 };
 
@@ -46,7 +35,7 @@ const headers = {
 };
 
 const handler: Handler = async (event, _context) => {
-  const response: Response = {
+  const response: HandlerResponse = {
     statusCode: 200,
     headers,
   };

netlify/functions/save_traits_interaction.ts

@@ -1,11 +1,14 @@
-import { Handler } from "@netlify/functions";
-import { Response } from "@netlify/functions/dist/function/response";
-import Airtable from "airtable";
+import { Handler, HandlerResponse } from "@netlify/functions";
+import { MongoClient } from "mongodb";
 import invariant from "tiny-invariant";
 import { State } from "../../src/components/TraitsBuilderTab/index.d";
 
+invariant(process.env.MONGODB_URI, "MongoDB URI is not defined.");
+const mongoClient = new MongoClient(process.env.MONGODB_URI);
+const clientPromise = mongoClient.connect();
+
 const saveLocatorsInteraction = async (type: "PNG" | "DDS", state: State) => {
-  const { AIRTABLE_API_KEY, AIRTABLE_BASE, AIRTABLE_TRAITS_TABLE } =
+  const { MONGODB_DATABASE, MONGODB_TRAITS_COLLECTION } =
     process.env;
   const {
     name,
@@ -17,37 +20,24 @@ const saveLocatorsInteraction = async (type: "PNG" | "DDS", state: State) => {
     iconYOffset,
   } = state;
 
-  invariant(AIRTABLE_API_KEY, "Airtable API key is not defined.");
-  invariant(AIRTABLE_BASE, "Airtable base is not defined.");
-  invariant(AIRTABLE_TRAITS_TABLE, "Airtable table id is not defined.");
+  invariant(MONGODB_DATABASE, "Mongo DB name is not defined.");
+  invariant(MONGODB_TRAITS_COLLECTION, "Mongo DB collection is not defined.");
 
-  Airtable.configure({
-    apiKey: AIRTABLE_API_KEY,
-    endpointUrl: "https://api.airtable.com",
-  });
-  const base = Airtable.base(AIRTABLE_BASE);
+  const database = (await clientPromise).db(MONGODB_DATABASE);
+  const collection = database.collection(MONGODB_TRAITS_COLLECTION);
 
-  return new Promise((resolve, reject) => {
-    base(AIRTABLE_TRAITS_TABLE).create(
-      {
-        name,
-        format: type,
-        bg_color: bgColor,
-        recolor_icon: recolorIcon,
-        icon_color: iconColor,
-        icon_scale: iconScale,
-        icon_x_offset: iconXOffset,
-        icon_y_offset: iconYOffset,
-        created_at: new Date().toISOString(),
-      },
-      (err) => {
-        if (err) {
-          reject(err);
-        }
-        resolve(true);
-      }
-    );
+  await collection.insertOne({
+    name,
+    format: type,
+    bg_color: bgColor,
+    recolor_icon: recolorIcon,
+    icon_color: iconColor,
+    icon_scale: iconScale,
+    icon_x_offset: iconXOffset,
+    icon_y_offset: iconYOffset,
+    created_at: new Date(),
   });
+
 };
 
 const headers = {
@@ -57,7 +47,7 @@ const headers = {
 };
 
 const handler: Handler = async (event, _context) => {
-  const response: Response = {
+  const response: HandlerResponse = {
     statusCode: 200,
     headers,
   };

package.json

@@ -19,12 +19,12 @@
     "@mantine/dropzone": "^7.0.0",
     "@mantine/hooks": "^7.0.0",
     "@mantine/notifications": "^7.0.0",
-    "@netlify/functions": "^1.0.0",
+    "@netlify/functions": "^2.8.1",
     "@sentry/browser": "^7.12.1",
     "@tabler/icons-react": "^3.5.0",
-    "airtable": "^0.11.4",
     "filesize": "^10.0.12",
     "konva": "^8.3.14",
+    "mongodb": "^6.8.0",
     "random": "^3.0.6",
     "react": "^18.3.1",
     "react-dom": "^18.3.1",