decrypt.js

import fs from 'fs';
// import crypto from 'crypto';
import forge from 'node-forge';

const privateKeyPath = 'private_key.pem';
const importFilename = 'input.csv';
const exportFilename = 'export.csv';

// const privateKey = crypto.createPrivateKey({ key: fs.readFileSync(privateKeyPath) });
const privateKey = forge.pki.privateKeyFromPem(fs.readFileSync(privateKeyPath).toString());

console.log('Starting decryption process...');

const decrypt = (encryptedValue) => {
  try {
    return privateKey.decrypt(
      forge.util.decode64(encryptedValue),
      'RSAES-PKCS1-V1_5'
    );
    // return crypto.privateDecrypt(
    //   {
    //     key: privateKey,
    //     padding: crypto.constants.RSA_PKCS1_PADDING,
    //   },
    //   Buffer.from(encryptedValue, 'base64')
    // ).toString();
  } catch (error) {
    console.error(`Decryption error: ${error.message}`);
  }
};

const processFile = async () => {
  try {
    const data = await fs.promises.readFile(importFilename, 'utf8');
    const results = data.split('\n')
      .filter(line => line)
      .map(line => {
        const [email, encryptedValue] = line.split(',');
        const unquotedEmail = email.replace(/"/g, '');
        const decryptedValue = decrypt(encryptedValue);
        return `${unquotedEmail},${decryptedValue}`;
      });
    await fs.promises.writeFile(exportFilename, results.join('\n'));
    console.log('Export completed successfully.');
  } catch (err) {
    console.error(`Error processing file: ${err.message}`);
  }
};

processFile();