API: Pass readonly OSDP context to event callback

Author: Powerbyte7

examples/cpp/cp_app.cpp

@@ -50,8 +50,9 @@ static struct osdp_channel cp_channel = {
 	.close = nullptr,
 };
 
-int event_handler(void *data, int pd, struct osdp_event *event) {
+int event_handler(void *data, const osdp_t *ctx, int pd, struct osdp_event *event) {
 	(void)(data);
+	(void)(ctx);
 
 	std::cout << "PD" << pd << " EVENT: " << event->type << std::endl;
 	return 0;

examples/platformio/cp.ino

@@ -58,9 +58,10 @@ void init_cp_info()
     cp_channel.send = serial1_send_func;
 }
 
-int event_handler(void *data, int pd, struct osdp_event *event)
+int event_handler(void *data, const osdp_t *ctx, int pd, struct osdp_event *event)
 {
     (void)(data);
+    (void)(ctx);
 
     Serial.println("Received an event!");
     return 0;

include/osdp.h

@@ -1025,14 +1025,17 @@ typedef int (*pd_command_callback_t)(void *arg, struct osdp_cmd *cmd);
  *
  * @param arg Opaque pointer provided by the application during callback
  * registration.
+ * @param ctx OSDP context, can be used to retrieve additional
+ * PD information. 
  * @param pd PD offset (0-indexed) of this PD in `osdp_pd_info_t *` passed to
  * osdp_cp_setup()
  * @param ev pointer to osdp_event struct (filled by libosdp).
  *
  * @retval 0 on handling the event successfully.
  * @retval -ve on errors.
  */
-typedef int (*cp_event_callback_t)(void *arg, int pd, struct osdp_event *ev);
+typedef int (*cp_event_callback_t)(void *arg, const osdp_t *ctx, int pd,
+				   struct osdp_event *ev);
 
 /**
  * @brief Terminal status of a submitted command/event object.

python/osdp_sys/cp.c

@@ -69,8 +69,10 @@ static PyObject *pyosdp_cp_sc_status(pyosdp_cp_t *self, PyObject *args)
 	return Py_BuildValue("I", bitmask);
 }
 
-int pyosdp_cp_event_cb(void *data, int address, struct osdp_event *event)
+int pyosdp_cp_event_cb(void *data, const osdp_t* ctx, int address, struct osdp_event *event)
 {
+	(void)(ctx);
+	
 	pyosdp_cp_t *self = data;
 	PyObject *arglist, *result, *event_dict;
 

src/osdp_cp.c

@@ -58,10 +58,10 @@ enum osdp_cp_error_e {
 static void cp_dispatch_event(struct osdp_pd *pd,
 			      const struct osdp_event *event)
 {
-	struct osdp *ctx = pd_to_osdp(pd);
+	const struct osdp *ctx = pd_to_osdp(pd);
 
 	if (ctx->event_callback) {
-		ctx->event_callback(ctx->event_callback_arg, pd->idx,
+		ctx->event_callback(ctx->event_callback_arg, ctx, pd->idx,
 				    (struct osdp_event *)event);
 		osdp_metrics_report(pd, OSDP_METRIC_EVENT);
 	}
@@ -966,7 +966,7 @@ static int cp_get_online_command(struct osdp_pd *pd)
 
 static void notify_pd_status(struct osdp_pd *pd, bool is_online)
 {
-	struct osdp *ctx = pd_to_osdp(pd);
+	const struct osdp *ctx = pd_to_osdp(pd);
 	struct osdp_event evt;
 
 	if (!ctx->event_callback || !is_notifications_enabled(pd)) {
@@ -976,13 +976,13 @@ static void notify_pd_status(struct osdp_pd *pd, bool is_online)
 	evt.type = OSDP_EVENT_NOTIFICATION;
 	evt.notif.type = OSDP_NOTIFICATION_PD_STATUS;
 	evt.notif.arg0 = is_online;
-	ctx->event_callback(ctx->event_callback_arg, pd->idx, &evt);
+	ctx->event_callback(ctx->event_callback_arg, ctx, pd->idx, &evt);
 	osdp_metrics_report(pd, OSDP_METRIC_EVENT);
 }
 
 static void notify_sc_status(struct osdp_pd *pd)
 {
-	struct osdp *ctx = pd_to_osdp(pd);
+	const struct osdp *ctx = pd_to_osdp(pd);
 	struct osdp_event evt;
 
 	if (!ctx->event_callback || !is_notifications_enabled(pd)) {
@@ -993,14 +993,14 @@ static void notify_sc_status(struct osdp_pd *pd)
 	evt.notif.type = OSDP_NOTIFICATION_SC_STATUS;
 	evt.notif.arg0 = sc_is_active(pd);
 	evt.notif.arg1 = sc_use_scbkd(pd);
-	ctx->event_callback(ctx->event_callback_arg, pd->idx, &evt);
+	ctx->event_callback(ctx->event_callback_arg, ctx, pd->idx, &evt);
 	osdp_metrics_report(pd, OSDP_METRIC_EVENT);
 }
 
 void osdp_file_tx_notify_done(struct osdp_pd *pd, int file_id,
 			      enum osdp_file_tx_outcome outcome)
 {
-	struct osdp *ctx = pd_to_osdp(pd);
+	const struct osdp *ctx = pd_to_osdp(pd);
 	struct osdp_event evt;
 
 	if (!ctx->event_callback || !is_notifications_enabled(pd)) {
@@ -1011,7 +1011,7 @@ void osdp_file_tx_notify_done(struct osdp_pd *pd, int file_id,
 	evt.notif.type = OSDP_NOTIFICATION_FILE_TX_DONE;
 	evt.notif.arg0 = file_id;
 	evt.notif.arg1 = outcome;
-	ctx->event_callback(ctx->event_callback_arg, pd->idx, &evt);
+	ctx->event_callback(ctx->event_callback_arg, ctx, pd->idx, &evt);
 	osdp_metrics_report(pd, OSDP_METRIC_EVENT);
 }
 
@@ -1280,7 +1280,7 @@ static void notify_command_status(struct osdp_pd *pd, int status)
 {
 	int app_cmd;
 	struct osdp_event evt;
-	struct osdp *ctx = pd_to_osdp(pd);
+	const struct osdp *ctx = pd_to_osdp(pd);
 
 	if (!ctx->event_callback || !is_notifications_enabled(pd)) {
 		return;
@@ -1317,7 +1317,7 @@ static void notify_command_status(struct osdp_pd *pd, int status)
 	evt.notif.arg0 = app_cmd;
 	evt.notif.arg1 = status ? 0 : -1;
 
-	ctx->event_callback(ctx->event_callback_arg, pd->idx, &evt);
+	ctx->event_callback(ctx->event_callback_arg, ctx, pd->idx, &evt);
 	osdp_metrics_report(pd, OSDP_METRIC_EVENT);
 }
 

tests/unit-tests/test-async-fuzz.c

@@ -27,11 +27,12 @@ struct async_test_data {
 	bool event_generated;
 };
 
-static int async_event_callback(void *data, int pd, struct osdp_event *event)
+static int async_event_callback(void *data, const osdp_t *ctx, int pd, struct osdp_event *event)
 {
 	struct async_test_data *d = data;
 
 	ARG_UNUSED(pd);
+	ARG_UNUSED(ctx);
 	if (event->type == OSDP_EVENT_CARDREAD) {
 		d->event_generated = true;
 	}

tests/unit-tests/test-commands.c

@@ -40,8 +40,9 @@ struct test_command_ctx {
 
 static struct test_command_ctx g_test_ctx = {0};
 
-int test_commands_event_callback(void *arg, int pd, struct osdp_event *ev)
+int test_commands_event_callback(void *arg, const osdp_t* cp_ctx, int pd, struct osdp_event *ev)
 {
+	ARG_UNUSED(cp_ctx);
 	ARG_UNUSED(pd);
 	struct test_command_ctx *ctx = arg;
 

tests/unit-tests/test-events.c

@@ -28,9 +28,10 @@ struct test_event_ctx {
 
 static struct test_event_ctx g_test_ctx = {0};
 
-int test_events_event_callback(void *arg, int pd, struct osdp_event *ev)
+int test_events_event_callback(void *arg, const osdp_t *cp_ctx, int pd, struct osdp_event *ev)
 {
 	ARG_UNUSED(pd);
+	ARG_UNUSED(cp_ctx);
 	struct test_event_ctx *ctx = arg;
 
 	ctx->event_seen = true;

tests/unit-tests/test-file.c

@@ -169,10 +169,11 @@ struct file_tx_notification {
 
 static struct file_tx_notification g_notif;
 
-static int event_callback(void *arg, int pd, struct osdp_event *ev)
+static int event_callback(void *arg, const osdp_t *ctx, int pd, struct osdp_event *ev)
 {
 	ARG_UNUSED(arg);
 	ARG_UNUSED(pd);
+	ARG_UNUSED(ctx);
 
 	if (ev->type != OSDP_EVENT_NOTIFICATION) {
 		return 0;

tests/unit-tests/test-hotplug.c

@@ -33,9 +33,10 @@ static struct test_hotplug_ctx g_test_ctx = {0};
 
 static bool wait_for_pd_online(int timeout_sec);
 
-int test_hotplug_event_callback(void *arg, int pd, struct osdp_event *ev)
+int test_hotplug_event_callback(void *arg, const osdp_t *cp_ctx, int pd, struct osdp_event *ev)
 {
 	ARG_UNUSED(pd);
+	ARG_UNUSED(cp_ctx);
 	struct test_hotplug_ctx *ctx = arg;
 
 	ctx->event_seen = true;