Merge pull request ubiquity-os-marketplace#23 from ubq-testing/gh-sto…

…rage

chore: add token fallback, add debug log

package.json

@@ -100,4 +100,4 @@
       "@commitlint/config-conventional"
     ]
   }
-}
+}

src/types/env.ts

@@ -92,6 +92,7 @@ export const env = T.Object({
     .Encode((obj) => JSON.stringify(obj)),
   APP_ID: T.String(),
   APP_PRIVATE_KEY: T.String(),
+  TEMP_SAFE_PAT: T.Optional(T.String()),
 });
 
 export type Env = StaticDecode<typeof env>;

src/types/plugin-context-single.ts

@@ -83,17 +83,27 @@ export class PluginContext {
    * This can be used with events from both Telegram and GitHub, this token comes from
    * the worker's environment variables i.e the Storage App.
    */
-  async getTelegramEventOctokit(): Promise<RestOctokitFromApp | null> {
-    let octokit: RestOctokitFromApp | null = null;
+  async getTelegramEventOctokit(): Promise<RestOctokitFromApp | Octokit | null> {
+    let octokit: RestOctokitFromApp | Octokit | null = null;
 
     try {
       await this.getApp().eachInstallation((installation) => {
+        logger.info("Checking installation", { installation: installation.installation.account?.login, storageOwner: this.config.storageOwner });
         if (installation.installation.account?.login.toLowerCase() === this.config.storageOwner.toLowerCase()) {
           octokit = installation.octokit;
         }
       });
     } catch (er) {
-      logger.error("Error initializing octokit in getTelegramEventOctokit", { er });
+      logger.error("Error initializing octokit in getTelegramEventOctokit", { er: String(er) });
+    }
+
+    if (!octokit) {
+      logger.info("Falling back to TEMP_SAFE_PAT for octokit");
+      octokit = new Octokit({ auth: this.env.TEMP_SAFE_PAT });
+    }
+
+    if (!octokit) {
+      throw new Error("Octokit could not be initialized");
     }
 
     return octokit;