Merge pull request #1065 from eeff/eeff/dev

feat(ekuiper): remove singleton

persistence/0004_2.4.0_ekuiper_node.sql

@@ -0,0 +1,48 @@
+/**
+ * NEURON IIoT System for Industry 4.0
+ * Copyright (C) 2020-2023 EMQ Technologies Co., Ltd All rights reserved.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ **/
+BEGIN TRANSACTION;
+
+-- from neuron version 2.4.0, eKuiper plugin is no more singleton
+-- remove default data-stream-processing node if not in use
+DELETE FROM
+  nodes
+WHERE
+  name = 'data-stream-processing'
+  AND name NOT in (
+    SELECT
+      node_name
+    FROM
+      settings
+  )
+  AND name NOT in (
+    SELECT
+      app_name
+    FROM
+      subscriptions
+  );
+
+-- fix data-stream-processing node plugin name
+UPDATE
+  nodes
+SET
+  plugin_name = 'eKuiper'
+where
+  name = 'data-stream-processing';
+
+COMMIT;

persistence/0004_2.4.0_ekuiper_node.sql.ex

@@ -0,0 +1,27 @@
+/**
+ * NEURON IIoT System for Industry 4.0
+ * Copyright (C) 2020-2023 EMQ Technologies Co., Ltd All rights reserved.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3 of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+ **/
+BEGIN TRANSACTION;
+
+-- default data-stream-processing node for neuronex
+INSERT
+OR REPLACE INTO nodes (name, type, state, plugin_name)
+VALUES
+  ('data-stream-processing', 2, 1, 'eKuiper');
+
+COMMIT;

plugins/ekuiper/plugin_ekuiper.c

@@ -281,6 +281,5 @@ const neu_plugin_module_t neu_plugin_module = {
     .kind            = NEU_PLUGIN_KIND_SYSTEM,
     .type            = NEU_NA_TYPE_APP,
     .display         = true,
-    .single          = true,
-    .single_name     = "data-stream-processing",
+    .single          = false,
 };