PipedreamHQ · dylburger · Jan 24, 2025 · Jan 13, 2025 · Jan 13, 2025 · Jan 24, 2025
diff --git a/components/clear_books/clear_books.app.mjs b/components/clear_books/clear_books.app.mjs
@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};
diff --git a/components/dixa/dixa.app.mjs b/components/dixa/dixa.app.mjs
@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};
diff --git a/components/linkup/linkup.app.mjs b/components/linkup/linkup.app.mjs
@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};
diff --git a/components/mailboxlayer/mailboxlayer.app.mjs b/components/mailboxlayer/mailboxlayer.app.mjs
@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};
diff --git a/components/nextdoor/nextdoor.app.mjs b/components/nextdoor/nextdoor.app.mjs
@@ -8,4 +8,4 @@ export default {
       console.log(Object.keys(this.$auth));
     },
   },
-};
+};
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/pnpm-workspace.yaml b/pnpm-workspace.yaml
@@ -5,3 +5,4 @@ packages:
   - 'platform/**'
   - 'packages/**'
   - 'docs-v2/**'
+  - 'scripts/**'
diff --git a/scripts/.gitignore b/scripts/.gitignore
@@ -1 +1,2 @@
 dist
+.env*
diff --git a/scripts/package.json b/scripts/package.json
@@ -0,0 +1,17 @@
+{
+  "name": "scripts",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "@supabase/supabase-js": "^2.45.6",
+    "dotenv": "^16.4.7",
+    "glob": "^11.0.0"
+  }
+}
diff --git a/scripts/upload-app-files-to-supabase.mjs b/scripts/upload-app-files-to-supabase.mjs
@@ -0,0 +1,61 @@
+import { createClient } from '@supabase/supabase-js'
+import { readFile } from 'fs/promises'
+import { glob } from 'glob'
+import path from 'path'
+import 'dotenv/config'
+
+if (!process.env.SUPABASE_URL || !process.env.SUPABASE_KEY) {
+  throw new Error('Missing required environment variables SUPABASE_URL and/or SUPABASE_KEY')
+}
+
+// Configure Supabase client
+const supabase = createClient(
+  process.env.SUPABASE_URL,
+  process.env.SUPABASE_KEY
+)
+
+async function findAndUploadFiles() {
+  try {
+    // Find all .app.mjs files recursively
+    const files = await glob('../components/**/*.app.mjs', {
+      // No need to recurse into the standard subdirs, since app files are always at 
+      // the root of the components/${app} directory
+      ignore: ['node_modules/**', 'actions/**', 'common/**', 'sources/**'],
+      absolute: true
+    })
+
+    console.log(`Found ${files.length} .app.mjs files`)
+
+    for (const filePath of files) {
+      try {
+        const content = await readFile(filePath, 'utf8')
+
+        const filename = path.basename(filePath)
+        const app = filename.replace('.app.mjs', '')
+
+        const { data, error } = await supabase
+          .from('registry_app_files')
+          .insert({
+            app: app,
+            app_file: content
+          })
+
+        if (error) {
+          console.error(`Error uploading ${filename}:`, error)
+          continue
+        }
+
+        console.log(`Successfully uploaded ${filename}`)
+      } catch (err) {
+        console.error(`Error processing ${filePath}:`, err)
+      }
+    }
-    for (const filePath of files) {
-      try {
-        const content = await readFile(filePath, 'utf8')
-
-        const filename = path.basename(filePath)
-        const app = filename.replace('.app.mjs', '')
-
-        const { data, error } = await supabase
-          .from('registry_app_files')
-          .insert({
-            app: app,
-            app_file: content
-          })
-
-        if (error) {
-          console.error(`Error uploading ${filename}:`, error)
-          continue
-        }
-
-        console.log(`Successfully uploaded ${filename}`)
-      } catch (err) {
-        console.error(`Error processing ${filePath}:`, err)
-      }
-    }
+    for (const filePath of files) {
+      try {
+        const content = await readFile(filePath, 'utf8')
+        // Validate content
+        if (!content.trim()) {
+          throw new Error('Empty file')
+        }
+
+        const filename = path.basename(filePath)
+        const app = filename.replace('.app.mjs', '')
+
+        const { data, error } = await supabase
+          .from('registry_app_files')
+          .upsert({
+            app: app,
+            app_file: content
+          }, {
+            onConflict: 'app',
+            ignoreDuplicates: false
+          })
+
+        if (error) {
+          console.error(`Error uploading ${filename}:`, error)
+          continue
+        }
+
+        console.log(`Successfully uploaded ${filename}`)
+      } catch (err) {
+        console.error(`Error processing ${filePath}:`, err)
+      }
+    }
-    for (const filePath of files) {
-      try {
-        const content = await readFile(filePath, 'utf8')
-
-        const filename = path.basename(filePath)
-        const app = filename.replace('.app.mjs', '')
-
-        const { data, error } = await supabase
-          .from('registry_app_files')
-          .insert({
-            app: app,
-            app_file: content
-          })
-
-        if (error) {
-          console.error(`Error uploading ${filename}:`, error)
-          continue
-        }
-
-        console.log(`Successfully uploaded ${filename}`)
-      } catch (err) {
-        console.error(`Error processing ${filePath}:`, err)
-      }
-    }
+    for (const filePath of files) {
+      try {
+        const content = await readFile(filePath, 'utf8')
+        // Validate content
+        if (!content.trim()) {
+          throw new Error('Empty file')
+        }
+
+        const filename = path.basename(filePath)
+        const app = filename.replace('.app.mjs', '')
+
+        const { data, error } = await supabase
+          .from('registry_app_files')
+          .upsert({
+            app: app,
+            app_file: content
+          }, {
+            onConflict: 'app',
+            ignoreDuplicates: false
+          })
+
+        if (error) {
+          console.error(`Error uploading ${filename}:`, error)
+          continue
+        }
+
+        console.log(`Successfully uploaded ${filename}`)
+      } catch (err) {
+        console.error(`Error processing ${filePath}:`, err)
+      }
+    }
+  } catch (err) {
+    console.error('Error finding files:', err)
+  }
+}
+
+// Run the script
+findAndUploadFiles()
+  .then(() => console.log('Upload complete'))
+  .catch(err => console.error('Script failed:', err))
-Original file line number
+Diff line change
@@ Expand Up / @@ -8,4 +8,4 @@ export default { @@
           console.log(Object.keys(this.$auth));
         },
       },
-    };
+    };