// METADATA // {"ai-commented":{"service":"openai-completion","model":"gpt-4o-mini"}}
/*
 * Copyright (C) 2024-present Puter Technologies Inc.
 *
 * This file is part of Puter.
 *
 * Puter is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published
 * by the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */
const { ansi_visible_length } = require('@heyputer/putility/src/libs/string');
const { consoleLogManager } = require('../util/consolelog');
const BaseService = require('./BaseService');
const { NullDevConsoleService } = require('./NullDevConsoleService');

/**
* DevConsoleService - A service for managing the developer console interface,
* providing functionalities such as adding and removing widgets, updating the display,
* and handling command input/output in a terminal environment.
*/
class DevConsoleService extends BaseService {
    static MODULES = {
        fs: require('fs'),
    };

    /**
    * Initializes the DevConsoleService instance, setting up required properties
    * and determining if the application is running in a Docker environment.
    *
    * @returns {void} This method does not return a value.
    */
    _construct () {
        this.static_lines = [];
        this.widgets = [];
        this.identifiers = {};
        this.has_updates = false;

        try {
            const require = this.require;
            const fs = require('fs');
            this.is_docker = fs.existsSync('/.dockerenv');
        } catch (e) {
            // if this fails, we assume is_docker should
            // be false.
            this.log.error(e.message);
            this.is_docker = false;
        }
    }

    /**
     * Activates the warning lights by adding a widget that outputs a warning message.
     * The widget will display a flashing warning message when it is turned on.
     */
    turn_on_the_warning_lights () {
        /**
        * Turns on the warning lights by adding a warning widget to the console.
        * This function calls the `add_widget` method to display a formatted
        * warning message. The widget will be shown in red and blinking,
        * indicating a warning state.
        */
        this.add_widget(() => {
            return `\x1B[31;1m\x1B[5m *** ${
                Array(3).fill('WARNING').join(' ** ')
            } ***\x1B[0m`;
        });
    }

    add_widget (outputter, opt_id) {
        this.widgets.push(outputter);
        if ( opt_id ) {
            this.identifiers[opt_id] = outputter;
        }
        this.mark_updated();
    }

    remove_widget (id_or_outputter) {
        if ( typeof id_or_outputter === 'string' ) {
            id_or_outputter = this.identifiers[id_or_outputter];
        }
        this.widgets = this.widgets.filter(w => w !== id_or_outputter);
        this.mark_updated();
    }

    notice = NullDevConsoleService.notice;

    /**
     * Updates the displayed output based on the current state of widgets.
     * This method collects output from all active widgets, handles any errors,
     * and maintains the integrity of displayed information.
     *
     * It modifies the static_lines array to reflect the latest outputs and
     * removes widgets that produce errors. The display is updated only if there
     * are changes in the output.
     */
    update_ () {
        const initialOutput = [...this.static_lines];
        this.static_lines = [];
        // if a widget throws an error we MUST remove it;
        // it's probably a stack overflow because it's printing.
        const to_remove = [];
        let positions = [];
        for ( const w of this.widgets ) {
            let output; try {
                output = w({ is_docker: this.is_docker });
            } catch ( e ) {
                consoleLogManager.log_raw('error', e);
                to_remove.push(w);
                continue;
            }
            output = Array.isArray(output) ? output : [output];
            positions.push([this.static_lines.length, output.length]);
            this.static_lines.push(...output);
        }

        // The desired minimum output lines for display; used to ensure there's enough space for content.
        const DESIRED_MIN_OUT = 10;
        const size_ok = () =>
            process.stdout.rows - DESIRED_MIN_OUT > this.static_lines.length;
        let n_hidden = 0;
        for ( let i = this.widgets.length - 1 ; i >= 0 ; i-- ) {
            if ( size_ok() ) break;
            const w = this.widgets[i];
            if ( w.critical ) continue;
            if ( ! w.unimportant ) continue;
            n_hidden++;
            const [start, length] = positions[i];
            this.static_lines.splice(start, length);
            // update positions
            for ( let j = i ; j < positions.length ; j++ ) {
                positions[j][0] -= length;
            }
        }
        for ( let i = this.widgets.length - 1 ; i >= 0 ; i-- ) {
            if ( size_ok() ) break;
            const w = this.widgets[i];
            if ( w.critical ) continue;
            n_hidden++;
            const [start, length] = positions[i];
            this.static_lines.splice(start, length);
        }
        if ( n_hidden && size_ok() ) {
            this.static_lines.push(`\x1B[33m${
                this.generateEnd(`[ ${n_hidden} widget${n_hidden === 1 ? '' : 's'} hidden ]`)
            }\x1B[0m`);
        }

        if ( ! this.arrays_equal(initialOutput, this.static_lines) ) {
            this.mark_updated(); // Update only if outputs have changed
        }
        for ( const w of to_remove ) {
            this.remove_widget(w);
        }
    }

    arrays_equal (a, b) {
        return a.length === b.length && a.every((val, index) => val === b[index]);
    }

    /**
    * Marks that an update has occurred in the DevConsoleService.
    * This method sets the has_updates flag to true, indicating that
    * the service should refresh the display during the next render cycle.
    */
    mark_updated () {
        this.has_updates = true;
    }

