X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Fsubscription_test.go;h=5772465c217864d2723fc06ec150ea41c3e91e10;hb=3fd54d11c9f548f1ebea30133e5198eb49511e55;hp=28549e73bebd016b3d9606ffa4f68bea1062e735;hpb=5120ec103eead26427b977f4b2456c2ce57b36ac;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/subscription_test.go b/pkg/xapp/subscription_test.go index 28549e7..5772465 100755 --- a/pkg/xapp/subscription_test.go +++ b/pkg/xapp/subscription_test.go @@ -7,88 +7,199 @@ package xapp import ( + "fmt" "testing" "time" - "github.com/stretchr/testify/assert" + + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/clientmodel" "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/models" - apimodel "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/clientmodel" + "github.com/stretchr/testify/assert" ) -var suite *testing.T +var ( + suite *testing.T + + meid = "gnb123456" + xappEventInstanceId = int64(1) + eventInstanceId = int64(1) + funId = int64(1) + actionId = int64(1) + actionType = "report" + subsequestActioType = "continue" + timeToWait = "w10ms" + direction = int64(0) + procedureCode = int64(27) + typeOfMessage = int64(1) + subscriptionId = "" + hPort = int64(8080) + rPort = int64(4560) + clientEndpoint = clientmodel.SubscriptionParamsClientEndpoint{Host: "localhost", HTTPPort: &hPort, RMRPort: &rPort} +) -var requestorId = int64(0x4EEC) -var direction = int64(0) -var procedureCode = int64(27) -var typeOfMessage = int64(1) +// Test cases +func TestSetup(t *testing.T) { + suite = t -var reportParams = apimodel.ReportParams{ - RequestorID: &requestorId, - EventTriggers: apimodel.EventTriggerList{ - &apimodel.EventTrigger{ - InterfaceDirection: &direction, - ProcedureCode: &procedureCode, - TypeOfMessage: &typeOfMessage, - }, - }, + // Start the server to simulate SubManager + go Subscription.Listen(subscriptionHandler, queryHandler, deleteHandler) + time.Sleep(time.Duration(2) * time.Second) } -var controlParams = apimodel.ControlParams{ - RequestorID: requestorId, -} +func TestSubscriptionQueryHandling(t *testing.T) { + resp, err := Subscription.QuerySubscriptions() -var policyParams = apimodel.PolicyParams{ - RequestorID: requestorId, + assert.Equal(t, err, nil) + assert.Equal(t, resp[0].SubscriptionID, int64(11)) + assert.Equal(t, resp[0].Meid, "Test-Gnb") + assert.Equal(t, resp[0].ClientEndpoint, []string{"127.0.0.1:4056"}) } -func subscriptionHandler(stype models.SubscriptionType, params interface{}) (models.SubscriptionResult, error) { - switch stype { - case models.SubscriptionTypeReport: - p := params.(*models.ReportParams) - assert.Equal(suite, requestorId, *p.RequestorID) - assert.Equal(suite, direction, *p.EventTriggers[0].InterfaceDirection) - assert.Equal(suite, procedureCode, *p.EventTriggers[0].ProcedureCode) - assert.Equal(suite, typeOfMessage, *p.EventTriggers[0].TypeOfMessage) - case models.SubscriptionTypeControl: - p := params.(*models.ControlParams) - assert.Equal(suite, requestorId, p.RequestorID) - case models.SubscriptionTypePolicy: - p := params.(*models.PolicyParams) - assert.Equal(suite, requestorId, p.RequestorID) +func TestSubscriptionHandling(t *testing.T) { + subscriptionParams := clientmodel.SubscriptionParams{ + SubscriptionID: "", + Meid: &meid, + RANFunctionID: &funId, + ClientEndpoint: &clientEndpoint, + SubscriptionDetails: clientmodel.SubscriptionDetailsList{ + &clientmodel.SubscriptionDetail{ + XappEventInstanceID: &eventInstanceId, + EventTriggers: &clientmodel.EventTriggerDefinition{ + OctetString: "1234", + }, + ActionToBeSetupList: clientmodel.ActionsToBeSetup{ + &clientmodel.ActionToBeSetup{ + ActionID: &actionId, + ActionType: &actionType, + ActionDefinition: &clientmodel.ActionDefinition{ + OctetString: "5678", + }, + SubsequentAction: &clientmodel.SubsequentAction{ + SubsequentActionType: &subsequestActioType, + TimeToWait: &timeToWait, + }, + }, + }, + }, + }, } - return models.SubscriptionResult{11, 22, 33}, nil + Subscription.SetResponseCB(func(resp *clientmodel.SubscriptionResponse) { + assert.Equal(t, len(resp.SubscriptionInstances), 1) + assert.Equal(t, *resp.SubscriptionInstances[0].XappEventInstanceID, int64(11)) + assert.Equal(t, *resp.SubscriptionInstances[0].E2EventInstanceID, int64(22)) + }) + + _, err := Subscription.Subscribe(&subscriptionParams) + assert.Equal(t, err, nil) } -func TestSetup(t *testing.T) { - suite = t +func TestSubscriptionWithClientProvidedIdHandling(t *testing.T) { + subscriptionParams := clientmodel.SubscriptionParams{ + SubscriptionID: "myxapp", + Meid: &meid, + RANFunctionID: &funId, + ClientEndpoint: &clientEndpoint, + SubscriptionDetails: clientmodel.SubscriptionDetailsList{ + &clientmodel.SubscriptionDetail{ + XappEventInstanceID: &eventInstanceId, + EventTriggers: &clientmodel.EventTriggerDefinition{ + OctetString: "1234", + }, + ActionToBeSetupList: clientmodel.ActionsToBeSetup{ + &clientmodel.ActionToBeSetup{ + ActionID: &actionId, + ActionType: &actionType, + ActionDefinition: &clientmodel.ActionDefinition{ + OctetString: "5678", + }, + SubsequentAction: &clientmodel.SubsequentAction{ + SubsequentActionType: &subsequestActioType, + TimeToWait: &timeToWait, + }, + }, + }, + }, + }, + } - // Start the server to simulate SubManager - go Subscription.Listen(subscriptionHandler) - time.Sleep(time.Duration(2) * time.Second) -} + Subscription.SetResponseCB(func(resp *clientmodel.SubscriptionResponse) { + assert.Equal(t, len(resp.SubscriptionInstances), 1) + assert.Equal(t, *resp.SubscriptionInstances[0].XappEventInstanceID, int64(11)) + assert.Equal(t, *resp.SubscriptionInstances[0].E2EventInstanceID, int64(22)) + }) -func TestSubscriptionReportHandling(t *testing.T) { - result, err := Subscription.SubscribeReport(&reportParams) + _, err := Subscription.Subscribe(&subscriptionParams) + assert.Equal(t, err, nil) +} +func TestSubscriptionDeleteHandling(t *testing.T) { + err := Subscription.Unsubscribe(subscriptionId) + fmt.Println(err) assert.Equal(t, err, nil) - assert.Equal(t, len(result), 3) - assert.Equal(t, result[0], int64(11)) - assert.Equal(t, result[1], int64(22)) - assert.Equal(t, result[2], int64(33)) } -func TestSubscriptionControltHandling(t *testing.T) { - result, err := Subscription.SubscribeControl(&controlParams) +// Helper functions +func processSubscriptions(subscriptionId string) { + // Generate requestorId, instanceId + xappInstanceId := int64(11) + e2InstanceId := int64(22) + + resp := &models.SubscriptionResponse{ + SubscriptionID: &subscriptionId, + SubscriptionInstances: []*models.SubscriptionInstance{ + { + XappEventInstanceID: &xappInstanceId, + E2EventInstanceID: &e2InstanceId, + }, + }, + } - assert.Equal(t, err, nil) - assert.Equal(t, len(result), 3) - assert.Equal(t, result[0], int64(11)) + // Notify the client: don't worry about errors ... Notify() will handle retries, etc. + Subscription.Notify(resp, models.SubscriptionParamsClientEndpoint{Host: "localhost", HTTPPort: &hPort, RMRPort: &rPort}) } -func TestSubscriptionPolicytHandling(t *testing.T) { - result, err := Subscription.SubscribePolicy(&policyParams) +func subscriptionHandler(params interface{}) (*models.SubscriptionResponse, error) { + p := params.(*models.SubscriptionParams) - assert.Equal(t, err, nil) - assert.Equal(t, len(result), 3) - assert.Equal(t, result[0], int64(11)) -} \ No newline at end of file + assert.Equal(suite, meid, *p.Meid) + assert.Equal(suite, funId, *p.RANFunctionID) + assert.Equal(suite, clientEndpoint.Host, p.ClientEndpoint.Host) + assert.Equal(suite, clientEndpoint.HTTPPort, p.ClientEndpoint.HTTPPort) + assert.Equal(suite, clientEndpoint.RMRPort, p.ClientEndpoint.RMRPort) + + assert.Equal(suite, xappEventInstanceId, *p.SubscriptionDetails[0].XappEventInstanceID) + assert.Equal(suite, "1234", p.SubscriptionDetails[0].EventTriggers.OctetString) + assert.Equal(suite, actionId, *p.SubscriptionDetails[0].ActionToBeSetupList[0].ActionID) + assert.Equal(suite, actionType, *p.SubscriptionDetails[0].ActionToBeSetupList[0].ActionType) + + assert.Equal(suite, subsequestActioType, *p.SubscriptionDetails[0].ActionToBeSetupList[0].SubsequentAction.SubsequentActionType) + assert.Equal(suite, timeToWait, *p.SubscriptionDetails[0].ActionToBeSetupList[0].SubsequentAction.TimeToWait) + assert.Equal(suite, "5678", p.SubscriptionDetails[0].ActionToBeSetupList[0].ActionDefinition.OctetString) + + // Generate a unique subscriptionId + subscriptionId = fmt.Sprintf("%s-%s", meid, clientEndpoint.Host) + + // Process subscriptions on the background + go processSubscriptions(subscriptionId) + + // and send response immediately + return &models.SubscriptionResponse{ + SubscriptionID: &subscriptionId, + }, nil +} + +func queryHandler() (models.SubscriptionList, error) { + resp := models.SubscriptionList{ + &models.SubscriptionData{ + SubscriptionID: 11, + Meid: "Test-Gnb", + ClientEndpoint: []string{"127.0.0.1:4056"}, + }, + } + return resp, nil +} + +func deleteHandler(ep string) error { + assert.Equal(suite, subscriptionId, ep) + return nil +}