[Rust] Fixes to Net Module (#1725)

* chore(cargo): Add dependencies

* feat: Create new module `net` in lib_ccxr

feat: Create new module `net` in lib_ccxr

* feat: Add block related functionality in `block.rs`

* feat: Add `target.rs` module for sending data blocks related functions

* feat(modules): Add all necessary modules

* feat: Add `source.rs` module for reading data blocks related functions from source

* feat: Add C equivalent functions in rust

* feat(module): Add `net` module in `libccxr_export`

* chore(cargo): Update Cargo.lock

* feat: Add C equivalent code in `libccxr_exports` & use in `networking.c`

* chore: Remove unused imports

* chore(clippy): Fix clippy warnings

* Net Module: Fixes in parser.rs - removed an extra check

* Net Module: Fixes in block.rs - fixed formatting issues

* Net Module: Fixes in source.rs - rewrote UDP implementation and a few other fixes

* Net Module: Fixes in target.rs - fixed formatting issues

* Net module: Rebasing and formatting changes

* Net module: Clashing names after rebase

* Net module: Clippy errors

---------

Co-authored-by: IshanGrover2004 <[email protected]>

Author: steel-bucket

src/lib_ccx/networking.c

@@ -45,6 +45,24 @@ const char *srv_pwd;
 unsigned char *srv_header;
 size_t srv_header_len;
 
+#ifndef DISABLE_RUST
+extern void ccxr_connect_to_srv(const char *addr, const char *port, const char *cc_desc, const char *pwd);
+extern void ccxr_net_send_header(const unsigned char *data, size_t len);
+extern int ccxr_net_send_cc(const unsigned char *data, int length, void *private_data, struct cc_subtitle *sub);
+extern void ccxr_net_check_conn();
+extern void ccxr_net_send_epg(
+    const char *start,
+    const char *stop,
+    const char *title,
+    const char *desc,
+    const char *lang,
+    const char *category);
+extern int ccxr_net_tcp_read(int socket, void *buffer, size_t length);
+extern int ccxr_net_udp_read(int socket, void *buffer, size_t length, const char *src_str, const char *addr_str);
+extern int ccxr_start_tcp_srv(const char *port, const char *pwd);
+extern int ccxr_start_udp_srv(const char *src, const char *addr, unsigned port);
+#endif
+
 /*
  * Established connection to specified address.
  * Returns socked id
@@ -84,6 +102,9 @@ int set_nonblocking(int fd);
 
 void connect_to_srv(const char *addr, const char *port, const char *cc_desc, const char *pwd)
 {
+#ifndef DISABLE_RUST
+	return ccxr_connect_to_srv(addr, port, cc_desc, pwd);
+#endif
 	if (NULL == addr)
 	{
 		mprint("Server address is not set\n");
@@ -115,6 +136,9 @@ void connect_to_srv(const char *addr, const char *port, const char *cc_desc, con
 
 void net_send_header(const unsigned char *data, size_t len)
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_send_header(data, len);
+#endif
 	assert(srv_sd > 0);
 
 #if DEBUG_OUT
@@ -141,6 +165,9 @@ void net_send_header(const unsigned char *data, size_t len)
 
 int net_send_cc(const unsigned char *data, int len, void *private_data, struct cc_subtitle *sub)
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_send_cc(data, len, private_data, sub);
+#endif
 	assert(srv_sd > 0);
 
 #if DEBUG_OUT
@@ -160,6 +187,9 @@ int net_send_cc(const unsigned char *data, int len, void *private_data, struct c
 
 void net_check_conn()
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_check_conn();
+#endif
 	time_t now;
 	static time_t last_ping = 0;
 	char c = 0;
@@ -221,6 +251,9 @@ void net_send_epg(
     const char *lang,
     const char *category)
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_send_epg(start, stop, title, desc, lang, category);
+#endif
 	size_t st;
 	size_t sp;
 	size_t t;
@@ -301,6 +334,9 @@ void net_send_epg(
 
 int net_tcp_read(int socket, void *buffer, size_t length)
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_tcp_read(socket, buffer, length);
+#endif
 	assert(buffer != NULL);
 	assert(length > 0);
 
@@ -333,6 +369,9 @@ int net_tcp_read(int socket, void *buffer, size_t length)
 
 int net_udp_read(int socket, void *buffer, size_t length, const char *src_str, const char *addr_str)
 {
+#ifndef DISABLE_RUST
+	return ccxr_net_udp_read(socket, buffer, length, src_str, addr_str);
+#endif
 	assert(buffer != NULL);
 	assert(length > 0);
 
@@ -519,6 +558,9 @@ int tcp_connect(const char *host, const char *port)
 
 int start_tcp_srv(const char *port, const char *pwd)
 {
+#ifndef DISABLE_RUST
+	return ccxr_start_tcp_srv(port, pwd);
+#endif
 	if (NULL == port)
 		port = DFT_PORT;
 
@@ -974,6 +1016,10 @@ ssize_t read_byte(int fd, char *ch)
 
 int start_upd_srv(const char *src_str, const char *addr_str, unsigned port)
 {
+#ifndef DISABLE_RUST
+	return ccxr_start_udp_srv(src_str, addr_str, port);
+#endif
+
 	init_sockets();
 
 	in_addr_t src;