2 #include "occloudprovisioning.h"
3 #include "oic_malloc.h"
4 #include "oic_string.h"
5 #include "srmutility.h"
6 #include "aclresource.h"
11 #define TAG "CLOUD-WRAPPER"
13 #define MAX_ID_LENGTH (64)
14 #define MAX_STRING_LENGTH (256)
16 #define UUID_EXAMPLE_1 "9cfbeb8e-5a1e-4d1c-9d01-2ae6fdb"
17 #define UUID_EXAMPLE_2 "123e4567-e89b-12d3-a456-4266554"
18 #define UUID_EXAMPLE_3 "987e6543-e21b-12d3-a456-4266554"
19 #define SUBJECT_ID_EXAMPLE "72616E64-5069-6E44-6576-557569643030"
21 #define ACL_ID_EXAMPLE "0f3d9f7fe5491d54077d"
22 #define ACE_ID_EXAMPLE "a0001"
24 #define ID_EXAMPLE_1 "78f98b4f25f21e2487e8"
25 #define ID_EXAMPLE_2 "6caa7009386290fd3681"
27 #define RESOURCE_URI_EXAMPLE "/a/light/0"
28 #define RESOURCE_TYPE_EXAMPLE "core.light"
29 #define INTERFACE_EXAMPLE "oic.if.baseline"
31 //in case of optional parameters absence should be sent NULL
32 #define OPTIONAL(str) (str[0] ? str : NULL)
35 * Skip special characters from stdin
37 static void skipSpecialCharacters()
39 for( ; 0x20<=getchar(); ); // for removing overflow garbages
40 // '0x20<=code' is character region
43 static bool readOptional(const char* description)
45 if (NULL == description)
50 printf("Do you want to Enter %s (y/n):\n", description);
56 skipSpecialCharacters();
60 case 'y': return true;
61 case 'n': return false;
62 default: printf("Wrong value entered. Please press 'y' or 'n'\n");
68 void readString(char* item, int length, const char* description, const char* example)
70 printf("Enter %s (f.e. %s):\n", description, example);
71 char template[8] = { 0 };
72 snprintf(template, sizeof(template), "%%%ds", length - 1);
73 scanf(template, item);
74 skipSpecialCharacters();
78 * Read user input (expect string value, but it is optional and can be skipped by user)
80 * @param[out] item string item to fill
81 * @param[in] length max allowed string length
82 * @param[in] description item description
83 * @param[in] example item example
85 static void readOptionalString(char* item, int length, const char* description, const char* example)
87 if (readOptional(description))
89 readString(item, length, description, example);
93 void readInteger(int* item, const char* description, const char* example)
95 printf("Enter %s (f.e. %s):\n", description, example);
97 skipSpecialCharacters();
101 * Read user input (expect array of strings)
103 * @param[out] list array of strings structure
104 * @param[in] length max allowed array item length
105 * @param[in] description whole array description
106 * @param[in] example array item example
108 static void readStringArray(stringArray_t *list, int length, const char* description, const char* example)
112 char hint[MAX_STRING_LENGTH] = { 0 };
114 snprintf(hint, sizeof(hint), "%s items count", description);
115 readInteger(&count, hint, "2");
124 item = OICCalloc(count, sizeof(char*));
131 for (i = 0; i < count; i++)
133 item[i] = OICCalloc(length, sizeof(char));
140 snprintf(hint, sizeof(hint), "%s %d item", description, i + 1);
141 readString(item[i], length, hint, example);
144 list->length = count;
148 //free already allocated memory here
149 for (int k = 0; k < i; k++)
157 * Read user input (expect array of strings)
158 * It is optional and can be skipped by user.
160 * @param[out] list array of strings structure
161 * @param[in] length max allowed array item length
162 * @param[in] description whole array description
163 * @param[in] example array item example
165 static void readOptionalStringArray(stringArray_t *list, int length, const char* description, const char* example)
167 if (readOptional(description))
169 readStringArray(list, length, description, example);
173 void printStringArray(stringArray_t *list)
177 OIC_LOG(INFO, TAG, "Received NULL list");
181 OIC_LOG_V(INFO, TAG, "List contains %zu items", list->length);
183 for (size_t i = 0; i < list->length; i++)
185 OIC_LOG_V(INFO, TAG, "item[%zu] = %s", i, list->array[i]);
189 void printInviteResponse(inviteResponse_t *in)
193 OIC_LOG(INFO, TAG, "Received NULL invitation response");
197 OIC_LOG(INFO, TAG, "Received next invite gid list:");
198 printStringArray(&in->invite.gidlist);
200 OIC_LOG(INFO, TAG, "Received next invite mid list:");
201 printStringArray(&in->invite.midlist);
203 OIC_LOG(INFO, TAG, "Received next invited gid list:");
204 printStringArray(&in->invited.gidlist);
206 OIC_LOG(INFO, TAG, "Received next invited mid list:");
207 printStringArray(&in->invited.midlist);
210 void clearInviteResponse(inviteResponse_t *in)
217 clearStringArray(&in->invite.gidlist);
218 clearStringArray(&in->invite.midlist);
220 clearStringArray(&in->invited.gidlist);
221 clearStringArray(&in->invited.midlist);
224 bool readFile(const char *name, OCByteString *out)
228 uint8_t *buffer = NULL;
232 file = fopen(name, "rb");
235 OIC_LOG_V(ERROR, TAG, "Unable to open file %s", name);
240 if (fseek(file, 0, SEEK_END))
242 OIC_LOG(ERROR, TAG, "Failed to SEEK_END");
246 length = ftell(file);
249 OIC_LOG(ERROR, TAG, "Failed to ftell");
253 if (fseek(file, 0, SEEK_SET))
255 OIC_LOG(ERROR, TAG, "Failed to SEEK_SET");
260 buffer = (uint8_t *)malloc(length);
263 OIC_LOG(ERROR, TAG, "Failed to allocate buffer");
267 //Read file contents into buffer
269 size_t realCount = fread(buffer, length, count, file);
270 if (realCount != count)
272 OIC_LOG_V(ERROR, TAG, "Read %d bytes %zu times instead of %zu", length, realCount, count);
286 * Frees particular cloudAce object
288 * @param[in] ace ace object to free
290 static void freeCloudAce(cloudAce_t *ace)
295 OicSecRsrc_t* rsrc = NULL;
296 OicSecRsrc_t* tmpRsrc = NULL;
297 LL_FOREACH_SAFE(ace->resources, rsrc, tmpRsrc)
299 LL_DELETE(ace->resources, rsrc);
307 * Deletes cloudAce list
309 * @param[in] ace aces list to delete
311 static void deleteCloudAceList(cloudAce_t *aces)
313 cloudAce_t *ace = NULL;
314 cloudAce_t *tmpAce = NULL;
315 LL_FOREACH_SAFE(aces, ace, tmpAce)
317 LL_DELETE(aces, ace);
322 OCStackResult OCWrapperCertificateIssueRequest(const OCDevAddr *endPoint, OCCloudResponseCB callback)
324 return OCCloudCertificateIssueRequest(NULL, endPoint, callback);
327 OCStackResult OCWrapperGetCRL(const OCDevAddr *endPoint, OCCloudResponseCB callback)
329 return OCCloudGetCRL(NULL, endPoint, callback);
332 OCStackResult OCWrapperPostCRL(const OCDevAddr *endPoint, OCCloudResponseCB callback)
334 OCStackResult result = OC_STACK_ERROR;
335 OCByteString crlData = {0, 0};
336 char filename[64] = {0};
337 char thisUpdate[16] = { 0 };
338 char nextUpdate[16] = { 0 };
339 stringArray_t serialNumbers = {0, 0};
341 readString(thisUpdate, sizeof(thisUpdate), "Crl's thisUpdate value", "20160727000000");
342 readString(nextUpdate, sizeof(nextUpdate), "Crl's nextUpdate value", "20161027000000");
343 readOptionalStringArray(&serialNumbers, 16, "Revoked serial numbers", "1234");
345 if (NULL == serialNumbers.array)
347 readString(filename, sizeof(filename),
348 "filename from which binary Crl in DER format will be read", "crl");
350 if (!readFile(filename, &crlData))
352 printf("Can't read crl from file %s\n", filename);
356 stringArray_t *rcsn = serialNumbers.array? &serialNumbers : NULL;
357 OCByteString *crl = crlData.bytes? &crlData : NULL;
359 result = OCCloudPostCRL(NULL, thisUpdate, nextUpdate, crl, rcsn,
362 clearStringArray(&serialNumbers);
363 OICFree(crlData.bytes);
368 OCStackResult OCWrapperAclIdGetByDevice(const OCDevAddr *endPoint, OCCloudResponseCB callback)
370 char di[MAX_ID_LENGTH] = { 0 };
372 readString(di, sizeof(di), "device id", UUID_EXAMPLE_1);
374 return OCCloudGetAclIdByDevice(NULL, di, endPoint, callback);
377 OCStackResult OCWrapperAclIdCreate(const OCDevAddr *endPoint, OCCloudResponseCB callback)
379 char oid[MAX_ID_LENGTH] = { 0 };
380 char di[MAX_ID_LENGTH] = { 0 };
382 readString(oid, sizeof(oid), "owner id", UUID_EXAMPLE_2);
383 readString(di, sizeof(di), "device id", UUID_EXAMPLE_1);
385 return OCCloudAclIdCreate(NULL, oid, di, endPoint, callback);
388 OCStackResult OCWrapperAclIdDelete(const OCDevAddr *endPoint, OCCloudResponseCB callback)
390 char aclid[MAX_ID_LENGTH] = { 0 };
392 readString(aclid, sizeof(aclid), "acl id", ACL_ID_EXAMPLE);
394 return OCCloudAclIdDelete(NULL, aclid, endPoint, callback);
397 OCStackResult OCWrapperAclIndividualGetInfo(const OCDevAddr *endPoint, OCCloudResponseCB callback)
399 char aclid[MAX_ID_LENGTH] = { 0 };
401 readString(aclid, sizeof(aclid), "acl id", ACL_ID_EXAMPLE);
403 return OCCloudAclIndividualGetInfo(NULL, aclid, endPoint, callback);
406 OCStackResult OCWrapperAclIndividualUpdateAce(const OCDevAddr *endPoint, OCCloudResponseCB callback)
408 OCStackResult result = OC_STACK_NO_MEMORY;
410 char aclid[MAX_ID_LENGTH] = { 0 };
411 readString(aclid, sizeof(aclid), "acl id", ACL_ID_EXAMPLE);
413 int acllist_count = 0;
414 readInteger(&acllist_count, "acl list count", "1");
416 cloudAce_t *aces = NULL;
418 for (int i = 0; i < acllist_count; i++)
420 cloudAce_t *ace = OICCalloc(1, sizeof(cloudAce_t));
423 OIC_LOG(ERROR, TAG, "Can't allocate memory for ace");
426 LL_APPEND(aces, ace);
428 char aceid[MAX_ID_LENGTH] = { 0 };
429 char subjectuuid[MAX_ID_LENGTH] = { 0 };
433 readString(aceid, sizeof(aceid), "ace id", ACE_ID_EXAMPLE);
436 readString(subjectuuid, sizeof(subjectuuid), "subjectuuid", SUBJECT_ID_EXAMPLE);
437 } while (OC_STACK_OK != ConvertStrToUuid(subjectuuid, &ace->subjectuuid));
439 readInteger(&stype, "subject type", "0 – Device, 1 – User, 2 - Group");
440 readInteger(&permission, "permission", "6");
442 ace->aceId = OICStrdup(aceid);
444 ace->permission = permission;
446 int reslist_count = 0;
447 readInteger(&reslist_count, "resources list count", "1");
449 for (int i = 0; i < reslist_count; i++)
451 OicSecRsrc_t *res = OICCalloc(1, sizeof(OicSecRsrc_t));
454 OIC_LOG(ERROR, TAG, "Can't allocate memory for res");
457 LL_APPEND(ace->resources, res);
459 char href[32] = { 0 };
460 readString(href, sizeof(href), "href", RESOURCE_URI_EXAMPLE);
462 stringArray_t rt = {0, 0};
463 readStringArray(&rt, MAX_ID_LENGTH, "resource type", RESOURCE_TYPE_EXAMPLE);
465 stringArray_t _if = {0, 0};
466 readStringArray(&_if, MAX_ID_LENGTH, "interface", INTERFACE_EXAMPLE);
468 res->href = OICStrdup(href);
469 res->types = rt.array;
470 res->typeLen = rt.length;
471 res->interfaces = _if.array;
472 res->interfaceLen = _if.length;
476 result = OCCloudAclIndividualUpdateAce(NULL, aclid, aces, endPoint, callback);
478 deleteCloudAceList(aces);
482 OCStackResult OCWrapperAclIndividualDelete(const OCDevAddr *endPoint, OCCloudResponseCB callback)
484 char aclid[MAX_ID_LENGTH] = { 0 };
486 readString(aclid, sizeof(aclid), "acl id", ACL_ID_EXAMPLE);
488 return OCCloudAclIndividualDelete(NULL, aclid, endPoint, callback);
491 OCStackResult OCWrapperAclCreateGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
493 char gtype[16] = { 0 };
494 char gmid[MAX_ID_LENGTH] = { 0 };
496 readString(gtype, sizeof(gtype), "Group type value", "Public");
497 readOptionalString(gmid, sizeof(gmid), "group member id value", UUID_EXAMPLE_2);
499 return OCCloudAclCreateGroup(NULL, gtype, OPTIONAL(gmid), endPoint, callback);
502 OCStackResult OCWrapperAclFindMyGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
504 char mid[MAX_ID_LENGTH] = { 0 };
506 readOptionalString(mid, sizeof(mid), "member id value", UUID_EXAMPLE_2);
508 return OCCloudAclFindMyGroup(NULL, OPTIONAL(mid), endPoint, callback);
511 OCStackResult OCWrapperAclDeleteGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
513 char gid[MAX_ID_LENGTH] = { 0 };
514 char gmid[MAX_ID_LENGTH] = { 0 };
516 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
518 readOptionalString(gmid, sizeof(gmid), "group member id value", UUID_EXAMPLE_2);
520 return OCCloudAclDeleteGroup(NULL, gid, OPTIONAL(gmid), endPoint, callback);
523 OCStackResult OCWrapperAclJoinToInvitedGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
525 char gid[MAX_ID_LENGTH] = { 0 };
527 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
529 return OCCloudAclJoinToInvitedGroup(NULL, gid, endPoint, callback);
532 OCStackResult OCWrapperAclObserveGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
534 char gid[MAX_ID_LENGTH] = { 0 };
536 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
538 return OCCloudAclObserveGroup(NULL, gid, endPoint, callback);
541 OCStackResult OCWrapperAclShareDeviceIntoGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
543 OCStackResult result = OC_STACK_NO_MEMORY;
544 char gid[MAX_ID_LENGTH] = { 0 };
545 stringArray_t midlist = {0,0};
546 stringArray_t dilist = {0,0};
548 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
550 readStringArray(&midlist, MAX_ID_LENGTH, "member id list", UUID_EXAMPLE_2);
552 readStringArray(&dilist, MAX_ID_LENGTH, "device list", UUID_EXAMPLE_1);
554 result = OCCloudAclShareDeviceIntoGroup(NULL, gid, &midlist, &dilist, endPoint, callback);
556 clearStringArray(&midlist);
557 clearStringArray(&dilist);
562 OCStackResult OCWrapperAclDeleteDeviceFromGroup(const OCDevAddr *endPoint, OCCloudResponseCB callback)
564 OCStackResult result = OC_STACK_NO_MEMORY;
565 char gid[MAX_ID_LENGTH] = { 0 };
566 stringArray_t midlist = {0,0};
567 stringArray_t dilist = {0,0};
569 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
571 readStringArray(&midlist, MAX_ID_LENGTH, "member id list", UUID_EXAMPLE_2);
573 readStringArray(&dilist, MAX_ID_LENGTH, "device list", UUID_EXAMPLE_1);
575 result = OCCloudAclDeleteDeviceFromGroup(NULL, gid, &midlist, &dilist, endPoint, callback);
577 clearStringArray(&midlist);
578 clearStringArray(&dilist);
583 OCStackResult OCWrapperAclGroupGetInfo(const OCDevAddr *endPoint, OCCloudResponseCB callback)
585 char gid[MAX_ID_LENGTH] = { 0 };
586 char mid[MAX_ID_LENGTH] = { 0 };
588 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
590 readOptionalString(mid, sizeof(mid), "member id value", UUID_EXAMPLE_2);
592 return OCCloudAclGroupGetInfo(NULL, gid, OPTIONAL(mid), endPoint, callback);
595 OCStackResult OCWrapperAclInviteUser(const OCDevAddr *endPoint, OCCloudResponseCB callback)
597 OCStackResult result = OC_STACK_NO_MEMORY;
598 char uid[MAX_ID_LENGTH] = { 0 };
599 stringArray_t midlist = {0,0};
600 stringArray_t gidlist = {0,0};
602 readOptionalString(uid, sizeof(uid), "user id value", UUID_EXAMPLE_2);
604 readStringArray(&gidlist, MAX_ID_LENGTH, "group id list", UUID_EXAMPLE_1);
606 readStringArray(&midlist, MAX_ID_LENGTH, "member id list", UUID_EXAMPLE_2);
608 result = OCCloudAclInviteUser(NULL, OPTIONAL(uid), &gidlist, &midlist, endPoint, callback);
610 clearStringArray(&midlist);
611 clearStringArray(&gidlist);
616 OCStackResult OCWrapperAclGetInvitation(const OCDevAddr *endPoint, OCCloudResponseCB callback)
618 char uid[MAX_ID_LENGTH] = { 0 };
620 readOptionalString(uid, sizeof(uid), "user uuid value", UUID_EXAMPLE_2);
622 return OCCloudAclGetInvitation(NULL, OPTIONAL(uid), endPoint, callback);
625 OCStackResult OCWrapperAclDeleteInvitation(const OCDevAddr *endPoint, OCCloudResponseCB callback)
627 char uid[MAX_ID_LENGTH] = { 0 };
628 char gid[MAX_ID_LENGTH] = { 0 };
630 readOptionalString(uid, sizeof(uid), "user uuid value", UUID_EXAMPLE_2);
631 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
633 return OCCloudAclDeleteInvitation(NULL, OPTIONAL(uid), gid, endPoint, callback);
636 OCStackResult OCWrapperAclCancelInvitation(const OCDevAddr *endPoint, OCCloudResponseCB callback)
638 char uid[MAX_ID_LENGTH] = { 0 };
639 char gid[MAX_ID_LENGTH] = { 0 };
640 char mid[MAX_ID_LENGTH] = { 0 };
642 readOptionalString(uid, sizeof(uid), "user uuid value", UUID_EXAMPLE_2);
644 readString(gid, sizeof(gid), "Group id value", ID_EXAMPLE_1);
645 readString(mid, sizeof(mid), "member id value", ID_EXAMPLE_1);
647 return OCCloudAclCancelInvitation(NULL, OPTIONAL(uid), gid, mid, endPoint, callback);
650 OCStackResult OCWrapperAclPolicyCheck(const OCDevAddr *endPoint, OCCloudResponseCB callback)
652 char sid[MAX_ID_LENGTH] = { 0 };
653 char di[MAX_ID_LENGTH] = { 0 };
655 char user_uri[32] = { 0 };
657 readString(sid, sizeof(sid), "subject id", UUID_EXAMPLE_1);
658 readString(di, sizeof(di), "device id", UUID_EXAMPLE_2);
659 readString(rm, sizeof(rm), "request method", "GET or POST or DELETE");
660 readString(user_uri, sizeof(user_uri), "request uri", RESOURCE_URI_EXAMPLE);
662 return OCCloudAclPolicyCheck(NULL, sid, di, rm, user_uri, endPoint, callback);