Merge pull request #326 from fboundy/add_workflows

Add workflows

.github/workflows/auto_release.yaml

@@ -0,0 +1,48 @@
+name: Auto Release for Main Branch
+
+on:
+  push:
+    branches:
+      - main  # Trigger on pushes to the main branch
+  pull_request:
+    branches:
+      - main  # Trigger on pull requests targeting the main branch
+
+jobs:
+  publish-release:
+    name: Publish Release
+    runs-on: ubuntu-latest
+
+    steps:
+      # Step 1: Checkout the repository
+      - name: Checkout Repository
+        uses: actions/checkout@v3
+
+      # Step 2: Extract Version from `pv_opt.py`
+      - name: Extract Version
+        id: extract_version
+        run: |
+          # Extract the VERSION variable from pv_opt.py
+          VERSION=$(grep -oP '(?<=^VERSION = ")[^"]+' apps/pv_opt/pv_opt.py)
+          if [ -z "$VERSION" ]; then
+            echo "Error: VERSION not found in apps/pv_opt/pv_opt.py"
+            exit 1
+          fi
+          echo "VERSION=$VERSION"
+          echo "version=$VERSION" >> $GITHUB_ENV
+          echo "::set-output name=version::$VERSION"
+
+      # Step 3: Create GitHub Release
+      - name: Create GitHub Release
+        if: github.event_name == 'push' || github.event.pull_request.merged == true
+        uses: actions/create-release@v1
+        with:
+          tag_name: "v${{ env.version }}"
+          release_name: "Release v${{ env.version }}"
+          body: |
+            ## Changes
+            This release was automatically generated from the `main` branch.
+          draft: false
+          prerelease: false
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.test/solis_cloud_test.py

@@ -1,13 +1,14 @@
 # %%
+import base64
 import hashlib
 import hmac
-import base64
 import json
 import re
-import requests
-from http import HTTPStatus
 from datetime import datetime, timezone
+from http import HTTPStatus
+
 import pandas as pd
+import requests
 
 # def getInverterList(config):
 #     body = getBody(stationId=config['plantId'])
@@ -62,7 +63,9 @@ def get_body(self, **params):
         return body
 
     def digest(self, body: str) -> str:
-        return base64.b64encode(hashlib.md5(body.encode("utf-8")).digest()).decode("utf-8")
+        return base64.b64encode(hashlib.md5(body.encode("utf-8")).digest()).decode(
+            "utf-8"
+        )
 
     def header(self, body: str, canonicalized_resource: str) -> dict[str, str]:
         content_md5 = self.digest(body)
@@ -71,8 +74,22 @@ def header(self, body: str, canonicalized_resource: str) -> dict[str, str]:
         now = datetime.now(timezone.utc)
         date = now.strftime("%a, %d %b %Y %H:%M:%S GMT")
 
-        encrypt_str = "POST" + "\n" + content_md5 + "\n" + content_type + "\n" + date + "\n" + canonicalized_resource
-        hmac_obj = hmac.new(self.key_secret.encode("utf-8"), msg=encrypt_str.encode("utf-8"), digestmod=hashlib.sha1)
+        encrypt_str = (
+            "POST"
+            + "\n"
+            + content_md5
+            + "\n"
+            + content_type
+            + "\n"
+            + date
+            + "\n"
+            + canonicalized_resource
+        )
+        hmac_obj = hmac.new(
+            self.key_secret.encode("utf-8"),
+            msg=encrypt_str.encode("utf-8"),
+            digestmod=hashlib.sha1,
+        )
         sign = base64.b64encode(hmac_obj.digest())
         authorization = "API " + self.key_id + ":" + sign.decode("utf-8")
 
@@ -88,23 +105,29 @@ def header(self, body: str, canonicalized_resource: str) -> dict[str, str]:
     def inverter_id(self):
         body = self.get_body(stationId=self.plant_id)
         header = self.header(body, self.URLS["inverterList"])
-        response = requests.post(self.URLS["root"] + self.URLS["inverterList"], data=body, headers=header)
+        response = requests.post(
+            self.URLS["root"] + self.URLS["inverterList"], data=body, headers=header
+        )
         if response.status_code == HTTPStatus.OK:
             return response.json()["data"]["page"]["records"][0].get("id", "")
 
     @property
     def inverter_sn(self):
         body = self.get_body(stationId=self.plant_id)
         header = self.header(body, self.URLS["inverterList"])
