Preserve symlinks in file copy

src/bin/dosh-client.rs

@@ -1866,6 +1866,30 @@ impl FileServiceClient {
             other => bail!("unexpected mkdir response: {other:?}"),
         }
     }
+
+    fn readlink(&mut self, path: &str) -> Result<String> {
+        self.send(FileRequest::Readlink {
+            path: path.to_string(),
+        })?;
+        match self.recv()? {
+            FileResponse::LinkTarget { target } => Ok(target),
+            FileResponse::Error { message } => Err(anyhow!(message)),
+            other => bail!("unexpected readlink response: {other:?}"),
+        }
+    }
+
+    fn symlink(&mut self, path: &str, target: &str, overwrite: bool) -> Result<()> {
+        self.send(FileRequest::Symlink {
+            path: path.to_string(),
+            target: target.to_string(),
+            overwrite,
+        })?;
+        match self.recv()? {
+            FileResponse::Ok => Ok(()),
+            FileResponse::Error { message } => Err(anyhow!(message)),
+            other => bail!("unexpected symlink response: {other:?}"),
+        }
+    }
 }
 
 fn run_cp_command(_config: &dosh::config::ClientConfig, args: &Args) -> Result<()> {
@@ -2197,6 +2221,18 @@ fn upload_path(
     let metadata =
         fs::symlink_metadata(local).with_context(|| format!("stat {}", local.display()))?;
     let remote = upload_destination(client, local, remote, metadata.is_dir())?;
+    if metadata.file_type().is_symlink() {
+        let target =
+            fs::read_link(local).with_context(|| format!("readlink {}", local.display()))?;
+        let target = target
+            .to_str()
+            .ok_or_else(|| anyhow!("symlink target is not valid UTF-8: {}", local.display()))?;
+        client.symlink(&remote, target, opts.overwrite)?;
+        if opts.progress {
+            eprintln!("linked {} -> {}", remote, target);
+        }
+        return Ok(());
+    }
     if metadata.is_dir() {
         anyhow::ensure!(
             opts.recursive,
@@ -2343,8 +2379,9 @@ fn download_path(
             Ok(())
         }
         FileKind::File => download_file(client, remote, &destination, &meta, opts),
+        FileKind::Symlink => download_symlink(client, remote, &destination, opts),
         _ => Err(anyhow!(
-            "remote path is not a regular file or directory: {remote}"
+            "remote path is not a regular file, directory, or symlink: {remote}"
         )),
     }
 }
@@ -2377,8 +2414,16 @@ fn copy_remote_path(
             Ok(())
         }
         FileKind::File => copy_remote_file(src_client, dst_client, src, &dst, &meta, opts),
+        FileKind::Symlink => {
+            let target = src_client.readlink(src)?;
+            dst_client.symlink(&dst, &target, opts.overwrite)?;
+            if opts.progress {
+                eprintln!("linked {dst} -> {target}");
+            }
+            Ok(())
+        }
         _ => Err(anyhow!(
-            "remote path is not a regular file or directory: {src}"
+            "remote path is not a regular file, directory, or symlink: {src}"
         )),
     }
 }
@@ -2609,6 +2654,45 @@ fn download_file(
     }
 }
 
+fn download_symlink(
+    client: &mut FileServiceClient,
+    remote: &str,
+    local: &Path,
+    opts: &CpOptions,
+) -> Result<()> {
+    if let Some(parent) = local.parent()
+        && !parent.as_os_str().is_empty()
+    {
+        fs::create_dir_all(parent).with_context(|| format!("create {}", parent.display()))?;
+    }
+    let target = client.readlink(remote)?;
+    create_local_symlink(local, &target, opts.overwrite)?;
+    if opts.progress {
+        eprintln!("linked {} -> {}", local.display(), target);
+    }
+    Ok(())
+}
+
+#[cfg(unix)]
+fn create_local_symlink(path: &Path, target: &str, overwrite: bool) -> Result<()> {
+    if let Ok(metadata) = fs::symlink_metadata(path) {
+        anyhow::ensure!(overwrite, "destination exists: {}", path.display());
+        anyhow::ensure!(
+            !metadata.is_dir(),
+            "destination is a directory: {}",
+            path.display()
+        );
+        fs::remove_file(path).with_context(|| format!("remove {}", path.display()))?;
+    }
+    std::os::unix::fs::symlink(target, path)
+        .with_context(|| format!("symlink {} -> {}", path.display(), target))
+}
+
+#[cfg(not(unix))]
+fn create_local_symlink(_path: &Path, _target: &str, _overwrite: bool) -> Result<()> {
+    bail!("symlink creation is not supported on this client platform")
+}
+
 fn hash_prefix(file: &mut fs::File, bytes: u64, hasher: &mut Sha256) -> Result<()> {
     file.seek(std::io::SeekFrom::Start(0))?;
     let mut remaining = bytes;