From: Michael Tremer <michael.tremer@ipfire.org>
Date: Sat, 5 Oct 2024 13:41:54 +0000 (+0000)
Subject: xfer: Make the WebSocket send callback more sensible
X-Git-Tag: 0.9.30~1160
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=be7d632ff15d67f2dfb4aa361f516b61e9fed908;p=pakfire.git

xfer: Make the WebSocket send callback more sensible

Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
---

diff --git a/src/libpakfire/include/pakfire/xfer.h b/src/libpakfire/include/pakfire/xfer.h
index cefb017c5..3ed5a2dc2 100644
--- a/src/libpakfire/include/pakfire/xfer.h
+++ b/src/libpakfire/include/pakfire/xfer.h
@@ -133,7 +133,7 @@ pakfire_xfer_error_code_t pakfire_xfer_run_api_request(
 // WebSocket
 typedef int (*pakfire_xfer_open_callback)(struct pakfire_xfer* xfer, void* data);
 typedef int (*pakfire_xfer_recv_callback)(struct pakfire_xfer* xfer, const char* message, const size_t size, void* data);
-typedef int (*pakfire_xfer_send_callback)(struct pakfire_xfer* xfer, const char* message, const size_t size, void* data);
+typedef int (*pakfire_xfer_send_callback)(struct pakfire_xfer* xfer, void* data);
 typedef int (*pakfire_xfer_close_callback)(struct pakfire_xfer* xfer, int code, void* data);
 
 int pakfire_xfer_socket(struct pakfire_xfer* xfer, pakfire_xfer_open_callback open,
diff --git a/src/libpakfire/xfer.c b/src/libpakfire/xfer.c
index 247c45a3c..67385fbd3 100644
--- a/src/libpakfire/xfer.c
+++ b/src/libpakfire/xfer.c
@@ -928,7 +928,16 @@ static int pakfire_xfer_allocate(struct pakfire_xfer* xfer, size_t size) {
 }
 
 static int pakfire_xfer_socket_send(struct pakfire_xfer* xfer) {
-	return -1; // TODO
+	int r;
+
+	// Just call the callback (if there is one)
+	if (xfer->callbacks.send) {
+		r = xfer->callbacks.send(xfer, xfer->callbacks.data);
+		if (r)
+			return r;
+	}
+
+	return 0;
 }
 
 static int pakfire_xfer_socket_recv(struct pakfire_xfer* xfer) {