(self, exchange_id, symbol_argv, method_argv)
| 53 | return True |
| 54 | |
| 55 | async def init_inner(self, exchange_id, symbol_argv, method_argv): |
| 56 | self.parse_cli_args_and_props() |
| 57 | if self.request_tests and self.response_tests: |
| 58 | await self.run_static_request_tests(exchange_id, symbol_argv) |
| 59 | await self.run_static_response_tests(exchange_id, symbol_argv) |
| 60 | return True |
| 61 | if self.response_tests: |
| 62 | await self.run_static_response_tests(exchange_id, symbol_argv) |
| 63 | return True |
| 64 | if self.request_tests: |
| 65 | await self.run_static_request_tests(exchange_id, symbol_argv) # symbol here is the testname |
| 66 | return True |
| 67 | if self.id_tests: |
| 68 | await self.run_broker_id_tests() |
| 69 | return True |
| 70 | new_line = '\n' |
| 71 | dump(new_line + '' + new_line + '' + '[INFO] TESTING ', self.ext, { |
| 72 | 'exchange': exchange_id, |
| 73 | 'symbol': symbol_argv, |
| 74 | 'method': method_argv, |
| 75 | 'isWs': self.ws_tests, |
| 76 | 'useProxy': get_cli_arg_value('--useProxy'), |
| 77 | }, new_line) |
| 78 | exchange_args = { |
| 79 | 'verbose': self.verbose, |
| 80 | 'debug': self.debug, |
| 81 | 'enableRateLimit': True, |
| 82 | 'timeout': 30000, |
| 83 | } |
| 84 | exchange = init_exchange(exchange_id, exchange_args, self.ws_tests) |
| 85 | if exchange.alias: |
| 86 | dump(self.add_padding('[INFO] skipping alias', 25)) |
| 87 | exit_script(0) |
| 88 | await self.import_files(exchange) |
| 89 | # ensure test files are found & filled |
| 90 | assert len(list(self.test_files.keys())) > 0, 'Test files were not loaded' |
| 91 | self.expand_settings(exchange) |
| 92 | self.check_if_specific_test_is_chosen(method_argv) |
| 93 | await self.start_test(exchange, symbol_argv) |
| 94 | exit_script(0) # needed to be explicitly finished for WS tests |
| 95 | |
| 96 | def check_if_specific_test_is_chosen(self, method_argv): |
| 97 | if method_argv is not None: |
no test coverage detected