start-validator.mjs 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  1. #!/usr/bin/env zx
  2. import { spawn } from 'node:child_process';
  3. import fs from 'node:fs';
  4. import 'zx/globals';
  5. import {
  6. getCargo,
  7. getExternalAccountAddresses,
  8. getExternalProgramAddresses,
  9. getExternalProgramOutputDir,
  10. getProgramFolders,
  11. } from './utils.mjs';
  12. // Options and arguments.
  13. const restart = argv['restart'];
  14. // Keep the validator running when not using the restart flag.
  15. const isValidatorRunning = (await $`lsof -t -i:8899`.quiet().exitCode) === 0;
  16. if (!restart && isValidatorRunning) {
  17. echo(chalk.yellow('Local validator is already running.'));
  18. process.exit();
  19. }
  20. // Initial message.
  21. const verb = isValidatorRunning ? 'Restarting' : 'Starting';
  22. // Get programs and accounts.
  23. const programs = [...getPrograms(), ...getExternalPrograms()];
  24. const programPluralized = programs.length === 1 ? 'program' : 'programs';
  25. const accounts = [...getExternalAccounts()];
  26. const accountsPluralized = accounts.length === 1 ? 'account' : 'accounts';
  27. echo(
  28. `${verb} local validator with ${programs.length} custom ${programPluralized}` +
  29. (accounts.length > 0
  30. ? ` and ${accounts.length} external ${accountsPluralized}...`
  31. : `...`)
  32. );
  33. // Kill the validator if it's already running.
  34. if (isValidatorRunning) {
  35. await $`pkill -f solana-test-validator`.quiet();
  36. await sleep(1000);
  37. }
  38. // Global validator arguments.
  39. const args = [/* Reset ledger */ '-r'];
  40. // Load programs.
  41. programs.forEach(({ programId, deployPath }) => {
  42. args.push(/* Load BPF program */ '--bpf-program', programId, deployPath);
  43. });
  44. // Load accounts.
  45. accounts.forEach(({ account, deployPath }) => {
  46. args.push(/* Load account */ '--account', account, deployPath);
  47. });
  48. // Start the validator in detached mode.
  49. const cliLogs = path.join(os.tmpdir(), 'validator-cli.log');
  50. fs.writeFileSync(cliLogs, '', () => {});
  51. const out = fs.openSync(cliLogs, 'a');
  52. const err = fs.openSync(cliLogs, 'a');
  53. const validator = spawn('solana-test-validator', args, {
  54. detached: true,
  55. stdio: ['ignore', out, err],
  56. });
  57. validator.unref();
  58. // Wait for the validator to stabilize.
  59. const waitForValidator = spinner(
  60. 'Waiting for local validator to stabilize...',
  61. () =>
  62. new Promise((resolve, reject) => {
  63. setInterval(() => {
  64. const logs = fs.readFileSync(cliLogs, 'utf8');
  65. if (validator.exitCode !== null) {
  66. reject(logs);
  67. } else if (logs.includes('Confirmed Slot: 1')) {
  68. resolve();
  69. }
  70. }, 1000);
  71. })
  72. );
  73. try {
  74. await waitForValidator;
  75. echo(chalk.green('Local validator is up and running!'));
  76. } catch (error) {
  77. echo(error);
  78. echo(chalk.red('Could not start local validator.'));
  79. } finally {
  80. fs.rmSync(cliLogs);
  81. process.exit();
  82. }
  83. function getPrograms() {
  84. const binaryDir = path.join(__dirname, '..', 'target', 'deploy');
  85. return getProgramFolders().map((folder) => {
  86. const cargo = getCargo(folder);
  87. const name = cargo.package.name.replace(/-/g, '_');
  88. return {
  89. programId: cargo.package.metadata.solana['program-id'],
  90. deployPath: path.join(binaryDir, `${name}.so`),
  91. };
  92. });
  93. }
  94. function getExternalPrograms() {
  95. const binaryDir = getExternalProgramOutputDir();
  96. return getExternalProgramAddresses().map((address) => ({
  97. programId: address,
  98. deployPath: path.join(binaryDir, `${address}.so`),
  99. }));
  100. }
  101. function getExternalAccounts() {
  102. const binaryDir = getExternalProgramOutputDir();
  103. return getExternalAccountAddresses().map((address) => ({
  104. account: address,
  105. deployPath: path.join(binaryDir, `${address}.json`),
  106. }));
  107. }