Changing index names to remove leading dot

documentation/documentation.md

@@ -33,7 +33,7 @@ curl -X PUT "http://localhost:9200/_plugins/ubi/awesome?index=ecommerce&id_field
 Send an event to the `awesome` store:
 
 ```
-curl -X POST http://localhost:9200/_plugins/ubi/mystore -H "Content-Type: application/json" -d '
+curl -X POST http://localhost:9200/_plugins/ubi/awesome -H "Content-Type: application/json" -d '
 {
   "action_name": "search",
   "user_id": "98fcf189-4fa8-4322-b6f5-63fbb6b556c9",
@@ -44,7 +44,7 @@ curl -X POST http://localhost:9200/_plugins/ubi/mystore -H "Content-Type: applic
 Get events:
 
 ```
-curl -s http://localhost:9200/.awesome_events/_search | jq
+curl -s http://localhost:9200/ubi_awesome_events/_search | jq
 ```
 
 Do a search of the `ecommerce` index:
@@ -56,7 +56,7 @@ curl -s http://localhost:9200/ecommerce/_search -H "X-ubi-store: awesome" | jq
 Get queries:
 
 ```
-curl -s http://localhost:9200/.awesome_queries/_search | jq
+curl -s http://localhost:9200/ubi_awesome_queries/_search | jq
 ```
 
 Delete the store:
@@ -130,7 +130,7 @@ The plugin exposes a REST API for managing UBI stores and persisting events.
 
 ### Creating a UBI Store
 
-To create a UBI store to contain events and queries, send a `PUT` request:
+To create a UBI store to contain events and queries, send a `PUT` request. The following request creates a store called `mystore`.
 
 ```
 curl -X PUT http://localhost:9200/_plugins/ubi/mystore?index=ecommerce

documentation/queries/dsl_queries.md

@@ -1,7 +1,7 @@
 
 
 ```json
-GET .ubi_log_events/_search
+GET ubi_log_events/_search
 {
   "size":0, 
   "aggs":{ 

documentation/queries/sql_queries.md

@@ -17,7 +17,7 @@ order by user_id
 ```sql
 select 
 	count(0)
-from .ubi_log_events
+from ubi_log_events
 where action_name='on_search' and  event_attributes.data.data_detail.query_data.query_response_hit_ids is null
 order by timestamp
 ```
@@ -30,7 +30,7 @@ Both client and server-side queries should return the same number.
 ```sql
 select 
 	message, count(0) Total  
-from .ubi_log_events 
+from ubi_log_events 
 where 
 	action_name='on_search' 
 group by message 
@@ -66,7 +66,7 @@ To make a pie chart like widget on all the most common events:
 ```sql
 select 
 	action_name, count(0) Total  
-from .ubi_log_events 
+from ubi_log_events 
 group by action_name
 order by Total desc
 ```
@@ -88,7 +88,7 @@ To make a pie chart like widget on the most common events preceded by a query:
 ```sql
 select 
 	action_name, count(0) Total  
-from .ubi_log_events
+from ubi_log_events
 where query_id is not null
 group by action_name
 order by Total desc
@@ -122,7 +122,7 @@ Search for the events that correspond to the query above, `1065c70f-d46a-442f-8c
 ```sql
 select 
   query_id, action_name, message_type, message, event_attributes.data.data_id, event_attributes.data.description, session_id, user_id
-from .ubi_log_events
+from ubi_log_events
 where query_id = '1065c70f-d46a-442f-8ce4-0b5e7a71a892'
 order by timestamp
 ```
@@ -147,7 +147,7 @@ To look at more sessions from the same user above, `155_7e3471ff-14c8-45cb-bc49-
 ```sql
 select 
 	user_id, session_id, query_id, action_name, message_type, message, event_attributes.data.data_type, timestamp 
-from .ubi_log_events
+from ubi_log_events
 where user_id ='155_7e3471ff-14c8-45cb-bc49-83a056c37192'
 order by timestamp
 ```
@@ -250,7 +250,7 @@ user_id|session_id|query_id|action_name|message_type|message|event_attributes.da
 ```sql
 select 
     user_id, session_id, count(0) EventTotal
-from .ubi_log_events
+from ubi_log_events
 where action_name='logout' and query_id is null
 group by user_id, session_id
 order by EventTotal desc
@@ -281,7 +281,7 @@ Since some of these query-less logouts repeat with some users, here is a query t
 ```sql
 select 
     user_id, count(0) EventTotal
-from .ubi_log_events
+from ubi_log_events
 where action_name='logout' and query_id is null
 group by user_id
 order by EventTotal desc

load-test/run.sh

@@ -16,9 +16,9 @@ locust -f load-test.py --headless -u 50 -r 10 --run-time 300s --host http://loca
 sleep 30
 
 # Get count of indexed events.
-EVENTS=`curl -s http://localhost:9200/.mystore_events/_count | jq .count`
+EVENTS=`curl -s http://localhost:9200/ubi_mystore_events/_count | jq .count`
 echo "Found $EVENTS events"
 
 # Get count of indexed queries.
