From 9bf6c9ade4f4d7ed9884095632d0c57448274a6d Mon Sep 17 00:00:00 2001
From: fastium <fastium.pro@proton.me>
Date: Fri, 5 Jun 2026 20:00:35 +0200
Subject: [PATCH] feat(MP/daemon): implement ipc server with callbacks

---
 src/06-mini-project/daemon/main.c | 105 +++++++++---------------------
 1 file changed, 30 insertions(+), 75 deletions(-)

diff --git a/src/06-mini-project/daemon/main.c b/src/06-mini-project/daemon/main.c
index 4b4b306..98c632b 100644
--- a/src/06-mini-project/daemon/main.c
+++ b/src/06-mini-project/daemon/main.c
@@ -11,117 +11,72 @@
 #include <syslog.h>
 #include <stdatomic.h>
 
-#include "timer/timer.h"
 #include "gpio/led.h"
 #include "gpio/button.h"
+#include "ipc/ipc_server.h"
 
 #define DEFAULT_TIME_MS 1000
 #define DUTY_CYCLE_PERCENT 2
 
+void set_mode(int mode) {
+    printf("set_mode: %d\n", mode);
+}
 
-typedef struct {
-    atomic_int flash_period_ms;
-    int timer_fd;
-    int epoll_fd;
-} ThreadData;
+void set_period(int period) {
+    printf("set_period: %d\n", period);
+}
 
-ThreadData data;
+uint32_t get_period() {
+    printf("get_period\n");
+    return 200;
+}
 
 void period_inc() {
-    int period = atomic_fetch_add(&data.flash_period_ms, 100);
-    printf("period_inc: flash_period_ms=%d\n", period + 100);
+    printf("period_inc\n");
 }
 
 void period_dec() {
-    int period = atomic_fetch_sub(&data.flash_period_ms, 100);
-    printf("period_dec: flash_period_ms=%d\n", period - 100);
+    printf("period_dec\n");
 }
 
 void period_reset() {
-    atomic_store(&data.flash_period_ms, DEFAULT_TIME_MS);
-    printf("period_reset: flash_period_ms=%d\n", DEFAULT_TIME_MS);
+    printf("period_reset\n");
 }
 
-static void* timer_thread(void* arg) {
-    ThreadData* data = (ThreadData*)arg;
-
-    led_t* led = led_init(LED_POWER);
-    led_off(led);
-
-    struct epoll_event ev;
-
-    int isLedOn = 0;
-    while(1) {
-
-        int n = epoll_wait(data->epoll_fd, &ev, 1, -1);
-        if (n == -1) {
-            perror("epoll_wait failed");
-            break;
-        }
-
-        uint64_t val;
-        if (read(data->timer_fd, &val, sizeof(val)) != sizeof(val)) {
-            perror("read timerfd failed");
-            break;
-        }
-
-        int period = atomic_load(&data->flash_period_ms);
-
-        long time_on_ms = period / 100 * DUTY_CYCLE_PERCENT; // 2% duty
-        long time_off_ms = period - time_on_ms; // rest of the period
-
-        int delay = 0;
-        if (isLedOn == 0) {
-            delay = time_on_ms; // 2% duty
-            led_on(led);
-            isLedOn = 1;
-        } else {
-            delay = time_off_ms; // rest of the period
-            led_off(led);
-            isLedOn = 0;
-        }
-
-        timer_set_time(&data->timer_fd, delay);
-
-    }
-    return NULL;
+void get_temp() {
+    printf("get_temp\n");
 }
 
-int main(int argc, char* argv[]) {
-    pthread_t thread;
+int main(void) {
 
-    atomic_store(&data.flash_period_ms, DEFAULT_TIME_MS);
-
-    // Create timerfd
-    data.timer_fd = timer_create_empty();
-    timer_set_time(&data.timer_fd, data.flash_period_ms);
-
-    // Create epoll instance for the timer
-    data.epoll_fd = epoll_create1(0);
-    if (data.epoll_fd == -1) {
-        perror("ERROR while create epoll");
-        exit(20);
-    }
-    timer_link_to_epoll(&data.timer_fd, &data.epoll_fd);
 
     btn_t* btn_inc = btn_init(BTN_INCREASE);
     btn_t* btn_dec = btn_init(BTN_DECREASE);
     btn_t* btn_mode = btn_init(BTN_MODE);
 
+    led_t* led_power = led_init(LED_POWER);
+
     btn_set_callback(btn_inc, period_inc);
     btn_set_callback(btn_dec, period_dec);
     btn_set_callback(btn_mode, period_reset);
 
+    struct ipc_callbacks_t ipc_cbs = {
+        .on_dec_frequency = period_dec,
+        .on_inc_frequency = period_inc,
+        .on_set_frequency = set_period,
+        .on_set_mode = set_mode,
+    };
 
-    if (pthread_create(&thread, NULL, timer_thread, &data) != 0) {
-        perror("Failed to create timer thread");
-        exit(30);
+    int ret = start_ipc_server(&ipc_cbs);
+    if (ret < 0) {
+        fprintf(stderr, "Failed to start IPC server: %d\n", ret);
+        return 1;
     }
 
     while (1) {
         sleep(1);
     }
 
-    closelog();
+    stop_ipc_server();
     return 0;
 }