fix

Author: signorecello

tooling/sparta/src/clients/discord.ts

@@ -17,6 +17,7 @@ import {
 import nodeOperatorCommands from "../roles/nodeOperators/index.js";
 import adminsCommands from "../roles/admins/index.js";
 import { logger } from "../utils/logger.js";
+import { subscribe } from "diagnostics_channel";
 
 // Extended Discord client interface with commands collection
 export interface ExtendedClient extends Client {
@@ -95,25 +96,33 @@ export class Discord {
 			const command = client.commands.get(interaction.commandName);
 			if (!command) return;
 
+			logger.debug(
+				{
+					command: interaction.commandName,
+					subcommand: interaction.options.getSubcommand(),
+				},
+				"Command"
+			);
 			try {
 				const channel = interaction.channel as TextChannel;
 
-				const reply = await command.execute(interaction);
-				logger.info(
+				logger.debug(
 					{
-						name: interaction.commandName,
 						channel: channel.name,
 						user: interaction.user.username,
 						date: interaction.createdAt,
-						result: reply,
 					},
-					"Command executed"
+					"Command info"
 				);
-			} catch (error) {
-				logger.error(
-					{ error, command: interaction.commandName },
-					"Error executing command"
+				const reply = await command.execute(interaction);
+				logger.debug(
+					{
+						reply,
+					},
+					"Command reply"
 				);
+			} catch (error) {
+				logger.error({ error }, "Error executing command");
 				await interaction.reply({
 					content: "There was an error executing this command!",
 					flags: MessageFlags.Ephemeral,

tooling/sparta/src/clients/google.ts

@@ -107,7 +107,7 @@ export class GoogleSheet {
 			row: number,
 			rowData: any[]
 		) => void,
-		intervalMs: number = 1000
+		intervalMs: number = 10000
 	): void {
 		logger.info(
 			{ columnIndexes, sheetRange, intervalMs },
@@ -192,7 +192,6 @@ export class GoogleSheet {
 		range: string
 	): Promise<any[][]> {
 		try {
-			logger.debug({ spreadsheetId, range }, "Fetching sheet data");
 			const response = await this.sheets.spreadsheets.values.get({
 				spreadsheetId,
 				range,

tooling/sparta/src/package.json

@@ -4,7 +4,7 @@
   "type": "module",
   "scripts": {
     "build": "FOUNDRY_DISABLE_NIGHTLY_WARNING=true bun build index.ts --target bun --minify --outdir=dist",
-    "dev": "FOUNDRY_DISABLE_NIGHTLY_WARNING=true bun run --watch index.ts",
+    "dev": "LOG_LEVEL=debug FOUNDRY_DISABLE_NIGHTLY_WARNING=true bun run --watch index.ts",
     "start": "FOUNDRY_DISABLE_NIGHTLY_WARNING=true bun run index.ts",
     "watch": "FOUNDRY_DISABLE_NIGHTLY_WARNING=true tsc -w",
     "lint": "eslint . --ext .ts",

tooling/sparta/src/roles/nodeOperators/chainInfo/get.ts

@@ -1,16 +1,63 @@
-import { ChatInputCommandInteraction } from "discord.js";
+import {
+	ChatInputCommandInteraction,
+	DiscordAPIError,
+	MessageFlags,
+	TextChannel,
+} from "discord.js";
 import { ChainInfoService } from "../../../services/chaininfo-service.js";
-
 export const get = async (
 	interaction: ChatInputCommandInteraction
-): Promise<void> => {
-	const info = await ChainInfoService.getInfo();
-	const { validators, committee } = info;
+): Promise<string> => {
+	const {
+		pendingBlockNum,
+		provenBlockNum,
+		currentEpoch,
+		currentSlot,
+		proposerNow,
+	} = await ChainInfoService.getInfo();
+	const channel = interaction.channel as TextChannel;
+	const messages = await channel.messages.fetch({
+		limit: 15,
+	});
+
+	// Filter for bot messages that look like chain info responses
+	// and aren't the current interaction's response
+	const botMessages = messages.filter(
+		(m) =>
+			m.author.id === interaction.client.user?.id &&
+			m.content.includes("Pending block:") &&
+			m.content.includes("Proven block:") &&
+			m.content.includes("Current epoch:") &&
+			!m.flags.has(MessageFlags.Ephemeral) &&
+			// Ensure we don't delete the message we're about to send
+			m.id !== interaction.id
+	);
 
-	let reply = `Current validators: ${validators.join(", ")}\n`;
-	reply += `Current committee: ${committee.join(", ")}`;
+	if (botMessages.size > 0) {
+		try {
+			// Try bulk delete first (only works for messages less than 14 days old)
+			await channel.bulkDelete(botMessages);
+		} catch (error) {
+			// If bulk delete fails (e.g., messages are too old), delete individually
+			if (error instanceof DiscordAPIError && error.code === 50034) {
+				for (const message of botMessages.values()) {
+					try {
+						await message.delete();
+					} catch (deleteError) {
+						console.error(
+							"Error deleting individual message:",
+							deleteError
+						);
+					}
+				}
+			} else {
+				throw error;
+			}
+		}
+	}
 
-	await interaction.editReply({
-		content: reply,
+	await interaction.reply({
+		content: `Pending block: ${pendingBlockNum}\nProven block: ${provenBlockNum}\nCurrent epoch: ${currentEpoch}\nCurrent slot: ${currentSlot}\nProposer now: ${proposerNow}`,
 	});
+	return `Pending block: ${pendingBlockNum}\nProven block: ${provenBlockNum}\nCurrent epoch: ${currentEpoch}\nCurrent slot: ${currentSlot}\nProposer now: ${proposerNow}`;
 };

tooling/sparta/src/roles/nodeOperators/chainInfo/index.ts

@@ -18,31 +18,25 @@ export default {
 				.setName(NodeOperatorSubcommands.ChainInfo)
 				.setDescription("Get chain information")
 		),
-	execute: async (
-		interaction: ChatInputCommandInteraction
-	): Promise<string> => {
+	execute: async (interaction: ChatInputCommandInteraction) => {
 		try {
-			await interaction.deferReply({ flags: MessageFlags.Ephemeral });
-
 			const subcommand = interaction.options.getSubcommand();
 			switch (subcommand) {
 				case NodeOperatorSubcommands.ChainInfo:
 					await get(interaction);
-					return `Retrieved chain info`;
+					break;
 				default:
 					await interaction.editReply({
-						content: `Unknown subcommand: ${subcommand}`,
+						content: `Invalid subcommand: ${subcommand}`,
 					});
-					return `Unknown subcommand`;
+					return;
 			}
 		} catch (error) {
 			await interaction.editReply({
-				content: `Failed with error: ${
-					error instanceof Error ? error.message : "Unknown error"
-				}`,
+				content: `Failed with error: ${error}`,
 			});
 			return `Failed with error: ${
-				error instanceof Error ? error.message : "Unknown error"
+				error instanceof Error && error.message
 			}`;
 		}
 	},