Revert "feat: encrypt pii data (#203)" (#204)

This reverts commit ba2e854.

packages/backend/config.ts

@@ -23,7 +23,6 @@ const config = {
     SHORTLOOP_AUTH_KEY: process.env.SHORTLOOP_AUTH_KEY!,
     SVIX_ENDPOINT_SECRET: process.env.SVIX_ENDPOINT_SECRET!,
     svix: new Svix(process.env.SVIX_AUTH_TOKEN!),
-    AES_ENCRYPTION_SECRET: process.env.AES_ENCRYPTION_SECRET!,
 };
 
 export default config;

packages/backend/prisma/client.ts

@@ -1,72 +1,6 @@
 import { PrismaClient, Prisma } from '@prisma/client';
-import config from '../config';
-import gcm from '../helpers/gcmUtil';
 
 const prisma = new PrismaClient();
 
-// Prisma middleware to encrypt and decrypt data on fly
-prisma.$use(async (params, next) => {
-    if (params.model !== 'connections') {
-        return next(params);
-    }
-
-    const isReadOperation = ['findFirst', 'findMany', 'delete'].includes(params.action);
-    const isWriteOperation = ['update', 'upsert'].includes(params.action);
-
-    if (isReadOperation) {
-        return handleReadOperation(params, next);
-    } else if (isWriteOperation) {
-        return handleWriteOperation(params, next);
-    }
-    return next(params);
-});
-
-async function handleReadOperation(
-    params: Prisma.MiddlewareParams,
-    next: (params: Prisma.MiddlewareParams) => Promise<any>
-): Promise<any> {
-    try {
-        const connections = await next(params);
-        if (!connections) return connections;
-        if (Array.isArray(connections)) {
-            connections.forEach((connection) => {
-                connection.tp_customer_id = gcm.decrypt(connection.tp_customer_id, config.AES_ENCRYPTION_SECRET);
-            });
-        } else {
-            connections.tp_customer_id = gcm.decrypt(connections.tp_customer_id, config.AES_ENCRYPTION_SECRET);
-        }
-        return connections;
-    } catch (error: any) {
-        throw new Error(error);
-    }
-}
-
-async function handleWriteOperation(
-    params: Prisma.MiddlewareParams,
-    _: (params: Prisma.MiddlewareParams) => Promise<any>
-): Promise<any> {
-    try {
-        if (Array.isArray(params.args?.data)) {
-            params.args?.data.forEach((connection: any) => {
-                connection.tp_customer_id = gcm.encrypt(connection.tp_customer_id, config.AES_ENCRYPTION_SECRET);
-            });
-        } else {
-            if (params.action === 'upsert') {
-                params.args.create.tp_customer_id = gcm.encrypt(
-                    params.args.create.tp_customer_id,
-                    config.AES_ENCRYPTION_SECRET
-                );
-            } else {
-                params.args.data.tp_customer_id = gcm.encrypt(
-                    params.args.data.tp_customer_id,
-                    config.AES_ENCRYPTION_SECRET
-                );
-            }
-        }
-    } catch (error: any) {
-        throw new Error(error);
-    }
-}
-
 export default prisma;
 export { Prisma };

packages/backend/services/connection.ts

@@ -102,7 +102,8 @@ const connectionService = new ConnectionService({
         const deleted: any = await prisma.connections.delete({
             // TODO: Add environments to connections.
             where: {
-                uniqueThirdPartyPerTenant: {
+                uniqueCustomerPerTenantPerThirdParty: {
+                    tp_customer_id: connection.tp_customer_id,
                     t_id: connection.t_id,
                     tp_id: connection.tp_id,
                 },