WIP poc

bootstrap.py

@@ -46,37 +46,39 @@ api.add_resource(IdfGenerator, '/v1.4/energy-plus/idf-generator')
 # workflows
 api.add_resource(Costs, '/v1.4/workflow/costs')
 api.add_resource(EnergyPlus, '/v1.4/workflow/energy-plus')
-api.add_resource(InselMonthlyEnergyBalance, '/v1.4/workflow/insel-monthly-energy-balance')
+api.add_resource(InselMonthlyEnergyBalance,
+                 '/v1.4/workflow/insel-monthly-energy-balance')
 
-yml_path = Path('./docs/openapi-specs.yml').resolve()
+yml_path = Path('./hub/docs/openapi-specs.yml').resolve()
 
 with open(yml_path, "r") as stream:
-  swagger_config = {
-    "headers": [],
-    "specs": [
-      {
-        "endpoint": '/api/apispec',
-        "route": '/api/apispec/apispec.json',
-        "rule_filter": lambda rule: True,  # all in
-        "model_filter": lambda tag: True,  # all in
-      }
-    ],
-    "static_url_path": "/api/static",
-    "specs_route": "/api/api-docs/",
-    "openapi": "3.0.0"
-  }
-  try:
-    Swagger(app, template=yaml.safe_load(stream), config=swagger_config)
-  except yaml.YAMLError as exc:
-    print(f'error: {exc}')
+    swagger_config = {
+        "headers": [],
+        "specs": [
+            {
+                "endpoint": '/api/apispec',
+                "route": '/api/apispec/apispec.json',
+                "rule_filter": lambda rule: True,  # all in
+                "model_filter": lambda tag: True,  # all in
+            }
+        ],
+        "static_url_path": "/api/static",
+        "specs_route": "/api/api-docs/",
+        "openapi": "3.0.0"
+    }
+    try:
+        Swagger(app, template=yaml.safe_load(stream), config=swagger_config)
+    except yaml.YAMLError as exc:
+        print(f'error: {exc}')
 
 
 @app.route("/")
 def home():
-  return Response(headers={'Access-Control-Allow-Origin': '*'})
+    return Response(headers={'Access-Control-Allow-Origin': '*'})
 
 
 sh.debug_mode = True
 
-threading.Thread(target=sh.expired_sessions_collector, daemon=True, args="5").start()
+threading.Thread(target=sh.expired_sessions_collector,
+                 daemon=True, args="5").start()
 app.run(port=15789, host="0.0.0.0", debug=sh.debug_mode)

hub_api/workflow/costs.py

@@ -2,13 +2,22 @@ from flask_restful import Resource
 
 from hub_api.config import Config
 
+import json
+
+config_json_path = "../configs/config.json"
+
+with open(config_json_path, "r") as stream:
+    config = json.load(stream)
+    if config:
+        print(f'{json.dumps(config, indent=2)}')
+
 
 class Costs(Resource, Config):
-  def __init__(self):
-    super().__init__()
+    def __init__(self):
+        super().__init__()
 
-  def post(self):
-    """
-    API call for performing the cost workflow
-    """
-    raise NotImplementedError()
+    def post(self):
+        """
+        API call for performing the cost workflow
+        """
+        raise NotImplementedError()

microservice.py

@@ -0,0 +1,23 @@
+import datetime
+
+import flask
+import json
+from pathlib import Path
+from flasgger import LazyJSONEncoder, Swagger
+from flask import Response
+from flask_restful import Api
+import threading
+
+app = flask.Flask('cerc_api')
+app.json_provider_class = LazyJSONEncoder
+api = Api(app)
+
+# Parse and register services.json
+
+services_json_path = "./configs/services.json"
+
+for service in json.load(open(services_json_path)):
+    print(f"service: {service}")
+    api.add_resource(service["name"], service["endpoint"])
+
+app.run(port=5000, debug=True, host="0.0.0.0")

microservice/services.json

@@ -0,0 +1,9 @@
+{
+  "apiVersion": "v1.4.0",
+  "services": [
+    {
+      "name": "Costs",
+      "endpoint": "workflow/costs"
+    }
+  ]
+}

microservice/workflow/costs.py

@@ -0,0 +1,16 @@
+from flask_restful import Resource
+
+# from hub_api.config import Config
+
+import json
+
+
+class Costs(Resource):
+    def __init__(self):
+        super().__init__()
+
+    def post(self):
+        """
+        API call for performing the cost workflow
+        """
+        raise NotImplementedError()

requirements.txt

@@ -28,3 +28,4 @@ cerc-hub
 python-dotenv
 mapbox_earcut
 cerc-costs
+cerc-co2-emission