11248Szelenkov@nginx.comimport os 21248Szelenkov@nginx.comimport unittest 31248Szelenkov@nginx.comfrom subprocess import call 41248Szelenkov@nginx.comfrom unit.applications.lang.python import TestApplicationPython 51248Szelenkov@nginx.com 61248Szelenkov@nginx.com 71248Szelenkov@nginx.comclass TestUSR1(TestApplicationPython): 81248Szelenkov@nginx.com prerequisites = {'modules': ['python']} 91248Szelenkov@nginx.com 101248Szelenkov@nginx.com def test_usr1_access_log(self): 111248Szelenkov@nginx.com self.load('empty') 121248Szelenkov@nginx.com 13*1397Szelenkov@nginx.com log = 'access.log' 14*1397Szelenkov@nginx.com log_new = 'new.log' 15*1397Szelenkov@nginx.com log_path = self.testdir + '/' + log 161248Szelenkov@nginx.com 171248Szelenkov@nginx.com self.assertIn( 181248Szelenkov@nginx.com 'success', 191248Szelenkov@nginx.com self.conf('"' + log_path + '"', 'access_log'), 201248Szelenkov@nginx.com 'access log configure', 211248Szelenkov@nginx.com ) 221248Szelenkov@nginx.com 231248Szelenkov@nginx.com self.assertTrue(self.waitforfiles(log_path), 'open') 241248Szelenkov@nginx.com 25*1397Szelenkov@nginx.com os.rename(log_path, self.testdir + '/' + log_new) 261248Szelenkov@nginx.com 27*1397Szelenkov@nginx.com self.assertEqual(self.get()['status'], 200) 281248Szelenkov@nginx.com 291248Szelenkov@nginx.com self.assertIsNotNone( 30*1397Szelenkov@nginx.com self.wait_for_record(r'"GET / HTTP/1.1" 200 0 "-" "-"', log_new), 311248Szelenkov@nginx.com 'rename new', 321248Szelenkov@nginx.com ) 331248Szelenkov@nginx.com self.assertFalse(os.path.isfile(log_path), 'rename old') 341248Szelenkov@nginx.com 351248Szelenkov@nginx.com with open(self.testdir + '/unit.pid', 'r') as f: 361248Szelenkov@nginx.com pid = f.read().rstrip() 371248Szelenkov@nginx.com 381248Szelenkov@nginx.com call(['kill', '-s', 'USR1', pid]) 391248Szelenkov@nginx.com 401248Szelenkov@nginx.com self.assertTrue(self.waitforfiles(log_path), 'reopen') 411248Szelenkov@nginx.com 42*1397Szelenkov@nginx.com self.assertEqual(self.get(url='/usr1')['status'], 200) 43*1397Szelenkov@nginx.com 44*1397Szelenkov@nginx.com self.stop() 451248Szelenkov@nginx.com 461248Szelenkov@nginx.com self.assertIsNotNone( 47*1397Szelenkov@nginx.com self.wait_for_record(r'"GET /usr1 HTTP/1.1" 200 0 "-" "-"', log), 481248Szelenkov@nginx.com 'reopen 2', 491248Szelenkov@nginx.com ) 501248Szelenkov@nginx.com self.assertIsNone( 51*1397Szelenkov@nginx.com self.search_in_log(r'/usr1', log_new), 'rename new 2' 521248Szelenkov@nginx.com ) 531248Szelenkov@nginx.com 541248Szelenkov@nginx.com @unittest.skip('not yet') 551248Szelenkov@nginx.com def test_usr1_unit_log(self): 561248Szelenkov@nginx.com self.load('log_body') 571248Szelenkov@nginx.com 58*1397Szelenkov@nginx.com log_new = 'new.log' 59*1397Szelenkov@nginx.com log_path = self.testdir + '/' + 'unit.log' 60*1397Szelenkov@nginx.com log_path_new = self.testdir + '/' + log_new 611248Szelenkov@nginx.com 621248Szelenkov@nginx.com os.rename(log_path, log_path_new) 631248Szelenkov@nginx.com 641248Szelenkov@nginx.com body = 'body_for_a_log_new' 65*1397Szelenkov@nginx.com self.assertEqual(self.post(body=body)['status'], 200) 661248Szelenkov@nginx.com 671248Szelenkov@nginx.com self.assertIsNotNone( 68*1397Szelenkov@nginx.com self.wait_for_record(body, log_new), 'rename new' 691248Szelenkov@nginx.com ) 701248Szelenkov@nginx.com self.assertFalse(os.path.isfile(log_path), 'rename old') 711248Szelenkov@nginx.com 721248Szelenkov@nginx.com with open(self.testdir + '/unit.pid', 'r') as f: 731248Szelenkov@nginx.com pid = f.read().rstrip() 741248Szelenkov@nginx.com 751248Szelenkov@nginx.com call(['kill', '-s', 'USR1', pid]) 761248Szelenkov@nginx.com 771248Szelenkov@nginx.com self.assertTrue(self.waitforfiles(log_path), 'reopen') 781248Szelenkov@nginx.com 791248Szelenkov@nginx.com body = 'body_for_a_log_unit' 80*1397Szelenkov@nginx.com self.assertEqual(self.post(body=body)['status'], 200) 81*1397Szelenkov@nginx.com 82*1397Szelenkov@nginx.com self.stop() 831248Szelenkov@nginx.com 841248Szelenkov@nginx.com self.assertIsNotNone(self.wait_for_record(body), 'rename new') 85*1397Szelenkov@nginx.com self.assertIsNone(self.search_in_log(body, log_new), 'rename new 2') 861248Szelenkov@nginx.com 871248Szelenkov@nginx.com # merge two log files into unit.log to check alerts 881248Szelenkov@nginx.com 891248Szelenkov@nginx.com with open(log_path, 'w') as unit_log, \ 90*1397Szelenkov@nginx.com open(log_path_new, 'r') as unit_log_new: 91*1397Szelenkov@nginx.com unit_log.write(unit_log_new.read()) 921248Szelenkov@nginx.com 931248Szelenkov@nginx.com 941248Szelenkov@nginx.comif __name__ == '__main__': 951248Szelenkov@nginx.com TestUSR1.main() 96