Skip to content
This repository has been archived by the owner on Oct 24, 2023. It is now read-only.

Refactored to use os.path.join for composing paths #8

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Refactored to use os.path.join for composing paths #8

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
185 changes: 104 additions & 81 deletions shrp2c16/gui/app.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,136 +24,148 @@
class MyApp:
""" Sample request handler class. """
popen = None

cwd = os.getcwd()
project_name = 'project'
project_dir = os.path.join(cwd, '../projects', project_name)

def scenarioes(self, _):
path = os.getcwd()+'\\..\\projects\\project'
directories = []
path = self.project_dir
if os.path.exists(path):
for directory in os.listdir(os.getcwd()+'\\..\\projects\\project'):
for directory in os.listdir(path):
if directory != 'parameters' and directory != 'reports':
directories.append(directory)
else:
os.makedirs(path)
directories = os.listdir(os.getcwd()+'\\..\\projects\\project')
directories = os.listdir(path)
return simplejson.dumps({"scenarios":directories})
scenarioes.exposed=True

def scenarioes_to_copy(self, _):
root_scenarios = []
root_scenarios.append("template")
scenarios = []
for directory in os.listdir(os.getcwd()+'\\..\\projects\\project'):
for directory in os.listdir(self.project_dir):
if directory != "parameters" and directory != "reports":
scenarios.append(directory)
return simplejson.dumps({"root_scenarios":root_scenarios, "scenarios":scenarios})

scenarioes_to_copy.exposed = True

def runstatus(self, _):
with open(os.getcwd()+'\\..\\projects\\stdout.txt', "r") as f:
with open(os.path.join(self.cwd, '../projects/stdout.txt'), "r") as f:
content = f.readline()
return simplejson.dumps({"output":content})
runstatus.exposed=True

def state_files(self, name, _):
files = os.listdir(os.getcwd()+'\\..\\projects\\project\\'+name+'\\parameters')
files = os.listdir(os.path.join(self.project_dir, name, 'parameters'))
return simplejson.dumps({"files":files})
state_files.exposed=True

def open_output_directory(self, name, _):
webbrowser.open(name)
return simplejson.dumps({"success":"true"})
open_output_directory.exposed=True

def output_directories(self, name, _):
files = os.listdir(os.getcwd()+'\\..\\projects\\project\\' + name + '\\outputs\\')
directory = os.getcwd()+'\\..\\projects\\project\\' + name + '\\outputs\\'
files = os.listdir(os.path.join(self.project_dir, name, 'outputs'))
directory = os.listdir(os.path.join(self.project_dir, name, 'outputs/'))
return simplejson.dumps({"files":files, "directory":directory})
output_directories.exposed=True

def output_files(self, name, _):
files = os.listdir(os.getcwd()+'\\..\\projects\\project\\' + name + '\\outputs\\')
files = os.listdir(os.path.join(self.project_dir, name, 'outputs/'))
return simplejson.dumps({"files":files})
output_files.exposed=True

def scenario(self,name, _):
files = os.listdir(os.getcwd()+'\\..\\projects\\project\\' + name + '\\inputs')
files = os.listdir(os.path.join(self.project_dir, name, 'inputs/'))
file_edits = [False for file in files]
return simplejson.dumps({"files":files, "file_edits":file_edits})
scenario.exposed=True

def get_default_state(self, _):
state = None
path =os.getcwd()+'\\state.txt'
path =os.path.join(self.cwd, 'state.txt')
if os.path.exists(path):
with open(path, "r") as f:
state = f.readlines()
return simplejson.dumps({"state":state})
get_default_state.exposed=True

def set_default_state(self, state, _):
state_file = open(os.getcwd()+'\\state.txt', "w")
path = os.path.join(self.cwd, 'state.txt')
state_file = open(path, "w")
state_file.write(state)
state_file.close()
set_default_state.exposed=True

def new_scenario(self, name, fromScenario, isFirst, _):
newdir = os.getcwd()+'\\..\\projects\\Project\\' + name
newdir = os.path.join(self.project_dir, name)
if not os.path.isdir(newdir):
if fromScenario.startswith('template'):
copytree(os.getcwd() + '\\..\\projects\\Demo Project\\base', os.getcwd()+'\\..\\projects\\project\\' + name + '')
else:
copytree(os.getcwd() + '\\..\\projects\\project\\'+fromScenario, os.getcwd()+'\\..\\projects\\project\\' + name)
timestamp_file = open(os.getcwd()+'\\..\\projects\\project\\'+name+'\\time.txt', "w")
copytree(os.path.join(self.cwd, '../projects/Demo Project/base'),
os.path.join(self.project_dir, name))
else:
copytree(os.path.join(self.project_dir, fromScenario),
os.path.join(self.project_dir, name))
timestamp_file = open(os.path.join(self.project_dir,name, 'time.txt'), "w")
timestamp_file.write(strftime("%a %b %d %H:%M:%S %Y", localtime()))
timestamp_file.close()
return simplejson.dumps({"success":True})
else:
return simplejson.dumps({"success":False})
new_scenario.exposed = True

