regression pushpull-v2 cortex for hotcount migr (SYN-9345)

cortexes/pushpull-v2/axon/axon.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/axon/blob.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/axon/cell.guid

@@ -0,0 +1 @@
+54a7ec684db3db24cc348a51763c01dc

cortexes/pushpull-v2/axon/cookie.secret

@@ -0,0 +1 @@
+0e7df0eb91e9f99e05d56197fea62159

cortexes/pushpull-v2/axon/slabs/cell.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/cell.guid

@@ -0,0 +1 @@
+cf8dc42935b289191a4a31a85e4884aa

cortexes/pushpull-v2/cookie.secret

@@ -0,0 +1 @@
+2bbcdd2010968d25426bb1a8d67d9f72

cortexes/pushpull-v2/jsonstor/cell.guid

@@ -0,0 +1 @@
+81d675e5690c4dd942cf0d605f62405b

cortexes/pushpull-v2/jsonstor/cookie.secret

@@ -0,0 +1 @@
+0cf3fa6cfecb5de587e0e85015dff3ab

cortexes/pushpull-v2/jsonstor/slabs/cell.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/2191f04f3b0d5c1b17ebf5f0be6a7506/layer_v2.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/2191f04f3b0d5c1b17ebf5f0be6a7506/nodedata.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/2191f04f3b0d5c1b17ebf5f0be6a7506/nodeedits.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/b333ec6901bf7c892629ff4bde9389cc/layer_v2.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/b333ec6901bf7c892629ff4bde9389cc/nodedata.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/b333ec6901bf7c892629ff4bde9389cc/nodeedits.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/dd924b9a39f26638411a719dfff6caca/layer_v2.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/dd924b9a39f26638411a719dfff6caca/nodedata.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/dd924b9a39f26638411a719dfff6caca/nodeedits.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/e2e19aefc3e535bf0040885f3c4b8e17/layer_v2.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/e2e19aefc3e535bf0040885f3c4b8e17/nodedata.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/layers/e2e19aefc3e535bf0040885f3c4b8e17/nodeedits.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/slabs/cell.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/slabs/graphs.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/slabs/nexus.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/slabs/nexuslog/seqn0000000000000000.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/slabs/queues.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/views/2fcfaa47f4c52588523ba2d350ce4ec2/viewstate.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/views/41552988daf582ac7d05813a834e9c26/viewstate.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/views/72bdda41d569c4eb9e74248fe29dce7d/viewstate.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

cortexes/pushpull-v2/views/92869a34b82f578120c0fa51da3d3f4e/viewstate.opts.yaml

@@ -0,0 +1,2 @@
+--- {}
+...

scripts/gen-pushpull-v2.py

@@ -0,0 +1,57 @@
+import shutil
+import asyncio
+
+import synapse.cortex as s_cortex
+import synapse.tools.backup as s_backup
+
+import synapse.lib.version as s_version
+
+async def main():
+
+    maxver = (2, 217, 0)
+    if s_version.version > (2, 217, 0):
+        verstr = '.'.join(map(str, maxver))
+        mesg = f'This regression cortex MUST be generated with a cortex LTE {verstr}, not {s_version.verstring}.'
+        raise s_exc.BadVersion(mesg=mesg, curv=s_version.verstring, maxver=maxver)
+
+    tmpdir = '/tmp/v/regress'
+    modldir = 'cortexes/pushpull-v2'
+
+    shutil.rmtree(tmpdir, ignore_errors=True)
+    shutil.rmtree(modldir, ignore_errors=True)
+
+    async with await s_cortex.Cortex.anit(tmpdir) as core:
+
+            await core.auth.rootuser.setPasswd('secret')
+            host, port = await core.dmon.listen('tcp://127.0.0.1:0/')
+
+            view0, layr0 = await core.callStorm('$view = $lib.view.get().fork() return(($view.iden, $view.layers.0.iden))')
+            view1, layr1 = await core.callStorm('$view = $lib.view.get().fork() return(($view.iden, $view.layers.0.iden))')
+            view2, layr2 = await core.callStorm('$view = $lib.view.get().fork() return(($view.iden, $view.layers.0.iden))')
+            opts = {'vars': {
+                'view0': view0,
+                'view1': view1,
+                'view2': view2,
+                'layr0': layr0,
+                'layr1': layr1,
+                'layr2': layr2,
+            }}
+
+            # view0 -push-> view1 <-pull- view2
+            await core.callStorm(f'$lib.layer.get($layr0).addPush("tcp://root:secret@127.0.0.1:{port}/*/layer/{layr1}")', opts=opts)
+            await core.callStorm(f'$lib.layer.get($layr2).addPull("tcp://root:secret@127.0.0.1:{port}/*/layer/{layr1}")', opts=opts)
+
+            await core.nodes('[ ps:contact=* ]', opts={'view': view0})
+
+            # wait for first write so we can get the correct offset
+            await core.layers.get(layr2).waitEditOffs(0, timeout=3)
+            offs = await core.layers.get(layr2).getEditOffs()
+
+            await core.nodes('[ ps:contact=* ]', opts={'view': view0})
+            await core.nodes('[ ps:contact=* ]', opts={'view': view0})
+            await core.layers.get(layr2).waitEditOffs(offs + 10, timeout=3)
+
+    s_backup.backup(tmpdir, modldir)
+
+if __name__ == '__main__':
+    asyncio.run(main())