move to adapter factory

examples/common_nestjs_remix/apps/api/.env.example

@@ -1,7 +1,7 @@
 # GENERAL
 CORS_ORIGIN="https://app.guidebook.localhost"
 EMAIL_ADAPTER="mailhog"
-
+FILE_ADAPTER="local"
 # DATABASE
 DATABASE_URL="postgres://postgres:guidebook@localhost:5432/guidebook"
 
@@ -17,11 +17,10 @@ SMTP_USER=
 SMTP_PASSWORD=
 
 # AWS
-AWS_ENDPOINT=https://s3.eu-central-1.amazonaws.com
 AWS_REGION=eu-central-1
 AWS_ACCESS_KEY_ID=
 AWS_SECRET_ACCESS_KEY=
-AWS_BUCKET_NAME=test-bucket\
+AWS_BUCKET_NAME=test-bucket
 
 
 # LOCAL UPLOADS

examples/common_nestjs_remix/apps/api/src/app.module.ts

@@ -15,7 +15,7 @@ import { EmailModule } from "./common/emails/emails.module";
 import { TestConfigModule } from "./test-config/test-config.module";
 import { StagingGuard } from "./common/guards/staging.guard";
 import { HealthModule } from "./health/health.module";
-import { FilesModule } from "./files/files.module";
+import { FilesModule } from "./common/files/files.module";
 import localFile from "./common/configuration/local_file";
 
 @Module({

examples/common_nestjs_remix/apps/api/src/common/configuration/aws.ts

@@ -7,7 +7,6 @@ const schema = Type.Object({
  AWS_ACCESS_KEY_ID: Type.String(),
  AWS_SECRET_ACCESS_KEY: Type.String(),
  BUCKET_NAME: Type.String(),
- AWS_ENDPOINT: Type.String(),
 });
 
 type AWSConfigSchema = Static<typeof schema>;
@@ -20,7 +19,6 @@ export default registerAs("aws", (): AWSConfigSchema => {
  AWS_ACCESS_KEY_ID: process.env.AWS_ACCESS_KEY_ID,
  AWS_SECRET_ACCESS_KEY: process.env.AWS_SECRET_ACCESS_KEY,
  BUCKET_NAME: process.env.AWS_BUCKET_NAME,
- AWS_ENDPOINT: process.env.AWS_ENDPOINT,
  };
 
  return validateAwsConfig(values);

examples/common_nestjs_remix/apps/api/src/common/files/factory/file-adapters.factory.ts

@@ -0,0 +1,32 @@
+import { Injectable } from "@nestjs/common";
+import { S3FileAdapter } from "../adapters/s3.adapter";
+import { match, P } from "ts-pattern";
+import { ConfigService } from "@nestjs/config";
+import { FilesAdapter } from "../adapters/files.adapter";
+import { LocalFilesAdapter } from "../adapters";
+import { ModuleRef } from "@nestjs/core";
+
+type AdapterType = "local" | "s3";
+
+@Injectable()
+export class FileAdapterFactory {
+ constructor(
+ private moduleRef: ModuleRef,
+ private configService: ConfigService,
+ ) {}
+
+ async createAdapter(): Promise<FilesAdapter> {
+ const adapterType = this.configService.get<AdapterType>("FILE_ADAPTER");
+ const adapter = match(adapterType)
+ .with("local", () => LocalFilesAdapter)
+ .with("s3", () => S3FileAdapter)
+ .with(P.nullish, () => {
+ throw new Error("FILE_ADAPTER is not defined in configuration");
+ })
+ .otherwise((type) => {
+ throw new Error(`Unknown file adapter type: ${type}`);
+ });
+
+ return await this.moduleRef.create<FilesAdapter>(adapter);
+ }
+}

examples/common_nestjs_remix/apps/api/src/common/files/file.service.ts

@@ -0,0 +1,22 @@
+import { Injectable } from "@nestjs/common";
+import { FilesAdapter } from "./adapters/files.adapter";
+
+@Injectable()
+export class FileService {
+ constructor(private fileAdapter: FilesAdapter) {}
+
+ async uploadFile(
+ directory: string,
+ file: Express.Multer.File,
+ ): Promise<{ path: string }> {
+ return await this.fileAdapter.uploadFile(directory, file);
+ }
+
+ async deleteFile(key: string): Promise<void> {
+ return await this.fileAdapter.deleteFile(key);
+ }
+
+ async getFileUrl(key: string): Promise<{ url: string }> {
+ return await this.fileAdapter.getFileUrl(key);
+ }
+}

examples/common_nestjs_remix/apps/api/src/common/files/files.module.ts

@@ -0,0 +1,20 @@
+import { Module } from "@nestjs/common";
+import { FileService } from "./file.service";
+import { ConfigModule } from "@nestjs/config";
+import { FileAdapterFactory } from "./factory/file-adapters.factory";
+import { FilesAdapter } from "./adapters/files.adapter";
+
+@Module({
+ imports: [ConfigModule],
+ providers: [
+ FileService,
+ FileAdapterFactory,
+ {
+ provide: FilesAdapter,
+ useFactory: (factory: FileAdapterFactory) => factory.createAdapter(),
+ inject: [FileAdapterFactory],
+ },
+ ],
+ exports: [FileService],
+})
+export class FilesModule {}