From 9e80b8cd1e44fcf863d926055d9fa458db46e0d3 Mon Sep 17 00:00:00 2001
From: Joel Klinghed <the_jk@spawned.biz>
Date: Sun, 26 Jan 2025 21:58:42 +0100
Subject: Add basic git support

Pushing a commit to a new branch creates a review.

Each project has its own git directory, with githooks installed
that talkes with server process via unix sockets.
---
 server/src/fs_utils.rs | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 54 insertions(+)
 create mode 100644 server/src/fs_utils.rs

(limited to 'server/src/fs_utils.rs')

diff --git a/server/src/fs_utils.rs b/server/src/fs_utils.rs
new file mode 100644
index 0000000..7905d01
--- /dev/null
+++ b/server/src/fs_utils.rs
@@ -0,0 +1,54 @@
+#![allow(dead_code)]
+
+use std::io;
+use std::path::Path;
+use tokio::fs;
+
+pub async fn create_dir_allow_existing(path: impl AsRef<Path>) -> io::Result<()> {
+    match fs::create_dir(path).await {
+        Ok(_) => Ok(()),
+        Err(e) => {
+            if e.kind() == io::ErrorKind::AlreadyExists {
+                Ok(())
+            } else {
+                Err(e)
+            }
+        }
+    }
+}
+
+pub async fn remove_file_allow_not_found(path: impl AsRef<Path>) -> io::Result<()> {
+    match fs::remove_file(path).await {
+        Ok(_) => Ok(()),
+        Err(e) => {
+            if e.kind() == io::ErrorKind::NotFound {
+                Ok(())
+            } else {
+                Err(e)
+            }
+        }
+    }
+}
+
+pub async fn symlink_update_existing(
+    src: impl AsRef<Path>,
+    dst: impl AsRef<Path>,
+) -> io::Result<()> {
+    let src = src.as_ref();
+    let dst = dst.as_ref();
+    match fs::symlink(&src, &dst).await {
+        Ok(_) => Ok(()),
+        Err(e) => {
+            if e.kind() == io::ErrorKind::AlreadyExists {
+                let path = fs::read_link(&dst).await?;
+                if path == src {
+                    return Ok(());
+                }
+                fs::remove_file(&dst).await?;
+                fs::symlink(&src, &dst).await
+            } else {
+                Err(e)
+            }
+        }
+    }
+}
-- 
cgit v1.2.3-70-g09d2