added /api/v1/active (#1987)

synapse/lib/cell.py

@@ -1342,6 +1342,7 @@ async def fini():
     def _initCellHttpApis(self):
 
         self.addHttpApi('/api/v1/login', s_httpapi.LoginV1, {'cell': self})
+        self.addHttpApi('/api/v1/active', s_httpapi.ActiveV1, {'cell': self})
         self.addHttpApi('/api/v1/healthcheck', s_httpapi.HealthCheckV1, {'cell': self})
 
         self.addHttpApi('/api/v1/auth/users', s_httpapi.AuthUsersV1, {'cell': self})

synapse/lib/httpapi.py

@@ -822,6 +822,12 @@ async def get(self):
         resp = await self.cell.getHealthCheck()
         return self.sendRestRetn(resp)
 
+class ActiveV1(Handler):
+
+    async def get(self):
+        resp = {'active': self.cell.isactive}
+        return self.sendRestRetn(resp)
+
 class StormVarsGetV1(Handler):
 
     async def get(self):

synapse/tests/test_lib_httpapi.py

@@ -838,6 +838,14 @@ async def test_healthcheck(self):
             host, port = await core.addHttpsPort(0, host='127.0.0.1')
 
             root = await core.auth.getUserByName('root')
+
+            async with self.getHttpSess(auth=None, port=port) as sess:
+                url = f'https://localhost:{port}/api/v1/active'
+                async with sess.get(url) as resp:
+                    result = await resp.json()
+                    self.eq(result.get('status'), 'ok')
+                    self.true(result['result']['active'])
+
             await root.setPasswd('secret')
 
             url = f'https://localhost:{port}/api/v1/healthcheck'