RIK Database ORM

import { DbSettings, Version, IVersion, NetworkInterfaceSettings } from 'rik-database';
import { createRequire } from 'module';

// Emulate CommonJS require for .env support in ESM context, or use dotenv directly
const require = createRequire(import.meta.url);
require('dotenv').config();

const dbConfig = {
    client: process.env.DB_CLIENT || 'pg',
    connection: {
        host: process.env.DB_HOST || 'localhost',
        user: process.env.DB_USER || 'user',
        password: process.env.DB_PASSWORD || 'password',
        database: process.env.DB_NAME || 'databaseName',
        port: process.env.DB_PORT ? parseInt(process.env.DB_PORT, 10) : 5432
    },
    pool: {
        min: 2,
        max: 10
    }
};

// Initialize database settings
DbSettings.setConfig(dbConfig);

class DatabaseOperations {
    public async demonstrateOperations(): Promise<void> {
        console.log('--- Demonstrating RIK Database ORM Operations ---');

        // Get current version data
        let currentVersion = await Version.query().orderBy('id', 'desc').first();
        console.log('\n+------- Current Version -------+');
        if (currentVersion) {
            console.log(currentVersion);
        } else {
            console.log('Version table is empty. Adding initial version.');
            const initialVersion: IVersion = { id: 1, name: 'Initial Version', number: '1.0.0', date: new Date().toISOString() };
            await Version.query().insert(initialVersion);
            currentVersion = await Version.query().orderBy('id', 'desc').first();
            console.log(currentVersion);
        }

        // Add a new version
        const newVersionData: IVersion = { name: 'Feature Update', number: '1.1.0', date: new Date().toISOString() };
        const newVersion = await Version.query().insert(newVersionData);
        console.log('\nNew version has been added. Version ID:', newVersion.id);

        // Update a version
        if (currentVersion) {
            const updatedVersionData: Partial<IVersion> = { name: 'Patched Feature Update' };
            const updatedVersion = await Version.query().patchAndFetchById(newVersion.id, updatedVersionData);
            console.log('\nVersion has been updated. Version:', updatedVersion);
        }

        // Insert multiple network settings with model instantiation
        try {
            const settingsToInsert = [
                new NetworkInterfaceSettings({
                    name: 'eth0', method_name: 'dhcp', ip_address: '0.0.0.0', gateway: '0.0.0.0'
                }),
                new NetworkInterfaceSettings({
                    name: 'eth1', method_name: 'static', ip_address: '192.168.1.100', gateway: '192.168.1.1'
                })
            ];
            const insertedSettings = await NetworkInterfaceSettings.query().insert(settingsToInsert);
            console.log('\nInserted Network Settings:', insertedSettings);
        } catch (error) {
            console.error('[DatabaseOperations:demonstrateOperations]: Error inserting settings:', error);
        }

        // Delete a version
        if (newVersion) {
            const deletedCount = await Version.query().deleteById(newVersion.id);
            console.log(`\nDeleted ${deletedCount} version(s) with ID ${newVersion.id}.`);
        }

        console.log('\n--- RIK Database ORM Operations Complete ---');
    }
}

// To run this example, ensure you have a .env file with DB_CLIENT, DB_HOST, DB_USER, DB_PASSWORD, DB_NAME, DB_PORT.
// Example .env:
// DB_CLIENT=pg
// DB_HOST=localhost
// DB_USER=myuser
// DB_PASSWORD=mypassword
// DB_NAME=mydb
// DB_PORT=5432

const app = new DatabaseOperations();
app.demonstrateOperations().catch(console.error);