added cpu lib

packages/streaming-server/src/lib/cpu/index.js

@@ -0,0 +1,45 @@
+import os from "os"
+
+export function averageUsage() {
+    //Initialise sum of idle and time of cores and fetch CPU info
+    let totalIdle = 0, totalTick = 0
+    let cpus = os.cpus()
+
+    //Loop through CPU cores
+    for (let i = 0, len = cpus.length; i < len; i++) {
+        //Select CPU core
+        let cpu = cpus[i]
+
+        //Total up the time in the cores tick
+        if (cpu.times.type) {
+            for (type in cpu.times) {
+                totalTick += cpu.times[type]
+            }
+        }
+
+        //Total up the idle time of the core
+        totalIdle += cpu.times.idle
+    }
+
+    //Return the average Idle and Tick times
+    return { idle: totalIdle / cpus.length, total: totalTick / cpus.length }
+}
+
+export function percentageUsage() {
+    return new Promise((resolve, reject) => {
+        let startMeasure = averageUsage()
+
+        setTimeout(() => {
+            let endMeasure = averageUsage()
+
+            //Calculate the difference in idle and total time between the measures
+            let idleDifference = endMeasure.idle - startMeasure.idle
+            let totalDifference = endMeasure.total - startMeasure.total
+
+            //Calculate the average percentage CPU usage
+            let percentageCPU = 100 - ~~(100 * idleDifference / totalDifference)
+
+            return resolve(percentageCPU)
+        }, 100)
+    })
+}

packages/streaming-server/src/lib/index.js

@@ -1 +1,2 @@
-export { default as getStreamingKeyFromStreamPath } from "./getStreamingKeyFromStreamPath"
+export { default as getStreamingKeyFromStreamPath } from "./getStreamingKeyFromStreamPath"
+export * as cpu from "./cpu"