clusters

.apprc

@@ -1,5 +1,6 @@
 {
   "cli": {
+    "cluster_id": "main",
     "funding": {
       "chain": "eth",
       "filters": [

.gitignore

@@ -22,4 +22,5 @@ reports/
 master_key
 .apprc
 .secretsrc
-.secrets
+.secrets
+clusters/

docs/profile.md

@@ -51,6 +51,5 @@ make recover
 Decrypt
 
 ```sh
-make decrypt in=.profiles out=.profiles.json
+make decrypt in=clusters/main/.profiles out=clusters/main/.profiles.json
 ```
-

src/cli/profiles.ts

@@ -1,12 +1,10 @@
 import { createProfiles } from "src/core/profiles";
 import { getAppConf } from "src/libs/configs";
-import { getMasterKey } from "src/libs/shared";
 import { logger } from "src/logger";
 
 (async function main() {
   logger.info("initiated", { label: "CLI::profiles" });
   const conf = await getAppConf();
-  const masterKey = await getMasterKey();
-  await createProfiles(conf.cli.profiles.amount, conf.cli.profiles.chains, masterKey);
+  await createProfiles(conf.cli.profiles.amount, conf.cli.profiles.chains);
   logger.info("finished", { label: "CLI::profiles" });
 })();

src/cli/recover.ts

@@ -1,12 +1,10 @@
 import { recoverProfiles } from "src/core/profiles";
 import { getAppConf } from "src/libs/configs";
-import { getMasterKey } from "src/libs/shared";
 import { logger } from "src/logger";
 
 (async function main() {
   logger.info("initiated", { label: "CLI::recover" });
   const conf = await getAppConf();
-  const masterKey = await getMasterKey();
-  await recoverProfiles(conf.cli.profiles.chains, masterKey);
+  await recoverProfiles(conf.cli.profiles.chains);
   logger.info("finished", { label: "CLI::recover" });
 })();

src/core/profiles/profiles.ts

@@ -4,8 +4,7 @@ import { genBtc } from "./btc";
 import { genTia, genAtom } from "./cosmos";
 import { genEVM } from "./evm";
 import { genSol } from "./sol";
-import { getProfiles } from "src/libs/configs";
-import { encrypt } from "src/libs/crypt";
+import { getProfilesSafe, saveProfiles } from "src/libs/configs";
 import { Networks, Profile, NetworkWallet } from "src/types/configs";
 
 const networksMap = {
@@ -27,10 +26,9 @@ const genAll = (seed: Buffer, networks: Networks[]) =>
     {} as Record<Networks, NetworkWallet>,
   );
 
-const generateAndSave = async (mnemonics: string[], networks: Networks[], masterKey: string) => {
-  const addProfiles = fs.existsSync(".profiles.json");
-  const profiles = addProfiles ? await getProfiles() : {};
-  const offsetIndex = addProfiles ? Number(Object.keys(profiles).sort((a, b) => Number(b) - Number(a))[0]) + 1 : 0;
+const generateAndSave = async (mnemonics: string[], networks: Networks[]) => {
+  const profiles = await getProfilesSafe();
+  const offsetIndex = profiles.length ? Number(Object.keys(profiles).sort((a, b) => Number(b) - Number(a))[0]) + 1 : 0;
   const data = mnemonics.reduce((acc, mnemonic, i) => {
     const seed = bip39.mnemonicToSeedSync(mnemonic);
     acc[i + offsetIndex] = {
@@ -39,24 +37,15 @@ const generateAndSave = async (mnemonics: string[], networks: Networks[], master
     };
     return acc;
   }, {} as Profile);
-  fs.writeFileSync(
-    ".profiles",
-    encrypt(
-      JSON.stringify({
-        ...profiles,
-        ...data,
-      }),
-      masterKey,
-    ),
-  );
+  saveProfiles({
+    ...profiles,
+    ...data,
+  });
 };
 
-export const createProfiles = (amount: number, networks: Networks[], masterKey: string) =>
-  generateAndSave(
-    Array.from({ length: amount }).map(() => bip39.generateMnemonic()),
-    networks,
-    masterKey,
-  );
+const genMnemonics = (amount: number) => Array.from({ length: amount }).map(() => bip39.generateMnemonic());
+
+export const createProfiles = (amount: number, networks: Networks[]) => generateAndSave(genMnemonics(amount), networks);
 
-export const recoverProfiles = (networks: Networks[], masterKey: string) =>
-  generateAndSave(JSON.parse(fs.readFileSync(".mnemonics.json", "utf-8")) as string[], networks, masterKey);
+export const recoverProfiles = (networks: Networks[]) =>
+  generateAndSave(JSON.parse(fs.readFileSync(".mnemonics.json", "utf-8")) as string[], networks);

src/core/reports/mainnet/mainnetReport.ts

@@ -1,7 +1,7 @@
 import axiosRetry from "axios-retry";
 import * as chains from "viem/chains";
 import { getFuelReport } from "./fuel";
-import { getProfiles } from "src/libs/configs";
+import { getProfiles, operationFolder } from "src/libs/configs";
 import { getFormattedPortfolio } from "src/libs/portfolio";
 import { refreshProxy } from "src/libs/proxify";
 import { saveInFolder, getRandomArbitrary } from "src/libs/shared";
@@ -53,6 +53,7 @@ export async function mainnetReport({ save, params }: { save: boolean; params: s
   }
 
   if (save) {
-    saveInFolder("./reports/mainnet.report.json", JSON.stringify(report, null, 2));
+    const folder = await operationFolder();
+    saveInFolder(`${folder}/reports/mainnet.report.json`, JSON.stringify(report, null, 2));
   }
 }

src/core/reports/scroll/scrollReport.ts

@@ -3,7 +3,7 @@ import { scroll } from "viem/chains";
 import { isProfileMinted } from "./canvas";
 import { getLpStats } from "./nuri";
 import { accountPoints } from "./points";
-import { getProfiles } from "src/libs/configs";
+import { getProfiles, operationFolder } from "src/libs/configs";
 import { getFormattedPortfolio } from "src/libs/portfolio";
 import { refreshProxy } from "src/libs/proxify";
 import { saveInFolder, getRandomArbitrary } from "src/libs/shared";
@@ -45,6 +45,7 @@ export async function scrollReport({ save }: { save: boolean }) {
     Promise.resolve({}),
   );
   if (save) {
-    saveInFolder("./reports/scroll.report.json", JSON.stringify(data, null, 2));
+    const folder = await operationFolder();
+    saveInFolder(`${folder}/reports/scroll.report.json`, JSON.stringify(data, null, 2));
   }
 }

src/libs/configs.ts

@@ -1,7 +1,8 @@
-import { readFileSync } from "node:fs";
+import { readFileSync, existsSync } from "node:fs";
 import { resolve } from "node:path";
-import { decryptJson } from "./crypt";
-import { getMasterKey } from "./shared";
+import { decryptJson, encrypt } from "./crypt";
+import { getMasterKey, saveInFolder } from "./shared";
+import { logger } from "src/logger";
 import { JsonObj } from "src/types/common";
 import { AppConfig, Profile, EVMWallet } from "src/types/configs";
 
@@ -22,13 +23,43 @@ let profiles: Profile;
 
 export const getProfiles = async () => {
   if (!profiles) {
+    const folder = await operationFolder();
     const masterKey = await getMasterKey();
-    profiles = decryptJson(readFileSync(resolve(".", ".profiles"), "utf-8").trimEnd(), masterKey) as Profile;
+    profiles = decryptJson(readFileSync(`${folder}/.profiles`, "utf-8").trimEnd(), masterKey) as Profile;
   }
   return profiles;
 };
 
-export const getEVMWallets = async () =>
-  Object.values(await getProfiles()).map(({ wallets }) => ({
-    ...(wallets.evm as EVMWallet),
-  }));
+export const getProfilesSafe = async () => {
+  const folder = await operationFolder();
+  const profilesExist = existsSync(`${folder}/.profiles`);
+  if (profilesExist) {
+    return getProfiles();
+  }
+  logger.warn(`.profiles file is not exist for path ${folder}/.profiles, return empty`, {
+    label: "utils/getProfilesSafe",
+  });
+  return {};
+};
+
+export const saveProfiles = async (profiles: Profile) => {
+  const masterKey = await getMasterKey();
+  const folder = await operationFolder();
+  return saveInFolder(`${folder}/.profiles`, encrypt(JSON.stringify(profiles), masterKey));
+};
+
+let wallets: EVMWallet[];
+
+export const getEVMWallets = async () => {
+  if (!wallets) {
+    wallets = Object.values(await getProfiles()).map(({ wallets }) => ({
+      ...(wallets.evm as EVMWallet),
+    }));
+  }
+  return wallets;
+};
+
+export const operationFolder = async () => {
+  const appConfig = await getAppConf();
+  return `clusters/${appConfig.cli.cluster_id}`;
+};

src/libs/shared.ts

@@ -16,13 +16,11 @@ export const getRandomArbitrary = (min: number, max: number) => {
 };
 
 export const saveInFolder = (savePath: string, data: string) => {
-  const parsedPath = savePath.split("/");
-  const clearPath = parsedPath
-    .slice(0, -1)
-    .filter((folderName) => !!folderName)
-    .join("/");
+  const parsedPath = savePath.split("/").filter((folderName) => !!folderName);
+  const clearPath = parsedPath.slice(0, -1).join("/");
   if (!existsSync(clearPath)) {
-    mkdirSync(clearPath);
+    logger.debug(`clearPath : ${clearPath}`, { label: "saveInFolder" });
+    mkdirSync(clearPath, { recursive: true });
   }
   writeFileSync(savePath, data);
 };

src/types/configs.ts

@@ -3,20 +3,20 @@ import { OKX_WITHDRAW_CHAINS } from "src/constants/okx";
 export type Networks = "btc" | "evm" | "sol" | "tia" | "atom";
 
 export type NetworkWallet = {
-  address?: string;
-  pkᵻ: string;
+  readonly address?: string;
+  readonly pkᵻ: string;
 };
 
-export type EVMWallet = { address: `0x${string}`; pkᵻ: `0x${string}` };
+export type EVMWallet = { readonly address: `0x${string}`; readonly pkᵻ: `0x${string}` };
 
 export type Wallet = {
-  [key in Networks]: NetworkWallet;
+  readonly [key in Networks]: NetworkWallet;
 };
 
 export type Profile = {
   [id: string]: {
-    wallets: Wallet;
-    mnemonicᵻ: string;
+    readonly wallets: Wallet;
+    readonly mnemonicᵻ: string;
   };
 };
 
@@ -26,49 +26,50 @@ export type ReportConf = {
 };
 
 export type AppConfig = {
-  proxy: {
-    userᵻ: string;
-    passᵻ: string;
-    hostᵻ: string;
-    portᵻ: string;
-    "reboot-linkᵻ": string;
+  readonly proxy: {
+    readonly userᵻ: string;
+    readonly passᵻ: string;
+    readonly hostᵻ: string;
+    readonly portᵻ: string;
+    readonly "reboot-linkᵻ": string;
   };
-  rpc: {
-    alchemy: {
-      keyᵻ: string;
+  readonly rpc: {
+    readonly alchemy: {
+      readonly keyᵻ: string;
     };
-    qnode: {
-      keyᵻ: string;
+    readonly qnode: {
+      readonly keyᵻ: string;
     };
   };
-  okx: {
-    keyᵻ: string;
-    secretᵻ: string;
-    passwordᵻ: string;
+  readonly okx: {
+    readonly keyᵻ: string;
+    readonly secretᵻ: string;
+    readonly passwordᵻ: string;
   };
-  randommer: {
-    keyᵻ: string;
+  readonly randommer: {
+    readonly keyᵻ: string;
   };
-  cli: {
-    funding: {
-      chain: keyof typeof OKX_WITHDRAW_CHAINS;
-      filters: ("noFuel" | "onlyZero" | "lteBalance")[];
-      depositRange: [number, number];
-      lteBalance?: number;
-      maxFee: number;
+  readonly cli: {
+    readonly cluster_id: string;
+    readonly funding: {
+      readonly chain: keyof typeof OKX_WITHDRAW_CHAINS;
+      readonly filters: ("noFuel" | "onlyZero" | "lteBalance")[];
+      readonly depositRange: [number, number];
+      readonly lteBalance?: number;
+      readonly maxFee: number;
     };
-    fuel: {
-      minDeposit: number;
+    readonly fuel: {
+      readonly minDeposit: number;
     };
-    scroll: {
-      kelp: {
-        minDeposit: number;
+    readonly scroll: {
+      readonly kelp: {
+        readonly minDeposit: number;
       };
     };
-    report: ReportConf;
-    profiles: {
-      amount: number;
-      chains: Networks[];
+    readonly report: ReportConf;
+    readonly profiles: {
+      readonly amount: number;
+      readonly chains: Networks[];
     };
   };
 };