Add http entry point

Author: matthewmturner

Cargo.toml

@@ -17,7 +17,7 @@ version = "0.2.2"
 arrow-flight = { version = "54.1.0", features = [
   "flight-sql-experimental",
 ], optional = true }
-axum = "0.8.1"
+axum = { version = "0.8.1", optional = true }
 clap = { version = "4.5.27", features = ["derive"] }
 color-eyre = "0.6.3"
 crossterm = { version = "0.28.1", features = ["event-stream"] }
@@ -75,6 +75,7 @@ flightsql = [
 ]
 functions-json = ["datafusion-app/functions-json"]
 functions-parquet = ["datafusion-app/functions-parquet"]
+http = ["axum"]
 hudi = ["datafusion-app/hudi"]
 huggingface = ["datafusion-app/huggingface"]
 iceberg = ["datafusion-app/iceberg"]

src/args.rs

@@ -120,6 +120,11 @@ impl DftArgs {
 
 #[derive(Clone, Debug, Subcommand)]
 pub enum Command {
+    /// Start a HTTP server
+    ServeHttp {
+        #[clap(short, long)]
+        config: Option<String>,
+    },
     /// Start a FlightSQL server
     ServeFlightSql {
         #[clap(short, long)]

src/http_server/mod.rs

@@ -0,0 +1,23 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you under the Apache License, Version 2.0 (the
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+use crate::{args::DftArgs, config::AppConfig};
+use color_eyre::Result;
+
+pub async fn try_run(cli: DftArgs, config: AppConfig) -> Result<()> {
+    Ok(())
+}

src/lib.rs

@@ -4,6 +4,8 @@ pub mod config;
 pub mod execution;
 #[cfg(feature = "flightsql")]
 pub mod flightsql_server;
+#[cfg(feature = "http")]
+pub mod http_server;
 pub mod telemetry;
 pub mod test_utils;
 pub mod tui;

src/main.rs

@@ -18,7 +18,7 @@
 use clap::Parser;
 use color_eyre::Result;
 #[cfg(feature = "flightsql")]
-use datafusion_dft::{args::Command, flightsql_server};
+use datafusion_dft::{args::Command, flightsql_server, http_server};
 use datafusion_dft::{args::DftArgs, cli, config::create_config, tui};
 
 fn main() -> Result<()> {
@@ -58,6 +58,11 @@ async fn app_entry_point(cli: DftArgs) -> Result<()> {
     if let Some(Command::ServeFlightSql { .. }) = cli.command {
         flightsql_server::try_run(cli.clone(), cfg.clone()).await?;
     }
+    #[cfg(feature = "http")]
+    if let Some(Command::ServeHttp { .. }) = cli.command {
+        http_server::try_run(cli.clone(), cfg.clone()).await?;
+    }
+
     if !cli.files.is_empty() || !cli.commands.is_empty() {
         cli::try_run(cli, cfg).await?;
     } else {