Add support to servers tools to allow custom share names for telepath.

synapse/servers/axon.py

@@ -17,10 +17,12 @@ def parse(argv):
 
     https = os.getenv('SYN_AXON_HTTPS', '4443')
     telep = os.getenv('SYN_AXON_TELEPATH', 'tcp://0.0.0.0:27492/')
+    telen = os.getenv('SYN_AXON_NAME', None)
 
     pars = argparse.ArgumentParser(prog='synapse.servers.axon')
     pars.add_argument('--telepath', default=telep, help='The telepath URL to listen on.')
     pars.add_argument('--https', default=https, dest='port', type=int, help='The port to bind for the HTTPS/REST API.')
+    pars.add_argument('--name', default=telen, help='The (optional) additional name to share the Axon as.')
     pars.add_argument('axondir', help='The directory for the axon to use for storage.')
 
     return pars.parse_args(argv)
@@ -43,6 +45,10 @@ async def main(argv, outp=s_output.stdout):
         outp.printf('...axon API (https): %s' % (opts.port,))
         await axon.addHttpsPort(opts.port)
 
+        if opts.name:
+            outp.printf(f'...axon additional share name: {opts.name}')
+            axon.dmon.share(opts.name, axon)
+
         return axon
 
     except Exception:

synapse/servers/cortex.py

@@ -17,10 +17,12 @@ def parse(argv):
 
     https = os.getenv('SYN_CORTEX_HTTPS', '4443')
     telep = os.getenv('SYN_CORTEX_TELEPATH', 'tcp://0.0.0.0:27492/')
+    telen = os.getenv('SYN_CORTEX_NAME', None)
 
     pars = argparse.ArgumentParser(prog='synapse.servers.cortex')
     pars.add_argument('--telepath', default=telep, help='The telepath URL to listen on.')
     pars.add_argument('--https', default=https, dest='port', type=int, help='The port to bind for the HTTPS/REST API.')
+    pars.add_argument('--name', default=telen, help='The (optional) additional name to share the Cortex as.')
     pars.add_argument('coredir', help='The directory for the cortex to use for storage.')
 
     return pars.parse_args(argv)
@@ -43,6 +45,10 @@ async def main(argv, outp=s_output.stdout):
         outp.printf('...cortex API (https): %s' % (opts.port,))
         await core.addHttpsPort(opts.port)
 
+        if opts.name:
+            outp.printf(f'...cortex additional share name: {opts.name}')
+            core.dmon.share(opts.name, core)
+
         return core
 
     except Exception:

synapse/servers/cryotank.py

@@ -17,10 +17,12 @@ def parse(argv):
 
     https = os.getenv('SYN_CRYOTANK_HTTPS', '4443')
     telep = os.getenv('SYN_CRYOTANK_TELEPATH', 'tcp://0.0.0.0:27492/')
+    telen = os.getenv('SYN_CRYOTANK_NAME', None)
 
     pars = argparse.ArgumentParser(prog='synapse.servers.cryotank')
     pars.add_argument('--telepath', default=telep, help='The telepath URL to listen on.')
     pars.add_argument('--https', default=https, dest='port', type=int, help='The port to bind for the HTTPS/REST API.')
+    pars.add_argument('--name', default=telen, help='The (optional) additional name to share the Cryotank as.')
     pars.add_argument('cryodir', help='The directory for the cryotank server to use for storage.')
 
     return pars.parse_args(argv)
@@ -43,6 +45,10 @@ async def main(argv, outp=s_output.stdout):
         outp.printf('...cryotank API (https): %s' % (opts.port,))
         await cryo.addHttpsPort(opts.port)
 
+        if opts.name:
+            outp.printf(f'...cryotank additional share name: {opts.name}')
+            cryo.dmon.share(opts.name, cryo)
+
         return cryo
 
     except Exception:

synapse/tests/test_servers_axon.py

@@ -1,8 +1,5 @@
 import hashlib
 
-import synapse.common as s_common
-import synapse.telepath as s_telepath
-
 import synapse.servers.axon as s_s_axon
 
 import synapse.tests.utils as s_t_utils
@@ -17,13 +14,18 @@ async def test_server(self):
 
             outp = self.getTestOutp()
 
-            argv = [dirn, '--telepath', 'tcp://127.0.0.1:0/', '--https', '0']
+            argv = [dirn,
+                    '--telepath', 'tcp://127.0.0.1:0/',
+                    '--https', '0',
+                    '--name', 'teleaxon']
             async with await s_s_axon.main(argv, outp=outp) as axon:
                 async with axon.getLocalProxy() as proxy:
                     async with await proxy.upload() as fd:
                         await fd.write(b'asdfasdf')
                         await fd.save()
 
+                self.true(axon.dmon.shared.get('teleaxon') is axon)
+
             # And data persists...
             async with await s_s_axon.main(argv, outp=outp) as axon:
                 async with axon.getLocalProxy() as proxy:

synapse/tests/test_servers_cortex.py

@@ -14,14 +14,19 @@ async def test_server(self):
             outp = self.getTestOutp()
             guid = s_common.guid()
 
-            argv = [dirn, '--telepath', 'tcp://127.0.0.1:0/', '--https', '0']
+            argv = [dirn,
+                    '--telepath', 'tcp://127.0.0.1:0/',
+                    '--https', '0',
+                    '--name', 'telecore']
             async with await s_s_cortex.main(argv, outp=outp) as core:
 
                 async with await s_telepath.openurl(f'cell://{dirn}') as proxy:
                     # Make a node with the cortex
                     podes = await s_t_utils.alist(proxy.eval(f'[ou:org={guid}]'))
                     self.len(1, podes)
 
+                self.true(core.dmon.shared.get('telecore') is core)
+
             # And data persists...
             async with await s_s_cortex.main(argv, outp=outp) as core:
                 async with await s_telepath.openurl(f'cell://{dirn}') as proxy:

synapse/tests/test_servers_cryotank.py

@@ -0,0 +1,33 @@
+import synapse.servers.cryotank as s_s_cryo
+
+import synapse.tests.utils as s_t_utils
+
+class CryoServerTest(s_t_utils.SynTest):
+
+    async def test_server(self):
+
+        recs = (
+            ('hehe', {'haha': 1}),
+            ('woah', {'dude': 1}),
+        )
+
+        with self.getTestDir() as dirn:
+
+            outp = self.getTestOutp()
+
+            argv = [dirn,
+                    '--telepath', 'tcp://127.0.0.1:0/',
+                    '--https', '0',
+                    '--name', 'telecryo']
+            async with await s_s_cryo.main(argv, outp=outp) as cryotank:
+                async with cryotank.getLocalProxy() as proxy:
+                    await proxy.puts('foo', recs)
+
+                self.true(cryotank.dmon.shared.get('telecryo') is cryotank)
+
+            # And data persists...
+            async with await s_s_cryo.main(argv, outp=outp) as telecryo:
+                async with telecryo.getLocalProxy() as proxy:
+                    precs = await s_t_utils.alist(proxy.slice('foo', 0, 100))
+                    precs = [rec for offset, rec in precs]
+                    self.eq(precs, recs)