Adding SunSpec storage 124 Model

src/connections/sunspec/connection/inverter.ts

@@ -11,6 +11,11 @@ import { type SettingsModel } from '../models/settings.js';
 import { settingsModel } from '../models/settings.js';
 import { type StatusModel } from '../models/status.js';
 import { statusModel } from '../models/status.js';
+import {
+    type StorageModel,
+    type StorageModelWrite,
+} from '../models/storage.js';
+import { storageModel } from '../models/storage.js';
 import { SunSpecConnection } from './base.js';
 
 export class InverterSunSpecConnection extends SunSpecConnection {
@@ -29,6 +34,11 @@ export class InverterSunSpecConnection extends SunSpecConnection {
     // note: if any other software also writes to the controls model for properties we don't care about, we will overwrite them
     private controlsModelCache: ControlsModel | null = null;
 
+    // this software expects to solely control the inverter
+    // cache the storage model once permanently to avoid unnecessary reads
+    // note: if any other software also writes to the storage model for properties we don't care about, we will overwrite them
+    private storageModelCache: StorageModel | null = null;
+
     async getInverterModel() {
         const modelAddressById = await this.getModelAddressById();
 
@@ -169,4 +179,45 @@ export class InverterSunSpecConnection extends SunSpecConnection {
             values,
         });
     }
+
+    async getStorageModel() {
+        if (this.storageModelCache) {
+            return this.storageModelCache;
+        }
+
+        const modelAddressById = await this.getModelAddressById();
+
+        const address = modelAddressById.get(124);
+
+        if (!address) {
+            throw new Error('No SunSpec storage model address');
+        }
+
+        const data = await storageModel.read({
+            modbusConnection: this.modbusConnection,
+            address,
+            unitId: this.unitId,
+        });
+
+        this.storageModelCache = data;
+
+        return data;
+    }
+
+    async writeStorageModel(values: StorageModelWrite) {
+        const modelAddressById = await this.getModelAddressById();
+
+        const address = modelAddressById.get(124);
+
+        if (!address) {
+            throw new Error('No SunSpec storage model address');
+        }
+
+        return await storageModel.write({
+            modbusConnection: this.modbusConnection,
+            address,
+            unitId: this.unitId,
+            values,
+        });
+    }
 }