Skip to content

Commit

Permalink
fix: added code removed via erroneous commit
Browse files Browse the repository at this point in the history
  • Loading branch information
Aradhya-Tripathi authored and saxenabhishek committed Feb 28, 2022
1 parent 58319a2 commit 5b64175
Show file tree
Hide file tree
Showing 3 changed files with 26 additions and 23 deletions.
29 changes: 14 additions & 15 deletions bench/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,6 @@ def _setup_details_from_name_tag(self):
self.tag = self.tag or self.branch

def _setup_details_from_installed_apps(self):
self.branch = subprocess.check_output(["git", "rev-parse", "--abbrev-ref", "HEAD"])
self.org, self.repo, self.tag = os.path.split(
os.path.join(self.bench.name, "apps", self.name)
)[-2:] + (self.branch,)
Expand Down Expand Up @@ -183,24 +182,25 @@ def remove(self):
shutil.move(active_app_path, archived_app_path)

@step(title="Installing App {repo}", success="App {repo} Installed")
def install(self, skip_assets=False, verbose=False, restart_bench=True):
def install(self, skip_assets=False, verbose=False, restart_bench=True, resolved=False):
import bench.cli
from bench.utils.app import get_app_name

verbose = bench.cli.verbose or verbose
app_name = get_app_name(self.bench.name, self.repo)

# TODO: this should go inside install_app only tho - issue: default/resolved branch
setup_app_dependencies(
repo_name=self.repo,
bench_path=self.bench.name,
branch=self.tag,
verbose=verbose,
skip_assets=skip_assets,
)
if not resolved:
# TODO: this should go inside install_app only tho - issue: default/resolved branch
setup_app_dependencies(
repo_name=self.repo,
bench_path=self.bench.name,
branch=self.tag,
verbose=verbose,
skip_assets=skip_assets,
)

install_app(
app=app_name,
tag=self.tag,
bench_path=self.bench.name,
verbose=verbose,
skip_assets=skip_assets,
Expand All @@ -211,7 +211,6 @@ def install(self, skip_assets=False, verbose=False, restart_bench=True):
def install_resolved_apps(self, *args, **kwargs):
self.get()
self.install(*args, **kwargs, resolved=True)
self.bench.apps.update_apps_states(self.repo, self.tag)

@step(title="Uninstalling App {repo}", success="App {repo} Uninstalled")
def uninstall(self):
Expand All @@ -226,11 +225,9 @@ def _get_dependencies(self):
lines = [x for x in f.split("\n") if x.strip().startswith("required_apps")]
required_apps = eval(lines[0].strip("required_apps").strip().lstrip("=").strip())
return required_apps
except Exception as e:
except Exception:
return []

return info_file["required_apps"] if info_file else {}

def make_resolution_plan(app: App, bench: "Bench"):
"""
decide what apps and versions to install and in what order
Expand Down Expand Up @@ -482,6 +479,7 @@ def new_app(app, no_git=None, bench_path="."):

def install_app(
app,
tag,
bench_path=".",
verbose=False,
no_cache=False,
Expand Down Expand Up @@ -513,6 +511,7 @@ def install_app(
bench.run("yarn install", cwd=app_path)

bench.apps.sync()
bench.apps.update_apps_states(app, tag)

if not skip_assets:
build_assets(bench_path=bench_path, app=app)
Expand Down
16 changes: 8 additions & 8 deletions bench/bench.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,6 @@ class Bench(Base, Validator):
def __init__(self, path):
self.name = path
self.cwd = os.path.abspath(path)
self.apps_states = os.path.join(self.name, "sites", "apps_states.json")
self.exists = is_bench_directory(self.name)

self.setup = BenchSetup(self)
Expand Down Expand Up @@ -159,19 +158,20 @@ def get_installed_apps(self) -> List:
class BenchApps(MutableSequence):
def __init__(self, bench: Bench):
self.bench = bench
self.states_path = os.path.join(self.bench.name, "sites", "apps_states.json")
self.initialize_apps()

def initialize_states(self):
def set_states(self):
try:
with open(self.bench.apps_states, "r") as f:
with open(self.states_path, "r") as f:
self.states = json.loads(f.read() or "{}")
except FileNotFoundError:
with open(self.bench.apps_states, "w") as f:
with open(self.states_path, "w+") as f:
self.states = json.loads(f.read() or "{}")

def update_apps_states(self, app_name: str = None, resolution: str = None):
self.initialize_states()
self.initialize_apps()
self.set_states()
apps_to_remove = []
for app in self.states:
if app not in self.apps:
Expand All @@ -180,14 +180,14 @@ def update_apps_states(self, app_name: str = None, resolution: str = None):
for app in apps_to_remove:
del self.states[app]

if app_name and resolution:
version = get_current_version(app_name)
if app_name:
version = get_current_version(app_name, self.bench.name)
self.states[app_name] = {
"resolution": resolution,
"version": version,
}

with open(self.bench.apps_states, "w") as f:
with open(self.states_path, "w") as f:
f.write(json.dumps(self.states, indent=4))

def sync(self):
Expand Down
4 changes: 4 additions & 0 deletions bench/utils/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -208,6 +208,10 @@ def get_app_name(bench_path, repo_name):

return repo_name

def check_existing_dir(bench_path, repo_name):
cloned_path = os.path.join(bench_path, "apps", repo_name)
dir_already_exists = os.path.isdir(cloned_path)
return dir_already_exists, cloned_path

def get_current_version(app, bench_path="."):
current_version = None
Expand Down

0 comments on commit 5b64175

Please sign in to comment.