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 cefb017c5f961c2111e23bec32e53288edc5529d..3ed5a2dc2113b4831ece1cb2a11d6d9b9f603c9a 100644 (file)
--- 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 247c45a3cf97658641eb8f795400a94d4dcd0769..67385fbd394cd175b8d0108f69e46b3c4e7ea79b 100644 (file)
--- 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) {