1 files changed, 95 insertions, 0 deletions
diff --git a/main.c b/main.c
new file mode 100644
index 0000000..fcc7511
--- /dev/null
+++ b/main.c
@@ -0,0 +1,95 @@
+/*
+ * Copyright (C) 2023 Mikhail Burakov. This file is part of receiver.
+ *
+ * receiver is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * receiver is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with receiver.  If not, see <https://www.gnu.org/licenses/>.
+ */
+
+#include <errno.h>
+#include <poll.h>
+#include <signal.h>
+#include <stddef.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+
+#include "decode.h"
+#include "util.h"
+#include "window.h"
+
+static volatile sig_atomic_t g_signal;
+static void OnSignal(int status) { g_signal = status; }
+
+int main(int argc, char* argv[]) {
+  (void)argc;
+  (void)argv;
+
+  struct AUTO(DecodeContext)* decode_context = DecodeContextCreate();
+  if (!decode_context) {
+    LOG("Failed to create decode context");
+    return EXIT_FAILURE;
+  }
+
+  struct AUTO(Window)* window = WindowCreate();
+  if (!window) {
+    LOG("Failed to create window");
+    return EXIT_FAILURE;
+  }
+
+  int events_fd = WindowGetEventsFd(window);
+  if (events_fd == -1) {
+    LOG("Failed to get events fd");
+    return EXIT_FAILURE;
+  }
+
+  if (signal(SIGINT, OnSignal) == SIG_ERR ||
+      signal(SIGTERM, OnSignal) == SIG_ERR) {
+    LOG("Failed to set signal handlers (%s)", strerror(errno));
+    return EXIT_FAILURE;
+  }
+
+  while (!g_signal) {
+    struct pollfd pfds[] = {
+        {.fd = STDIN_FILENO, .events = POLLIN},
+        {.fd = events_fd, .events = POLLIN},
+    };
+    switch (poll(pfds, LENGTH(pfds), -1)) {
+      case -1:
+        if (errno != EINTR) {
+          LOG("Failed to poll (%s)", strerror(errno));
+          return EXIT_FAILURE;
+        }
+        __attribute__((fallthrough));
+      case 0:
+        continue;
+      default:
+        break;
+    }
+    if (pfds[0].revents && !DecodeContextDecode(decode_context, STDIN_FILENO)) {
+      LOG("Failed to decode incoming data");
+      return EXIT_FAILURE;
+    }
+    if (pfds[1].revents && !WindowProcessEvents(window)) {
+      LOG("Failed to process window events");
+      return EXIT_FAILURE;
+    }
+    const struct Frame* frame = DecodeContextGetFrame(decode_context);
+    if (frame && !WindowRenderFrame(window, frame)) {
+      LOG("Failed to render frame");
+      return EXIT_FAILURE;
+    }
+  }
+
+  return EXIT_SUCCESS;
+}