    /**
    * Initializes the DevConsoleService, setting up necessary interfaces
    * and handlers for command execution. This method manages input and
    * output streams, integrates command completion, and refreshes console
    * output based on widget updates.
    *
    * @async
    * @returns {Promise<void>} Resolves when the initialization completes.
    */
    async _init () {
        const services = this.services;
        const commands = services.get('commands');

        const readline = require('readline');
        const rl = readline.createInterface({
            input: process.stdin,
            output: process.stdout,
            prompt: 'puter> ',
            terminal: true,
            completer: line => {
                if ( line.includes(' ') ) {
                    const [ commandName, ...args ] = line.split(/\s+/);
                    const command = commands.getCommand(commandName);
                    if ( ! command )
                    {
                        return;
                    }
                    return [ command.completeArgument(args), args[args.length - 1] ];
                }

                const results = commands.commandNames
                    .filter(name => name.startsWith(line))
                    .map(name => `${name} `); // Add a space after to make typing arguments more convenient
                return [ results, line ];
            },
        });
        rl.on('line', async (input) => {
            this._before_cmd();
            if ( input.startsWith('ev') ) {
                eval(input.slice(3));
            } else {
                await commands.executeRawCommand(input, console);
            }
            this._after_cmd();
        });

        /**
        * _before_cmd - Handles operations needed before a command is executed.
        *
        * (resets cursor to correct position, if I recall correctly)
        */
        this._before_cmd = () => {
            rl.pause();
            rl.output.write('\x1b[1A\r');
            rl.output.write('\x1b[2K\r');
            console.log(`\x1B[33m${
                this.generateSeparator('[ Command Output ]')
            }\x1B[0m`);
        };

        /**
        * _after_cmd - Handles operations needed after a command is executed.
        *
        * This method is called to clean up the output after a command has been processed.
        * It logs a formatted message indicating the end of the command output.
        */
        this._after_cmd = () => {
            console.log(`\x1B[33m${
                this.generateEnd()
            }\x1B[0m`);
        };

        /**
         * Prepares the output console by pausing input, clearing the console lines,
         * and writing the static lines to be displayed. This method interacts directly
         * with the terminal output handling the cursor movements and line clearances.
         */
        this._pre_write = () => {
            rl.pause();
            process.stdout.write('\x1b[0m');
            rl.output.write('\x1b[2K\r');
            for ( let i = 0; i < this.static_lines.length + 1; i++ ) {
                process.stdout.write('\x1b[1A'); // Move cursor up one line
                process.stdout.write('\x1b[2K'); // Clear the line
            }
        };

        /**
        * Re-draws static lines and the input prompt (everything at the bottom of
        * the dev console) when something is written.
        */
        this._post_write = () => {
            this.update_();
            // Draw separator bar
            process.stdout.write(`\x1B[36m${
                this.generateSeparator()
            }\x1B[0m\n`);

            // Input background disabled on Mac OS because it
            // has a - brace yourself - light-theme terminal 😱
            const drawInputBackground =
                process.platform !== 'darwin';

            // Redraw the static lines
            this.static_lines.forEach(line => {
                process.stdout.write(`${line }\n`);
            });
            if ( drawInputBackground ) {
                // input background
                process.stdout.write('\x1b[48;5;234m');
            }
            rl.resume();
            rl._refreshLine();
            if ( drawInputBackground ) {
                // input background
                process.stdout.write('\x1b[48;5;237m');
            }
        };

        /**
        * Triggers the pre-write and post-write processes to refresh the console output.
        * This method ensures that the latest changes are reflected in the console view.
        */
        this._redraw = () => {
            this._pre_write();
            this._post_write();
        };

        /**
        * Starts an interval that periodically checks for updates and redraws the console output if needed.
        * The interval runs every 2000 milliseconds (2 seconds) and invokes the `_redraw` method if
        * any updates have occurred since the last check.
        */
        setInterval(() => {
            if ( this.has_updates ) {
                this._redraw();
                this.has_updates = false;
            }
        }, 2000);

        /**
        * Decorates all console log messages with the specified pre-write actions.
        *
        * This method is invoked before each log message is printed to the console,
        * ensuring that any necessary updates or redrawing of the console UI
        * can occur before the message is displayed.
        *
        * It does not accept any parameters and does not return any value.
        */
        consoleLogManager.decorate_all(({ replace }, ...args) => {
            this._pre_write();
        });

        consoleLogManager.post_all(() => {
            this._post_write();
        });

        // This prevents the promptline background from staying
        // when Ctrl+C is used to terminate the server
        rl.on('SIGINT', () => {
            process.stdout.write('\x1b[0m\r');
            process.exit(0);
        });
    }

    generateSeparator (text) {
        text = text || '[ Dev Console ]';
        const totalWidth = process.stdout.columns;

        if ( totalWidth <= text.length + 1 ) {
            return '═'.repeat(totalWidth < 0 ? 0 : totalWidth);
        }

        const paddingSize = (totalWidth - text.length) / 2;

        // Construct the separator
        return '═'.repeat(Math.floor(paddingSize)) + text + '═'.repeat(Math.ceil(paddingSize));
    }

    generateEnd (text) {
        text = text || '';
        const totalWidth = process.stdout.columns;
        const paddingSize = (totalWidth - text.length) / 2;

        // Construct the separator
        return '─'.repeat(Math.floor(paddingSize)) + text + '─'.repeat(Math.ceil(paddingSize));
    }
}

module.exports = {
    DevConsoleService,
};
