Added experimental auto renew session for smbfs

mod/filesystem/abstractions/smbfs/smbfs.go

@@ -26,8 +26,10 @@ import (
 type ServerMessageBlockFileSystemAbstraction struct {
 	UUID      string
 	Hierarchy string
+	root      string
 	ipaddr    string
 	user      string
+	pass      string
 	conn      *net.Conn
 	session   *smb2.Session
 	share     *smb2.Share
@@ -62,16 +64,43 @@ func NewServerMessageBlockFileSystemAbstraction(uuid string, hierarchy string, i
 		return ServerMessageBlockFileSystemAbstraction{}, err
 	}
 
-	log.Println("[SMB-FS] Connected to remote: " + ipaddr)
-	return ServerMessageBlockFileSystemAbstraction{
+	fsAbstraction := ServerMessageBlockFileSystemAbstraction{
 		UUID:      uuid,
 		Hierarchy: hierarchy,
+		root:      rootShare,
 		ipaddr:    ipaddr,
 		user:      username,
+		pass:      password,
 		conn:      &conn,
 		session:   s,
 		share:     fs,
-	}, nil
+	}
+
+	//Create a ticker to check for renewing conncetion once an hour
+	ticker := time.NewTicker(1 * time.Hour)
+	done := make(chan bool)
+	go func(s *ServerMessageBlockFileSystemAbstraction) {
+		for {
+			select {
+			case <-done:
+				return
+			case <-ticker.C:
+				//Unable to list share due to session timeout. Close the handler and try connecting again.
+				s.share.Umount()
+				time.Sleep(300 * time.Millisecond)
+				fs, err := s.session.Mount(s.root)
+				if err != nil {
+					fmt.Println("[SMBFS] Unable to remount " + s.root)
+					return
+				}
+				fmt.Println("[SMBFS] Session Renewed for " + s.root)
+				s.share = fs
+			}
+		}
+	}(&fsAbstraction)
+
+	log.Println("[SMB-FS] Connected to remote: " + ipaddr)
+	return fsAbstraction, nil
 }
 
 func (a ServerMessageBlockFileSystemAbstraction) Chmod(filename string, mode os.FileMode) error {

mod/filesystem/fssort/fssort.go

@@ -1,7 +1,6 @@
 package fssort
 
 import (
-	"fmt"
 	"io/fs"
 	"path/filepath"
 	"sort"
@@ -23,7 +22,6 @@ func SortFileList(filelistRealpath []string, fileInfos []fs.FileInfo, sortMode s
 	parsedFilelist := []*sortBufferedStructure{}
 	if len(filelistRealpath) != len(fileInfos) {
 		//Invalid usage
-		fmt.Println("[fssort] Invalid Usage!")
 		return filelistRealpath
 	}
 	for i, file := range filelistRealpath {