-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
added some non-interactive commands
- Loading branch information
Showing
5 changed files
with
179 additions
and
108 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,89 @@ | ||
| import {CLIConfig} from "../../config/config.js"; | ||
| import {removeExistingNetwork} from "./removeExistingNetwork.js"; | ||
| import ora from "ora"; | ||
| import {upContainer} from "./upContainer.js"; | ||
| import {Constants} from "../../config/constants.js"; | ||
| import {saveLatestConfig} from "../config/saveLatestConfig.js"; | ||
| import {waitForVMQueryToBeReady} from "../healthchecks/waitForVMQueryToBeReady.js"; | ||
| import {waitForAPIToBeReady} from "../healthchecks/waitForAPIToBeReady.js"; | ||
| import {execCustomInRepo, ExecError} from "../exec.js"; | ||
| import {ResultLogger} from "../../result/resultLogger.js"; | ||
|
|
||
| export async function createNetwork(config: CLIConfig) { | ||
| try { | ||
| await removeExistingNetwork() | ||
|
|
||
| if (config.shouldHaveElasticSearch) { | ||
| const startingElasticSearchSpinner = ora('Starting ElasticSearch container...').start() | ||
| await upContainer(Constants.ELASTIC_CONTAINER.name) | ||
| startingElasticSearchSpinner.succeed('Started ElasticSearch container') | ||
| } | ||
|
|
||
| if (config.shouldHaveMySQL) { | ||
| const startingMySQLSpinner = ora('Starting MySQL container...').start() | ||
| await upContainer(Constants.MYSQL_CONTAINER.name) | ||
| startingMySQLSpinner.succeed('Started MySQL container') | ||
| } | ||
|
|
||
| if (config.shouldHaveRedis) { | ||
| const startingRedisSpinner = ora('Starting Redis container...').start() | ||
| await upContainer(Constants.REDIS_CONTAINER.name) | ||
| startingRedisSpinner.succeed('Started Redis container') | ||
| } | ||
|
|
||
| if (config.shouldHaveRabbitMQ) { | ||
| const startingRabbitMQSpinner = ora('Starting RabbitMQ container...').start() | ||
| await upContainer(Constants.RABBITMQ_CONTAINER.name) | ||
| startingRabbitMQSpinner.succeed('Started RabbitMQ container') | ||
| } | ||
|
|
||
| const startingNetworkSpinner = ora('Starting network...').start() | ||
| await upContainer(Constants.TESTNET_CONTAINER.name, { | ||
| ...process.env, | ||
| "MX_LT_NUM_SHARDS": config.numberOfShards.toString(), | ||
| "MX_LT_ELASTIC_ENABLED": config.shouldHaveElasticSearch.toString(), | ||
| "MX_LT_CUSTOM_EGLD_ADDRESS": config.initialEGLDAddress ?? "" | ||
| }) | ||
| startingNetworkSpinner.succeed('Started network successfully') | ||
|
|
||
| await saveLatestConfig(config) | ||
|
|
||
| await waitForVMQueryToBeReady() | ||
|
|
||
| if (config.shouldHaveApi) { | ||
| const startingApiSpinner = ora('Starting API container...').start() | ||
| await upContainer(Constants.API_CONTAINER.name) | ||
| startingApiSpinner.succeed('Started API container') | ||
|
|
||
| const startingApiHealthCheckSpinner = ora('Waiting for API to be ready').start() | ||
| await waitForAPIToBeReady() | ||
| startingApiHealthCheckSpinner.succeed('API is ready') | ||
| } | ||
|
|
||
| if (config.mxOpsScenesPath) { | ||
| const copyingScenesSpinner = ora('Copying mxops scenes...').start() | ||
| await execCustomInRepo(`docker-compose cp ${config.mxOpsScenesPath} testnet:/home/ubuntu/mxops`) | ||
| copyingScenesSpinner.succeed('Copied mxops scenes') | ||
|
|
||
| const runningScenesSpinner = ora('Running mxops scenes...').start() | ||
| await execCustomInRepo(`docker-compose exec testnet python3 run_mxops.py`) | ||
| runningScenesSpinner.succeed('Ran mxops scenes') | ||
| } | ||
|
|
||
| const resultLogger = new ResultLogger() | ||
| await resultLogger.printResults(config) | ||
| } catch (e) { | ||
| try { | ||
| const error = e as ExecError | ||
| console.log("Error while running network...") | ||
| console.log("Command : ", error.error.cmd) | ||
| console.log("Exit code : ", error.error.code) | ||
| console.log("Message : ", error.stderr) | ||
| } catch (e2) { | ||
| console.log("Error while running network...") | ||
| console.log(e) | ||
| } | ||
|
|
||
| throw e | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| import {DockerPrerequisites} from "../../prerequisites/dockerPrerequisites.js"; | ||
| import {GitRepoPrerequisites} from "../../prerequisites/gitRepoPrerequisites.js"; | ||
|
|
||
| export async function checkPrerequisites() { | ||
| console.log('Checking prerequisites...') | ||
|
|
||
| try { | ||
| await (new DockerPrerequisites()).check() | ||
| await (new GitRepoPrerequisites()).check() | ||
| } catch (e) { | ||
| if (typeof e === 'string') { | ||
| console.log(e) | ||
| process.exit(1) | ||
| } else { | ||
| throw e | ||
| } | ||
| } | ||
| } |