lightcrypto-link-node

Application-level field encryption SDK for Node.js with pluggable storage adapters and multi-KMS support.

Transparent encrypt/decrypt via Mongoose plugin or programmatic API, HKDF-based blind index for exact-match queries, multi-DEK envelope encryption with key rotation, bootstrap self-check engine, structured event bus, and byte-level Wire Format V1 compatibility with the Java LightCrypto-Link ecosystem.

---

TL;DR

1. npm install lightcrypto-link-node
2. Configure a CMK provider (local hex key, Azure Key Vault, or Alibaba Cloud KMS).
3. Define schema with encrypt: true and optionally blindIndex: true.
4. Use Mongoose normally — encryption/decryption is automatic.

Deep docs are in docs:

• Configuration — env vars, secret managers, CMK provider setup
• Architecture — envelope encryption, Wire Format V1, namespace model, key vault format, rotation
• CMK Provider — custom provider interface and built-in providers
• Type Mapping — Java ↔ Node.js type compatibility
• Troubleshooting — common errors, security, limitations

Features

• Transparent field encryption via Mongoose plugin (pre-save/post-find hooks)
• Blind indexing for exact-match queries (HKDF-SHA256 namespace-scoped key derivation + HMAC-SHA-256)
• Multiple algorithms: AES-256-GCM (default), AES-256-CBC, SM4-CBC (China compliance)
• Structured type encryption: whole-object (DOC), whole-array (COL), element-level array encryption
• Nested path encryption for sub-documents and array elements (e.g., address.street, items[].price)
• Encryption mode control: AUTO (default), ELEMENT, WHOLE
• Per-entity DEK versioning and rotation
• Pluggable CMK providers: Local, Azure Key Vault, Alibaba Cloud KMS
• Pluggable storage adapters: VaultStore SPI (MongoVaultStore, InMemoryVaultStore) + Data Storage SPI (StorageAdapter, DocumentAccessor, StructuredValueCodec, QueryTransformer) with Mongoose/BSON defaults
• Bootstrap self-check engine: KAT vector verification, KMS/Vault reachability checks at startup
• Structured event bus: L1/L2/L3 tiered events with composite multi-cast and failure isolation
• Zero third-party crypto dependencies (native Node.js crypto)
• Wire Format V1 cross-language binary compatibility with Java LightCrypto-Link (verified by golden vector test suite)
• BSON format compatible with Java LightCrypto-Link (DOC, COL, MAP type markers)

Quick Start

1. Install

npm install lightcrypto-link-node

Cloud KMS (optional):

# Azure Key Vault
npm install @azure/keyvault-keys @azure/identity

# Alibaba Cloud KMS
npm install @alicloud/kms20160120 @alicloud/openapi-client

ESM usage:

import { LocalCmkProvider, AesGcmEncryptor } from 'lightcrypto-link-node';

const cmkProvider = new LocalCmkProvider('your-64-char-hex-cmk-key');
const encryptor = new AesGcmEncryptor();

2. Configure

Local symmetric CMK:

const { LocalCmkProvider } = require('lightcrypto-link-node');
const cmkProvider = new LocalCmkProvider('your-64-char-hex-cmk-key');

See docs/configuration.md for Azure Key Vault, Alibaba Cloud KMS, and environment variable setup.

3. Define schema

const mongoose = require('mongoose');
const { lclCryptoPlugin, KeyVaultService, MongoVaultStore, prepareEncryptedSchema } = require('lightcrypto-link-node');

const keyVaultService = new KeyVaultService({
  vaultStore: new MongoVaultStore(mongoose.connection.getClient().db(mongoose.connection.name)),
  cmkProvider,
  cacheTtl: 3600000  // 1 hour
});

const userSchema = new mongoose.Schema(prepareEncryptedSchema({
  name: { type: String },
  phone: { type: String, encrypt: true, blindIndex: true },
  ssn: { type: String, encrypt: true }
}));

userSchema.plugin(lclCryptoPlugin, {
  keyVaultService,
  entityName: 'User',
  algorithm: 'AES_256_GCM'
});

const User = mongoose.model('User', userSchema);

4. Use normally

// Encryption is automatic on save
const user = new User({ name: 'John', phone: '13800138000', ssn: '123-45-6789' });
await user.save();

// Decryption is automatic on find
const found = await User.findById(user._id);
console.log(found.phone); // '13800138000'

