AggregatedReportInterfaceTest.java

/*
 * Copyright (c) 2014 Intel Corporation.
 *
 * Permission is hereby granted, free of charge, to any person obtaining
 * a copy of this software and associated documentation files (the
 * "Software"), to deal in the Software without restriction, including
 * without limitation the rights to use, copy, modify, merge, publish,
 * distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so, subject to
 * the following conditions:
 *
 * The above copyright notice and this permission notice shall be
 * included in all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
 * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
 * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 */
package com.intel.iotkit;

import com.intel.iotkitlib.AggregatedReportInterface;
import com.intel.iotkitlib.RequestStatusHandler;
import com.intel.iotkitlib.http.CloudResponse;
import com.intel.iotkitlib.models.AttributeFilter;
import com.intel.iotkitlib.utils.Utilities;

import org.json.JSONException;

public class AggregatedReportInterfaceTest extends ApplicationTest {
    private boolean serverResponse = false;

    private void waitForServerResponse(Object object) {
        synchronized (object) {
            while (!serverResponse) {
            }
            serverResponse = false;
        }
    }

    public void testAggregatedReportInterface() throws JSONException {
        AggregatedReportInterface aggregatedReportInterface = new AggregatedReportInterface(new RequestStatusHandler() {
            @Override
            public void readResponse(CloudResponse response) {
                assertEquals(200, response.getCode());
                serverResponse = true;
            }
        });

        aggregatedReportInterface.addGatewayId(deviceName);
        aggregatedReportInterface.addDeviceId(deviceName);
        aggregatedReportInterface.addComponentId(Utilities.getSensorMatch(deviceComponentName).getValue().toString());

        aggregatedReportInterface.setStartTimestamp(0L);
        aggregatedReportInterface.setEndTimestamp(System.currentTimeMillis());

        //report filters
        AttributeFilter filter1 = new AttributeFilter("Tags");
        filter1.addAttributeFilterValue("intel");

        aggregatedReportInterface.addFilter(filter1);

        aggregatedReportInterface.setOutputType("json");
        aggregatedReportInterface.setLimit(100);
        aggregatedReportInterface.setOffset(0);

        aggregatedReportInterface.addAggregationMethod("average");
        aggregatedReportInterface.addAggregationMethod("min");
        /*aggregatedReportInterface.addDimensions("dim1");
        aggregatedReportInterface.addDimensions("dim2");
        aggregatedReportInterface.setReportCountOnly(true);*/
        //sort
        aggregatedReportInterface.addSortInfo("timeHour", "Asc");
        CloudResponse response = aggregatedReportInterface.request();
        assertEquals(true, response.getStatus());
        waitForServerResponse(aggregatedReportInterface);
    }
}