Merge pull request #52 from supabase-community/fix-cdn

fix: remove filtering by a event name

README.md

@@ -4,8 +4,12 @@ _Launch in minutes. Scale to millions._
 
 This repo includes a template of starting Supabase stack on AWS via CloudFormation/CDK. This template use managed services such as Amazon ECS and Amazon Aurora etc...
 
+## Architecture
+
 ![architecture-diagram](docs/images/architecture-diagram.png)
 
+![smart-cdn-caching](docs/images/smart-cdn-caching.png)
+
 ## Deploy via CloudFormation template
 
 | Region | View | Stable | Latest |

src/supabase-cdn/cache-manager/api.ts

@@ -7,10 +7,12 @@ import { handle } from 'hono/aws-lambda';
 import { bearerAuth } from 'hono/bearer-auth';
 import { WebhookEvent } from './types';
 
+/** AWS region */
 const region = process.env.AWS_REGION;
+/** SQS queue URL */
 const queueUrl = process.env.QUEUE_URL;
+/** Bearer token */
 const token = process.env.API_KEY!;
-const eventList = process.env.EVENT_LIST!.split(',');
 
 const logger = new Logger();
 const tracer = new Tracer();
@@ -26,7 +28,8 @@ const enqueue = async (message: object) => {
     QueueUrl: queueUrl,
     MessageBody: JSON.stringify(message),
   });
-  await sqs.send(cmd);
+  const output = await sqs.send(cmd);
+  return output;
 };
 
 /** Hono app */
@@ -37,9 +40,7 @@ app.post('/', bearerAuth({ token }), async (c) => {
   const body: WebhookEvent = await c.req.json();
   console.log(JSON.stringify(body));
 
-  if (eventList.includes(body.event.type)) {
-    await enqueue(body);
-  }
+  await enqueue(body);
   return c.text('Accepted', 202);
 });
 

src/supabase-cdn/index.ts

@@ -169,11 +169,6 @@ class CacheManager extends Construct {
       environment: {
         QUEUE_URL: queue.queueUrl,
         API_KEY: this.apiKey.secretValue.toString(),
-        EVENT_LIST: [
-          'ObjectRemoved:Delete',
-          'ObjectRemoved:Move',
-          'ObjectUpdated:Metadata',
-        ].join(','),
       },
       tracing: lambda.Tracing.ACTIVE,
     });