Support Kubernetes instance list (#20)

NOTICE.md

@@ -0,0 +1,2 @@
+## 图标来自
+[品牌图标](https://brands.iconhelper.cn/)

README.md

@@ -5,6 +5,9 @@ Flutter Paas Dashboard
 ## 其他语言文档
 - [English Doc](README_en.md)
 
+# 安装
+- [Install Doc](install.md)
+
 # 开发环境准备
 ```bash
 flutter config --enable-macos-desktop

install.md

@@ -0,0 +1,5 @@
+## 安装步骤
+### windows
+下载最新的release压缩包，[下载地址](https://github.com/paashzj/paas_dashboard_flutter/releases) <br/>
+解压压缩文件 <br/>
+运行**pass_dashboard_flutter.exe** 即可

lib/l10n/intl_en.arb

@@ -1,4 +1,5 @@
 {
+  "@@locale": "en",
   "aboutAuthor": "About author",
   "appName": "Paas Dashboard",
   "basic": "Basic",

lib/l10n/intl_zh.arb

@@ -1,4 +1,5 @@
 {
+  "@@locale": "zh",
   "aboutAuthor": "关于作者",
   "appName": "Paas 仪表盘",
   "basic": "基础信息",

lib/main.dart

@@ -7,9 +7,11 @@ import 'package:paas_dashboard_flutter/ui/bk/bk_page.dart';
 import 'package:paas_dashboard_flutter/ui/general/author_screen.dart';
 import 'package:paas_dashboard_flutter/ui/general/settings_screen.dart';
 import 'package:paas_dashboard_flutter/ui/home/home_page.dart';
+import 'package:paas_dashboard_flutter/ui/kubernetes/k8s_page.dart';
 import 'package:paas_dashboard_flutter/ui/pulsar/pulsar_page.dart';
 import 'package:paas_dashboard_flutter/vm/bk/bk_instance_list_view_model.dart';
 import 'package:paas_dashboard_flutter/vm/general/settings_view_model.dart';
+import 'package:paas_dashboard_flutter/vm/kubernetes/k8s_instance_list_view_model.dart';
 import 'package:paas_dashboard_flutter/vm/pulsar/pulsar_instance_list_view_model.dart';
 import 'package:paas_dashboard_flutter/vm/pulsar/pulsar_instance_view_model.dart';
 import 'package:paas_dashboard_flutter/vm/pulsar/pulsar_namespace_view_model.dart';
@@ -61,6 +63,10 @@ class MyApp extends StatelessWidget {
               create: (context) => BkInstanceListViewModel(),
               child: BkPage(),
             ),
+        PageRouteConst.Kubernetes: (context) => ChangeNotifierProvider(
+          create: (context) => K8sInstanceListViewModel(),
+          child: K8sPage(),
+        ),
         PageRouteConst.Pulsar: (context) => ChangeNotifierProvider(
               create: (context) => PulsarInstanceListViewModel(),
               child: PulsarPage(),

lib/module/ssh/ssh_step.dart

@@ -0,0 +1,8 @@
+class SshStep {
+  final String username;
+  final String password;
+  String? suUser;
+  String? suPassword;
+
+  SshStep(this.username, this.password);
+}

lib/persistent/persistent.dart

@@ -1,8 +1,10 @@
 import 'package:flutter/foundation.dart' show kIsWeb;
+import 'package:paas_dashboard_flutter/module/ssh/ssh_step.dart';
 import 'package:paas_dashboard_flutter/persistent/persistent_api.dart';
 import 'package:paas_dashboard_flutter/persistent/persistent_db.dart';
 import 'package:paas_dashboard_flutter/persistent/persistent_memory.dart';
 import 'package:paas_dashboard_flutter/persistent/po/bk_instance_po.dart';
+import 'package:paas_dashboard_flutter/persistent/po/k8s_instance_po.dart';
 import 'package:paas_dashboard_flutter/persistent/po/pulsar_instance_po.dart';
 
 class Persistent {
@@ -44,6 +46,18 @@ class Persistent {
     return (await getApi()).bookkeeperInstances();
   }
 
+  static Future<void> saveKubernetesSsh(String name, List<SshStep> sshSteps) async {
+    return (await getApi()).saveKubernetesSsh(name, sshSteps);
+  }
+
+  static Future<void> deleteKubernetes(int id) async {
+    return (await getApi()).deleteKubernetes(id);
+  }
+
+  static Future<List<K8sInstancePo>> kubernetesInstances() async {
+    return (await getApi()).kubernetesInstances();
+  }
+
   static bool supportDb() {
     return !kIsWeb;
   }

lib/persistent/persistent_api.dart

@@ -1,4 +1,6 @@
+import 'package:paas_dashboard_flutter/module/ssh/ssh_step.dart';
 import 'package:paas_dashboard_flutter/persistent/po/bk_instance_po.dart';
+import 'package:paas_dashboard_flutter/persistent/po/k8s_instance_po.dart';
 import 'package:paas_dashboard_flutter/persistent/po/pulsar_instance_po.dart';
 
 abstract class PersistentApi {
@@ -13,4 +15,10 @@ abstract class PersistentApi {
   Future<void> deleteBookkeeper(int id);
 
   Future<List<BkInstancePo>> bookkeeperInstances();
+
+  Future<void> saveKubernetesSsh(String name, List<SshStep> sshSteps);
+
+  Future<void> deleteKubernetes(int id);
+
+  Future<List<K8sInstancePo>> kubernetesInstances();
 }

lib/persistent/persistent_db.dart

@@ -1,8 +1,10 @@
 import 'dart:developer';
 import 'dart:io';
 
+import 'package:paas_dashboard_flutter/module/ssh/ssh_step.dart';
 import 'package:paas_dashboard_flutter/persistent/persistent_api.dart';
 import 'package:paas_dashboard_flutter/persistent/po/bk_instance_po.dart';
+import 'package:paas_dashboard_flutter/persistent/po/k8s_instance_po.dart';
 import 'package:paas_dashboard_flutter/persistent/po/pulsar_instance_po.dart';
 import 'package:path/path.dart';
 import 'package:sqflite/sqflite.dart';
@@ -59,6 +61,19 @@ class PersistentDb implements PersistentApi {
     await db.execute(
       'INSERT INTO bookkeeper_instances(name, host, port) VALUES ("example", "localhost", 8080)',
     );
+    await db.execute(
+      'CREATE TABLE zookeeper_instances(id INTEGER PRIMARY KEY, name TEXT, host TEXT, port INTEGER)',
+    );
+    await db.execute(
+      'INSERT INTO zookeeper_instances(name, host, port) VALUES ("example", "localhost", 8080)',
+    );
+    // type: api、host
+    await db.execute(
+      'CREATE TABLE kubernetes_instances(id INTEGER PRIMARY KEY, name TEXT, type TEXT, content TEXT)',
+    );
+    await db.execute(
+      'INSERT INTO kubernetes_instances(name, type, content) VALUES ("example", "host", "{}")',
+    );
   }
 
   @override
@@ -113,4 +128,22 @@ class PersistentDb implements PersistentApi {
     });
   }
 
+  @override
+  Future<void> saveKubernetesSsh(String name, List<SshStep> sshSteps) {
+    // TODO: implement saveKubernetesSsh
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> deleteKubernetes(int id) {
+    // TODO: implement deleteKubernetes
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<List<K8sInstancePo>> kubernetesInstances() {
+    // TODO: implement k8sInstances
+    throw UnimplementedError();
+  }
+
 }

lib/persistent/persistent_memory.dart

@@ -1,5 +1,7 @@
+import 'package:paas_dashboard_flutter/module/ssh/ssh_step.dart';
 import 'package:paas_dashboard_flutter/persistent/persistent_api.dart';
 import 'package:paas_dashboard_flutter/persistent/po/bk_instance_po.dart';
+import 'package:paas_dashboard_flutter/persistent/po/k8s_instance_po.dart';
 import 'package:paas_dashboard_flutter/persistent/po/pulsar_instance_po.dart';
 
 class PersistentMemory implements PersistentApi {
@@ -36,4 +38,21 @@ class PersistentMemory implements PersistentApi {
   Future<List<BkInstancePo>> bookkeeperInstances() async {
     return [new BkInstancePo(0, "example", "localhost", 8080)];
   }
+
+  @override
+  Future<void> saveKubernetesSsh(String name, List<SshStep> sshSteps) {
+    // TODO: implement saveKubernetesSsh
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> deleteKubernetes(int id) {
+    // TODO: implement deleteKubernetes
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<List<K8sInstancePo>> kubernetesInstances() async{
+    return [new K8sInstancePo(0, "example")];
+  }
 }

lib/persistent/po/bk_instance_po.dart

@@ -17,7 +17,7 @@ class BkInstancePo extends HttpEndpoint {
 
   @override
   String toString() {
-    return 'BookKeeperInstance{id: $id, name: $name, host: $host, port: port}';
+    return 'BookKeeperInstance{id: $id, name: $name, host: $host, port: $port}';
   }
 
 }

lib/persistent/po/http_endpoint.dart

@@ -7,6 +7,6 @@ class HttpEndpoint {
 
   @override
   String toString() {
-    return 'HttpEndpoint{name: $name, host: $host, port: port}';
+    return 'HttpEndpoint{name: $name, host: $host, port: $port}';
   }
 }

lib/persistent/po/k8s_instance_po.dart

@@ -0,0 +1,19 @@
+
+class K8sInstancePo {
+  final int id;
+  final String name;
+
+  K8sInstancePo(this.id, this.name);
+
+  Map<String, dynamic> toMap() {
+    return {
+      'id': id,
+      'name': name,
+    };
+  }
+
+  @override
+  String toString() {
+    return 'BookKeeperInstance{id: $id, name: $name}';
+  }
+}

lib/route/page_route_const.dart

@@ -3,6 +3,7 @@ class PageRouteConst {
   static const String Author = '/author';
   static const String Settings = '/settings';
   static const String Bookkeeper = '/bookkeeper';
+  static const String Kubernetes = '/kubernetes';
   static const String Pulsar = '/pulsar';
   static const String PulsarInstance = '/pulsar/instance';
   static const String PulsarTenant = '/pulsar/instance/tenant';

lib/ui/kubernetes/k8s_page.dart

@@ -0,0 +1,68 @@
+import 'package:flutter/material.dart';
+import 'package:paas_dashboard_flutter/generated/l10n.dart';
+import 'package:paas_dashboard_flutter/vm/kubernetes/k8s_instance_list_view_model.dart';
+import 'package:provider/provider.dart';
+
+class K8sPage extends StatefulWidget {
+  @override
+  State<StatefulWidget> createState() {
+    return new _K8sPageState();
+  }
+}
+
+class _K8sPageState extends State<K8sPage> {
+  @override
+  void initState() {
+    super.initState();
+    Provider.of<K8sInstanceListViewModel>(context, listen: false)
+        .fetchBkInstances();
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    final vm = Provider.of<K8sInstanceListViewModel>(context);
+    var refreshButton = TextButton(
+        onPressed: () {
+          setState(() {
+            vm.fetchBkInstances();
+          });
+        },
+        child: Text(S.of(context).refresh));
+    var body = ListView(
+      children: [
+        Container(
+          height: 50,
+          child: ListView(
+            scrollDirection: Axis.horizontal,
+            shrinkWrap: true,
+            children: [refreshButton],
+          ),
+        ),
+        Center(
+          child: Text('Kubernetes Instance List'),
+        ),
+        SingleChildScrollView(
+          child: DataTable(
+            showCheckboxColumn: false,
+            columns: [
+              DataColumn(label: Text('Id')),
+              DataColumn(label: Text('Name')),
+            ],
+            rows: vm.instances
+                .map((itemRow) =>
+                DataRow(onSelectChanged: (bool? selected) {}, cells: [
+                  DataCell(Text(itemRow.id.toString())),
+                  DataCell(Text(itemRow.name)),
+                ]))
+                .toList(),
+          ),
+        ),
+      ],
+    );
+    return Scaffold(
+        appBar: AppBar(
+          title: Text('Kubernetes Dashboard'),
+        ),
+        body: body);
+  }
+}

lib/vm/kubernetes/k8s_instance_list_view_model.dart

@@ -0,0 +1,25 @@
+import 'package:flutter/material.dart';
+import 'package:paas_dashboard_flutter/persistent/persistent.dart';
+
+import 'k8s_instance_view_model.dart';
+
+class K8sInstanceListViewModel extends ChangeNotifier {
+  List<K8sInstanceViewModel> instances = <K8sInstanceViewModel>[];
+
+  Future<void> fetchBkInstances() async {
+    final results = await Persistent.kubernetesInstances();
+    this.instances = results.map((e) => K8sInstanceViewModel(e)).toList();
+    notifyListeners();
+  }
+
+  Future<void> createBk(String name, String host, int port) async {
+    Persistent.saveBookkeeper(name, host, port);
+    fetchBkInstances();
+  }
+
+  Future<void> deleteBk(int id) async {
+    Persistent.deleteBookkeeper(id);
+    fetchBkInstances();
+  }
+
+}

lib/vm/kubernetes/k8s_instance_view_model.dart

@@ -0,0 +1,15 @@
+import 'package:paas_dashboard_flutter/persistent/po/k8s_instance_po.dart';
+
+class K8sInstanceViewModel {
+  final K8sInstancePo k8sInstancePo;
+
+  K8sInstanceViewModel(this.k8sInstancePo);
+
+  int get id {
+    return this.k8sInstancePo.id;
+  }
+
+  String get name {
+    return this.k8sInstancePo.name;
+  }
+}