Mercurial > repos > rhohensinner > galaxy_irods_interface
annotate main.py @ 0:7d8912d20007 draft
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
author | rhohensinner |
---|---|
date | Fri, 21 May 2021 09:51:30 +0000 |
parents | |
children | 19c1cecdfdfd |
rev | line source |
---|---|
0
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
1 ___author___ = "Richard Hohensinner" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
2 ___created___ = "04.02.2021" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
3 ___last_modified___ = "20.05.2021" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
4 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
5 # general imports |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
6 import os, sys, json |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
7 from shutil import copyfile |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
8 from datetime import datetime |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
9 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
10 # irods-client imports |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
11 from irods.session import iRODSSession |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
12 from irods.models import Collection, DataObject |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
13 from irods.query import SpecificQuery |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
14 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
15 # Tkinter imports |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
16 from tkinter import messagebox, Label, Button, Entry, Listbox, Tk, PhotoImage, Grid |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
17 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
18 # global variables |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
19 session = None |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
20 file_path_list = [] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
21 selected_file = "" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
22 session_success = False |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
23 selection_success = False |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
24 iRODSCredentials = {"host": "", "port": "", "user": "", "pw": "", "zone": ""} |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
25 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
26 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
27 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
28 # Main function of the iRODS tools |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
29 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
30 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
31 # JSON Object params (argv[1]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
32 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
33 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
34 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
35 def main(): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
36 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
37 # check input parameters |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
38 if len(sys.argv) == 2: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
39 params = json.loads(sys.argv[1]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
40 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
41 raise Exception("Invalid Parameters submitted!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
42 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
43 tool_type = params["tool_type"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
44 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
45 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
46 if params["tool_type"] != "up" and params["tool_type"] != "down": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
47 raise Exception("Invalid tool-type parameter submitted!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
48 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
49 raise Exception("No tool-type parameter submitted!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
50 is_download_call = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
51 if tool_type == "up": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
52 is_download_call = False |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
53 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
54 # check params for integrity |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
55 result_string, params_faulty = check_params(params) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
56 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
57 if params_faulty: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
58 raise Exception(result_string) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
59 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
60 global iRODSCredentials, session_success, selected_file, selection_success |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
61 iRODSCredentials["host"] = params["irods_host"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
62 iRODSCredentials["port"] = params["irods_port"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
63 iRODSCredentials["zone"] = params["irods_zone"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
64 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
65 # create login window |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
66 make_login_window() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
67 # check tool settings and start tool execution |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
68 if session_success: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
69 # initialize download tool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
70 if params["tool_type"] == "down": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
71 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
72 if params["selection_type"] == "explorer": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
73 make_file_select_window() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
74 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
75 if (params["file_path"] != ""): #and ("/" in params["file_path"]): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
76 selected_file = params["file_path"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
77 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
78 raise Exception("Invalid File Path submitted!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
79 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
80 if selection_success or params["selection_type"] == "path": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
81 params["user"] = iRODSCredentials["pw"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
82 params["password"] = iRODSCredentials["user"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
83 # start download routine |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
84 handle_download_call(params) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
85 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
86 raise Exception("File Selection failed (No file selected)") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
87 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
88 # initialize upload tool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
89 elif params["tool_type"] == "up": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
90 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
91 if session_success: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
92 params["user"] = iRODSCredentials["pw"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
93 params["password"] = iRODSCredentials["user"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
94 # start upload routine |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
95 handle_upload_call(params) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
96 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
97 raise Exception("Logging into iRODS failed") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
98 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
99 raise Exception("Logging into iRODS failed") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
100 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
101 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
102 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
103 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
104 # Login Window class for Tkinter |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
105 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
106 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
107 # Tk Window win |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
108 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
109 # (sets global variables iRODSCredentials, session and session_success) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
110 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
111 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
112 class LoginWindow: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
113 def __init__(self, win): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
114 self.window = win |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
115 self.lbl1 = Label(win, text='iRODS Username:') |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
116 self.lbl2 = Label(win, text='iRODS Password:') |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
117 self.t1 = Entry(bd=3) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
118 self.t2 = Entry(show="*") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
119 self.b1 = Button(win, text='Login', command=self.login) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
120 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
121 self.window.grid() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
122 Grid.rowconfigure(self.window, 0, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
123 Grid.rowconfigure(self.window, 1, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
124 Grid.rowconfigure(self.window, 2, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
125 Grid.rowconfigure(self.window, 3, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
126 Grid.rowconfigure(self.window, 4, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
127 Grid.columnconfigure(self.window, 0, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
128 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
129 self.lbl1.grid(row=0, column=0, padx="20", pady="1", sticky="w") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
130 self.t1.grid(row=1, column=0, padx="10", pady="1", sticky="nsew") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
131 self.lbl2.grid(row=2, column=0, padx="20", pady="1", sticky="w") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
132 self.t2.grid(row=3, column=0, padx="10", pady="1", sticky="nsew") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
133 self.b1.grid(row=4, column=0, padx="50", pady="10", sticky="nsew") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
134 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
135 def login(self): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
136 global iRODSCredentials |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
137 user = str(self.t1.get()) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
138 password = str(self.t2.get()) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
139 if user == "" or password == "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
140 self.window.iconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
141 messagebox.showerror("Error", "Username or Password empty!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
142 self.window.deiconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
143 return |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
144 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
145 iRODSCredentials["user"] = user |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
146 iRODSCredentials["pw"] = password |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
147 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
148 get_irods_session(self.window) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
149 if not session_success: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
150 return |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
151 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
152 self.window.destroy() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
153 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
154 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
155 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
156 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
157 # File Selection Window class for Tkinter |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
158 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
159 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
160 # Tk Window win |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
161 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
162 # (sets global variables selected_file and selection_success) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
163 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
164 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
165 class FileSelectWindow: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
166 def __init__(self, win): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
167 global session, iRODSCredentials |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
168 self.session = session |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
169 self.window = win |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
170 self.b1 = Button(win, text='Select', command=self.select) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
171 self.lb1 = Listbox(win) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
172 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
173 self.window.grid() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
174 Grid.rowconfigure(self.window, 0, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
175 Grid.rowconfigure(self.window, 1, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
176 Grid.columnconfigure(self.window, 0, weight=1) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
177 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
178 self.lb1.grid(row=0, column=0, padx="20", pady="1", sticky="nswe") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
179 self.b1.grid(row=1, column=0, padx="50", pady="1", sticky="ew") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
180 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
181 coll = session.collections.get("/" + iRODSCredentials["zone"] + "/" + "home" + "/" + iRODSCredentials["user"]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
182 file_list = [] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
183 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
184 self.get_files_from_collections(coll, file_list) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
185 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
186 for counter in range(len(file_list)): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
187 self.lb1.insert(counter, file_list[counter]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
188 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
189 def get_files_from_collections(self, coll, file_list): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
190 for obj in coll.data_objects: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
191 file_list.append(obj.path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
192 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
193 for col in coll.subcollections: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
194 self.get_files_from_collections(col, file_list) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
195 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
196 def select(self): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
197 global session, selected_file, selection_success |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
198 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
199 selection = self.lb1.get(self.lb1.curselection()) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
200 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
201 self.window.iconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
202 messagebox.showerror("Error", "No file selected!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
203 self.window.deiconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
204 return |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
205 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
206 selected_file = selection |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
207 selection_success = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
208 self.window.destroy() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
209 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
210 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
211 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
212 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
213 # Creates an iRODS session and sets the global session variable |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
214 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
215 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
216 # Tk Window window |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
217 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
218 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
219 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
220 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
221 def get_irods_session(window): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
222 global iRODSCredentials |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
223 host = iRODSCredentials["host"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
224 port = iRODSCredentials["port"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
225 user = iRODSCredentials["user"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
226 password = iRODSCredentials["pw"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
227 zone = iRODSCredentials["zone"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
228 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
229 iRODSsession = get_iRODS_connection(host=host, port=port, user=user, password=password, zone=zone) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
230 global session, session_success |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
231 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
232 coll = iRODSsession.collections.get("/" + zone + "/" + "home" + "/" + user) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
233 except Exception: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
234 window.iconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
235 messagebox.showerror("Error", "Invalid Authentification") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
236 window.deiconify() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
237 return |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
238 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
239 if coll: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
240 session = iRODSsession |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
241 session_success = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
242 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
243 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
244 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
245 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
246 # Helper function to initialize Login Window classes and Tk windows |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
247 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
248 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
249 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
250 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
251 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
252 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
253 def make_login_window(): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
254 window = Tk() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
255 LoginWindow(window) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
256 window.title('iRODS Login') |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
257 window.geometry("450x225+10+10") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
258 window.minsize(450, 225) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
259 window.tk.call('wm', 'iconphoto', window._w, PhotoImage(file='/home/richard/git/galaxy_irods_tools/login.png')) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
260 # alternative options: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
261 # window.iconphoto(False, PhotoImage(file='/path/to/ico/icon.png')) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
262 # window.iconbitmap("/home/richard/git/galaxy_irods_tools/login.ico") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
263 window.mainloop() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
264 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
265 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
266 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
267 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
268 # Helper function to initialize File Selection Window classes and Tk windows |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
269 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
270 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
271 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
272 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
273 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
274 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
275 def make_file_select_window(): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
276 window = Tk() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
277 FileSelectWindow(window) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
278 window.title('iRODS File Select') |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
279 window.geometry("450x225+10+10") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
280 window.minsize(450, 225) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
281 window.mainloop() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
282 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
283 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
284 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
285 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
286 # Checks whether arguments are valid and returns true/false depending on params |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
287 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
288 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
289 # Dict params |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
290 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
291 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
292 # String res_string |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
293 # Bool res_bool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
294 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
295 def check_params(params): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
296 res_string = "" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
297 res_bool = False |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
298 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
299 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
300 if params["irods_host"] == "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
301 res_string += "Host empty!\n" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
302 res_bool = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
303 if params["irods_port"] == "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
304 res_string += "Port empty!\n" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
305 res_bool = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
306 if params["irods_zone"] == "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
307 res_string += "Zone empty!\n" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
308 res_bool = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
309 if params["selection_type"] == "path" and params["file_path"] == "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
310 res_string += "Missing file path!\n" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
311 res_bool = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
312 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
313 raise Exception("Invalid/Missing Parameters") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
314 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
315 return res_string, res_bool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
316 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
317 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
318 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
319 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
320 # Function to handle iRODS download calls |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
321 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
322 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
323 # Dict params |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
324 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
325 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
326 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
327 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
328 def handle_download_call(params): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
329 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
330 global session, selected_file |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
331 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
332 # check if /ZONE/USER/...FILE... pattern is valid |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
333 if len(selected_file.split("/")) < 2: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
334 raise Exception("Path to file is not valid in iRODS") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
335 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
336 file_list = [] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
337 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
338 # check if file is a directory |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
339 if "." not in selected_file: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
340 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
341 coll = session.collections.get(selected_file) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
342 for file in coll.data_objects: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
343 file_list.append(file.path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
344 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
345 raise Exception("Invalid directory path specified!") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
346 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
347 file_list.append(selected_file) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
348 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
349 # get registry file |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
350 reg_file = "" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
351 for dirpath, dirnames, filenames in os.walk(params["galaxy_root"]): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
352 for fn in filenames: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
353 if fn == "irods_galaxy_registry.xml": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
354 reg_file = os.path.join(dirpath, fn) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
355 if reg_file != "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
356 break |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
357 if reg_file != "": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
358 break |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
359 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
360 # handle download for all files in file_list |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
361 for file in file_list: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
362 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
363 file_to_get = file |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
364 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
365 # handle path and file name |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
366 name_file_to_get = file_to_get.split("/")[-1] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
367 path_file_to_get = "/".join(file_to_get.split("/")[0:len(file_to_get.split("/")) - 1]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
368 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
369 # check iRODS filesystem |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
370 check_iRODS_destination(session, path_file_to_get, name_file_to_get) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
371 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
372 # get file object from iRODS |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
373 iRODS_file_object = session.data_objects.get(path_file_to_get + "/" + name_file_to_get) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
374 input_file = iRODS_file_object.open("r+") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
375 output_file = open(name_file_to_get, "wb") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
376 output_file.write(input_file.read()) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
377 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
378 input_file.close() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
379 output_file.close() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
380 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
381 abs_file_path = os.path.abspath(name_file_to_get) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
382 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
383 file_type = str(name_file_to_get.split(".")[-1]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
384 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
385 file_content = {"uuid": None, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
386 "file_type": "auto", |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
387 "space_to_tab": False, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
388 "dbkey": "?", |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
389 "to_posix_lines": True, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
390 "ext": file_type, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
391 "path": abs_file_path, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
392 "in_place": True, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
393 "dataset_id": params["job_id"], |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
394 "type": "file", |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
395 "is_binary": False, |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
396 "link_data_only": "copy_files", |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
397 "name": name_file_to_get |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
398 } |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
399 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
400 with open("temporal.json", "w") as fileParams: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
401 fileParams.write(json.dumps(file_content)) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
402 fileParams.close() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
403 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
404 # load file into Galaxy by using the integrated upload tool - Preparation |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
405 python_command = params["galaxy_root"] + "/tools/data_source/upload.py" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
406 arg1 = params["galaxy_root"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
407 arg2 = params["galaxy_datatypes"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
408 arg3 = os.path.abspath(fileParams.name) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
409 arg4 = params["job_id"] + ":" + params["out_dir"] + ":" + params["out_file"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
410 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
411 # copy sample registry.xml to working directory |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
412 copyfile(reg_file, params["galaxy_datatypes"]) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
413 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
414 # activate environment for new process call and call the python upload command either both with |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
415 sys.path.append(params["galaxy_root"] + "/lib") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
416 os.system("python -c \'import sys;sys.path.append(\"" + params["galaxy_root"] + "/lib\")\'" + " python " + |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
417 python_command + " " + arg1 + " " + arg2 + " " + arg3 + " " + arg4) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
418 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
419 # close connection |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
420 session.cleanup() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
421 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
422 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
423 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
424 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
425 # Function to handle iRODS upload calls |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
426 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
427 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
428 # Dict params |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
429 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
430 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
431 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
432 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
433 def handle_upload_call(params): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
434 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
435 global session, iRODSCredentials |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
436 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
437 path_to_file = params["up_file_path"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
438 name_of_file = params["up_file"] |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
439 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
440 coll_path = "/" + iRODSCredentials["zone"] + "/home/" + iRODSCredentials["user"] + "/galaxyupload" |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
441 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
442 coll = session.collections.get(coll_path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
443 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
444 coll = session.collections.create(coll_path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
445 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
446 now = datetime.now() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
447 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
448 # dd/mm/YY |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
449 day = now.strftime("%d%m%Y") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
450 time = now.strftime("%H%M%S") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
451 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
452 coll_path = coll_path + "/" + day |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
453 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
454 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
455 coll = session.collections.get(coll_path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
456 except: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
457 coll = session.collections.create(coll_path) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
458 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
459 irods_file_name = time + "_" + name_of_file |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
460 iRODS_file_object = session.data_objects.create(coll_path + "/" + irods_file_name) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
461 iRODS_file_object = session.data_objects.get(coll_path + "/" + irods_file_name) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
462 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
463 irods_file = iRODS_file_object.open("w") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
464 galaxy_file = open(path_to_file, "rb") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
465 content = galaxy_file.read() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
466 irods_file.write(content) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
467 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
468 # TODO can't close session without writing process finished - but reading/writing happens async. |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
469 # session.cleanup() |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
470 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
471 pass |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
472 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
473 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
474 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
475 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
476 # Function to initialize an iRODS Session - will raise an Exception if timeout is longer than 2 seconds |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
477 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
478 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
479 # String host |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
480 # String port |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
481 # String user |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
482 # String password |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
483 # String zone |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
484 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
485 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
486 # iRODSSession-object session |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
487 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
488 def get_iRODS_connection(host, port, user, password, zone): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
489 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
490 # initialize timeout checker - fires after 2 secs |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
491 import signal |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
492 signal.signal(signal.SIGALRM, timeout_checker) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
493 signal.alarm(2) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
494 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
495 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
496 session = iRODSSession(host=host, port=port, user=user, password=password, zone=zone) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
497 except Exception: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
498 raise Exception("There was a timeout creating the iRODS session") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
499 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
500 # void/reset alarm |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
501 signal.alarm(0) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
502 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
503 return session |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
504 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
505 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
506 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
507 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
508 # Helper function to raise timeout exception when SIGALRM fires |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
509 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
510 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
511 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
512 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
513 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
514 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
515 def timeout_checker(): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
516 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
517 raise Exception("iRODS session timeout") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
518 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
519 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
520 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
521 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
522 # Function to check if file exists in iRODS |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
523 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
524 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
525 # String path |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
526 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
527 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
528 # Bool ret_bool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
529 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
530 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
531 def check_if_file_exists(path): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
532 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
533 if os.path.isfile(path): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
534 ret_bool = True |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
535 else: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
536 ret_bool = False |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
537 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
538 return ret_bool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
539 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
540 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
541 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
542 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
543 # Function to check iRODS destination |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
544 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
545 # IN: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
546 # iRODSSession-object session |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
547 # String path |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
548 # String name |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
549 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
550 # OUT: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
551 # Bool ret_bool |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
552 # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
553 ######################################################################################################################## |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
554 def check_iRODS_destination(session, path, name): |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
555 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
556 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
557 session.collections.get(path.rstrip("/")) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
558 except Exception: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
559 raise Exception("Collection doesn't exist in iRODS file system") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
560 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
561 try: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
562 session.data_objects.get(path.rstrip("/") + "/" + name) |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
563 except Exception: |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
564 raise Exception("File doesn't exist in iRODS file system") |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
565 # -------------------------------------------------------------------------------------------------------------------- # |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
566 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
567 |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
568 if __name__ == "__main__": |
7d8912d20007
"planemo upload commit b2a00d9c24285fef0fb131d1832ecf4c337e5038-dirty"
rhohensinner
parents:
diff
changeset
|
569 main() |