// Blind index queries work transparently
const result = await User.findOne({ phone: '13800138000' });

// NOTE: Querying encrypted fields WITHOUT blindIndex throws an error.
// Enable blindIndex: true on queryable fields, or use a backfill migration.

// NOTE: For encrypted fields with blindIndex=true, only exact-match and $in are supported.
// The SDK throws for range/pattern operators such as $gt/$lt/$gte/$lte/$regex/$text.

Blind Index Query Semantics

To keep behavior aligned with Java LightCrypto-Link and avoid silent query mismatches:

• Supported on encrypt: true + blindIndex: true fields:
  • exact match ({ phone: '13800138000' })
  • $in ({ phone: { $in: ['13800138000', '13900139000'] } })
• Unsupported (throws):
  • range ($gt, $lt, $gte, $lte)
  • pattern/full-text ($regex, $text)
  • other operator-style predicates on encrypted fields

If you need range or fuzzy search, model a separate plaintext/search-friendly projection field (for example, masked prefix, normalized keyword tokens, or external search index), and keep the sensitive field encrypted.

Schema Options

Option	Type	Description
encrypt: true	Boolean	Enable encryption for this field
blindIndex: true	Boolean	Enable blind index for exact-match queries
fieldName: string	String	Custom field name for blind index (cross-entity sharing)
mode: string	String	Encryption mode: AUTO (default), ELEMENT, WHOLE

Encryption Modes

Field Type	AUTO (default)	ELEMENT	WHOLE
Scalar (String, Number, etc.)	field-level	field-level	field-level
Sub-document (POJO)	whole-object (DOC)	error	whole-object (DOC)
Array of scalars	element-level	element-level	whole-array (COL)
Array of sub-docs	whole-array (COL)	error	whole-array (COL)

Structured Type Encryption

// Whole-object encryption (DOC) — sub-document Schema instance
const addressSchema = new mongoose.Schema({ street: String, city: String });
const userSchema = new mongoose.Schema(prepareEncryptedSchema({
  name: String,
  address: { type: addressSchema, encrypt: true }  // AUTO → DOC
}));

// Element-level encryption — scalar array
tags: { type: [String], encrypt: true }  // AUTO → element-level

// Whole-array encryption (COL) — explicit mode
tags: { type: [String], encrypt: true, mode: 'WHOLE' }  // → COL

// Nested path encryption — encrypt specific fields within sub-documents
address: {
  street: { type: String, encrypt: true },  // only street encrypted, city visible
  city: String
}

// Nested path in array elements — items[].price encrypted per-element
items: [{ sku: String, price: { type: Number, encrypt: true } }]

Migration from Plaintext Data

When introducing encryption to an existing system with plaintext MongoDB data:

• Reads: Plaintext historical values pass through safely (only encrypted sub-documents are decrypted).
• Writes: Re-saving a document automatically encrypts plaintext fields (lazy migration).
• Queries: Blind index queries only match encrypted records. Querying an encrypted field without blindIndex: true throws an error.
• Operator constraints: Blind index queries support exact-match and $in only. Unsupported operators throw explicit errors.

Use the backfill runner to migrate all historical records:

# Dry-run: estimate how many records need migration
node examples/plaintext-backfill.js --dry-run

# Run migration with batch size control
node examples/plaintext-backfill.js --batch-size=500

# Resume from last cursor if interrupted
node examples/plaintext-backfill.js --batch-size=500 --start-after-id=6691a2b3c4d5e6f7a8b9c0d1

See examples/plaintext-backfill.js for full configuration options.

Rotation

await keyVaultService.rotateDek('User');
keyVaultService.flushCache();

For behavior details, see docs/architecture.md.

Programmatic API

Use ProgrammaticCryptoService for manual encryption/decryption outside Mongoose — raw driver queries, aggregation pipelines, migration scripts, and DTO encryption:

const { ProgrammaticCryptoService, KeyVaultService, LocalCmkProvider, MongoVaultStore, MongooseStorageAdapter, BsonStructuredValueCodec } = require('lightcrypto-link-node');

const keyVaultService = new KeyVaultService({
  vaultStore: new MongoVaultStore(db),
  cmkProvider
});
const programmatic = new ProgrammaticCryptoService({
  keyVaultService,
  storageAdapter: new MongooseStorageAdapter(),
  structuredValueCodec: new BsonStructuredValueCodec(),
  algorithm: 'AES_256_GCM'
});

