features

.vscode/c_cpp_properties.json

@@ -0,0 +1,17 @@
+{
+    "configurations": [
+        {
+            "name": "Linux",
+            "includePath": [
+                "${workspaceFolder}/**",
+                "/home/ilya/libvirt-dev/node_modules/node-addon-api"
+            ],
+            "defines": [],
+            "compilerPath": "/usr/bin/gcc",
+            "cStandard": "c11",
+            "cppStandard": "c++17",
+            "intelliSenseMode": "clang-x64"
+        }
+    ],
+    "version": 4
+}

.vscode/launch.json

@@ -0,0 +1,10 @@
+  {
+    "version": "0.2.0",
+    "configurations": [{
+       "type": "lldb",
+       "request": "launch",
+       "name": "Addon debug",
+       "program": "${workspaceFolder}/dist/examples/",
+       "preLaunchTask": "npm: build",
+    }]
+  }

.vscode/settings.json

@@ -0,0 +1,12 @@
+{
+    "files.exclude": {
+        "**/.git": false,
+        "**/.svn": true,
+        "**/.hg": true,
+        "**/CVS": true,
+        "**/.DS_Store": true,
+        "**/node_modules": true,
+        "**/build": true,
+        "**/dist": true
+    }
+}

binding.gyp

@@ -17,10 +17,13 @@
             ],
             "include_dirs": [
                 "<!@(node -p \"require('node-addon-api').include\")",
-                "."
+                ".",
+                "/usr/include/glib-2.0",
+                "/usr/lib/glib-2.0/include",
+                "/usr/lib/x86_64-linux-gnu/glib-2.0/include"
             ],
             "link_settings": {
-                "libraries": [ "-lvirt" ]
+                "libraries": [ "-lvirt" , "-lglib-2.0" ]
             }
         }
     ]

examples/create.ts

@@ -0,0 +1,97 @@
+import chalk from "chalk";
+import process from "process";
+
+import libvirt, { Domain } from "../"
+import { domainDescToXml, DomainDesc, DomainBuilder } from "../dist";
+import uuidv1 from 'uuid/v1';
+
+(async ()=>{
+    const uri = "qemu:///system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    // Connecting to our hypervisor
+    await hypervisor.connectOpen();
+
+    const builDomainDesc = createDomainDesc("Example VM");
+
+    builDomainDesc.addDisk({
+        type: "file", device: "disk",
+        driver: { name: "qemu", type: "qcow2" },
+        source: { file: "/" }, // Define path of your qcow2 disk
+        target: { dev: "vda", bus: "virtio" }
+    });
+
+    const domainXML = domainDescToXml(builDomainDesc.build());
+
+    const domain: Domain = await hypervisor.domainDefineXML(domainXML);
+    // Our domain has been defined or edited if DomainDesc have existing uuid 
+    // Then we can start domain
+
+    const domainName = await hypervisor.domainGetName(domain);
+
+    await hypervisor.domainCreate(domain).then(() => {
+        process.stdout.write(`Domain ${chalk.green(domainName)} started \n\n`)
+    }).catch((err) => {
+        process.stdout.write(`Error on starting ${chalk.red(domainName)} domain  \n\n`);
+    })
+
+    await hypervisor.connectClose();
+
+})()
+
+function createDomainDesc(domainName: string){
+
+    const template: DomainDesc = {
+
+        type: "kvm",
+
+        memory: { value: 1048576 },
+        currentMemory: { value: 1048576 },
+
+        vcpu: { value: 1 },
+
+        os: {
+            type: { arch: "x86_64", machine: "q35", value: "hvm" },
+            boot: { dev: "hd" },
+        },
+
+        devices: [
+
+            {
+                type: "emulator",
+                emulator: { value: "/usr/bin/qemu-system-x86_64" },
+            },
+
+            {
+                type: "console",
+                console: { type: "pty" },
+            },
+
+            {
+                type: "graphics",
+                graphics: {
+                    type: "vnc",
+                    port: -1,
+                    listen: "0.0.0.0",
+                    passwd: "test1",
+                }
+            },
+
+        ],
+
+    };
+
+    const domainUUID = uuidv1();
+    const domain = new DomainBuilder()
+        .fromTemplate(template)
+        .setName(domainName)
+        .setUUID(domainUUID)
+        .addInterface({
+            type: "network",
+            source: { network: "default" },
+            mac: { address: "52:54:00:8e:c6:5f" },
+            model: { type: "virtio" },
+        })
+
+    return domain;
+}

