forked from lorenzodonini/ocpp-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathpublish_firmware_test.go
115 lines (107 loc) · 6.37 KB
/
publish_firmware_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
package ocpp2_test
import (
"fmt"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/mock"
"github.com/stretchr/testify/require"
"github.com/lorenzodonini/ocpp-go/ocpp2.0.1/firmware"
"github.com/lorenzodonini/ocpp-go/ocpp2.0.1/types"
)
// Test
func (suite *OcppV2TestSuite) TestPublishFirmwareRequestValidation() {
t := suite.T()
var requestTable = []GenericTestEntry{
{firmware.NewPublishFirmwareRequest("https://someurl", "deadbeef", 42), true},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(5), Checksum: "deadbeef", RequestID: 42, RetryInterval: newInt(300)}, true},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(5), Checksum: "deadbeef", RequestID: 42}, true},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Checksum: "deadbeef", RequestID: 42}, true},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Checksum: "deadbeef"}, true},
{firmware.PublishFirmwareRequest{Location: "http://someurl"}, false},
{firmware.PublishFirmwareRequest{Checksum: "deadbeef"}, false},
{firmware.PublishFirmwareRequest{}, false},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(5), Checksum: "deadbeef", RequestID: 42, RetryInterval: newInt(-1)}, false},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(5), Checksum: "deadbeef", RequestID: -1, RetryInterval: newInt(300)}, false},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(5), Checksum: ">32..............................", RequestID: 42, RetryInterval: newInt(300)}, false},
{firmware.PublishFirmwareRequest{Location: "http://someurl", Retries: newInt(-1), Checksum: "deadbeef", RequestID: 42, RetryInterval: newInt(300)}, false},
{firmware.PublishFirmwareRequest{Location: ">512.............................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................", Retries: newInt(5), Checksum: "deadbeef", RequestID: 42, RetryInterval: newInt(300)}, false},
}
ExecuteGenericTestTable(t, requestTable)
}
func (suite *OcppV2TestSuite) TestPublishFirmwareResponseValidation() {
t := suite.T()
var confirmationTable = []GenericTestEntry{
{firmware.PublishFirmwareResponse{Status: types.GenericStatusAccepted, StatusInfo: &types.StatusInfo{ReasonCode: "ok", AdditionalInfo: "someInfo"}}, true},
{firmware.PublishFirmwareResponse{Status: types.GenericStatusAccepted}, true},
{firmware.PublishFirmwareResponse{}, false},
{firmware.PublishFirmwareResponse{Status: "invalidStatus"}, false},
{firmware.PublishFirmwareResponse{Status: types.GenericStatusAccepted, StatusInfo: &types.StatusInfo{}}, false},
}
ExecuteGenericTestTable(t, confirmationTable)
}
func (suite *OcppV2TestSuite) TestPublishFirmwareE2EMocked() {
t := suite.T()
wsId := "test_id"
messageId := defaultMessageId
wsUrl := "someUrl"
location := "http://someUrl"
retries := newInt(5)
checksum := "deadc0d3"
requestID := 42
retryInterval := newInt(300)
status := types.GenericStatusAccepted
statusInfo := types.StatusInfo{ReasonCode: "ok", AdditionalInfo: "someInfo"}
requestJson := fmt.Sprintf(`[2,"%v","%v",{"location":"%v","retries":%v,"checksum":"%v","requestId":%v,"retryInterval":%v}]`,
messageId, firmware.PublishFirmwareFeatureName, location, *retries, checksum, requestID, *retryInterval)
responseJson := fmt.Sprintf(`[3,"%v",{"status":"%v","statusInfo":{"reasonCode":"%v","additionalInfo":"%v"}}]`,
messageId, status, statusInfo.ReasonCode, statusInfo.AdditionalInfo)
publishFirmwareResponse := firmware.NewPublishFirmwareResponse(status)
publishFirmwareResponse.StatusInfo = &statusInfo
channel := NewMockWebSocket(wsId)
handler := &MockChargingStationFirmwareHandler{}
handler.On("OnPublishFirmware", mock.Anything).Return(publishFirmwareResponse, nil).Run(func(args mock.Arguments) {
request := args.Get(0).(*firmware.PublishFirmwareRequest)
assert.Equal(t, location, request.Location)
assert.Equal(t, *retries, *request.Retries)
assert.Equal(t, checksum, request.Checksum)
assert.Equal(t, requestID, request.RequestID)
assert.Equal(t, *retryInterval, *request.RetryInterval)
})
setupDefaultCSMSHandlers(suite, expectedCSMSOptions{clientId: wsId, rawWrittenMessage: []byte(requestJson), forwardWrittenMessage: true})
setupDefaultChargingStationHandlers(suite, expectedChargingStationOptions{serverUrl: wsUrl, clientId: wsId, createChannelOnStart: true, channel: channel, rawWrittenMessage: []byte(responseJson), forwardWrittenMessage: true}, handler)
// Run Test
suite.csms.Start(8887, "somePath")
err := suite.chargingStation.Start(wsUrl)
assert.Nil(t, err)
resultChannel := make(chan bool, 1)
err = suite.csms.PublishFirmware(wsId, func(resp *firmware.PublishFirmwareResponse, err error) {
assert.Nil(t, err)
require.NotNil(t, resp)
assert.Equal(t, publishFirmwareResponse.Status, resp.Status)
require.NotNil(t, resp.StatusInfo)
assert.Equal(t, publishFirmwareResponse.StatusInfo.ReasonCode, resp.StatusInfo.ReasonCode)
assert.Equal(t, publishFirmwareResponse.StatusInfo.AdditionalInfo, resp.StatusInfo.AdditionalInfo)
resultChannel <- true
}, location, checksum, requestID, func(request *firmware.PublishFirmwareRequest) {
request.Retries = retries
request.RetryInterval = retryInterval
})
require.Nil(t, err)
if err == nil {
result := <-resultChannel
assert.True(t, result)
}
}
func (suite *OcppV2TestSuite) TestPublishFirmwareInvalidEndpoint() {
messageId := defaultMessageId
location := "http://someUrl"
retries := newInt(5)
checksum := "deadc0d3"
requestID := 42
retryInterval := newInt(300)
request := firmware.NewPublishFirmwareRequest(location, checksum, requestID)
request.Retries = retries
request.RetryInterval = retryInterval
requestJson := fmt.Sprintf(`[2,"%v","%v",{"location":"%v","retries":%v,"checksum":"%v","requestId":%v,"retryInterval":%v}]`,
messageId, firmware.PublishFirmwareFeatureName, location, *retries, checksum, requestID, *retryInterval)
testUnsupportedRequestFromChargingStation(suite, request, requestJson, messageId)
}