tools: initial implementation of a wireplumber-cli tool

Currently all it does is that it prints the properties
of all device nodes (Audio/Source & Audio/Sink), which
is useful for editing the configuration files

meson.build

@@ -41,3 +41,4 @@ subdir('lib')
 subdir('modules')
 subdir('src')
 subdir('tests')
+subdir('tools')

tools/meson.build

+executable('wireplumber-cli',
+  'wireplumber-cli.c',
+  c_args : [
+    '-D_GNU_SOURCE',
+    '-DG_LOG_USE_STRUCTURED',
+    '-DG_LOG_DOMAIN="wireplumber-cli"',
+  ],
+  install: true,
+  dependencies : [gobject_dep, gio_dep, wp_dep, pipewire_dep],
+)

tools/wireplumber-cli.c

+/* WirePlumber
+ *
+ * Copyright © 2019 Collabora Ltd.
+ *    @author George Kiagiadakis <george.kiagiadakis@collabora.com>
+ *
+ * SPDX-License-Identifier: MIT
+ */
+
+#include <wp/wp.h>
+#include <pipewire/pipewire.h>
+
+static GOptionEntry entries[] =
+{
+  { NULL }
+};
+
+struct WpCliData
+{
+  WpCore *core;
+  GMainLoop *loop;
+};
+
+static void
+on_objects_changed (WpObjectManager * om, struct WpCliData * d)
+{
+  g_autoptr (GPtrArray) arr = NULL;
+  guint i;
+  const struct spa_dict * dict;
+  const struct spa_dict_item *item;
+
+  arr = wp_object_manager_get_objects (om, WP_TYPE_PROXY_NODE);
+
+  g_print ("Capture device nodes:\n");
+
+  for (i = 0; i < arr->len; i++) {
+    WpProxyNode *node = g_ptr_array_index (arr, i);
+    g_autoptr (WpProperties) props = wp_proxy_node_get_properties (node);
+
+    if (g_strcmp0 (wp_properties_get (props, "media.class"), "Audio/Source") != 0)
+      continue;
+
+    g_print (" node id: %u\n", wp_proxy_get_global_id (WP_PROXY (node)));
+
+    dict = wp_properties_peek_dict (props);
+    spa_dict_for_each (item, dict) {
+      g_print ("    %s = \"%s\"\n", item->key, item->value);
+    }
+
+    g_print ("\n");
+  }
+
+  g_print ("Playback device nodes:\n");
+
+  for (i = 0; i < arr->len; i++) {
+    WpProxyNode *node = g_ptr_array_index (arr, i);
+    g_autoptr (WpProperties) props = wp_proxy_node_get_properties (node);
+
+    if (g_strcmp0 (wp_properties_get (props, "media.class"), "Audio/Sink") != 0)
+      continue;
+
+    g_print (" node id: %u\n", wp_proxy_get_global_id (WP_PROXY (node)));
+
+    dict = wp_properties_peek_dict (props);
+    spa_dict_for_each (item, dict) {
+      g_print ("    %s = \"%s\"\n", item->key, item->value);
+    }
+
+    g_print ("\n");
+  }
+
+  g_main_loop_quit (d->loop);
+}
+
+static void
+remote_state_changed (WpCore *core, WpRemoteState state,
+    struct WpCliData * d)
+{
+  switch (state) {
+  case WP_REMOTE_STATE_UNCONNECTED:
+    g_main_loop_quit (d->loop);
+    break;
+  case WP_REMOTE_STATE_ERROR:
+    g_message ("pipewire remote error");
+    g_main_loop_quit (d->loop);
+    break;
+  default:
+    break;
+  }
+}
+
+gint
+main (gint argc, gchar **argv)
+{
+  struct WpCliData data = {0};
+  g_autoptr (GOptionContext) context = NULL;
+  g_autoptr (GError) error = NULL;
+  g_autoptr (WpCore) core = NULL;
+  g_autoptr (WpObjectManager) om = NULL;
+  g_autoptr (GMainLoop) loop = NULL;
+
+  context = g_option_context_new ("- PipeWire Session/Policy Manager Helper CLI");
+  g_option_context_add_main_entries (context, entries, NULL);
+  if (!g_option_context_parse (context, &argc, &argv, &error)) {
+    return 1;
+  }
+
+  data.core = core = wp_core_new (NULL, NULL);
+  g_signal_connect (core, "remote-state-changed",
+      (GCallback) remote_state_changed, &data);
+
+  om = wp_object_manager_new ();
+  wp_object_manager_add_proxy_interest (om, PW_TYPE_INTERFACE_Node, NULL,
+      WP_PROXY_FEATURE_INFO);
+  g_signal_connect (om, "objects-changed",
+      (GCallback) on_objects_changed, &data);
+  wp_core_install_object_manager (core, om);
+
+  wp_core_connect (core);
+
+  data.loop = loop = g_main_loop_new (NULL, FALSE);
+  g_main_loop_run (loop);
+
+  return 0;
+}