Added cell.isCellActive() API

synapse/lib/cell.py

@@ -147,6 +147,12 @@ def getCellType(self):
     def getCellIden(self):
         return self.cell.getCellIden()
 
+    async def isCellActive(self):
+        '''
+        Returns True if the cell is an active/leader cell.
+        '''
+        return await self.cell.isCellActive()
+
     @adminapi()
     def getNexsIndx(self):
         return self.cell.getNexsIndx()
@@ -983,6 +989,9 @@ async def _killActiveCoro(self, cdef):
             task.cancel()
             await asyncio.sleep(0)
 
+    async def isCellActive(self):
+        return self.isactive
+
     async def setCellActive(self, active):
         self.isactive = active
 

synapse/tests/test_lib_cell.py

@@ -241,6 +241,7 @@ async def test_cell_unix_sock(self):
             async with core.getLocalProxy() as prox:
                 user = await prox.getCellUser()
                 self.eq('root', user.get('name'))
+                self.true(await prox.isCellActive())
 
         # Explicit use of the unix:// handler
         async with self.getTestCore() as core: