X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=resource%2Fcsdk%2Fstack%2Ftest%2Fstacktests.cpp;h=3e145ad61b54f6d27bceb30160e4b2251f049be7;hb=7f00f942c39b7bc27c7eeecf213a239c3fe4173c;hp=5d893cef224f2567c5fe7ec6296d7bdd3872e421;hpb=55d1fe2483c28e509293b9e4908d2bdfe66fb5bc;p=platform%2Fupstream%2Fiotivity.git diff --git a/resource/csdk/stack/test/stacktests.cpp b/resource/csdk/stack/test/stacktests.cpp index 5d893ce..3e145ad 100644 --- a/resource/csdk/stack/test/stacktests.cpp +++ b/resource/csdk/stack/test/stacktests.cpp @@ -21,10 +21,13 @@ extern "C" { + #include "ocpayload.h" #include "ocstack.h" #include "ocstackinternal.h" #include "logger.h" #include "oic_malloc.h" + #include "oic_string.h" + #include "oic_time.h" } #include "gtest/gtest.h" @@ -32,7 +35,9 @@ extern "C" #include #include #include +#ifdef HAVE_UNISTD_H #include +#endif #include //----------------------------------------------------------------------------- @@ -57,21 +62,70 @@ namespace itst = iotivity::test; //----------------------------------------------------------------------------- static const char TAG[] = "TestHarness"; +char gDeviceUUID[] = "myDeviceUUID"; +char gManufacturerName[] = "myName"; +static OCPrm_t pmSel; +static char pinNumber; +static OCDPDev_t peer; + std::chrono::seconds const SHORT_TEST_TIMEOUT = std::chrono::seconds(5); +std::chrono::seconds const LONG_TEST_TIMEOUT = std::chrono::seconds(300); //----------------------------------------------------------------------------- // Callback functions //----------------------------------------------------------------------------- -extern "C" OCStackApplicationResult asyncDoResourcesCallback(void* ctx, OCDoHandle handle, OCClientResponse * clientResponse) +extern "C" OCStackApplicationResult asyncDoResourcesCallback(void* ctx, + OCDoHandle /*handle*/, OCClientResponse * clientResponse) { - OC_LOG(INFO, TAG, "Entering asyncDoResourcesCallback"); + OIC_LOG(INFO, TAG, "Entering asyncDoResourcesCallback"); EXPECT_EQ(OC_STACK_OK, clientResponse->result); if(ctx == (void*)DEFAULT_CONTEXT_VALUE) { - OC_LOG_V(INFO, TAG, "Callback Context recvd successfully"); + OIC_LOG_V(INFO, TAG, "Callback Context recvd successfully"); } - OC_LOG_V(INFO, TAG, "result = %d", clientResponse->result); + OIC_LOG_V(INFO, TAG, "result = %d", clientResponse->result); + + return OC_STACK_KEEP_TRANSACTION; +} + +static void resultCallback(void *UNUSED1, OCDPDev_t *UNUSED2, OCStackResult UNUSED3) +{ + (void) (UNUSED1); + (void) (UNUSED2); + (void) (UNUSED3); +} + +extern "C" OCStackApplicationResult discoveryCallback(void* ctx, + OCDoHandle /*handle*/, OCClientResponse * clientResponse) +{ + OIC_LOG(INFO, TAG, "Entering asyncDoResourcesCallback"); + + EXPECT_EQ(OC_STACK_OK, clientResponse->result); + + if(ctx == (void*)DEFAULT_CONTEXT_VALUE) + { + OIC_LOG_V(INFO, TAG, "Callback Context recvd successfully"); + } + + OIC_LOG_V(INFO, TAG, "result = %d", clientResponse->result); + + OCDiscoveryPayload *discoveryPayload = ((OCDiscoveryPayload *) clientResponse->payload); + EXPECT_TRUE(discoveryPayload != NULL); + OCResourcePayload *res = discoveryPayload->resources; + int count = 0; + for (OCResourcePayload *res1 = discoveryPayload->resources; res1; res1 = res1->next) + { + count++; + } + EXPECT_EQ(3, count); + EXPECT_EQ("/a/led1", res->uri); + res = res->next; + EXPECT_EQ("/a/led2", res->uri); + res = res->next; + EXPECT_EQ("/a/led3", res->uri); + res = res->next; + EXPECT_TRUE(res == NULL); return OC_STACK_KEEP_TRANSACTION; } @@ -79,10 +133,11 @@ extern "C" OCStackApplicationResult asyncDoResourcesCallback(void* ctx, OCDoHan //----------------------------------------------------------------------------- // Entity handler //----------------------------------------------------------------------------- -OCEntityHandlerResult entityHandler(OCEntityHandlerFlag flag, OCEntityHandlerRequest * entityHandlerRequest, - void* callbackParam) +OCEntityHandlerResult entityHandler(OCEntityHandlerFlag /*flag*/, + OCEntityHandlerRequest * /*entityHandlerRequest*/, + void* /*callbackParam*/) { - OC_LOG(INFO, TAG, "Entering entityHandler"); + OIC_LOG(INFO, TAG, "Entering entityHandler"); return OC_EH_OK; } @@ -92,10 +147,10 @@ OCEntityHandlerResult entityHandler(OCEntityHandlerFlag flag, OCEntityHandlerReq //----------------------------------------------------------------------------- void InitStack(OCMode mode) { - OC_LOG(INFO, TAG, "Entering InitStack"); + OIC_LOG(INFO, TAG, "Entering InitStack"); EXPECT_EQ(OC_STACK_OK, OCInit(NULL, 0, mode)); - OC_LOG(INFO, TAG, "Leaving InitStack"); + OIC_LOG(INFO, TAG, "Leaving InitStack"); } uint8_t InitNumExpectedResources() @@ -121,6 +176,60 @@ uint8_t InitResourceIndex() return 0; #endif } + +class Callback +{ + public: + Callback(OCClientResponseHandler cb) : m_cb(cb), m_called(false) + { + m_cbData.cb = &Callback::handler; + m_cbData.cd = NULL; + m_cbData.context = this; + } + void Wait(long waitTime) + { + uint64_t startTime = OICGetCurrentTime(TIME_IN_MS); + while (!m_called) + { + uint64_t currTime = OICGetCurrentTime(TIME_IN_MS); + long elapsed = (long)((currTime - startTime) / MS_PER_SEC); + if (elapsed > waitTime) + { + m_called = true; + } + OCProcess(); + } + } + operator OCCallbackData *() + { + return &m_cbData; + } + private: + OCCallbackData m_cbData; + OCClientResponseHandler m_cb; + bool m_called; + static OCStackApplicationResult handler(void *ctx, OCDoHandle handle, OCClientResponse *clientResponse) + { + Callback *callback = (Callback *) ctx; + OCStackApplicationResult result = callback->m_cb(NULL, handle, clientResponse); + callback->m_called = true; + return result; + } +}; + +class OCDiscoverTests : public testing::Test +{ + protected: + virtual void SetUp() + { + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_CLIENT_SERVER)); + } + + virtual void TearDown() + { + OCStop(); + } +}; //----------------------------------------------------------------------------- // Tests //----------------------------------------------------------------------------- @@ -174,6 +283,24 @@ TEST(StackStart, StackStartSuccessClientServer) EXPECT_EQ(OC_STACK_OK, OCStop()); } +TEST(StackStart, StackStartSuccessServerThenClient) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCStop()); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_CLIENT)); + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + +TEST(StackStart, StackStartSuccessClientThenServer) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_CLIENT)); + EXPECT_EQ(OC_STACK_OK, OCStop()); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + TEST(StackStart, StackStartSuccessiveInits) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); @@ -187,21 +314,42 @@ TEST(StackStart, SetPlatformInfoValid) itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - OCPlatformInfo info = {}; - info.platformID = (char *) "platform_id"; - info.manufacturerName = (char *) "manufac_name"; - + OCPlatformInfo info = + { + gDeviceUUID, + gManufacturerName, + 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; EXPECT_EQ(OC_STACK_OK, OCSetPlatformInfo(info)); EXPECT_EQ(OC_STACK_OK, OCStop()); } +TEST(StackStart, SetPlatformInfoWithClientMode) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_CLIENT)); + + OCPlatformInfo info = + { + gDeviceUUID, + gManufacturerName, + 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + TEST(StackStart, SetPlatformInfoWithNoPlatformID) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - OCPlatformInfo info = {}; - info.manufacturerName = (char *) "manufac_name"; + OCPlatformInfo info = + { + 0, + gDeviceUUID, + 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); EXPECT_EQ(OC_STACK_OK, OCStop()); @@ -212,8 +360,11 @@ TEST(StackStart, SetPlatformInfoWithNoManufacturerName) itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - OCPlatformInfo info = {}; - info.platformID = (char *) "platform_id"; + OCPlatformInfo info = + { + gDeviceUUID, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); EXPECT_EQ(OC_STACK_OK, OCStop()); @@ -224,8 +375,11 @@ TEST(StackStart, SetPlatformInfoWithZeroLengthManufacturerName) itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - OCPlatformInfo info = {}; - info.platformID = (char *) "platform_id"; + OCPlatformInfo info = + { + gDeviceUUID, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; info.manufacturerName = (char *) ""; EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); @@ -236,10 +390,18 @@ TEST(StackStart, SetPlatformInfoWithTooLongManufacName) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - - OCPlatformInfo info = {}; - info.platformID = (char *) "platform_id"; - info.manufacturerName = (char *) "extremelylongmanufacturername"; + char gTooLongManufacturerName[MAX_PLATFORM_NAME_LENGTH+2]; + for (int i = 0; i <= MAX_PLATFORM_NAME_LENGTH; i++ ) + { + gTooLongManufacturerName[i] = 'a'; + } + gTooLongManufacturerName[MAX_PLATFORM_NAME_LENGTH+1] = '\0'; + OCPlatformInfo info = + { + gDeviceUUID, + gTooLongManufacturerName, + 0, 0, 0, 0, 0, 0, 0, 0, 0 + }; EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); EXPECT_EQ(OC_STACK_OK, OCStop()); @@ -249,16 +411,203 @@ TEST(StackStart, SetPlatformInfoWithTooLongManufacURL) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); - - OCPlatformInfo info = {}; - info.platformID = (char *) "platform_id"; - info.manufacturerName = (char *) "extremelylongmanufacturername"; - info.manufacturerUrl = (char *)"www.foooooooooooooooo.baaaaaaaaaaaaar"; + char gManufacturerUrl[MAX_PLATFORM_URL_LENGTH+2]; + for (int i = 0; i <= MAX_PLATFORM_URL_LENGTH; i++ ) + { + gManufacturerUrl[i] = 'a'; + } + gManufacturerUrl[MAX_PLATFORM_URL_LENGTH+1] = '\0'; + OCPlatformInfo info = + { + gDeviceUUID, + gManufacturerName, + gManufacturerUrl, + 0, 0, 0, 0, 0, 0, 0, 0 + }; EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPlatformInfo(info)); EXPECT_EQ(OC_STACK_OK, OCStop()); } +TEST(StackStart, SetPlatformInfoWithOCSetPropertyValueAPI) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_ID, gDeviceUUID)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_NAME, gManufacturerName)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_URL, "http://www.iotivity.org")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MODEL_NUM, "S777")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_DATE, "15 Nov, 2016")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_OS_VERSION, "1.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_VERSION, "14")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_HARDWARE_VERSION, "0.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_FIRMWARE_VERSION, "0.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SUPPORT_URL, "http://www.iotivity.org")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SYSTEM_TIME, "")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, "x.org.iotivity.AAAA", "value")); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, NULL, "")); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPropertyValue(PAYLOAD_TYPE_INVALID, NULL, NULL)); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPropertyValue(PAYLOAD_TYPE_INVALID, NULL, NULL)); + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + +TEST(StackStart, GetPlatformInfoWithOCGetPropertyValueAPI) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_ID, gDeviceUUID)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_NAME, gManufacturerName)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_URL, "http://www.iotivity.org")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MODEL_NUM, "S777")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_DATE, "15 Nov, 2016")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_OS_VERSION, "1.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_VERSION, "14")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_HARDWARE_VERSION, "0.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_FIRMWARE_VERSION, "0.1")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SUPPORT_URL, "http://www.iotivity.org")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SYSTEM_TIME, "")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_PLATFORM, "x.org.iotivity.AAAA", "value")); + + void *value = NULL; + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_ID, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ(gDeviceUUID, (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_NAME, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ(gManufacturerName, (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_URL, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("http://www.iotivity.org", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MODEL_NUM, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("S777", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_MFG_DATE, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("15 Nov, 2016", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_OS_VERSION, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("1.1", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_PLATFORM_VERSION, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("14", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_HARDWARE_VERSION, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("0.1", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_FIRMWARE_VERSION, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("0.1", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SUPPORT_URL, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("http://www.iotivity.org", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, OC_RSRVD_SYSTEM_TIME, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK,OCGetPropertyValue(PAYLOAD_TYPE_PLATFORM, "x.org.iotivity.AAAA", &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("value", (char *)value); + OICFree(value); + + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + +TEST(StackStart, SetDeviceInfoAPI) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DEVICE_NAME, "Sample")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_SPEC_VERSION, "specVersion")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "x.org.iotivity.newproperty", "value")); + OCStringLL *dataModelVersions = OCCreateOCStringLL("Data Model Version"); + EXPECT_TRUE(dataModelVersions != NULL); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DATA_MODEL_VERSION, dataModelVersions)); + OCFreeOCStringLL(dataModelVersions); + OCResourceHandle handle = OCGetResourceHandleAtUri(OC_RSRVD_DEVICE_URI); + EXPECT_TRUE(handle != NULL); + EXPECT_EQ(OC_STACK_OK, OCBindResourceTypeToResource(handle, "oic.wk.tv")); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPropertyValue(PAYLOAD_TYPE_INVALID, NULL, NULL)); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCSetPropertyValue(PAYLOAD_TYPE_INVALID, "", NULL)); + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + +TEST(StackStart, GetDeviceInfoAPI) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + EXPECT_EQ(OC_STACK_OK, OCInit("127.0.0.1", 5683, OC_SERVER)); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DEVICE_NAME, "Sample")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_SPEC_VERSION, "specVersion")); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "x.org.iotivity.newproperty", "value")); + OCStringLL *dataModelVersions = OCCreateOCStringLL("Data Model Version"); + EXPECT_TRUE(dataModelVersions != NULL); + EXPECT_EQ(OC_STACK_OK, OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DATA_MODEL_VERSION, dataModelVersions)); + OCFreeOCStringLL(dataModelVersions); + OCResourceHandle handle = OCGetResourceHandleAtUri(OC_RSRVD_DEVICE_URI); + EXPECT_TRUE(handle != NULL); + EXPECT_EQ(OC_STACK_OK, OCBindResourceTypeToResource(handle, "oic.wk.tv")); + + void *value = NULL; + EXPECT_EQ(OC_STACK_OK, OCGetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DEVICE_NAME, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("Sample", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK, OCGetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_SPEC_VERSION, &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("specVersion", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK, OCGetPropertyValue(PAYLOAD_TYPE_DEVICE, "x.org.iotivity.newproperty", &value)); + ASSERT_TRUE(value != NULL); + EXPECT_STREQ("value", (char *)value); + OICFree(value); + value = NULL; + + EXPECT_EQ(OC_STACK_OK, OCGetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DATA_MODEL_VERSION, &value)); + ASSERT_TRUE(value != NULL); + ASSERT_TRUE(((OCStringLL *)value)->value); + EXPECT_STREQ("Data Model Version", ((OCStringLL *)value)->value); + OCFreeOCStringLL((OCStringLL *) value); + value = NULL; + + EXPECT_STREQ("oic.wk.d", OCGetResourceTypeName(handle, 0)); + EXPECT_STREQ("oic.wk.tv", OCGetResourceTypeName(handle, 1)); + + EXPECT_EQ(OC_STACK_OK, OCStop()); +} TEST(StackDiscovery, DISABLED_DoResourceDeviceDiscovery) { @@ -266,12 +615,12 @@ TEST(StackDiscovery, DISABLED_DoResourceDeviceDiscovery) OCCallbackData cbData; OCDoHandle handle; - OC_LOG(INFO, TAG, "Starting DoResourceDeviceDiscovery test "); + OIC_LOG(INFO, TAG, "Starting DoResourceDeviceDiscovery test "); InitStack(OC_CLIENT); /* Start a discovery query*/ - char szQueryUri[64] = { 0 }; - strcpy(szQueryUri, OC_WELL_KNOWN_QUERY); + char szQueryUri[MAX_QUERY_LENGTH] = { 0 }; + OICStrcpy(szQueryUri, MAX_QUERY_LENGTH, OC_RSRVD_WELL_KNOWN_URI); cbData.cb = asyncDoResourcesCallback; cbData.context = (void*)DEFAULT_CONTEXT_VALUE; cbData.cd = NULL; @@ -308,12 +657,12 @@ TEST(StackResource, DISABLED_UpdateResourceNullURI) OCCallbackData cbData; OCDoHandle handle; - OC_LOG(INFO, TAG, "Starting UpdateResourceNullURI test"); + OIC_LOG(INFO, TAG, "Starting UpdateResourceNullURI test"); InitStack(OC_CLIENT); /* Start a discovery query*/ - char szQueryUri[64] = { 0 }; - strcpy(szQueryUri, OC_WELL_KNOWN_QUERY); + char szQueryUri[MAX_QUERY_LENGTH] = { 0 }; + OICStrcpy(szQueryUri, MAX_QUERY_LENGTH, OC_RSRVD_WELL_KNOWN_URI); cbData.cb = asyncDoResourcesCallback; cbData.context = (void*)DEFAULT_CONTEXT_VALUE; cbData.cd = NULL; @@ -333,7 +682,7 @@ TEST(StackResource, DISABLED_UpdateResourceNullURI) TEST(StackResource, CreateResourceBadParams) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceBadParams test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceBadParams test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -361,7 +710,7 @@ TEST(StackResource, CreateResourceBadParams) "/a/led", 0, NULL, - 128));// invalid bitmask for OCResourceProperty + 255));// invalid bitmask for OCResourceProperty EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -369,10 +718,10 @@ TEST(StackResource, CreateResourceBadParams) TEST(StackResource, CreateResourceBadUri) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceBadUri test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceBadUri test"); InitStack(OC_SERVER); - const char *uri65 = "ABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKL"; + const char *uri257 = "ABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVWXYZABCDEFGHIJKLMNOPQRSTUVW"; OCResourceHandle handle; @@ -395,7 +744,7 @@ TEST(StackResource, CreateResourceBadUri) EXPECT_EQ(OC_STACK_INVALID_URI, OCCreateResource(&handle, "core.led", "core.rw", - uri65, //"/a/led", + uri257, //"/a/led", 0, 0, OC_DISCOVERABLE|OC_OBSERVABLE)); @@ -406,7 +755,7 @@ TEST(StackResource, CreateResourceBadUri) TEST(StackResource, CreateResourceSuccess) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceSuccess test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceSuccess test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -423,10 +772,50 @@ TEST(StackResource, CreateResourceSuccess) EXPECT_EQ(OC_STACK_OK, OCStop()); } +TEST(StackResource, CreateResourceSuccessWithResourcePolicyPropNone) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + OIC_LOG(INFO, TAG, "Starting CreateResourceSuccessWithResourcePolicyPropNone test"); + InitStack(OC_SERVER); + + OCResourceHandle handle; + // the resource is non-discoverable & non-observable by the client. + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handle, + "core.led", + "core.rw", + "/a/led", + 0, + NULL, + OC_RES_PROP_NONE));// the resource is non-discoverable & + // non-observable by the client. + const char* url = OCGetResourceUri(handle); + EXPECT_STREQ("/a/led", url); + + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + +TEST(StackResource, CreateResourceWithClientStackMode) +{ + itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); + OIC_LOG(INFO, TAG, "Starting CreateResourceSuccess test"); + InitStack(OC_CLIENT); + + OCResourceHandle handle; + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCCreateResource(&handle, + "core.led", + "core.rw", + "/a/led", + 0, + NULL, + OC_DISCOVERABLE|OC_OBSERVABLE)); + + EXPECT_EQ(OC_STACK_OK, OCStop()); +} + TEST(StackResource, CreateResourceFailDuplicateUri) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceFailDuplicateUri test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceFailDuplicateUri test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -454,7 +843,7 @@ TEST(StackResource, CreateResourceFailDuplicateUri) TEST(StackResource, CreateResourceMultipleResources) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceMultipleResources test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceMultipleResources test"); InitStack(OC_SERVER); OCResourceHandle handle1; @@ -498,7 +887,7 @@ TEST(StackResource, CreateResourceMultipleResources) TEST(StackResource, CreateResourceBadResoureType) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceBadResoureType test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceBadResoureType test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -510,13 +899,22 @@ TEST(StackResource, CreateResourceBadResoureType) NULL, OC_DISCOVERABLE|OC_OBSERVABLE)); + OCResourceHandle handle2; + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCCreateResource(&handle2, + "", + "core.rw", + "/a/led", + 0, + NULL, + OC_DISCOVERABLE|OC_OBSERVABLE)); + EXPECT_EQ(OC_STACK_OK, OCStop()); } TEST(StackResource, CreateResourceGoodResourceType) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting CreateResourceGoodResourceType test"); + OIC_LOG(INFO, TAG, "Starting CreateResourceGoodResourceType test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -534,7 +932,7 @@ TEST(StackResource, CreateResourceGoodResourceType) TEST(StackResource, ResourceTypeName) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceTypeName test"); + OIC_LOG(INFO, TAG, "Starting ResourceTypeName test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -565,7 +963,7 @@ TEST(StackResource, ResourceTypeName) TEST(StackResource, ResourceTypeAttrRepresentation) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceTypeAttrRepresentation test"); + OIC_LOG(INFO, TAG, "Starting ResourceTypeAttrRepresentation test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -587,7 +985,7 @@ TEST(StackResource, ResourceTypeAttrRepresentation) TEST(StackResource, ResourceTypeInterface) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceTypeInterface test"); + OIC_LOG(INFO, TAG, "Starting ResourceTypeInterface test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -601,12 +999,14 @@ TEST(StackResource, ResourceTypeInterface) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); - const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 0); + EXPECT_EQ(2, numResourceInterfaces); + const char *resourceInterfaceName1 = OCGetResourceInterfaceName(handle, 0); + EXPECT_STREQ(OC_RSRVD_INTERFACE_DEFAULT, resourceInterfaceName1); + const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 1); EXPECT_STREQ("core.rw", resourceInterfaceName); // try getting resource interface names with an invalid index - resourceInterfaceName = OCGetResourceInterfaceName(handle, 1); + resourceInterfaceName = OCGetResourceInterfaceName(handle, 2); EXPECT_STREQ(NULL, resourceInterfaceName); // try getting resource interface names with an invalid index resourceInterfaceName = OCGetResourceInterfaceName(handle, 10); @@ -619,7 +1019,7 @@ TEST(StackResource, ResourceDefaultInterfaceAlwaysFirst) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceDefaultInterfaceAlwaysFirst test"); + OIC_LOG(INFO, TAG, "Starting ResourceDefaultInterfaceAlwaysFirst test"); InitStack(OC_SERVER); @@ -650,7 +1050,7 @@ TEST(StackResource, ResourceDuplicateDefaultInterfaces) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceDuplicateDefaultInterfaces test"); + OIC_LOG(INFO, TAG, "Starting ResourceDuplicateDefaultInterfaces test"); InitStack(OC_SERVER); @@ -682,7 +1082,7 @@ TEST(StackResource, ResourceDuplicateNonDefaultInterfaces) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceDuplicateInterfaces test"); + OIC_LOG(INFO, TAG, "Starting ResourceDuplicateInterfaces test"); InitStack(OC_SERVER); @@ -702,7 +1102,7 @@ TEST(StackResource, ResourceDuplicateNonDefaultInterfaces) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); + EXPECT_EQ(2, numResourceInterfaces); EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -710,7 +1110,7 @@ TEST(StackResource, ResourceDuplicateNonDefaultInterfaces) TEST(StackResource, ResourceTypeInterfaceMethods) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ResourceTypeInterfaceMethods test"); + OIC_LOG(INFO, TAG, "Starting ResourceTypeInterfaceMethods test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -724,7 +1124,7 @@ TEST(StackResource, ResourceTypeInterfaceMethods) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); + EXPECT_EQ(2, numResourceInterfaces); EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -732,7 +1132,7 @@ TEST(StackResource, ResourceTypeInterfaceMethods) TEST(StackResource, GetResourceProperties) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting GetResourceProperties test"); + OIC_LOG(INFO, TAG, "Starting GetResourceProperties test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -744,7 +1144,11 @@ TEST(StackResource, GetResourceProperties) NULL, OC_DISCOVERABLE|OC_OBSERVABLE)); +#ifdef MQ_PUBLISHER + EXPECT_EQ(OC_ACTIVE|OC_DISCOVERABLE|OC_OBSERVABLE|OC_MQ_PUBLISHER, OCGetResourceProperties(handle)); +#else EXPECT_EQ(OC_ACTIVE|OC_DISCOVERABLE|OC_OBSERVABLE, OCGetResourceProperties(handle)); +#endif EXPECT_EQ(OC_STACK_OK, OCDeleteResource(handle)); EXPECT_EQ(OC_STACK_OK, OCStop()); @@ -753,7 +1157,7 @@ TEST(StackResource, GetResourceProperties) TEST(StackResource, StackTestResourceDiscoverOneResourceBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverOneResourceBad test"); + OIC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverOneResourceBad test"); InitStack(OC_SERVER); uint8_t numResources = 0; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResources(&numResources)); @@ -782,7 +1186,7 @@ TEST(StackResource, StackTestResourceDiscoverOneResourceBad) TEST(StackResource, StackTestResourceDiscoverOneResource) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverOneResource test"); + OIC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverOneResource test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -805,7 +1209,7 @@ TEST(StackResource, StackTestResourceDiscoverOneResource) TEST(StackResource, StackTestResourceDiscoverManyResources) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverManyResources test"); + OIC_LOG(INFO, TAG, "Starting StackTestResourceDiscoverManyResources test"); InitStack(OC_SERVER); OCResourceHandle handle1; @@ -870,7 +1274,7 @@ TEST(StackResource, StackTestResourceDiscoverManyResources) TEST(StackBind, BindResourceTypeNameBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceTypeNameBad test"); + OIC_LOG(INFO, TAG, "Starting BindResourceTypeNameBad test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -889,6 +1293,8 @@ TEST(StackBind, BindResourceTypeNameBad) EXPECT_STREQ("core.led", resourceTypeName); EXPECT_EQ(OC_STACK_INVALID_PARAM, OCBindResourceTypeToResource(handle, NULL)); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCBindResourceTypeToResource(handle, "core.nameBad")); + EXPECT_EQ(OC_STACK_INVALID_PARAM, OCBindResourceTypeToResource(handle, "core.name bad")); EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -896,7 +1302,7 @@ TEST(StackBind, BindResourceTypeNameBad) TEST(StackBind, BindResourceTypeNameGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceTypeNameGood test"); + OIC_LOG(INFO, TAG, "Starting BindResourceTypeNameGood test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -926,13 +1332,19 @@ TEST(StackBind, BindResourceTypeNameGood) resourceTypeName = OCGetResourceTypeName(handle, 2); EXPECT_STREQ("core.reallybrightled", resourceTypeName); + EXPECT_EQ(OC_STACK_OK, OCBindResourceTypeToResource(handle, "x.ReallyReallyBrightLED")); + EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceTypes(handle, &numResourceTypes)); + EXPECT_EQ(4, numResourceTypes); + resourceTypeName = OCGetResourceTypeName(handle, 3); + EXPECT_STREQ("x.ReallyReallyBrightLED", resourceTypeName); + EXPECT_EQ(OC_STACK_OK, OCStop()); } TEST(StackBind, BindResourceTypeAttribRepGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceTypeAttribRepGood test"); + OIC_LOG(INFO, TAG, "Starting BindResourceTypeAttribRepGood test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -963,7 +1375,7 @@ TEST(StackBind, BindResourceTypeAttribRepGood) TEST(StackBind, BindResourceInterfaceNameBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceInterfaceNameBad test"); + OIC_LOG(INFO, TAG, "Starting BindResourceInterfaceNameBad test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -977,8 +1389,8 @@ TEST(StackBind, BindResourceInterfaceNameBad) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); - const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 0); + EXPECT_EQ(2, numResourceInterfaces); + const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 1); EXPECT_STREQ("core.rw", resourceInterfaceName); EXPECT_EQ(OC_STACK_INVALID_PARAM, OCBindResourceInterfaceToResource(handle, NULL)); @@ -989,7 +1401,7 @@ TEST(StackBind, BindResourceInterfaceNameBad) TEST(StackBind, BindResourceInterfaceNameGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceInterfaceNameGood test"); + OIC_LOG(INFO, TAG, "Starting BindResourceInterfaceNameGood test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -1003,15 +1415,15 @@ TEST(StackBind, BindResourceInterfaceNameGood) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); - const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 0); + EXPECT_EQ(2, numResourceInterfaces); + const char *resourceInterfaceName = OCGetResourceInterfaceName(handle, 1); EXPECT_STREQ("core.rw", resourceInterfaceName); EXPECT_EQ(OC_STACK_OK, OCBindResourceInterfaceToResource(handle, "core.r")); EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(2, numResourceInterfaces); - resourceInterfaceName = OCGetResourceInterfaceName(handle, 1); + EXPECT_EQ(3, numResourceInterfaces); + resourceInterfaceName = OCGetResourceInterfaceName(handle, 2); EXPECT_STREQ("core.r", resourceInterfaceName); EXPECT_EQ(OC_STACK_OK, OCStop()); @@ -1020,7 +1432,7 @@ TEST(StackBind, BindResourceInterfaceNameGood) TEST(StackBind, BindResourceInterfaceMethodsBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceInterfaceMethodsBad test"); + OIC_LOG(INFO, TAG, "Starting BindResourceInterfaceMethodsBad test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -1034,7 +1446,7 @@ TEST(StackBind, BindResourceInterfaceMethodsBad) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); + EXPECT_EQ(2, numResourceInterfaces); EXPECT_EQ(OC_STACK_INVALID_PARAM, OCBindResourceInterfaceToResource(handle, 0)); @@ -1044,7 +1456,7 @@ TEST(StackBind, BindResourceInterfaceMethodsBad) TEST(StackBind, BindResourceInterfaceMethodsGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindResourceInterfaceMethodsGood test"); + OIC_LOG(INFO, TAG, "Starting BindResourceInterfaceMethodsGood test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -1058,12 +1470,12 @@ TEST(StackBind, BindResourceInterfaceMethodsGood) uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); + EXPECT_EQ(2, numResourceInterfaces); EXPECT_EQ(OC_STACK_OK, OCBindResourceInterfaceToResource(handle, "core.r")); EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle, &numResourceInterfaces)); - EXPECT_EQ(2, numResourceInterfaces); + EXPECT_EQ(3, numResourceInterfaces); EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -1071,7 +1483,7 @@ TEST(StackBind, BindResourceInterfaceMethodsGood) TEST(StackBind, BindContainedResourceBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindContainedResourceBad test"); + OIC_LOG(INFO, TAG, "Starting BindContainedResourceBad test"); InitStack(OC_SERVER); OCResourceHandle containerHandle; @@ -1102,7 +1514,7 @@ TEST(StackBind, BindContainedResourceBad) TEST(StackBind, BindContainedResourceGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindContainedResourceGood test"); + OIC_LOG(INFO, TAG, "Starting BindContainedResourceGood test"); InitStack(OC_SERVER); uint8_t numResources = 0; @@ -1193,15 +1605,14 @@ TEST(StackBind, BindContainedResourceGood) EXPECT_EQ(OC_STACK_OK, OCBindResource(containerHandle, handle2)); EXPECT_EQ(OC_STACK_OK, OCBindResource(containerHandle, handle3)); EXPECT_EQ(OC_STACK_OK, OCBindResource(containerHandle, handle4)); - EXPECT_EQ(OC_STACK_ERROR, OCBindResource(containerHandle, handle5)); + EXPECT_EQ(OC_STACK_OK, OCBindResource(containerHandle, handle5)); EXPECT_EQ(handle0, OCGetResourceHandleFromCollection(containerHandle, 0)); EXPECT_EQ(handle1, OCGetResourceHandleFromCollection(containerHandle, 1)); EXPECT_EQ(handle2, OCGetResourceHandleFromCollection(containerHandle, 2)); EXPECT_EQ(handle3, OCGetResourceHandleFromCollection(containerHandle, 3)); EXPECT_EQ(handle4, OCGetResourceHandleFromCollection(containerHandle, 4)); - - EXPECT_EQ(NULL, OCGetResourceHandleFromCollection(containerHandle, 5)); + EXPECT_EQ(handle5, OCGetResourceHandleFromCollection(containerHandle, 5)); EXPECT_EQ(OC_STACK_OK, OCStop()); } @@ -1210,7 +1621,7 @@ TEST(StackBind, BindContainedResourceGood) TEST(StackBind, BindEntityHandlerBad) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindEntityHandlerBad test"); + OIC_LOG(INFO, TAG, "Starting BindEntityHandlerBad test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -1230,7 +1641,7 @@ TEST(StackBind, BindEntityHandlerBad) TEST(StackBind, BindEntityHandlerGood) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting BindEntityHandlerGood test"); + OIC_LOG(INFO, TAG, "Starting BindEntityHandlerGood test"); InitStack(OC_SERVER); OCResourceHandle handle; @@ -1254,7 +1665,7 @@ TEST(StackBind, BindEntityHandlerGood) TEST(StackResourceAccess, GetResourceByIndex) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting GetResourceByIndex test"); + OIC_LOG(INFO, TAG, "Starting GetResourceByIndex test"); InitStack(OC_SERVER); uint8_t numResources = 0; @@ -1354,7 +1765,7 @@ TEST(StackResourceAccess, GetResourceByIndex) TEST(StackResourceAccess, DeleteHeadResource) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting DeleteHeadResource test"); + OIC_LOG(INFO, TAG, "Starting DeleteHeadResource test"); InitStack(OC_SERVER); uint8_t numResources = 0; @@ -1383,7 +1794,7 @@ TEST(StackResourceAccess, DeleteHeadResource) TEST(StackResourceAccess, DeleteHeadResource2) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting DeleteHeadResource2 test"); + OIC_LOG(INFO, TAG, "Starting DeleteHeadResource2 test"); InitStack(OC_SERVER); uint8_t numResources = 0; @@ -1425,14 +1836,14 @@ TEST(StackResourceAccess, DeleteHeadResource2) TEST(StackResourceAccess, DeleteLastResource) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting DeleteLastResource test"); + OIC_LOG(INFO, TAG, "Starting DeleteLastResource test"); InitStack(OC_SERVER); uint8_t numResources = 0; uint8_t numExpectedResources = 0; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResources(&numExpectedResources)); - + OCResourceHandle handle0; EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handle0, "core.led", @@ -1478,7 +1889,7 @@ TEST(StackResourceAccess, DeleteLastResource) TEST(StackResourceAccess, DeleteMiddleResource) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting DeleteMiddleResource test"); + OIC_LOG(INFO, TAG, "Starting DeleteMiddleResource test"); InitStack(OC_SERVER); uint8_t numResources = 0; @@ -1530,110 +1941,595 @@ TEST(StackResourceAccess, DeleteMiddleResource) // Make sure the resource elements are still correct uint8_t numResourceInterfaces; EXPECT_EQ(OC_STACK_OK, OCGetNumberOfResourceInterfaces(handle2, &numResourceInterfaces)); - EXPECT_EQ(1, numResourceInterfaces); - const char *resourceInterfaceName = OCGetResourceInterfaceName(handle2, 0); + EXPECT_EQ(2, numResourceInterfaces); + const char *resourceInterfaceName = OCGetResourceInterfaceName(handle2, 1); EXPECT_STREQ("core.rw", resourceInterfaceName); EXPECT_EQ(OC_STACK_OK, OCStop()); } +// Visual Studio versions earlier than 2015 have bugs in is_pod and report the wrong answer. +#if !defined(_MSC_VER) || (_MSC_VER >= 1900) +TEST(PODTests, OCHeaderOption) +{ + EXPECT_TRUE(std::is_pod::value); +} + +TEST(PODTests, OCCallbackData) +{ + EXPECT_TRUE(std::is_pod::value); +} +#endif + +TEST(OCDoDirectPairingTests, Nullpeer) +{ + EXPECT_EQ(OC_STACK_INVALID_PARAM,OCDoDirectPairing(NULL, NULL, pmSel, &pinNumber, &resultCallback)); +} -#ifdef __cplusplus -extern "C" { -#endif // __cplusplus - void parsePresencePayload(char* payload, uint32_t* seqNum, - uint32_t* maxAge, OCPresenceTrigger* presenceTrigger, char** resType); -#ifdef __cplusplus +TEST(OCDoDirectPairingTests, NullCallback) +{ + EXPECT_EQ(OC_STACK_INVALID_CALLBACK,OCDoDirectPairing(NULL, &peer, pmSel, &pinNumber, NULL)); +} + +TEST(OCDoDirectPairingTests, NullpinNumber) +{ + EXPECT_EQ(OC_STACK_INVALID_PARAM,OCDoDirectPairing(NULL, &peer, pmSel, NULL, &resultCallback)); } -#endif // __cplusplus -TEST(StackPresence, ParsePresencePayload) +TEST(StackResource, MultipleResourcesDiscovery) { itst::DeadmanTimer killSwitch(SHORT_TEST_TIMEOUT); - OC_LOG(INFO, TAG, "Starting ParsePresencePayload test"); - - char payload[100]; - uint32_t seqNum = 0, maxAge = 0; - OCPresenceTrigger presenceTrigger = OC_PRESENCE_TRIGGER_CHANGE; - char * resType = NULL; - - //Good Scenario - strncpy(payload, "{\"oic\":[{\"ttl\":99,\"non\":100,\"trg\":" - "\"delete\",\"rt\":\"presence\"}]}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, - &presenceTrigger, &resType); - EXPECT_TRUE(100 == seqNum); - EXPECT_TRUE(99 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_DELETE == presenceTrigger); - EXPECT_TRUE(NULL != resType); - EXPECT_STREQ("presence", resType); - OICFree(resType); - - presenceTrigger = OC_PRESENCE_TRIGGER_CHANGE; - - //Bad Scenario -- should not result in Seg Fault - parsePresencePayload(payload, NULL, &maxAge, &presenceTrigger, &resType); - - //Bad Scenario - seqNum = 0; maxAge = 0; resType = NULL; - strncpy(payload, "{abracadabra}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, &presenceTrigger, &resType); - EXPECT_TRUE(0 == seqNum); - EXPECT_TRUE(0 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_CHANGE == presenceTrigger); - EXPECT_TRUE(NULL == resType); - EXPECT_EQ(NULL, resType); - OICFree(resType); - - //Bad Scenario - seqNum = 0; maxAge = 0; resType = NULL; - strncpy(payload, "{\"oic\":[100]}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, &presenceTrigger, &resType); - EXPECT_TRUE(0 == seqNum); - EXPECT_TRUE(0 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_CHANGE == presenceTrigger); - EXPECT_TRUE(NULL == resType); - EXPECT_EQ(NULL, resType); - OICFree(resType); - - //Bad Scenario - seqNum = 0; maxAge = 0; resType = NULL; - strncpy(payload, "{\"oic\":[]}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, &presenceTrigger, &resType); - EXPECT_TRUE(0 == seqNum); - EXPECT_TRUE(0 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_CHANGE == presenceTrigger); - EXPECT_TRUE(NULL == resType); - EXPECT_EQ(NULL, resType); - OICFree(resType); - - //Bad Scenario - strncpy(payload, "{:]}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, &presenceTrigger, &resType); - EXPECT_TRUE(0 == seqNum); - EXPECT_TRUE(0 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_CHANGE == presenceTrigger); - EXPECT_TRUE(NULL == resType); - EXPECT_EQ(NULL, resType); - OICFree(resType); - - //Bad Scenario - strncpy(payload, "{:[presence}", sizeof(payload)); - parsePresencePayload(payload, &seqNum, &maxAge, &presenceTrigger, &resType); - EXPECT_TRUE(0 == seqNum); - EXPECT_TRUE(0 == maxAge); - EXPECT_TRUE(OC_PRESENCE_TRIGGER_CHANGE == presenceTrigger); - EXPECT_TRUE(NULL == resType); - EXPECT_EQ(NULL, resType); - OICFree(resType); + OIC_LOG(INFO, TAG, "Starting MultipleResourcesDiscovery test"); + InitStack(OC_SERVER); + + OCResourceHandle handle1; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handle1, + "core.led", + "core.rw", + "/a/led1", + 0, + NULL, + OC_DISCOVERABLE|OC_OBSERVABLE)); + + OCResourceHandle handle2; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handle2, + "core.led", + "core.rw", + "/a/led2", + 0, + NULL, + OC_DISCOVERABLE|OC_OBSERVABLE)); + OCResourceHandle handle3; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handle3, + "core.led", + "core.rw", + "/a/led3", + 0, + NULL, + OC_DISCOVERABLE|OC_OBSERVABLE)); + /* Start a discovery query*/ + char szQueryUri[MAX_QUERY_LENGTH] = "/oic/res?if=oic.if.ll"; + OCCallbackData cbData; + cbData.cb = discoveryCallback; + cbData.context = (void*)DEFAULT_CONTEXT_VALUE; + cbData.cd = NULL; + + OCDoHandle handle; + EXPECT_EQ(OC_STACK_OK, OCDoResource(&handle, + OC_REST_DISCOVER, + szQueryUri, + 0, + 0, + CT_ADAPTER_IP, + OC_LOW_QOS, + &cbData, + NULL, + 0)); + + EXPECT_EQ(OC_STACK_OK, OCStop()); } -TEST(PODTests, OCHeaderOption) +TEST(StackPayload, CloneByteString) { - EXPECT_TRUE(std::is_pod::value); + uint8_t bytes[] = { 0, 1, 2, 3 }; + OCByteString byteString; + byteString.bytes = bytes; + byteString.len = sizeof(bytes); + + OCRepPayload *original = OCRepPayloadCreate(); + ASSERT_TRUE(original != NULL); + EXPECT_TRUE(OCRepPayloadSetPropByteString(original, "name", byteString)); + + OCRepPayload *clone = OCRepPayloadClone(original); + ASSERT_TRUE(clone != NULL); + + OCRepPayloadDestroy(original); + + OCByteString cloneByteString; + EXPECT_TRUE(OCRepPayloadGetPropByteString(clone, "name", &cloneByteString)); + ASSERT_TRUE(cloneByteString.bytes != NULL); + EXPECT_EQ(sizeof(bytes), cloneByteString.len); + EXPECT_TRUE(0 == memcmp(bytes, cloneByteString.bytes, sizeof(bytes))); + OICFree(cloneByteString.bytes); + + OCRepPayloadDestroy(clone); } -TEST(PODTests, OCCallbackData) +TEST(StackUri, Rfc6874_Noop_1) { - EXPECT_TRUE(std::is_pod::value); + char validIPv6Address[] = "FF01:0:0:0:0:0:0:FB"; + char bytes[100] = {0}; + strncpy(bytes, validIPv6Address, sizeof(bytes)); + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), validIPv6Address); + + // No % sign, should do nothing + EXPECT_STREQ(bytes, validIPv6Address); + EXPECT_EQ(OC_STACK_OK, result); +} + +TEST(StackUri, Rfc6874_Noop_2) +{ + char validIPv6Address[] = "3812:a61::4:1"; + char bytes[100] = {0}; + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), validIPv6Address); + + // No % sign, should do nothing + EXPECT_STREQ(bytes, validIPv6Address); + EXPECT_EQ(OC_STACK_OK, result); +} + +TEST(StackUri, Rfc6874_WithEncoding) +{ + char validIPv6Address[] = "fe80::dafe:e3ff:fe00:ebfa%wlan0"; + char validIPv6AddressEncoded[] = "fe80::dafe:e3ff:fe00:ebfa%25wlan0"; + char bytes[100] = ""; + strncpy(bytes, validIPv6Address, sizeof(bytes)); + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), validIPv6Address); + + // Encoding should have occured + EXPECT_STREQ(bytes, validIPv6AddressEncoded); + EXPECT_EQ(OC_STACK_OK, result); +} + +TEST(StackUri, Rfc6874_WithEncoding_ExtraPercent) +{ + char validIPv6Address[] = "fe80::dafe:e3ff:fe00:ebfa%%wlan0"; + char bytes[100] = {0}; + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), validIPv6Address); + + // Encoding should have failed due to extra '%' character + EXPECT_STREQ(bytes, ""); + EXPECT_EQ(OC_STACK_ERROR, result); +} + +TEST(StackUri, Rfc6874_AlreadyEncoded) +{ + char validIPv6AddressEncoded[] = "fe80::dafe:e3ff:fe00:ebfa%25wlan0"; + char bytes[100] = {0}; + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), validIPv6AddressEncoded); + + // Encoding should have failed due to extra '%' character + EXPECT_STREQ(bytes, ""); + EXPECT_EQ(OC_STACK_ERROR, result); +} + +TEST(StackUri, Rfc6874_NoOverflow) +{ + char validIPv6Address[] = "fe80::dafe:e3ff:fe00:ebfa%wlan0"; + char addrBuffer[100]; + char bytes[100] = {0}; + memset(addrBuffer, sizeof(addrBuffer), '_'); + + // Just enough room to encode + addrBuffer[sizeof(addrBuffer) - sizeof(validIPv6Address) - 3] = '\0'; + strcat(addrBuffer, validIPv6Address); + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), addrBuffer); + + // Encoding should have succeeded + EXPECT_EQ(OC_STACK_OK, result); +} + +TEST(StackUri, Rfc6874_NoOverflow_2) +{ + char validIPv6Address[] = "fe80::dafe:e3ff:fe00:ebfa%wlan0"; + char addrBuffer[100]; + char bytes[100] = {0}; + memset(addrBuffer, sizeof(addrBuffer), '_'); + + // Not enough room to encode + addrBuffer[sizeof(addrBuffer) - sizeof(validIPv6Address) - 1] = '\0'; + strcat(addrBuffer, validIPv6Address); + + OCStackResult result = OCEncodeAddressForRFC6874(bytes, sizeof(bytes), addrBuffer); + + // Encoding should have failed due to output size limitations + EXPECT_STREQ(bytes, ""); + EXPECT_EQ(OC_STACK_ERROR, result); +} + +TEST(StackHeaderOption, setHeaderOption) +{ + uint8_t optionValue1[MAX_HEADER_OPTION_DATA_LENGTH] = + { 1 }; + OCHeaderOption options[MAX_HEADER_OPTIONS] = + { + { OC_COAP_ID, 6, 8, optionValue1 }, }; + uint8_t optionData = 255; + size_t optionDataSize = sizeof(optionData); + size_t numOptions = 1; + uint16_t optionID = 2048; + EXPECT_EQ(OC_STACK_OK, OCSetHeaderOption(options, + &numOptions, + optionID, + &optionData, + optionDataSize)); + EXPECT_EQ(options[1].optionID, optionID); + EXPECT_EQ(options[1].optionData[0], 255); +} + +TEST(StackHeaderOption, getHeaderOption) +{ + uint8_t optionValue1[MAX_HEADER_OPTION_DATA_LENGTH] = + { 1 }; + uint8_t optionValue2[MAX_HEADER_OPTION_DATA_LENGTH] = + { 255 }; + OCHeaderOption options[MAX_HEADER_OPTIONS] = + { + { OC_COAP_ID, 6, 8, optionValue1 }, + { OC_COAP_ID, 2048, 16, optionValue2 }, }; + uint8_t optionData[MAX_HEADER_OPTION_DATA_LENGTH]; + size_t optionDataSize = sizeof(optionData); + size_t numOptions = 2; + uint16_t optionID = 6; + uint16_t actualDataSize = 0; + EXPECT_EQ(OC_STACK_OK, OCGetHeaderOption(options, + numOptions, + optionID, + optionData, + optionDataSize, + &actualDataSize)); + EXPECT_EQ(optionData[0], 1); + EXPECT_EQ(actualDataSize, 8); +} + +static OCStackApplicationResult DiscoverBaslineResource(void *ctx, OCDoHandle handle, + OCClientResponse *response) +{ + OC_UNUSED(ctx); + OC_UNUSED(handle); + EXPECT_EQ(OC_STACK_OK, response->result); + EXPECT_TRUE(NULL != response->payload); + if (NULL != response->payload) + { + EXPECT_EQ(PAYLOAD_TYPE_DISCOVERY, response->payload->type); + + OCDiscoveryPayload *payload = (OCDiscoveryPayload *)response->payload; + EXPECT_TRUE(NULL != payload->sid); + if (payload->name) + { + EXPECT_STREQ("StackTest", payload->name); + } + EXPECT_STREQ(OC_RSRVD_RESOURCE_TYPE_RES, payload->type->value); + EXPECT_STREQ(OC_RSRVD_INTERFACE_LL, payload->iface->value); + EXPECT_STREQ(OC_RSRVD_INTERFACE_DEFAULT, payload->iface->next->value); + + for (OCResourcePayload *resource = payload->resources; resource; resource = resource->next) + { + if (0 == strcmp("/a/light", resource->uri)) + { + EXPECT_STREQ("/a/light", resource->uri); + EXPECT_STREQ("core.light", resource->types->value); + EXPECT_EQ(NULL, resource->types->next); + EXPECT_STREQ("oic.if.baseline", resource->interfaces->value); + EXPECT_EQ(NULL, resource->interfaces->next); + EXPECT_TRUE(resource->bitmap & OC_DISCOVERABLE); + EXPECT_TRUE(resource->bitmap & OC_OBSERVABLE); + EXPECT_FALSE(resource->secure); + EXPECT_EQ(0, resource->port); + EXPECT_EQ(NULL, resource->next); + } + } + } + + return OC_STACK_DELETE_TRANSACTION; +} + +static OCStackApplicationResult DiscoverLinkedListResource(void *ctx, OCDoHandle handle, + OCClientResponse *response) +{ + OC_UNUSED(ctx); + OC_UNUSED(handle); + EXPECT_EQ(OC_STACK_OK, response->result); + EXPECT_TRUE(NULL != response->payload); + if (NULL != response->payload) + { + EXPECT_EQ(PAYLOAD_TYPE_DISCOVERY, response->payload->type); + + OCDiscoveryPayload *payload = (OCDiscoveryPayload *)response->payload; + EXPECT_NE((char *)NULL, payload->sid); + EXPECT_EQ(NULL, payload->name); + EXPECT_EQ(NULL, payload->type); + EXPECT_EQ(NULL, payload->iface); + + for (OCResourcePayload *resource = payload->resources; resource; resource = resource->next) + { + if (0 == strcmp("/a/light", resource->uri)) + { + EXPECT_STREQ("/a/light", resource->uri); + EXPECT_STREQ("core.light", resource->types->value); + EXPECT_EQ(NULL, resource->types->next); + EXPECT_STREQ("oic.if.baseline", resource->interfaces->value); + EXPECT_EQ(NULL, resource->interfaces->next); + EXPECT_TRUE(resource->bitmap & OC_DISCOVERABLE); + EXPECT_TRUE(resource->bitmap & OC_OBSERVABLE); + EXPECT_FALSE(resource->secure); + EXPECT_EQ(0, resource->port); + EXPECT_EQ(NULL, resource->next); + } + } + } + return OC_STACK_DELETE_TRANSACTION; +} + + +static OCStackApplicationResult DiscoverResourceTypeResponse(void *ctx, OCDoHandle handle, + OCClientResponse *response) +{ + OC_UNUSED(ctx); + OC_UNUSED(handle); + EXPECT_EQ(OC_STACK_OK, response->result); + EXPECT_TRUE(NULL != response->payload); + if (NULL != response->payload) + { + EXPECT_EQ(PAYLOAD_TYPE_DISCOVERY, response->payload->type); + + OCDiscoveryPayload *payload = (OCDiscoveryPayload *)response->payload; + EXPECT_NE((char *)NULL, payload->sid); + EXPECT_EQ(NULL, payload->name); + EXPECT_EQ(NULL, payload->type); + EXPECT_EQ(NULL, payload->iface); + EXPECT_TRUE(NULL != payload->resources); + + OCResourcePayload *resource = payload->resources; + + if (0 == strcmp("/a/light", resource->uri)) + { + EXPECT_STREQ("/a/light", resource->uri); + EXPECT_STREQ("core.light", resource->types->value); + EXPECT_EQ(NULL, resource->types->next); + EXPECT_STREQ("oic.if.baseline", resource->interfaces->value); + EXPECT_EQ(NULL, resource->interfaces->next); + EXPECT_TRUE(resource->bitmap & OC_DISCOVERABLE); + EXPECT_TRUE(resource->bitmap & OC_OBSERVABLE); + EXPECT_FALSE(resource->secure); + EXPECT_EQ(0, resource->port); + EXPECT_EQ(NULL, resource->next); + } + } + + return OC_STACK_DELETE_TRANSACTION; +} + +static OCStackApplicationResult DiscoverNoResource(void *ctx, OCDoHandle handle, + OCClientResponse *response) +{ + OC_UNUSED(ctx); + OC_UNUSED(handle); + EXPECT_EQ(OC_STACK_OK, response->result); + EXPECT_TRUE(NULL != response->payload); + if (NULL != response->payload) + { + EXPECT_EQ(PAYLOAD_TYPE_DISCOVERY, response->payload->type); + + OCDiscoveryPayload *payload = (OCDiscoveryPayload *)response->payload; + EXPECT_EQ(NULL, payload->sid); + EXPECT_EQ(NULL, payload->name); + EXPECT_EQ(NULL, payload->type); + EXPECT_EQ(NULL, payload->iface); + + bool resourceFound = false; + for (OCResourcePayload *resource = payload->resources; resource; resource = resource->next) + { + if (0 == strcmp("/a/light", resource->uri)) + { + resourceFound = true; + } + } + + EXPECT_FALSE(resourceFound); + } + return OC_STACK_DELETE_TRANSACTION; +} + +static OCStackApplicationResult DiscoverUnicastErrorResponse(void *ctx, OCDoHandle handle, + OCClientResponse *response) +{ + OC_UNUSED(ctx); + OC_UNUSED(handle); + EXPECT_NE(OC_STACK_OK, response->result); + EXPECT_TRUE(NULL == response->payload); + + return OC_STACK_DELETE_TRANSACTION; +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInterfaceBaselineQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, OC_RSRVD_DEVICE_NAME, "StackTest"); + Callback discoverCB(&DiscoverBaslineResource); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?if=oic.if.baseline", NULL, + 0, CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(100); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithoutAnyQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverLinkedListResource); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res", NULL, 0, CT_DEFAULT, + OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(100); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInterfaceLinkedListQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverLinkedListResource); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?if=oic.if.ll", NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(100); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithResourceTypeQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverResourceTypeResponse); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?rt=core.light", NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(100); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInvalidInterfaceQuery_Unicast) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + char targetUri[MAX_URI_LENGTH * 2] ={ 0, }; + snprintf(targetUri, MAX_URI_LENGTH * 2, "127.0.0.1/oic/res?if=invalid"); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, targetUri, NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(100); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithoutInterfaceQuery_Unicast) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + char targetUri[MAX_URI_LENGTH * 2] ={ 0, }; + snprintf(targetUri, MAX_URI_LENGTH * 2, "127.0.0.1/oic/res?if="); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, targetUri, NULL, 0, CT_DEFAULT, + OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(10); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInvalidResourceTypeQuery_Unicast) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + char targetUri[MAX_URI_LENGTH * 2] ={ 0, }; + snprintf(targetUri, MAX_URI_LENGTH * 2, "127.0.0.1/oic/res?rt=invalid"); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, targetUri, NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(10); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithoutResourceTypeQuery_Unicast) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + char targetUri[MAX_URI_LENGTH * 2] ={ 0, }; + snprintf(targetUri, MAX_URI_LENGTH * 2, "127.0.0.1/oic/res?rt="); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, targetUri, NULL, 0, CT_DEFAULT, + OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(10); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInvalidResourceTypeQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?rt=invalid", NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(5); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithoutResourceTypeQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverUnicastErrorResponse); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?rt=", NULL, 0, CT_DEFAULT, + OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(5); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithInvalidInterfaceQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverNoResource); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?if=invalid", NULL, 0, + CT_DEFAULT, OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(5); +} + +TEST_F(OCDiscoverTests, DiscoverResourceWithoutInterfaceQuery) +{ + itst::DeadmanTimer killSwitch(LONG_TEST_TIMEOUT); + + OCResourceHandle handles; + EXPECT_EQ(OC_STACK_OK, OCCreateResource(&handles, "core.light", "oic.if.baseline", "/a/light", + entityHandler, NULL, (OC_DISCOVERABLE | OC_OBSERVABLE))); + OCSetPropertyValue(PAYLOAD_TYPE_DEVICE, "deviceName", "StackTest"); + Callback discoverCB(&DiscoverNoResource); + EXPECT_EQ(OC_STACK_OK, OCDoResource(NULL, OC_REST_DISCOVER, "/oic/res?if=", NULL, 0, CT_DEFAULT, + OC_HIGH_QOS, discoverCB, NULL, 0)); + discoverCB.Wait(5); }