This commit is contained in:
andig 2024-08-24 11:45:57 +02:00
parent 0b0df05699
commit 42872ee34b

View file

@ -33,8 +33,12 @@ func (suite *connTestSuite) SetupSuite() {
for _, m := range []types.Measurand{
types.MeasurandPowerActiveImport,
types.MeasurandEnergyActiveImportRegister,
types.MeasurandVoltage,
types.MeasurandCurrentImport,
types.MeasurandCurrentImport + ".L1",
types.MeasurandCurrentImport + ".L2",
types.MeasurandCurrentImport + ".L3",
types.MeasurandVoltage + ".L1-N",
types.MeasurandVoltage + ".L2-N",
types.MeasurandVoltage + ".L3-N",
types.MeasurandCurrentOffered,
} {
suite.conn.measurements[m] = types.SampledValue{Value: "1"}
@ -60,19 +64,37 @@ func (suite *connTestSuite) TestConnectorMeasurementsNoTxn() {
suite.Equal(api.ErrTimeout, err, "Voltages")
}
func (suite *connTestSuite) TestConnectorMeasurementsRunningTxn() {
func (suite *connTestSuite) TestConnectorMeasurementsRunningTxnOutdated() {
// connected, running txn, no meter update since 1 hour
suite.clock.Add(time.Hour)
suite.conn.txnId = 1
_, err := suite.conn.CurrentPower()
suite.Require().Equal(api.ErrTimeout, err)
suite.Equal(api.ErrTimeout, err, "CurrentPower")
_, err = suite.conn.TotalEnergy()
suite.Require().Equal(api.ErrTimeout, err)
suite.Equal(api.ErrTimeout, err, "TotalEnergy")
_, err = suite.conn.GetMaxCurrent()
suite.Require().Equal(api.ErrTimeout, err)
suite.Equal(api.ErrTimeout, err, "GetMaxCurrent")
_, _, _, err = suite.conn.Currents()
suite.Require().Equal(api.ErrTimeout, err)
suite.Equal(api.ErrTimeout, err, "Currents")
_, _, _, err = suite.conn.Voltages()
suite.Require().Equal(api.ErrTimeout, err)
suite.Equal(api.ErrTimeout, err, "Voltages")
}
func (suite *connTestSuite) TestConnectorMeasurementsRunningTxn() {
// connected, running txn, no meter update since 1 hour
suite.clock.Add(time.Hour)
suite.conn.meterUpdated = suite.clock.Now()
suite.conn.txnId = 1
_, err := suite.conn.CurrentPower()
suite.NoError(err, "CurrentPower")
_, err = suite.conn.TotalEnergy()
suite.NoError(err, "TotalEnergy")
_, err = suite.conn.GetMaxCurrent()
suite.NoError(err, "GetMaxCurrent")
_, _, _, err = suite.conn.Currents()
suite.NoError(err, "Currents")
_, _, _, err = suite.conn.Voltages()
suite.NoError(err, "Voltages")
}