Merge pull request #28 from subspace/fix-issue-16-peculiar-x509

Author: abhi3700

packages/auto-id/package.json

@@ -12,6 +12,8 @@
     "@autonomys/auto-utils": "workspace:*",
     "@peculiar/asn1-schema": "^2.3.8",
     "@peculiar/asn1-x509": "^2.3.8",
+    "@peculiar/webcrypto": "^1.5.0",
+    "@peculiar/x509": "^1.11.0",
     "asn1js": "^3.0.5"
   },
   "files": [
@@ -26,4 +28,4 @@
     "ts-node": "^10.9.2",
     "typescript": "^5.4.5"
   }
-}
+}

packages/auto-id/src/certificateManager.ts

@@ -0,0 +1,344 @@
+//! For key generation, management, `keyManagement.ts` file is used using "crypto" library.
+//! And for certificate related, used "@peculiar/x509" library.
+
+import {
+  blake2b_256,
+  concatenateUint8Arrays,
+  save,
+  stringToUint8Array,
+} from '@autonomys/auto-utils'
+import { AsnConvert } from '@peculiar/asn1-schema'
+import { AttributeTypeAndValue, GeneralNames } from '@peculiar/asn1-x509'
+import { Crypto } from '@peculiar/webcrypto'
+import * as x509 from '@peculiar/x509'
+import { KeyObject, createPublicKey } from 'crypto'
+import { doPublicKeysMatch, pemToPublicKey } from './keyManagement'
+
+const crypto = new Crypto()
+x509.cryptoProvider.set(crypto)
+
+interface SigningParams {
+  privateKey: CryptoKey
+  algorithm: 'sha256' | null // Only 'sha256' or null for Ed25519
+}
+
+export const OID_COMMON_NAME = '2.5.4.3' // OID for Common Name, not available in the library.
+const OID_SUBJECT_ALT_NAME = '2.5.29.17' // OID for Subject Alternative Name, not available in the library.
+
+export class CertificateManager {
+  private certificate: x509.X509Certificate | null
+  private privateKey: CryptoKey | null
+  private publicKey: CryptoKey | null
+
+  constructor(
+    certificate: x509.X509Certificate | null = null,
+    privateKey: CryptoKey | null = null,
+    publicKey: CryptoKey | null = null,
+  ) {
+    this.certificate = certificate
+    this.privateKey = privateKey
+    this.publicKey = publicKey
+  }
+
+  protected prepareSigningParams(): SigningParams {
+    const privateKey = this.privateKey
+
+    if (!privateKey) {
+      throw new Error('Private key is not set.')
+    }
+
+    if (privateKey.algorithm.name === 'Ed25519') {
+      return { privateKey: privateKey, algorithm: null }
+    }
+
+    if (privateKey.algorithm.name === 'rsa') {
+      return { privateKey: privateKey, algorithm: 'sha256' }
+    }
+
+    throw new Error('Unsupported key type for signing.')
+  }
+
+  protected static toCommonName(subjectName: string): x509.Name {
+    const commonNameAttr = new AttributeTypeAndValue({
+      type: OID_COMMON_NAME,
+      value: subjectName,
+    })
+    return new x509.Name([[commonNameAttr]])
+  }
+
+  static prettyPrintCertificate(cert: x509.X509Certificate): void {
+    console.log('Certificate:')
+    console.log('============')
+    console.log(`Subject: ${cert.subject}`)
+    console.log(`Issuer: ${cert.issuer}`)
+    console.log(`Serial Number: ${cert.serialNumber}`)
+    console.log(`Not Valid Before: ${cert.notBefore}`)
+    console.log(`Not Valid After: ${cert.notAfter}`)
+
+    console.log('\nExtensions:')
+    cert.extensions.forEach((ext) => {
+      console.log(` - ${ext.type}: ${JSON.stringify(ext.value)}`)
+    })
+    console.log('\nPublic Key:')
+    console.log(cert.publicKey)
+  }
+
+  static certificateToPem(cert: x509.X509Certificate): string {
+    return cert.toString('pem')
+  }
+
+  static pemToCertificate(pem: string): x509.X509Certificate {
+    return new x509.X509Certificate(pem)
+  }
+
+  static getSubjectCommonName(subject: x509.Name): string | undefined {
+    const commonNames = subject.getField(OID_COMMON_NAME) // OID for commonName
+    return commonNames.length > 0 ? commonNames[0] : undefined
+  }
+
+  static getCertificateAutoId(certificate: x509.X509Certificate): string | undefined {
+    const sanExtension = certificate.extensions.find((ext) => ext.type === OID_SUBJECT_ALT_NAME)
+
+    if (sanExtension && sanExtension.value) {
+      // Deserialize the ArrayBuffer to GeneralNames ASN.1 object
+      const san = AsnConvert.parse(sanExtension.value, GeneralNames)
+
+      for (const name of san) {
+        if (
+          name.uniformResourceIdentifier &&
+          name.uniformResourceIdentifier.startsWith('autoid:auto:')
+        ) {
+          return name.uniformResourceIdentifier.split(':').pop()
+        }
+      }
+    }
+    return undefined
+  }
+
+  async createCSR(subjectName: string): Promise<x509.Pkcs10CertificateRequest> {
+    const privateKey = this.privateKey
+    const publicKey = this.publicKey
+
+    if (!privateKey || !publicKey) {
+      throw new Error('Private or public key is not set.')
+    }
+
+    // Set the signing algorithm based on the key type
+    let signingAlgorithm: Algorithm | EcdsaParams
+    if (privateKey.algorithm.name === 'Ed25519') {
+      signingAlgorithm = { name: 'Ed25519' }
+    } else if (privateKey.algorithm.name === 'rsa') {
+      signingAlgorithm = { name: 'RSASSA-PKCS1-v1_5', hash: { name: 'SHA-256' } }
+    } else {
+      throw new Error('Unsupported key type for signing')
+    }
+
+    const csr = await x509.Pkcs10CertificateRequestGenerator.create({
+      name: `CN=${subjectName}`,
+      keys: {
+        privateKey: privateKey,
+        publicKey: publicKey,
+      },
+      signingAlgorithm: signingAlgorithm,
+    })
+
+    return csr
+  }
+
+  async signCSR(csr: x509.Pkcs10CertificateRequest): Promise<x509.Pkcs10CertificateRequest> {
+    const privateKey = this.privateKey
+    if (!privateKey) {
+      throw new Error('Private key is not set.')
+    }
+
+    const _signingParams = this.prepareSigningParams()
+
+    const derBuffer = csr.rawData
+    const signature = await crypto.subtle.sign(privateKey.algorithm.name, privateKey, derBuffer)
+    csr.signature = new Uint8Array(signature)
+
+    return csr
+  }
+
+  async createAndSignCSR(subjectName: string): Promise<x509.Pkcs10CertificateRequest> {
+    const csr = await this.createCSR(subjectName)
+    return this.signCSR(csr)
+  }
+
+  // TODO: later on move to "keyManagement.ts"
+  private static publicKeyToKeyObject(publicKey: x509.PublicKey): KeyObject {
+    // Export the key data to ArrayBuffer
+    const keyData = publicKey.rawData // DER format
+
+    // Create a KeyObject from the key data
+    const keyObject = createPublicKey({
+      key: Buffer.from(keyData),
+      format: 'der',
+      type: 'spki',
+    })
+
+    return keyObject
+  }
+
+  async issueCertificate(
+    csr: x509.Pkcs10CertificateRequest,
+    validityPeriodDays: number = 365,
+  ): Promise<x509.X509Certificate> {
+    const privateKey = this.privateKey
+    const publicKey = this.publicKey
+    if (!privateKey || !publicKey) {
+      throw new Error('Private or public key is not set.')
+    }
+
+    let issuerName: x509.Name
+    let autoId: string
+    const certificate = this.certificate
+    if (!certificate) {
+      issuerName = csr.subjectName
+      const subjectCommonName = CertificateManager.getSubjectCommonName(issuerName)
+      if (!subjectCommonName) {
+        throw new Error('Subject common name not found in CSR.')
+      }
+      autoId = blake2b_256(stringToUint8Array(subjectCommonName))
+    } else {
+      if (
+        // FIXME: modify
+        !doPublicKeysMatch(
+          CertificateManager.publicKeyToKeyObject(certificate.publicKey),
+          pemToPublicKey(await cryptoKeyToPem(publicKey)),
+        )
+      ) {
+        throw new Error(
+          'Issuer certificate public key does not match the private key used for signing.',
+        )
+      }
+
+      issuerName = certificate.subjectName
+      const certificateAutoId = CertificateManager.getCertificateAutoId(certificate) || ''
+      const certificateSubjectCommonName =
+        CertificateManager.getSubjectCommonName(certificate.subjectName) || ''
+      if (certificateAutoId === '' || certificateSubjectCommonName === '') {
+        throw new Error(
+          'Issuer certificate does not have either an auto ID or a subject common name or both.',
+        )
+      }
+      autoId = blake2b_256(
+        concatenateUint8Arrays(
+          stringToUint8Array(certificateAutoId),
+          stringToUint8Array(certificateSubjectCommonName),
+        ),
+      )
+    }
+
+    // Prepare the certificate builder with information from the CSR
+    const notBefore = new Date()
+    const notAfter = new Date()
+    notAfter.setDate(notBefore.getDate() + validityPeriodDays)
+
+    let certificateBuilder = await x509.X509CertificateGenerator.create({
+      issuer: csr.subject,
+      subject: csr.subject,
+      notBefore,
+      notAfter,
+      signingAlgorithm: privateKey.algorithm,
+      publicKey: publicKey,
+      signingKey: privateKey,
+    })
+
+    const autoIdSan = `autoid:auto:${Buffer.from(autoId).toString('hex')}`
+
+    const sanExtensions = csr.extensions.filter((ext) => ext.type === OID_SUBJECT_ALT_NAME) // OID for subjectAltName
+    if (sanExtensions.length) {
+      // const existingSan = sanExtensions[0].value
+      const existingSan = sanExtensions[0] as x509.SubjectAlternativeNameExtension
+
+      const generalNames = existingSan.names.toJSON()
+
+      // Add autoIdSan to generalNames
+      generalNames.push({
+        type: 'url' as x509.GeneralNameType,
+        value: autoIdSan,
+      })
+
+      // const newSanExtension = existingSan + CertificateManager.stringToArrayBuffer(autoIdSan)
+      const newSanExtension = new x509.SubjectAlternativeNameExtension(
+        generalNames,
+        existingSan.critical,
+      )
+      certificateBuilder.extensions.push(newSanExtension)
+    } else {
+      // certificateBuilder.extensions.push(
+      //   new x509.SubjectAlternativeNameExtension([autoIdSan]),
+      //   false,
+      // )
+
+      certificateBuilder.extensions.push(
+        new x509.SubjectAlternativeNameExtension([
+          { type: 'url' /* as x509.GeneralNameType */, value: autoIdSan },
+        ]),
+      )
+    }
+
+    // Copy all extensions from the CSR to the certificate
+    for (const ext of csr.extensions) {
+      // certificateBuilder.extensions.push(new x509.Extension(ext.value, ext.critical))
+      certificateBuilder.extensions.push(ext)
+    }
+
+    const certificateSigned = await x509.X509CertificateGenerator.create({
+      serialNumber: certificateBuilder.serialNumber,
+      issuer: certificateBuilder.issuer,
+      subject: certificateBuilder.subject,
+      notBefore: certificateBuilder.notBefore,
+      notAfter: certificateBuilder.notAfter,
+      extensions: certificateBuilder.extensions,
+      publicKey: certificateBuilder.publicKey,
+      signingAlgorithm: certificateBuilder.signatureAlgorithm,
+      signingKey: privateKey,
+    })
+
+    return certificateSigned
+  }
+
+  async selfIssueCertificate(
+    subjectName: string,
+    validityPeriodDays: number = 365,
+  ): Promise<x509.X509Certificate> {
+    if (!this.privateKey || !this.publicKey) {
+      throw new Error('Private or public key is not set.')
+    }
+
+    const csr = await this.createAndSignCSR(subjectName)
+    const certificate = await this.issueCertificate(csr, validityPeriodDays)
+
+    this.certificate = certificate
+    return certificate
+  }
+
+  async saveCertificate(filePath: string): Promise<void> {
+    if (!this.certificate) {
+      throw new Error('No certificate available to save.')
+    }
+
+    const certificatePem = CertificateManager.certificateToPem(this.certificate)
+    await save(filePath, certificatePem)
+  }
+}
+
+function arrayBufferToBase64(buffer: ArrayBuffer): string {
+  let binary = ''
+  const bytes = new Uint8Array(buffer)
+  const len = bytes.byteLength
+  for (let i = 0; i < len; i++) {
+    binary += String.fromCharCode(bytes[i])
+  }
+  return btoa(binary)
+}
+
+async function cryptoKeyToPem(key: CryptoKey): Promise<string> {
+  const exported = await crypto.subtle.exportKey(key.type === 'private' ? 'pkcs8' : 'spki', key)
+  const base64 = arrayBufferToBase64(exported)
+  const type = key.type === 'private' ? 'PRIVATE KEY' : 'PUBLIC KEY'
+  const pem = `-----BEGIN ${type}-----\n${base64.match(/.{1,64}/g)?.join('\n')}\n-----END ${type}-----`
+  return pem
+}

packages/auto-id/src/index.ts

@@ -1,2 +1,3 @@
+export * from './certificateManager'
 export * from './keyManagement'
 export * from './utils'