Class PrometheusPlugin

save/save.ts:105–1468

      .replace(/[^a-zA-Z0-9_\-.\u4e00-\u9fff]+/g, "_")
      .replace(/_+/g, "_")
      .replace(/^_+|_+$/g, "")
      .slice(0, 80);

    return sanitized || fallback;
  }

  private getLocalSaveRoot(): string {
    return path.join(process.cwd(), "save");
  }

  private buildUniquePath(dirPath: string, fileName: string): string {
    const parsed = path.parse(fileName);
    const baseName = parsed.name || "file";
    const extension = parsed.ext || "";
    let candidate = path.join(dirPath, `${baseName}${extension}`);
    let counter = 1;

    while (existsSync(candidate)) {
      candidate = path.join(dirPath, `${baseName}_${counter}${extension}`);
      counter++;
    }

    return candidate;
  }

  private async moveFile(sourcePath: string, destinationPath: string): Promise<void> {
    try {
      await fs.rename(sourcePath, destinationPath);
    } catch {
      await fs.copyFile(sourcePath, destinationPath);
      await fs.unlink(sourcePath);
    }
  }

  private async saveLocalMetadata(filePath: string, metadata: Record<string, unknown>): Promise<string> {
    const parsed = path.parse(filePath);
    const metadataPath = this.buildUniquePath(parsed.dir, `${parsed.name}.json`);
    await fs.writeFile(metadataPath, JSON.stringify(metadata, null, 2), "utf8");
    return metadataPath;
  }

  private async ensureLocalChatDirectory(chatId: string): Promise<{ rootDir: string; chatDir: string; displayName: string }> {
    const rootDir = this.getLocalSaveRoot();
    await fs.mkdir(rootDir, { recursive: true });

    const displayName = await this.getChatDisplayName(chatId);
    const dirName = this.sanitizePathSegment(chatId, "chat");
    const chatDir = path.join(rootDir, dirName);
    await fs.mkdir(chatDir, { recursive: true });

    return { rootDir, chatDir, displayName };
  }

  private getLocalChatRelativeDirectory(chatId: string): string {
    const chatDir = path.join(this.getLocalSaveRoot(), this.sanitizePathSegment(chatId, "chat"));
    return path.relative(process.cwd(), chatDir) || chatDir;
  }