Added udp/dropPacket

Author: cmaglie

network-api/network-api.go

@@ -52,6 +52,7 @@ func Register(router *msgpackrouter.Router) {
 	_ = router.RegisterMethod("udp/endPacket", udpEndPacket)
 	_ = router.RegisterMethod("udp/awaitPacket", udpAwaitPacket)
 	_ = router.RegisterMethod("udp/read", udpRead)
+	_ = router.RegisterMethod("udp/dropPacket", udpDropPacket)
 	_ = router.RegisterMethod("udp/close", udpClose)
 }
 
@@ -527,6 +528,24 @@ func udpAwaitPacket(ctx context.Context, rpc *msgpackrpc.Connection, params []an
 	return []any{n, host, port}, nil
 }
 
+func udpDropPacket(ctx context.Context, rpc *msgpackrpc.Connection, params []any) (_result any, _err any) {
+	if len(params) != 1 && len(params) != 2 {
+		return nil, []any{1, "Invalid number of parameters, expected (UDP connection ID[, optional timeout in ms])"}
+	}
+	id, ok := msgpackrpc.ToUint(params[0])
+	if !ok {
+		return nil, []any{1, "Invalid parameter type, expected uint for UDP connection ID"}
+	}
+
+	lock.RLock()
+	delete(udpReadBuffers, id)
+	lock.RUnlock()
+	if !ok {
+		return nil, []any{2, fmt.Sprintf("UDP connection not found for ID: %d", id)}
+	}
+	return true, nil
+}
+
 func udpRead(ctx context.Context, rpc *msgpackrpc.Connection, params []any) (_result any, _err any) {
 	if len(params) != 2 && len(params) != 3 {
 		return nil, []any{1, "Invalid number of parameters, expected (UDP connection ID, max bytes to read)"}