|
25 | 25 | TOP_DIR = os.path.dirname(os.path.dirname(os.path.realpath(__file__)))
|
26 | 26 |
|
27 | 27 |
|
28 |
| - |
29 |
| -def _create_update_user(cluster_id, grafana_url,grafana_secret,user_secret,update_secret): |
| 28 | +def _create_update_user(cluster_id, grafana_url, grafana_secret, user_secret, update_secret=False): |
30 | 29 | if not grafana_url.startswith("https://"):
|
31 | 30 | if grafana_url.startswith("http://"):
|
32 | 31 | grafana_url = grafana_url.replace("http://", "https://", 1)
|
@@ -78,11 +77,6 @@ def _create_update_user(cluster_id, grafana_url,grafana_secret,user_secret,updat
|
78 | 77 | time.sleep(5)
|
79 | 78 |
|
80 | 79 | return response.status_code == 200
|
81 |
| - |
82 |
| - |
83 |
| - |
84 |
| - |
85 |
| - |
86 | 80 |
|
87 | 81 |
|
88 | 82 | def _add_graylog_input(cluster_ip, password):
|
@@ -220,12 +214,12 @@ def create_cluster(blk_size, page_size_in_blocks, cli_pass,
|
220 | 214 | ret = scripts.deploy_stack(cli_pass, DEV_IP, constants.SIMPLY_BLOCK_DOCKER_IMAGE, c.secret, c.uuid,
|
221 | 215 | log_del_interval, metrics_retention_period)
|
222 | 216 | logger.info("Deploying swarm stack > Done")
|
223 |
| - |
224 |
| - if ret != 0: |
| 217 | + |
| 218 | + if ret == 0: |
| 219 | + logger.info("deploying swarm stack succeeded") |
| 220 | + else: |
225 | 221 | logger.error("deploying swarm stack failed")
|
226 |
| - |
227 |
| - logger.info("deploying swarm stack succeeded") |
228 |
| - |
| 222 | + |
229 | 223 | logger.info("Configuring DB...")
|
230 | 224 | out = scripts.set_db_config_single()
|
231 | 225 | logger.info("Configuring DB > Done")
|
@@ -314,8 +308,7 @@ def add_cluster(blk_size, page_size_in_blocks, cap_warn, cap_crit, prov_cap_warn
|
314 | 308 | cluster.db_connection = default_cluster.db_connection
|
315 | 309 | cluster.grafana_endpoint = default_cluster.grafana_endpoint
|
316 | 310 |
|
317 |
| - _create_update_user(cluster.uuid,cluster.grafana_endpoint,default_cluster.secret,cluster.secret,False) |
318 |
| - |
| 311 | + _create_update_user(cluster.uuid, cluster.grafana_endpoint, default_cluster.secret, cluster.secret) |
319 | 312 |
|
320 | 313 | if distr_ndcs == 0 and distr_npcs == 0:
|
321 | 314 | cluster.distr_ndcs = 4
|
@@ -620,12 +613,11 @@ def set_secret(cluster_id, secret):
|
620 | 613 | logger.error(f"Cluster not found {cluster_id}")
|
621 | 614 | return False
|
622 | 615 |
|
623 |
| - |
624 | 616 | secret = secret.strip()
|
625 | 617 | if len(secret) < 20:
|
626 | 618 | return "Secret must be at least 20 char"
|
627 | 619 |
|
628 |
| - _create_update_user(cluster_id,clusters[0].grafana_endpoint,clusters[0].secret,secret,True) |
| 620 | + _create_update_user(cluster_id, clusters[0].grafana_endpoint, clusters[0].secret, secret, update_secret=True) |
629 | 621 |
|
630 | 622 | cluster.secret = secret
|
631 | 623 | cluster.write_to_db(db_controller.kv_store)
|
|
0 commit comments