ADD: subscription template (#66)

* ADD: subscription template

* Add RAML implementation

Author: ned29

src/main/java/com/ericsson/ei/controller/SubscriptionTemplateControllerImpl.java

@@ -0,0 +1,36 @@
+package com.ericsson.ei.controller;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.io.IOUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.CrossOrigin;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+@Component
+@CrossOrigin
+@Api(value = "Get template", description = "REST end-points for template subscription")
+public class SubscriptionTemplateControllerImpl implements SubscriptiontemplateController {
+
+    private static final Logger LOGGER = (Logger) LoggerFactory.getLogger(SubscriptionTemplateControllerImpl.class);
+
+    @Override
+    @CrossOrigin
+    @ApiOperation(value = "")
+    public ResponseEntity<?> getDownloadSubscriptiontemplate() {
+        try {
+            InputStream is = getClass().getResourceAsStream("/subscriptionsTemplate.json");
+            return new ResponseEntity<>(IOUtils.toByteArray(is), new HttpHeaders(), HttpStatus.OK);
+        } catch (IOException e) {
+            LOGGER.error("Error " + e.getMessage());
+            return new ResponseEntity<>("File not found", HttpStatus.OK);
+        }
+    }
+}

src/main/java/com/ericsson/ei/controller/SubscriptiontemplateController.java

@@ -0,0 +1,27 @@
+
+package com.ericsson.ei.controller;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+
+/**
+ * No description
+ * (Generated with springmvc-raml-parser v.0.10.11)
+ * 
+ */
+@RestController
+@RequestMapping(value = "/download/subscriptiontemplate", produces = "application/json")
+public interface SubscriptiontemplateController {
+
+
+    /**
+     * Subscription template
+     * 
+     */
+    @RequestMapping(value = "", method = RequestMethod.GET)
+    public ResponseEntity<?> getDownloadSubscriptiontemplate();
+
+}

src/main/resources/public/raml/eiffel-intelligence.raml

@@ -28,4 +28,5 @@
   baseUri: /
   /subscriptions: !include subscription.raml
   /query: !include queryservice.raml  
-  /jmespathrule: !include jmespath.raml
+  /jmespathrule: !include jmespath.raml
+  /download: !include template.raml

src/main/resources/public/raml/template.raml

@@ -0,0 +1,7 @@
+    /subscriptiontemplate:
+      get:
+        description: Subscription template
+        responses:
+          200:
+            body:
+              application/json:

src/main/resources/subscriptionsTemplate.json

@@ -0,0 +1,58 @@
+[{
+    "notificationMessage" : "sample@ericsson.com",
+    "notificationMeta" : "http://127.0.0.1:3000/ei/test_subscription_rest",
+    "notificationType" : "REST_POST",
+    "repeat" : false,
+    "requirements" : [ 
+        {
+            "conditions" : [ 
+                {
+                    "jmespath" : "gav.groupId=='com.mycompany.myproduct'"
+                }, 
+                {
+                    "jmespath" : "testCaseExecutions[?testCase.conclusion == 'SUCCESSFUL' && testCase.id=='TC5']"
+                }
+            ]
+       	}, 
+        {
+            "conditions" : [ 
+                {
+                    "jmespath" : "gav.groupId=='com.mycompany.myproduct'"
+                }, 
+                {
+                    "jmespath" : "testCaseExecutions[?testCaseStartedEventId == '13af4a14-f951-4346-a1ba-624c79f10e98']"
+                }
+            ]
+        }
+    ],
+    "subscriptionName" : "Subscription_Test"
+},
+{
+    "notificationMessage" : "sample2@ericsson.com",
+    "notificationMeta" : "http://127.0.0.1:3000/ei/test_subscription_rest",
+    "notificationType" : "REST_POST",
+    "repeat" : false,
+    "requirements" : [ 
+        {
+            "conditions" : [ 
+                {
+                    "jmespath" : "gav.groupId=='com.mycompany.myproduct'"
+                }, 
+                {
+                    "jmespath" : "testCaseExecutions[?testCase.conclusion == 'SUCCESSFUL' && testCase.id=='TC5']"
+                }
+            ]
+        }, 
+        {
+            "conditions" : [ 
+                {
+                    "jmespath" : "gav.groupId=='com.mycompany.myproduct'"
+                }, 
+                {
+                    "jmespath" : "testCaseExecutions[?testCaseStartedEventId == '13af4a14-f951-4346-a1ba-624c79f10e98']"
+                }
+            ]
+        }
+    ],
+    "subscriptionName" : "Subscription_Test_Modify"
+}]

src/test/java/com/ericsson/ei/controller/TestSubscriptionTemplateControllerImpl.java

@@ -0,0 +1,32 @@
+package com.ericsson.ei.controller;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.servlet.WebMvcTest;
+import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.http.MediaType;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
+
+import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@WebMvcTest(value = SubscriptiontemplateController.class, secure = false)
+public class TestSubscriptionTemplateControllerImpl {
+
+    @Autowired
+    private MockMvc mockMvc;
+
+    @MockBean
+    private SubscriptiontemplateController subscriptiontemplateController;
+
+    @Test
+    public void testResponseStatus() throws Exception {
+        mockMvc.perform(MockMvcRequestBuilders.get("/download/subscriptiontemplate")
+                .accept(MediaType.APPLICATION_JSON_VALUE))
+                .andExpect(status().isOk())
+                .andReturn();
+    }
+}