///
/// HybridDatabaseSpec.hpp
/// This file was generated by nitrogen. DO NOT MODIFY THIS FILE.
/// https://github.com/mrousavy/nitro
/// Copyright © Marc Rousavy @ Margelo
///

#pragma once

#if __has_include(<NitroModules/HybridObject.hpp>)
#include <NitroModules/HybridObject.hpp>
#else
#error NitroModules cannot be found! Are you sure you installed NitroModules properly?
#endif

// Forward declaration of `CloseOptions` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct CloseOptions; }
// Forward declaration of `HybridQueryResultSpec` to properly resolve imports.
namespace margelo::nitro::rnduckdb { class HybridQueryResultSpec; }
// Forward declaration of `ExecuteOptions` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct ExecuteOptions; }
// Forward declaration of `HybridPreparedStatementSpec` to properly resolve imports.
namespace margelo::nitro::rnduckdb { class HybridPreparedStatementSpec; }
// Forward declaration of `HybridStreamingResultSpec` to properly resolve imports.
namespace margelo::nitro::rnduckdb { class HybridStreamingResultSpec; }
// Forward declaration of `HybridAppenderSpec` to properly resolve imports.
namespace margelo::nitro::rnduckdb { class HybridAppenderSpec; }
// Forward declaration of `AppenderOptions` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct AppenderOptions; }
// Forward declaration of `HybridDatabaseSpec` to properly resolve imports.
namespace margelo::nitro::rnduckdb { class HybridDatabaseSpec; }
// Forward declaration of `ConnectionInfo` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct ConnectionInfo; }
// Forward declaration of `AttachOptions` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct AttachOptions; }
// Forward declaration of `BatchResult` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct BatchResult; }
// Forward declaration of `BatchCommand` to properly resolve imports.
namespace margelo::nitro::rnduckdb { struct BatchCommand; }

#include "CloseOptions.hpp"
#include <optional>
#include <memory>
#include "HybridQueryResultSpec.hpp"
#include <string>
#include <NitroModules/Null.hpp>
#include <NitroModules/ArrayBuffer.hpp>
#include <variant>
#include <vector>
#include <NitroModules/Promise.hpp>
#include "ExecuteOptions.hpp"
#include "HybridPreparedStatementSpec.hpp"
#include <unordered_map>
#include "HybridStreamingResultSpec.hpp"
#include "HybridAppenderSpec.hpp"
#include "AppenderOptions.hpp"
#include <functional>
#include "HybridDatabaseSpec.hpp"
#include "ConnectionInfo.hpp"
#include "AttachOptions.hpp"
#include "BatchResult.hpp"
#include "BatchCommand.hpp"

namespace margelo::nitro::rnduckdb {

  using namespace margelo::nitro;

  /**
   * An abstract base class for `Database`
   * Inherit this class to create instances of `HybridDatabaseSpec` in C++.
   * You must explicitly call `HybridObject`'s constructor yourself, because it is virtual.
   * @example
   * ```cpp
   * class HybridDatabase: public HybridDatabaseSpec {
   * public:
   *   HybridDatabase(...): HybridObject(TAG) { ... }
   *   // ...
   * };
   * ```
   */
  class HybridDatabaseSpec: public virtual HybridObject {
    public:
      // Constructor
      explicit HybridDatabaseSpec(): HybridObject(TAG) { }

      // Destructor
      ~HybridDatabaseSpec() override = default;

    public:
      // Properties
      virtual bool getIsOpen() = 0;

    public:
      // Methods
      virtual void close(const std::optional<CloseOptions>& options) = 0;
      virtual std::shared_ptr<HybridQueryResultSpec> executeSync(const std::string& sql, const std::optional<std::vector<std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>>& params) = 0;
      virtual std::shared_ptr<Promise<std::shared_ptr<HybridQueryResultSpec>>> execute(const std::string& sql, const std::optional<std::vector<std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>>& params, const std::optional<ExecuteOptions>& options) = 0;
      virtual std::shared_ptr<HybridPreparedStatementSpec> prepare(const std::string& sql) = 0;
      virtual void cancel() = 0;
      virtual std::shared_ptr<HybridQueryResultSpec> executeSyncNamed(const std::string& sql, const std::unordered_map<std::string, std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>& params) = 0;
      virtual std::shared_ptr<Promise<std::shared_ptr<HybridQueryResultSpec>>> executeNamed(const std::string& sql, const std::unordered_map<std::string, std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>& params, const std::optional<ExecuteOptions>& options) = 0;
      virtual std::shared_ptr<Promise<std::shared_ptr<HybridStreamingResultSpec>>> stream(const std::string& sql, const std::optional<std::vector<std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>>& params, const std::optional<ExecuteOptions>& options) = 0;
      virtual std::shared_ptr<Promise<std::shared_ptr<HybridStreamingResultSpec>>> streamNamed(const std::string& sql, const std::unordered_map<std::string, std::variant<nitro::NullType, bool, int64_t, std::shared_ptr<ArrayBuffer>, std::string, double>>& params, const std::optional<ExecuteOptions>& options) = 0;
      virtual std::shared_ptr<HybridAppenderSpec> createAppender(const std::string& table, const std::optional<AppenderOptions>& options) = 0;
      virtual std::string getProfilingInfo() = 0;
      virtual void setProgressCallback(const std::function<void(double /* percentage */)>& callback) = 0;
      virtual void removeProgressCallback() = 0;
      virtual std::shared_ptr<HybridDatabaseSpec> connect() = 0;
      virtual ConnectionInfo connections() = 0;
      virtual void closeConnections() = 0;
      virtual void attach(const std::string& path, const std::string& alias, const std::optional<AttachOptions>& options) = 0;
      virtual void detach(const std::string& alias) = 0;
      virtual BatchResult executeBatchSync(const std::vector<BatchCommand>& commands) = 0;
      virtual std::shared_ptr<Promise<BatchResult>> executeBatch(const std::vector<BatchCommand>& commands) = 0;

    protected:
      // Hybrid Setup
      void loadHybridMethods() override;

    protected:
      // Tag for logging
      static constexpr auto TAG = "Database";
  };

} // namespace margelo::nitro::rnduckdb