feat: separate current project to libs and node fastify

Author: tranhoangvuit

packages/stripe-sync-engine-fastify/package-lock.json

@@ -0,0 +1,40 @@
+{
+  "name": "stripe-sync-engine-fastify",
+  "version": "0.0.1",
+  "description": "Stripe sync engine node fastify. Sync your Stripe account to your Postgres database",
+  "main": "index.js",
+  "author": "Supabase",
+  "license": "MIT",
+  "engines": {
+    "node": ">= 20.0.0"
+  },
+  "dependencies": {
+    "@stripe-sync-engine/lib": "workspace:^",
+    "@fastify/autoload": "^5.8.0",
+    "@fastify/swagger": "^8.14.0",
+    "@fastify/swagger-ui": "^2.1.0",
+    "fastify": "^4.25.2",
+    "dotenv": "^16.3.1",
+    "p-limit": "^3.1.0",
+    "pg": "^8.11.3",
+    "pino": "^8.17.2",
+    "stripe": "^14.21.0",
+    "yesql": "^7.0.0"
+  },
+  "devDependencies": {
+    "@types/jest": "^29.5.11",
+    "@types/node": "^20.11.5",
+    "@types/pg": "^8.10.9",
+    "@types/yesql": "^4.1.4",
+    "@typescript-eslint/eslint-plugin": "^6.19.0",
+    "@typescript-eslint/parser": "^6.19.0",
+    "eslint": "^8.56.0",
+    "eslint-config-prettier": "^9.1.0",
+    "eslint-plugin-prettier": "^5.1.3",
+    "jest": "^29.7.0",
+    "prettier": "^3.2.4",
+    "ts-jest": "^29.1.1",
+    "tsx": "^4.7.0",
+    "typescript": "^5.3.3"
+  }
+}

packages/stripe-sync-engine-fastify/package.json

@@ -0,0 +1,55 @@
+import { FastifyInstance } from 'fastify'
+import { syncBackfill, SyncBackfillParams, syncSingleEntity } from '@stripe-sync-engine/lib'
+import { verifyApiKey } from '../utils/verifyApiKey'
+
+import Stripe from 'stripe'
+
+// eslint-disable-next-line @typescript-eslint/explicit-module-boundary-types
+export default async function routes(fastify: FastifyInstance) {
+  fastify.post('/sync', {
+    preHandler: [verifyApiKey],
+    handler: async (request, reply) => {
+      const { created, object, backfillRelatedEntities } =
+        (request.body as {
+          created?: Stripe.RangeQueryParam
+          object?: string
+          backfillRelatedEntities?: boolean
+        }) ?? {}
+
+      const params = { created, object, backfillRelatedEntities } as SyncBackfillParams
+      const result = await syncBackfill(params)
+      return reply.send({
+        statusCode: 200,
+        ts: Date.now(),
+        ...result,
+      })
+    },
+  })
+
+  fastify.post<{
+    Params: {
+      stripeId: string
+    }
+  }>('/sync/single/:stripeId', {
+    preHandler: [verifyApiKey],
+    schema: {
+      params: {
+        type: 'object',
+        properties: {
+          stripeId: { type: 'string' },
+        },
+      },
+    },
+    handler: async (request, reply) => {
+      const { stripeId } = request.params
+
+      const result = await syncSingleEntity(stripeId)
+
+      return reply.send({
+        statusCode: 200,
+        ts: Date.now(),
+        data: result,
+      })
+    },
+  })
+}

packages/stripe-sync-engine-fastify/src/routes/sync.ts

@@ -0,0 +1,59 @@
+import dotenv from 'dotenv'
+
+type configType = {
+  /** Postgres database URL including authentication */
+  DATABASE_URL: string
+
+  NODE_ENV: string
+
+  /** Database schema name. */
+  SCHEMA: string
+
+  /** Stripe secret key used to authenticate requests to the Stripe API. Defaults to empty string */
+  STRIPE_SECRET_KEY: string
+
+  /** Webhook secret from Stripe to verify the signature of webhook events. */
+
+  STRIPE_WEBHOOK_SECRET: string
+
+  /** API_KEY is used to authenticate requests to the sync-engine. */
+  API_KEY: string
+
+  /** Stripe API version for the webhooks, defaults to 2020-08-27 */
+  STRIPE_API_VERSION: string
+
+  /** Port number the API is running on, defaults to 8080 */
+  PORT: number
+
+  /**
+
+   * Stripe limits related lists like invoice items in an invoice to 10 by default.
+
+   * By enabling this, sync-engine automatically fetches the remaining elements before saving
+   * */
+  AUTO_EXPAND_LISTS: boolean
+}
+
+function getConfigFromEnv(key: string, defaultValue?: string): string {
+  const value = process.env[key]
+  if (!value && defaultValue === undefined) {
+    throw new Error(`${key} is undefined`)
+  }
+  return value || defaultValue!
+}
+
+export function getConfig(): configType {
+  dotenv.config()
+
+  return {
+    DATABASE_URL: getConfigFromEnv('DATABASE_URL'),
+    SCHEMA: getConfigFromEnv('SCHEMA', 'stripe'),
+    NODE_ENV: getConfigFromEnv('NODE_ENV'),
+    STRIPE_SECRET_KEY: getConfigFromEnv('STRIPE_SECRET_KEY', ''),
+    STRIPE_WEBHOOK_SECRET: getConfigFromEnv('STRIPE_WEBHOOK_SECRET'),
+    API_KEY: getConfigFromEnv('API_KEY', 'false'),
+    STRIPE_API_VERSION: getConfigFromEnv('STRIPE_API_VERSION', '2020-08-27'),
+    PORT: Number(getConfigFromEnv('PORT', '8080')),
+    AUTO_EXPAND_LISTS: getConfigFromEnv('AUTO_EXPAND_LISTS', 'false') === 'true',
+  }
+}

packages/stripe-sync-engine-fastify/src/utils/config.ts

@@ -0,0 +1,19 @@
+import { FastifyReply, FastifyRequest, HookHandlerDoneFunction } from 'fastify'
+import { getConfig } from './config'
+
+const config = getConfig()
+
+export const verifyApiKey = (
+  request: FastifyRequest,
+  reply: FastifyReply,
+  done: HookHandlerDoneFunction
+): unknown => {
+  if (!request.headers || !request.headers.authorization) {
+    return reply.code(401).send('Unauthorized')
+  }
+  const { authorization } = request.headers
+  if (authorization !== config.API_KEY) {
+    return reply.code(401).send('Unauthorized')
+  }
+  done()
+}