diff --git a/persistence/0004_2.4.0_ekuiper_node.sql b/persistence/0004_2.4.0_ekuiper_node.sql new file mode 100644 index 00000000..854520c7 --- /dev/null +++ b/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; diff --git a/persistence/0004_2.4.0_ekuiper_node.sql.ex b/persistence/0004_2.4.0_ekuiper_node.sql.ex new file mode 100644 index 00000000..23fedf46 --- /dev/null +++ b/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; diff --git a/plugins/ekuiper/plugin_ekuiper.c b/plugins/ekuiper/plugin_ekuiper.c index 93592be1..4ed4d60d 100644 --- a/plugins/ekuiper/plugin_ekuiper.c +++ b/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, };