diff --git a/src/include/utils/helpers.hpp b/src/include/utils/helpers.hpp index db1e709..69ac1d9 100644 --- a/src/include/utils/helpers.hpp +++ b/src/include/utils/helpers.hpp @@ -74,22 +74,9 @@ void RegisterTF(DatabaseInstance &instance, const char *name) { ExtensionUtil::RegisterFunction(instance, tf); } -template -void RegisterTFWithArgs(DatabaseInstance &instance, const char *name, - vector arguments, - table_function_bind_t bind) { - TableFunction tf(name, arguments, internal::TableFunc, bind, - RunOnceTableFunctionState::Init); - ExtensionUtil::RegisterFunction(instance, tf); -} - } // namespace internal #define RESISTER_TF(name, func) \ internal::RegisterTF(instance, name) -#define RESISTER_TF_ARGS(name, args, func, bind) \ - internal::RegisterTFWithArgs(instance, name, args, \ - bind) - } // namespace duckdb diff --git a/src/ui_extension.cpp b/src/ui_extension.cpp index a2cb64c..e1c2a46 100644 --- a/src/ui_extension.cpp +++ b/src/ui_extension.cpp @@ -70,39 +70,6 @@ std::string StopUIServerFunction(ClientContext &context) { : "UI server already stopped"; } -// Connected notification -struct NotifyConnectedFunctionData : public TableFunctionData { - NotifyConnectedFunctionData(std::string _token) : token(_token) {} - - std::string token; -}; - -static unique_ptr -NotifyConnectedBind(ClientContext &, TableFunctionBindInput &input, - vector &out_types, vector &out_names) { - if (input.inputs[0].IsNull()) { - throw BinderException("Must provide a token"); - } - - out_names.emplace_back("result"); - out_types.emplace_back(LogicalType::VARCHAR); - return make_uniq(input.inputs[0].ToString()); -} - -std::string NotifyConnectedFunction(ClientContext &context, - TableFunctionInput &input) { - auto &inputs = input.bind_data->Cast(); - ui::HttpServer::GetInstance(context)->SendConnectedEvent(inputs.token); - return "OK"; -} - -std::string NotifyCatalogChangedFunction(ClientContext &context) { - ui::HttpServer::GetInstance(context)->SendCatalogChangedEvent(); - return "OK"; -} - -// - connected notification - unique_ptr SingleBoolResultBind(ClientContext &, TableFunctionBindInput &, vector &out_types, @@ -151,9 +118,6 @@ static void LoadInternal(DatabaseInstance &instance) { RESISTER_TF("start_ui", StartUIFunction); RESISTER_TF("start_ui_server", StartUIServerFunction); RESISTER_TF("stop_ui_server", StopUIServerFunction); - RESISTER_TF("notify_ui_catalog_changed", NotifyCatalogChangedFunction); - RESISTER_TF_ARGS("notify_ui_connected", {LogicalType::VARCHAR}, - NotifyConnectedFunction, NotifyConnectedBind); { TableFunction tf("ui_is_started", {}, IsUIStartedTableFunc, SingleBoolResultBind, RunOnceTableFunctionState::Init);