all done

python/nistoar/midas/dbio/base.py

@@ -901,9 +901,15 @@ def create_record(self, name: str, shoulder: str = None, foruser: str = None) ->
         rec.save()
         # Send a message through the WebSocket
         message = f"{name}"
-        asyncio.run(self.websocket_server.send_message_to_clients(message))
-        #print(message)
+        self._send_message_async(message)
         return rec
+
+    def _send_message_async(self, message):
+        loop = asyncio.get_event_loop()
+        if loop.is_running():
+            asyncio.create_task(self.websocket_server.send_message_to_clients(message))
+        else:
+            asyncio.run(self.websocket_server.send_message_to_clients(message))
 
     def _default_shoulder(self):
         out = self._cfg.get("default_shoulder")

python/tests/nistoar/midas/dbio/test_inmem.py

@@ -542,7 +542,6 @@ async def receive_messages(uri):
                         messages.append(message)
                         #print(f"Messages: {messages}")
                         # Break the loop after receiving the first message for this test
-                        break
             except Exception as e:
                 print(f"Failed to connect to WebSocket server: {e}")
 
@@ -553,17 +552,12 @@ async def receive_messages(uri):
 
         #await self.websocket_server.send_message_to_clients("Connection established")
         # Inject some data into the database
-        await self.websocket_server.send_message_to_clients("test1")
+        rec = self.cli.create_record("mine1")
         await asyncio.sleep(2)
-        id = "pdr0:0002"
-        rec = base.ProjectRecord(
-            base.DMP_PROJECTS, {"id": id, "name": "test 1"}, self.cli)
-        self.cli._db[base.DMP_PROJECTS][id] = rec.to_dict()
-
 
-        # Assert the number of messages received
+        #print(f"Messages: {messages}")
         self.assertEqual(len(messages), 1)
-        self.assertEqual(messages[0], "test1")
+        self.assertEqual(messages[0], "mine1")