onem2m-mgr_test.go

/*
 * Copyright (c) 2025  The AdvantEDGE Authors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on ance "AS IS" BASIS,
 * 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.
 */

package sssmgr

import (
	"fmt"
	"reflect"
	"testing"

	log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger"
)

const tmName = "meep-iot"
const tmNamespace = "sandboxtest"

func TestNewSssMgr(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Invalid Connector
	fmt.Println("Invalid SSS Asset Manager")
	tm, err := NewSssMgr("", tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err == nil || tm != nil {
		t.Fatalf("Service name not set")
	}
	tm, err = NewSssMgr(tmName, tmNamespace, "", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err == nil || tm != nil {
		t.Fatalf("Binding protocol not set")
	}
	tm, err = NewSssMgr(tmName, tmNamespace, "MQTT", "", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err == nil || tm != nil {
		t.Fatalf("Host not set")
	}
	tm, err = NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "", "laboai-acme-ic-cse", nil, nil, nil)
	if err == nil || tm != nil {
		t.Fatalf("Host id not set")
	}
	tm, err = NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "", nil, nil, nil)
	if err == nil || tm != nil {
		t.Fatalf("CSE name not set")
	}

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err = NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}
	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil

	fmt.Println("Create valid SSS Asset Manager")
	tm, err = NewSssMgr(tmName, tmNamespace, "REST_HTTP", "172.29.10.56", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestPopulateDevicesPerIotPlatformsHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "", 0, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	err = tm.populateDevicesPerIotPlatforms()
	if err != nil {
		t.Fatalf(err.Error())
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestSensorDiscoveryInfoAllHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "", 0, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	sensors, err := tm.SensorDiscoveryInfoAll()
	if err != nil {
		t.Fatalf(err.Error())
	}
	fmt.Println("len=", len(sensors))
	fmt.Println("sensors", sensors)

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestGetSensorHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	sensors, err := tm.SensorDiscoveryInfoAll()
	if err != nil {
		t.Fatalf(err.Error())
	}

	for _, v := range sensors {
		fmt.Println("v", v)
		fmt.Println("TypeOf(v)", reflect.TypeOf(v))

		sensor, err := tm.GetSensor(v.SensorIdentifier)
		if !validate_sensor_discovery_info(v, sensor) {
			t.Fatalf(err.Error())
		}
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAEHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var sensor = SensorDiscoveryInfo{
		SensorIdentifier: "12345",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	new_sensor, err := tm.OneM2M_create(sensor, "")
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor, new_sensor) {
		t.Fatalf("Failed to validate AE content")
	}

	_ = tm.OneM2M_Delete(new_sensor)

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAE_CNTHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var sensor_ae = SensorDiscoveryInfo{
		SensorIdentifier: "CMyAE",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	new_sensor_ae, err := tm.OneM2M_create(sensor_ae, "")
	if err != nil {
		t.Fatalf("Failed to create new AE sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor_ae, new_sensor_ae) {
		t.Fatalf("Failed to validate AE content")
	}

	var sensor_cnt = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNT",
		SensorType:       "CNT",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	// sensor_cnt.SensorCharacteristicList = make([]SensorCharacteristic, 1)
	// sensor_cnt.SensorCharacteristicList[0] = SensorCharacteristic{CharacteristicName: "con", CharacteristicValue: "OFF"}
	sensorPath := new_sensor_ae.SensorIdentifier
	new_sensor_cnt, err := tm.OneM2M_create(sensor_cnt, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new CNT sensor")
	}

	// Verify content
	if !validate_sensor_cnt(sensor_cnt, new_sensor_cnt) {
		t.Fatalf("Failed to validate AE content")
	}

	err = tm.OneM2M_Delete(new_sensor_cnt)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_ae)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAE_CNT_CNIHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var sensor_ae = SensorDiscoveryInfo{
		SensorIdentifier: "CMyAE",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	new_sensor_ae, err := tm.OneM2M_create(sensor_ae, "")
	if err != nil {
		t.Fatalf("Failed to create new AE sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor_ae, new_sensor_ae) {
		t.Fatalf("Failed to validate AE content")
	}

	var sensor_cnt = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNT",
		SensorType:       "CNT",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensorPath := new_sensor_ae.SensorIdentifier
	new_sensor_cnt, err := tm.OneM2M_create(sensor_cnt, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new CNT sensor")
	}

	// Verify content
	if !validate_sensor_cnt(sensor_cnt, new_sensor_cnt) {
		t.Fatalf("Failed to validate CNT content")
	}

	var sensor_cin = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNI",
		SensorType:       "CIN",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor_cin.SensorCharacteristicList = make([]SensorCharacteristic, 1)
	sensor_cin.SensorCharacteristicList[0] = SensorCharacteristic{CharacteristicName: "con", CharacteristicValue: "OFF"}
	sensorPath = new_sensor_cnt.SensorIdentifier
	new_sensor_cin, err := tm.OneM2M_create(sensor_cin, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Verify content
	if !validate_sensor_cin(sensor_cin, new_sensor_cin) {
		t.Fatalf("Failed to validate CIN content")
	}

	err = tm.OneM2M_Delete(new_sensor_cin)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_cnt)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_ae)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_deleteHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var new_sensor = SensorDiscoveryInfo{
		SensorIdentifier: "12345",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor, err := oneM2M_create(tm, new_sensor, "")
	if err != nil {
		t.Fatalf("Failed to create new sensor: " + err.Error())
	}

	err = tm.OneM2M_Delete(sensor)
	if err != nil {
		t.Fatalf("Failed to create new sensor: " + err.Error())
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_getHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	sensors, received_sensors, err := oneM2M_createAE_CNT_CIN(tm)
	if err != nil {
		t.Fatalf("Failed to create sensors")
	}

	// Verify content
	if len(sensors) != 3 || len(received_sensors) != 3 {
		t.Fatalf("Failed to create sensors")
	}

	// Get one sensor
	sensorResp, err := tm.OneM2M_get(received_sensors["CNT"].SensorIdentifier, received_sensors["CNT"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	// Verify content
	if !validate_sensor_cnt(received_sensors["CNT"], sensorResp) {
		t.Fatalf("Failed to validate CNT content")
	}

	sensorResp, err = tm.OneM2M_get(received_sensors["CIN"].SensorIdentifier, received_sensors["CIN"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	// Verify content
	if !validate_sensor_cin(received_sensors["CIN"], sensorResp) {
		t.Fatalf("Failed to validate CIN content")
	}

	_ = tm.OneM2M_Delete(received_sensors["CIN"])
	_ = tm.OneM2M_Delete(received_sensors["CNT"])
	_ = tm.OneM2M_Delete(received_sensors["AE"])

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_discoveryHttp(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "REST_HTTP", "lab-oai.etsi.org", 31110, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	_, received_sensors, err := oneM2M_createAE_CNT_CIN(tm)
	if err != nil {
		t.Fatalf("Failed to create sensors")
	}

	// Verify content
	if len(received_sensors) != 3 {
		t.Fatalf("Failed to create sensors")
	}

	// Discover CNTs
	sensorList, err := tm.OneM2M_discovery(received_sensors["CNT"].SensorType, received_sensors["CNT"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	if len(sensorList) != 1 {
		t.Fatalf("Wrong discover result")
	}
	// Verify content
	if !validate_sensor_cnt(received_sensors["CNT"], sensorList[0]) {
		t.Fatalf("Failed to validate CNT content")
	}

	// Discover AEs
	sensorList, err = tm.OneM2M_discovery(received_sensors["AE"].SensorType, received_sensors["AE"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover AE sensor")
	}
	if len(sensorList) != 1 {
		t.Fatalf("Wrong discover result")
	}
	// Verify content
	if !validate_sensor_ae(received_sensors["AE"], sensorList[0]) {
		t.Fatalf("Failed to validate AE content")
	}

	_ = tm.OneM2M_Delete(received_sensors["CIN"])
	_ = tm.OneM2M_Delete(received_sensors["CNT"])
	_ = tm.OneM2M_Delete(received_sensors["AE"])

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestPopulateDevicesPerIotPlatformsMqtt(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())
	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}
	err = tm.populateDevicesPerIotPlatforms()
	if err != nil {
		t.Fatalf(err.Error())
	}
	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestSensorDiscoveryInfoAllMqtt(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	err = tm.populateDevicesPerIotPlatforms()
	if err != nil {
		t.Fatalf(err.Error())
	}

	sensors, err := tm.SensorDiscoveryInfoAll()
	if err != nil {
		t.Fatalf(err.Error())
	}
	fmt.Println("sensors: ", sensors)

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
}

func TestGetSensorMqtt(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	sensors, err := tm.SensorDiscoveryInfoAll()
	if err != nil {
		t.Fatalf(err.Error())
	}

	for _, v := range sensors {
		fmt.Println("v", v)
		fmt.Println("TypeOf(v)", reflect.TypeOf(v))

		sensor, err := tm.GetSensor(v.SensorIdentifier)
		if !validate_sensor_discovery_info(v, sensor) {
			t.Fatalf(err.Error())
		}
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAEMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var new_sensor = SensorDiscoveryInfo{
		SensorIdentifier: "12345",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor, err := tm.OneM2M_create(new_sensor, "")
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor, new_sensor) {
		t.Fatalf("Failed to validate AE content")
	}

	_ = tm.OneM2M_Delete(sensor)

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAE_CNTMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var sensor_ae = SensorDiscoveryInfo{
		SensorIdentifier: "CMyAE",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	new_sensor_ae, err := tm.OneM2M_create(sensor_ae, "")
	if err != nil {
		t.Fatalf("Failed to create new AE sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor_ae, new_sensor_ae) {
		t.Fatalf("Failed to validate AE content")
	}

	var sensor_cnt = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNT",
		SensorType:       "CNT",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	// sensor_cnt.SensorCharacteristicList = make([]SensorCharacteristic, 1)
	// sensor_cnt.SensorCharacteristicList[0] = SensorCharacteristic{CharacteristicName: "con", CharacteristicValue: "OFF"}
	sensorPath := new_sensor_ae.SensorIdentifier
	new_sensor_cnt, err := tm.OneM2M_create(sensor_cnt, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Verify content
	if !validate_sensor_cnt(sensor_cnt, new_sensor_cnt) {
		t.Fatalf("Failed to validate CNT content")
	}

	err = tm.OneM2M_Delete(new_sensor_cnt)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_ae)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_createAE_CNT_CNIMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var sensor_ae = SensorDiscoveryInfo{
		SensorIdentifier: "CMyAE",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	new_sensor_ae, err := tm.OneM2M_create(sensor_ae, "")
	if err != nil {
		t.Fatalf("Failed to create new AE sensor")
	}

	// Verify content
	if !validate_sensor_ae(sensor_ae, new_sensor_ae) {
		t.Fatalf("Failed to validate AE content")
	}

	var sensor_cnt = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNT",
		SensorType:       "CNT",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensorPath := new_sensor_ae.SensorIdentifier
	new_sensor_cnt, err := tm.OneM2M_create(sensor_cnt, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Verify content
	if !validate_sensor_cnt(sensor_cnt, new_sensor_cnt) {
		t.Fatalf("Failed to validate CNT content")
	}

	var sensor_cin = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNI",
		SensorType:       "CIN",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor_cin.SensorCharacteristicList = make([]SensorCharacteristic, 1)
	sensor_cin.SensorCharacteristicList[0] = SensorCharacteristic{CharacteristicName: "con", CharacteristicValue: "OFF"}
	sensorPath = new_sensor_cnt.SensorIdentifier
	new_sensor_cin, err := tm.OneM2M_create(sensor_cin, sensorPath)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	if new_sensor_cin.SensorType != sensor_cin.SensorType {
		t.Fatalf("received_sensor.SensorType != SensorType")
	}
	if new_sensor_cin.IotPlatformId != sensor_cin.IotPlatformId {
		t.Fatalf("received_sensor.IotPlatformId != IotPlatformId")
	}
	if len(new_sensor_cin.SensorCharacteristicList) == 0 {
		t.Fatalf("received_sensor.SensorCharacteristicList shall not be empty")
	}

	err = tm.OneM2M_Delete(new_sensor_cin)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_cnt)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}
	err = tm.OneM2M_Delete(new_sensor_ae)
	if err != nil {
		t.Fatalf("Failed to create new sensor")
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_deleteMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	var new_sensor = SensorDiscoveryInfo{
		SensorIdentifier: "12345",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor, err := oneM2M_create(tm, new_sensor, "")
	if err != nil {
		t.Fatalf("Failed to create new sensor: " + err.Error())
	}

	err = tm.OneM2M_Delete(sensor)
	if err != nil {
		t.Fatalf("Failed to create new sensor: " + err.Error())
	}

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_getMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	sensors, received_sensors, err := oneM2M_createAE_CNT_CIN(tm)
	if err != nil {
		t.Fatalf("Failed to create sensors")
	}

	// Verify content
	if len(sensors) != 3 || len(received_sensors) != 3 {
		t.Fatalf("Failed to create sensors")
	}

	// Get one sensor
	sensorResp, err := tm.OneM2M_get(received_sensors["CNT"].SensorIdentifier, received_sensors["CNT"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	// Verify content
	if !validate_sensor_cnt(received_sensors["CNT"], sensorResp) {
		t.Fatalf("Failed to validate CNT content")
	}

	sensorResp, err = tm.OneM2M_get(received_sensors["CIN"].SensorIdentifier, received_sensors["CIN"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	// Verify content
	if !validate_sensor_cin(received_sensors["CIN"], sensorResp) {
		t.Fatalf("Failed to validate CIN content")
	}

	_ = tm.OneM2M_Delete(received_sensors["CIN"])
	_ = tm.OneM2M_Delete(received_sensors["CNT"])
	_ = tm.OneM2M_Delete(received_sensors["AE"])

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

func TestOneM2M_discoveryMQTT(t *testing.T) {
	fmt.Println("--- ", t.Name())
	log.MeepTextLogInit(t.Name())

	// Valid Connector
	fmt.Println("Create valid SSS Asset Manager")
	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
	if err != nil || tm == nil {
		t.Fatalf("Failed to create SSS Asset Manager")
	}

	_, received_sensors, err := oneM2M_createAE_CNT_CIN(tm)
	if err != nil {
		t.Fatalf("Failed to create sensors")
	}

	// Verify content
	if len(received_sensors) != 3 {
		t.Fatalf("Failed to create sensors")
	}

	// Discover CNTs
	sensorList, err := tm.OneM2M_discovery(received_sensors["CNT"].SensorType, received_sensors["CNT"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover CNT sensor")
	}
	if len(sensorList) != 1 {
		t.Fatalf("Wrong discover result")
	}
	// Verify content
	if !validate_sensor_cnt(received_sensors["CNT"], sensorList[0]) {
		t.Fatalf("Failed to validate CNT content")
	}

	// Discover AEs
	sensorList, err = tm.OneM2M_discovery(received_sensors["AE"].SensorType, received_sensors["AE"].IotPlatformId)
	if err != nil {
		t.Fatalf("Failed to discover AE sensor")
	}
	if len(sensorList) != 1 {
		t.Fatalf("Wrong discover result")
	}
	// Verify content
	if !validate_sensor_ae(received_sensors["AE"], sensorList[0]) {
		t.Fatalf("Failed to validate AE content")
	}

	_ = tm.OneM2M_Delete(received_sensors["CIN"])
	_ = tm.OneM2M_Delete(received_sensors["CNT"])
	_ = tm.OneM2M_Delete(received_sensors["AE"])

	// Cleanup
	err = tm.DeleteSssMgr()
	if err != nil {
		t.Fatalf("Failed to cleanup SSS Asset Manager")
	}
	tm = nil
}

// func TestVaidateOneM2MNotificationServer(t *testing.T) {
// 	fmt.Println("--- ", t.Name())
// 	log.MeepTextLogInit(t.Name())

// 	// Valid Connector
// 	fmt.Println("Create valid SSS Asset Manager")
// 	tm, err := NewSssMgr(tmName, tmNamespace, "MQTT", "172.29.10.56", 1883, "MQTT", "172.29.10.56", 1883, "7feaadbb0400", "laboai-acme-ic-cse", nil, nil, nil)
// 	if err != nil || tm == nil {
// 		t.Fatalf("Failed to create SSS Asset Manager")
// 	}

// 	tm.init()
// 	fmt.Println("Waiting for 2 minutes to do curl request: curl -v http://mec-platform.etsi.org:33122/sbxykqjr17/mep1/sens/v1 ")

// 	// Cleanup
// 	err = tm.DeleteSssMgr()
// 	if err != nil {
// 		t.Fatalf("Failed to cleanup SSS Asset Manager")
// 	}
// }

func oneM2M_create(tm *SssMgr, sensor SensorDiscoveryInfo, path string) (sensorResp SensorDiscoveryInfo, err error) {
	sensorResp, err = tm.OneM2M_create(sensor, path)
	if err != nil {
		return sensorResp, err
	}

	return sensorResp, nil
}

func oneM2M_createAE_CNT_CIN(tm *SssMgr) (sensors map[string]SensorDiscoveryInfo, received_sensors map[string]SensorDiscoveryInfo, err error) {
	sensors = make(map[string]SensorDiscoveryInfo, 0)
	received_sensors = make(map[string]SensorDiscoveryInfo, 0)

	var sensor_ae = SensorDiscoveryInfo{
		SensorIdentifier: "CMyAE",
		SensorType:       "AE",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensors[sensor_ae.SensorType] = sensor_ae
	new_sensor_ae, err := oneM2M_create(tm, sensor_ae, "")
	if err != nil {
		return nil, nil, err
	}
	received_sensors[new_sensor_ae.SensorType] = new_sensor_ae

	var sensor_cnt = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNT",
		SensorType:       "CNT",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensorPath := new_sensor_ae.SensorIdentifier
	sensors[sensor_cnt.SensorType] = sensor_cnt
	new_sensor_cnt, err := oneM2M_create(tm, sensor_cnt, sensorPath)
	if err != nil {
		return nil, nil, err
	}
	received_sensors[new_sensor_cnt.SensorType] = new_sensor_cnt

	var sensor_cin = SensorDiscoveryInfo{
		SensorIdentifier: "CMyCNI",
		SensorType:       "CIN",
		SensorPosition:   nil,
		IotPlatformId:    "7feaadbb0400",
	}
	sensor_cin.SensorCharacteristicList = make([]SensorCharacteristic, 1)
	sensor_cin.SensorCharacteristicList[0] = SensorCharacteristic{CharacteristicName: "con", CharacteristicValue: "OFF"}
	sensorPath = new_sensor_cnt.SensorIdentifier
	sensors[sensor_cin.SensorType] = sensor_cin
	new_sensor_cin, err := oneM2M_create(tm, sensor_cin, sensorPath)
	if err != nil {
		return nil, nil, err
	}
	received_sensors[new_sensor_cin.SensorType] = new_sensor_cin

	return sensors, received_sensors, nil
}

func validate_sensor_discovery_info(expected_sensor SensorDiscoveryInfo, received_sensor SensorDiscoveryInfo) bool {
	fmt.Println(">>> validate_sensor_discovery_info: expected_sensor: ", expected_sensor)
	fmt.Println(">>> validate_sensor_discovery_info: received_sensor: ", received_sensor)

	if expected_sensor.SensorIdentifier != received_sensor.SensorIdentifier {
		fmt.Println("received_sensor.SensorIdentifier != SensorIdentifier")
		return false