Add: scenario for testing blob service

1 files changed, 42 insertions, 0 deletions

diff --git a/yarns/900-local.yarn b/yarns/900-local.yarn
index 409a8e6..89652de 100644
--- a/yarns/900-local.yarn
+++ b/yarns/900-local.yarn
@@ -100,3 +100,45 @@ along with this program.  If not, see <http://www.gnu.org/licenses/>.
     name = get_next_match()
     filename = os.path.join(vars['statedir'], 'workers', name + '.yaml')
     assertTrue(os.path.exists(filename))
+
+## Start and stop blob service
+
+    IMPLEMENTS GIVEN blob service config uses (\S+) at the blob directory
+    vars['blobdir'] = get_next_match()
+
+    IMPLEMENTS GIVEN a running blob service
+    import os, time, cliapp, yaml
+    vars['blob_service.log'] = 'blob_service.log'
+    vars['gunicorn3_bs.log'] = 'gunicorn3_bs.log'
+    vars['bsport'] = random_free_port()
+    vars['bsurl'] = 'http://127.0.0.1:{}'.format(vars['bsport'])
+    config = {
+        'token-issuer': vars['issuer'],
+        'token-audience': vars['audience'],
+        'token-public-key': cat('token.key.pub'),
+        'log': [
+            {
+                'filename': vars['blob_service.log'],
+            },
+        ],
+        'blobdir': vars['blobdir'],
+    }
+    env = dict(os.environ)
+    env['BLOB_SERVICE_CONFIG'] = 'blob_service.yaml'
+    yaml.safe_dump(config, open('blob_service.yaml', 'w'))
+    argv = [
+        'gunicorn3',
+        '--daemon',
+        '--bind', '127.0.0.1:{}'.format(vars['bsport']),
+        '--log-file', vars['gunicorn3_bs.log'],
+        '--log-level', 'debug',
+        '-p', 'bspid',
+        'blob_service:app',
+    ]
+    cliapp.runcmd(argv, env=env)
+    vars['bspid'] = int(cat('bspid'))
+    wait_for_port(vars['bsport'])
+
+    IMPLEMENTS FINALLY stop blob service
+    import os, signal
+    os.kill(vars['bspid'], signal.SIGTERM)