Update apps/aura_measure.js

apps/aura_measure.js

@@ -84,6 +84,17 @@ router.post('/analyze', async (req, res) => {
             return res.status(400).json({ success: false, error: 'Missing media or device_id.' });
         }
 
+        // ── Step 1: Upsert profile FIRST (fast DB write, gives us the ID) ────
+        const { data: profile, error: profileError } = await supabase
+            .from('aura_profiles')
+            .upsert({ device_id, username, avatar }, { onConflict: 'device_id' })
+            .select('id')
+            .single();
+
+        if (profileError) throw profileError;
+        console.log('[Analyze] Profile ID:', profile.id);
+
+        // ── Step 2: Build AI prompt ───────────────────────────────────────────
         let systemPrompt = AURA_PROMPT_STANDALONE;
         let promptText = 'Analyze this image and calculate my Aura. Return JSON.';
         let imagesToProcess = [media_base64];
@@ -94,6 +105,7 @@ router.post('/analyze', async (req, res) => {
             imagesToProcess = [reference_data.image_base64, media_base64];
         }
 
+        // ── Step 3: Run AI ────────────────────────────────────────────────────
         console.log('[Analyze] Running AI...');
         const aiResult = await generateCompletion({
             model: 'qwen-vl-max',
@@ -118,14 +130,14 @@ router.post('/analyze', async (req, res) => {
 
         console.log('[Analyze] AI done. Score:', parsedData.score);
 
-        // Store temp entry immediately
+        // ── Step 4: Store temp scan entry ─────────────────────────────────────
         const tempId = crypto.randomUUID();
         const imageBuffer = Buffer.from(media_base64, 'base64');
 
         tempScans.set(tempId, {
             filepath: path.join(TEMP_DIR, `${tempId}.jpg`),
             timestamp: Date.now(),
-            user_id: null,
+            user_id: profile.id,   // We have this now
             session_id: null,
             score: parsedData.score,
             analysis: parsedData.analysis_markdown,
@@ -134,28 +146,22 @@ router.post('/analyze', async (req, res) => {
             ready: false,
         });
 
-        // Respond immediately
+        // ── Step 5: Respond immediately with profile_id included ──────────────
         res.json({
             success: true,
             score: parsedData.score,
             analysis: parsedData.analysis_markdown,
-            temp_scan_id: tempId
+            temp_scan_id: tempId,
+            profile_id: profile.id,   // ← send this so client can store it
         });
 
         console.log('[Analyze] Response sent. Running async DB writes...');
 
-        // Async DB writes
+        // ── Step 6: Remaining DB writes async ─────────────────────────────────
         (async () => {
             try {
                 await fs.writeFile(path.join(TEMP_DIR, `${tempId}.jpg`), imageBuffer);
 
-                const { data: profile, error: profileError } = await supabase
-                    .from('aura_profiles')
-                    .upsert({ device_id, username, avatar }, { onConflict: 'device_id' })
-                    .select('id')
-                    .single();
-                if (profileError) throw profileError;
-
                 let { data: session } = await supabase
                     .from('aura_sessions')
                     .select('id')
@@ -182,7 +188,6 @@ router.post('/analyze', async (req, res) => {
                 });
                 if (rpcError) throw rpcError;
 
-                // Fetch updated profile so publish has accurate data
                 const { data: updatedProfile } = await supabase
                     .from('aura_profiles')
                     .select('cumulative_aura, current_grade')
@@ -193,7 +198,6 @@ router.post('/analyze', async (req, res) => {
                 if (existing) {
                     tempScans.set(tempId, {
                         ...existing,
-                        user_id: profile.id,
                         session_id: session.id,
                         ready: true,
                         cumulative_aura: updatedProfile?.cumulative_aura ?? 0,