Configure Space: migrate catalog and autopilot database adapter to Supabase

package-lock.json

@@ -9,6 +9,7 @@
       "version": "1.0.0",
       "dependencies": {
         "@huggingface/inference": "^2.8.1",
+        "@supabase/supabase-js": "^2.106.2",
         "cors": "^2.8.5",
         "dotenv": "^16.4.5",
         "express": "^4.19.2",
@@ -45,6 +46,90 @@
         "sparse-bitfield": "^3.0.3"
       }
     },
+    "node_modules/@supabase/auth-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/auth-js/-/auth-js-2.106.2.tgz",
+      "integrity": "sha512-VcAjUErkHkhC5Jaf+g/G1qbkQrFh8edaCdHa7pxJmHUjkWKjT7UnYCtPA89XV0N0GIYRkEqJZw5V62CtOxTmBQ==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/functions-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/functions-js/-/functions-js-2.106.2.tgz",
+      "integrity": "sha512-oRnr0QrL8H+zTO1YyQ1QjiHZU/957jvubbxSJTUm2XLAgzoGGV9Tahfyd+uvLsBLRVmXLtpU3oyCjdQIvkGMOA==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/phoenix": {
+      "version": "0.4.2",
+      "resolved": "https://registry.npmjs.org/@supabase/phoenix/-/phoenix-0.4.2.tgz",
+      "integrity": "sha512-YSAGnmDAfuleFCVt3CeurQZAhxRfXWeZIIkwp7NhYzQ1UwW6ePSnzsFAiUm/mbCkfoCf70QQHKW/K6RKh52a4A==",
+      "license": "MIT"
+    },
+    "node_modules/@supabase/postgrest-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/postgrest-js/-/postgrest-js-2.106.2.tgz",
+      "integrity": "sha512-tDOzyPgp9pIRMR2x6C9+uDSJrnXSzxLtt3d7nC+Lrsy3jnJDHYfdQC/xcRyhJE/TOBJ0heSqRKR3UmejDjZxsw==",
+      "license": "MIT",
+      "dependencies": {
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/realtime-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/realtime-js/-/realtime-js-2.106.2.tgz",
+      "integrity": "sha512-LdRGT7DNhyZkPjubUv5bSdAZ0jSEX8wTHvx7htj7+K59TOZRvz4TuQK7tL2RWxyIZVeFMRluL04SzWS61rKnUA==",
+      "license": "MIT",
+      "dependencies": {
+        "@supabase/phoenix": "^0.4.2",
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/storage-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/storage-js/-/storage-js-2.106.2.tgz",
+      "integrity": "sha512-xgKCSYuev1YarV+iVqr+zlfgSyremnJtn8T0NCT8L4XmMv1CLtESc0Q6kNp8+mKWdX/8ND0nzm7OMKx08kwNAw==",
+      "license": "MIT",
+      "dependencies": {
+        "iceberg-js": "^0.8.1",
+        "tslib": "2.8.1"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
+    "node_modules/@supabase/supabase-js": {
+      "version": "2.106.2",
+      "resolved": "https://registry.npmjs.org/@supabase/supabase-js/-/supabase-js-2.106.2.tgz",
+      "integrity": "sha512-2/RZ/1fmJx/MRSEDG2Xk8+J4JVk5clM9V0uSI6kUTrcS32KA89DtqI5RUOC9r6mzY3WBC9qexLjssIHjbLyVJA==",
+      "license": "MIT",
+      "dependencies": {
+        "@supabase/auth-js": "2.106.2",
+        "@supabase/functions-js": "2.106.2",
+        "@supabase/postgrest-js": "2.106.2",
+        "@supabase/realtime-js": "2.106.2",
+        "@supabase/storage-js": "2.106.2"
+      },
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
     "node_modules/@types/webidl-conversions": {
       "version": "7.0.3",
       "resolved": "https://registry.npmjs.org/@types/webidl-conversions/-/webidl-conversions-7.0.3.tgz",
@@ -640,6 +725,15 @@
         "url": "https://opencollective.com/express"
       }
     },
+    "node_modules/iceberg-js": {
+      "version": "0.8.1",
+      "resolved": "https://registry.npmjs.org/iceberg-js/-/iceberg-js-0.8.1.tgz",
+      "integrity": "sha512-1dhVQZXhcHje7798IVM+xoo/1ZdVfzOMIc8/rgVSijRK38EDqOJoGula9N/8ZI5RD8QTxNQtK/Gozpr+qUqRRA==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=20.0.0"
+      }
+    },
     "node_modules/iconv-lite": {
       "version": "0.4.24",
       "resolved": "https://registry.npmjs.org/iconv-lite/-/iconv-lite-0.4.24.tgz",
@@ -1401,6 +1495,12 @@
         "node": ">=18"
       }
     },
+    "node_modules/tslib": {
+      "version": "2.8.1",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.8.1.tgz",
+      "integrity": "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==",
+      "license": "0BSD"
+    },
     "node_modules/type-is": {
       "version": "1.6.18",
       "resolved": "https://registry.npmjs.org/type-is/-/type-is-1.6.18.tgz",

package.json

@@ -10,6 +10,7 @@
   },
   "dependencies": {
     "@huggingface/inference": "^2.8.1",
+    "@supabase/supabase-js": "^2.106.2",
     "cors": "^2.8.5",
     "dotenv": "^16.4.5",
     "express": "^4.19.2",

server.js

@@ -4,7 +4,7 @@ import dotenv from 'dotenv';
 import { HfInference } from '@huggingface/inference';
 import fs from 'fs';
 import path from 'path';
-import mongoose from 'mongoose';
+import { createClient } from '@supabase/supabase-js';
 
 // Load environment variables
 dotenv.config();
@@ -17,36 +17,25 @@ app.use(cors());
 app.use(express.json());
 
 // ----------------------------------------------------
-// DATABASE CONFIGURATION: MONGODB ATLAS WITH JSON FALLBACK
+// DATABASE CONFIGURATION: SUPABASE WITH JSON FALLBACK
 // ----------------------------------------------------
 
-let isMongoConnected = false;
+let isSupabaseConnected = false;
+let supabase = null;
 
-// Define MongoDB Schema & Model
-const BookSchema = new mongoose.Schema({
-  title: { type: String, required: true },
-  subtitle: { type: String, default: '' },
-  type: { type: String, default: 'other' },
-  price: { type: Number, default: 9.99 },
-  date: { type: String, default: () => new Date().toLocaleDateString() }
-});
-
-const BookModel = mongoose.models.Book || mongoose.model('Book', BookSchema);
-
-// Attempt MongoDB Connection if MONGODB_URI is provided
-if (process.env.MONGODB_URI && !process.env.MONGODB_URI.includes('cluster0.xxxx')) {
-  console.log('🔌 Connecting to MongoDB Atlas Cloud...');
-  mongoose.connect(process.env.MONGODB_URI)
-    .then(() => {
-      isMongoConnected = true;
-      console.log('✅ Connected to MongoDB Atlas Cloud Database!');
-    })
-    .catch((err) => {
-      console.error('❌ MongoDB Atlas Connection Error:', err.message);
-      console.log('⚠️ Falling back to Local JSON Database.');
-    });
+// Attempt Supabase Connection if credentials are provided
+if (process.env.SUPABASE_URL && process.env.SUPABASE_KEY && !process.env.SUPABASE_URL.includes('your-project-id')) {
+  console.log('🔌 Connecting to Supabase Cloud Database...');
+  try {
+    supabase = createClient(process.env.SUPABASE_URL, process.env.SUPABASE_KEY);
+    isSupabaseConnected = true;
+    console.log('✅ Connected to Supabase Cloud Database!');
+  } catch (err) {
+    console.error('❌ Supabase Connection Error:', err.message);
+    console.log('⚠️ Falling back to Local JSON Database.');
+  }
 } else {
-  console.log('ℹ️ MONGODB_URI not set or using template. Using Local JSON Database.');
+  console.log('ℹ️ Supabase credentials not set or using template. Using Local JSON Database.');
 }
 
 // JSON File Database Fallback Configuration
@@ -94,7 +83,7 @@ app.get('/api/health', (req, res) => {
   res.json({ 
     status: 'ok', 
     hfConfigured: !!process.env.HF_API_KEY, 
-    dbType: isMongoConnected ? 'mongodb_atlas' : 'local_json',
+    dbType: isSupabaseConnected ? 'supabase' : 'local_json',
     dbConnected: true 
   });
 });
@@ -104,21 +93,17 @@ app.get('/api/health', (req, res) => {
 // ----------------------------------------------------
 
 app.get('/api/catalog', async (req, res) => {
-  if (isMongoConnected) {
+  if (isSupabaseConnected) {
     try {
-      const catalog = await BookModel.find().sort({ _id: -1 });
-      // Map _id to id for frontend compatibility
-      const mappedCatalog = catalog.map(book => ({
-        id: book._id.toString(),
-        title: book.title,
-        subtitle: book.subtitle,
-        type: book.type,
-        price: book.price,
-        date: book.date
-      }));
-      return res.json(mappedCatalog);
+      const { data, error } = await supabase
+        .from('catalog')
+        .select('*')
+        .order('id', { ascending: false });
+      
+      if (error) throw error;
+      return res.json(data || []);
     } catch (err) {
-      console.error('Error fetching from MongoDB:', err);
+      console.error('Error fetching from Supabase:', err.message);
       // Fallback
     }
   }
@@ -134,24 +119,24 @@ app.post('/api/catalog', async (req, res) => {
     return res.status(400).json({ error: 'Book title is required' });
   }
 
-  if (isMongoConnected) {
+  if (isSupabaseConnected) {
     try {
-      const newBook = await BookModel.create({
-        title,
-        subtitle: subtitle || '',
-        type: type || 'other',
-        price: price || 9.99
-      });
-      return res.status(201).json({
-        id: newBook._id.toString(),
-        title: newBook.title,
-        subtitle: newBook.subtitle,
-        type: newBook.type,
-        price: newBook.price,
-        date: newBook.date
-      });
+      const { data, error } = await supabase
+        .from('catalog')
+        .insert([{
+          title,
+          subtitle: subtitle || '',
+          type: type || 'other',
+          price: price || 9.99
+        }])
+        .select();
+
+      if (error) throw error;
+      if (data && data.length > 0) {
+        return res.status(201).json(data[0]);
+      }
     } catch (err) {
-      console.error('Error saving to MongoDB:', err);
+      console.error('Error saving to Supabase:', err.message);
       // Fallback
     }
   }
@@ -175,15 +160,17 @@ app.post('/api/catalog', async (req, res) => {
 app.delete('/api/catalog/:id', async (req, res) => {
   const { id } = req.params;
 
-  if (isMongoConnected) {
+  if (isSupabaseConnected) {
     try {
-      const deletedBook = await BookModel.findByIdAndDelete(id);
-      if (!deletedBook) {
-        return res.status(404).json({ error: 'Book not found' });
-      }
+      const { error } = await supabase
+        .from('catalog')
+        .delete()
+        .eq('id', id);
+
+      if (error) throw error;
       return res.json({ success: true });
     } catch (err) {
-      console.error('Error deleting from MongoDB:', err);
+      console.error('Error deleting from Supabase:', err.message);
       // Fallback
     }
   }
@@ -330,14 +317,35 @@ Start writing now:`;
 
     autopilotThoughts.unshift(`[${timestamp}] 💰 Printing Cost Calculations: pages=120. Maximizing net margin for price $${recommendedPrice}...`);
     
-    if (isMongoConnected) {
-      await BookModel.create({
-        title: parsedTitle,
-        subtitle: parsedSubtitle,
-        type: bookType,
-        price: recommendedPrice
-      });
-      autopilotThoughts.unshift(`[${timestamp}] 📦 Cloud Save: Stored "${parsedTitle.slice(0, 30)}..." to MongoDB Atlas!`);
+    if (isSupabaseConnected) {
+      try {
+        const { error } = await supabase
+          .from('catalog')
+          .insert([{
+            title: parsedTitle,
+            subtitle: parsedSubtitle,
+            type: bookType,
+            price: recommendedPrice
+          }]);
+        
+        if (error) throw error;
+        autopilotThoughts.unshift(`[${timestamp}] 📦 Cloud Save: Stored "${parsedTitle.slice(0, 30)}..." to Supabase!`);
+      } catch (err) {
+        console.error('Error saving to Supabase in Autopilot:', err.message);
+        autopilotThoughts.unshift(`[${timestamp}] ⚠️ Cloud Save Failed. Storing to local fallback...`);
+        // Fallback
+        const catalog = readDb();
+        catalog.unshift({
+          id: Date.now().toString(),
+          title: parsedTitle,
+          subtitle: parsedSubtitle,
+          type: bookType,
+          price: recommendedPrice,
+          date: new Date().toLocaleDateString()
+        });
+        writeDb(catalog);
+        autopilotThoughts.unshift(`[${timestamp}] 📦 Database Save: Stored "${parsedTitle.slice(0, 30)}..." to Local JSON Fallback!`);
+      }
     } else {
       const catalog = readDb();
       catalog.unshift({