Skip to content

Commit

Permalink
add O-RAN v3.0 API compliance tests
Browse files Browse the repository at this point in the history 
Signed-off-by: Jack Ding <[email protected]>
  • Loading branch information
@jzding
jzding committed Sep 9, 2024
1 parent 1a7aa4c commit 3aaee24
Showing 1 changed file with 146 additions and 59 deletions.
205 changes: 146 additions & 59 deletions v2/server_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -52,22 +52,28 @@ var (
port = 8990
apHost = "localhost"
apPath = "/api/ocloudNotifications/v2/"
resource = "/test/test"
resourceNoneSubscribed = "/test/nonesubscribed"
resource = "/cluster/node/mynode.example.com/example-status"
resourceNoneSubscribed = "/cluster/node/mynode.example.com/nonesubscribed"
storePath = "."
ObjSub pubsub.PubSub
ObjPub pubsub.PubSub
dummySource = "dummySource"
dummyType = "dummyType"
)

func onReceiveOverrideFn(_ cloudevents.Event, d *channel.DataChan) error {
func onReceiveOverrideFn(e cloudevents.Event, d *channel.DataChan) error {
if e.Source() != resource {
return fmt.Errorf("could not find any events for requested resource type %s", e.Source())
}

data := &event.Data{
Version: event.APISchemaVersion,
Values: []event.DataValue{},
}
ce := cloudevents.NewEvent(cloudevents.VersionV1)
ce.SetTime(types.Timestamp{Time: time.Now().UTC()}.Time)
ce.SetType("dummyType")
ce.SetSource("dummySource")
ce.SetType(dummyType)
ce.SetSource(dummySource)
ce.SetSpecVersion(cloudevents.VersionV1)
ce.SetID(uuid.New().String())
ce.SetData("", *data) //nolint:errcheck
Expand Down Expand Up @@ -97,9 +103,9 @@ func TestMain(m *testing.M) {
cneEvent.SetTime(types.Timestamp{Time: time.Now().UTC()}.Time)
cneEvent.SetDataContentType(event.ApplicationJSON)
data := event.Data{
Version: "event",
Version: "v1.0",
Values: []event.DataValue{{
Resource: "test",
Resource: resource,
DataType: event.NOTIFICATION,
ValueType: event.ENUMERATION,
Value: ptp.ACQUIRING_SYNC,
Expand Down Expand Up @@ -167,6 +173,55 @@ func TestServer_Health(t *testing.T) {
assert.Equal(t, http.StatusOK, resp.StatusCode)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.1 Create a subscription resource 5.3.1.5 (2)
func TestServer_CreateSubscription_BadReq(t *testing.T) {
/// create new subscription without message body
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel()
req, err := http.NewRequestWithContext(ctx, "POST", fmt.Sprintf("http://localhost:%d%s%s", port, apPath, "subscriptions"), bytes.NewBuffer(nil))
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
bodyString := string(bodyBytes)
log.Print(bodyString)
assert.Equal(t, http.StatusBadRequest, resp.StatusCode)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.1 Create a subscription resource 5.3.1.5 (3)
func TestServer_CreateSubscription_Resource_Not_Avail(t *testing.T) {
// create subscription
sub := api.NewPubSub(
&types.URI{URL: url.URL{Scheme: "http", Host: fmt.Sprintf("localhost:%d", port), Path: fmt.Sprintf("%s%s", apPath, "dummy")}},
"resourceNotExist", "2.0")
data, err := json.Marshal(&sub)
assert.Nil(t, err)
assert.NotNil(t, data)
/// create new subscription
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel()
req, err := http.NewRequestWithContext(ctx, "POST", fmt.Sprintf("http://localhost:%d%s%s", port, apPath, "subscriptions"), bytes.NewBuffer(data))
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
bodyString := string(bodyBytes)
log.Print(bodyString)
assert.Equal(t, http.StatusNotFound, resp.StatusCode)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.1 Create a subscription resource 5.3.1.5 (1)
func TestServer_CreateSubscription(t *testing.T) {
// create subscription
sub := api.NewPubSub(
Expand Down Expand Up @@ -200,6 +255,8 @@ func TestServer_CreateSubscription(t *testing.T) {
log.Infof("Subscription:\n%s", ObjSub.String())
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.1 Create a subscription resource 5.3.1.5 (4)
func TestServer_CreateSubscriptionConflict(t *testing.T) {
// create subscription
sub := api.NewPubSub(
Expand All @@ -225,13 +282,39 @@ func TestServer_CreateSubscriptionConflict(t *testing.T) {
assert.Equal(t, http.StatusConflict, resp.StatusCode)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.2 Get a list of subscription resources
func TestServer_ListSubscriptions(t *testing.T) {
// Get All Subscriptions
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel()
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s", port, apPath, "subscriptions"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close() // Close body only if response non-nil
bodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
assert.Equal(t, http.StatusOK, resp.StatusCode)
var subList []pubsub.PubSub
log.Printf("TestServer_ListSubscriptions :%s\n", string(bodyBytes))
err = json.Unmarshal(bodyBytes, &subList)
assert.Nil(t, err)
assert.Greater(t, len(subList), 0)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.3 Get Detail of individual subscription resource 5.3.3.5 (1)
func TestServer_GetSubscription(t *testing.T) {
// Get Just Created Subscription
req, err := http.NewRequest("GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, "subscriptions", ObjSub.ID), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
assert.Equal(t, http.StatusOK, resp.StatusCode)
defer resp.Body.Close()
bodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
Expand All @@ -244,6 +327,19 @@ func TestServer_GetSubscription(t *testing.T) {
assert.Equal(t, rSub.ID, ObjSub.ID)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.3 Get Detail of individual subscription resource 5.3.3.5 (2)
func TestServer_GetSubscription_Not_Avail(t *testing.T) {
// Get Just Created Subscription
req, err := http.NewRequest("GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, "subscriptions", "InvalidId"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
assert.Equal(t, http.StatusNotFound, resp.StatusCode)
}

func TestServer_CreatePublisher(t *testing.T) {
pub := pubsub.PubSub{
ID: "",
Expand Down Expand Up @@ -275,42 +371,64 @@ func TestServer_CreatePublisher(t *testing.T) {
log.Infof("publisher \n%s", ObjPub.String())
}

func TestServer_GetPublisher(t *testing.T) {
// Get Just created Publisher
req, err := http.NewRequest("GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, "publishers", ObjPub.ID), nil)
// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.6 Event pull status notification 5.3.6.5 (1)
func TestServer_GetCurrentState_withSubscription(t *testing.T) {
ctx := context.Background()
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, ObjSub.Resource, "CurrentState"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
pubBodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
var rPub pubsub.PubSub
log.Printf("the data %s", string(pubBodyBytes))
err = json.Unmarshal(pubBodyBytes, &rPub)
assert.Equal(t, resp.StatusCode, http.StatusOK)
s, err2 := io.ReadAll(resp.Body)
assert.Nil(t, err2)
log.Infof("tedt %s ", string(s))
var e cloudevents.Event
err = json.Unmarshal(s, &e)
assert.Nil(t, err)
assert.Equal(t, ObjPub.ID, rPub.ID)
assert.Equal(t, dummySource, e.Context.GetSource())
assert.Equal(t, dummyType, e.Context.GetType())
assert.Equal(t, http.StatusOK, resp.StatusCode)
}

func TestServer_ListSubscriptions(t *testing.T) {
// Get All Subscriptions
// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.6 Event pull status notification 5.3.6.5 (2)
func TestServer_GetCurrentState_withoutSubscription(t *testing.T) {
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel()
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s", port, apPath, "subscriptions"), nil)

// try getting event
time.Sleep(2 * time.Second)
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, resourceNoneSubscribed, "CurrentState"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close() // Close body only if response non-nil
bodyBytes, err := io.ReadAll(resp.Body)
defer resp.Body.Close()
s, err2 := io.ReadAll(resp.Body)
assert.Nil(t, err2)
log.Infof("tedt %s ", string(s))
assert.Equal(t, http.StatusNotFound, resp.StatusCode)
}

func TestServer_GetPublisher(t *testing.T) {
// Get Just created Publisher
req, err := http.NewRequest("GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, "publishers", ObjPub.ID), nil)
assert.Nil(t, err)
var subList []pubsub.PubSub
log.Printf("TestServer_ListSubscriptions :%s\n", string(bodyBytes))
err = json.Unmarshal(bodyBytes, &subList)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
assert.Greater(t, len(subList), 0)
defer resp.Body.Close()
pubBodyBytes, err := io.ReadAll(resp.Body)
assert.Nil(t, err)
var rPub pubsub.PubSub
log.Printf("the data %s", string(pubBodyBytes))
err = json.Unmarshal(pubBodyBytes, &rPub)
assert.Equal(t, resp.StatusCode, http.StatusOK)
assert.Nil(t, err)
assert.Equal(t, ObjPub.ID, rPub.ID)
}

func TestServer_ListPublishers(t *testing.T) {
Expand All @@ -333,39 +451,6 @@ func TestServer_ListPublishers(t *testing.T) {
assert.Greater(t, len(pubList), 0)
}

func TestServer_GetCurrentState_withSubscription(t *testing.T) {
ctx := context.Background()
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, ObjSub.Resource, "CurrentState"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
s, err2 := io.ReadAll(resp.Body)
assert.Nil(t, err2)
log.Infof("tedt %s ", string(s))
assert.Equal(t, http.StatusOK, resp.StatusCode)
}

func TestServer_GetCurrentState_withoutSubscription(t *testing.T) {
ctx := context.Background()
ctx, cancel := context.WithCancel(ctx)
defer cancel()

// try getting event
time.Sleep(2 * time.Second)
req, err := http.NewRequestWithContext(ctx, "GET", fmt.Sprintf("http://localhost:%d%s%s/%s", port, apPath, resourceNoneSubscribed, "CurrentState"), nil)
assert.Nil(t, err)
req.Header.Set("Content-Type", "application/json")
resp, err := server.HTTPClient.Do(req)
assert.Nil(t, err)
defer resp.Body.Close()
s, err2 := io.ReadAll(resp.Body)
assert.Nil(t, err2)
log.Infof("tedt %s ", string(s))
assert.Equal(t, http.StatusNotFound, resp.StatusCode)
}

func TestServer_TestPingStatusStatusCode(t *testing.T) {
req, err := http.NewRequest("PUT", fmt.Sprintf("http://localhost:%d%s%s%s", port, apPath, "subscriptions/status/", ObjSub.ID), nil)
assert.Nil(t, err)
Expand All @@ -376,6 +461,8 @@ func TestServer_TestPingStatusStatusCode(t *testing.T) {
assert.Equal(t, http.StatusBadRequest, resp.StatusCode)
}

// O-RAN.WG6.O-CLOUD-CONF-Test-R003-v02.00
// TC5.3.4 Delete individual subscription resources
func TestServer_DeleteSubscription(t *testing.T) {
clientIDs := server.GetSubscriberAPI().GetClientIDByResource(ObjSub.Resource)
ctx := context.Background()
Expand Down

0 comments on commit 3aaee24

Please sign in to comment.