Server that parses origin and starts a job with message path

websocketServer.py

@@ -1,19 +1,60 @@
 import asyncio
 import websockets
+import sys
+import json
+import importlib
+import pathlib
+import os
 
 async def hello(websocket):
-    name = await websocket.recv()
-    print(f"<<< {name}")
+    #websocket is a WebSocketServerProtocol
+    message = await websocket.recv()
+    host=websocket.remote_address[0]
 
-    greeting = f"Hello {name}!"
+    #delegate parsing to subroutine
+    #assume the message will be
+    #pathToPythonCode:argument
+    #where argument is some sort of a string or a number
 
+    #pathToPythonCode can have replacementStrings 
+    #that reflect local software arrangement,
+    #for example _softwareSrc_ will get replaced by 
+    #software/src directory from setup.json
+
+    message=':'.join([host,message])
+
+    print(f"<<< FROM: {host}")
+    print(f"<<< {message}")
+
+    greeting = f"Hello {message}!"
+    run(message)
     #await websocket.send(greeting)
     #don't send anything, just log
     print(f">>> {greeting}")
 
 async def main():
-    async with websockets.serve(hello, "193.2.68.227", 8765):
+    origins=["merlin","labkey-public","onko-nix",None]
+    #server="vangogh.fmf.uni-lj.si"
+    server="193.2.68.227"
+    async with websockets.serve(hello, server, 8765,origins=origins):
         await asyncio.Future()  # run forever
 
+def run(message):
+    args=message.split(':')
+    scriptFile=args[1]
+    fsetup=os.path.join(os.path.expanduser('~'),'.labkey','setup.json')
+    with open(fsetup) as f:
+        setup=json.load(f)
+
+    scriptFile=scriptFile.replace('_softwareSrc_',setup['paths']['softwareSrc'])
+        
+    spath=pathlib.Path(scriptFile)
+    print('script: {} [{}]{}'.format(scriptFile,spath.parent,spath.stem))
+    sys.path.append(str(spath.parent))
+    #print(sys.path)
+    module=importlib.import_module(spath.stem)
+    module.main(args[0],args[2])
+	
+
 if __name__ == "__main__":
     asyncio.run(main())