Fun server client stuff do now be working xP

Author: Daxode

Blobtory/Scripts/Main.py

@@ -18,21 +18,32 @@
 
 
 class Main(ShowBase):
-    server: Server.Server
-    client: Client.Client
+    server: Server.Server = None
+    client: Client.Client = None
 
     def __init__(self):
         super().__init__()
         self.winCreator = WindowCreator(self, enableRP=False, isFullscreen=False)
         self.scene: SceneBuilder = SceneBuilder(self.winCreator)
         self.accept("c", self.ConnectClient)
         self.accept("v", self.StartServer)
+        self.accept("r", self.GoToNext)
 
     def StartServer(self):
-        self.server: Server = Server.Server(self.winCreator)
+        if self.server is None:
+            self.server: Server = Server.Server(self.winCreator)
+        else:
+            self.winCreator.baseData.debuggerMain.Inform("Server already connected")
 
     def ConnectClient(self):
-        self.client = Client.Client(self.winCreator)
+        if self.client is None:
+            self.client = Client.Client(self.winCreator, self.scene)
+        else:
+            self.winCreator.baseData.debuggerMain.Inform("Client already connected")
+
+    def GoToNext(self):
+        if self.client is not None:
+            self.client.GoNextMsg()
 
 
 loadPrcFileData('', 'framebuffer-srgb #t')

Blobtory/Scripts/Server/Client.py

@@ -1,11 +1,17 @@
 from direct.distributed.PyDatagram import PyDatagram
+from direct.distributed.PyDatagramIterator import PyDatagramIterator
+from direct.task import Task
 from panda3d.core import QueuedConnectionManager, QueuedConnectionListener, QueuedConnectionReader, ConnectionWriter
 from panda3d.core import PointerToConnection, NetAddress, NetDatagram
 
 from Blobtory.Scripts.Pipeline.WindowCreator import WindowCreator
+from Blobtory.Scripts.game.SceneBuilder import SceneBuilder
+
 
 class Client:
-    def __init__(self, winCreator: WindowCreator):
+    def __init__(self, winCreator: WindowCreator, scene: SceneBuilder):
+        self.winCreator = winCreator
+        self.scene = scene
         self.cManager = QueuedConnectionManager()
         self.cReader = QueuedConnectionReader(self.cManager, 0)
         self.cWriter = ConnectionWriter(self.cManager, 0)
@@ -14,12 +20,35 @@ def __init__(self, winCreator: WindowCreator):
         ip_address = "localhost"
         timeout = 3000  # 3 seconds
 
-        myConnection = self.cManager.openTCPClientConnection(ip_address, port_address, timeout)
-        if myConnection:
-            self.cReader.addConnection(myConnection)  # receive messages from server
+        self.winCreator.base.taskMgr.add(self.tskReaderPolling, "Poll the connection reader", -41)
+
+        self.myConnection = self.cManager.openTCPClientConnection(ip_address, port_address, timeout)
+        if self.myConnection:
+            self.cReader.addConnection(self.myConnection)  # receive messages from server
+
+    def tskReaderPolling(self, taskdata):
+        if self.cReader.dataAvailable():
+            datagram = NetDatagram()  # catch the incoming data in this instance
+            # Check the return value; if we were threaded, someone else could have
+            # snagged this data before we did
+            if self.cReader.getData(datagram):
+                self.myProcessDataFunction(datagram)
+        return Task.cont
+
+    def myProcessDataFunction(self, datagram):
+        myIterator = PyDatagramIterator(datagram)
+        msgID = myIterator.getUint8()
+        if msgID == 1:
+            messageToPrint = myIterator.getString()
+            if "Go" in messageToPrint:
+                if "Next" in messageToPrint:
+                    print("yay it worked")
+                    self.scene.planetGen.NextPoint()
 
-            myPyDatagram = PyDatagram()
-            myPyDatagram.addUint8(1)
-            myPyDatagram.addString("Hello, world!")
+            print(messageToPrint)
 
