datamining integration, with itest

dist/pom.xml

@@ -103,6 +103,11 @@
       <version>${version.org.hawkular.agent}</version>
     </dependency>
 
+    <dependency>
+      <groupId>org.hawkular.datamining</groupId>
+      <artifactId>hawkular-datamining-dist</artifactId>
+      <type>war</type>
+    </dependency>
     <dependency>
       <groupId>org.hawkular.inventory</groupId>
       <artifactId>hawkular-inventory-dist</artifactId>
@@ -305,6 +310,12 @@
                   <version>${version.org.hawkular.inventory}</version>
                   <type>war</type>
                 </artifactItem>
+                <artifactItem>
+                  <groupId>org.hawkular.datamining</groupId>
+                  <artifactId>hawkular-datamining-dist</artifactId>
+                  <version>${version.org.hawkular.datamining}</version>
+                  <type>war</type>
+                </artifactItem>
 
               </artifactItems>
             </configuration>

modules/end-to-end-test/src/test/groovy/org/hawkular/integration/test/DataminingITest.groovy

@@ -0,0 +1,133 @@
+/*
+ * Copyright 2015-2016 Red Hat, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * 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.
+ */
+
+package org.hawkular.integration.test
+import org.hawkular.inventory.api.model.Metric
+import org.hawkular.inventory.api.model.MetricDataType
+import org.hawkular.inventory.api.model.MetricType
+import org.hawkular.inventory.api.model.MetricUnit
+import org.junit.Assert
+import org.junit.BeforeClass
+import org.junit.Test
+
+import static org.junit.Assert.assertEquals
+
+class DataminingITest extends AbstractTestBase {
+
+    private static final String invBasePath = "/hawkular/inventory"
+    private static final String dtmBasePath = "/hawkular/datamining"
+
+    private static final String predictionRelationshipName = "__inPrediction"
+
+    private static final String environmentId = "test"
+    private static final String feedId = "itest-dtm-feed"
+    private static final String metricTypeId = "itest-dtm-mt"
+    private static final String metricId = "itest-dtm-m"
+
+    private static String tenantId;
+
+    @BeforeClass
+    public static void setUpData() {
+
+        def payload = null;
+        def response = null
+        String path = "/hawkular/inventory/environments/$environmentId";
+        int attemptCount = 5;
+        int delay = 500;
+        for (int i = 0; i < attemptCount; i++) {
+            try {
+                response = client.get(path: path)
+                /* all is well, we can leave the loop */
+                break;
+            } catch (groovyx.net.http.HttpResponseException e) {
+                /* some initial attempts may fail */
+            }
+            println "'$path' not ready yet, about to retry after $delay ms"
+            /* sleep one second */
+            Thread.sleep(delay);
+        }
+        if (response.status != 200) {
+            Assert.fail("Getting path '$path' returned status ${response.status}, tried $attemptCount times");
+        }
+        assertEquals(environmentId, response.data.id)
+
+        String path2 = "/hawkular/inventory/tenant"
+        for (int i = 0; i < attemptCount; i++) {
+            try {
+                response = client.get(path: path2)
+                /* all is well, we can leave the loop */
+                break;
+            } catch (groovyx.net.http.HttpResponseException e) {
+                /* some initial attempts may fail */
+            }
+            println "'$path2' not ready yet, about to retry after $delay ms"
+            /* sleep one second */
+            Thread.sleep(delay);
+        }
+        if (response.status != 200) {
+            Assert.fail("Getting path '$path2' returned status ${response.status}, tried $attemptCount times");
+        }
+        tenantId = response.data.id
+
+
+        /**
+         * Create Feed
+         */
+        payload = [
+                id: "$feedId".toString()
+        ]
+        response = client.post(path: "$invBasePath/feeds", body: payload)
+        assertEquals(201, response.status)
+
+        /**
+         * Create metricType
+         */
+        def metricType = MetricType.Blueprint.builder(MetricDataType.GAUGE)
+                .withId(metricTypeId).withUnit(MetricUnit.BYTES).withInterval(2000).build()
+        response = client.post(path: "$invBasePath/feeds/$feedId/metricTypes", body: metricType)
+        assertEquals(201, response.status)
+
+        /**
+         * Create metric
+         */
+        def metric = Metric.Blueprint.builder().withId(metricId).withMetricTypePath(metricTypeId).build()
+        response = client.post(path: "$invBasePath/feeds/$feedId/metrics", body: metric)
+        assertEquals(201, response.status)
+
+        /**
+         * Create prediction relationship
+         */
+        payload = [
+            name: "$predictionRelationshipName".toString(),
+            source: "/t;$tenantId".toString(),
+            target: "/t;$tenantId/f;$feedId/m;$metricId".toString()
+        ]
+        response = client.post(path: "$invBasePath/tenants/relationships", body: payload)
+        assertEquals(201, response.status)
+
+
+        Thread.sleep(2000);
+    }
+
+    @Test
+    public void testSubscriptionExists() {
+        def response = client.get(path: "$dtmBasePath/subscriptions", headers: ["Hawkular-Tenant": tenantId])
+        assertEquals(200, response.status)
+    }
+}
+
+

pom.xml

@@ -94,6 +94,7 @@
     <version.rxjava>1.0.16</version.rxjava>
     <version.hystrix-core>1.4.21</version.hystrix-core>
     <version.hystrix-request-servlet>1.1.2</version.hystrix-request-servlet>
+    <version.org.hawkular.datamining>0.0.1.Alpha1-SNAPSHOT</version.org.hawkular.datamining>
   </properties>
 
   <dependencyManagement>
@@ -144,6 +145,13 @@
         <type>ear</type>
       </dependency>
 
+      <dependency>
+        <groupId>org.hawkular.datamining</groupId>
+        <artifactId>hawkular-datamining-dist</artifactId>
+        <version>${version.org.hawkular.datamining}</version>
+        <type>war</type>
+      </dependency>
+
       <dependency>
         <groupId>org.hawkular.inventory</groupId>
         <artifactId>hawkular-inventory-api</artifactId>