fix: resolve public-api transaction timeout, dashboard empty table, and sdk parsing error

Author: yash-pouranik

apps/public-api/src/controllers/data.controller.js

@@ -534,54 +534,37 @@ module.exports.updateSingleData = async (req, res, next) => {
 
     // Only enforce quota for internal databases
     if (!project.resources.db.isExternal) {
-      const session = await mongoose.startSession();
-      session.startTransaction();
-
-      try {
-        // 1. Fetch existing doc securely within transaction
-        const existingDoc = await Model.findOne(queryFilter).session(session).lean();
-        if (!existingDoc) {
-          await session.abortTransaction();
-          session.endSession();
-          return next(new AppError(404, "Document not found."));
-        }
+      // 1. Fetch existing doc securely
+      const existingDoc = await Model.findOne(queryFilter).lean();
+      if (!existingDoc) {
+        return next(new AppError(404, "Document not found."));
+      }
 
-        // 2. Calculate sizes
-        const oldSize = mongoose.mongo.BSON.calculateObjectSize(existingDoc);
-        const simulatedNewDoc = { ...existingDoc, ...sanitizedData };
-        const newSize = mongoose.mongo.BSON.calculateObjectSize(simulatedNewDoc);
-        const sizeDelta = newSize - oldSize;
-
-        // 3. Enforce quota if size is increasing
-        if (sizeDelta > 0) {
-          if ((project.databaseUsed || 0) + sizeDelta > project.databaseLimit) {
-            await session.abortTransaction();
-            session.endSession();
-            return next(new AppError(403, "Storage quota exceeded. Please upgrade your plan."));
-          }
-        }
+      // 2. Calculate sizes
+      const oldSize = mongoose.mongo.BSON.calculateObjectSize(existingDoc);
+      const simulatedNewDoc = { ...existingDoc, ...sanitizedData };
+      const newSize = mongoose.mongo.BSON.calculateObjectSize(simulatedNewDoc);
+      const sizeDelta = newSize - oldSize;
 
-        // 4. Update the document
-        result = await Model.findOneAndUpdate(
-          queryFilter,
-          { $set: sanitizedData },
-          { new: true, runValidators: true, session },
-        ).lean();
-
-        // 5. Apply the delta (positive or negative) atomically
-        await Project.findByIdAndUpdate(
-          project._id,
-          { $inc: { databaseUsed: sizeDelta } },
-          { session }
-        );
-
-        await session.commitTransaction();
-        session.endSession();
-      } catch (error) {
-        await session.abortTransaction();
-        session.endSession();
-        throw error;
+      // 3. Enforce quota if size is increasing
+      if (sizeDelta > 0) {
+        if ((project.databaseUsed || 0) + sizeDelta > project.databaseLimit) {
+          return next(new AppError(403, "Storage quota exceeded. Please upgrade your plan."));
+        }
       }
+
+      // 4. Update the document
+      result = await Model.findOneAndUpdate(
+        queryFilter,
+        { $set: sanitizedData },
+        { new: true, runValidators: true },
+      ).lean();
+
+      // 5. Apply the delta (positive or negative) atomically
+      await Project.findByIdAndUpdate(
+        project._id,
+        { $inc: { databaseUsed: sizeDelta } }
+      );
     } else {
       // External DB Flow (No quota checks)
       result = await Model.findOneAndUpdate(

apps/web-dashboard/src/pages/Database.jsx

@@ -109,11 +109,18 @@ export default function Database() {
          if (f.field && f.value !== '') queryStr += `&${f.field}${f.operator === '=' ? '' : f.operator}=${encodeURIComponent(f.value)}`;
       });
       const res = await api.get(`/api/projects/${projectId}/collections/${activeCollection.name}/data${queryStr}`);
-      // Handle wrapped metadata response
-      if (res.data && res.data.items) {
+      // Handle standard API response format { success, data: { items, total } }
+      if (res.data?.success && res.data?.data?.items) {
+        setData(res.data.data.items);
+        setTotalRecords(res.data.data.total || 0);
+      } 
+      // Handle legacy metadata response { items, total }
+      else if (res.data && res.data.items) {
         setData(res.data.items);
         setTotalRecords(res.data.total || 0);
-      } else {
+      } 
+      // Fallback
+      else {
         setData(res.data || []);
         setTotalRecords(Array.isArray(res.data) ? res.data.length : 0);
       }

sdks/urbackend-sdk/src/errors.ts

@@ -71,7 +71,7 @@ export async function parseApiError(response: Response): Promise<UrBackendError>
           candidate = JSON.stringify(errData.error);
         }
 
-        if (candidate.trim().length > 0 && candidate !== '[]' && candidate !== 'null') {
+        if (candidate && candidate.trim().length > 0 && candidate !== '[]' && candidate !== 'null') {
           message = candidate;
         } else if ('message' in errData) {
           message = typeof errData.message === 'string' ? errData.message : JSON.stringify(errData.message);