Skip to content
GitLab
Projects
Groups
Snippets
Help
Loading...
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
I
iotivity-classic
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
3,289
Issues
3,289
List
Boards
Labels
Service Desk
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Incidents
Environments
Packages & Registries
Packages & Registries
Container Registry
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
IoTivity
iotivity-classic
Commits
2b44971c
Commit
2b44971c
authored
May 26, 2017
by
Philippe Coval
Committed by
Gerrit Code Review
May 26, 2017
Browse files
Options
Browse Files
Download
Plain Diff
Merge "Merge branch '1.3-rel' (
c22b1d43
)"
parents
ffad5c66
4ac85a74
Changes
40
Expand all
Show whitespace changes
Inline
Side-by-side
Showing
40 changed files
with
752 additions
and
850 deletions
+752
-850
cloud/account/src/main/java/org/iotivity/cloud/accountserver/db/MongoDB.java
...ain/java/org/iotivity/cloud/accountserver/db/MongoDB.java
+0
-14
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/AccountResourceTest.java
.../accountserver/resources/account/AccountResourceTest.java
+2
-2
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/session/SessionResourceTest.java
...server/resources/account/session/SessionResourceTest.java
+2
-2
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/tokenrefresh/TokenRefreshResourceTest.java
...ources/account/tokenrefresh/TokenRefreshResourceTest.java
+1
-1
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupAclManagerTest.java
...ccountserver/resources/acl/group/GroupAclManagerTest.java
+1
-1
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupBrokerTest.java
...ud/accountserver/resources/acl/group/GroupBrokerTest.java
+2
-2
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupResourceTest.java
.../accountserver/resources/acl/group/GroupResourceTest.java
+2
-2
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/id/AclIdResourceTest.java
...oud/accountserver/resources/acl/id/AclIdResourceTest.java
+66
-42
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/invite/InviteResourceTest.java
...ccountserver/resources/acl/invite/InviteResourceTest.java
+1
-1
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/verify/AclVerifyResourceTest.java
...untserver/resources/acl/verify/AclVerifyResourceTest.java
+56
-38
java/jni/JniOcAccountManager.cpp
java/jni/JniOcAccountManager.cpp
+1
-1
resource/IPCA/src/ocfframework.cpp
resource/IPCA/src/ocfframework.cpp
+2
-2
resource/c_common/oic_platform/src/others/oic_otherplatforms.c
...rce/c_common/oic_platform/src/others/oic_otherplatforms.c
+2
-2
resource/c_common/oic_platform/src/windows/oic_winplatform.cpp
...rce/c_common/oic_platform/src/windows/oic_winplatform.cpp
+6
-3
resource/csdk/connectivity/src/bt_edr_adapter/android/caedrutils.c
...csdk/connectivity/src/bt_edr_adapter/android/caedrutils.c
+2
-3
resource/csdk/connectivity/src/cablockwisetransfer.c
resource/csdk/connectivity/src/cablockwisetransfer.c
+1
-0
resource/csdk/connectivity/src/ip_adapter/caipserver.c
resource/csdk/connectivity/src/ip_adapter/caipserver.c
+7
-1
resource/csdk/connectivity/src/tcp_adapter/catcpserver.c
resource/csdk/connectivity/src/tcp_adapter/catcpserver.c
+1
-1
resource/csdk/connectivity/test/ssladapter_test.cpp
resource/csdk/connectivity/test/ssladapter_test.cpp
+67
-299
resource/csdk/resource-directory/src/rd_client.c
resource/csdk/resource-directory/src/rd_client.c
+9
-7
resource/csdk/security/provisioning/include/internal/secureresourceprovider.h
...ty/provisioning/include/internal/secureresourceprovider.h
+16
-0
resource/csdk/security/provisioning/src/ocprovisioningmanager.c
...ce/csdk/security/provisioning/src/ocprovisioningmanager.c
+4
-4
resource/csdk/security/provisioning/src/secureresourceprovider.c
...e/csdk/security/provisioning/src/secureresourceprovider.c
+371
-50
resource/csdk/stack/samples/linux/secure/oic_amss_db.dat
resource/csdk/stack/samples/linux/secure/oic_amss_db.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_amss_db.json
resource/csdk/stack/samples/linux/secure/oic_amss_db.json
+10
-48
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_devowner.dat
...stack/samples/linux/secure/oic_svr_db_client_devowner.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_devowner.json
...tack/samples/linux/secure/oic_svr_db_client_devowner.json
+10
-48
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_directpairing.dat
.../samples/linux/secure/oic_svr_db_client_directpairing.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_directpairing.json
...samples/linux/secure/oic_svr_db_client_directpairing.json
+15
-58
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_nondevowner.dat
...ck/samples/linux/secure/oic_svr_db_client_nondevowner.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_svr_db_client_nondevowner.json
...k/samples/linux/secure/oic_svr_db_client_nondevowner.json
+10
-48
resource/csdk/stack/samples/linux/secure/oic_svr_db_server.dat
...rce/csdk/stack/samples/linux/secure/oic_svr_db_server.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_svr_db_server.json
...ce/csdk/stack/samples/linux/secure/oic_svr_db_server.json
+16
-71
resource/csdk/stack/samples/linux/secure/oic_svr_db_server_justworks.dat
...tack/samples/linux/secure/oic_svr_db_server_justworks.dat
+0
-0
resource/csdk/stack/samples/linux/secure/oic_svr_db_server_justworks.json
...ack/samples/linux/secure/oic_svr_db_server_justworks.json
+16
-89
resource/csdk/stack/src/ocstack.c
resource/csdk/stack/src/ocstack.c
+10
-4
resource/provisioning/examples/oic_svr_db_client.dat
resource/provisioning/examples/oic_svr_db_client.dat
+0
-0
resource/provisioning/examples/oic_svr_db_client.json
resource/provisioning/examples/oic_svr_db_client.json
+32
-0
resource/src/InProcServerWrapper.cpp
resource/src/InProcServerWrapper.cpp
+5
-6
resource/src/OCResource.cpp
resource/src/OCResource.cpp
+6
-0
No files found.
cloud/account/src/main/java/org/iotivity/cloud/accountserver/db/MongoDB.java
View file @
2b44971c
...
...
@@ -21,7 +21,6 @@
*/
package
org.iotivity.cloud.accountserver.db
;
import
java.net.InetAddress
;
import
java.util.ArrayList
;
import
java.util.HashMap
;
import
java.util.Iterator
;
...
...
@@ -50,19 +49,6 @@ public class MongoDB {
private
MongoClient
mongoClient
=
null
;
private
MongoDatabase
db
=
null
;
/**
* API creating MongoClient and initializing MongoDatabase
*
* @param dbname
* database name to create MongoDatabase
* @throws Exception
*/
public
MongoDB
(
String
dbname
)
throws
Exception
{
mongoClient
=
new
MongoClient
(
InetAddress
.
getLocalHost
().
getHostAddress
());
mongoClient
.
dropDatabase
(
dbname
);
db
=
mongoClient
.
getDatabase
(
dbname
);
}
/**
* API creating MongoClient and initializing MongoDatabase
*
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/AccountResourceTest.java
View file @
2b44971c
...
...
@@ -66,7 +66,7 @@ public class AccountResourceTest {
private
static
final
String
REGISTER_URI
=
Constants
.
ACCOUNT_FULL_URI
;
private
static
final
String
GROUP_URI
=
Constants
.
GROUP_FULL_URI
;
private
static
final
String
DEVICE_ID
=
"DEVICE"
;
private
String
mAuthProvider
=
"
G
ithub"
;
private
String
mAuthProvider
=
"
g
ithub"
;
private
String
mAuthCode
=
"3af038b49edc4ebdc45c"
;
private
CoapDevice
mMockDevice
=
mock
(
CoapDevice
.
class
);
...
...
@@ -112,7 +112,7 @@ public class AccountResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/session/SessionResourceTest.java
View file @
2b44971c
...
...
@@ -106,7 +106,7 @@ public class SessionResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
...
...
@@ -362,7 +362,7 @@ public class SessionResourceTest {
}
private
void
resetDB
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
USER_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/account/tokenrefresh/TokenRefreshResourceTest.java
View file @
2b44971c
...
...
@@ -64,7 +64,7 @@ public class TokenRefreshResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupAclManagerTest.java
View file @
2b44971c
...
...
@@ -83,7 +83,7 @@ public class GroupAclManagerTest {
AclResource
.
getInstance
().
deleteAcl
((
String
)
AclResource
.
getInstance
()
.
getAclid
(
mDi2
).
get
(
Constants
.
KEYFIELD_ACLID
));
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
ACL_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupBrokerTest.java
View file @
2b44971c
...
...
@@ -78,7 +78,7 @@ public class GroupBrokerTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
...
...
@@ -189,7 +189,7 @@ public class GroupBrokerTest {
}
private
void
resetDB
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
USER_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/group/GroupResourceTest.java
View file @
2b44971c
...
...
@@ -108,7 +108,7 @@ public class GroupResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
TOKEN_TABLE
);
...
...
@@ -824,7 +824,7 @@ public class GroupResourceTest {
}
public
void
resetDB
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
USER_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/id/AclIdResourceTest.java
View file @
2b44971c
...
...
@@ -54,7 +54,8 @@ import org.mockito.stubbing.Answer;
public
class
AclIdResourceTest
{
private
static
final
String
ACL_ID_URI
=
Constants
.
ACL_ID_FULL_URI
;
final
CountDownLatch
mLatch
=
new
CountDownLatch
(
1
);
final
CountDownLatch
mLatch
=
new
CountDownLatch
(
1
);
private
final
String
mDeviceUuid
=
"9cfbeb8e-5a1e-4d1c-9d01-2ae6fdb"
;
private
final
String
mOwnerUuid
=
"123e4567-e89b-12d3-a456-4266554"
;
private
final
String
mSubjectUuid
=
"72616E64-5069-6E44-6576-5575696"
;
...
...
@@ -67,7 +68,8 @@ public class AclIdResourceTest {
private
final
String
mResourceIf
=
"oic.if.baseline"
;
private
String
mAceId
=
"a0001"
;
private
String
mAclId
=
"987e6543-e21b-12d3-a456-4266554"
;
private
CoapDevice
mMockDevice
=
Mockito
.
mock
(
CoapDevice
.
class
);
private
CoapDevice
mMockDevice
=
Mockito
.
mock
(
CoapDevice
.
class
);
private
Cbor
<
HashMap
<
String
,
Object
>>
mCbor
=
new
Cbor
<>();
private
IResponse
mResponse
=
null
;
private
AclResource
mAclResource
=
new
AclResource
();
...
...
@@ -79,14 +81,18 @@ public class AclIdResourceTest {
resetDB
();
Mockito
.
doAnswer
(
new
Answer
<
Object
>()
{
@Override
public
CoapResponse
answer
(
InvocationOnMock
invocation
)
throws
Throwable
{
public
CoapResponse
answer
(
InvocationOnMock
invocation
)
throws
Throwable
{
Object
[]
args
=
invocation
.
getArguments
();
CoapResponse
resp
=
(
CoapResponse
)
args
[
0
];
System
.
out
.
println
(
"\t----------payload : "
+
resp
.
getPayloadString
());
System
.
out
.
println
(
"\t----------payload : "
+
resp
.
getPayloadString
());
System
.
out
.
println
(
"\t---------method : "
+
resp
.
getStatus
());
mResponse
=
resp
;
if
(
mAclId
==
null
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
resp
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
resp
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
"aclid"
))
{
mAclId
=
(
String
)
payloadData
.
get
(
"aclid"
);
}
...
...
@@ -99,7 +105,7 @@ public class AclIdResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
ACL_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
...
...
@@ -184,7 +190,8 @@ public class AclIdResourceTest {
assertTrue
(
mLatch
.
await
(
2L
,
SECONDS
));
}
private
void
createAclId
(
CoapDevice
device
,
String
di
,
String
oid
)
throws
Exception
{
private
void
createAclId
(
CoapDevice
device
,
String
di
,
String
oid
)
throws
Exception
{
System
.
out
.
println
(
"-----Create Acl Id"
);
IRequest
request
=
null
;
request
=
createAclIdRequest
(
oid
,
di
);
...
...
@@ -212,21 +219,24 @@ public class AclIdResourceTest {
mAclResource
.
onDefaultRequestReceived
(
device
,
request
);
}
private
void
addIndividualAce
(
CoapDevice
device
,
String
aclId
)
throws
Exception
{
private
void
addIndividualAce
(
CoapDevice
device
,
String
aclId
)
throws
Exception
{
System
.
out
.
println
(
"-----Add Individual Ace"
);
IRequest
request
=
null
;
request
=
addIndividualAceRequest
(
aclId
);
mAclResource
.
onDefaultRequestReceived
(
device
,
request
);
}
private
void
updateIndividualAce
(
CoapDevice
device
,
String
aclId
,
String
aceId
)
throws
Exception
{
private
void
updateIndividualAce
(
CoapDevice
device
,
String
aclId
,
String
aceId
)
throws
Exception
{
System
.
out
.
println
(
"-----Update Individual Acl Ace"
);
IRequest
request
=
null
;
request
=
updateIndividualAceRequest
(
aclId
,
aceId
);
mAclResource
.
onDefaultRequestReceived
(
device
,
request
);
}
private
void
deleteIndividualAclAce
(
CoapDevice
device
,
String
aclId
,
String
aceId
)
throws
Exception
{
private
void
deleteIndividualAclAce
(
CoapDevice
device
,
String
aclId
,
String
aceId
)
throws
Exception
{
System
.
out
.
println
(
"-----Delete Individual Acl Ace"
);
IRequest
request
=
null
;
request
=
deleteIndividualAclAceRequest
(
aclId
,
aceId
);
...
...
@@ -235,27 +245,32 @@ public class AclIdResourceTest {
private
IRequest
getAclIdRequest
(
String
deviceUuid
)
{
IRequest
request
=
null
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_ID_URI
,
"di="
+
deviceUuid
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_ID_URI
,
"di="
+
deviceUuid
);
((
CoapRequest
)
request
).
setObserve
(
Observe
.
SUBSCRIBE
);
return
request
;
}
private
IRequest
createAclIdRequest
(
String
oid
,
String
di
)
{
IRequest
request
=
null
;
String
uriQuery
=
Constants
.
REQ_OWNER_ID
+
"="
+
oid
+
";"
+
Constants
.
REQ_DEVICE_ID
+
"="
+
di
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
PUT
,
ACL_ID_URI
,
uriQuery
);
String
uriQuery
=
Constants
.
REQ_OWNER_ID
+
"="
+
oid
+
";"
+
Constants
.
REQ_DEVICE_ID
+
"="
+
di
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
PUT
,
ACL_ID_URI
,
uriQuery
);
return
request
;
}
private
IRequest
deleteAclIdRequest
(
String
aclId
)
{
IRequest
request
=
null
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
DELETE
,
ACL_ID_URI
,
"aclid="
+
aclId
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
DELETE
,
ACL_ID_URI
,
"aclid="
+
aclId
);
return
request
;
}
private
IRequest
getIndividualAclRequest
(
String
aclId
)
{
IRequest
request
=
null
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_ID_URI
+
"/"
+
aclId
,
null
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_ID_URI
+
"/"
+
aclId
,
null
);
((
CoapRequest
)
request
).
setObserve
(
Observe
.
NOTHING
);
return
request
;
}
...
...
@@ -283,8 +298,9 @@ public class AclIdResourceTest {
HashMap
<
String
,
Object
>
payload
=
new
HashMap
<>();
payload
.
put
(
Constants
.
REQ_ACL_LIST
,
Arrays
.
asList
(
acelist
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
null
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
null
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
}
private
IRequest
updateIndividualAceRequest
(
String
aclId
,
String
aceId
)
{
...
...
@@ -310,18 +326,22 @@ public class AclIdResourceTest {
HashMap
<
String
,
Object
>
payload
=
new
HashMap
<>();
payload
.
put
(
Constants
.
REQ_ACL_LIST
,
Arrays
.
asList
(
acelist
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
"aceid="
+
aceId
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
"aceid="
+
aceId
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
}
private
IRequest
deleteIndividualAclAceRequest
(
String
aclId
,
String
aceId
)
{
IRequest
request
=
null
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
DELETE
,
ACL_ID_URI
+
"/"
+
aclId
,
"aceid="
+
aceId
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
DELETE
,
ACL_ID_URI
+
"/"
+
aclId
,
"aceid="
+
aceId
);
return
request
;
}
private
void
hashmapGetAclId
(
IResponse
response
,
String
propertyName
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
propertyName
))
{
mAclId
=
(
String
)
payloadData
.
get
(
propertyName
);
...
...
@@ -330,16 +350,19 @@ public class AclIdResourceTest {
}
private
void
hashmapGetAceId
(
IResponse
response
,
String
propertyName
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
"aclist"
))
{
List
<
HashMap
<
String
,
Object
>>
aclist
=
(
List
<
HashMap
<
String
,
Object
>>)
payloadData
.
get
(
"aclist"
);
List
<
HashMap
<
String
,
Object
>>
aclist
=
(
List
<
HashMap
<
String
,
Object
>>)
payloadData
.
get
(
"aclist"
);
mAceId
=
(
String
)
aclist
.
get
(
0
).
get
(
propertyName
);
System
.
out
.
println
(
"hashmapGetAceId getace "
+
mAceId
);
}
}
private
boolean
hashmapCheck
(
IResponse
response
,
String
propertyName
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
propertyName
))
{
return
true
;
}
else
{
...
...
@@ -347,7 +370,8 @@ public class AclIdResourceTest {
}
}
private
boolean
methodCheck
(
IResponse
response
,
ResponseStatus
responseStatus
)
{
private
boolean
methodCheck
(
IResponse
response
,
ResponseStatus
responseStatus
)
{
if
(
responseStatus
==
response
.
getStatus
())
{
return
true
;
}
else
{
...
...
@@ -362,7 +386,7 @@ public class AclIdResourceTest {
}
public
void
resetDB
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
ACL_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/invite/InviteResourceTest.java
View file @
2b44971c
...
...
@@ -85,7 +85,7 @@ public class InviteResourceTest {
mResponse
=
null
;
// reset data base
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
INVITE_TABLE
);
mongoDB
.
createTable
(
Constants
.
INVITE_TABLE
);
...
...
cloud/account/src/test/java/org/iotivity/cloud/accountserver/resources/acl/verify/AclVerifyResourceTest.java
View file @
2b44971c
...
...
@@ -34,7 +34,6 @@ import org.iotivity.cloud.accountserver.Constants;
import
org.iotivity.cloud.accountserver.db.MongoDB
;
import
org.iotivity.cloud.accountserver.resources.acl.id.AclResource
;
import
org.iotivity.cloud.base.device.CoapDevice
;
import
org.iotivity.cloud.base.protocols.IRequest
;
import
org.iotivity.cloud.base.protocols.IResponse
;
import
org.iotivity.cloud.base.protocols.MessageBuilder
;
...
...
@@ -56,7 +55,8 @@ import org.mockito.stubbing.Answer;
public
class
AclVerifyResourceTest
{
private
static
final
String
ACL_ID_URI
=
Constants
.
ACL_ID_FULL_URI
;
private
static
final
String
ACL_VERIFY_URI
=
Constants
.
ACL_VERIFY_FULL_URI
;
final
CountDownLatch
mLatch
=
new
CountDownLatch
(
1
);
final
CountDownLatch
mLatch
=
new
CountDownLatch
(
1
);
private
final
String
mDeviceUuid
=
"9cfbeb8e-5a1e-4d1c-9d01-2ae6fdb"
;
private
final
String
mOwnerUuid
=
"123e4567-e89b-12d3-a456-4266554"
;
private
final
String
mSubjectUuid
=
"72616E64-5069-6E44-6576-5575696"
;
...
...
@@ -67,7 +67,8 @@ public class AclVerifyResourceTest {
private
final
String
mResourceType
=
"core.light"
;
private
final
String
mResourceIf
=
"oic.if.baseline"
;
private
String
mAclId
=
"987e6543-e21b-12d3-a456-4266554"
;
private
CoapDevice
mMockDevice
=
Mockito
.
mock
(
CoapDevice
.
class
);
private
CoapDevice
mMockDevice
=
Mockito
.
mock
(
CoapDevice
.
class
);
private
Cbor
<
HashMap
<
String
,
Object
>>
mCbor
=
new
Cbor
<>();
private
IResponse
mResponse
=
null
;
private
AclVerifyResource
mAclVerifyResource
=
new
AclVerifyResource
();
...
...
@@ -80,14 +81,18 @@ public class AclVerifyResourceTest {
resetDB
();
Mockito
.
doAnswer
(
new
Answer
<
Object
>()
{
@Override
public
CoapResponse
answer
(
InvocationOnMock
invocation
)
throws
Throwable
{
public
CoapResponse
answer
(
InvocationOnMock
invocation
)
throws
Throwable
{
Object
[]
args
=
invocation
.
getArguments
();
CoapResponse
resp
=
(
CoapResponse
)
args
[
0
];
System
.
out
.
println
(
"\t----------payload : "
+
resp
.
getPayloadString
());
System
.
out
.
println
(
"\t----------payload : "
+
resp
.
getPayloadString
());
System
.
out
.
println
(
"\t---------method : "
+
resp
.
getStatus
());
mResponse
=
resp
;
if
(
mAclId
==
null
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
resp
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
resp
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
"aclid"
))
{
mAclId
=
(
String
)
payloadData
.
get
(
"aclid"
);
}
...
...
@@ -100,7 +105,7 @@ public class AclVerifyResourceTest {
@After
public
void
resetAccountDatabase
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
createTable
(
Constants
.
USER_TABLE
);
mongoDB
.
createTable
(
Constants
.
ACL_TABLE
);
mongoDB
.
createTable
(
Constants
.
TOKEN_TABLE
);
...
...
@@ -113,13 +118,15 @@ public class AclVerifyResourceTest {
createAclId
(
mMockDevice
,
mDeviceUuid
,
mOwnerUuid
);
hashmapGetAclId
(
mResponse
,
"aclid"
);
addIndividualAce
(
mMockDevice
,
mAclId
);
verifyAcl
(
mMockDevice
,
mSubjectUuid
,
mDeviceUuid
,
mRmType
,
mResourceUri
);
verifyAcl
(
mMockDevice
,
mSubjectUuid
,
mDeviceUuid
,
mRmType
,
mResourceUri
);
assertTrue
(
methodCheck
(
mResponse
,
ResponseStatus
.
CONTENT
));
assertTrue
(
hashmapCheck
(
mResponse
,
"gp"
));
assertTrue
(
mLatch
.
await
(
2L
,
SECONDS
));
}
private
void
createAclId
(
CoapDevice
device
,
String
di
,
String
oid
)
throws
Exception
{
private
void
createAclId
(
CoapDevice
device
,
String
di
,
String
oid
)
throws
Exception
{
System
.
out
.
println
(
"-----Create Acl Id"
);
IRequest
request
=
null
;
request
=
createAclIdRequest
(
oid
,
di
);
...
...
@@ -128,12 +135,15 @@ public class AclVerifyResourceTest {
private
IRequest
createAclIdRequest
(
String
oid
,
String
di
)
{
IRequest
request
=
null
;
String
uriQuery
=
Constants
.
REQ_OWNER_ID
+
"="
+
oid
+
";"
+
Constants
.
REQ_DEVICE_ID
+
"="
+
di
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
PUT
,
ACL_ID_URI
,
uriQuery
);
String
uriQuery
=
Constants
.
REQ_OWNER_ID
+
"="
+
oid
+
";"
+
Constants
.
REQ_DEVICE_ID
+
"="
+
di
;
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
PUT
,
ACL_ID_URI
,
uriQuery
);
return
request
;
}
private
void
addIndividualAce
(
CoapDevice
device
,
String
aclId
)
throws
Exception
{
private
void
addIndividualAce
(
CoapDevice
device
,
String
aclId
)
throws
Exception
{
System
.
out
.
println
(
"-----Add Individual Ace"
);
IRequest
request
=
null
;
request
=
addIndividualAceRequest
(
aclId
);
...
...
@@ -163,28 +173,34 @@ public class AclVerifyResourceTest {
HashMap
<
String
,
Object
>
payload
=
new
HashMap
<>();
payload
.
put
(
Constants
.
REQ_ACL_LIST
,
Arrays
.
asList
(
acelist
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
null
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
return
MessageBuilder
.
createRequest
(
RequestMethod
.
POST
,
ACL_ID_URI
+
"/"
+
aclId
,
null
,
ContentFormat
.
APPLICATION_CBOR
,
mCbor
.
encodingPayloadToCbor
(
payload
));
}
private
void
verifyAcl
(
CoapDevice
device
,
String
subjectUuid
,
String
di
,
String
rm
,
String
uri
)
throws
Exception
{
private
void
verifyAcl
(
CoapDevice
device
,
String
subjectUuid
,
String
di
,
String
rm
,
String
uri
)
throws
Exception
{
System
.
out
.
println
(
"-----Verify Acl"
);
IRequest
request
=
null
;
request
=
verifyAclRequest
(
subjectUuid
,
di
,
rm
,
uri
);
mAclVerifyResource
.
onDefaultRequestReceived
(
device
,
request
);
}
private
IRequest
verifyAclRequest
(
String
subjectUuid
,
String
di
,
String
rm
,
String
uri
)
{
private
IRequest
verifyAclRequest
(
String
subjectUuid
,
String
di
,
String
rm
,
String
uri
)
{
IRequest
request
=
null
;
String
queryUrl
=
"sid="
+
subjectUuid
+
";di="
+
di
+
";rm="
+
rm
+
";uri="
+
uri
;
String
queryUrl
=
"sid="
+
subjectUuid
+
";di="
+
di
+
";rm="
+
rm
+
";uri="
+
uri
;
System
.
out
.
println
(
queryUrl
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_VERIFY_URI
,
queryUrl
);
request
=
MessageBuilder
.
createRequest
(
RequestMethod
.
GET
,
ACL_VERIFY_URI
,
queryUrl
);
((
CoapRequest
)
request
).
setObserve
(
Observe
.
SUBSCRIBE
);
return
request
;
}
private
void
hashmapGetAclId
(
IResponse
response
,
String
propertyName
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
propertyName
))
{
mAclId
=
(
String
)
payloadData
.
get
(
propertyName
);
...
...
@@ -193,7 +209,8 @@ public class AclVerifyResourceTest {
}
private
boolean
hashmapCheck
(
IResponse
response
,
String
propertyName
)
{
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
HashMap
<
String
,
Object
>
payloadData
=
mCbor
.
parsePayloadFromCbor
(
response
.
getPayload
(),
HashMap
.
class
);
if
(
payloadData
.
containsKey
(
propertyName
))
{
return
true
;
}
else
{
...
...
@@ -201,7 +218,8 @@ public class AclVerifyResourceTest {
}
}
private
boolean
methodCheck
(
IResponse
response
,
ResponseStatus
responseStatus
)
{
private
boolean
methodCheck
(
IResponse
response
,
ResponseStatus
responseStatus
)
{
if
(
responseStatus
==
response
.
getStatus
())
{
return
true
;
}
else
{
...
...
@@ -216,7 +234,7 @@ public class AclVerifyResourceTest {
}
public
void
resetDB
()
throws
Exception
{
MongoDB
mongoDB
=
new
MongoDB
(
Constants
.
DB_NAME
);
MongoDB
mongoDB
=
new
MongoDB
(
"127.0.0.1"
,
Constants
.
DB_NAME
);
mongoDB
.
deleteTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
createTable
(
Constants
.
GROUP_TABLE
);
mongoDB
.
deleteTable
(
Constants
.
ACL_TABLE
);
...
...
java/jni/JniOcAccountManager.cpp
View file @
2b44971c
...
...
@@ -28,6 +28,7 @@
if (!(arg)) \
{ \
ThrowOcException(exc, log_message); \
return; \
} \
JniOcAccountManager
::
JniOcAccountManager
(
std
::
shared_ptr
<
OCAccountManager
>
accountManager
)
...
...
@@ -70,7 +71,6 @@ OCConnectivityType JniOcAccountManager::connectivityType() const
}
std
::
shared_ptr
<
OCAccountManager
>
JniOcAccountManager
::
getOcAccountManagerObject
()
const
{
return
m_sharedAccountManager
;
}
...
...
resource/IPCA/src/ocfframework.cpp
View file @
2b44971c
...
...
@@ -234,7 +234,7 @@ IPCAStatus OCFFramework::Start(const IPCAAppInfoInternal& appInfo, bool isUnitTe
if
(
ret
!=
OIC_PLATFORM_OK
)
{
OIC_LOG_V
(
FATAL
,
TAG
,
"Failed to get persistent storage path from OICGetLocalAppDataPath, ret: %"
PRIuPTR
,
"Failed to get persistent storage path from OICGetLocalAppDataPath, ret: %"
PRIuPTR
,
static_cast
<
size_t
>
(
ret
));
OICFree
(
psPath
);
return
IPCA_FAIL
;
...
...
@@ -252,7 +252,7 @@ IPCAStatus OCFFramework::Start(const IPCAAppInfoInternal& appInfo, bool isUnitTe
if
(
ret
!=
OIC_PLATFORM_NOTIMPL
)
{
OIC_LOG_V
(
FATAL
,
TAG
,
"Failed to get path length from OICGetLocalAppDataPath, ret: %"
PRIuPTR
,
"Failed to get path length from OICGetLocalAppDataPath, ret: %"
PRIuPTR
,
static_cast
<
size_t
>
(
ret
));
// An error occurred, fail
return
IPCA_FAIL
;
...
...
resource/c_common/oic_platform/src/others/oic_otherplatforms.c
View file @
2b44971c
...
...
@@ -25,7 +25,7 @@
OICPlatformResult_t
OICGetLocalAppDataPath
(
char
*
buffer
,
size_t
*
bufferLen
)
{
OIC_LOG
(
WARNING
,
TAG
,
"
Unsupported platform."
);
OIC_LOG
(
INFO
,
TAG
,
"OICGetLocalAppDataPath:
Unsupported platform."
);
OC_UNUSED
(
buffer
);
OC_UNUSED
(
bufferLen
);
return
OIC_PLATFORM_NOTIMPL
;
...
...
@@ -33,7 +33,7 @@ OICPlatformResult_t OICGetLocalAppDataPath(char* buffer, size_t* bufferLen)
OICPlatformResult_t
OICGetTempAppDataPath
(
char
*
buffer
,
size_t
*
bufferLen
)
{
OIC_LOG
(
WARNING
,
TAG
,
"
Unsupported platform."
);
OIC_LOG
(
INFO
,
TAG
,
"OICGetTempAppDataPath:
Unsupported platform."
);
OC_UNUSED
(
buffer
);
OC_UNUSED
(
bufferLen
);
return
OIC_PLATFORM_NOTIMPL
;
...
...
resource/c_common/oic_platform/src/windows/oic_winplatform.cpp
View file @
2b44971c
...
...
@@ -201,7 +201,7 @@ static OICPlatformResult_t GetSysLocalAppDataPath(std::string &path, size_t &sys
sysPathLen
=
path
.
length
();
#else // UWP_APP
// Unsupported for win32 apps
OIC_LOG
(
WARNING
,
TAG
,
"
Unsupported platform."
);
OIC_LOG
(
INFO
,
TAG
,
"GetSysLocalAppDataPath:
Unsupported platform."
);
OC_UNUSED
(
path
);
OC_UNUSED
(
sysPathLen
);
OC_UNUSED
(
getTempDir
);
...
...
@@ -232,8 +232,11 @@ static OICPlatformResult_t GetLocalAppDataPath(std::string &path, bool getTempDi
// Set path to the appropriate system local or temp application data path
if
(
ret
!=
OIC_PLATFORM_OK
)