from base_test_ci import BaseTest
import config
import os
import time
from google.cloud import pubsub_v1
import unittest

class Test0(BaseTest):
    def test_verifyUp(self):
        testers_nodes = 1
        messages = self.run_phase(nodes = testers_nodes, bootstrap = 'false')
        messages = self.send_and_wait('SEND_UP', testers_nodes)
        self.assertEqual('UP', messages[0])

if __name__ == '__main__':
    unittest.main()