Function remoteCopyFileInternal

pkg/wshrpc/wshremote/wshremote_file.go:75–108

remoteCopyFileInternal copies FROM local (this host) TO local (this host) Only supports copying files, not directories

(srcUri, destUri string, srcPathCleaned, destPathCleaned string, destHasSlash bool, overwrite bool)

// remoteCopyFileInternal copies FROM local (this host) TO local (this host)
// Only supports copying files, not directories
func remoteCopyFileInternal(srcUri, destUri string, srcPathCleaned, destPathCleaned string, destHasSlash bool, overwrite bool) error {
	srcFileStat, err := os.Stat(srcPathCleaned)
	if err != nil {
		return fmt.Errorf("cannot stat file %q: %w", srcPathCleaned, err)
	}
	if srcFileStat.IsDir() {
		return fmt.Errorf("copying directories is not supported")
	}
	if srcFileStat.Size() > RemoteFileTransferSizeLimit {
		return fmt.Errorf("file %q size %d exceeds transfer limit of %d bytes", srcPathCleaned, srcFileStat.Size(), RemoteFileTransferSizeLimit)
	}

	destFilePath, err := prepareDestForCopy(destPathCleaned, filepath.Base(srcPathCleaned), destHasSlash, overwrite)
	if err != nil {
		return err
	}

	srcFile, err := os.Open(srcPathCleaned)
	if err != nil {
		return fmt.Errorf("cannot open file %q: %w", srcPathCleaned, err)
	}
	defer srcFile.Close()

	destFile, err := os.OpenFile(destFilePath, os.O_CREATE|os.O_WRONLY|os.O_TRUNC, srcFileStat.Mode())
	if err != nil {
		return fmt.Errorf("cannot create file %q: %w", destFilePath, err)
	}
	defer destFile.Close()

	if _, err = io.Copy(destFile, srcFile); err != nil {
		return fmt.Errorf("cannot copy %q to %q: %w", srcUri, destUri, err)
	}
	return nil
}

// RemoteFileCopyCommand copies a file FROM somewhere TO here
func (impl *ServerImpl) RemoteFileCopyCommand(ctx context.Context, data wshrpc.CommandFileCopyData) (bool, error) {