feat(certificates): implement certificate manager

After the implementation from cloudmos

refs #76

package.json

@@ -18,6 +18,7 @@
     "cosmwasm": "^1.1.1",
     "js-yaml": "^4.1.0",
     "json-stable-stringify": "^1.0.2",
+    "jsrsasign": "^11.1.0",
     "keytar": "^7.7.0",
     "node-fetch": "2",
     "pkijs": "^3.0.0",

src/certificates/certificate-manager/CertificateManager.spec.ts

@@ -0,0 +1,101 @@
+import { faker } from "@faker-js/faker";
+
+import { CertificateManager } from "./CertificateManager";
+
+describe("CertificateManager", () => {
+  let certificateManager: CertificateManager;
+  let address: string;
+
+  beforeEach(() => {
+    certificateManager = new CertificateManager();
+    address = `akash1${faker.string.alpha({ length: 38 })}`;
+  });
+
+  describe("prototype.generateCertificate", () => {
+    it("should generate certificate PEMs with the default validity range", () => {
+      const now = new Date();
+      now.setMilliseconds(0);
+      const inOneYear = getTime1yearFrom(now);
+      const pem = certificateManager.generatePEM(address);
+      const meta = certificateManager.parsePem(pem.certKey);
+
+      expect(pem).toMatchObject({
+        certKey: expect.stringMatching(/^-----BEGIN CERTIFICATE-----[\s\S]*-----END CERTIFICATE-----\r\n$/),
+        publicKey: expect.stringMatching(/^-----BEGIN EC PUBLIC KEY-----[\s\S]*-----END EC PUBLIC KEY-----\r\n$/),
+        privateKey: expect.stringMatching(/^-----BEGIN PRIVATE KEY-----[\s\S]*-----END PRIVATE KEY-----\r\n$/)
+      });
+      expect(new Date(meta.issuedOn).getTime()).toBeGreaterThanOrEqual(now.getTime());
+      expect(new Date(meta.issuedOn).getTime()).toBeLessThan(new Date().getTime());
+      expect(new Date(meta.expiresOn).getTime()).toBeGreaterThanOrEqual(inOneYear);
+      expect(new Date(meta.issuedOn).getTime()).toBeLessThan(getTime1yearFrom(new Date()));
+    });
+  });
+
+  it("should generate certificate PEMs with the provided validity range", () => {
+    const now = new Date();
+    const MONTH = 1000 * 60 * 60 * 24 * 30;
+    const inOneMonth = new Date(now.getTime() + MONTH);
+    const inTwoMonths = new Date(now.getTime() + MONTH * 2);
+    const pem = certificateManager.generatePEM(address, {
+      validFrom: inOneMonth,
+      validTo: inTwoMonths
+    });
+    const meta = certificateManager.parsePem(pem.certKey);
+
+    expect(pem).toMatchObject({
+      certKey: expect.stringMatching(/^-----BEGIN CERTIFICATE-----[\s\S]*-----END CERTIFICATE-----\r\n$/),
+      publicKey: expect.stringMatching(/^-----BEGIN EC PUBLIC KEY-----[\s\S]*-----END EC PUBLIC KEY-----\r\n$/),
+      privateKey: expect.stringMatching(/^-----BEGIN PRIVATE KEY-----[\s\S]*-----END PRIVATE KEY-----\r\n$/)
+    });
+
+    inOneMonth.setMilliseconds(0);
+    inTwoMonths.setMilliseconds(0);
+    expect(new Date(meta.issuedOn).getTime()).toBe(inOneMonth.getTime());
+    expect(new Date(meta.expiresOn).getTime()).toBe(inTwoMonths.getTime());
+  });
+
+  describe("prototype.parsePem", () => {
+    it("should extract certificate data", () => {
+      const cert = certificateManager.parsePem(certificateManager.generatePEM(address).certKey);
+
+      expect(cert).toMatchObject({
+        hSerial: expect.any(String),
+        sIssuer: expect.any(String),
+        sSubject: expect.any(String),
+        sNotBefore: expect.any(String),
+        sNotAfter: expect.any(String),
+        issuedOn: expect.any(Date),
+        expiresOn: expect.any(Date)
+      });
+    });
+  });
+
+  describe("prototype.strToDate", () => {
+    it("should convert string to date", () => {
+      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+      // @ts-expect-error
+      const date = certificateManager.strToDate("240507122350Z");
+
+      expect(date).toBeInstanceOf(Date);
+      expect(date.toISOString()).toBe("2024-05-07T12:23:50.000Z");
+    });
+  });
+
+  describe("prototype.dateToStr", () => {
+    it("should convert date to string", () => {
+      const date = new Date("2024-05-07T12:23:50.000Z");
+      // eslint-disable-next-line @typescript-eslint/ban-ts-comment
+      // @ts-expect-error
+      const str = certificateManager.dateToStr(date);
+
+      expect(str).toBe("240507122350Z");
+    });
+  });
+});
+
+function getTime1yearFrom(date = new Date()): number {
+  const clone = new Date(date);
+  const inOneYear = new Date(date);
+  inOneYear.setFullYear(clone.getFullYear() + 1);
+  return inOneYear.getTime();
+}

