-#include <stdio.h>
+//******************************************************************
+//
+// Copyright 2016 Samsung Electronics All Rights Reserved.
+//
+//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+//
+// 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 an "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.
+//
+//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
+#include <stdio.h>
#include <unistd.h>
+#include <string.h>
+#include "pthread.h"
+
+#include "ocstack.h"
#include "NSCommon.h"
#include "NSConsumerInterface.h"
-#include "ocstack.h"
-void onDiscoverNotification(NSProvider * provider)
+#ifdef WITH_CLOUD
+#include "NSConstants.h"
+#include "oic_malloc.h"
+#include "cloud_connector.h"
+
+#define CLOUD_CONTEXT_VALUE 0x99
+
+char CLOUD_ADDRESS[100];
+char CLOUD_TOPIC[100];
+char CLOUD_AUTH_PROVIDER[100];
+char CLOUD_AUTH_CODE[100];
+char CLOUD_UID[100];
+char CLOUD_ACCESS_TOKEN[100];
+#endif
+
+
+NSProvider * g_provider = NULL;
+NSTopicLL * g_topicLL = NULL;
+
+FILE* server_fopen(const char *path, const char *mode)
{
- printf("notification resource discovered\n");
- printf("subscribe result %d\n", NSSubscribe(provider));
- printf("startSubscribing\n");
+ (void)path;
+ return fopen("oic_ns_provider_db.dat", mode);
}
-void onSubscriptionAccepted(NSProvider * provider)
+void printProviderTopicList(NSTopicLL * topics)
{
- printf("Subscription accepted\n");
+ printf("printProviderTopicList\n");
+ if (topics)
+ {
+ NSTopicLL * iter = topics;
+ while (iter)
+ {
+ printf("Topic Name: %s\t Topic State: %d\n", iter->topicName, iter->state);
+ iter = iter->next;
+ }
+ }
+}
+
+void onProviderChanged(NSProvider * provider, NSProviderState response)
+{
+ printf("Provider changed: %d\n", response);
printf("subscribed provider Id : %s\n", provider->providerId);
+
+ if (response == NS_DISCOVERED)
+ {
+ printf("notification resource discovered\n");
+ printf("subscribe result %d\n", NSSubscribe(provider->providerId));
+ printf("startSubscribing\n");
+ }
+
+ else if (response == NS_TOPIC)
+ {
+ printf ("Provider Topic Updated\n");
+ g_topicLL = NSConsumerGetTopicList(provider->providerId);
+ printProviderTopicList(g_topicLL);
+ g_provider = provider;
+ }
}
void onNotificationPosted(NSMessage * notification)
{
- printf("id : %ld\n", notification->messageId);
+ printf("id : %lld\n", (long long int)notification->messageId);
printf("title : %s\n", notification->title);
printf("content : %s\n", notification->contentText);
printf("source : %s\n", notification->sourceName);
+ if (notification->topic && strlen(notification->topic) > 0)
+ {
+ printf("topic : %s\n", notification->topic);
+ }
NSConsumerSendSyncInfo(notification->providerId, notification->messageId, NS_SYNC_READ);
}
void onNotificationSync(NSSyncInfo * sync)
{
- printf("Sync ID : %ld\n", sync->messageId);
+ printf("Sync ID : %lld\n", (long long int)sync->messageId);
printf("Sync STATE : %d\n", sync->state);
}
+void* OCProcessThread(void * ptr)
+{
+ (void) ptr;
+
+ while (true)
+ {
+ usleep(2000);
+ if(OCProcess() != OC_STACK_OK)
+ {
+ OCStop();
+ break;
+ }
+ }
+
+ return NULL;
+}
+
+void input(char * buffer)
+{
+ char ch;
+ int i = 0;
+
+ while( (ch = getchar()) != '\n' && i < 100)
+ buffer[i++] = ch;
+
+ buffer[i] = '\0';
+}
+
int main(void)
{
+ bool isExit = false;
+ pthread_t OCThread = NULL;
printf("start Iotivity\n");
- if (OCInit1(OC_CLIENT, OC_DEFAULT_FLAGS, OC_DEFAULT_FLAGS) != OC_STACK_OK)
+
+ // open oic_db
+ static OCPersistentStorage ps = {server_fopen, fread, fwrite, fclose, unlink};
+ OCRegisterPersistentStorageHandler(&ps);
+
+ if (OCInit1(OC_CLIENT_SERVER, OC_DEFAULT_FLAGS, OC_DEFAULT_FLAGS) != OC_STACK_OK)
{
printf("OCInit fail\n");
return 0;
}
NSConsumerConfig cfg;
- cfg.discoverCb = onDiscoverNotification;
- cfg.acceptedCb = onSubscriptionAccepted;
+ cfg.changedCb = onProviderChanged;
cfg.messageCb = onNotificationPosted;
cfg.syncInfoCb = onNotificationSync;
+ pthread_create(&OCThread, NULL, OCProcessThread, NULL);
printf("start notification consumer service\n");
- NSResult ret = NSStartConsumer(cfg);
- if(ret != NS_OK)
+ while (!isExit)
{
- printf("error discoverNoti %d\n", ret);
- }
+ int num = 0;
+ char dummy = '\0';
- while (true)
- {
- usleep(2000);
- if(OCProcess() != OC_STACK_OK)
+ printf("1. Start Consumer\n");
+ printf("2. Stop Consumer\n");
+ printf("3. Get Topics\n");
+ printf("4. Select Topics\n");
+ printf("5. Cancel select Topics\n");
+ printf("0. Exit\n");
+#ifdef WITH_MQ
+ printf("11. Subscribe MQ Service\n");
+#endif
+#ifdef WITH_CLOUD
+ printf("21. Enable Remote Service (after login)\n");
+ printf("31. Cloud Signup\n");
+ printf("32. Cloud Login\n");
+ printf("33. Cloud Logout\n");
+#endif
+
+ printf("Input: ");
+
+ if(scanf("%d", &num) == EOF)
{
- OCStop();
- break;
+ printf("Fail to input num\n");
}
- }
+ fflush(stdin);
+ if(scanf("%c", &dummy) == EOF)
+ {
+ printf("Fail to input dummy\n");
+ }
+ fflush(stdin);
+
+ switch (num)
+ {
+ case 1:
+ printf("1. Start Consumer\n");
+ NSStartConsumer(cfg);
+ break;
+ case 2:
+ printf("2. Stop Consumer");
+ NSStopConsumer();
+ break;
+ case 3:
+ printf("3. Get Topics\n");
+ if(g_provider)
+ {
+ g_topicLL = NSConsumerGetTopicList(g_provider->providerId);
+ printProviderTopicList(g_topicLL);
+ }
+ break;
+ case 4:
+ printf("4. Select Topics\n");
+
+ if (g_provider && g_topicLL)
+ {
+ NSTopicLL * iter = g_topicLL;
+ int i = 0;
+ while (iter)
+ {
+ iter->state = (i++)%2;
+ iter = iter->next;
+ }
+ NSResult ret = NSConsumerUpdateTopicList(g_provider->providerId, g_topicLL);
+ if (ret == NS_OK)
+ {
+ printProviderTopicList(g_topicLL);
+ }
+ else
+ {
+ printf("Update fail\n");
+ }
+ }
+ break;
+ case 5:
+ printf("5. Cancel select Topics\n");
+ NSTopicLL * iter = g_topicLL;
+ while (iter)
+ {
+ iter->state = NS_TOPIC_UNSUBSCRIBED;
+ iter = iter->next;
+ }
+
+ NSResult ret = NSConsumerUpdateTopicList(g_provider->providerId, g_topicLL);
+ if (ret != NS_OK)
+ {
+ printf("Cancel select topic fail\n");
+ }
+ break;
+ case 0:
+ printf("0. Exit");
+ isExit = true;
+ break;
+#if WITH_MQ
+ case 11:
+ printf("11. Subscribe MQ Service\n");
+
+ printf("Remote Server Address: ");
+ input(CLOUD_ADDRESS);
+
+ printf("Topic[notification]: ");
+ input(CLOUD_TOPIC);
+
+ NSConsumerSubscribeMQService(CLOUD_ADDRESS, CLOUD_TOPIC);
+ break;
+#endif
+#ifdef WITH_CLOUD
+ case 21:
+ printf("Enable Remote Service");
+ if(!IsCloudLoggedin())
+ {
+ printf("Cloud Login required");
+ break;
+ }
+ NSConsumerEnableRemoteService(CLOUD_ADDRESS);
+ break;
+ case 31:
+ printf("Remote Server Address: ");
+ input(CLOUD_ADDRESS);
+
+ printf("Auth Provider(eg. github): ");
+ input(CLOUD_AUTH_PROVIDER);
+
+ printf("Auth Code: ");
+ input(CLOUD_AUTH_CODE);
+
+ OCCloudSignup(CLOUD_ADDRESS, OCGetServerInstanceIDString(),
+ CLOUD_AUTH_PROVIDER, CLOUD_AUTH_CODE, CloudSignupCallback);
+ printf("OCCloudSignup requested");
+ break;
+ case 32:
+ printf("Remote Server Address: ");
+ input(CLOUD_ADDRESS);
+
+ printf("UID: ");
+ input(CLOUD_UID);
+
+ printf("ACCESS_TOKEN: ");
+ input(CLOUD_ACCESS_TOKEN);
+
+ OCCloudLogin(CLOUD_ADDRESS, CLOUD_UID, OCGetServerInstanceIDString(),
+ CLOUD_ACCESS_TOKEN, CloudLoginoutCallback);
+ printf("OCCloudLogin requested");
+ break;
+ case 33:
+ OCCloudLogout(CLOUD_ADDRESS, CloudLoginoutCallback);
+ printf("OCCloudLogin requested");
+ break;
+#endif
+ default:
+ break;
+ }
+ }
return 0;
}
+
projects / platform / upstream / iotivity.git / blobdiff