examples/interface_stats.ts

@@ -0,0 +1,29 @@
+import chalk from "chalk";
+import process from "process";
+import util from 'util';
+
+import libvirt from "../";
+
+(async () => {
+    const vmName = "debian9-vm3", // VM name
+          ifName = "vnet2";        // VM Interface Name
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    await hypervisor.connectOpen();
+
+    const hostname = await hypervisor.connectGetHostname();
+    process.stdout.write(`Connected to ${hostname}!\n\n`);
+
+    const activeDomain = await hypervisor.domainLookupByName(vmName).then(domain => domain).catch(() => null); // Domain not exist or error
+    if (!activeDomain){
+        console.log(`Error on lookup for ${chalk.blue(vmName)}`);
+        return;
+    }
+
+    const ifStats = await hypervisor.domainInterfaceStats(activeDomain, ifName);
+    console.log(`Domain ${chalk.green(vmName)} interface stats of ${chalk.green(ifName)} interface:`);
+
+    console.log(util.inspect(ifStats, { colors: true, sorted: true }));
+})();

examples/list.ts

@@ -9,7 +9,7 @@ import libvirt from "../";
     const hypervisor = new libvirt.Hypervisor({ uri });
 
     await hypervisor.connectOpen();
-
+    console.time('s');
     const hostname = await hypervisor.connectGetHostname();
     process.stdout.write(`Connected to ${hostname}!\n\n`);
 
@@ -24,7 +24,7 @@ import libvirt from "../";
     const inactiveDomainNames = await Promise.all(inactiveDomains
         .map((domain) => hypervisor.domainGetName(domain)));
     await hypervisor.connectClose();
