Growatt support

config.schema.json

@@ -262,6 +262,27 @@
                 ],
                 "additionalProperties": false,
                 "description": "SMA inverter configuration"
+              },
+              {
+                "type": "object",
+                "properties": {
+                  "type": {
+                    "type": "string",
+                    "const": "growatt"
+                  },
+                  "connection": {
+                    "$ref": "#/definitions/config/properties/inverters/items/anyOf/0/properties/connection"
+                  },
+                  "unitId": {
+                    "$ref": "#/definitions/config/properties/inverters/items/anyOf/0/properties/unitId"
+                  }
+                },
+                "required": [
+                  "type",
+                  "connection"
+                ],
+                "additionalProperties": false,
+                "description": "Growatt inverter configuration"
               }
             ]
           },
@@ -349,6 +370,27 @@
               "additionalProperties": false,
               "description": "SMA meter configuration"
             },
+            {
+              "type": "object",
+              "properties": {
+                "type": {
+                  "type": "string",
+                  "const": "growatt"
+                },
+                "connection": {
+                  "$ref": "#/definitions/config/properties/inverters/items/anyOf/0/properties/connection"
+                },
+                "unitId": {
+                  "$ref": "#/definitions/config/properties/inverters/items/anyOf/0/properties/unitId"
+                }
+              },
+              "required": [
+                "type",
+                "connection"
+              ],
+              "additionalProperties": false,
+              "description": "Growatt meter configuration"
+            },
             {
               "type": "object",
               "properties": {

src/connections/modbus/connection/growatt.ts

@@ -0,0 +1,81 @@
+import { type ModbusSchema } from '../../../helpers/config.js';
+import { getModbusConnection } from '../connections.js';
+import { type GrowattInverterModels } from '../models/growatt/inverter.js';
+import { GrowattInveter1Model } from '../models/growatt/inverter.js';
+import { type GrowattInverterControl } from '../models/growatt/inverterControl.js';
+import { GrowattInverterControl1Model } from '../models/growatt/inverterControl.js';
+import { type GrowattMeterModels } from '../models/growatt/meter.js';
+import {
+    GrowattMeter1Model,
+    GrowattMeter2Model,
+} from '../models/growatt/meter.js';
+import { type ModbusConnection } from './base.js';
+import { type Logger } from 'pino';
+
+export class GrowattConnection {
+    protected readonly modbusConnection: ModbusConnection;
+    protected readonly unitId: number;
+    private logger: Logger;
+
+    constructor({ connection, unitId }: ModbusSchema) {
+        this.modbusConnection = getModbusConnection(connection);
+        this.unitId = unitId;
+        this.logger = this.modbusConnection.logger.child({
+            module: 'GrowattConnection',
+            unitId,
+        });
+    }
+
+    async getInverterModel(): Promise<GrowattInverterModels> {
+        const model1 = await GrowattInveter1Model.read({
+            modbusConnection: this.modbusConnection,
+            address: {
+                start: 0,
+                length: 3,
+            },
+            unitId: this.unitId,
+        });
+
+        return model1;
+    }
+
+    async getMeterModel(): Promise<GrowattMeterModels> {
+        const model1 = await GrowattMeter1Model.read({
+            modbusConnection: this.modbusConnection,
+            address: {
+                start: 37,
+                length: 10,
+            },
+            unitId: this.unitId,
+        });
+
+        const model2 = await GrowattMeter2Model.read({
+            modbusConnection: this.modbusConnection,
+            address: {
+                start: 1015,
+                length: 24,
+            },
+            unitId: this.unitId,
+        });
+
+        const data = { ...model1, ...model2 };
+
+        return data;
+    }
+
+    async writeInverterControlModel(values: GrowattInverterControl) {
+        return await GrowattInverterControl1Model.write({
+            modbusConnection: this.modbusConnection,
+            address: {
+                start: 3,
+                length: 1,
+            },
+            unitId: this.unitId,
+            values,
+        });
+    }
+
+    public onDestroy(): void {
+        this.modbusConnection.close();
+    }
+}

src/connections/modbus/modbusModelFactory.ts

@@ -1,7 +1,10 @@
 import { writeLatency } from '../../helpers/influxdb.js';
 import { objectEntriesWithType } from '../../helpers/object.js';
 import { type ModelAddress } from '../sunspec/connection/base.js';
-import { type ModbusConnection } from './connection/base.js';
+import {
+    type ModbusConnection,
+    type ModbusRegisterType,
+} from './connection/base.js';
 
 export type Mapping<
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -22,8 +25,13 @@ export function modbusModelFactory<
     // eslint-disable-next-line @typescript-eslint/no-explicit-any
     Model extends Record<string, any>,
     WriteableKeys extends keyof Model = never,
->(config: {
+>({
+    name,
+    type = 'holding',
+    mapping,
+}: {
     name: string;
+    type?: ModbusRegisterType;
     mapping: Mapping<Model, WriteableKeys>;
 }): {
     read(params: {
@@ -42,7 +50,7 @@ export function modbusModelFactory<
         read: async ({ modbusConnection, address, unitId }) => {
             const logger = modbusConnection.logger.child({
                 module: 'modbusModelFactory',
-                model: config.name,
+                model: name,
                 type: 'read',
             });
 
@@ -51,7 +59,7 @@ export function modbusModelFactory<
             await modbusConnection.connect();
 
             const registers = await modbusConnection.readRegisters({
-                type: 'holding',
+                type,
                 unitId,
                 start: address.start,
                 length: address.length,
@@ -77,7 +85,7 @@ export function modbusModelFactory<
                         }
                     })(),
                     unitId: unitId.toString(),
-                    model: config.name,
+                    model: name,
                     addressStart: address.start.toString(),
                     addressLength: address.length.toString(),
                 },
@@ -90,28 +98,28 @@ export function modbusModelFactory<
 
             return convertReadRegisters({
                 registers: registers.data,
-                mapping: config.mapping,
+                mapping,
             });
         },
         write: async ({ modbusConnection, address, unitId, values }) => {
             const logger = modbusConnection.logger.child({
                 module: 'modbusModelFactory',
-                model: config.name,
+                model: name,
                 type: 'write',
             });
 
             const start = performance.now();
 
             const registerValues = convertWriteRegisters({
                 values,
-                mapping: config.mapping,
+                mapping,
                 length: address.length,
             });
 
             await modbusConnection.connect();
 
             await modbusConnection.writeRegisters({
-                type: 'holding',
+                type,
                 unitId,
                 start: address.start,
                 data: registerValues,
@@ -137,7 +145,7 @@ export function modbusModelFactory<
                         }
                     })(),
                     unitId: unitId.toString(),
-                    model: config.name,
+                    model: name,
                     addressStart: address.start.toString(),
                     addressLength: address.length.toString(),
                 },

src/connections/modbus/models/growatt/inverter.ts

@@ -0,0 +1,32 @@
+import {
+    registersToUint16,
+    registersToUint32,
+} from '../../helpers/converters.js';
+import { modbusModelFactory } from '../../modbusModelFactory.js';
+
+export type GrowattInverterModels = GrowattInverter1;
+
+type GrowattInverter1 = {
+    // Inverter run state
+    // 0:waiting, 1:normal, 3:fault
+    InverterStatus: number;
+    // Input power
+    Ppv: number;
+};
+
+export const GrowattInveter1Model = modbusModelFactory<GrowattInverter1>({
+    name: 'GrowattInveter1Model',
+    type: 'input',
+    mapping: {
+        InverterStatus: {
+            start: 0,
+            end: 1,
+            readConverter: registersToUint16,
+        },
+        Ppv: {
+            start: 1,
+            end: 3,
+            readConverter: (value) => registersToUint32(value, -1),
+        },
+    },
+});

src/connections/modbus/models/growatt/inverterControl.ts

@@ -0,0 +1,29 @@
+import {
+    registersToUint16,
+    uint16ToRegisters,
+} from '../../helpers/converters.js';
+import { modbusModelFactory } from '../../modbusModelFactory.js';
+
+export type GrowattInverterControl = GrowattInverterControl1;
+
+export type GrowattInverterControl1 = {
+    // Inverter Max output active power percent
+    // 0-100 or 255
+    // 255: power is not belimited
+    ActivePRate: number;
+};
+
+export const GrowattInverterControl1Model = modbusModelFactory<
+    GrowattInverterControl1,
+    keyof GrowattInverterControl1
+>({
+    name: 'GrowattInverterControl1Model',
+    mapping: {
+        ActivePRate: {
+            start: 0,
+            end: 1,
+            readConverter: registersToUint16,
+            writeConverter: uint16ToRegisters,
+        },
+    },
+});