Class StorageRepo

packages/web-backend/src/Storage/StorageRepo.ts:72–500

};

export class StorageRepo extends Effect.Service<StorageRepo>()("StorageRepo", {
	effect: Effect.gen(function* () {
		const db = yield* Database;

		const decodeGoogleDriveAccessTokenCache = Effect.fn(
			"StorageRepo.decodeGoogleDriveAccessTokenCache",
		)(
			(input: {
				googleDriveAccessToken: string | null;
				googleDriveAccessTokenExpiresAt: Date | null;
			}) =>
				Effect.gen(function* () {
					if (
						!input.googleDriveAccessToken ||
						!input.googleDriveAccessTokenExpiresAt
					) {
						return Option.none<GoogleDriveAccessTokenCache>();
					}

					const accessToken = yield* Effect.tryPromise({
						try: () => decrypt(input.googleDriveAccessToken as string),
						catch: (cause) => new Storage.StorageError({ cause }),
					});

					return Option.some({
						accessToken,
						expiresAt: input.googleDriveAccessTokenExpiresAt,
					});
				}),
		);

		const getActiveIntegrationForUser = Effect.fn(
			"StorageRepo.getActiveIntegrationForUser",
		)((userId: User.UserId) =>
			Effect.gen(function* () {
				const [integration] = yield* db.use((db) =>
					db
						.select()
						.from(Db.storageIntegrations)
						.where(
							Dz.and(
								Dz.eq(Db.storageIntegrations.ownerId, userId),
								Dz.isNull(Db.storageIntegrations.organizationId),
								Dz.eq(Db.storageIntegrations.active, true),
								Dz.eq(Db.storageIntegrations.status, "active"),
							),
						),
				);

				return Option.fromNullable(integration);
			}),
		);

		const getActiveIntegrationForOrganization = Effect.fn(
			"StorageRepo.getActiveIntegrationForOrganization",
		)((organizationId: Organisation.OrganisationId) =>
			Effect.gen(function* () {
				const [integration] = yield* db.use((db) =>