-
+    console.timeEnd('s')
     process.stdout.write("Active Domains\n");
     process.stdout.write("--------------\n");
     for (const name of activeDomainNames) {

examples/memorystats.ts

@@ -0,0 +1,35 @@
+import chalk from "chalk";
+import process from "process";
+import _ from "lodash";
+import bytes from "bytes";
+import { prettifyMemoryUsage } from '../dist/domain-utils'
+
+import libvirt, { Domain } from "../";
+
+(async () => {
+    const vmName = "debian9-vm1", // VM name
+          ifName = "vnet0";        // VM Interface Name
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    await hypervisor.connectOpen();
+
+    const hostname = await hypervisor.connectGetHostname();
+    process.stdout.write(`Connected to ${hostname}!\n\n`);
+
+    const activeDomain = await hypervisor.domainLookupByName(vmName).then(domain => domain).catch(() => null); // Domain not exist or error
+    if (!activeDomain){
+        console.log(`Error on lookup for ${chalk.blue(vmName)}`);
+        return;
+    }   
+
+    setInterval(async () => {
+        const memoryStats = await hypervisor.domainMemoryStats(activeDomain);
+        const pretty = prettifyMemoryUsage(memoryStats);
+        console.log(pretty);
+        // console.log(memoryStats);
+
+        // Pretty is just an example.
+    }, 1000)
+})();

examples/node_cpustats.ts

@@ -0,0 +1,25 @@
+import chalk from "chalk";
+import process from "process";
+import _ from "lodash";
+import bytes from "bytes";
+
+import libvirt, { Domain, prettifyCpuUsage } from "../";
+
+(async () => {
+    const vmName = "debian9-vm1", // VM name
+          ifName = "vnet0";        // VM Interface Name
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    await hypervisor.connectOpen();
+
+    const hostname = await hypervisor.connectGetHostname();
+    process.stdout.write(`Connected to ${hostname}!\n\n`);
+
+    const prev = await hypervisor.nodeCpuStats();
+    await new Promise(resolve => setTimeout(resolve, 1000));
+    const current = await hypervisor.nodeCpuStats();
+    const usage = prettifyCpuUsage(prev, current);
+    console.log(usage);
+})();

examples/node_memory.ts

@@ -0,0 +1,19 @@
+import chalk from "chalk";
+import process from "process";
+import util from 'util';
+
+import libvirt from "../";
+
+(async () => {
+    const vmName = "debian9-vm1", // VM name
+          ifName = "vnet0";        // VM Interface Name
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    await hypervisor.connectOpen();
+
+    const hostname = await hypervisor.connectGetHostname();
+    process.stdout.write(`Connected to ${hostname}!\n\n`);
+    console.log(await hypervisor.nodeGetMemoryStats());
+})();

examples/parse.ts

@@ -0,0 +1,53 @@
+import chalk from "chalk";
+import process from "process";
+
+import libvirt, { ConnectListAllDomainsFlags } from "../";
+
+import { Parser, Builder } from 'xml2js'
+
+(async () => {
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    await hypervisor.connectOpen();
+
+    const hostname = await hypervisor.connectGetHostname();
+    process.stdout.write(`Connected to ${hostname}!\n\n`);
+
+    const debianDomain = await hypervisor.domainLookupByName('debian9-vm1');
+
+    const domainXML = await hypervisor.domainGetXMLDesc(debianDomain);
+
+    const xmlParser = new Parser({ headless: true, explicitRoot: false, rootName: 'domain'});
+    const xmlBuilder = new Builder({ headless: true, explicitRoot: false, rootName: "domain"});
+
+    const domainObj = await xmlParser.parseStringPromise(domainXML);
+
+    let domainVNCIndex = domainObj.devices[0].graphics.findIndex((graphics:any) => graphics.$.type === 'vnc');
+
+    const newVNCPort = parseInt(domainObj.devices[0].graphics[domainVNCIndex].$.port) + 1
+    domainObj.devices[0].graphics[domainVNCIndex].$.port = String(newVNCPort);
+
+
+    const domainChangeVNCXML = xmlBuilder.buildObject(domainObj);
+
+    await hypervisor.domainShutdown(debianDomain).then(()=>{
+        console.log("DOMAIN SHUTDOWN OK");
+    }).catch(err => {
+        console.log("shutdown err:", err);
+    });
+    await new Promise(resolve => setTimeout(resolve, 5000));
+
+    await hypervisor.domainDefineXML(domainChangeVNCXML).then(()=>{
+        console.log("DOMAIN DEFINE OK")
+    });
+
+    await hypervisor.domainCreate(debianDomain).then(()=>{
+        console.log("DOMAIN START OK");
+        console.log(`New VNC port : ${newVNCPort}`)
+    });
+
+    await hypervisor.connectClose();
+
+})();

examples/reboot.ts

@@ -0,0 +1,37 @@
+import chalk from "chalk";
+import process from "process";
+
+import libvirt from "../";
+
+(async () => {
+
+    const uri = "qemu+ssh://root@libvirt_dev/system";
+    const hypervisor = new libvirt.Hypervisor({ uri });
+
+    // Connecting to our hypervisor
+    await hypervisor.connectOpen();
+
+    const activeDomains = await hypervisor.connectListAllDomains(
+        libvirt.ConnectListAllDomainsFlags.ACTIVE);
+
+    if (activeDomains.length === 0) {
+        process.stdout.write("No domains for reboot :( \n\n");
+        return;
+    }
+
+    for (const activeDomain of activeDomains) {
+        const domainName = await hypervisor.domainGetName(activeDomain);
+
+        process.stdout.write(`Rebooting domain: `
+            + `${chalk.blue(domainName)} ... \n\n`);
+
+        await hypervisor.domainReboot(activeDomain).then(() => {
+            process.stdout.write(`domain ${chalk.green(domainName)} `
+                + "is being to be rebooted!\n\n");
+        }).catch((err: Error) => {
+            process.stderr.write(`domain ${chalk.red(domainName)} reboot `
+                + `ERROR: ${err}\n\n`);
+        });
+    }
+
+})();

examples/shutdown.ts

@@ -23,7 +23,7 @@ import libvirt from "../";
         const domainName = await hypervisor.domainGetName(activeDomain);
 
         process.stdout.write(`Shutting down domain: `
-            + `${chalk.blue(domainName)} ... `);
+            + `${chalk.blue(domainName)} ... \n\n`);
 
         await hypervisor.domainShutdown(activeDomain).then(() => {
             process.stdout.write(`domain ${chalk.green(domainName)} `