@inngest/middleware-encryption - npm Package Compare versions

middleware.d.ts

		@@ -75,3 +75,3 @@ import { InngestMiddleware, type MiddlewareOptions } from "inngest";
		*/
		abstract encrypt(value: unknown): MaybePromise<EncryptionService.PartialEncryptedValue>;
		abstract encrypt(value: unknown): MaybePromise<string>;
		/**
		@@ -78,0 +78,0 @@ * Given an encrypted `string`, decrypts it and returns the decrypted value as

package.json

		{
		"name": "@inngest/middleware-encryption",
		"version": "0.1.8-pr-555.1",
		"version": "0.1.8-pr-555.2",
		"description": "E2E encryption middleware for Inngest.",
		@@ -5,0 +5,0 @@ "main": "./index.js",

stages.js

		@@ -51,6 +51,10 @@ "use strict";
		[middleware_1.EncryptionService.ENCRYPTION_MARKER]: true,
		data: getV0LegacyService().service.encrypt(value).data,
		data: getV0LegacyService().service.encrypt(value),
		};
		}
		return Object.assign({ [middleware_1.EncryptionService.ENCRYPTION_MARKER]: true, [middleware_1.EncryptionService.STRATEGY_MARKER]: service.identifier }, (yield service.encrypt(value)));
		return {
		[middleware_1.EncryptionService.ENCRYPTION_MARKER]: true,
		[middleware_1.EncryptionService.STRATEGY_MARKER]: service.identifier,
		data: yield service.encrypt(value),
		};
		});
		@@ -57,0 +61,0 @@ const decryptValue = (value) => __awaiter(void 0, void 0, void 0, function* () {

strategies/aes.d.ts

		@@ -17,4 +17,4 @@ import { type EncryptionService } from "../middleware";
		constructor(key: string \| string[] \| undefined);
		encrypt(value: unknown): EncryptionService.PartialEncryptedValue;
		encrypt(value: unknown): string;
		decrypt(value: string): unknown;
		}

strategies/aes.js

		@@ -35,5 +35,3 @@ "use strict";
		encrypt(value) {
		return {
		data: aes_js_1.default.encrypt(JSON.stringify(value), this.keys[0]).toString(),
		};
		return aes_js_1.default.encrypt(JSON.stringify(value), this.keys[0]).toString();
		}
		@@ -40,0 +38,0 @@ decrypt(value) {

strategies/legacy.d.ts

		@@ -45,3 +45,2 @@ import { AESEncryptionService } from "./aes";
		encryptEventData(data: Record<string, unknown>): unknown;
		decryptEventData(data: Record<string, unknown>): unknown;
		}

strategies/legacy.js

		@@ -5,3 +5,2 @@ "use strict";
		const middleware_1 = require("../middleware");
		const stages_1 = require("../stages");
		const aes_1 = require("./aes");
		@@ -32,5 +31,6 @@ /**
		if (this.fieldShouldBeEncrypted(key)) {
		const value = this.service.encrypt(data[key]);
		delete value[middleware_1.EncryptionService.STRATEGY_MARKER];
		return Object.assign(Object.assign({}, acc), { [key]: value });
		return Object.assign(Object.assign({}, acc), { [key]: {
		[middleware_1.EncryptionService.ENCRYPTION_MARKER]: true,
		data: this.service.encrypt(data[key]),
		} });
		}
		@@ -41,12 +41,3 @@ return Object.assign(Object.assign({}, acc), { [key]: data[key] });
		}
		decryptEventData(data) {
		const decryptedData = Object.keys(data).reduce((acc, key) => {
		if ((0, stages_1.isEncryptedValue)(data[key])) {
		return Object.assign(Object.assign({}, acc), { [key]: this.service.decrypt(data[key].data) });
		}
		return Object.assign(Object.assign({}, acc), { [key]: data[key] });
		}, {});
		return decryptedData;
		}
		}
		exports.LEGACY_V0Service = LEGACY_V0Service;

strategies/libSodium.d.ts

		@@ -16,4 +16,4 @@ import { type EncryptionService } from "../middleware";
		constructor(key: string \| string[] \| undefined);
		encrypt(value: unknown): Promise<EncryptionService.PartialEncryptedValue>;
		encrypt(value: unknown): Promise<string>;
		decrypt(value: string): Promise<unknown>;
		}

strategies/libSodium.js

		@@ -60,5 +60,3 @@ "use strict";
		combined.set(ciphertext, nonce.length);
		return {
		data: libsodium_wrappers_1.default.to_base64(combined, libsodium_wrappers_1.default.base64_variants.ORIGINAL),
		};
		return libsodium_wrappers_1.default.to_base64(combined, libsodium_wrappers_1.default.base64_variants.ORIGINAL);
		});
		@@ -65,0 +63,0 @@ }

Worsened metrics