diff --git a/common/protocol/src/methods/helpers/archiveDebugBundle.ts b/common/protocol/src/methods/helpers/archiveDebugBundle.ts index 26fd771d..6fb133f4 100644 --- a/common/protocol/src/methods/helpers/archiveDebugBundle.ts +++ b/common/protocol/src/methods/helpers/archiveDebugBundle.ts @@ -2,8 +2,8 @@ import { existsSync, mkdirSync, createWriteStream, readFileSync } from "fs"; import path from "path"; import { DataItem, standardizeError, Validator } from "../.."; import JSZip from "jszip"; -import * as Diff from "diff"; import { VoteType } from "@kyvejs/types/client/kyve/bundles/v1beta1/tx"; +import Diff from "diff"; /** * archiveDebugBundle is used for storing a bundle for debug @@ -25,88 +25,76 @@ export function archiveDebugBundle( metadata: object ): void { try { - this.logger.info("Archiving debug bundle"); - - // if "debug" folder under target path does not exist create it - if (!existsSync(path.join(this.home, `debug`))) { - mkdirSync(path.join(this.home, `debug`), { recursive: true }); - } - - const zip = new JSZip(); - - // save metadata which includes vote reasons and args - const metadata_str = JSON.stringify(metadata || {}, null, 2); - zip.file("metadata.json", metadata_str); - - // save current pool state including the raw bundle proposal - const pool_str = JSON.stringify(this.pool || {}, null, 2); - zip.file("pool.json", pool_str); - - // save the proposed bundle from the uploader - const proposed_bundle_str = JSON.stringify(proposedBundle || [], null, 2); - zip.file("proposed_bundle.json", proposed_bundle_str); - - // save the locally created bundle from this node - const validation_bundle_str = JSON.stringify( - validationBundle || [], - null, - 2 - ); - zip.file("validation_bundle.json", validation_bundle_str); - - // save the diff of the proposed and local bundle - const diff_str = Diff.createTwoFilesPatch( - "proposed_bundle.json", - "validation_bundle.json", - proposed_bundle_str, - validation_bundle_str - ); - zip.file("diff.txt", diff_str); - - // save the logfile of the current session - const debug_str = readFileSync(path.join(this.home, "logs", this.logFile)); - zip.file("debug.log", debug_str); - - // get human readable vote - let voteType = ""; - - switch (vote) { - case VoteType.VOTE_TYPE_VALID: - voteType = "valid"; - break; - case VoteType.VOTE_TYPE_INVALID: - voteType = "invalid"; - break; - case VoteType.VOTE_TYPE_ABSTAIN: - voteType = "abstain"; - break; - case VoteType.VOTE_TYPE_UNSPECIFIED: - voteType = "unspecified"; - break; - default: - voteType = "unrecognized"; - } - - const storageId = this.pool?.bundle_proposal?.storage_id ?? ""; - const zipPath = path.join( - this.home, - `debug`, - `${voteType}_${this.pool.id}_${Math.floor( - Date.now() / 1000 - )}_${storageId.slice(0, 6)}.zip` - ); - - // save zip file - zip - .generateNodeStream({ type: "nodebuffer", streamFiles: true }) - .pipe(createWriteStream(zipPath)) - .on("finish", () => { - this.logger.info("Successfully saved debug information"); - }) - .on("error", (err) => { - this.logger.error("Failed to save debug information"); - this.logger.error(standardizeError(err)); - }); + // this.logger.info("Archiving debug bundle"); + // // if "debug" folder under target path does not exist create it + // if (!existsSync(path.join(this.home, `debug`))) { + // mkdirSync(path.join(this.home, `debug`), { recursive: true }); + // } + // const zip = new JSZip(); + // // save metadata which includes vote reasons and args + // const metadata_str = JSON.stringify(metadata || {}, null, 2); + // zip.file("metadata.json", metadata_str); + // // save current pool state including the raw bundle proposal + // const pool_str = JSON.stringify(this.pool || {}, null, 2); + // zip.file("pool.json", pool_str); + // // save the proposed bundle from the uploader + // const proposed_bundle_str = JSON.stringify(proposedBundle || [], null, 2); + // zip.file("proposed_bundle.json", proposed_bundle_str); + // // save the locally created bundle from this node + // const validation_bundle_str = JSON.stringify( + // validationBundle || [], + // null, + // 2 + // ); + // zip.file("validation_bundle.json", validation_bundle_str); + // // save the diff of the proposed and local bundle + // const diff_str = Diff.createTwoFilesPatch( + // "proposed_bundle.json", + // "validation_bundle.json", + // proposed_bundle_str, + // validation_bundle_str + // ); + // zip.file("diff.txt", diff_str); + // // save the logfile of the current session + // const debug_str = readFileSync(path.join(this.home, "logs", this.logFile)); + // zip.file("debug.log", debug_str); + // // get human readable vote + // let voteType = ""; + // switch (vote) { + // case VoteType.VOTE_TYPE_VALID: + // voteType = "valid"; + // break; + // case VoteType.VOTE_TYPE_INVALID: + // voteType = "invalid"; + // break; + // case VoteType.VOTE_TYPE_ABSTAIN: + // voteType = "abstain"; + // break; + // case VoteType.VOTE_TYPE_UNSPECIFIED: + // voteType = "unspecified"; + // break; + // default: + // voteType = "unrecognized"; + // } + // const storageId = this.pool?.bundle_proposal?.storage_id ?? ""; + // const zipPath = path.join( + // this.home, + // `debug`, + // `${voteType}_${this.pool.id}_${Math.floor( + // Date.now() / 1000 + // )}_${storageId.slice(0, 6)}.zip` + // ); + // // save zip file + // zip + // .generateNodeStream({ type: "nodebuffer", streamFiles: true }) + // .pipe(createWriteStream(zipPath)) + // .on("finish", () => { + // this.logger.info("Successfully saved debug information"); + // }) + // .on("error", (err) => { + // this.logger.error("Failed to save debug information"); + // this.logger.error(standardizeError(err)); + // }); } catch (err) { this.logger.error("Failed to save debug information"); this.logger.error(standardizeError(err));