add unexpected eof handler

internal/agent/sftp/config.go

@@ -37,9 +37,6 @@ func (s *SFTPConfig) GetRegistryKey() string {
 
 func InitializeSFTPConfig(svc service.Service, driveLetter string) (*SFTPConfig, error) {
 	var err error
-	if err != nil {
-		return nil, fmt.Errorf("InitializeLogger: failed to initialize logger -> %w", err)
-	}
 
 	baseKey, _, err := registry.CreateKey(registry.LOCAL_MACHINE, "Software\\PBSPlus\\Config", registry.QUERY_VALUE)
 	if err != nil {

internal/agent/sftp/eof.go

@@ -0,0 +1,28 @@
+package sftp
+
+import "io"
+
+type eofInjectingReaderAt struct {
+	file   io.ReaderAt
+	length int64
+}
+
+func NewEOFInjectingReaderAt(file io.ReaderAt, length int64) io.ReaderAt {
+	return &eofInjectingReaderAt{file: file, length: length}
+}
+
+func (r *eofInjectingReaderAt) ReadAt(p []byte, off int64) (n int, err error) {
+	if off >= r.length {
+		// If reading beyond the file length, return EOF to simulate a proper end.
+		return 0, io.EOF
+	}
+
+	// Attempt to read as usual.
+	n, err = r.file.ReadAt(p, off)
+	if err == io.ErrUnexpectedEOF || n < len(p) {
+		// If an unexpected EOF or partial read, return what we have and inject EOF.
+		return n, io.EOF
+	}
+
+	return n, err
+}

internal/agent/sftp/filelister.go

@@ -88,8 +88,8 @@ func (h *SftpHandler) setFilePath(r *sftp.Request) {
 	r.Filepath = filepath.Join(h.Snapshot.SnapshotPath, filepath.Clean(r.Filepath))
 }
 
-func (h *SftpHandler) fetch(path string, mode int) (*os.File, error) {
-	return os.OpenFile(path, mode, 0777)
+func (h *SftpHandler) fetch(path string) (*os.File, error) {
+	return os.Open(path)
 }
 
 func wildcardToRegex(pattern string) string {
@@ -175,13 +175,5 @@ func skipFile(path string, fileInfo os.FileInfo) bool {
 		}
 	}
 
-	if !fileInfo.IsDir() {
-		f, err := os.Open(path)
-		if err != nil {
-			return true
-		}
-		f.Close()
-	}
-
 	return false
 }

internal/agent/sftp/handler.go

@@ -40,12 +40,19 @@ func (h *SftpHandler) Fileread(r *sftp.Request) (io.ReaderAt, error) {
 	h.Snapshot.UpdateTimestamp()
 	h.setFilePath(r)
 
-	file, err := h.fetch(r.Filepath, os.O_RDONLY)
+	file, err := h.fetch(r.Filepath)
 	if err != nil {
 		log.Printf("error reading file: %v", err)
 		return nil, err
 	}
-	return file, nil
+
+	stat, err := os.Lstat(r.Filepath)
+	if err != nil {
+		log.Printf("error getting file stats: %v", err)
+		return nil, err
+	}
+
+	return NewEOFInjectingReaderAt(file, stat.Size()), nil
 }
 
 func (h *SftpHandler) Filewrite(r *sftp.Request) (io.WriterAt, error) {

internal/backend/mount/mount.go

@@ -60,7 +60,7 @@ func Mount(target *store.Target) (*AgentMount, error) {
 		"--sftp-user", "proxmox",
 		"--sftp-host", agentHost,
 		"--allow-other",
-		"--sftp-shell-type", "unix",
+		"--sftp-shell-type", "none",
 		":sftp:/", agentMount.Path,
 	}