@corespeed/zypher@0.4.4

Built and signed on GitHub Actions

Built and signed on GitHub Actions

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
import * as path from "jsr:@std/path@^1.1.2";
import type { Message } from "../message.ts";
import { isMessage } from "../message.ts";
import { formatError } from "../error.ts";
import type { ZypherContext } from "../ZypherAgent.ts";

/**
 * Checks if a file exists and is readable.
 *
 * @param {string} path - Path to the file to check
 * @returns {Promise<boolean>} True if file exists and is readable, false otherwise
 */
export async function fileExists(path: string): Promise<boolean> {
  try {
    await Deno.stat(path);
    return true;
  } catch {
    return false;
  }
}

/**
 * Loads the message history for the current workspace.
 * Each workspace has its own message history file based on its path.
 *
 * @returns {Promise<Message[]>} Array of messages from history, empty array if no history exists
 */
export async function loadMessageHistory(
  context: ZypherContext,
): Promise<Message[]> {
  try {
    const historyPath = path.join(context.workspaceDataDir, "history.json");

    // Check if file exists before trying to read it
    if (!(await fileExists(historyPath))) {
      return [];
    }

    const content = await Deno.readTextFile(historyPath);
    const parsedData: unknown = JSON.parse(content);

    // Validate that parsedData is an array
    if (!Array.isArray(parsedData)) {
      console.warn("Message history is not an array, returning empty array");
      return [];
    }

    // Filter out invalid messages using the isMessage type guard
    const messages: Message[] = parsedData.filter((item): item is Message => {
      const valid = isMessage(item);
      if (!valid) {
        console.warn(
          "Found invalid message in history, filtering it out:",
          item,
        );
      }
      return valid;
    });

    return messages;
  } catch (error) {
    console.warn(
      `Failed to load message history: ${
        formatError(error)
      }, falling back to empty history`,
    );
    return [];
  }
}

/**
 * Saves the message history for the current workspace.
 * Creates a new history file if it doesn't exist, or updates the existing one.
 *
 * @param {Message[]} messages - Array of messages to save
 * @returns {Promise<void>}
 */
export async function saveMessageHistory(
  messages: Message[],
  context: ZypherContext,
): Promise<void> {
  const historyPath = path.join(context.workspaceDataDir, "history.json");
  await Deno.writeTextFile(historyPath, JSON.stringify(messages, null, 2));
}