From 8b8845e452b45b765c0c74a388296d10e91787fc Mon Sep 17 00:00:00 2001 From: Samo Penic <samo.penic@gmail.com> Date: Tue, 28 Nov 2017 21:03:17 +0000 Subject: [PATCH] Changed the executabe to tssystem ;) --- trisurf/Remote.py | 57 ++++++++++++++++++++++++++++++++++++++------------------- 1 files changed, 38 insertions(+), 19 deletions(-) diff --git a/trisurf/Remote.py b/trisurf/Remote.py index 8da08be..aec5762 100644 --- a/trisurf/Remote.py +++ b/trisurf/Remote.py @@ -1,6 +1,5 @@ import paramiko - - +import os.path class Connection: def __init__(self, hostname, port=22, username=None, password=None): @@ -21,23 +20,21 @@ def connect(self, Timeout=5): if(not self.connected): - try: - print("Trying to connect to: "+self.username+"@"+self.hostname+":"+str(self.port)+".") - self.ssh.connect(self.hostname, username=self.username, password=self.password, port=self.port, timeout=Timeout) - self.connected=True - except: - print("Error establishing connection with "+self.username+"@"+self.hostname+":"+str(self.port)+".") - exit(1) +# try: + print("Trying to connect to: "+self.username+"@"+self.hostname+":"+str(self.port)+".") + self.ssh.connect(self.hostname, username=self.username, password=self.password, port=self.port, timeout=Timeout) + self.connected=True +# except: +# print("Error establishing connection with "+self.username+"@"+self.hostname+":"+str(self.port)+".") +# self.connected=False +# exit(1) else: print("Already connected!") return def disconnect(self): if(self.connected): - try: - self.ssh.close() - except: - print("Cannot disconect. Unknown error.") + self.ssh.close() else: print("Cannot disconect. Already disconnected.") self.connected=False @@ -56,18 +53,40 @@ print("Cannot execute remote commands. Connect first.") def send_file(self, local, remote): - sftp=self.ssh.open_sftp() - sftp.put(local,remote) - sftp.close() + pass +# sftp=self.ssh.open_sftp() +# sftp.put(local,remote) +# sftp.close() def receive_file(self,remote,local): - sftp=self.ssh.open_sftp() - sftp.get(remote,local) - sftp.close() + pass +# sftp=self.ssh.open_sftp() +# sftp.get(remote,local) +# sftp.close() def mkdir_remote(self,directory): sftp=self.ssh.open_sftp() sftp.mkdir(directory) sftp.close() + def mkdir_p(self,sftp, remote_directory): + """Change to this directory, recursively making new folders if needed. + Returns True if any folders were created. Recursive algorithm.""" + if remote_directory == '/': + # absolute path so change directory to root + sftp.chdir('/') + return + if remote_directory == '': + # top-level relative directory must exist + return + try: + sftp.chdir(remote_directory) # sub-directory exists + except IOError: + dirname, basename = os.path.split(remote_directory.rstrip('/')) + self.mkdir_p(sftp, dirname) # make parent directories + sftp.mkdir(basename) # sub-directory missing, so created it + sftp.chdir(basename) + return True + def send_multiple_files_in_directory(self,local_files,directory): + pass -- Gitblit v1.9.3