fix: github queue cannot process image

__tests__/queue/base.test.ts

@@ -17,7 +17,7 @@ describe('queue consumer', () => {
     consumer.addWorker('test', wk);
     consumer.push(...batch.messages);
     expect(wk.queue.length).toBe(100);
-    await consumer.runAndWait();
+    await consumer.runAndAwait();
   });
 });
 

src/api/context.ts

@@ -6,8 +6,8 @@ export type ContinuationContext = {
   ctx: Context<THonoEnvironment>;
 };
 
-const { store, get } = asyncLocalStorage<ContinuationContext>();
+const { middleware, get } = asyncLocalStorage<ContinuationContext>();
 
-export { store };
+export { middleware };
 
 export const context = () => get('ctx');

src/api/middleware/async-local-storage.ts

@@ -8,7 +8,7 @@ type Callback<T, E extends Env> = (c: Context<E>) => T;
 export const asyncLocalStorage = <T>() => {
   const localStorage = new AsyncLocalStorage<T>();
   return {
-    store: <E extends Env = Env>(callback: Callback<T, E>) =>
+    middleware: <E extends Env = Env>(callback: Callback<T, E>) =>
       createMiddleware(async (c, next) => {
         const obj = callback(c);
         return localStorage.run(obj, next);

src/api/middleware/index.ts

@@ -1,6 +1,6 @@
 import { StatusCode } from 'hono/utils/http-status';
 
-import { store } from '../context';
+import { middleware } from '../context';
 
 import * as GitHub from './github';
 
@@ -37,7 +37,7 @@ export const enhanceContext = (hono: THono) => {
   });
 
   hono.use(
-    store<THonoEnvironment>((ctx) => ({
+    middleware<THonoEnvironment>((ctx) => ({
       ctx,
     })),
   );

src/github/dingtalk.ts

@@ -35,7 +35,11 @@ function dingSecurityInterception(text: string) {
 export const createImageProxy = () => {
   return {
     handleImageUrl: (url: string) => {
-      return context().getProxiedUrl(url);
+      try {
+        return context().getProxiedUrl(url);
+      } catch (error) {
+        return url;
+      }
     },
   };
 };

src/queue/index.ts

@@ -30,7 +30,7 @@ export class QueueConsumer<T extends { type: string }> {
     }
   }
 
-  async runAndWait() {
+  async runAndAwait() {
     const promises = [] as Promise<void>[];
     for (const w of this.workerMap.values()) {
       promises.push(w.run());

src/runtime/cfworker/index.ts

@@ -25,10 +25,9 @@ export default {
     const consumer = createConsumer();
 
     consumer.push(...batch.messages);
-
     ctx.waitUntil(
       consumer
-        .runAndWait()
+        .runAndAwait()
         .then((res) => {
           logger.info('queue done', res);
         })