WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
+
+
+ This source code is part of the near-RT RIC (RAN Intelligent Controller)
+ platform project (RICP).
+
==================================================================================
*/
/*
"net"
"net/http"
"net/http/httptest"
- "routing-manager/pkg/rtmgr"
"testing"
+ "routing-manager/pkg/sbi"
+ "routing-manager/pkg/sdl"
+ "routing-manager/pkg/rpe"
+ "fmt"
+ "sync"
)
var (
- XMURL string = "http://127.0.0.1:3000/ric/v1/xapps"
+ XMURL = "http://127.0.0.1:3000/ric/v1/xapps"
+ E2MURL = "http://127.0.0.1:8085/ric/v1/e2t/list"
)
-
func TestFetchXappListInvalidData(t *testing.T) {
var httpGetter = NewHttpGetter()
- _, err := httpGetter.FetchAllXapps(XMURL)
+ _, err := httpGetter.FetchAllXApps(XMURL)
if err == nil {
- t.Error("No XApp data received: "+err.Error())
+ t.Error("No XApp data received: " + err.Error())
}
}
-
func TestFetchXappListWithInvalidData(t *testing.T) {
- var expected int = 0
- rtmgr.SetLogLevel("debug")
+ var expected = 0
b := []byte(`{"ID":"deadbeef1234567890", "Version":0, "EventType":"all"}`)
l, err := net.Listen("tcp", "127.0.0.1:3000")
if err != nil {
ts.Start()
defer ts.Close()
var httpGetter = NewHttpGetter()
- xapplist, err := httpGetter.FetchAllXapps(XMURL)
+ xapplist, err := httpGetter.FetchAllXApps(XMURL)
if err == nil {
t.Error("Error occured: " + err.Error())
} else {
}
}
-func TestFetchAllXappsWithValidData(t *testing.T) {
- var expected int = 1
+func TestFetchAllXAppsWithValidData(t *testing.T) {
+ var expected = 1
b := []byte(`[
{
"name":"xapp-01","status":"unknown","version":"1.2.3",
ts.Start()
defer ts.Close()
var httpGetter = NewHttpGetter()
- xapplist, err := httpGetter.FetchAllXapps(XMURL)
+ xapplist, err := httpGetter.FetchAllXApps(XMURL)
if err != nil {
t.Error("Error occured: " + err.Error())
} else {
}
}
+func TestHttpInstance1(t *testing.T) {
+ sdlEngine, _ := sdl.GetSdl("file")
+ rpeEngine, _ := rpe.GetRpe("rmrpush")
+ sbiEngine, _ := sbi.GetSbi("rmrpush")
+ httpinstance := NewHttpGetter()
+ err := httpinstance.Terminate()
+ t.Log(err)
+ fmt.Printf("sbiEngine = %v", sbiEngine)
+
+ createMockPlatformComponents()
+ //ts := createMockAppmgrWithData("127.0.0.1:3000", BasicXAppLists, nil)
+ //ts.Start()
+ //defer ts.Close()
+ var m sync.Mutex
+ err = httpinstance.Initialize(XMURL, "httpgetter", "rt.json", "config.json", E2MURL, sdlEngine, rpeEngine, &m)
+}
+