def delete_scenario(self, name, _):
shutil.rmtree(os.getcwd()+'\\..\\projects\\project\\' + name)
shutil.rmtree(os.path.join(self.project_dir, name))
try:
shutil.rmtree(os.getcwd() + '\\views\\scenarios\\' + name)
shutil.rmtree(os.path.join(self.cwd, 'views/scenarios/', name))
except:
pass
return simplejson.dumps({"success":True})
delete_scenario.exposed=True

def loadTextFile(self, name, fileName, _):
out = [[line.strip()] for line in open(os.getcwd()+'\\scenarios\\' + name + '\\inputs\\'+fileName)]
filepath = os.path.join(self.cwd, 'scenarios/', name, 'inputs/', fileName)
out = [[line.strip()] for line in open(filepath)]
return json.dumps({"data":out})
loadTextFile.exposed = True

def loadoutputcsvfile(self, name,fileName, _):
with open(os.getcwd()+'\\..\\projects\\project\\' + name + '\\outputs\\'+fileName) as csvfile:
filepath = os.path.join(self.project_dir, name, 'outputs/', fileName)
with open(filepath) as csvfile:
filereader = csv.reader(csvfile)
out = [rowItem for rowItem in filereader]
return json.dumps({"data":out})
loadoutputcsvfile.exposed=True

def load_documentation(self, filename, _):
out = ""
for line in open(os.getcwd()+'\\views\\docs\\' + filename, encoding="utf8"):\
filepath = os.path.join(self.cwd, 'views/docs/', filename)
for line in open(filepath, encoding="utf8"):\
out += line
return json.dumps({"data":out})
load_documentation.exposed=True

def loadcsvfile(self, name, fileName, _):
with open(os.getcwd()+'\\..\\projects\\project\\'+name+'\\inputs\\' +fileName) as csvfile:
filepath = os.path.join(self.project_dir, name, 'inputs/', fileName)
with open(filepath) as csvfile:
filereader = csv.reader(csvfile)
out = [rowItem for rowItem in filereader]
return json.dumps({"data":out})
loadcsvfile.exposed=True

def loadstatetextfile(self, name, fileName, directory, _):
out = [[line.strip()] for line in open(os.getcwd()+'\\model\\states\\' + name + ('\\' + directory if directory != 'root' else '') + '\\'+fileName)]
directory = directory if directory != 'root' else ''
filepath = os.path.join(self.cwd, 'model/states/', directory, filename)
out = [[line.strip()] for line in open(filepath)]
return json.dumps({"data":out})
loadstatetextfile.exposed = True

def loadReportSettings(self, _):
with open(os.getcwd()+'\\..\\scripts\\outputs.csv') as csvfile:
with open(os.path.join(self.cwd, '../scripts/outputs.csv')) as csvfile:
filereader = csv.reader(csvfile)
out = [rowItem for rowItem in filereader]
return json.dumps({"data":out})
Expand All @@ -176,100 +188,110 @@ def runReport(self, **kw):
if isinstance(passinmetrics, list):
metrics = passinmetrics
else:
metrics.append(passinmetrics)
metrics.append(passinmetrics)

measures = []
passinmeasure = kw.pop('measures[]', [])

if isinstance(passinmeasure, list):
measures = passinmeasure
else:
measures.append(passinmeasure)
measures.append(passinmeasure)
test = []
images = []
for metric in metrics:
for measure in measures:
metric_array = metric.split('_')
images.append(scenarios_dash +'_'+metric_array[1] + '_'+metric_array[0] + '_'+ measure+'.jpeg')
MyApp.popen = subprocess.Popen([os.getcwd()+"\\..\\R\\bin\\Rscript", os.getcwd() + '\\..\\scripts\\SmartGAP_Reports.r', '-s', scenarios_delimited, '-p', '"'+metric_array[1]+'"', '-a', '"'+metric_array[0]+'"', '-m', '"'+measure+'"'],
cwd=os.getcwd() + '\\..\\projects\\project\\Base',
stdout = subprocess.PIPE,
stderr = subprocess.STDOUT)
cmd = os.path.join(self.cwd, '../R/bin/Rscript')
script = os.path.join(self.cwd, '../scripts/SmartGAP_Reports.r')
MyApp.popen = subprocess.Popen([cmd, script, '-s', scenarios_delimited, '-p', '"'+metric_array[1]+'"', '-a', '"'+metric_array[0]+'"', '-m', '"'+measure+'"'],
cwd=os.path.join(self.cwd(), '../projects/project/Base'), #TODO: why Base is hardcoded here?
stdout = subprocess.PIPE,
stderr = subprocess.STDOUT)
MyApp.popen.wait()

return json.dumps({'scenarios':scenarios, 'metrics':metrics, 'images':images, 'test':test})#, 'test':test})
runReport.exposed = True

def loadstatecsvfile(self, fileName, directory, name, _):
with open(os.getcwd()+'\\..\\projects\\project\\'+name+'\\parameters\\'+fileName) as csvfile:
filepath = os.path.join(self.project_dir, name, 'parameters/', fileName)
with open(filepath) as csvfile:
filereader = csv.reader(csvfile)
out = [rowItem for rowItem in filereader]
return json.dumps({"data":out})