src/certificates/certificate-manager/CertificateManager.ts

@@ -0,0 +1,114 @@
+// eslint-disable-next-line @typescript-eslint/ban-ts-comment
+// @ts-expect-error
+import rs from "jsrsasign";
+
+export interface CertificatePem {
+  certKey: string;
+  publicKey: string;
+  privateKey: string;
+}
+
+export interface CertificateInfo {
+  hSerial: string;
+  sIssuer: string;
+  sSubject: string;
+  sNotBefore: string;
+  sNotAfter: string;
+  issuedOn: Date;
+  expiresOn: Date;
+}
+
+export interface ValidityRangeOptions {
+  validFrom?: Date;
+  validTo?: Date;
+}
+
+export class CertificateManager {
+  parsePem(certPEM: string): CertificateInfo {
+    const certificate = new rs.X509();
+    certificate.readCertPEM(certPEM);
+    const hSerial: string = certificate.getSerialNumberHex();
+    const sIssuer: string = certificate.getIssuerString();
+    const sSubject: string = certificate.getSubjectString();
+    const sNotBefore: string = certificate.getNotBefore();
+    const sNotAfter: string = certificate.getNotAfter();
+
+    return {
+      hSerial,
+      sIssuer,
+      sSubject,
+      sNotBefore,
+      sNotAfter,
+      issuedOn: this.strToDate(sNotBefore),
+      expiresOn: this.strToDate(sNotAfter)
+    };
+  }
+
+  generatePEM(address: string, options?: ValidityRangeOptions): CertificatePem {
+    const { notBeforeStr, notAfterStr } = this.createValidityRange(options);
+    const { prvKeyObj, pubKeyObj } = rs.KEYUTIL.generateKeypair("EC", "secp256r1");
+    const cert = new rs.KJUR.asn1.x509.Certificate({
+      version: 3,
+      serial: { int: Math.floor(new Date().getTime() * 1000) },
+      issuer: { str: "/CN=" + address },
+      notbefore: notBeforeStr,
+      notafter: notAfterStr,
+      subject: { str: "/CN=" + address },
+      sbjpubkey: pubKeyObj,
+      ext: [
+        { extname: "keyUsage", critical: true, names: ["keyEncipherment", "dataEncipherment"] },
+        {
+          extname: "extKeyUsage",
+          array: [{ name: "clientAuth" }]
+        },
+        { extname: "basicConstraints", cA: true, critical: true }
+      ],
+      sigalg: "SHA256withECDSA",
+      cakey: prvKeyObj
+    });
+    const publicKey: string = rs.KEYUTIL.getPEM(pubKeyObj, "PKCS8PUB").replaceAll("PUBLIC KEY", "EC PUBLIC KEY");
+    const certKey: string = cert.getPEM();
+
+    return {
+      certKey,
+      publicKey,
+      privateKey: rs.KEYUTIL.getPEM(prvKeyObj, "PKCS8PRV")
+    };
+  }
+
+  private createValidityRange(options?: ValidityRangeOptions) {
+    const notBefore = options?.validFrom || new Date();
+    const notAfter = options?.validTo || new Date();
+
+    if (!options?.validTo) {
+      notAfter.setFullYear(notBefore.getFullYear() + 1);
+    }
+
+    const notBeforeStr = this.dateToStr(notBefore);
+    const notAfterStr = this.dateToStr(notAfter);
+
+    return { notBeforeStr, notAfterStr };
+  }
+
+  private dateToStr(date: Date): string {
+    const year = date.getUTCFullYear().toString().substring(2).padStart(2, "0");
+    const month = (date.getUTCMonth() + 1).toString().padStart(2, "0");
+    const day = date.getUTCDate().toString().padStart(2, "0");
+    const hours = date.getUTCHours().toString().padStart(2, "0");
+    const minutes = date.getUTCMinutes().toString().padStart(2, "0");
+    const secs = date.getUTCSeconds().toString().padStart(2, "0");
+
+    return `${year}${month}${day}${hours}${minutes}${secs}Z`;
+  }
+
+  private strToDate(str: string): Date {
+    const year = parseInt(`20${str.substring(0, 2)}`);
+    const month = parseInt(str.substring(2, 4)) - 1;
+    const day = parseInt(str.substring(4, 6));
+    const hours = parseInt(str.substring(6, 8));
+    const minutes = parseInt(str.substring(8, 10));
+    const secs = parseInt(str.substring(10, 12));
+
+    return new Date(Date.UTC(year, month, day, hours, minutes, secs));
+  }
+}

