Make sure ports are integers.

Author: dariusstefan

opensips/event/datagram.py

@@ -29,7 +29,7 @@ def __init__(self, **kwargs):
             self.sock_name = kwargs["unix_path"]
         elif "ip" in kwargs and "port" in kwargs:
             self.ip = kwargs["ip"]
-            self.port = kwargs["port"]
+            self.port = int(kwargs["port"])
             self.sock_name = f"udp:{self.ip}:{self.port}"
         else:
             raise ValueError("ip and port or unix_path is required for Datagram connector")

opensips/event/stream.py

@@ -28,7 +28,7 @@ def __init__(self, **kwargs):
             raise ValueError("port is required for Stream connector")
 
         self.ip = kwargs["ip"]
-        self.port = kwargs["port"]
+        self.port = int(kwargs["port"])
         self.sock_name = f"tcp:{self.ip}:{self.port}"
 
     def create(self):

opensips/mi/datagram.py

@@ -4,14 +4,14 @@
 
 class Datagram(Connection):
     def __init__(self, **kwargs):
-        if "ip" not in kwargs:
-            raise ValueError("ip is required for Datagram connector")
+        if "datagram_ip" not in kwargs:
+            raise ValueError("datagram_ip is required for Datagram connector")
 
-        if "port" not in kwargs:
-            raise ValueError("port is required for Datagram connector")
+        if "datagram_port" not in kwargs:
+            raise ValueError("datagram_port is required for Datagram connector")
 
-        self.ip = kwargs["ip"]
-        self.port = kwargs["port"]
+        self.ip = kwargs["datagram_ip"]
+        self.port = int(kwargs["datagram_port"])
 
     def execute(self, method: str, params: dict):
         jsoncmd = jsonrpc_helper.get_command(method, params)