-        response = requests.post(self.URLS["root"] + self.URLS["inverterList"], data=body, headers=header)
+        response = requests.post(
+            self.URLS["root"] + self.URLS["inverterList"], data=body, headers=header
+        )
         if response.status_code == HTTPStatus.OK:
             return response.json()["data"]["page"]["records"][0].get("sn", "")
 
     @property
     def inverter_details(self):
         body = self.get_body(id=self.inverter_id, sn=self.inverter_sn)
         header = self.header(body, self.URLS["inverterDetail"])
-        response = requests.post(self.URLS["root"] + self.URLS["inverterDetail"], data=body, headers=header)
+        response = requests.post(
+            self.URLS["root"] + self.URLS["inverterDetail"], data=body, headers=header
+        )
 
         if response.status_code == HTTPStatus.OK:
             return response.json()["data"]
@@ -125,7 +148,9 @@ def set_code(self, cid, value):
             body = self.get_body(inverterSn=self.inverter_sn, cid=cid, value=value)
             headers = self.header(body, self.URLS["control"])
             headers["token"] = self.token
-            response = requests.post(self.URLS["root"] + self.URLS["control"], data=body, headers=headers)
+            response = requests.post(
+                self.URLS["root"] + self.URLS["control"], data=body, headers=headers
+            )
             if response.status_code == HTTPStatus.OK:
                 return response.json()
 
@@ -137,14 +162,18 @@ def read_code(self, cid):
             body = self.get_body(inverterSn=self.inverter_sn, cid=cid)
             headers = self.header(body, self.URLS["atRead"])
             headers["token"] = self.token
-            response = requests.post(self.URLS["root"] + self.URLS["atRead"], data=body, headers=headers)
+            response = requests.post(
+                self.URLS["root"] + self.URLS["atRead"], data=body, headers=headers
+            )
             if response.status_code == HTTPStatus.OK:
                 return response.json()["data"]["msg"]
 
     def login(self):
         body = self.get_body(username=self.username, password=self.md5passowrd)
         header = self.header(body, self.URLS["login"])
-        response = requests.post(self.URLS["root"] + self.URLS["login"], data=body, headers=header)
+        response = requests.post(
+            self.URLS["root"] + self.URLS["login"], data=body, headers=header
+        )
         status = response.status_code
         if status == HTTPStatus.OK:
             result = response.json()
@@ -227,7 +256,7 @@ def set_timer(self, direction, start, end, power):
 # %%
 sc.set_mode_switch(35)
 # %%
-r=sc.set_code(696, 3600)
+r = sc.set_code(696, 3600)
 # %%
 
 # %%

apps/pv_opt/.test.py

@@ -1,16 +1,15 @@
 # %%
-import pandas as pd
+from datetime import datetime, time
+
+import matplotlib.pyplot as plt
 import numpy as np
+import pandas as pd
+import pvpy as pvpy
 import requests
-from datetime import datetime
-from datetime import time
-import matplotlib.pyplot as plt
 import yaml
 from influxdb_client import InfluxDBClient, Point
 from influxdb_client.client.write_api import SYNCHRONOUS
 
-import pvpy as pvpy
-
 entities = [
     "pv_total_power",
     "battery_input_energy",
@@ -39,9 +38,19 @@
     result = query_api.query(org=org, query=query)
 
     # Process the results
-    data = [{"Time": record.get_time(), "Value": record.get_value()} for record in result[-1].records]
+    data = [
+        {"Time": record.get_time(), "Value": record.get_value()}
+        for record in result[-1].records
+    ]
     series += [pd.DataFrame(data)]
-    series[-1] = series[-1].set_index("Time").resample("1min").mean().fillna(0)["Value"].rename(entity)
+    series[-1] = (
+        series[-1]
+        .set_index("Time")
+        .resample("1min")
+        .mean()
+        .fillna(0)["Value"]
+        .rename(entity)
+    )
 df = pd.concat(series, axis=1)
 df = df.resample("5min").mean()
 # Close the client