-QUERIES=`curl -s http://localhost:9200/.mystore_queries/_count | jq .count`
+QUERIES=`curl -s http://localhost:9200/ubi_mystore_queries/_count | jq .count`
 echo "Found $QUERIES queries"

src/main/java/com/o19s/ubi/rest/UserBehaviorInsightsRestHandler.java

@@ -161,13 +161,7 @@ private RestChannelConsumer get(final NodeClient nodeClient) {
                 @Override
                 public void processResponse(final GetIndexResponse getIndexResponse) throws Exception {
 
-                    final Set<String> stores = new HashSet<>();
-
-                    for(final String index : getIndexResponse.indices()) {
-                        if(index.startsWith(".") && index.endsWith("_events")) {
-                            stores.add(index.substring(1, index.length() - 7));
-                        }
-                    }
+                    final Set<String> stores = getStoreNames(getIndexResponse.indices());
 
                     final XContentBuilder builder = XContentType.JSON.contentBuilder();
                     builder.startObject().field("stores", stores);
@@ -304,8 +298,8 @@ private String setEventTimestamp(final String eventJson) throws JsonProcessingEx
     private Set<String> getStoreNames(String[] indices) {
         final Set<String> stores = new HashSet<>();
         for (final String index : indices) {
-            if (index.startsWith(".") && index.endsWith("_events")) {
-                stores.add(index.substring(1, index.length() - 7));
+            if (index.startsWith("ubi_") && index.endsWith("_events")) {
+                stores.add(index.substring(4, index.length() - 7));
             }
         }
         return stores;

src/main/java/com/o19s/ubi/utils/UbiUtils.java

@@ -33,7 +33,7 @@ private UbiUtils() {
      * @return The formatted name of the queries index.
      */
     public static String getQueriesIndexName(final String storeName) {
-        return "." + storeName + "_queries";
+        return "ubi_" + storeName + "_queries";
     }
 
     /**
@@ -42,7 +42,7 @@ public static String getQueriesIndexName(final String storeName) {
      * @return The formatted name of the events index.
      */
     public static String getEventsIndexName(final String storeName) {
-        return "." + storeName + "_events";
+        return "ubi_" + storeName + "_events";
     }
 
     /**

src/yamlRestTest/resources/rest-api-spec/test/_plugins.ubi/20_manage_stores.yml

@@ -10,18 +10,18 @@
 
   - do:
       cluster.health:
-        index: [.mystore_events, .mystore_queries]
+        index: [ubi_mystore_events, ubi_mystore_queries]
         wait_for_no_initializing_shards: true
 
   - do:
       indices.exists:
-        index: .mystore_events
+        index: ubi_mystore_events
 
   - is_true: ''
 
   - do:
       indices.exists:
-        index: .mystore_queries
+        index: ubi_mystore_queries
 
   - is_true: ''
 
@@ -39,13 +39,13 @@
 
   - do:
       indices.exists:
-        index: .mystore_events
+        index: ubi_mystore_events
 
   - is_false: ''
 
   - do:
       indices.exists:
-        index: .mystore_queries
+        index: ubi_mystore_queries
 
   - is_false: ''
 
@@ -90,7 +90,7 @@
 
   - do:
       cluster.health:
-        index: [.mystore_events, .mystore_queries]
+        index: [ubi_mystore_events, ubi_mystore_queries]
         wait_for_no_initializing_shards: true
 
   - do:

src/yamlRestTest/resources/rest-api-spec/test/_plugins.ubi/30_storing_queries.yml

@@ -23,18 +23,18 @@ setup:
 
   - do:
       cluster.health:
-        index: [.mystore_events, .mystore_queries]
+        index: [ubi_mystore_events, ubi_mystore_queries]
         wait_for_no_initializing_shards: true
 
   - do:
       indices.exists:
-        index: .mystore_events
+        index: ubi_mystore_events
 
   - is_true: ''
 
   - do:
       indices.exists:
-        index: .mystore_queries
+        index: ubi_mystore_queries
 
   - is_true: ''
 

src/yamlRestTest/resources/rest-api-spec/test/_plugins.ubi/40_storing_events.yml

@@ -13,7 +13,7 @@ setup:
 
   - do:
       cluster.health:
-        index: [.mystore2_events, .mystore2_queries]
+        index: [ubi_mystore2_events, ubi_mystore2_queries]
         wait_for_no_initializing_shards: true
 
   # With an empty timestamp