1 package org.iotivity.cloud.ciserver.resources.proxy.account;
3 import static java.util.concurrent.TimeUnit.SECONDS;
4 import static org.junit.Assert.assertEquals;
5 import static org.junit.Assert.assertTrue;
6 import static org.mockito.Mockito.mock;
8 import java.util.concurrent.CountDownLatch;
10 import org.iotivity.cloud.base.OCFConstants;
11 import org.iotivity.cloud.base.connector.ConnectorPool;
12 import org.iotivity.cloud.base.device.CoapDevice;
13 import org.iotivity.cloud.base.device.IRequestChannel;
14 import org.iotivity.cloud.base.protocols.IRequest;
15 import org.iotivity.cloud.base.protocols.MessageBuilder;
16 import org.iotivity.cloud.base.protocols.coap.CoapRequest;
17 import org.iotivity.cloud.base.protocols.enums.RequestMethod;
18 import org.iotivity.cloud.ciserver.DeviceServerSystem;
19 import org.junit.Before;
20 import org.junit.Test;
21 import org.mockito.InjectMocks;
22 import org.mockito.Mock;
23 import org.mockito.Mockito;
24 import org.mockito.MockitoAnnotations;
25 import org.mockito.invocation.InvocationOnMock;
26 import org.mockito.stubbing.Answer;
28 public class CertificateTest {
29 private static final String TEST_RESOURCE_CERTI_URI = "/"
30 + OCFConstants.PREFIX_WELL_KNOWN + "/" + OCFConstants.PREFIX_OCF
31 + "/" + OCFConstants.CREDPROV_URI + "/" + OCFConstants.CERT_URI;
32 private CoapDevice mockDevice = mock(
35 ConnectorPool connectorPool = null;
36 DeviceServerSystem deviceServerSystem = new DeviceServerSystem();
37 final CountDownLatch latch = new CountDownLatch(1);
40 IRequestChannel requestChannel;
43 Certificate certHandler = new Certificate();
46 public void setUp() throws Exception {
48 MockitoAnnotations.initMocks(this);
49 deviceServerSystem.addResource(certHandler);
51 Mockito.doAnswer(new Answer<Object>() {
53 public CoapRequest answer(InvocationOnMock invocation)
55 Object[] args = invocation.getArguments();
56 CoapRequest request = (CoapRequest) args[0];
58 "\t----------payload : " + request.getPayloadString());
60 "\t----------uripath : " + request.getUriPath());
62 "\t---------uriquery : " + request.getUriQuery());
67 }).when(requestChannel).sendRequest(Mockito.any(IRequest.class),
68 Mockito.any(CoapDevice.class));
72 public void testOnDefaultRequestReceived() throws Exception {
74 "\t--------------OnRequestReceived(AS) Test------------");
76 IRequest request = MessageBuilder.createRequest(RequestMethod.POST,
77 TEST_RESOURCE_CERTI_URI, null, null, null);
78 certHandler.onRequestReceived(mockDevice, request);
80 assertTrue(latch.await(1L, SECONDS));
81 assertEquals(req.getUriPath(), TEST_RESOURCE_CERTI_URI);