src/certificates/certificate-manager/index.ts

@@ -0,0 +1,5 @@
+import { CertificateManager } from "./CertificateManager";
+
+const certificateManager = new CertificateManager();
+
+export { CertificateManager, certificateManager };

src/certificates/index.ts

@@ -1,22 +1,38 @@
-import { create as create509, pems } from "./generate509";
 import { SigningStargateClient } from "@cosmjs/stargate";
+import { DeliverTxResponse } from "@cosmjs/stargate/build/stargateclient";
+import { toBase64 } from "pvutils";
+import { CertificateFilter, QueryCertificatesRequest, QueryCertificatesResponse } from "@akashnetwork/akash-api/akash/cert/v1beta3";
+
+import type { pems } from "./generate509";
 import { Message as stargateMessages } from "../stargate";
 import { createStarGateMessage } from "../pbclient/pbclient";
-
-import { QueryCertificatesRequest, QueryCertificatesResponse, CertificateFilter } from "@akashnetwork/akash-api/akash/cert/v1beta3";
+import type { CertificatePem } from "./certificate-manager/CertificateManager";
+import { certificateManager } from "./certificate-manager";
 
 // eslint-disable-next-line @typescript-eslint/no-var-requires
 const JsonRPC = require("simple-jsonrpc-js");
 
-import { toBase64 } from "pvutils";
-
 const jrpc = JsonRPC.connect_xhr("https://bridge.testnet.akash.network/akashnetwork");
 
 export type { pems };
 
-export async function broadcastCertificate({ csr, publicKey }: pems, owner: string, client: SigningStargateClient) {
-  const encodedCsr = base64ToUInt(toBase64(csr));
-  const encdodedPublicKey = base64ToUInt(toBase64(publicKey));
+export async function broadcastCertificate(
+  pem: Pick<CertificatePem, "certKey" | "publicKey">,
+  owner: string,
+  client: SigningStargateClient
+): Promise<DeliverTxResponse>;
+export async function broadcastCertificate(pem: pems, owner: string, client: SigningStargateClient): Promise<DeliverTxResponse>;
+export async function broadcastCertificate(
+  pem: Pick<CertificatePem, "certKey" | "publicKey"> | pems,
+  owner: string,
+  client: SigningStargateClient
+): Promise<DeliverTxResponse> {
+  if ("csr" in pem) {
+    console.warn("The `csr` field is deprecated. Use `certKey` instead.");
+  }
+  const certKey = "certKey" in pem ? pem.certKey : pem.csr;
+  const encodedCsr = base64ToUInt(toBase64(certKey));
+  const encdodedPublicKey = base64ToUInt(toBase64(pem.publicKey));
   const message = createStarGateMessage(stargateMessages.MsgCreateCertificate, {
     owner: owner,
     cert: encodedCsr,
@@ -27,8 +43,17 @@ export async function broadcastCertificate({ csr, publicKey }: pems, owner: stri
 }
 
 export async function createCertificate(bech32Address: string) {
-  const certificate = create509(bech32Address);
-  return certificate;
+  const pem = certificateManager.generatePEM(bech32Address);
+
+  return {
+    get csr() {
+      console.warn("The `csr` field is deprecated. Use `certKey` instead.");
+      return pem.certKey;
+    },
+    certKey: pem.certKey,
+    publicKey: pem.publicKey,
+    privateKey: pem.privateKey
+  };
 }
 
 export async function revokeCertificate(owner: string, serial: string, client: SigningStargateClient) {