Class Storage

packages/web-backend/src/Storage/index.ts:745–949

};

export class Storage extends Effect.Service<Storage>()("Storage", {
	effect: Effect.gen(function* () {
		const repo = yield* StorageRepo;
		const s3Buckets = yield* S3Buckets;

		const getS3WritableAccessForUser = Effect.fn(
			"Storage.getS3WritableAccessForUser",
		)(function* (
			userId: User.UserId,
			organizationId?: Organisation.OrganisationId,
		) {
			if (organizationId) {
				const organizationBucket = yield* mapStorageError(
					s3Buckets.getBucketAccessForOrganization(organizationId),
				);

				if (Option.isSome(organizationBucket)) {
					const [s3, customBucket] = organizationBucket.value;
					return {
						access: makeS3Access(s3),
						bucketId: Option.map(customBucket, (bucket) => bucket.id),
						storageIntegrationId: Option.none(),
					};
				}
			}

			const [s3, customBucket] = yield* mapStorageError(
				s3Buckets.getBucketAccessForUser(userId),
			);
			return {
				access: makeS3Access(s3),
				bucketId: Option.map(customBucket, (bucket) => bucket.id),
				storageIntegrationId: Option.none(),
			};
		});

		const getDriveAccess = Effect.fn("Storage.getDriveAccess")(function* (
			integrationId: StorageDomain.StorageIntegrationId,
		) {
			const integration = yield* mapStorageError(
				repo.getIntegrationById(integrationId),
			).pipe(
				Effect.flatMap(
					Option.match({
						onNone: () =>
							Effect.fail(
								new StorageDomain.StorageError({
									cause: new Error("Storage integration not found"),
								}),
							),
						onSome: Effect.succeed,
					}),
				),
			);
			const config = yield* mapStorageError(
				repo.getGoogleDriveConfig(integration),
			);
			return makeGoogleDriveAccess({ repo, integration, config });