Fix windows build

bolcom · May 19, 2024 · a377e0d · a377e0d
1 parent 3159845
commit a377e0d
Show file tree

Hide file tree

Showing 2 changed files with 147 additions and 19 deletions.
diff --git a/.github/workflows/rust.yml b/.github/workflows/rust.yml
@@ -80,3 +80,111 @@ jobs:
         run: cargo build  --workspace
       - name: Build Docs
         run: cargo doc --workspace --no-deps
+
+  build-linux-gnu:
+    runs-on: ubuntu-latest
+    name: Build for Linux (GNU)
+    env:
+      target: x86_64-unknown-linux-gnu
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0  # Otherwise the code that retrieves the git version doesn't work
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.RUST_VERSION }}
+          override: true
+          default: true
+          target: ${{ env.target }}
+      - name: Install build dependencies
+        run: sudo apt-get update && sudo apt-get install -y libpam-dev
+      - name: Build for Linux (GNU)
+        run: cargo build --target=${{ env.target }}
+
+  build-linux-musl:
+    runs-on: ubuntu-latest
+    name: Build for Linux (MUSL)
+    env:
+      target: x86_64-unknown-linux-musl
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0  # Otherwise the code that retrieves the git version doesn't work
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.RUST_VERSION }}
+          override: true
+          default: true
+          target: ${{ env.target }}
+      - name: Install build dependencies
+        run: sudo apt-get update && sudo apt-get install -y musl-tools
+      - name: Build for Linux (MUSL)
+        run: RUSTFLAGS="-C target-feature=+crt-static" cargo build --target=${{ env.target }}
+
+  build-windows:
+    runs-on: windows-latest
+    name: Build for Windows
+    env:
+      trget: x86_64-pc-windows-msvc
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0  # Otherwise the code that retrieves the git version doesn't work
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.RUST_VERSION }}
+          override: true
+          default: true
+          target: ${{ env.trget }}
+      - name: Build for Windows
+        run: cargo build --target=${{ env.trget }}
+
+  build-macos-intel:
+    runs-on: macos-latest
+    name: Build for macOS (Intel)
+    env:
+      target: x86_64-apple-darwin
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0  # Otherwise the code that retrieves the git version doesn't work
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.RUST_VERSION }}
+          override: true
+          default: true
+          target: ${{ env.target }}
+      - name: Build for macOS (Intel)
+        run: cargo build --target=${{ env.target }}
+
+  build-macos-arm:
+    runs-on: macos-latest
+    name: Build for macOS (ARM)
+    env:
+      target: aarch64-apple-darwin
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v3
+        with:
+          fetch-depth: 0  # Otherwise the code that retrieves the git version doesn't work
+      - name: Install Rust toolchain
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.RUST_VERSION }}
+          override: true
+          default: true
+          target: ${{ env.target }}
+      - name: Install Rosetta
+        if: runner.os == 'macOS' && runner.arch == 'arm64'
+        run: softwareupdate --install-rosetta --agree-to-license
+      - name: Build
+        run: cargo build --target=${{ env.target }}
+
diff --git a/src/server/ftpserver/listen.rs b/src/server/ftpserver/listen.rs
@@ -6,6 +6,7 @@ use crate::server::shutdown;
 use crate::{auth::UserDetail, server::controlchan, storage::StorageBackend};
 use std::ffi::OsString;
 use std::net::SocketAddr;
+#[cfg(unix)]
 use std::os::fd::AsRawFd;
 use std::sync::Arc;
 use tokio::net::TcpListener;
@@ -49,25 +50,16 @@ where
                 Ok((tcp_stream, socket_addr)) => {
                     slog::info!(logger, "Incoming control connection from {:?}", socket_addr);
                     if let Some(helper) = connection_helper.as_ref() {
-                        slog::info!(logger, "Spawning {:?}", helper);
-                        let fd = tcp_stream.as_raw_fd();
-                        nix::fcntl::fcntl(fd, nix::fcntl::FcntlArg::F_SETFD(nix::fcntl::FdFlag::empty())).unwrap();
-                        let result = tokio::process::Command::new(helper)
-                            .args(connection_helper_args.iter())
-                            .arg(fd.to_string())
-                            .spawn();
-                        let logger2 = logger.clone();
-                        match result {
-                            Ok(mut child) => {
-                                tokio::spawn(async move {
-                                    let child_status = child.wait().await;
-                                    slog::debug!(logger2, "helper process exited {:?}", child_status);
-                                });
-                            }
-                            Err(err) => {
-                                slog::error!(logger, "Could not spawn helper process for connection from {:?}: {:?}", socket_addr, err);
-                            }
-                        }
+                        slog::info!(logger, "Spawning connection helper: {:?}", helper);
+                        #[cfg(unix)]
+                        Self::spawn_helper(&logger, helper, &connection_helper_args, &tcp_stream, socket_addr);
+                        #[cfg(not(unix))]
+                        slog::error!(
+                            logger,
+                            "Cannot run helper {:?} {:?}, sandboxing feature not available",
+                            helper,
+                            connection_helper_args
+                        );
                     } else {
                         let result =
                             controlchan::spawn_loop::<Storage, User>((&options).into(), tcp_stream, None, None, shutdown_listener, failed_logins.clone()).await;
@@ -82,4 +74,32 @@ where
             }
         }
     }
+
+    #[cfg(unix)]
+    fn spawn_helper(
+        logger: &slog::Logger,
+        helper: &OsString,
+        connection_helper_args: &[OsString],
+        tcp_stream: &tokio::net::TcpStream,
+        socket_addr: SocketAddr,
+    ) {
+        let fd = tcp_stream.as_raw_fd();
+        nix::fcntl::fcntl(fd, nix::fcntl::FcntlArg::F_SETFD(nix::fcntl::FdFlag::empty())).unwrap();
+        let result = tokio::process::Command::new(helper)
+            .args(connection_helper_args.iter())
+            .arg(fd.to_string())
+            .spawn();
+        let logger2 = logger.clone();
+        match result {
+            Ok(mut child) => {
+                tokio::spawn(async move {
+                    let child_status = child.wait().await;
+                    slog::debug!(logger2, "helper process exited {:?}", child_status);
+                });
+            }
+            Err(err) => {
+                slog::error!(logger, "Could not spawn helper process for connection from {:?}: {:?}", socket_addr, err);
+            }
+        }
+    }
 }