Fix UI bugs

Issue-ID: DCAEGEN2-1716

Change-Id: I01a5a3c69ff65afde37650e559619723f100e69a
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>

diff --git a/components/datalake-handler/admin/src/src/app/core/services/rest-api.service.ts b/components/datalake-handler/admin/src/src/app/core/services/rest-api.service.ts
index aa34b51..8ccbcc9 100644 (file)
--- a/components/datalake-handler/admin/src/src/app/core/services/rest-api.service.ts
+++ b/components/datalake-handler/admin/src/src/app/core/services/rest-api.service.ts
@@ -166,7 +166,7 @@ export class RestApiService {
     Database
   */
   getDbEncryptList(flag): Observable<any> {
-    return this.http.get(prefix + "dbs/list?tool="+flag).pipe(
+    return this.http.get(prefix + "dbs/list?isDb="+flag).pipe(
       retry(1),
       map(this.extractData),
       catchError(this.handleError)

diff --git a/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.html b/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.html
index 304879e..440485c 100644 (file)
--- a/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.html
+++ b/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.html
@@ -24,7 +24,7 @@ limitations under the License.
   </div>
 
   <!-- Only for feeder page -->
-  <div class="pt-3 pl-2 align-self-center" *ngIf="this.title == 'SIDEBAR.FEDDFER'">
+  <div class="pt-3 pl-2 align-self-center" *ngIf="this.title == 'SIDEBAR.FEEDER'">
     <label class="dl-switch">
       <input id="switch" type="checkbox" [(ngModel)]="this.feeder.running"
         (ngModelChange)="this.changeFeederStatus()" />

diff --git a/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.ts b/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.ts
index 8c39ec1..2d479ea 100644 (file)
--- a/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.ts
+++ b/components/datalake-handler/admin/src/src/app/shared/layout/header/header.component.ts
@@ -64,7 +64,7 @@ export class HeaderComponent {
     });
     this.selectedLang = this.translateService.defaultLang;
 
-    if ((this.title = "SIDEBAR.FEDDFER")) {
+    if ((this.title = "SIDEBAR.FEEDER")) {
       this.restApiService.getFeederstatus().subscribe((data: {}) => {
         this.feeder = new Feeder();
         this.feeder = data;

diff --git a/components/datalake-handler/admin/src/src/app/shared/layout/sidebar/sidebar.component.html b/components/datalake-handler/admin/src/src/app/shared/layout/sidebar/sidebar.component.html
index 2e46388..a0ed00c 100644 (file)
--- a/components/datalake-handler/admin/src/src/app/shared/layout/sidebar/sidebar.component.html
+++ b/components/datalake-handler/admin/src/src/app/shared/layout/sidebar/sidebar.component.html
@@ -30,7 +30,7 @@ limitations under the License.
         <a class="nav-link" [routerLinkActive]="['active']" [routerLinkActiveOptions]="{exact:true}"
           routerLink="/feeder">
           <i class="fas fa-tachometer-alt">&nbsp;</i>
-          {{"SIDEBAR.FEDDFER" | translate}}
+          {{"SIDEBAR.FEEDER" | translate}}
         </a>
       </li>
 

diff --git a/components/datalake-handler/admin/src/src/app/views/feeder/feeder.component.ts b/components/datalake-handler/admin/src/src/app/views/feeder/feeder.component.ts
index 921910b..ceb9e59 100644 (file)
--- a/components/datalake-handler/admin/src/src/app/views/feeder/feeder.component.ts
+++ b/components/datalake-handler/admin/src/src/app/views/feeder/feeder.component.ts
@@ -49,7 +49,7 @@ export class FeederComponent implements OnInit {
     private notificationService: ToastrNotificationService,
     private spinner: NgxSpinnerService
   ) {
-    this.adminService.setTitle("SIDEBAR.FEDDFER");
+    this.adminService.setTitle("SIDEBAR.FEEDER");
     this.restApiService.getTopicsFromFeeder().subscribe(
       res => {
         this.topicContent = res.length.toString();

diff --git a/components/datalake-handler/admin/src/src/assets/i18n/en-us.json b/components/datalake-handler/admin/src/src/assets/i18n/en-us.json
index 233f137..f0217a8 100644 (file)
--- a/components/datalake-handler/admin/src/src/assets/i18n/en-us.json
+++ b/components/datalake-handler/admin/src/src/assets/i18n/en-us.json
@@ -1,6 +1,6 @@
 {
   "SIDEBAR": {
-    "FEDDFER": "DataLake Feeder",
+    "FEEDER": "DataLake Feeder",
     "KAFKA": "Kafka",
     "TOPICS": "Topics",
     "DATABASE": "Database",
@@ -11,7 +11,7 @@
   },
   "NAME": "Name",
   "STATUS": "Status",
-  "SINK": "Sink",
+  "SINK": "Target",
   "AUTHENTICATION": "Authentication",
   "DATA_FORMAT": "Data format",
   "TTL": "TTL",
@@ -56,7 +56,7 @@
   "NODATA": "No Data",
   "NEW_TEMPLATE": "New design",
   "TEMPLATE_BODY": "Body",
-  "FIELUPLOAD": "Import",
+  "FIELUPLOAD": "Select File ...",
   "SUCCESSFULLY_CREARED": "Successfully created.",
   "FAILED_CREARED": "Failed updated.",
   "SUCCESSFULLY_UPDATED": "Successfully updated.",

diff --git a/components/datalake-handler/admin/src/src/assets/i18n/zh-hans.json b/components/datalake-handler/admin/src/src/assets/i18n/zh-hans.json
index 22bfe42..0ba8503 100644 (file)
--- a/components/datalake-handler/admin/src/src/assets/i18n/zh-hans.json
+++ b/components/datalake-handler/admin/src/src/assets/i18n/zh-hans.json
@@ -1,11 +1,11 @@
 {
   "SIDEBAR": {
-    "FEDDFER": "DataLake Feeder",
+    "FEEDER": "DataLake Feeder",
     "TOPICS": "Topics",
-    "KAFKA":"卡夫卡",
+    "KAFKA":"Kafka",
     "DATABASE": "Database",
-    "DASHBOARD": "仪表板设置",
-    "DASHBOARDLIST": "仪表板",
+    "DASHBOARD": "工具设置",
+    "DASHBOARDLIST": "工具",
     "TEMPLATE": "模板",
     "ABOUT": "About"
   },

diff --git a/components/datalake-handler/admin/src/src/assets/i18n/zh-hant.json b/components/datalake-handler/admin/src/src/assets/i18n/zh-hant.json
index 83e1be9..a3649be 100644 (file)
--- a/components/datalake-handler/admin/src/src/assets/i18n/zh-hant.json
+++ b/components/datalake-handler/admin/src/src/assets/i18n/zh-hant.json
@@ -1,11 +1,11 @@
 {
   "SIDEBAR": {
-    "FEDDFER": "DataLake Feeder",
-    "KAFKA":"卡夫卡",
+    "FEEDER": "DataLake Feeder",
+    "KAFKA":"Kafka",
     "TOPICS": "Topics",
     "DATABASE": "Database",
-    "DASHBOARD": "å\84\80表æ\9d¿設置",
-    "DASHBOARDLIST": "å\84\80表æ\9d¿",
+    "DASHBOARD": "å·¥å\85·設置",
+    "DASHBOARDLIST": "å·¥å\85·",
     "TEMPLATE": "模板",
     "ABOUT": "About"
   },

diff --git a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
index 72892a2..8a91427 100644 (file)
--- a/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
+++ b/components/datalake-handler/feeder/src/assembly/scripts/init_db.sql
@@ -1,3 +1,23 @@
+/*\r
+* ============LICENSE_START=======================================================\r
+* ONAP : DATALAKE\r
+* ================================================================================\r
+* Copyright 2019 China Mobile\r
+*=================================================================================\r
+* Licensed under the Apache License, Version 2.0 (the "License");\r
+* you may not use this file except in compliance with the License.\r
+* You may obtain a copy of the License at\r
+*\r
+*     http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+* ============LICENSE_END=========================================================\r
+*/\r
+\r
 drop DATABASE datalake;\r
 create database datalake;\r
 use datalake;\r
@@ -46,7 +66,7 @@ CREATE TABLE `design_type` (
 \r
 CREATE TABLE `design` (\r
   `id` int(11) NOT NULL AUTO_INCREMENT,\r
-  `body` varchar(255) DEFAULT NULL,\r
+  `body` text DEFAULT NULL,\r
   `name` varchar(255) DEFAULT NULL,\r
   `note` varchar(255) DEFAULT NULL,\r
   `submitted` bit(1) DEFAULT NULL,\r

diff --git a/components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql b/components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql
index 770c68b..1328279 100644 (file)
--- a/components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql
+++ b/components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql
@@ -1,3 +1,23 @@
+/*\r
+* ============LICENSE_START=======================================================\r
+* ONAP : DATALAKE\r
+* ================================================================================\r
+* Copyright 2019 China Mobile\r
+*=================================================================================\r
+* Licensed under the Apache License, Version 2.0 (the "License");\r
+* you may not use this file except in compliance with the License.\r
+* You may obtain a copy of the License at\r
+*\r
+*     http://www.apache.org/licenses/LICENSE-2.0\r
+*\r
+* Unless required by applicable law or agreed to in writing, software\r
+* distributed under the License is distributed on an "AS IS" BASIS,\r
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+* See the License for the specific language governing permissions and\r
+* limitations under the License.\r
+* ============LICENSE_END=========================================================\r
+*/\r
+\r
 INSERT INTO datalake.kafka(\r
    id\r
   ,name\r
@@ -36,14 +56,13 @@ insert into db_type (`id`, `name`, tool) values ('HDFS', 'HDFS', false);
 insert into db_type (`id`, `name`, tool) values ('KIBANA', 'Kibana', true);\r
 insert into db_type (`id`, `name`, tool) values ('SUPERSET', 'Apache Superset', true);\r
 \r
-insert into db (id, db_type_id, enabled, `name`,`host`,`login`,`pass`,`database_name`) values (1, 'CB', true, 'Couchbase 1','dl-couchbase','dl','dl1234','datalake');\r
-insert into db (id, db_type_id, enabled, `name`,`host`) values (2, 'ES', true, 'Elasticsearch','dl-es');\r
-insert into db (id, db_type_id, enabled, `name`,`host`,`port`,`database_name`) values (3, 'MONGO', true, 'MongoDB 1','dl-mongodb',27017,'datalake');\r
-insert into db (id, db_type_id, enabled, `name`,`host`) values (4, 'DRUID', true, 'Druid','dl-druid');\r
-insert into db (id, db_type_id, enabled, `name`,`host`,`login`) values (5, 'HDFS', true, 'Hadoop Cluster','dl-hdfs','dl');\r
-insert into db (id, db_type_id, enabled, `name`,`host`) values (6, 'KIBANA', true, 'Kibana demo','dl-es');\r
-insert into db (id, db_type_id, enabled, `name`,`host`) values (7, 'SUPERSET', true, 'Superset demo','dl-druid');\r
-\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`,`login`,`pass`,`database_name`) values (1, 'CB', true, true, 'Couchbase 1','dl-couchbase','dl','dl1234','datalake');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`) values (2, 'ES', true, true, 'Elasticsearch','dl-es');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`,`port`,`database_name`) values (3, 'MONGO', true, true, 'MongoDB 1','dl-mongodb',27017,'datalake');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`) values (4, 'DRUID', true, true, 'Druid','dl-druid');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`,`login`) values (5, 'HDFS', true, true, 'Hadoop Cluster','dl-hdfs','dl');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`) values (6, 'KIBANA', true, false, 'Kibana demo','dl-es');\r
+insert into db (id, db_type_id, enabled, encrypt, `name`,`host`) values (7, 'SUPERSET', true, false, 'Superset demo','dl-druid');\r
 \r
 insert into topic_name (id) values ('_DL_DEFAULT_');\r
 insert into topic_name (id) values ('unauthenticated.SEC_FAULT_OUTPUT');\r

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
index 6d43300..54f46e6 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java
@@ -86,10 +86,10 @@ public class DbController {
 
        @GetMapping("/list")
        @ResponseBody
-       @ApiOperation(value="Get all dbs by tool")
-       public List<DbConfig> dblistByTool(@RequestParam boolean tool) {
+       @ApiOperation(value="Get all tools or dbs")
+       public List<DbConfig> dblistByTool(@RequestParam boolean isDb) {
                log.info("Search dbs by tool start......");
-               Iterable<DbType> dbType  = dbTypeRepository.findByTool(tool);
+               Iterable<DbType> dbType  = dbTypeRepository.findByTool(!isDb);
                List<DbConfig> retDbConfig = new ArrayList<>();
                for (DbType item : dbType) {
                        for (Db d : item.getDbs()) {
@@ -148,7 +148,7 @@ public class DbController {
 
                        if(!dbConfig.getName().equals("Elecsticsearch") || dbConfig.getName().equals("Druid"))
                        {
-                               newdb.setDatabase(new String(dbConfig.getDatabase()));
+                               newdb.setDatabase(dbConfig.getDatabase());
                        }
                        dbRepository.save(newdb);
             log.info("Db save ....... name: " + dbConfig.getName());

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
index ff2b87a..2c23599 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java
@@ -79,7 +79,7 @@ public class Db {
        private String database;
 
        @Column(name="`encrypt`")
-       private Boolean encrypt;
+       private boolean encrypt;
 
        @Column(name="`property1`")
        private String property1;
@@ -162,7 +162,7 @@ public class Db {
         dbConfig.setPort(getPort());
         dbConfig.setPass(getPass());
         dbConfig.setLogin(getLogin());
-        dbConfig.setEncrypt(getEncrypt());
+        dbConfig.setEncrypt(isEncrypt());
         dbConfig.setEnabled(isEnabled());
         dbConfig.setDatabase(getDatabase());
         dbConfig.setDbTypeId(getDbType().getId());

diff --git a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
index eb8a3a1..689f83c 100644 (file)
--- a/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
+++ b/components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java
@@ -106,7 +106,7 @@ public class MongodbService implements DbStoreService {
 
                //http://mongodb.github.io/mongo-java-driver/3.0/driver/reference/connecting/ssl/
                if (config.isEnableSSL()) {
-                       builder.sslEnabled(Boolean.TRUE.equals(mongodb.getEncrypt()));// getEncrypt() can be null
+                       builder.sslEnabled(Boolean.TRUE.equals(mongodb.isEncrypt()));// getEncrypt() can be null
                }
                MongoClientOptions options = builder.build();
                List<ServerAddress> addrs = new ArrayList<>();
@@ -162,7 +162,7 @@ public class MongodbService implements DbStoreService {
                        documents.add(doc);
                }
 
-               String collectionName = effectiveTopic.getName().replaceAll("[^a-zA-Z0-9]", "");//remove - _ .
+               String collectionName = effectiveTopic.getName().replaceAll("[^a-zA-Z0-9]", "").toLowerCase();//remove - _ .
                MongoCollection<Document> collection = mongoCollectionMap.computeIfAbsent(collectionName, k -> database.getCollection(k));
 
                try {

diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/DbTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/DbTest.java
index 0accf5a..e1972c5 100644 (file)
--- a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/DbTest.java
+++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/DbTest.java
@@ -84,7 +84,7 @@ public class DbTest {
         assertTrue("root".equals(mongoDB2.getLogin()));
         assertTrue("root123".equals(mongoDB2.getPass()));
         assertTrue("mongoDB2".equals(mongoDB2.getDatabase()));
-        assertFalse("true".equals(mongoDB2.getEncrypt()));
+        assertFalse("true".equals(mongoDB2.isEncrypt()));
         assertTrue("property1".equals(mongoDB2.getProperty1()));
         assertTrue("property2".equals(mongoDB2.getProperty2()));
         assertTrue("property3".equals(mongoDB2.getProperty3()));