1 files changed, 66 insertions, 0 deletions
diff --git a/ctrl/libhicnctrl/src/modules/hicn_light/subscription.c b/ctrl/libhicnctrl/src/modules/hicn_light/subscription.c
new file mode 100644
index 000000000..d00055e89
--- /dev/null
+++ b/ctrl/libhicnctrl/src/modules/hicn_light/subscription.c
@@ -0,0 +1,66 @@
+#include <assert.h>
+#include <hicn/ctrl/api.h>
+#include <hicn/util/log.h>
+
+#include "base.h"
+#include "../../object_private.h"
+#include "subscription.h"
+
+static int hicnlight_subscription_parse(const u8 *buffer, size_t size,
+                                        hc_subscription_t *subscription) {
+  /* We should never have to parse subscriptions */
+  return -1;
+}
+
+int _hicnlight_subscription_parse(const uint8_t *buffer, size_t size,
+                                  hc_object_t *object) {
+  return hicnlight_subscription_parse(buffer, size, &object->subscription);
+}
+
+/* SUBSCRIPTION CREATE */
+
+int hicnlight_subscription_serialize_create(const hc_object_t *object,
+                                            uint8_t *packet) {
+  const hc_subscription_t *subscription = &object->subscription;
+
+  msg_subscription_add_t *msg = (msg_subscription_add_t *)packet;
+  *msg = (msg_subscription_add_t){
+      .header =
+          {
+              .message_type = REQUEST_LIGHT,
+              .command_id = COMMAND_TYPE_SUBSCRIPTION_ADD,
+              .length = 1,
+              .seq_num = 0,
+          },
+      .payload = {.topics = subscription->topics}};
+
+  return sizeof(msg_subscription_add_t);
+}
+
+/* SUBSCRIPTION DELETE */
+
+int hicnlight_subscription_serialize_delete(const hc_object_t *object,
+                                            uint8_t *packet) {
+  const hc_subscription_t *subscription = &object->subscription;
+
+  msg_subscription_remove_t *msg = (msg_subscription_remove_t *)packet;
+  *msg = (msg_subscription_remove_t){
+      .header =
+          {
+              .message_type = REQUEST_LIGHT,
+              .command_id = COMMAND_TYPE_SUBSCRIPTION_REMOVE,
+              .length = 1,
+              .seq_num = 0,
+          },
+      .payload = {.topics = subscription->topics}};
+
+  return sizeof(msg_subscription_remove_t);
+}
+
+int hicnlight_subscription_serialize_list(const hc_object_t *object,
+                                          uint8_t *packet) {
+  assert(!object);
+  return -1;
+}
+
+DECLARE_MODULE_OBJECT_OPS(hicnlight, subscription);