datagram_test.go

package sdm630

import (
	"testing"
	"time"

	// . "github.com/gonium/gosdm630"
	. "github.com/gonium/gosdm630/internal/meters"
)

func TestQuerySnipMerge(t *testing.T) {
	r := Readings{
		Timestamp: time.Now(),
		Unix:      time.Now().Unix(),
		DeviceId:  1,
		UniqueId:  "Instrument1",
		Power: ThreePhaseReadings{
			L1: F2fp(1.0), L2: F2fp(2.0), L3: F2fp(3.0),
		},
		Voltage: ThreePhaseReadings{
			L1: F2fp(1.0), L2: F2fp(2.0), L3: F2fp(3.0),
		},
		Current: ThreePhaseReadings{
			L1: F2fp(4.0), L2: F2fp(5.0), L3: F2fp(6.0),
		},
		Cosphi: ThreePhaseReadings{
			L1: F2fp(7.0), L2: F2fp(8.0), L3: F2fp(9.0),
		},
		Import: ThreePhaseReadings{
			L1: F2fp(10.0), L2: F2fp(11.0), L3: F2fp(12.0),
		},
		Export: ThreePhaseReadings{
			L1: F2fp(13.0), L2: F2fp(14.0), L3: F2fp(15.0),
		},
	}

	setvalue := float64(230.0)
	var sniptests = []struct {
		snip  QuerySnip
		param func(Readings) float64
	}{
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Voltage,
					IEC61850: "VolLocPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Voltage.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Voltage,
					IEC61850: "VolLocPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Voltage.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Voltage,
					IEC61850: "VolLocPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Voltage.L3) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Current,
					IEC61850: "AmpLocPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Current.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Current,
					IEC61850: "AmpLocPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Current.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Current,
					IEC61850: "AmpLocPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Current.L3) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Power,
					IEC61850: "WLocPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Power.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Power,
					IEC61850: "WLocPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Power.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Power,
					IEC61850: "WLocPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Power.L3) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Cosphi,
					IEC61850: "AngLocPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Cosphi.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Cosphi,
					IEC61850: "AngLocPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Cosphi.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Cosphi,
					IEC61850: "AngLocPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Cosphi.L3) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Import,
					IEC61850: "TotkWhImportPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Import.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Import,
					IEC61850: "TotkWhImportPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Import.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Import,
					IEC61850: "TotkWhImportPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Import.L3) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML1Export,
					IEC61850: "TotkWhExportPhsA",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Export.L1) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML2Export,
					IEC61850: "TotkWhExportPhsB",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Export.L2) },
		},
		{
			QuerySnip{
				DeviceId: 1, Value: setvalue,
				Operation: Operation{
					OpCode:   OpCodeSDML3Export,
					IEC61850: "TotkWhExportPhsC",
				},
			},
			func(r Readings) float64 { return Fp2f(r.Export.L3) },
		},
	}

	for _, test := range sniptests {
		r.MergeSnip(test.snip)
		if test.param(r) != setvalue {
			t.Errorf("Merge of querysnip failed: Expected %.2f, got %.2f",
				setvalue, test.param(r))
		}
	}
}