loadstatecsvfile.exposed=True
def savecsvfile(self, data, name, fileName):

def savecsvfile(self, data, name, fileName):
data = simplejson.loads(data)
with open(os.getcwd()+'\\..\\projects\\project\\' + name + '\\inputs\\'+fileName, 'w', newline='') as csvfile:
filepath = os.path.join(self.project_dir, name, 'inputs/', fileName)
with open(filepath, 'w', newline='') as csvfile:
filewriter = csv.writer(csvfile)
filewriter.writerows(data)
return simplejson.dumps({"success":True})
savecsvfile.exposed=True
def saveTextFile(self, data, name, fileName):

def saveTextFile(self, data, name, fileName):
data = simplejson.loads(data)
with open(os.getcwd()+'\\scenarios\\' + name + '\\inputs\\'+fileName, "wb") as file:
filepath = os.path.join(self.project_dir, name, 'inputs/', fileName)
with open(filepath, "wb") as file:
for line in data:
file.write(line[0] + "\n")
return simplejson.dumps({"success":True})
saveTextFile.exposed=True

def savestatetextfile(self,data,name,fileName,directory):
data = simplejson.loads(data)
with open(os.getcwd()+'\\model\\states\\' + name + ('\\' + directory if directory != 'root' else '') + '\\'+fileName, "wb") as file:
directory = directory if directory != 'root' else ''
filepath = os.path.join(self.cwd, 'model/states/', directory, filename)
with open(filepath, "wb") as file:
for line in data:
file.write(line[0] + "\n")

return simplejson.dumps({"success":True})
savestatetextfile.exposed=True
def savestatecsvfile(self, data, name, fileName, directory):

def savestatecsvfile(self, data, name, fileName, directory):
data = simplejson.loads(data)
with open(os.getcwd()+'\\..\\projects\\project\\'+name+'\\parameters\\'+fileName, 'w', newline='') as csvfile:
filepath = os.path.join(self.project_dir, name, 'parameters', filename)
with open(filepath, 'w', newline='') as csvfile:
filewriter = csv.writer(csvfile)
filewriter.writerows(data)
return simplejson.dumps({"success":True})
savestatecsvfile.exposed=True

def resetrunstatus(self, _):
my_stdout_file = open(os.getcwd()+'\\..\\projects\\stdout.txt', 'w', newline='')
my_stdout_file = open(os.path.join(self.cwd, '../projects/stdout.txt'), 'w', newline='')
my_stdout_file.write('pending')
my_stdout_file.close()
return simplejson.dumps({'Status':'Success'})
resetrunstatus.exposed = True

def startrun(self, name, _):
MyApp.popen = subprocess.Popen([os.getcwd()+"\\..\\R\\bin\\Rscript", os.getcwd() + '\\..\\scripts\\SmartGAP.r'],
cmd = os.path.join(self.cwd, '../R/bin/Rscript')
script = os.path.join(self.cwd, '../scripts/SmartGAP.r')
MyApp.popen = subprocess.Popen([cmd, script],
stdout=subprocess.PIPE,
cwd=os.getcwd() + '\\..\\projects\\project\\' + name,
cwd=os.path.join(self.project_dir, name),
stderr = subprocess.STDOUT)
my_stdout_file = open(os.getcwd()+'\\test.txt', "w")
my_stdout_file = open(os.path.join(self.cwd, 'test.txt'), "w")
my_stdout_file.close()
for line in iter(MyApp.popen.stdout.readline, ""):
my_stdout_file = open(os.getcwd()+'\\test.txt', "ab")
my_stdout_file = open(os.path.join(self.cwd, 'test.txt'), "ab")
my_stdout_file.write(line)
my_stdout_file.close()

return simplejson.dumps({"pid":MyApp.popen.pid})
startrun.exposed=True

def stoprun(self, _):
os.system("taskkill /F /T /pid "+ str(MyApp.popen.pid))
my_stdout_file = open(os.getcwd()+'\\stdout.txt', "w")
my_stdout_file = open(os.path.join(self.cwd, 'stdout.txt'), "w")
my_stdout_file.close()
return simplejson.dumps({"success":1})
stoprun.exposed=True

def exit(self, _):
raise SystemExit(0)
exit.exposed = True
Expand All @@ -283,18 +305,19 @@ def exit(self, _):
print("Stopped Python Process ", proc)
proc.kill()


dir= os.getcwd()
report_dir = os.getcwd() + '/../projects/project/reports'
my_stdout_file = open(os.getcwd()+'\\stdout.txt', "w")


cwd = os.getcwd()
report_dir = os.path.join(cwd, '../projects/project/reports')
my_stdout_file = open(os.path.join(cwd, 'stdout.txt'), "w")
my_stdout_file.close()

config = {'/':
{
'tools.staticdir.on' : True,
'tools.staticdir.dir' : dir+'/views',
'tools.staticdir.dir' : os.path.join(cwd, 'views'),
'tools.staticdir.index' : 'index.html',

},
'/reports':
{
Expand Down