libmutton/syncclient/oneOff.go

package syncclient

import (
	"errors"
	"strings"

	"github.com/rwinkhart/go-boilerplate/back"
	"github.com/rwinkhart/libmutton/global"
	"github.com/rwinkhart/libmutton/synccommon"
)

// ShearRemoteFromClient removes the target file or directory from
// the local system and calls the server to remove it remotely and
// add it to the deletions list.
// It can safely be called in offline mode, as well, so this is
// the intended interface for shearing (ShearLocal should only
// be used directly by the server binary).
func ShearRemoteFromClient(targetLocationIncomplete string) error {
	deviceID, isDir, err := synccommon.ShearLocal(targetLocationIncomplete, "") // remove the target from the local system and get the device ID of the client
	if err != nil {
		return errors.New("unable to shear target locally: " + err.Error())
	}

	sshClient, offlineMode, _, _, err := GetSSHClient()
	if offlineMode {
		goto end
	}
	if err != nil {
		return errors.New("unable to connect to SSH client: " + err.Error())
	}
	if deviceID == "" {
		return errors.New("unable to shear target remotely: no device ID found")
	}

	// ensure targetLocationIncomplete ends with a slash if it is a directory (for clarity in shear message)
	if isDir && !strings.HasSuffix(targetLocationIncomplete, "/") {
		targetLocationIncomplete += "/"
	}

	// call the server to remotely shear the target and add it to the deletions list
	_, err = GetSSHOutput(sshClient, "libmuttonserver shear", deviceID+"\n"+strings.ReplaceAll(targetLocationIncomplete, global.PathSeparator, global.FSPath))
	if err != nil {
		return errors.New("unable to shear target remotely: " + err.Error())
	}

	// close the SSH client
	err = sshClient.Close()
	if err != nil {
		return errors.New("unable to close SSH client: " + err.Error())
	}

end:
	back.Exit(0) // sync is not required after shearing since the target has already been removed from the local system
	return nil
}

// RenameRemoteFromClient renames oldLocationIncomplete to newLocationIncomplete on
// the local system and calls the server to perform the rename remotely and add the
// old target to the deletions list.
// It can safely be called in offline mode, as well, so this is the intended
// interface for renaming (RenameLocal should only be used directly by the server binary).
func RenameRemoteFromClient(oldLocationIncomplete, newLocationIncomplete string) error {
	err := synccommon.RenameLocal(oldLocationIncomplete, newLocationIncomplete, false) // move the target on the local system
	if err != nil {
		return errors.New("unable to rename target locally: " + err.Error())
	}

	deviceIDList, err := global.GenDeviceIDList()
	if err != nil {
		return errors.New("unable to generate device ID list: " + err.Error())
	}
	// create an SSH client
	sshClient, offlineMode, _, _, err := GetSSHClient()
	if offlineMode {
		goto end
	}
	if err != nil {
		return errors.New("unable to connect to SSH client: " + err.Error())
	}
	if deviceIDList[0].Name() == "" {
		return errors.New("unable to rename target remotely: no device ID found")
	}

	// call the server to move the target on the remote system and add the old target to the deletions list
	_, err = GetSSHOutput(sshClient, "libmuttonserver rename",
		(deviceIDList)[0].Name()+"\n"+
			strings.ReplaceAll(oldLocationIncomplete, global.PathSeparator, global.FSPath)+"\n"+
			strings.ReplaceAll(newLocationIncomplete, global.PathSeparator, global.FSPath))
	if err != nil {
		return errors.New("unable to rename target remotely: " + err.Error())
	}

	// close the SSH client
	err = sshClient.Close()
	if err != nil {
		return errors.New("unable to close SSH client: " + err.Error())
	}

end:
	back.Exit(0)
	return nil
}

// AddFolderRemoteFromClient creates a new entry-containing directory
// on the local system and calls the server to create the folder remotely.
// It can safely be called in offline mode, as well, so this is the
// intended interface for adding folders (AddFolderLocal should only be
// used directly by the server binary).
func AddFolderRemoteFromClient(targetLocationIncomplete string) error {
	err := synccommon.AddFolderLocal(targetLocationIncomplete) // add the folder on the local system
	if err != nil {
		return errors.New("unable to add folder locally: " + err.Error())
	}

	// create an SSH client
	sshClient, offlineMode, _, _, err := GetSSHClient()
	if offlineMode {
		goto end
	}
	if err != nil {
		return errors.New("unable to connect to SSH client: " + err.Error())
	}

	// call the server to create the folder remotely
	_, err = GetSSHOutput(sshClient, "libmuttonserver addfolder", strings.ReplaceAll(targetLocationIncomplete, global.PathSeparator, global.FSPath)) // call the server to create the folder remotely
	if err != nil {
		return errors.New("unable to add folder remotely: " + err.Error())
	}

	// close the SSH client
	err = sshClient.Close()
	if err != nil {
		return errors.New("unable to close SSH client: " + err.Error())
	}

end:
	back.Exit(0)
	return nil
}