-            self.cWriter.send(myPyDatagram, myConnection)
+    def GoNextMsg(self):
+        myPyDatagram = PyDatagram()
+        myPyDatagram.addUint8(1)
+        myPyDatagram.addString("Go Next")
+        self.cWriter.send(myPyDatagram, self.myConnection)

Blobtory/Scripts/Server/Server.py

@@ -1,3 +1,4 @@
+from direct.distributed.PyDatagram import PyDatagram
 from direct.distributed.PyDatagramIterator import PyDatagramIterator
 from panda3d.core import QueuedConnectionManager, QueuedConnectionListener, QueuedConnectionReader, ConnectionWriter
 from panda3d.core import PointerToConnection, NetAddress, NetDatagram
@@ -54,4 +55,13 @@ def myProcessDataFunction(self, datagram):
         msgID = myIterator.getUint8()
         if msgID == 1:
             messageToPrint = myIterator.getString()
+            if "Go" in messageToPrint:
+                if "Next" in messageToPrint:
+                    print("go next on all clients")
+                    for clientConnection in self.activeConnections:
+                        myPyDatagram = PyDatagram()
+                        myPyDatagram.addUint8(1)
+                        myPyDatagram.addString("Go Next")
+                        self.cWriter.send(myPyDatagram, clientConnection)
+
             print(messageToPrint)

Blobtory/Scripts/game/SceneBuilder.py

@@ -7,6 +7,8 @@
 
 
 class SceneBuilder:
+    planetGen: PlanetGenerator
+
     def __init__(self, winCreator: WindowCreator):
         self.winCreator = winCreator
         self.base = winCreator.base
@@ -31,11 +33,11 @@ def SetupScene(self):
         Sequence(startInterval, endInterval).loop()
 
     def SetupPlanets(self):
-        planetGen: PlanetGenerator = PlanetGenerator(self.winCreator, 128, 450)
-        self.base.accept("d", self.IncreaseSize, [planetGen, 1.5])
-        self.base.accept("d-repeat", self.IncreaseSize, [planetGen, 1.5])
-        self.base.accept("a", self.IncreaseSize, [planetGen, -1.5])
-        self.base.accept("a-repeat", self.IncreaseSize, [planetGen, -1.5])
+        self.planetGen = PlanetGenerator(self.winCreator, 128, 450)
+        self.base.accept("d", self.IncreaseSize, [self.planetGen, 1.5])
+        self.base.accept("d-repeat", self.IncreaseSize, [self.planetGen, 1.5])
+        self.base.accept("a", self.IncreaseSize, [self.planetGen, -1.5])
+        self.base.accept("a-repeat", self.IncreaseSize, [self.planetGen, -1.5])
 
     def IncreaseSize(self, planetGen: PlanetGenerator, a):
         planetGen.cubeformer.mouseTime.setData(PTAFloat([10, 0, 0, planetGen.cubeformer.mouseTime.getElement(3)+a]))

Blobtory/Scripts/planet_former/PlanetGenerator.py

@@ -61,8 +61,6 @@ def __init__(self, winCreator: WindowCreator, gridSize: int, radius: float):
         self.RegenPlanet()
         self.winCreator.base.taskMgr.doMethodLater(1, self.UpdatePhysicsMesh, "Planet Physics Updater")
 
-        self.winCreator.base.accept("r", self.NextPoint)
-
     def NextPoint(self):
         for i in range(20): next(self.listOfItems)
         examplePointTo: NodeKey = next(self.listOfItems)

docs/Concept Art/.PlanetIcon.kra-autosave.kra

@@ -1,5 +1,5 @@
 panda3d~=1.10.7
-numpy~=1.19.3
+numpy~=1.19.4
 setuptools~=50.3.2
 multipledispatch~=0.6.0
 pip~=20.3b1