refactor(logging): migrate from CCLog to structured logger

src/accesscontrol/cli.ts

@@ -1,6 +1,5 @@
 import { Command, createCli } from "@/lib/ccCLI";
 import { Ok } from "@/lib/thirdparty/ts-result-es";
-import { CCLog } from "@/lib/ccLog";
 import {
     AccessConfig,
     UserGroupConfig,
@@ -8,12 +7,13 @@ import {
     saveConfig,
 } from "./config";
 import { parseBoolean } from "@/lib/common";
+import { Logger } from "@/lib/ccStructLog";
 
 // 1. Define AppContext
 export interface AppContext {
     configFilepath: string;
     reloadConfig: () => void;
-  logger: CCLog;
+    logger: Logger;
     print: (
         message: string | MinecraftTextComponent | MinecraftTextComponent[],
     ) => void;
@@ -48,7 +48,9 @@ const addCommand: Command<AppContext> = {
                 config.adminGroupConfig.groupUsers.push(playerName);
             }
         } else {
-      const group = config.usersGroups.find((g) => g.groupName === groupName);
+            const group = config.usersGroups.find(
+                (g) => g.groupName === groupName,
+            );
             if (!group) {
                 const groupNames = getGroupNames(config);
                 context.print({
@@ -107,7 +109,9 @@ const delCommand: Command<AppContext> = {
         }
 
         if (group.groupUsers !== undefined) {
-      group.groupUsers = group.groupUsers.filter((user) => user !== playerName);
+            group.groupUsers = group.groupUsers.filter(
+                (user) => user !== playerName,
+            );
         }
 
         saveConfig(config, context.configFilepath);
@@ -238,7 +242,10 @@ const configCommand: Command<AppContext> = {
         { name: "value", description: "要设置的值", required: true },
     ],
     action: ({ args, context }) => {
-    const [option, valueStr] = [args.option as string, args.value as string];
+        const [option, valueStr] = [
+            args.option as string,
+            args.value as string,
+        ];
         const config = loadConfig(context.configFilepath)!;
 
         // Check if it's a group property (contains a dot)
@@ -251,7 +258,9 @@ const configCommand: Command<AppContext> = {
             if (groupName === "admin") {
                 groupConfig = config.adminGroupConfig;
             } else {
-        groupConfig = config.usersGroups.find((g) => g.groupName === groupName);
+                groupConfig = config.usersGroups.find(
+                    (g) => g.groupName === groupName,
+                );
             }
 
             if (!groupConfig) {
@@ -321,7 +330,9 @@ const configCommand: Command<AppContext> = {
                 const value = parseInt(valueStr);
 
                 if (isNaN(value)) {
-          context.print({ text: `无效的值: ${valueStr}. 必须是一个数字。` });
+                    context.print({
+                        text: `无效的值: ${valueStr}. 必须是一个数字。`,
+                    });
                     return Ok.EMPTY;
                 }
 

src/accesscontrol/main.ts

@@ -11,9 +11,12 @@ import {
     ConsoleStream,
     DAY,
     FileStream,
-    Logger,
+    getStructLogger,
+    LoggerOptions,
     LogLevel,
+    MB,
     processor,
+    setStructLoggerConfig,
     textRenderer,
 } from "@/lib/ccStructLog";
 
@@ -21,7 +24,7 @@ const args = [...$vararg];
 
 // Init Log
 let isOnConsoleStream = true;
-const logger = new Logger({
+const loggerConfig: LoggerOptions = {
     processors: [
         processor.filterByLevel(LogLevel.Info),
         processor.addTimestamp(),
@@ -29,9 +32,19 @@ const logger = new Logger({
     renderer: textRenderer,
     streams: [
         new ConditionalStream(new ConsoleStream(), () => isOnConsoleStream),
-        new FileStream("accesscontrol.log", DAY),
+        new FileStream({
+            filePath: "accesscontrol.log",
+            rotationInterval: DAY,
+            autoCleanup: {
+                enabled: true,
+                maxFiles: 7,
+                maxSizeBytes: MB,
+            },
+        }),
     ],
-});
+};
+setStructLoggerConfig(loggerConfig);
+const logger = getStructLogger();
 
 // Load Config
 const configFilepath = `${shell.dir()}/access.config.json`;
@@ -70,6 +83,11 @@ function reloadConfig() {
     gWatchPlayersInfo = [];
     releaser.release();
     logger.info("Reload config successfully!");
+    const tutorial: string[] = [];
+    tutorial.push("Access Control System started.");
+    tutorial.push("\tPress 'c' to open configuration TUI.");
+    tutorial.push("\tPress 'r' to reload configuration.");
+    print(tutorial.join("\n"));
 }
 
 function safeParseTextComponent(

src/accesscontrol/tui.ts

@@ -99,25 +99,31 @@ const AccessControlTUI = () => {
 
             // Validate numbers
             if (
-        validateNumber(currentConfig.detectInterval?.toString() ?? "") === null
+                validateNumber(
+                    currentConfig.detectInterval?.toString() ?? "",
+                ) === null
             ) {
                 showError("Invalid Detect Interval: must be a number");
                 return;
             }
             if (
-        validateNumber(currentConfig.watchInterval?.toString() ?? "") === null
+                validateNumber(
+                    currentConfig.watchInterval?.toString() ?? "",
+                ) === null
             ) {
                 showError("Invalid Watch Interval: must be a number");
                 return;
             }
             if (
-        validateNumber(currentConfig.noticeTimes?.toString() ?? "") === null
+                validateNumber(currentConfig.noticeTimes?.toString() ?? "") ===
+                null
             ) {
                 showError("Invalid Notice Times: must be a number");
                 return;
             }
             if (
-        validateNumber(currentConfig.detectRange?.toString() ?? "") === null
+                validateNumber(currentConfig.detectRange?.toString() ?? "") ===
+                null
             ) {
                 showError("Invalid Detect Range: must be a number");
                 return;
@@ -153,7 +159,9 @@ const AccessControlTUI = () => {
 
             for (const toastConfig of toastConfigs) {
                 if (toastConfig.value != undefined) {
-          const serialized = textutils.serialiseJSON(toastConfig.value);
+                    const serialized = textutils.serialiseJSON(
+                        toastConfig.value,
+                    );
                     if (!validateTextComponent(serialized)) {
                         showError(
                             `Invalid ${toastConfig.name}: must be valid MinecraftTextComponent JSON`,
@@ -210,7 +218,9 @@ const AccessControlTUI = () => {
             const currentAdmin = config().adminGroupConfig;
             setConfig("adminGroupConfig", {
                 ...currentAdmin,
-        groupUsers: currentAdmin.groupUsers.filter((user) => user !== userName),
+                groupUsers: currentAdmin.groupUsers.filter(
+                    (user) => user !== userName,
+                ),
             });
         } else {
             // Regular group
@@ -268,7 +278,10 @@ const AccessControlTUI = () => {
                     onFocusChanged: () => {
                         const num = validateNumber(getDetectInterval());
                         if (num !== null) setConfig("detectInterval", num);
-            else setDetectInterval(config().detectInterval.toString());
+                        else
+                            setDetectInterval(
+                                config().detectInterval.toString(),
+                            );
                     },
                 }),
             ),
@@ -282,7 +295,8 @@ const AccessControlTUI = () => {
                     onFocusChanged: () => {
                         const num = validateNumber(getWatchInterval());
                         if (num !== null) setConfig("watchInterval", num);
-            else setWatchInterval(config().watchInterval.toString());
+                        else
+                            setWatchInterval(config().watchInterval.toString());
                     },
                 }),
             ),
@@ -347,11 +361,15 @@ const AccessControlTUI = () => {
             div(
                 { class: "flex flex-col" },
                 label({}, "Groups:"),
-        For({ each: () => groups, class: "flex flex-col" }, (group, index) =>
+                For(
+                    { each: () => groups, class: "flex flex-col" },
+                    (group, index) =>
                         button(
                             {
                                 class:
-                selectedGroupIndex() === index() ? "bg-blue text-white" : "",
+                                    selectedGroupIndex() === index()
+                                        ? "bg-blue text-white"
+                                        : "",
                                 onClick: () => setSelectedGroupIndex(index()),
                             },
                             group.groupName,
@@ -489,7 +507,10 @@ const AccessControlTUI = () => {
      * Toast Configuration Tab Factory
      */
     const createToastTab = (
-    toastType: "welcomeToastConfig" | "warnToastConfig" | "noticeToastConfig",
+        toastType:
+            | "welcomeToastConfig"
+            | "warnToastConfig"
+            | "noticeToastConfig",
     ) => {
         return () => {
             const toastConfig = config()[toastType];
@@ -533,7 +554,9 @@ const AccessControlTUI = () => {
                         } catch {
                             setTempToastConfig({
                                 ...getTempToastConfig(),
-                title: textutils.serialiseJSON(currentToastConfig.title),
+                                title: textutils.serialiseJSON(
+                                    currentToastConfig.title,
+                                ),
                             });
                         }
                     },
@@ -545,7 +568,10 @@ const AccessControlTUI = () => {
                     type: "text",
                     value: () => getTempToastConfig().msg,
                     onInput: (value) =>
-            setTempToastConfig({ ...getTempToastConfig(), msg: value }),
+                        setTempToastConfig({
+                            ...getTempToastConfig(),
+                            msg: value,
+                        }),
                     onFocusChanged: () => {
                         const currentToastConfig = config()[toastType];
 
@@ -566,7 +592,9 @@ const AccessControlTUI = () => {
                         } catch {
                             setTempToastConfig({
                                 ...getTempToastConfig(),
-                msg: textutils.serialiseJSON(currentToastConfig.msg),
+                                msg: textutils.serialiseJSON(
+                                    currentToastConfig.msg,
+                                ),
                             });
                             // Invalid JSON, ignore
                         }
@@ -579,13 +607,19 @@ const AccessControlTUI = () => {
                     input({
                         type: "text",
                         value: () => {
-              const str = textutils.serialiseJSON(getTempToastConfig().prefix, {
+                            const str = textutils.serialiseJSON(
+                                getTempToastConfig().prefix,
+                                {
                                     unicode_strings: true,
-              });
+                                },
+                            );
                             return str.substring(1, str.length - 1);
                         },
                         onInput: (value) =>
-              setTempToastConfig({ ...getTempToastConfig(), prefix: value }),
+                            setTempToastConfig({
+                                ...getTempToastConfig(),
+                                prefix: value,
+                            }),
                         onFocusChanged: () => {
                             const currentToastConfig = config()[toastType];
                             setConfig(toastType, {
@@ -603,7 +637,10 @@ const AccessControlTUI = () => {
                         type: "text",
                         value: () => getTempToastConfig().brackets,
                         onInput: (value) =>
-              setTempToastConfig({ ...getTempToastConfig(), brackets: value }),
+                            setTempToastConfig({
+                                ...getTempToastConfig(),
+                                brackets: value,
+                            }),
                         onFocusChanged: () => {
                             const currentToastConfig = config()[toastType];
                             setConfig(toastType, {
@@ -678,7 +715,10 @@ const AccessControlTUI = () => {
                 { when: () => currentTab() === TABS.WELCOME_TOAST },
                 WelcomeToastTab(),
             ),
-      Match({ when: () => currentTab() === TABS.WARN_TOAST }, WarnToastTab()),
+            Match(
+                { when: () => currentTab() === TABS.WARN_TOAST },
+                WarnToastTab(),
+            ),
             Match(
                 { when: () => currentTab() === TABS.NOTICE_TOAST },
                 NoticeToastTab(),
@@ -703,7 +743,10 @@ const AccessControlTUI = () => {
             For({ each: () => tabNames }, (tabName, index) =>
                 button(
                     {
-            class: currentTab() === index() ? "bg-blue text-white" : "",
+                        class:
+                            currentTab() === index()
+                                ? "bg-blue text-white"
+                                : "",
                         onClick: () => setCurrentTab(index() as TabIndex),
                     },
                     tabName,

src/autocraft/main.ts

@@ -6,6 +6,8 @@ import {
 import { Queue } from "@/lib/datatype/Queue";
 import {
     ConsoleStream,
+    DAY,
+    FileStream,
     Logger,
     LogLevel,
     processor,
@@ -18,7 +20,17 @@ const logger = new Logger({
         processor.addTimestamp(),
     ],
     renderer: textRenderer,
-    streams: [new ConsoleStream()],
+    streams: [
+        new ConsoleStream(),
+        new FileStream({
+            filePath: "autocraft.log",
+            rotationInterval: DAY,
+            autoCleanup: {
+                enabled: true,
+                maxFiles: 3,
+            },
+        }),
+    ],
 });
 
 const peripheralsNames = {
@@ -47,7 +59,8 @@ enum State {
 }
 
 function main() {
-    while (true) {
+    let isFinishedInitPeripheral = false;
+    while (!isFinishedInitPeripheral) {
         try {
             packsInventory = peripheral.wrap(
                 peripheralsNames.packsInventory,
@@ -67,7 +80,7 @@ function main() {
             turtleLocalName = wiredModem.getNameLocal();
 
             logger.info("Peripheral initialization complete...");
-            break;
+            isFinishedInitPeripheral = true;
         } catch (error) {
             logger.warn(
                 `Peripheral initialization failed for ${String(error)}, try again...`,

src/lib/ccStructLog/Logger.ts

@@ -4,6 +4,9 @@
  */
 
 import { LogLevel, LoggerOptions, LogEvent, ILogger } from "./types";
+import { processor } from "./processors";
+import { ConsoleStream } from "./streams";
+import { textRenderer } from "./renderers";
 
 /**
  * The main Logger class that orchestrates the logging pipeline.
@@ -13,26 +16,19 @@ import { LogLevel, LoggerOptions, LogEvent, ILogger } from "./types";
  */
 export class Logger implements ILogger {
     private options: LoggerOptions;
+    private loggerName?: string;
 
     /**
      * Create a new Logger instance.
      *
      * @param options - Configuration options for the logger
+     * @param name - The name of the logger
      */
-    constructor(options: Partial<LoggerOptions>) {
-        this.options = {
-            processors: options.processors ?? [],
-            renderer: options.renderer ?? this.defaultRenderer,
-            streams: options.streams ?? [],
-        };
+    constructor(options: LoggerOptions, name?: string) {
+        this.options = options;
+        this.loggerName = name;
     }
 
-    /**
-     * Default renderer that returns an empty string.
-     * Used as fallback when no renderer is provided.
-     */
-    private defaultRenderer = (): string => "";
-
     /**
      * Main logging method that handles the complete logging pipeline.
      *
@@ -51,6 +47,8 @@ export class Logger implements ILogger {
             ["message", message],
             ...Object.entries(context),
         ]);
+        if (this.loggerName !== undefined)
+            event.set("loggerName", this.loggerName);
 
         // 2. Process through the processor chain
         for (const processor of this.options.processors) {
@@ -62,12 +60,11 @@ export class Logger implements ILogger {
 
         // 3. Render and output if event wasn't dropped
         if (event !== undefined) {
-            const finalEvent = event;
-            const output = this.options.renderer(finalEvent);
+            const output = this.options.renderer(event);
 
             // Send to all configured streams
             for (const stream of this.options.streams) {
-                stream.write(output, finalEvent);
+                stream.write(output, event);
             }
         }
     }
@@ -163,3 +160,17 @@ export class Logger implements ILogger {
         }
     }
 }
+
+let globalLoggerConfig: LoggerOptions = {
+    processors: [processor.addTimestamp()],
+    renderer: textRenderer,
+    streams: [new ConsoleStream()],
+};
+
+export function getStructLogger(name?: string): Logger {
+    return new Logger(globalLoggerConfig, name);
+}
+
+export function setStructLoggerConfig(config: LoggerOptions): void {
+    globalLoggerConfig = config;
+}

src/lib/ccStructLog/processors.ts

@@ -61,7 +61,7 @@ export namespace processor {
                 return event; // Pass through if no level is set
             }
 
-            if (eventLevel !== undefined && eventLevel < minLevel) {
+            if (eventLevel < minLevel) {
                 return undefined; // Drop the log event
             }
 
@@ -69,22 +69,6 @@ export namespace processor {
         };
     }
 
-    /**
-     * Adds a logger name/source to the log event.
-     *
-     * This processor is useful when you have multiple loggers in your application
-     * and want to identify which component generated each log entry.
-     *
-     * @param name - The name/source to add to log events
-     * @returns A processor function that adds the source name
-     */
-    export function addSource(name: string): Processor {
-        return (event) => {
-            event.set("source", name);
-            return event;
-        };
-    }
-
     /**
      * Adds the current computer ID to the log event.
      *

src/lib/ccStructLog/renderers.ts

@@ -53,14 +53,20 @@ export const textRenderer: Renderer = (event) => {
     const timeStr = event.get("timestamp") as string | undefined;
     const level: string | undefined = LogLevel[event.get("level") as LogLevel];
     const message = (event.get("message") as string) ?? "";
+    const loggerName = event.get("loggerName") as string | undefined;
 
     // Start building the output
-    let output = `[${timeStr}] [${level}] ${message} \t`;
+    let output = `${timeStr} [${level}] ${message} \t ${loggerName !== undefined ? "[" + loggerName + "]" : ""}`;
 
     // Add context fields (excluding the core fields we already used)
     const contextFields: string[] = [];
     for (const [key, value] of event.entries()) {
-        if (key !== "timestamp" && key !== "level" && key !== "message") {
+        if (
+            key !== "timestamp" &&
+            key !== "level" &&
+            key !== "message" &&
+            key !== "loggerName"
+        ) {
             contextFields.push(`${key}=${tostring(value)}`);
         }
     }

src/lib/ccStructLog/streams.ts

@@ -8,6 +8,33 @@
 
 import { LogLevel, Stream, LogEvent } from "./types";
 
+/**
+ * Configuration interface for FileStream with auto-cleanup options.
+ */
+interface FileStreamConfig {
+    /** Path to the log file */
+    filePath: string;
+    /**
+     * Time in seconds between file rotations (0 = no rotation)
+     * Time must larger than one DAY
+     * @default 0
+     */
+    rotationInterval?: number;
+    /** Auto-cleanup configuration */
+    autoCleanup?: {
+        /** Whether to enable auto-cleanup */
+        enabled: boolean;
+        /** Maximum number of log files to keep */
+        maxFiles?: number;
+        /** Maximum total size in bytes for all log files */
+        maxSizeBytes?: number;
+        /** Directory to search for log files (defaults to log file directory) */
+        logDir?: string;
+        /** File pattern to match (defaults to base filename pattern) */
+        pattern?: string;
+    };
+}
+
 /**
  * Console stream that outputs to the CC:Tweaked terminal.
  *
@@ -59,20 +86,20 @@ export class FileStream implements Stream {
     private filePath: string;
     private rotationInterval: number;
     private lastRotationTime: number;
-    private baseFilename: string;
+    private autoCleanupConfig?: FileStreamConfig["autoCleanup"];
 
     /**
-     * Create a new file stream.
+     * Create a new file stream with configuration object.
      *
-     * @param filePath - Path to the log file
-     * @param rotationInterval - Time in seconds between file rotations (0 = no rotation)
+     * @param config - FileStream configuration object
      */
-    constructor(filePath: string, rotationInterval: number = 0) {
-        this.filePath = filePath;
-        this.rotationInterval = rotationInterval;
+    constructor(config: FileStreamConfig) {
+        this.filePath = config.filePath;
+        this.rotationInterval = config.rotationInterval || 0;
+        if (this.rotationInterval !== 0 && this.rotationInterval < DAY)
+            throw Error("Rotation interval must be at least one day");
+        this.autoCleanupConfig = config.autoCleanup;
         this.lastRotationTime = os.time();
-        this.baseFilename = filePath;
-
         this.openFile();
     }
 
@@ -94,24 +121,27 @@ export class FileStream implements Stream {
             return;
         }
         this.fileHandle = handle;
+
+        // Perform auto-cleanup when opening file
+        this.performAutoCleanup();
     }
 
     /**
      * Generate a filename with timestamp for file rotation.
      */
     private getRotatedFilename(): string {
-        const currentTime = os.time();
+        const currentTime = os.time(os.date("*t"));
         const rotationPeriod =
             Math.floor(currentTime / this.rotationInterval) *
             this.rotationInterval;
         const date = os.date("*t", rotationPeriod) as LuaDate;
 
-        const timestamp = `${date.year}-${string.format("%02d", date.month)}-${string.format("%02d", date.day)}_${string.format("%02d", date.hour)}-${string.format("%02d", date.min)}`;
+        const timestamp = `${date.year}-${string.format("%02d", date.month)}-${string.format("%02d", date.day)}`;
 
         // Split filename and extension
-        const splitStrs = this.baseFilename.split(".");
+        const splitStrs = this.filePath.split(".");
         if (splitStrs.length === 1) {
-            return `${this.baseFilename}_${timestamp}.log`;
+            return `${this.filePath}_${timestamp}.log`;
         }
 
         const name = splitStrs[0];
@@ -126,19 +156,50 @@ export class FileStream implements Stream {
         if (this.rotationInterval <= 0) return;
 
         const currentTime = os.time();
-        const currentPeriod = Math.floor(currentTime / this.rotationInterval);
-        const lastPeriod = Math.floor(
-            this.lastRotationTime / this.rotationInterval,
-        );
-
-        if (currentPeriod > lastPeriod) {
+        if (
+            Math.floor(
+                (currentTime - this.lastRotationTime) / this.rotationInterval,
+            ) > 0
+        ) {
             // Time to rotate
             this.close();
             this.lastRotationTime = currentTime;
             this.openFile();
+            // Auto-cleanup is performed in openFile()
         }
     }
 
+    /**
+     * Perform auto-cleanup based on configuration.
+     * This method is called automatically when opening files or rotating.
+     */
+    private performAutoCleanup(): void {
+        if (!this.autoCleanupConfig || !this.autoCleanupConfig.enabled) {
+            return;
+        }
+
+        const config = this.autoCleanupConfig;
+
+        // Cleanup by file count if configured
+        if (config.maxFiles !== undefined && config.maxFiles > 0) {
+            this.cleanupOldLogFiles(config.maxFiles, config.logDir);
+        }
+
+        // Cleanup by total size if configured
+        if (config.maxSizeBytes !== undefined && config.maxSizeBytes > 0) {
+            this.cleanupLogFilesBySize(config.maxSizeBytes, config.logDir);
+        }
+    }
+
+    /**
+     * Enable or update auto-cleanup configuration at runtime.
+     *
+     * @param config - Auto-cleanup configuration
+     */
+    public setAutoCleanup(config: FileStreamConfig["autoCleanup"]): void {
+        this.autoCleanupConfig = config;
+    }
+
     /**
      * Write a formatted log message to the file.
      *
@@ -163,6 +224,123 @@ export class FileStream implements Stream {
             this.fileHandle = undefined;
         }
     }
+
+    /**
+     * Search for log files matching the specified pattern in a directory.
+     *
+     * @param logDir - Directory containing log files (defaults to directory of current log file)
+     * @returns Array of log file information including path, size, and modification time
+     */
+    private searchLogFiles(
+        logDir?: string,
+    ): Array<{ path: string; size: number; modified: number }> {
+        const directory = logDir || fs.getDir(this.filePath);
+        const splitStrs = this.filePath.split(".");
+
+        const name = splitStrs[0] + "_";
+        const ext = splitStrs.length > 1 ? splitStrs[1] : "log";
+
+        if (!fs.exists(directory) || !fs.isDir(directory)) {
+            return [];
+        }
+
+        const logFiles: Array<{
+            path: string;
+            size: number;
+            modified: number;
+        }> = [];
+        const files = fs.list(directory);
+
+        for (const file of files) {
+            const fullPath = fs.combine(directory, file);
+            if (
+                fs.isDir(fullPath) ||
+                !file.startsWith(name) ||
+                !file.endsWith(ext)
+            )
+                continue;
+
+            const attributes = fs.attributes(fullPath);
+            if (attributes !== undefined) {
+                logFiles.push({
+                    path: fullPath,
+                    size: attributes.size,
+                    modified: attributes.modified,
+                });
+            }
+        }
+
+        return logFiles;
+    }
+
+    /**
+     * Clean up old log files by keeping only the specified number of most recent files.
+     *
+     * @param maxFiles - Maximum number of log files to keep
+     * @param logDir - Directory containing log files (defaults to directory of current log file)
+     */
+    public cleanupOldLogFiles(maxFiles: number, logDir?: string): void {
+        if (maxFiles <= 0) return;
+
+        const logFiles = this.searchLogFiles(logDir);
+        if (logFiles.length <= maxFiles) return;
+
+        // Sort by modification time (newest first)
+        logFiles.sort((a, b) => b.modified - a.modified);
+
+        // Delete files beyond the limit
+        for (let i = maxFiles; i < logFiles.length; i++) {
+            try {
+                fs.delete(logFiles[i].path);
+            } catch (err) {
+                printError(
+                    `Failed to delete old log file ${logFiles[i].path}: ${err}`,
+                );
+            }
+        }
+    }
+
+    /**
+     * Clean up log files by total size, deleting oldest files until total size is under limit.
+     *
+     * @param maxSizeBytes - Maximum total size in bytes for all log files
+     * @param logDir - Directory containing log files (defaults to directory of current log file)
+     * @param fileName - Base File Name
+     */
+    public cleanupLogFilesBySize(maxSizeBytes: number, logDir?: string): void {
+        if (maxSizeBytes <= 0) return;
+
+        const logFiles = this.searchLogFiles(logDir);
+        if (logFiles.length === 0) return;
+
+        // Calculate total size
+        let totalSize = 0;
+        for (const logFile of logFiles) {
+            totalSize += logFile.size;
+        }
+
+        // If total size is within limit, no cleanup needed
+        if (totalSize <= maxSizeBytes) {
+            return;
+        }
+
+        // Sort by modification time (oldest first for deletion)
+        logFiles.sort((a, b) => a.modified - b.modified);
+
+        // Delete oldest files until we're under the size limit
+        for (const logFile of logFiles) {
+            if (totalSize <= maxSizeBytes) {
+                break;
+            }
+
+            try {
+                fs.delete(logFile.path);
+                totalSize -= logFile.size;
+            } catch (err) {
+                printError(`Failed to delete log file ${logFile.path}: ${err}`);
+            }
+        }
+    }
 }
 
 /**
@@ -307,3 +485,7 @@ export const MINUTE = 60 * SECOND;
 export const HOUR = 60 * MINUTE;
 export const DAY = 24 * HOUR;
 export const WEEK = 7 * DAY;
+
+// Byte constants for file rotation
+export const MB = 1024 * 1024;
+export const KB = 1024;

src/lib/ccTUI/UIObject.ts

@@ -398,11 +398,17 @@ export class UIObject {
 
         const newScrollX = Math.max(
             0,
-      Math.min(this.scrollProps.maxScrollX, this.scrollProps.scrollX + deltaX),
+            Math.min(
+                this.scrollProps.maxScrollX,
+                this.scrollProps.scrollX + deltaX,
+            ),
         );
         const newScrollY = Math.max(
             0,
-      Math.min(this.scrollProps.maxScrollY, this.scrollProps.scrollY + deltaY),
+            Math.min(
+                this.scrollProps.maxScrollY,
+                this.scrollProps.scrollY + deltaY,
+            ),
         );
 
         this.scrollProps.scrollX = newScrollX;

src/lib/ccTUI/application.ts

@@ -5,10 +5,10 @@
 import { UIObject } from "./UIObject";
 import { calculateLayout } from "./layout";
 import { render as renderTree, clearScreen } from "./renderer";
-import { CCLog, DAY, LogLevel } from "../ccLog";
-import { setLogger } from "./context";
 import { InputProps } from "./components";
 import { Setter } from "./reactivity";
+import { getStructLogger, Logger } from "@/lib/ccStructLog";
+import { setLogger } from "./context";
 
 /**
  * Main application class
@@ -21,7 +21,7 @@ export class Application {
     private focusedNode?: UIObject;
     private termWidth: number;
     private termHeight: number;
-  private logger: CCLog;
+    private logger: Logger;
     private cursorBlinkState = false;
     private lastBlinkTime = 0;
     private readonly BLINK_INTERVAL = 0.5; // seconds
@@ -30,11 +30,7 @@ export class Application {
         const [width, height] = term.getSize();
         this.termWidth = width;
         this.termHeight = height;
-    this.logger = new CCLog("tui_debug.log", {
-      printTerminal: false,
-      logInterval: DAY,
-      outputMinLevel: LogLevel.Info,
-    });
+        this.logger = getStructLogger("ccTUI");
         setLogger(this.logger);
         this.logger.debug("Application constructed.");
     }
@@ -99,7 +95,6 @@ export class Application {
             this.root.unmount();
         }
 
-    this.logger.close();
         clearScreen();
     }
 
@@ -224,8 +219,10 @@ export class Application {
                     | undefined;
                 if (type === "checkbox") {
                     // Toggle checkbox
-          const onChangeProp = (this.focusedNode.props as InputProps).onChange;
-          const checkedProp = (this.focusedNode.props as InputProps).checked;
+                    const onChangeProp = (this.focusedNode.props as InputProps)
+                        .onChange;
+                    const checkedProp = (this.focusedNode.props as InputProps)
+                        .checked;
 
                     if (
                         typeof onChangeProp === "function" &&
@@ -260,7 +257,10 @@ export class Application {
         const valueProp = (this.focusedNode.props as InputProps).value;
         const onInputProp = (this.focusedNode.props as InputProps).onInput;
 
-    if (typeof valueProp !== "function" || typeof onInputProp !== "function") {
+        if (
+            typeof valueProp !== "function" ||
+            typeof onInputProp !== "function"
+        ) {
             return;
         }
 
@@ -273,7 +273,10 @@ export class Application {
             this.needsRender = true;
         } else if (key === keys.right) {
             // Move cursor right
-      this.focusedNode.cursorPos = math.min(currentValue.length, cursorPos + 1);
+            this.focusedNode.cursorPos = math.min(
+                currentValue.length,
+                cursorPos + 1,
+            );
             this.needsRender = true;
         } else if (key === keys.backspace) {
             // Delete character before cursor
@@ -301,11 +304,15 @@ export class Application {
      * Handle character input events
      */
     private handleCharEvent(char: string): void {
-    if (this.focusedNode !== undefined && this.focusedNode.type === "input") {
+        if (
+            this.focusedNode !== undefined &&
+            this.focusedNode.type === "input"
+        ) {
             const type = (this.focusedNode.props as InputProps).type;
             if (type !== "checkbox") {
                 // Insert character at cursor position
-        const onInputProp = (this.focusedNode.props as InputProps).onInput;
+                const onInputProp = (this.focusedNode.props as InputProps)
+                    .onInput;
                 const valueProp = (this.focusedNode.props as InputProps).value;
 
                 if (
@@ -338,7 +345,10 @@ export class Application {
 
         if (clicked !== undefined) {
             this.logger.debug(
-        string.format("handleMouseClick: Found node of type %s.", clicked.type),
+                string.format(
+                    "handleMouseClick: Found node of type %s.",
+                    clicked.type,
+                ),
             );
             // Set focus
             if (
@@ -351,7 +361,8 @@ export class Application {
             }
             this.focusedNode = clicked;
             if (typeof clicked.props.onFocusChanged === "function") {
-        const onFocusChanged = clicked.props.onFocusChanged as Setter<boolean>;
+                const onFocusChanged = clicked.props
+                    .onFocusChanged as Setter<boolean>;
                 onFocusChanged(true);
             }
 
@@ -375,11 +386,15 @@ export class Application {
                         "handleMouseClick: onClick handler found, executing.",
                     );
                     (onClick as () => void)();
-          this.logger.debug("handleMouseClick: onClick handler finished.");
+                    this.logger.debug(
+                        "handleMouseClick: onClick handler finished.",
+                    );
                     this.needsRender = true;
                 }
             } else if (clicked.type === "input") {
-        const type = (clicked.props as InputProps).type as string | undefined;
+                const type = (clicked.props as InputProps).type as
+                    | string
+                    | undefined;
                 if (type === "checkbox") {
                     const onChangeProp = (clicked.props as InputProps).onChange;
                     const checkedProp = (clicked.props as InputProps).checked;
@@ -397,7 +412,9 @@ export class Application {
 
             this.needsRender = true;
         } else {
-      this.logger.debug("handleMouseClick: No node found at click position.");
+            this.logger.debug(
+                "handleMouseClick: No node found at click position.",
+            );
         }
     }
 
@@ -432,7 +449,9 @@ export class Application {
                 );
                 // Only return interactive elements
                 if (node.type === "button" || node.type === "input") {
-          this.logger.debug("findNodeAt: Node is interactive, returning.");
+                    this.logger.debug(
+                        "findNodeAt: Node is interactive, returning.",
+                    );
                     return node;
                 }
             }
@@ -502,7 +521,9 @@ export class Application {
                 );
                 // Only return scrollable elements
                 if (node.type === "scroll-container") {
-          this.logger.debug("findNodeAt: Node is scrollable, returning.");
+                    this.logger.debug(
+                        "findNodeAt: Node is scrollable, returning.",
+                    );
                     return node;
                 }
             }

src/lib/ccTUI/components.ts

@@ -167,12 +167,15 @@ export function label(
             const sentences = createMemo(() => {
                 const words = splitByWhitespace(text());
                 const ret = concatSentence(words, 40);
-        context.logger?.debug(`label words changed : [ ${ret.join(",")} ]`);
+                context.logger?.debug(
+                    `label words changed : [ ${ret.join(",")} ]`,
+                );
                 return ret;
             });
 
-      const forNode = For({ class: `flex flex-col`, each: sentences }, (word) =>
-        label({ class: p.class }, word),
+            const forNode = For(
+                { class: `flex flex-col`, each: sentences },
+                (word) => label({ class: p.class }, word),
             );
 
             return forNode;

src/lib/ccTUI/context.ts

@@ -4,13 +4,13 @@
  * to all components without prop drilling.
  */
 
-import type { CCLog } from "../ccLog";
+import { Logger } from "@/lib/ccStructLog";
 
 /**
  * The global context object for the TUI application.
  * This will be set by the Application instance on creation.
  */
-export const context: { logger: CCLog | undefined } = {
+export const context: { logger: Logger | undefined } = {
     logger: undefined,
 };
 
@@ -18,6 +18,6 @@ export const context: { logger: CCLog | undefined } = {
  * Sets the global logger instance.
  * @param l The logger instance.
  */
-export function setLogger(l: CCLog): void {
+export function setLogger(l: Logger): void {
     context.logger = l;
 }

src/lib/ccTUI/layout.ts

@@ -62,7 +62,10 @@ function measureNode(
         if (node.styleProps.width === "screen") {
             const termSize = getTerminalSize();
             measuredWidth = termSize.width;
-    } else if (node.styleProps.width === "full" && parentWidth !== undefined) {
+        } else if (
+            node.styleProps.width === "full" &&
+            parentWidth !== undefined
+        ) {
             measuredWidth = parentWidth;
         } else if (typeof node.styleProps.width === "number") {
             measuredWidth = node.styleProps.width;
@@ -297,7 +300,13 @@ export function calculateLayout(
             const childY = startY + scrollOffsetY;
 
             // Recursively calculate layout for child with its natural size
-      calculateLayout(child, childSize.width, childSize.height, childX, childY);
+            calculateLayout(
+                child,
+                childSize.width,
+                childSize.height,
+                childX,
+                childY,
+            );
         }
         return;
     }
@@ -368,7 +377,8 @@ export function calculateLayout(
 
             // Cross axis (vertical) alignment
             if (align === "center") {
-        childY = startY + math.floor((availableHeight - measure.height) / 2);
+                childY =
+                    startY + math.floor((availableHeight - measure.height) / 2);
             } else if (align === "end") {
                 childY = startY + (availableHeight - measure.height);
             } else {
@@ -385,7 +395,8 @@ export function calculateLayout(
 
             // Cross axis (horizontal) alignment
             if (align === "center") {
-        childX = startX + math.floor((availableWidth - measure.width) / 2);
+                childX =
+                    startX + math.floor((availableWidth - measure.width) / 2);
             } else if (align === "end") {
                 childX = startX + (availableWidth - measure.width);
             } else {

src/lib/ccTUI/reactivity.ts

@@ -75,10 +75,10 @@ export function createSignal<T>(initialValue: T): Signal<T> {
             // Notify all subscribed listeners
             if (batchDepth > 0) {
                 // In batch mode, collect effects to run later
-        listeners.forEach(listener => pendingEffects.add(listener));
+                listeners.forEach((listener) => pendingEffects.add(listener));
             } else {
                 // Run effects immediately
-        listeners.forEach(listener => {
+                listeners.forEach((listener) => {
                     try {
                         listener();
                     } catch (e) {
@@ -152,7 +152,7 @@ export function batch(fn: () => void): void {
             const effects = Array.from(pendingEffects);
             pendingEffects.clear();
 
-      effects.forEach(effect => {
+            effects.forEach((effect) => {
                 try {
                     effect();
                 } catch (e) {

src/lib/ccTUI/renderer.ts

@@ -18,7 +18,10 @@ function getTextContent(node: UIObject): string {
     }
 
     // For nodes with text children, get their content
-  if (node.children.length > 0 && node.children[0].textContent !== undefined) {
+    if (
+        node.children.length > 0 &&
+        node.children[0].textContent !== undefined
+    ) {
         const child = node.children[0];
         if (typeof child.textContent === "function") {
             return child.textContent();
@@ -39,7 +42,11 @@ function isPositionVisible(
 ): boolean {
     let current = node.parent;
     while (current) {
-    if (isScrollContainer(current) && current.layout && current.scrollProps) {
+        if (
+            isScrollContainer(current) &&
+            current.layout &&
+            current.scrollProps
+        ) {
             const { x: containerX, y: containerY } = current.layout;
             const { viewportWidth, viewportHeight } = current.scrollProps;
 
@@ -189,7 +196,9 @@ function drawNode(
             }
 
             case "input": {
-        const type = (node.props as InputProps).type as string | undefined;
+                const type = (node.props as InputProps).type as
+                    | string
+                    | undefined;
 
                 if (type === "checkbox") {
                     // Draw checkbox
@@ -224,7 +233,11 @@ function drawNode(
                     const focusedBgColor = bgColor ?? colors.white;
                     const unfocusedBgColor = bgColor ?? colors.black;
 
-          if (displayText === "" && placeholder !== undefined && !focused) {
+                    if (
+                        displayText === "" &&
+                        placeholder !== undefined &&
+                        !focused
+                    ) {
                         displayText = placeholder;
                         showPlaceholder = true;
                         currentTextColor = currentTextColor ?? colors.gray;
@@ -235,7 +248,9 @@ function drawNode(
                     }
 
                     // Set background and clear the input area, creating a 1-character padding on the left
-          term.setBackgroundColor(focused ? focusedBgColor : unfocusedBgColor);
+                    term.setBackgroundColor(
+                        focused ? focusedBgColor : unfocusedBgColor,
+                    );
                     term.setCursorPos(x, y);
                     term.write(" ".repeat(width));
 
@@ -247,7 +262,9 @@ function drawNode(
 
                     // Move text if it's too long for the padded area
                     const startDisPos =
-            cursorPos >= renderWidth ? cursorPos - renderWidth + 1 : 0;
+                        cursorPos >= renderWidth
+                            ? cursorPos - renderWidth + 1
+                            : 0;
                     const stopDisPos = startDisPos + renderWidth;
 
                     if (focused && !showPlaceholder && cursorBlinkState) {
@@ -271,7 +288,10 @@ function drawNode(
                             }
                         }
                         // Draw cursor at the end of the text if applicable
-            if (cursorPos === textToRender.length && cursorPos < renderWidth) {
+                        if (
+                            cursorPos === textToRender.length &&
+                            cursorPos < renderWidth
+                        ) {
                             term.setBackgroundColor(currentTextColor);
                             term.setTextColor(focusedBgColor);
                             term.write(" ");
@@ -281,7 +301,9 @@ function drawNode(
                         }
                     } else {
                         // Not focused or no cursor, just write the text
-            term.write(textToRender.substring(startDisPos, stopDisPos));
+                        term.write(
+                            textToRender.substring(startDisPos, stopDisPos),
+                        );
                     }
                 }
                 break;

src/lib/ccTUI/store.ts

@@ -45,7 +45,9 @@ export interface SetStoreFunction<T> {
  * setTodos([{ title: "First", done: false }]);
  * ```
  */
-export function createStore<T extends object>(initialValue: T): [Accessor<T>, SetStoreFunction<T>] {
+export function createStore<T extends object>(
+    initialValue: T,
+): [Accessor<T>, SetStoreFunction<T>] {
     // Use a signal to track the entire state
     const [get, set] = createSignal(initialValue);
 
@@ -88,8 +90,11 @@ export function createStore<T extends object>(initialValue: T): [Accessor<T>, Se
 
             if (Array.isArray(current)) {
                 const newArray = [...current] as unknown[];
-        if (typeof newArray[index] === "object" && newArray[index] !== undefined) {
-          newArray[index] = { ...(newArray[index]!), [key]: value };
+                if (
+                    typeof newArray[index] === "object" &&
+                    newArray[index] !== undefined
+                ) {
+                    newArray[index] = { ...newArray[index]!, [key]: value };
                 }
                 set(newArray as T);
             }

src/logExample/main.ts

@@ -36,7 +36,13 @@ const customLogger = new Logger({
         }),
     ],
     renderer: jsonRenderer,
-    streams: [new ConsoleStream(), new FileStream("custom.log", HOUR)],
+    streams: [
+        new ConsoleStream(),
+        new FileStream({
+            filePath: "custom.log",
+            rotationInterval: HOUR,
+        }),
+    ],
 });
 
 customLogger.info("Custom logger example", {
@@ -136,7 +142,10 @@ const multiFormatLogger = new Logger({
         {
             write: (_, event) => {
                 const formatted = jsonRenderer(event);
-                new FileStream("structured.log").write(formatted, event);
+                new FileStream({ filePath: "structured.log" }).write(
+                    formatted,
+                    event,
+                );
             },
         },
     ],
@@ -193,7 +202,7 @@ print("\n=== Cleanup Examples ===");
 const fileLogger = new Logger({
     processors: [processor.addTimestamp()],
     renderer: jsonRenderer,
-    streams: [new FileStream("temp.log")],
+    streams: [new FileStream({ filePath: "structured.log" })],
 });
 
 fileLogger.info("Temporary log entry");