feat: tus v1 stable

package.json

@@ -34,9 +34,9 @@
     "@fastify/swagger": "^8.3.1",
     "@fastify/swagger-ui": "^1.7.0",
     "@isaacs/ttlcache": "^1.4.1",
-    "@tus/file-store": "^1.0.0-beta.1",
-    "@tus/s3-store": "https://gitpkg.now.sh/supabase/tus-node-server/packages/s3-store/dist?build",
-    "@tus/server": "https://gitpkg.now.sh/supabase/tus-node-server/packages/server/dist?build",
+    "@tus/file-store": "https://gitpkg.now.sh/supabase/tus-node-server/packages/file-store/dist?supabase/build-v2",
+    "@tus/s3-store": "https://gitpkg.now.sh/supabase/tus-node-server/packages/s3-store/dist?supabase/build-v2",
+    "@tus/server": "https://gitpkg.now.sh/supabase/tus-node-server/packages/server/dist?supabase/build-v2",
     "agentkeepalive": "^4.2.1",
     "async-retry": "^1.3.3",
     "axios": "^0.27.2",
@@ -46,7 +46,6 @@
     "crypto-js": "^4.2.0",
     "dotenv": "^16.0.0",
     "fastify": "^4.8.1",
-    "fastify-cors": "^6.1.0",
     "fastify-metrics": "^10.2.0",
     "fastify-plugin": "^4.0.0",
     "fs-extra": "^10.0.1",

src/database/migrate.ts

@@ -1,30 +1,31 @@
 import { Client, ClientConfig } from 'pg'
 import { migrate } from 'postgres-migrations'
 import { getConfig } from '../config'
+import { logger } from '../monitoring'
 
 const { multitenantDatabaseUrl, databaseSSLRootCert } = getConfig()
 
 /**
  * Runs tenant migrations
  */
 export async function runMigrations(): Promise<void> {
-  console.log('running migrations')
+  logger.info('running migrations')
   let ssl: ClientConfig['ssl'] | undefined = undefined
 
   if (databaseSSLRootCert) {
     ssl = { ca: databaseSSLRootCert }
   }
   await connectAndMigrate(process.env.DATABASE_URL, './migrations/tenant', ssl)
-  console.log('finished migrations')
+  logger.info('finished migrations')
 }
 
 /**
  * Runs multi-tenant migrations
  */
 export async function runMultitenantMigrations(): Promise<void> {
-  console.log('running multitenant migrations')
+  logger.info('running multitenant migrations')
   await connectAndMigrate(multitenantDatabaseUrl, './migrations/multitenant')
-  console.log('finished multitenant migrations')
+  logger.info('finished multitenant migrations')
 }
 
 /**

src/database/pubsub.ts

@@ -0,0 +1,7 @@
+import { PostgresPubSub } from '../pubsub'
+import { getConfig } from '../config'
+
+const { isMultitenant, databaseURL, multitenantDatabaseUrl } = getConfig()
+
+const connectionString = isMultitenant ? (multitenantDatabaseUrl as string) : databaseURL
+export const PubSub = new PostgresPubSub(connectionString)

src/database/tenant.ts

@@ -1,10 +1,10 @@
-import createSubscriber from 'pg-listen'
 import { getConfig } from '../config'
 import { decrypt, verifyJWT } from '../auth'
 import { runMigrationsOnTenant } from './migrate'
 import { knex } from './multitenant-db'
 import { StorageBackendError } from '../storage'
 import { JwtPayload } from 'jsonwebtoken'
+import { PubSubAdapter } from '../pubsub'
 
 interface TenantConfig {
   anonKey: string
@@ -26,7 +26,7 @@ export interface Features {
   }
 }
 
-const { multitenantDatabaseUrl, isMultitenant, serviceKey, jwtSecret } = getConfig()
+const { isMultitenant, serviceKey, jwtSecret } = getConfig()
 
 const tenantConfigCache = new Map<string, TenantConfig>()
 
@@ -197,19 +197,10 @@ const TENANTS_UPDATE_CHANNEL = 'tenants_update'
 /**
  * Keeps the in memory config cache up to date
  */
-export async function listenForTenantUpdate(): Promise<void> {
-  const subscriber = createSubscriber({ connectionString: multitenantDatabaseUrl })
-
-  subscriber.notifications.on(TENANTS_UPDATE_CHANNEL, (tenantId) => {
+export async function listenForTenantUpdate(pubSub: PubSubAdapter): Promise<void> {
+  await pubSub.subscribe(TENANTS_UPDATE_CHANNEL, (tenantId) => {
     tenantConfigCache.delete(tenantId)
   })
-
-  subscriber.events.on('error', (error) => {
-    console.error('Postgres notification subscription error:', error)
-  })
-
-  await subscriber.connect()
-  await subscriber.listenTo(TENANTS_UPDATE_CHANNEL)
 }
 
 async function cacheTenantConfigAndRunMigrations(

src/http/routes/tus/file-store.ts

@@ -3,17 +3,11 @@ import { Upload } from '@tus/server'
 import fsExtra from 'fs-extra'
 import path from 'path'
 import { FileBackend } from '../../../storage/backend'
-
-type Store = {
-  get(key: string): Upload | undefined
-  set(key: string, value: Upload): void
-  delete(key: string): void
-  all: Record<string, Upload>
-}
+import { Configstore } from '@tus/file-store/configstores'
 
 type FileStoreOptions = {
   directory: string
-  configstore?: Store
+  configstore?: Configstore
   expirationPeriodInMilliseconds?: number
 }
 
@@ -33,7 +27,7 @@ export class FileStore extends TusFileStore {
       cacheControl: file.metadata?.cacheControl || '',
       contentType: file.metadata?.contentType || '',
     })
-    this.configstore.set(file.id, file)
+    await this.configstore.set(file.id, file)
     return file
   }
 }