@wataruoguchi/emmett-crypto-shredding-kysely

Kysely adapters for Emmett Crypto Shredding, providing PostgreSQL implementations for key storage and policy storage.

📚 Documentation

👉 View Complete Documentation →

What This Package Does

This package provides Kysely-specific database adapters for:

• Key Storage - PostgreSQL implementation of the KeyStorage interface
• Policy Storage - PostgreSQL implementation of the PolicyStorage interface
• Policy Management - Utilities for managing encryption policies in the database

The actual encryption/decryption logic, key rotation, and crypto shredding functionality are provided by @wataruoguchi/emmett-crypto-shredding.

Installation

npm install @wataruoguchi/emmett-crypto-shredding-kysely @wataruoguchi/emmett-crypto-shredding kysely pg

Quick Start

1. Run Database Migration

Copy the migration file from database/migrations/1761627233034_crypto_shredding.ts to your migrations directory and run it.

2. Create Encryption Policies

⚠️ Important: Create policies before encrypting events (typically during tenant onboarding):

import { createPolicies } from '@wataruoguchi/emmett-crypto-shredding-kysely';

// Example: During tenant onboarding
await createPolicies(db, [
  {
    policyId: `${tenantId}-generator`,
    partition: tenantId,
    streamTypeClass: 'generator', // Stream type to encrypt
    encryptionAlgorithm: 'AES-GCM',
    keyRotationIntervalDays: 180,
    keyScope: 'stream', // 'stream' or 'type'
  },
]);

Or use default policies:

import { createDefaultPolicies } from '@wataruoguchi/emmett-crypto-shredding-kysely';

// Creates policies for 'user-data' and 'audit-log' stream types
await createDefaultPolicies(db, tenantId);

3. Create Encrypted Event Store

Wire up the crypto event store in your module:

import { 
  createCryptoEventStore,
  createWebCryptoProvider,
} from '@wataruoguchi/emmett-crypto-shredding';
import {
  createKeyManagement,
  createPolicyResolver,
} from '@wataruoguchi/emmett-crypto-shredding-kysely';
import { getKyselyEventStore } from '@wataruoguchi/emmett-event-store-kysely';

export function createMyModule({ db, logger }) {
  const eventStore = createCryptoEventStore(
    getKyselyEventStore({ db, logger }),
    {
      policy: createPolicyResolver(db, logger),
      keys: createKeyManagement(db),
      crypto: createWebCryptoProvider(),
      buildAAD: ({ partition, streamId }) =>
        new TextEncoder().encode(`${partition}:${streamId}`),
      logger,
    },
  );
  
  // Use eventStore with your event handlers...
}

API Reference

Key Management

createKeyManagement(db: Kysely<any> | any): KeyManagement

Creates a key management service backed by PostgreSQL.

createKeyStorage(db: Kysely<any> | any): KeyStorage

Creates a lower-level key storage adapter (if you need direct access).

Policy Resolution

createPolicyResolver(db: Kysely<any> | any, logger?: Logger): EncryptionPolicyResolver

Creates a policy resolver backed by PostgreSQL.

createPolicyStorage(db: Kysely<any> | any, logger?: Logger): PolicyStorage

Creates a lower-level policy storage adapter.

Policy Management

createPolicies(db: Kysely<any> | any, policies: DatabasePolicyConfig[]): Promise<void>

Create multiple encryption policies in a single batch operation.

createDefaultPolicies(db: Kysely<any> | any, partition: string): Promise<void>

Create default encryption policies for a partition using the default policy configuration.

updatePolicy(db: Kysely<any> | any, policyId: string, partition: string, updates: {...}): Promise<void>

Update an existing encryption policy.

deletePolicy(db: Kysely<any> | any, policyId: string, partition: string): Promise<void>

Delete an encryption policy.

listPolicies(db: Kysely<any> | any, partition: string): Promise<PolicyRecord[]>

List all policies for a partition.

See Also

• Emmett Crypto Shredding Documentation
• Example Application

License

MIT