// Encrypt a scalar value
const subDoc = await programmatic.encryptValue('13800138000', 'User#phone');
// → { _e: 1, _k: 'v1-abcd1234', _a: 'AES_256_GCM', _t: 'STR', c: '<Base64URL string>' }

// Decrypt a sub-document
const plaintext = await programmatic.decryptValue(subDoc);
// → '13800138000'

// Decrypt fields in a raw document (e.g., from aggregation or db.collection.find())
const rawDoc = await db.collection('users').findOne({ name: 'Alice' });
await programmatic.decryptDocument(rawDoc, 'User', ['phone', 'ssn']);
// rawDoc.phone and rawDoc.ssn are now plaintext

For low-level field operations (without key vault integration), use FieldCryptoService:

const { FieldCryptoService, MongooseStorageAdapter, BsonStructuredValueCodec } = require('lightcrypto-link-node');
const fieldService = new FieldCryptoService({
  storageAdapter: new MongooseStorageAdapter(),
  structuredValueCodec: new BsonStructuredValueCodec()
});

const encrypted = fieldService.encryptField(value, fieldName, dek, hmacKey, kid, algorithm, { namespace, dekVersion });
// → { _e: 1, _k: kid, _a: algorithm, _t: 'STR', c: '<Base64URL string>' }
const decrypted = fieldService.decryptField(encrypted, dek, hmacKey, algorithm);

Examples

See examples/ for runnable demos:

node examples/basic-crud.js          # CRUD with blind index
node examples/plaintext-backfill.js  # Migrate plaintext data to encrypted
node examples/multi-algorithm.js     # AES-GCM, AES-CBC, SM4-CBC
node examples/key-rotation.js        # DEK rotation
node examples/config-from-env.js     # Configuration sources
node examples/programmatic-encrypt.js # Programmatic encrypt/decrypt API
node examples/azure-kms.js           # Azure Key Vault
node examples/alibaba-kms.js         # Alibaba Cloud KMS

Project Structure

lightcrypto-link-node/
├── src/
│   ├── spi/             # SPI interfaces (VaultStore, StorageAdapter, DocumentAccessor, QueryTransformer, StructuredValueCodec, VaultDocument, OptimisticLockError)
│   ├── adapter/         # Default implementations (MongoVaultStore, InMemoryVaultStore, MongooseStorageAdapter, MongooseDocumentAccessor, BsonStructuredValueCodec, MongooseQueryTransformer)
│   ├── crypto/          # Encryptor implementations (AES-GCM, AES-CBC, SM4-CBC, CryptoCodec)
│   ├── format/          # Wire Format V1 (AlgorithmId, WireFormatEncoder, WireFormatDecoder)
│   ├── namespace/       # Namespace model (tenant.realm.entity#field)
│   ├── blindindex/      # HKDF-SHA256 blind index engine
│   ├── service/         # KeyVaultService, FieldCryptoService, ProgrammaticCryptoService, TypeSerializer/Deserializer
│   ├── provider/        # CMK providers (Local, Azure, Alibaba)
│   ├── plugin/          # Mongoose plugin and query rewriter
│   ├── bootstrap/       # Bootstrap engine, KAT runner, startup checks
│   ├── event/           # Structured event bus (EventBus, LclEvent, EventTier, CompositeEventBus)
│   ├── config/          # LclConfig (multi-source loader)
│   └── index.js         # Public API exports
├── test/
│   ├── unit/
│   ├── integration/
│   ├── golden/          # Java golden vector test suite
│   ├── vectors/         # Java-generated test vectors
│   └── interoperability/
├── docs/                # Detailed documentation
├── examples/            # Runnable examples
└── openspec/            # OpenSpec change proposals

Compatibility

• Node.js: 22.x (recommended), 24.x
• Mongoose: 8.x, 9.x
• MongoDB: 5.0+, 6.0+, 7.0+, 8.0+
• Java LightCrypto-Link: Full Wire Format V1 byte-level compatibility (encryption, blind index, KCV, roundtrip verified by golden vector suite). BSON format compatible (DOC, COL, MAP type markers). Note: SM4-GCM encryption from Node.js is not yet supported (OpenSSL limitation); SM4-GCM decryption and wire format parsing work.

License

Apache License 2.0