Rename SP Components as Streaming Integrator

README.md

@@ -9,7 +9,7 @@
 
 This project contains compontents which implements common functionalities used in WSO2 analytics platform.
 
-#### Carbon Analytics repo contains components realted to WSO2 Stream Processor such as:
+#### Carbon Analytics repo contains components realted to WSO2 Streaming Integrator such as:
 
 * stream-processing
 * editor      

components/org.wso2.carbon.analytics.auth.rest.api/pom.xml

@@ -26,7 +26,7 @@
     <artifactId>org.wso2.carbon.analytics.auth.rest.api</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Authentication API</name>
+    <name>WSO2 Streaming Integrator - Authentication API</name>
     <url>http://maven.apache.org</url>
 
     <dependencies>

components/org.wso2.carbon.analytics.auth.rest.api/src/gen/java/org/wso2/carbon/analytics/auth/rest/api/LoginApi.java

@@ -56,7 +56,7 @@ public class LoginApi implements Microservice {
     @Path("/{appName:(.*)}")
     @Consumes({"application/x-www-form-urlencoded", "multipart/form-data"})
     @Produces({"application/json"})
-    @io.swagger.annotations.ApiOperation(value = "", notes = "Login Request to Stream Processor.",
+    @io.swagger.annotations.ApiOperation(value = "", notes = "Login Request to Streaming Integrator.",
             response = UserDTO.class, tags = {})
     @io.swagger.annotations.ApiResponses(value = {
             @io.swagger.annotations.ApiResponse(code = 200, message = "Authorization Request Successful.",
@@ -108,7 +108,7 @@ public Response loginCallbackAppNameGet(@ApiParam(value = "AppName", required =
 
     @GET
     @Path("/auth-type")
-    @io.swagger.annotations.ApiOperation(value = "", notes = "Login type check Request to Stream Processor.",
+    @io.swagger.annotations.ApiOperation(value = "", notes = "Login type check Request to Streaming Integrator.",
             response = UserDTO.class, tags = {})
     @io.swagger.annotations.ApiResponses(value = {
             @io.swagger.annotations.ApiResponse(code = 200, message = "Type Check Request Successful.",

components/org.wso2.carbon.analytics.auth.rest.api/src/gen/java/org/wso2/carbon/analytics/auth/rest/api/LogoutApi.java

@@ -55,7 +55,7 @@ public class LogoutApi implements Microservice {
     @Path("/{appName:(.*)}")
     @Consumes({"application/json"})
     @Produces({"application/json"})
-    @io.swagger.annotations.ApiOperation(value = "", notes = "Logout Request to Stream Processor",
+    @io.swagger.annotations.ApiOperation(value = "", notes = "Logout Request to Streaming Integrator",
             response = void.class, tags = {})
     @io.swagger.annotations.ApiResponses(value = {
             @io.swagger.annotations.ApiResponse(code = 200, message = "Authorization Request Successful.",
@@ -72,7 +72,7 @@ public Response logoutAppNamePost(@ApiParam(value = "AppName", required = true)
     @GET
     @Path("/slo/{appName}")
     @Produces({"application/json"})
-    @io.swagger.annotations.ApiOperation(value = "", notes = "Login type check Request to Stream Processor.",
+    @io.swagger.annotations.ApiOperation(value = "", notes = "Login type check Request to Streaming Integrator.",
             response = HashMap.class, tags = {})
     @io.swagger.annotations.ApiResponses(value = {
             @io.swagger.annotations.ApiResponse(code = 200, message = "SSO logout Request to Stream processor",

components/org.wso2.carbon.analytics.auth.rest.api/src/main/resources/authenticator-api.yaml

@@ -1,8 +1,8 @@
 swagger: '2.0'
 info:
   version: 1.0.0
-  title: Stream Processor Authentication Service
-  description: This provides service to authenticate users in Stream Processor
+  title: Streaming Integrator Authentication Service
+  description: This provides service to authenticate users in Streaming Integrator
   contact:
     name: WSO2
     url: 'http://wso2.com/smart-analytics'
@@ -22,7 +22,7 @@ paths:
   /login/{appName}:
     post:
       description:
-        Login Request to Stream Processor.
+        Login Request to Streaming Integrator.
       consumes:
         - application/x-www-form-urlencoded
         - multipart/form-data
@@ -92,7 +92,7 @@ paths:
   /logout/{appName}:
     post:
       description:
-        Logout Request to Stream Processor
+        Logout Request to Streaming Integrator
       parameters:
         - name: appName
           in: path

components/org.wso2.carbon.analytics.msf4j.interceptor.common/pom.xml

@@ -28,7 +28,7 @@
     <artifactId>org.wso2.carbon.analytics.msf4j.interceptor.common</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Interceptors</name>
+    <name>WSO2 Streaming Integrator - Interceptors</name>
     <url>http://maven.apache.org</url>
 
     <dependencies>

components/org.wso2.carbon.business.rules.core/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.business.rules.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Business Rules</name>
+    <name>WSO2 Streaming Integrator - Business Rules</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.business.rules.templates.editor.core/package.json

@@ -25,7 +25,7 @@
     "react-router-dom": "^4.2.2",
     "react-scripts": "1.0.11",
     "react-tap-event-plugin": "^2.0.1",
-    "rimraf": "^2.6.3",
+    "rimraf": "^2.7.1",
     "typeface-roboto": "0.0.35"
   },
   "devDependencies": {

components/org.wso2.carbon.business.rules.templates.editor.core/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.business.rules.templates.editor.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Business Rules Template Editor</name>
+    <name>WSO2 Streaming Integrator - Business Rules Template Editor</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.business.rules.web/package.json

@@ -20,7 +20,7 @@
     "react-router-dom": "^4.2.2",
     "react-scripts": "1.0.11",
     "react-tap-event-plugin": "^2.0.1",
-    "rimraf": "^2.6.3",
+    "rimraf": "^2.7.1",
     "typeface-roboto": "0.0.35"
   },
   "devDependencies": {

components/org.wso2.carbon.event.simulator.core/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.event.simulator.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Event Simulator</name>
+    <name>WSO2 Streaming Integrator - Event Simulator</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.health.check.core/pom.xml

@@ -30,7 +30,7 @@
     <artifactId>org.wso2.carbon.health.check.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Health Check REST API</name>
+    <name>WSO2 Streaming Integrator - Health Check REST API</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.health.check.core/src/gen/java/org/wso2/carbon/health/check/core/api/HealthApi.java

@@ -43,11 +43,11 @@ public class HealthApi implements Microservice {
 
     @GET
     @Produces({"application/json"})
-    @io.swagger.annotations.ApiOperation(value = "Fetches the status of the Stream Processor.",
-            notes = "Fetches the status of the Stream Processor. ", response = ServerStatus.class, tags = {"Artifact",})
+    @io.swagger.annotations.ApiOperation(value = "Fetches the status of the Streaming Integrator.",
+            notes = "Fetches the status of the Streaming Integrator. ", response = ServerStatus.class, tags = {"Artifact",})
     @io.swagger.annotations.ApiResponses(value = {
             @io.swagger.annotations.ApiResponse(code = 200,
-                    message = "The state of the Stream Processor is successfully retrieved.",
+                    message = "The state of the Streaming Integrator is successfully retrieved.",
                     response = ServerStatus.class)})
     public Response healthGet()
             throws NotFoundException {

components/org.wso2.carbon.health.check.core/src/main/resources/health-check-rest-api.yaml

@@ -3,7 +3,7 @@ info:
   description: >-
     This is the REST Micro Service for System Availability.
   version: 1.0.0
-  title: Stream Processor Health Check API
+  title: Streaming Integrator Health Check API
   termsOfService: 'http://wso2.com/terms'
   contact:
     email: [email protected]
@@ -13,7 +13,7 @@ info:
 basePath: /v1.0
 tags:
   - name: health
-    description: Everything about Stream Processor health
+    description: Everything about Streaming Integrator health
     externalDocs:
       description: Find out more about server health
       url: 'https://docs.wso2.com/display/SP400/Key+Concepts'
@@ -27,14 +27,14 @@ paths:
       x-wso2-response: 'HTTP/1.1 200 OK Content-Type: application/json {"status":"active"}'
       tags:
         - Artifact
-      summary: Fetches the status of the Stream Processor.
+      summary: Fetches the status of the Streaming Integrator.
       description: |
-        Fetches the status of the Stream Processor.
+        Fetches the status of the Streaming Integrator.
       produces:
         - application/json
       responses:
         '200':
-          description: The state of the Stream Processor is successfully retrieved.
+          description: The state of the Streaming Integrator is successfully retrieved.
           schema:
             $ref: '#/definitions/ServerStatus'
 

components/org.wso2.carbon.siddhi.editor.core/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.siddhi.editor.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Editor Core</name>
+    <name>WSO2 Streaming Integrator - Editor Core</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.siddhi.editor.core/src/main/java/org/wso2/carbon/siddhi/editor/core/internal/EditorConsoleService.java

@@ -72,7 +72,7 @@ public void onOpen(WebSocketConnection webSocketConnection) {
 
     @OnMessage
     public void onMessage(String text, WebSocketConnection webSocketConnection) {
-        webSocketConnection.pushText("Welcome to Stream Processor Studio");
+        webSocketConnection.pushText("Welcome to Streaming Integrator Tooling");
         LOGGER.info("Received message : " + text);
     }
 

components/org.wso2.carbon.siddhi.editor.core/src/main/java/org/wso2/carbon/siddhi/editor/core/internal/EditorMicroservice.java

@@ -1082,7 +1082,7 @@ public Response getDefaultSampleStreamEvent(@PathParam("appName") String appName
      */
     @Activate
     protected void start(BundleContext bundleContext) throws Exception {
-        // Create Stream Processor Service
+        // Create Streaming Integrator Service
         EditorDataHolder.setDebugProcessorService(new DebugProcessorService());
         SiddhiManager siddhiManager = new SiddhiManager();
         FileConfigManager fileConfigManager = new FileConfigManager(configProvider);

components/org.wso2.carbon.siddhi.editor.core/src/main/resources/web/index.html

@@ -379,7 +379,7 @@ <h4 class="modal-title" style="color:lightgoldenrodyellow">Warning!</h4>
                 <button type="button" class="close" data-dismiss="modal" aria-label="Close">
                     <span aria-hidden="true">&times;</span>
                 </button>
-                <h4 class="modal-title" id="newConfigModalLabel">Stream Processor Configuration Wizard</h4>
+                <h4 class="modal-title" id="newConfigModalLabel">Streaming Integrator Configuration Wizard</h4>
             </div>
             <div class="modal-body">
                 <div class="container-fluid">
@@ -2176,7 +2176,7 @@ <h4 class="modal-title file-dialog-title" id="aboutDockerExportLabel">Export as
                 <button type="button" class="close" data-dismiss="modal" aria-label="Close">
                     <span aria-hidden='true'>&times;</span>
                 </button>
-                <h4 class="modal-title file-dialog-title text-center" id="whereToStart">Welcome to the Stream Processor Studio Tour Guide</h4>
+                <h4 class="modal-title file-dialog-title text-center" id="whereToStart">Welcome to the Streaming Integrator Studio Tour Guide</h4>
                 <hr class="style1">
                 <div class="divider"></div>
             </div>

components/org.wso2.carbon.siddhi.editor.core/src/main/resources/web/js/guide/guide.js

@@ -43,7 +43,7 @@ define(['jquery', 'lodash', 'log', 'enjoyhint', 'designViewUtils', 'workspace',
             //Script array for the complete guide
             this.completeGuide = [
                 {
-                    'click #newButton': '<b>Welcome to WSO2 Stream Processor Studio!</b> Click <b class="lime-text">New</b> to get started.',
+                    'click #newButton': '<b>Welcome to WSO2 Streaming Integrator Studio!</b> Click <b class="lime-text">New</b> to get started.',
                     'showNext' : false
                 },
                 {

components/org.wso2.carbon.siddhi.editor.core/src/main/resources/web/js/source-editor/constants.js

@@ -67,7 +67,7 @@ define(function() {
      */
     constants.typeToDisplayNameMap = {};
     constants.typeToDisplayNameMap[constants.FUNCTIONS] = "Function";
-    constants.typeToDisplayNameMap[constants.STREAM_PROCESSORS] = "Stream Processor";
+    constants.typeToDisplayNameMap[constants.STREAM_PROCESSORS] = "Streaming Integrator";
     constants.typeToDisplayNameMap[constants.WINDOW_PROCESSORS] = "Window Processor";
     constants.typeToDisplayNameMap[constants.STREAMS] = "Stream";
     constants.typeToDisplayNameMap[constants.INNER_STREAMS] = "Inner Stream";

components/org.wso2.carbon.siddhi.store.api.rest/pom.xml

@@ -30,7 +30,7 @@
     <artifactId>org.wso2.carbon.siddhi.store.api.rest</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Siddhi Store Query REST API</name>
+    <name>WSO2 Streaming Integrator - Siddhi Store Query REST API</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.streaming.integrator.common/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.streaming.integrator.common</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Common</name>
+    <name>WSO2 Streaming Integrator - Common</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.streaming.integrator.common/src/main/java/org/wso2/carbon/streaming/integrator/common/utils/SPConstants.java

@@ -18,7 +18,7 @@
 package org.wso2.carbon.streaming.integrator.common.utils;
 
 /**
- * Stream Processor Constants.
+ * Streaming Integrator Constants.
  */
 public class SPConstants {
     public static final String WSO2_SP_TOKEN_2 = "HID";

components/org.wso2.carbon.streaming.integrator.core/pom.xml

@@ -29,7 +29,7 @@
     <artifactId>org.wso2.carbon.streaming.integrator.core</artifactId>
     <packaging>bundle</packaging>
 
-    <name>WSO2 Stream Processor - Core</name>
+    <name>WSO2 Streaming Integrator - Core</name>
     <url>http://wso2.org</url>
 
     <dependencies>

components/org.wso2.carbon.streaming.integrator.core/src/main/java/org/wso2/carbon/streaming/integrator/core/internal/ServiceComponent.java

@@ -99,7 +99,7 @@ protected void start(BundleContext bundleContext) throws Exception {
 
         String siddhiAppsReference = System.getProperty(SiddhiAppProcessorConstants.SYSTEM_PROP_RUN_SIDDHI_APPS);
         ConfigProvider configProvider = StreamProcessorDataHolder.getInstance().getConfigProvider();
-        // Create Stream Processor Service
+        // Create Streaming Integrator Service
         StreamProcessorDataHolder.setStreamProcessorService(new StreamProcessorService());
         SiddhiManager siddhiManager = new SiddhiManager();
         FileConfigManager fileConfigManager = new FileConfigManager(configProvider);
@@ -361,7 +361,7 @@ private void setUpClustering(ClusterCoordinator clusterCoordinator) throws Confi
                     throw new HAModeException("More than two nodes can not be used in the minimum HA mode. " +
                             "Use another clustering mode, change the groupId or disable clustering.");
                 }
-                log.info("WSO2 Stream Processor Starting in Two Node Minimum HA Deployment");
+                log.info("WSO2 Streaming Integrator Starting in Two Node Minimum HA Deployment");
                 StreamProcessorDataHolder.setIsStatisticsEnabled(
                         SPMetricsDataHolder.getInstance().getMetricManagementService().isEnabled());
                 StatisticsManager statisticsManager = StreamProcessorDataHolder.getStatisticsConfiguration().

components/org.wso2.carbon.streaming.integrator.core/src/main/java/org/wso2/carbon/streaming/integrator/core/internal/StreamProcessorDeployer.java

@@ -316,7 +316,7 @@ public void init() {
         try {
             directoryLocation = new URL("file:" + SiddhiAppProcessorConstants.SIDDHI_APP_FILES_DIRECTORY);
             setServerType();
-            log.debug("Stream Processor Deployer initiated.");
+            log.debug("Streaming Integrator Deployer initiated.");
         } catch (MalformedURLException e) {
             log.error("Error while initializing directoryLocation" + SiddhiAppProcessorConstants.
                     SIDDHI_APP_FILES_DIRECTORY, e);

components/org.wso2.carbon.streaming.integrator.core/src/main/resources/exposeSystemVariable.yaml

@@ -1,7 +1,7 @@
 swagger: '2.0'
 info:
   version: 1.0.0
-  title: Exposing System Run Time of Stream Processor
+  title: Exposing System Run Time of Streaming Integrator
   description: >-
     This provides information about the runtime of the stream processor.
   contact:

components/org.wso2.carbon.streaming.integrator.statistics/src/main/resources/staticstics-api.yaml

@@ -20,7 +20,7 @@
 swagger: '2.0'
 info:
   version: 1.0.0
-  title: Stream Processor Status Dashboard Service
+  title: Streaming Integrator Status Dashboard Service
   description: >-
     This provides information about the REST APIs available for WSO2 Steam
     Processor Status Dashboard from SP worker.

components/org.wso2.carbon.streaming.integrator.statistics/src/main/resources/system-details-api.yaml

@@ -20,7 +20,7 @@
 swagger: '2.0'
 info:
   version: 1.0.0
-  title: Stream Processor Status Dashboard Service
+  title: Streaming Integrator Status Dashboard Service
   description: >-
     This provides information about the REST API available for getting general details of a SP node.
   contact:

components/si-distribution/carbon-home/bin/version.txt

@@ -1 +1 @@
-WSO2 Stream Processor v${project.version}
+WSO2 Streaming Integrator v${project.version}

components/si-distribution/carbon-home/conf/server/deployment.yaml

@@ -17,9 +17,9 @@
   # Carbon Configuration Parameters
 wso2.carbon:
     # value to uniquely identify a server
-  id: wso2-sp
+  id: wso2-si
     # server name
-  name: WSO2 Stream Processor
+  name: WSO2 Streaming Integrator
     # ports used by this server
   ports:
       # port offset

components/si-distribution/carbon-home/samples/artifacts/1001/ReceiveAndCount.siddhi

@@ -5,7 +5,7 @@
 /*
 
 Purpose:
-    This application demonstrates how to configure WSO2 Stream Processor to receive events via HTTP transport and view the output on the console. The count of all events arriving to the stream is calculated.
+    This application demonstrates how to configure WSO2 Streaming Integrator to receive events via HTTP transport and view the output on the console. The count of all events arriving to the stream is calculated.
 
 Prerequisites:
     1) Save this sample