Skip to content

Commit 88c8fa7

Browse files
committed
address comments
1 parent 29082d4 commit 88c8fa7

File tree

2 files changed

+42
-5
lines changed

2 files changed

+42
-5
lines changed

cns/restserver/api.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1317,6 +1317,7 @@ func (service *HTTPRestService) nmAgentNCListHandler(w http.ResponseWriter, r *h
13171317
if ncVersionerr != nil {
13181318
returnCode = types.NmAgentNCVersionListError
13191319
returnMessage = "[Azure-CNS] " + ncVersionerr.Error()
1320+
break
13201321
}
13211322

13221323
for _, container := range ncVersionList.Containers {

cns/restserver/api_test.go

Lines changed: 41 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1304,11 +1304,47 @@ func TestNmAgentSupportedApisHandler(t *testing.T) {
13041304

13051305
func TestNMAgentNCListHandler(t *testing.T) {
13061306
fmt.Println("Test: nmAgentNCListHandler")
1307-
var (
1308-
err error
1309-
req *http.Request
1310-
)
13111307

1308+
setEnv(t)
1309+
setOrchestratorType(t, cns.Kubernetes)
1310+
1311+
mnma := &fakes.NMAgentClientFake{}
1312+
cleanupNMA := setMockNMAgent(svc, mnma)
1313+
defer cleanupNMA()
1314+
1315+
wsproxy := fakes.WireserverProxyFake{}
1316+
cleanupWSP := setWireserverProxy(svc, &wsproxy)
1317+
defer cleanupWSP()
1318+
1319+
params := createOrUpdateNetworkContainerParams{
1320+
ncID: "f47ac10b-58cc-0372-8567-0e02b2c3d475", // random guid
1321+
ncIP: "11.0.0.5",
1322+
ncType: cns.AzureContainerInstance,
1323+
ncVersion: "0",
1324+
vnetID: "vnet1",
1325+
podName: "testpod",
1326+
podNamespace: "testpodnamespace",
1327+
}
1328+
1329+
err := createNC(params)
1330+
if err != nil {
1331+
t.Fatal("error creating NC: err:", err)
1332+
}
1333+
1334+
mnma.GetNCVersionListF = func(_ context.Context) (nmagent.NCVersionList, error) {
1335+
return nmagent.NCVersionList{
1336+
Containers: []nmagent.NCVersion{
1337+
{
1338+
// Must set it as params.ncID without cns.SwiftPrefix to mock real nmagent nc format.
1339+
NetworkContainerID: params.ncID,
1340+
Version: params.ncVersion,
1341+
},
1342+
},
1343+
}, nil
1344+
}
1345+
1346+
// test CNS' new GET /ncList API
1347+
var req *http.Request
13121348
req, err = http.NewRequestWithContext(context.TODO(), http.MethodGet, cns.NMAgentGetNCListAPIPath, http.NoBody)
13131349
if err != nil {
13141350
t.Fatal(err)
@@ -1324,7 +1360,7 @@ func TestNMAgentNCListHandler(t *testing.T) {
13241360
}
13251361

13261362
fmt.Printf("nmAgentNCListHandler responded with %+v\n", nmAgentNCListResponse)
1327-
require.Empty(t, nmAgentNCListResponse.NCList)
1363+
require.Equal(t, params.ncID, nmAgentNCListResponse.NCList[0])
13281364
}
13291365

13301366
// Testing GetHomeAz API handler, return UnsupportedVerb if http method is not supported

0 commit comments

Comments
 (0)