From 83f62dc21789b01db98af0c6c57f877670d949ed Mon Sep 17 00:00:00 2001
From: Robby Zambito <contact@robbyzambito.me>
Date: Sun, 3 Mar 2024 15:22:36 -0500
Subject: [PATCH] Remove router loop

---
 guestfs-inspectd.c | 47 +++++-----------------------------------------
 1 file changed, 5 insertions(+), 42 deletions(-)

diff --git a/guestfs-inspectd.c b/guestfs-inspectd.c
index 4bf816c..cf7d713 100644
--- a/guestfs-inspectd.c
+++ b/guestfs-inspectd.c
@@ -134,54 +134,17 @@ int main(int argc, char **argv) {
     return EXIT_FAILURE;
   }
 
-  const int worker_count = argc - 1;
-
-  // One worker per disk image.
-  struct {
-    char *name;
-    zactor_t *worker;
-  } worker_map[worker_count];
-
-  for (int i = 0; i < worker_count; i++) {
-    char *path = strtok(argv[i+1], ":");
-    worker_map[i].name = strtok(NULL, ":");
-    printf("name: %s\n", worker_map[i].name);
-    worker_map[i].worker = zactor_new(worker_task, path);
-  }
+  char *path = strtok(argv[1], ":");
+  char *name = strtok(NULL, ":");
+  printf("name: '%s'\n", name);
 
   char *ep = endpoint();
   printf("ep: %s\n", ep);
-  zsock_t *frontend = zsock_new_router(ep);
+  zsock_t *worker = zsock_new_rep(ep);
   free(ep);
 
-  while (true) {
-    zmsg_t *msg = zmsg_recv(frontend);
-    printf("Received a message in the router\n");
-    if (!msg) break;
+  worker_task(worker, path);
 
-    // Find the worker with the given name.
-    zactor_t *worker = NULL;
-    struct guestfs_inpsect_command *cmd = (struct guestfs_inpsect_command *) zmsg_last(msg);
-    for (int i = 0; i < worker_count; i++) {
-      if (STREQ(cmd->name, worker_map[i].name)) {
-        worker = worker_map[i].name;
-        break;
-      }
-    }
-
-    // TODO: REMOVE
-    if (!worker) {
-      worker = worker_map[0].worker;
-    }
-    // TODO: REMOVE
-
-    if (worker) {
-      zmsg_send(&msg, zactor_sock(worker));
-    } else {
-      // The name specified does not exist.
-      printf("There is no drive with the name %s\n.", cmd->name);
-    }
-  }
   return EXIT_SUCCESS;
 }