Added database to services

Author: luloxi

packages/nextjs/services/database/collections.ts

@@ -0,0 +1,45 @@
+// import { firestore } from "firebase-admin";
+import getFirestoreConnector from "~~/services/database/firestoreDB";
+
+// import getFirestoreConnector from "./firestoreDB.js";
+
+// Firestore instance
+const firestoreDB = getFirestoreConnector();
+
+// Function to create a collection
+export async function createCollection({
+  name,
+  symbol,
+  tokenURI,
+  userAddress,
+}: {
+  name: string;
+  symbol: string;
+  tokenURI: string;
+  userAddress: string;
+}) {
+  try {
+    console.log("Creating collection with data:", { name, symbol, tokenURI, userAddress });
+
+    const collectionRef = await firestoreDB.collection("collections").add({
+      name,
+      symbol,
+      tokenURI,
+      userAddress,
+      // createdAt: new Date().toISOString(),
+    });
+
+    console.log("Collection created with ID:", collectionRef.id);
+
+    return {
+      id: collectionRef.id,
+      name,
+      symbol,
+      tokenURI,
+      userAddress,
+    };
+  } catch (error) {
+    console.error("Error creating collection:", error);
+    throw new Error("Failed to create collection");
+  }
+}

packages/nextjs/services/database/firestoreDB.ts

@@ -0,0 +1,16 @@
+import { firestore } from "firebase-admin";
+import admin from "firebase-admin";
+
+// Ensure Firebase Admin SDK is initialized
+if (!admin.apps.length) {
+  admin.initializeApp({
+    credential: admin.credential.applicationDefault(),
+  });
+}
+
+const getFirestoreConnector = () => {
+  console.log("Initializing Firestore");
+  return firestore(); // Correctly returns the Firestore instance
+};
+
+export default getFirestoreConnector;

packages/nextjs/services/database/users.ts

@@ -0,0 +1,16 @@
+import getFirestoreConnector from "~~/services/database/firestoreDB";
+
+// Firestore instance
+const firestoreDB = getFirestoreConnector();
+
+// Find a user (or user) by their wallet address
+export async function findUserByAddress(address: string) {
+  const userSnapshot = await firestoreDB.collection("users").where("walletAddress", "==", address).get();
+
+  if (!userSnapshot.empty) {
+    const userDoc = userSnapshot.docs[0];
+    return { exists: true, data: userDoc.data() };
+  }
+
+  return { exists: false };
+}