Feat: Add quickstart scripts #690
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 |
|---|---|---|
|
|
@@ -188,11 +188,18 @@ class LedgerConfig(LocalResource): | |
| LedgerConfigs = t.Dict[str, LedgerConfig] | ||
|
|
||
|
|
||
| class NodeConfig(TypedDict): | ||
| """Deployment node config.""" | ||
|
|
||
| ports: t.Optional[t.Dict[t.Union[str, int], t.Dict[int, int]]] | ||
| volumes: t.Optional[t.Union[t.Dict[str, str], t.Dict[t.Union[str, int], t.Dict[str, str]]]] | ||
|
|
||
|
|
||
| class DeploymentConfig(TypedDict): | ||
| """Deployments template.""" | ||
|
|
||
| agent: t.Optional[NodeConfig] | ||
| tendermint: t.Optional[NodeConfig] | ||
|
|
||
| class FundRequirementsTemplate(TypedDict): | ||
| """Fund requirement template.""" | ||
|
|
@@ -241,11 +248,13 @@ class ServiceTemplate(TypedDict, total=False): | |
| """Service template.""" | ||
|
|
||
| name: str | ||
| agent_id: int | ||
| hash: str | ||
| image: str | ||
| description: str | ||
| service_version: str | ||
| home_chain: str | ||
| staking_programs: t.Dict[str, str] | ||
|
There was a problem hiding this comment. What is the purpose of this ? There was a problem hiding this comment. so I need you to check a service template of the quickstart There was a problem hiding this comment. Makes sense moving the staking program to the service template, but the staking contract addresses are per chain. I.e., let's not assume they can only be made on the home chain. |
||
| configurations: ConfigurationTemplates | ||
| env_variables: EnvVariables | ||
|
|
||
|
|
||
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,92 @@ | ||
| import json | ||
| import os | ||
| import subprocess | ||
| import sys | ||
| from pathlib import Path | ||
| from typing import TYPE_CHECKING | ||
|
|
||
| from operate.constants import DEPLOYMENT | ||
|
|
||
| if TYPE_CHECKING: | ||
| from operate.cli import OperateApp | ||
|
|
||
|
|
||
| def find_build_directory(config_file: Path, operate: "OperateApp") -> Path: | ||
| """Find the appropriate build directory of the configured service.""" | ||
| with open(config_file, "r") as f: | ||
| config = json.load(f) | ||
| config_service_hash = config.get("hash") | ||
|
|
||
| services = operate.service_manager()._get_all_services() | ||
| for service in services: | ||
| if service.hash == config_service_hash: | ||
| build_dir = service.path / DEPLOYMENT | ||
| if not build_dir.exists(): | ||
| print(f"{config.get('name')} not deployed.") | ||
| sys.exit(1) | ||
| return build_dir | ||
|
|
||
| print(f"{config.get('name')} not found.") | ||
| sys.exit(1) | ||
|
|
||
|
|
||
| def run_analysis(logs_dir, **kwargs): | ||
| """Run the log analysis command.""" | ||
| command = [ | ||
| "poetry", "run", "autonomy", "analyse", "logs", | ||
| "--from-dir", logs_dir, | ||
| ] | ||
| if kwargs.get("agent"): | ||
| command.extend(["--agent", kwargs.get("agent")]) | ||
| if kwargs.get("reset_db"): | ||
| command.extend(["--reset-db"]) | ||
| if kwargs.get("start_time"): | ||
| command.extend(["--start-time", kwargs.get("start_time")]) | ||
| if kwargs.get("end_time"): | ||
| command.extend(["--end-time", kwargs.get("end_time")]) | ||
| if kwargs.get("log_level"): | ||
| command.extend(["--log-level", kwargs.get("log_level")]) | ||
| if kwargs.get("period"): | ||
| command.extend(["--period", kwargs.get("period")]) | ||
| if kwargs.get("round"): | ||
| command.extend(["--round", kwargs.get("round")]) | ||
| if kwargs.get("behaviour"): | ||
| command.extend(["--behaviour", kwargs.get("behaviour")]) | ||
| if kwargs.get("fsm"): | ||
| command.extend(["--fsm"]) | ||
| if kwargs.get("include_regex"): | ||
| command.extend(["--include-regex", kwargs.get("include_regex")]) | ||
| if kwargs.get("exclude_regex"): | ||
| command.extend(["--exclude-regex", kwargs.get("exclude_regex")]) | ||
|
|
||
| try: | ||
| subprocess.run(command, check=True) | ||
| print("Analysis completed successfully.") | ||
| except subprocess.CalledProcessError as e: | ||
| print(f"Command failed with exit code {e.returncode}") | ||
| sys.exit(e.returncode) | ||
| except FileNotFoundError: | ||
| print("Poetry or autonomy not found. Ensure they are installed and accessible.") | ||
| sys.exit(1) | ||
|
|
||
|
|
||
| def analyse_logs( | ||
| operate: "OperateApp", | ||
| config_path: str, | ||
| **kwargs | ||
| ): | ||
|
|
||
| config_file = Path(config_path) | ||
| if not config_file.exists(): | ||
| print(f"Config file '{config_file}' not found.") | ||
| sys.exit(1) | ||
|
|
||
| # Auto-detect the logs directory | ||
| build_dir = find_build_directory(config_file, operate) | ||
| logs_dir = os.path.join(build_dir, "persistent_data", "logs") | ||
| if not os.path.exists(logs_dir): | ||
| print(f"Logs directory '{logs_dir}' not found.") | ||
| sys.exit(1) | ||
|
|
||
| # Run the analysis | ||
| run_analysis(logs_dir, **kwargs) |
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Would the removal of Path.cwd not cause any issue?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
OPERATE_HOMEis already defined asPath.cwd() / OPERATEinoperate/constants.py