Make list ofplugins and cache

Author: ajboni

README.md

@@ -0,0 +1,3 @@
+## Dependencies
+
+JACK, Nodejs, lilv (https://github.com/moddevices/lilvlib), jack-tools

__pycache__/lilv.cpython-36.pyc

@@ -5,9 +5,10 @@ const Keyboard = require("./keyboard");
 const Jack = require("./jack_client");
 const ModHost = require("./modhost_client");
 const { settings } = require("./settings");
+const LV2 = require("./lv2");
+const { lv2ls, pluginInfo, grep, listAllPlugins } = require("./lv2");
+const { pluginsUriByName } = require("./store");
 
-// const welcomeScreen = blessed.screen({});
-// welcomeScreen.render();
 const program = blessed.program();
 
 // Create a screen object.
@@ -18,6 +19,9 @@ const screen = blessed.screen({
 try {
   const mainGrid = Layout.setUpLayout(screen);
   Keyboard.registerKeyboardShortcuts(screen, mainGrid);
+  LV2.init();
+  console.log(pluginsUriByName.keys());
+
   Jack.init();
   ModHost.init();
 } catch (error) {

app.js

@@ -1,11 +1,5 @@
-var shell = require("shelljs");
 var { removeNewLines } = require("./string_utils");
-
-const status = {
-  DSP_LOAD: 0,
-  SAMPLE_RATE: "-----",
-  JACK_STATUS: "-----",
-};
+let { jack } = require("./store");
 
 function init() {
   if (isJackServerRunning()) {
@@ -16,39 +10,50 @@ function init() {
 
 function poll() {
   if (isJackServerRunning()) {
-    getSampleRate();
+    updateStatus();
   } else {
     throw "JACK IS NOT RUNNING";
   }
 }
 
+function updateStatus() {
+  jack.SAMPLE_RATE = getSampleRate();
+  jack.JACK_STATUS = getJackStatus();
+}
+
+/**
+ * Check whether or not the JACK server is running in the system. Uses jack_wait
+ * @returns Returns True if JACK server is running.
+ */
 function isJackServerRunning() {
-  const isJackRunning = shell.exec("jack_wait --check", { silent: true });
-  status.JACK_STATUS = removeNewLines(isJackRunning.stdout);
-  return isJackRunning.stdout.startsWith("running");
+  const cp = require("child_process");
+  const isJackRunning = cp.execSync("jack_wait --check", { encoding: "utf8" });
+  return isJackRunning.startsWith("running");
 }
 
-// Start Polling CPU usage.
-function startPollingCpuLoad() {
-  const cpuLoad = shell.exec("jack_cpu_load", { silent: true });
-  cpuLoad.stdout.on("data", function (data) {
-    status.DSP_LOAD = data;
-  });
+/**
+ * Get Jack Status as returned from jack_wait --check.
+ * @returns Returns "Running" "Not Running"
+ */
+function getJackStatus() {
+  const cp = require("child_process");
+  const isJackRunning = cp.execSync("jack_wait --check", { encoding: "utf8" });
+  return removeNewLines(isJackRunning) === "running"
+    ? "Running"
+    : "Not Running";
 }
 
-// Start Polling CPU usage.
+/**
+ * Get sample rate of Jack Server. Uses jack_samplerate.
+ * @returns JACK current sample rate.
+ */
 function getSampleRate() {
-  const jack_samplerate = shell.exec(
-    "jack_samplerate",
-    { silent: true },
-    (code, stdout, stderr) => {
-      status.SAMPLE_RATE = stdout.replace(/(\r\n|\n|\r)/gm, "");
-    }
-  );
+  const cp = require("child_process");
+  let jack_samplerate = cp.execSync("jack_samplerate", { encoding: "utf8" });
+  jack_samplerate = jack_samplerate.replace(/(\r\n|\n|\r)/gm, "");
+  return jack_samplerate;
 }
 
 exports.isJackServerRunning = isJackServerRunning;
-exports.startPollingCpuLoad = startPollingCpuLoad;
-exports.status = status;
 exports.init = init;
 exports.poll = poll;

jack_client.js

@@ -2,7 +2,7 @@ const blessed = require("blessed");
 const contrib = require("blessed-contrib");
 const Jack = require("./jack_client");
 const { settings } = require("./settings");
-const { modHostProcess } = require("./modhost_client");
+const { jack, modHost, modHostStatusEnum } = require("./store");
 
 const defaultWidgetStyle = {
   focus: {
@@ -13,7 +13,7 @@ const defaultWidgetStyle = {
 
 let focusIndex = 0;
 var mainScreen;
-var jackStatusWidget, modHostStatusWidget;
+var jackStatusWidget, modHostStatusWidget, logWidget;
 
 function setUpLayout(screen) {
   var grid = new contrib.grid({ rows: 12, cols: 12, screen: screen });
@@ -61,19 +61,17 @@ function setUpLayout(screen) {
 }
 
 function updateLayoutData() {
-  //   statusSampleRateWidget.content = Jack.status.SAMPLE_RATE;
-
   jackStatusWidget.content = `
-  JACK Status: ${Jack.status.JACK_STATUS}
-  Sample Rate: ${Jack.status.SAMPLE_RATE}
-  DSP Load: ${Jack.status.DSP_LOAD} %
+  JACK Status: ${jack.JACK_STATUS}
+  Sample Rate: ${jack.SAMPLE_RATE}
+  DSP Load: ${jack.DSP_LOAD} %
   `;
 
   modHostStatusWidget.content = `
-  mod-host Status: ${modHostProcess.STATUS}
-  mod-host PID: ${modHostProcess.PID}
-  mod-host Port: ${modHostProcess.PORT}
-  mod-host FB Port: ${modHostProcess.FEEDBACK_PORT}
+  mod-host Status: ${modHost.STATUS}
+  mod-host PID: ${modHost.PID}
+  mod-host Port: ${modHost.PORT}
+  mod-host FB Port: ${modHost.FEEDBACK_PORT}
   `;
 }
 
@@ -95,6 +93,7 @@ function focusPrev() {
   }
   focus();
   mainScreen.children[focusIndex].focusable === false ? focusPrev() : focus();
+  logWidget.log(msg);
 }
 
 function focus() {
@@ -103,11 +102,19 @@ function focus() {
 }
 
 function wlog(msg) {
-  logWidget.log(msg);
+  if (logWidget) {
+    logWidget.log(msg);
+  } else {
+    console.log(msg);
+  }
 }
 
 function wlogError(msg) {
-  logWidget.log(`{red-fg}${msg}{/}`);
+  if (logWidget) {
+    logWidget.log(`{red-fg}${msg}{/}`);
+  } else {
+    console.log(msg);
+  }
 }
 
 exports.setUpLayout = setUpLayout;

layout.js

@@ -0,0 +1,121 @@
+const { tabbedTreeToJSON, stringToTrimmedArray } = require("./string_utils");
+const { wlogError, wlog } = require("./layout");
+const { pluginsUriByName, saveCache, loadCache } = require("./store");
+const { settings } = require("./settings");
+
+/**
+ * Initialize: Scan for plugins and setup store (cache)
+ *
+ */
+function init() {
+  if (!settings.SCAN_PLUGINS) {
+    console.log("Loading plugins cache...");
+    loadCache(pluginsUriByName, "pluginsUriByName");
+    return;
+  }
+
+  console.log("Building plugins cache, please wait...");
+  try {
+    const names = lv2ls(true);
+    const uris = lv2ls(false);
+    names.forEach((name, index) => {
+      pluginsUriByName.set(name, uris[index]);
+    });
+    saveCache(pluginsUriByName, "pluginsUriByName");
+  } catch (error) {
+    wlog(error);
+  }
+}
+
+/**
+ * Gets all plugins Names AND Uris
+ *
+ * @returns An array of objects with name, uris as properties.
+ */
+function listAllPlugins() {
+  let arr = [];
+  try {
+    const names = lv2ls(true);
+    const uris = lv2ls(false);
+
+    names.forEach((name, index) => {
+      let obj = {};
+      obj.name = name;
+      obj.uri = uris[index];
+      arr.push(obj);
+    });
+    return arr;
+  } catch (error) {
+    wlog(error);
+    return error;
+  }
+}
+
+/**
+ * List all lv2 plugins available on the system.
+ * @param {boolean} [names=false] Show names instead of URIS
+ * @returns Returns an array with all plugins URIs/Names available on the system
+ */
+function lv2ls(names = false) {
+  const cp = require("child_process");
+  const param = names ? "-n" : "";
+  try {
+    const result = cp.execSync(`lv2ls ${param}`, { encoding: "utf8" });
+    return stringToTrimmedArray(result);
+  } catch (error) {
+    wlog(error);
+    return error;
+  }
+}
+
+/**
+ * Grep LV2 plugin by uris, filtered by regex.
+ *
+ * @param {string} [regex="."] Regex to query plugins. By default it will return all plugins available.
+ * @returns Returns an array with the plugins found filtered by the regex.
+ */
+function grep(regex = ".") {
+  const cp = require("child_process");
+  try {
+    const result = cp.execSync(
+      `python3 -m jackaudiotools.lv2.lv2_grep ${regex}`,
+      {
+        cwd: "./py",
+        encoding: "utf8",
+      }
+    );
+    return stringToTrimmedArray(result);
+  } catch (error) {
+    wlog(error);
+    return error;
+  }
+}
+
+/**
+ * Get detailed information about a plugin.
+ * @param {*} uri URI of the plugin.
+ * @returns Returns a JSON object with the plugin's LV2 properties.
+ */
+function pluginInfo(uri) {
+  const cp = require("child_process");
+
+  try {
+    const result = cp.execSync(
+      `python3 -m jackaudiotools.lv2.plugin_info ${uri}`,
+      {
+        cwd: "./py",
+        encoding: "utf8",
+      }
+    );
+    return JSON.parse(result);
+  } catch (error) {
+    wlogError(`Plugin ${uri} could not be loaded.`);
+    return error;
+  }
+}
+
+exports.lv2ls = lv2ls;
+exports.grep = grep;
+exports.pluginInfo = pluginInfo;
+exports.listAllPlugins = listAllPlugins;
+exports.init = init;