chore: initial commit (#186)

## Description
resolves paritytech/dotns#136
## Type

- [ ] Bug fix
- [x] Feature
- [ ] Breaking change
- [ ] Documentation
- [ ] Chore

## Package

- [ ] `@parity/dotns-cli`
- [ ] Root/monorepo
- [ ] Documentation

## Related Issues

## Fixes 

## Checklist

### Code

- [x] Follows project style
- [x] `bun run lint` passes
- [x] `bun run format` passes
- [x] `bun run typecheck` passes

### Documentation

- [ ] README updated if needed
- [ ] Types updated if needed

### Breaking Changes

- [ ] No breaking changes
- [ ] Breaking changes documented below

**Breaking changes:**

## Testing

How to test:

1. 
2. 

## Notes

Author: sphamjoli

packages/cli/package.json

@@ -22,7 +22,8 @@
     "benchmark": "bun benchmarks/benchmark.ts",
     "benchmark:dashboard": "bun benchmarks/generate-dashboard.ts",
     "build": "bun build src/cli/index.ts --outfile dist/cli.tmp.js --target node --format esm && echo '#!/usr/bin/env node' | cat - dist/cli.tmp.js > dist/cli.js && rm dist/cli.tmp.js && chmod +x dist/cli.js",
-    "prepublishOnly": "bun run build",
+    "build:lib": "bun build src/core/index.ts --outfile dist/core/index.js --target node --format esm && bun build src/core/keyring.ts --outfile dist/core/keyring.js --target node --format esm && bunx tsc -p tsconfig.build.json --emitDeclarationOnly",
+    "prepublishOnly": "bun run build && bun run build:lib",
     "prepare": "bunx papi generate"
   },
   "engines": {
@@ -35,7 +36,15 @@
     "dotns": "./dist/cli.js"
   },
   "exports": {
-    ".": "./dist/cli.js"
+    ".": "./dist/cli.js",
+    "./core": {
+      "types": "./dist/src/core/index.d.ts",
+      "import": "./dist/core/index.js"
+    },
+    "./core/keyring": {
+      "types": "./dist/src/core/keyring.d.ts",
+      "import": "./dist/core/keyring.js"
+    }
   },
   "devDependencies": {
     "@polkadot-api/descriptors": "file:.papi/descriptors",

packages/cli/src/bulletin/cid.ts

@@ -14,9 +14,9 @@ export const HASH = {
   BLAKE2B_256: 0xb220,
 } as const;
 
-export const HASH_LENGTH = 32;
+const HASH_LENGTH = 32;
 
-export function computeHash(data: Uint8Array, hashCode: number): Uint8Array {
+function computeHash(data: Uint8Array, hashCode: number): Uint8Array {
   switch (hashCode) {
     case HASH.SHA2_256:
       return sha256(data);

packages/cli/src/bulletin/cidHistory.ts

@@ -1,13 +1,13 @@
 import { promises as fs } from "node:fs";
 import path from "node:path";
 import os from "node:os";
-import { PREVIEW_BASE_URL } from "../utils/constants";
+import { getActiveDotnsEnvironment } from "../utils/constants";
 import type { UploadRecord } from "../types/types";
 
 const HISTORY_DIR = path.join(os.homedir(), ".dotns");
 const HISTORY_FILE = path.join(HISTORY_DIR, "uploads.json");
 
-export function formatLocalTimestamp(date: Date): string {
+function formatLocalTimestamp(date: Date): string {
   const months = [
     "January",
     "February",
@@ -55,7 +55,7 @@ export async function readHistory(): Promise<UploadRecord[]> {
   }
 }
 
-export async function writeHistory(records: UploadRecord[]): Promise<void> {
+async function writeHistory(records: UploadRecord[]): Promise<void> {
   await ensureHistoryDir();
   await fs.writeFile(HISTORY_FILE, JSON.stringify(records, null, 2));
 }
@@ -107,7 +107,11 @@ function encodeForPreview(cid: string): string {
   return base64.replace(/\+/g, "-").replace(/\//g, "_").replace(/=+$/, "");
 }
 
-export function getPreviewUrl(record: UploadRecord): string {
+// Null when the active environment has no web app (e.g. previewnet): callers omit
+// the preview link rather than emit a wrong-network or broken URL.
+export function getPreviewUrl(record: UploadRecord): string | null {
+  const { previewBaseUrl } = getActiveDotnsEnvironment();
+  if (!previewBaseUrl) return null;
   const encoded = encodeForPreview(record.cid);
-  return `${PREVIEW_BASE_URL}/${encoded}`;
+  return `${previewBaseUrl}/${encoded}`;
 }

packages/cli/src/bulletin/uploadManifest.ts

@@ -164,7 +164,7 @@ async function listManifestFiles(): Promise<string[]> {
   }
 }
 
-export async function loadManifest(
+async function loadManifest(
   target: string | UploadManifestIdentity,
 ): Promise<UploadManifest | null> {
   if (typeof target === "string") {

packages/cli/src/bulletin/uploadRetry.ts

@@ -51,7 +51,7 @@ const RECONNECT_REQUIRED_UPLOAD_ERROR_MARKERS = [
   "aborted",
 ] as const;
 
-export type UploadRetryAttemptContext = {
+type UploadRetryAttemptContext = {
   retry: number;
   nextAttempt: number;
   totalAttempts: number;

packages/cli/src/cli/commands/bulletin.ts

@@ -984,7 +984,7 @@ export function attachBulletinCommands(root: Command): void {
           writeBulletinJson({
             cid,
             contenthash: `0x${contenthash}`,
-            preview: previewUrl,
+            preview: previewUrl ?? undefined,
             path: resolvedPath,
             type: isDirectory ? "directory" : "file",
             size: uploadSize,
@@ -996,7 +996,9 @@ export function attachBulletinCommands(root: Command): void {
           });
         } else {
           console.log(chalk.gray("\n  cid:         ") + chalk.cyan(cid));
-          console.log(chalk.gray("  preview:     ") + chalk.blue(previewUrl));
+          if (previewUrl) {
+            console.log(chalk.gray("  preview:     ") + chalk.blue(previewUrl));
+          }
           console.log(
             chalk.gray("  total time:  ") + chalk.white(formatDuration(totalUploadTimeSeconds)),
           );
@@ -1227,7 +1229,10 @@ export function attachBulletinCommands(root: Command): void {
         if (record.size > 0) {
           console.log(chalk.gray("      size:    ") + chalk.white(formatBytes(record.size)));
         }
-        console.log(chalk.gray("      preview: ") + chalk.blue(getPreviewUrl(record)));
+        const recordPreviewUrl = getPreviewUrl(record);
+        if (recordPreviewUrl) {
+          console.log(chalk.gray("      preview: ") + chalk.blue(recordPreviewUrl));
+        }
         console.log();
       });
 

packages/cli/src/cli/commands/content.ts

@@ -1,9 +1,11 @@
+import { printCommandHeader } from "../ui";
 import { Command } from "commander";
 import chalk from "chalk";
-import { viewDomainContentHash, setDomainContentHash } from "../../commands/contentHash";
+import { getContentHash, setContentHash } from "../../commands/contentHash";
 import { addAuthOptions } from "./authOptions";
-import { prepareContext } from "../context";
+import { buildDotnsContext, prepareContext } from "../context";
 import { prepareReadOnlyContext } from "./lookup";
+import { makeOnStatus } from "../txStatus";
 import { dotliViewUrls } from "../../utils/constants";
 import {
   getMergedOptions,
@@ -14,11 +16,11 @@ import {
 } from "./jsonHelpers";
 import ora from "ora";
 
-export interface ContentViewOptions {
+interface ContentViewOptions {
   rpc?: string;
 }
 
-export interface ContentSetOptions {
+interface ContentSetOptions {
   rpc?: string;
 }
 
@@ -41,14 +43,25 @@ export function attachContentCommands(root: Command) {
           prepareReadOnlyContext(mergedOptions as any),
         );
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Content View\n"));
+        if (!jsonOutput) printCommandHeader("Content View");
         const spinner = ora();
-
-        const result = await maybeQuiet(jsonOutput, () =>
-          viewDomainContentHash(context.clientWrapper!, context.account.address, name, spinner),
+        const ctx = buildDotnsContext(
+          { ...context, substrateAddress: context.account.address, signer: undefined } as any,
+          { onStatus: makeOnStatus(spinner, "content hash") },
         );
 
+        const result = await maybeQuiet(jsonOutput, () => getContentHash(ctx, name));
+
         if (!emitJsonResult(jsonOutput, result)) {
+          console.log(chalk.gray("  domain:      ") + chalk.cyan(result.domain));
+          console.log(
+            chalk.gray("  contenthash: ") +
+              (result.contenthash ? chalk.white(result.contenthash) : chalk.yellow("(not set)")),
+          );
+          console.log(
+            chalk.gray("  cid:         ") +
+              (result.cid ? chalk.cyan(result.cid) : chalk.yellow("(not set)")),
+          );
           console.log(chalk.green("\n✓ Complete\n"));
         }
         process.exit(0);
@@ -77,21 +90,18 @@ export function attachContentCommands(root: Command) {
           prepareContext({ ...mergedOptions, useRevive: true }),
         );
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Content Set\n"));
+        if (!jsonOutput) printCommandHeader("Content Set");
         const spinner = ora();
+        const ctx = buildDotnsContext(context as any, {
+          onStatus: makeOnStatus(spinner, "content hash"),
+        });
 
-        const result = await maybeQuiet(jsonOutput, () =>
-          setDomainContentHash(
-            context.clientWrapper!,
-            context.substrateAddress,
-            context.signer,
-            name,
-            cid,
-            spinner,
-          ),
-        );
+        const result = await maybeQuiet(jsonOutput, () => setContentHash(ctx, name, cid));
 
         if (!emitJsonResult(jsonOutput, result)) {
+          console.log(chalk.gray("  domain: ") + chalk.cyan(result.domain));
+          console.log(chalk.gray("  cid:    ") + chalk.cyan(result.cid));
+          console.log(chalk.gray("  tx:     ") + chalk.blue(result.txHash));
           console.log(chalk.green("\n✓ Complete\n"));
           console.log(chalk.gray("  View on dot.li:"));
           for (const url of dotliViewUrls(name)) {

packages/cli/src/cli/commands/delegate.ts

@@ -1,3 +1,4 @@
+import { printCommandHeader } from "../ui";
 import { Command } from "commander";
 import chalk from "chalk";
 import ora from "ora";
@@ -11,7 +12,8 @@ import {
 } from "../../commands/delegate";
 import { resolveTransferRecipient } from "../transfer";
 import { addAuthOptions } from "./authOptions";
-import { prepareContext } from "../context";
+import { prepareAssetHubContext, buildDotnsContext, buildReadOnlyDotnsContext } from "../context";
+import { makeOnStatus } from "../txStatus";
 import { prepareReadOnlyContext } from "./lookup";
 import {
   getMergedOptions,
@@ -44,15 +46,14 @@ export function attachDelegateCommands(root: Command) {
       const jsonOutput = getJsonFlag(command);
       try {
         const mergedOptions = getMergedOptions(command, options);
-        const context = await maybeQuiet(jsonOutput, () =>
-          prepareContext({ ...mergedOptions, useRevive: true }),
-        );
+        const context = await maybeQuiet(jsonOutput, () => prepareAssetHubContext(mergedOptions));
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Delegate name\n"));
+        if (!jsonOutput) printCommandHeader("Delegate name");
         const spinner = ora();
+        const ctx = buildDotnsContext(context, { onStatus: makeOnStatus(spinner, "Delegating") });
 
         const delegateAddress = await maybeQuiet(jsonOutput, () =>
-          resolveTransferRecipient(context.clientWrapper!, context.substrateAddress, delegate),
+          resolveTransferRecipient(ctx, delegate),
         );
 
         if (!jsonOutput) {
@@ -61,14 +62,7 @@ export function attachDelegateCommands(root: Command) {
         }
 
         const result = await maybeQuiet(jsonOutput, () =>
-          setNameDelegate(
-            context.clientWrapper!,
-            context.substrateAddress,
-            context.signer,
-            name,
-            delegateAddress as Address,
-            spinner,
-          ),
+          setNameDelegate(ctx, name, delegateAddress as Address),
         );
 
         if (!emitJsonResult(jsonOutput, result)) {
@@ -91,22 +85,15 @@ export function attachDelegateCommands(root: Command) {
       const jsonOutput = getJsonFlag(command);
       try {
         const mergedOptions = getMergedOptions(command, options);
-        const context = await maybeQuiet(jsonOutput, () =>
-          prepareContext({ ...mergedOptions, useRevive: true }),
-        );
+        const context = await maybeQuiet(jsonOutput, () => prepareAssetHubContext(mergedOptions));
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Revoke delegate\n"));
+        if (!jsonOutput) printCommandHeader("Revoke delegate");
         const spinner = ora();
+        const ctx = buildDotnsContext(context, {
+          onStatus: makeOnStatus(spinner, "Revoking delegate on"),
+        });
 
-        const result = await maybeQuiet(jsonOutput, () =>
-          revokeNameDelegate(
-            context.clientWrapper!,
-            context.substrateAddress,
-            context.signer,
-            name,
-            spinner,
-          ),
-        );
+        const result = await maybeQuiet(jsonOutput, () => revokeNameDelegate(ctx, name));
 
         if (!emitJsonResult(jsonOutput, result)) {
           console.log(chalk.gray("  name: ") + chalk.cyan(result.name));
@@ -133,12 +120,11 @@ export function attachDelegateCommands(root: Command) {
           prepareReadOnlyContext(mergedOptions as never),
         );
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Delegate status\n"));
+        if (!jsonOutput) printCommandHeader("Delegate status");
         const spinner = ora();
+        const ctx = buildReadOnlyDotnsContext(context, { onStatus: makeOnStatus(spinner) });
 
-        const delegate = await maybeQuiet(jsonOutput, () =>
-          getNameDelegate(context.clientWrapper!, context.account.address, name, spinner),
-        );
+        const delegate = await maybeQuiet(jsonOutput, () => getNameDelegate(ctx, name));
 
         if (!emitJsonResult(jsonOutput, { name, delegate })) {
           if (delegate === null) {
@@ -167,35 +153,27 @@ export function attachDelegateCommands(root: Command) {
       const jsonOutput = getJsonFlag(command);
       try {
         const mergedOptions = getMergedOptions(command, options);
-        const context = await maybeQuiet(jsonOutput, () =>
-          prepareContext({ ...mergedOptions, useRevive: true }),
-        );
+        const context = await maybeQuiet(jsonOutput, () => prepareAssetHubContext(mergedOptions));
 
         const approved = !options.revoke;
         if (!jsonOutput) {
-          console.log(
-            chalk.bold(approved ? "\n▶ Delegate records\n" : "\n▶ Revoke record delegate\n"),
-          );
+          printCommandHeader(approved ? "Delegate records" : "Revoke record delegate");
         }
         const spinner = ora();
+        const ctx = buildDotnsContext(context, {
+          onStatus: makeOnStatus(spinner, "Delegating record control to"),
+        });
 
         const operatorAddress = await maybeQuiet(jsonOutput, () =>
-          resolveTransferRecipient(context.clientWrapper!, context.substrateAddress, operator),
+          resolveTransferRecipient(ctx, operator),
         );
 
         if (!jsonOutput) {
           console.log(chalk.gray("  operator: ") + chalk.white(operatorAddress));
         }
 
         const result = await maybeQuiet(jsonOutput, () =>
-          setRecordDelegate(
-            context.clientWrapper!,
-            context.substrateAddress,
-            context.signer,
-            operatorAddress as Address,
-            approved,
-            spinner,
-          ),
+          setRecordDelegate(ctx, operatorAddress as Address, approved),
         );
 
         if (!emitJsonResult(jsonOutput, result)) {
@@ -222,20 +200,16 @@ export function attachDelegateCommands(root: Command) {
           prepareReadOnlyContext(mergedOptions as never),
         );
 
-        if (!jsonOutput) console.log(chalk.bold("\n▶ Record delegate status\n"));
+        if (!jsonOutput) printCommandHeader("Record delegate status");
         const spinner = ora();
+        const ctx = buildReadOnlyDotnsContext(context, { onStatus: makeOnStatus(spinner) });
 
         const operatorAddress = await maybeQuiet(jsonOutput, () =>
-          resolveTransferRecipient(context.clientWrapper!, context.account.address, operator),
+          resolveTransferRecipient(ctx, operator),
         );
 
         const approved = await maybeQuiet(jsonOutput, () =>
-          getRecordDelegate(
-            context.clientWrapper!,
-            context.account.address,
-            operatorAddress as Address,
-            spinner,
-          ),
+          getRecordDelegate(ctx, operatorAddress as Address),
         );
 
         if (!emitJsonResult(jsonOutput, { operator: operatorAddress, approved })) {