frikky
2801 lines
131 KiB
Python
2801 lines
131 KiB
Python
import os
|
|
import copy
|
|
import sys
|
|
import re
|
|
import time
|
|
import json
|
|
import logging
|
|
import requests
|
|
import urllib.parse
|
|
import http.client
|
|
import urllib3
|
|
import hashlib
|
|
from liquid import Liquid
|
|
import liquid
|
|
import zipfile
|
|
from io import BytesIO
|
|
|
|
class AppBase:
|
|
__version__ = None
|
|
app_name = None
|
|
|
|
def __init__(self, redis=None, logger=None, console_logger=None):#, docker_client=None):
|
|
self.logger = logger if logger is not None else logging.getLogger("AppBaseLogger")
|
|
self.redis=redis
|
|
self.console_logger = logger if logger is not None else logging.getLogger("AppBaseLogger")
|
|
|
|
# apikey is for the user / org
|
|
# authorization is for the specific workflow
|
|
|
|
self.url = os.getenv("CALLBACK_URL", "https://shuffler.io")
|
|
self.base_url = os.getenv("BASE_URL", "https://shuffler.io")
|
|
self.action = os.getenv("ACTION", "")
|
|
self.authorization = os.getenv("AUTHORIZATION", "")
|
|
self.current_execution_id = os.getenv("EXECUTIONID", "")
|
|
self.full_execution = os.getenv("FULL_EXECUTION", "")
|
|
self.start_time = int(time.time())
|
|
self.result_wrapper_count = 0
|
|
|
|
if isinstance(self.action, str):
|
|
try:
|
|
self.action = json.loads(self.action)
|
|
except:
|
|
print("[WARNING] Failed parsing action as JSON")
|
|
|
|
if len(self.base_url) == 0:
|
|
self.base_url = self.url
|
|
|
|
# FIXME: Add more info like logs in here.
|
|
# Docker logs: https://forums.docker.com/t/docker-logs-inside-the-docker-container/68190/2
|
|
def send_result(self, action_result, headers, stream_path):
|
|
if action_result["status"] == "EXECUTING":
|
|
action_result["status"] = "FAILURE"
|
|
|
|
# FIXME: Add cleanup of parameters to not send to frontend here
|
|
params = {}
|
|
#action = action_result["action"]
|
|
#try:
|
|
# for item in action["authentication"]:
|
|
# for action["parameters"]
|
|
# print("AUTH: ", key, value)
|
|
# params[item["key"]] = item["value"]
|
|
#except KeyError:
|
|
# print("No authentication specified!")
|
|
# pass
|
|
|
|
# I wonder if this actually works
|
|
self.logger.info("Before last stream result")
|
|
url = "%s%s" % (self.base_url, stream_path)
|
|
#print("[INFO] URL (URL): %s" % url)
|
|
try:
|
|
ret = requests.post(url, headers=headers, json=action_result)
|
|
self.logger.info("Result: %d" % ret.status_code)
|
|
if ret.status_code != 200:
|
|
self.logger.info(ret.text)
|
|
except requests.exceptions.ConnectionError as e:
|
|
#self.logger.exception("ConnectionError: %s" % e)
|
|
self.logger.info("Expected ConnectionError happened")
|
|
return
|
|
except TypeError as e:
|
|
#self.logger.exception(e)
|
|
action_result["status"] = "FAILURE"
|
|
action_result["result"] = "POST error: %s" % e
|
|
self.logger.info("Before typeerror stream result")
|
|
ret = requests.post("%s%s" % (self.base_url, stream_path), headers=headers, json=action_result)
|
|
self.logger.info("Result: %d" % ret.status_code)
|
|
if ret.status_code != 200:
|
|
self.logger.info(ret.text)
|
|
except http.client.RemoteDisconnected as e:
|
|
self.logger.info("Expected Remotedisconnect happened")
|
|
return
|
|
except urllib3.exceptions.ProtocolError as e:
|
|
self.logger.info("Expected ProtocolError happened")
|
|
return
|
|
|
|
async def cartesian_product(self, L):
|
|
if L:
|
|
return {(a, ) + b for a in L[0] for b in await self.cartesian_product(L[1:])}
|
|
else:
|
|
return {()}
|
|
|
|
# Handles unique fields by negoiating with the backend
|
|
def validate_unique_fields(self, params):
|
|
#print("IN THE UNIQUE FIELDS PLACE!")
|
|
|
|
newlist = [params]
|
|
if isinstance(params, list):
|
|
#print("ITS A LIST!")
|
|
newlist = params
|
|
|
|
#self.full_execution = os.getenv("FULL_EXECUTION", "")
|
|
#print(len(params))
|
|
#print(params.items())
|
|
#print(list(params.items()))
|
|
#print(f"PARAM: {params}")
|
|
#print(f"NEWLIST: {newlist}")
|
|
|
|
# FIXME: Also handle MULTI PARAM
|
|
values = []
|
|
param_names = []
|
|
all_values = {}
|
|
index = 0
|
|
for outerparam in newlist:
|
|
|
|
#print(f"INNERTYPE: {type(outerparam)}")
|
|
#print(f"HANDLING PARAM {key}")
|
|
param_value = ""
|
|
for key, value in outerparam.items():
|
|
#print("KEY: %s" % key)
|
|
#value = params[key]
|
|
for param in self.action["parameters"]:
|
|
try:
|
|
if param["name"] == key and param["unique_toggled"]:
|
|
print(f"FOUND: {key} with param {param}!")
|
|
if isinstance(value, dict) or isinstance(value, list):
|
|
try:
|
|
value = json.dumps(value)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print(f"Error in json decode for param {value}: {e}")
|
|
continue
|
|
elif isinstance(value, int) or isinstance(value, float):
|
|
value = str(value)
|
|
elif value == False:
|
|
value = "False"
|
|
elif value == True:
|
|
value = "True"
|
|
|
|
print(f"VALUE APPEND: {value}")
|
|
param_value += value
|
|
if param["name"] not in param_names:
|
|
param_names.append(param["name"])
|
|
|
|
except (KeyError, NameError) as e:
|
|
print(f"""Key/NameError in param handler for {param["name"]}: {e}""")
|
|
|
|
print(f"OUTER VALUE: {param_value}")
|
|
if len(param_value) > 0:
|
|
md5 = hashlib.md5(param_value.encode('utf-8')).hexdigest()
|
|
values.append(md5)
|
|
all_values[md5] = {
|
|
"index": index,
|
|
}
|
|
|
|
index += 1
|
|
|
|
# When in here, it means it should be unique
|
|
# Should this be done by the backend? E.g. ask it if the value is valid?
|
|
# 1. Check if it's unique towards key:value store in org for action
|
|
# 2. Check if COMBINATION is unique towards key:value store of action for org
|
|
# 3. Have a workflow configuration for unique ID's in unison or per field? E.g. if toggled, then send a hash of all fields together alphabetically, but if not, send one field at a time
|
|
|
|
# org_id = full_execution["workflow"]["execution_org"]["id"]
|
|
|
|
# USE ARRAY?
|
|
|
|
new_params = []
|
|
if len(values) > 0:
|
|
org_id = self.full_execution["workflow"]["execution_org"]["id"]
|
|
data = {
|
|
"append": True,
|
|
"workflow_check": False,
|
|
"authorization": self.authorization,
|
|
"execution_ref": self.current_execution_id,
|
|
"org_id": org_id,
|
|
"values": [{
|
|
"app": self.action["app_name"],
|
|
"action": self.action["name"],
|
|
"parameternames": param_names,
|
|
"parametervalues": values,
|
|
}]
|
|
}
|
|
|
|
#print(f"DATA: {data}")
|
|
# 1594869a676630b397bc34f7dc0951a3
|
|
|
|
#print(f"VALUE URL: {url}")
|
|
#print(f"RET: {ret.text}")
|
|
#print(f"ID: {ret.status_code}")
|
|
url = f"{self.url}/api/v1/orgs/{org_id}/validate_app_values"
|
|
ret = requests.post(url, json=data)
|
|
if ret.status_code == 200:
|
|
json_value = ret.json()
|
|
if len(json_value["found"]) > 0:
|
|
modifier = 0
|
|
for item in json_value["found"]:
|
|
print(f"Should remove {item}")
|
|
|
|
try:
|
|
print(f"FOUND: {all_values[item]}")
|
|
print(f"SHOULD REMOVE INDEX: {all_values[item]['index']}")
|
|
|
|
try:
|
|
newlist.pop(all_values[item]["index"]-modifier)
|
|
modifier += 1
|
|
except IndexError as e:
|
|
print(f"Error popping value from array: {e}")
|
|
except (NameError, KeyError) as e:
|
|
print(f"Failed removal: {e}")
|
|
|
|
|
|
#return False
|
|
else:
|
|
print("None of the items were found!")
|
|
return newlist
|
|
else:
|
|
print(f"[WARNING] Failed checking values with status code {ret.status_code}!")
|
|
|
|
#return True
|
|
return newlist
|
|
|
|
# Returns a list of all the executions to be done in the inner loop
|
|
# FIXME: Doesn't take into account whether you actually WANT to loop or not
|
|
# Check if the last part of the value is #?
|
|
async def get_param_multipliers(self, baseparams):
|
|
# Example:
|
|
# {'call': ['hello', 'hello4'], 'call2': ['hello2', 'hello3'], 'call3': '1'}
|
|
#
|
|
# Should become this because of pairs (all same-length arrays, PROBABLY indicates same source node's values.
|
|
# [
|
|
# {'call': 'hello', 'call2': 'hello2', 'call3': '1'},
|
|
# {'call': 'hello4', 'call2': 'hello3', 'call3': '1'}
|
|
# ]
|
|
#
|
|
# ----------------------------------------------------------------------
|
|
# Example2:
|
|
# {'call': ['hello'], 'call2': ['hello2', 'hello3'], 'call3': '1'}
|
|
#
|
|
# Should become this because NOT pairs/triplets:
|
|
# [
|
|
# {'call': 'hello', 'call2': 'hello2', 'call3': '1'},
|
|
# {'call': 'hello', 'call2': 'hello3', 'call3': '1'}
|
|
# ]
|
|
#
|
|
# ----------------------------------------------------------------------
|
|
# Example3:
|
|
# {'call': ['hello', 'hello2'], 'call2': ['hello3', 'hello4', 'hello5'], 'call3': '1'}
|
|
#
|
|
# Should become this because arrays are not same length, aka no pairs/triplets. This is the multiplier effect. 2x3 arrays = 6 iterations
|
|
# [
|
|
# {'call': 'hello', 'call2': 'hello3', 'call3': '1'},
|
|
# {'call': 'hello', 'call2': 'hello4', 'call3': '1'},
|
|
# {'call': 'hello', 'call2': 'hello5', 'call3': '1'},
|
|
# {'call': 'hello2', 'call2': 'hello3', 'call3': '1'},
|
|
# {'call': 'hello2', 'call2': 'hello4', 'call3': '1'},
|
|
# {'call': 'hello2', 'call2': 'hello5', 'call3': '1'}
|
|
# ]
|
|
# To achieve this, we'll do this:
|
|
# 1. For the first array, take the total amount(y) (2x3=6) and divide it by the current array (x): 2. x/y = 3. This means do 3 of each value
|
|
# 2. For the second array, take the total amount(y) (2x3=6) and divide it by the current array (x): 3. x/y = 2.
|
|
# 3. What does the 3rd array do? Same, but ehhh?
|
|
#
|
|
# Example4:
|
|
# What if there are multiple loops inside a single item?
|
|
#
|
|
#
|
|
|
|
paramlist = []
|
|
listitems = []
|
|
listlengths = []
|
|
all_lists = []
|
|
all_list_keys = []
|
|
|
|
#check_value = "$Filter_list_testing.wrapper.#.tmp"
|
|
#self.action = action
|
|
|
|
loopnames = []
|
|
#print(f"Baseparams to check!!: {baseparams}")
|
|
for key, value in baseparams.items():
|
|
check_value = ""
|
|
for param in self.action["parameters"]:
|
|
if param["name"] == key:
|
|
#print("PARAM: %s" % param)
|
|
check_value = param["value"]
|
|
# self.result_wrapper_count = 0
|
|
|
|
octothorpe_count = param["value"].count(".#")
|
|
if octothorpe_count > self.result_wrapper_count:
|
|
self.result_wrapper_count = octothorpe_count
|
|
print("[INFO] NEW OCTOTHORPE WRAPPER: %d" % octothorpe_count)
|
|
|
|
|
|
# This whole thing is hard.
|
|
# item = [{"data": "1.2.3.4", "dataType": "ip"}]
|
|
# $item = DONT loop items.
|
|
# $item.# = Loop items
|
|
# $item.#.data = Loop items
|
|
# With a single item, this is fine.
|
|
|
|
# item = [{"list": [{"data": "1.2.3.4", "dataType": "ip"}]}]
|
|
# $item = DONT loop items
|
|
# $item.# = Loop items
|
|
# $item.#.list = DONT loop items
|
|
# $item.#.list.# = Loop items
|
|
# $item.#.list.#.data = Loop items
|
|
# If the item itself is a list.. hmm
|
|
|
|
# FIXME: Check the above, and fix so that nested looped items can be
|
|
# Skipped if wanted
|
|
|
|
#print("\nCHECK: %s" % check_value)
|
|
#try:
|
|
# values = parameter["value_replace"]
|
|
# if values != None:
|
|
# print(values)
|
|
# for val in values:
|
|
# print(val)
|
|
#except:
|
|
# pass
|
|
|
|
should_merge = False
|
|
if "#" in check_value:
|
|
should_merge = True
|
|
|
|
# Specific for OpenAPI body replacement
|
|
#print("\n\n\nDOING STUFF BELOW HERE")
|
|
if not should_merge:
|
|
for parameter in self.action["parameters"]:
|
|
if parameter["name"] == key:
|
|
#print("CHECKING BODY FOR VALUE REPLACE DATA!")
|
|
try:
|
|
values = parameter["value_replace"]
|
|
if values != None:
|
|
print(values)
|
|
for val in values:
|
|
if "#" in val["value"]:
|
|
should_merge = True
|
|
break
|
|
except:
|
|
pass
|
|
|
|
#print(f"MERGE: {should_merge}")
|
|
if isinstance(value, list):
|
|
print("Item {value} is a list.")
|
|
if len(value) <= 1:
|
|
if len(value) == 1:
|
|
baseparams[key] = value[0]
|
|
|
|
#if "#" in check_value:
|
|
# should_merge = True
|
|
else:
|
|
if not should_merge:
|
|
print("Adding WITHOUT looping list")
|
|
else:
|
|
if len(value) not in listlengths:
|
|
listlengths.append(len(value))
|
|
|
|
listitems.append(
|
|
{
|
|
key: len(value)
|
|
}
|
|
)
|
|
|
|
all_list_keys.append(key)
|
|
all_lists.append(baseparams[key])
|
|
else:
|
|
#print(f"{value} is not a list")
|
|
pass
|
|
|
|
print("Listlengths: %s" % listlengths)
|
|
if len(listlengths) == 0:
|
|
print("NO multiplier. Running a single iteration.")
|
|
paramlist.append(baseparams)
|
|
elif len(listlengths) == 1:
|
|
print("NO MULTIPLIER NECESSARY. Length is %d" % len(listitems))
|
|
|
|
for item in listitems:
|
|
# This loops should always be length 1
|
|
for key, value in item.items():
|
|
if isinstance(value, int):
|
|
print("\nShould run key %s %d times from %s" % (key, value, baseparams[key]))
|
|
if len(paramlist) == value:
|
|
print("List ALREADY exists - just changing values")
|
|
for subloop in range(value):
|
|
baseitem = copy.deepcopy(baseparams)
|
|
paramlist[subloop][key] = baseparams[key][subloop]
|
|
else:
|
|
print("List DOESNT exist - ADDING values")
|
|
for subloop in range(value):
|
|
baseitem = copy.deepcopy(baseparams)
|
|
baseitem[key] = baseparams[key][subloop]
|
|
paramlist.append(baseitem)
|
|
|
|
else:
|
|
print("Multipliers to handle: %s" % listitems)
|
|
newlength = 1
|
|
for item in listitems:
|
|
for key, value in item.items():
|
|
newlength = newlength * value
|
|
|
|
print("Newlength of array: %d. Lists: %s" % (newlength, all_lists))
|
|
# Get the cartesian product of the arrays
|
|
cartesian = await self.cartesian_product(all_lists)
|
|
newlist = []
|
|
for item in cartesian:
|
|
newlist.append(list(item))
|
|
|
|
newobject = {}
|
|
for subitem in range(len(newlist)):
|
|
baseitem = copy.deepcopy(baseparams)
|
|
for key in range(len(newlist[subitem])):
|
|
baseitem[all_list_keys[key]] = newlist[subitem][key]
|
|
|
|
paramlist.append(baseitem)
|
|
|
|
#print("PARAMLIST: %s" % paramlist)
|
|
|
|
#newlist[subitem[0]]
|
|
#if len(newlist) > 0:
|
|
# itemlength = len(newlist[0])
|
|
|
|
# How do we get it back, ordered?
|
|
#for item in cartesian:
|
|
#print("Listlengths: %s" % listlengths)
|
|
#paramlist = [baseparams]
|
|
|
|
#print("[INFO] Return paramlist: %s" % paramlist)
|
|
return paramlist
|
|
|
|
|
|
# Runs recursed versions with inner loops and such
|
|
async def run_recursed_items(self, func, baseparams, loop_wrapper):
|
|
#print(f"RECURSED ITEMS: {baseparams}")
|
|
has_loop = False
|
|
|
|
newparams = {}
|
|
for key, value in baseparams.items():
|
|
if isinstance(value, list) and len(value) > 0:
|
|
print(f"In list check for {key}")
|
|
|
|
try:
|
|
# Added skip for body (OpenAPI) which uses data= in requests
|
|
# Can be screwed up if they name theirs body too
|
|
if key != "body":
|
|
value[0] = json.loads(value[0])
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("JSON casting error: %s" % e)
|
|
except TypeError as e:
|
|
print("TypeError: %s" % e)
|
|
|
|
print("POST initial list check")
|
|
|
|
if isinstance(value, list) and len(value) == 1 and isinstance(value[0], list):
|
|
try:
|
|
loop_wrapper[key] += 1
|
|
except IndexError:
|
|
loop_wrapper[key] = 1
|
|
except KeyError:
|
|
loop_wrapper[key] = 1
|
|
|
|
print(f"Key {key} is a list: {value}")
|
|
newparams[key] = value[0]
|
|
has_loop = True
|
|
else:
|
|
#print(f"Key {key} is NOT a list within a list. Value: {value}")
|
|
newparams[key] = value
|
|
|
|
results = []
|
|
if has_loop:
|
|
print("[WARNING] Should run inner loop: %s" % newparams)
|
|
ret = await self.run_recursed_items(func, newparams, loop_wrapper)
|
|
else:
|
|
#print("[INFO] Should run multiplier check with params (inner): %s" % newparams)
|
|
# 1. Find the loops that are required and create new multipliers
|
|
# If here: check for multipliers within this scope.
|
|
ret = []
|
|
param_multiplier = await self.get_param_multipliers(newparams)
|
|
|
|
# FIXME: This does a deduplication of the data
|
|
new_params = self.validate_unique_fields(param_multiplier)
|
|
#print(f"NEW PARAMS: {new_params}")
|
|
if len(new_params) == 0:
|
|
print("[WARNING] SHOULD STOP MULTI-EXECUTION BECAUSE FIELDS AREN'T UNIQUE")
|
|
action_result = {
|
|
"action": self.action,
|
|
"authorization": self.authorization,
|
|
"execution_id": self.current_execution_id,
|
|
"result": f"All {len(param_multiplier)} values were non-unique",
|
|
"started_at": self.start_time,
|
|
"status": "SKIPPED",
|
|
"completed_at": int(time.time()),
|
|
}
|
|
|
|
self.send_result(action_result, {"Content-Type": "application/json", "Authorization": "Bearer %s" % self.authorization}, "/api/v1/streams")
|
|
exit()
|
|
#return
|
|
else:
|
|
#subparams = new_params
|
|
#print(f"NEW PARAMS: {new_params}")
|
|
param_multiplier = new_params
|
|
|
|
#print("Returned with newparams of length %d", len(new_params))
|
|
#if isinstance(new_params, list) and len(new_params) == 1:
|
|
# params = new_params[0]
|
|
#else:
|
|
# print("[WARNING] SHOULD STOP EXECUTION BECAUSE FIELDS AREN'T UNIQUE")
|
|
# action_result["status"] = "SKIPPED"
|
|
# action_result["result"] = f"A non-unique value was found"
|
|
# action_result["completed_at"] = int(time.time())
|
|
# self.send_result(action_result, headers, stream_path)
|
|
# return
|
|
|
|
print("[INFO] Multiplier length: %d" % len(param_multiplier))
|
|
#tmp = ""
|
|
for subparams in param_multiplier:
|
|
#print(f"SUBPARAMS IN MULTI: {subparams}")
|
|
try:
|
|
#tmp = await func(**subparams)
|
|
|
|
while True:
|
|
try:
|
|
tmp = await func(**subparams)
|
|
break
|
|
except TypeError as e:
|
|
errorstring = "%s" % e
|
|
if "got an unexpected keyword argument" in errorstring:
|
|
fieldsplit = errorstring.split("'")
|
|
if len(fieldsplit) > 1:
|
|
field = fieldsplit[1]
|
|
|
|
try:
|
|
del subparams[field]
|
|
print("Removed field invalid field %s" % field)
|
|
except KeyError:
|
|
break
|
|
else:
|
|
raise e
|
|
|
|
except:
|
|
e = ""
|
|
try:
|
|
e = sys.exc_info()[1]
|
|
except:
|
|
print("Exc check fail: %s" % e)
|
|
pass
|
|
|
|
tmp = "An error occured during execution: %s" % e
|
|
|
|
#print("RET from execution: %s" % ret)
|
|
new_value = tmp
|
|
if tmp == None:
|
|
new_value = ""
|
|
elif isinstance(tmp, dict):
|
|
new_value = json.dumps(tmp)
|
|
elif isinstance(tmp, list):
|
|
new_value = json.dumps(tmp)
|
|
#else:
|
|
#tmp = tmp.replace("\"", "\\\"", -1)
|
|
|
|
try:
|
|
new_value = json.loads(new_value)
|
|
except json.decoder.JSONDecodeError as e:
|
|
pass
|
|
except TypeError as e:
|
|
pass
|
|
except:
|
|
pass
|
|
#print("Json: %s" % e)
|
|
#ret.append(tmp)
|
|
|
|
#if self.result_wrapper_count > 0:
|
|
# ret.append("["*(self.result_wrapper_count-1)+new_value+"]"*(self.result_wrapper_count-1))
|
|
#else:
|
|
ret.append(new_value)
|
|
|
|
print("Ret length: %d" % len(ret))
|
|
if len(ret) == 1:
|
|
#ret = ret[0]
|
|
print("DONT make list of 1 into 0!!")
|
|
|
|
print("Return from execution: %s" % ret)
|
|
if ret == None:
|
|
results.append("")
|
|
json_object = False
|
|
elif isinstance(ret, dict):
|
|
results.append(ret)
|
|
json_object = True
|
|
elif isinstance(ret, list):
|
|
results = ret
|
|
json_object = True
|
|
else:
|
|
ret = ret.replace("\"", "\\\"", -1)
|
|
|
|
try:
|
|
results.append(json.loads(ret))
|
|
json_object = True
|
|
except json.decoder.JSONDecodeError as e:
|
|
#print("Json: %s" % e)
|
|
results.append(ret)
|
|
except TypeError as e:
|
|
results.append(ret)
|
|
except:
|
|
results.append(ret)
|
|
|
|
if len(results) == 1:
|
|
#results = results[0]
|
|
print("DONT MAKE LIST FROM 1 TO 0!!")
|
|
|
|
print("\nLOOP: %s\nRESULTS: %s" % (loop_wrapper, results))
|
|
return results
|
|
|
|
# Downloads all files from a namespace
|
|
# Currently only working on local version of Shuffle
|
|
def get_file_namespace(self, namespace):
|
|
org_id = self.full_execution["workflow"]["execution_org"]["id"]
|
|
|
|
get_path = "/api/v1/files/namespaces/%s?execution_id=%s" % (namespace, self.full_execution["execution_id"])
|
|
headers = {
|
|
"Authorization": "Bearer %s" % self.authorization
|
|
}
|
|
|
|
ret1 = requests.get("%s%s" % (self.url, get_path), headers=headers)
|
|
if ret1.status_code != 200:
|
|
return None
|
|
|
|
filebytes = BytesIO(ret1.content)
|
|
myzipfile = zipfile.ZipFile(filebytes)
|
|
return myzipfile
|
|
|
|
# Things to consider for files:
|
|
# - How can you download / stream a file?
|
|
# - Can you decide if you want a stream or the files directly?
|
|
def get_file(self, value):
|
|
full_execution = self.full_execution
|
|
org_id = full_execution["workflow"]["execution_org"]["id"]
|
|
|
|
print("SHOULD GET FILES BASED ON ORG %s, workflow %s and value(s) %s" % (org_id, full_execution["workflow"]["id"], value))
|
|
|
|
if isinstance(value, list):
|
|
print("IS LIST!")
|
|
#if len(value) == 1:
|
|
# value = value[0]
|
|
else:
|
|
value = [value]
|
|
|
|
returns = []
|
|
for item in value:
|
|
print("VALUE: %s" % item)
|
|
if len(item) != 36:
|
|
print("Bad length for file value %s" % item)
|
|
continue
|
|
#return {
|
|
# "filename": "",
|
|
# "data": "",
|
|
# "success": False,
|
|
#}
|
|
|
|
get_path = "/api/v1/files/%s?execution_id=%s" % (item, full_execution["execution_id"])
|
|
headers = {
|
|
"Content-Type": "application/json",
|
|
"Authorization": "Bearer %s" % self.authorization
|
|
}
|
|
|
|
ret1 = requests.get("%s%s" % (self.url, get_path), headers=headers)
|
|
print("RET1 (file get): %s" % ret1.text)
|
|
if ret1.status_code != 200:
|
|
returns.append({
|
|
"filename": "",
|
|
"data": "",
|
|
"success": False,
|
|
})
|
|
continue
|
|
|
|
content_path = "/api/v1/files/%s/content?execution_id=%s" % (item, full_execution["execution_id"])
|
|
ret2 = requests.get("%s%s" % (self.url, content_path), headers=headers)
|
|
print("RET2 (file get) done")
|
|
if ret2.status_code == 200:
|
|
tmpdata = ret1.json()
|
|
returndata = {
|
|
"success": True,
|
|
"filename": tmpdata["filename"],
|
|
"data": ret2.content,
|
|
}
|
|
returns.append(returndata)
|
|
|
|
print("RET3 (file get done)")
|
|
|
|
if len(returns) == 0:
|
|
return {
|
|
"success": False,
|
|
"filename": "",
|
|
"data": b"",
|
|
}
|
|
elif len(returns) == 1:
|
|
return returns[0]
|
|
else:
|
|
return returns
|
|
|
|
def set_cache(self, key, value):
|
|
org_id = self.full_execution["workflow"]["execution_org"]["id"]
|
|
url = "%s/api/v1/orgs/%s/set_cache" % (self.url, org_id)
|
|
data = {
|
|
"workflow_id": self.full_execution["workflow"]["id"],
|
|
"execution_id": self.current_execution_id,
|
|
"authorization": self.authorization,
|
|
"org_id": org_id,
|
|
"key": key,
|
|
"value": str(value),
|
|
}
|
|
|
|
response = requests.post(url, json=data)
|
|
try:
|
|
allvalues = response.json()
|
|
allvalues["key"] = key
|
|
allvalues["value"] = str(value)
|
|
return allvalues
|
|
except:
|
|
print("Value couldn't be parsed")
|
|
#return response.json()
|
|
return {"success": False}
|
|
|
|
def get_cache(self, key):
|
|
org_id = self.full_execution["workflow"]["execution_org"]["id"]
|
|
url = "%s/api/v1/orgs/%s/get_cache" % (self.url, org_id)
|
|
data = {
|
|
"workflow_id": self.full_execution["workflow"]["id"],
|
|
"execution_id": self.current_execution_id,
|
|
"authorization": self.authorization,
|
|
"org_id": org_id,
|
|
"key": key,
|
|
}
|
|
|
|
value = requests.post(url, json=data)
|
|
try:
|
|
allvalues = value.json()
|
|
print("VAL1: ", allvalues)
|
|
allvalues["key"] = key
|
|
print("VAL2: ", allvalues)
|
|
|
|
try:
|
|
parsedvalue = json.loads(allvalues["value"])
|
|
allvalues["value"] = parsedvalue
|
|
except:
|
|
print("Parsing of value as JSON failed. Continue anyway!")
|
|
|
|
return allvalues
|
|
except:
|
|
print("Value couldn't be parsed, or json dump of value failed")
|
|
#return value.json()
|
|
return {"success": False}
|
|
|
|
def set_file(self, infiles):
|
|
return self.set_files(infiles)
|
|
|
|
# Sets files in the backend
|
|
def set_files(self, infiles):
|
|
full_execution = self.full_execution
|
|
workflow_id = full_execution["workflow"]["id"]
|
|
org_id = full_execution["workflow"]["execution_org"]["id"]
|
|
headers = {
|
|
"Content-Type": "application/json",
|
|
"Authorization": "Bearer %s" % self.authorization
|
|
}
|
|
|
|
if not isinstance(infiles, list):
|
|
infiles = [infiles]
|
|
|
|
create_path = "/api/v1/files/create?execution_id=%s" % full_execution["execution_id"]
|
|
file_ids = []
|
|
for curfile in infiles:
|
|
filename = "unspecified"
|
|
data = {
|
|
"filename": filename,
|
|
"workflow_id": workflow_id,
|
|
"org_id": org_id,
|
|
}
|
|
|
|
try:
|
|
data["filename"] = curfile["filename"]
|
|
filename = curfile["filename"]
|
|
except KeyError as e:
|
|
print(f"KeyError in file setup: {e}")
|
|
pass
|
|
|
|
ret = requests.post("%s%s" % (self.url, create_path), headers=headers, json=data)
|
|
print(f"Ret CREATE: {ret.text}")
|
|
cur_id = ""
|
|
if ret.status_code == 200:
|
|
print("RET: %s" % ret.text)
|
|
ret_json = ret.json()
|
|
if not ret_json["success"]:
|
|
print("Not success in file upload creation.")
|
|
continue
|
|
|
|
print("Should handle ID %s" % ret_json["id"])
|
|
file_ids.append(ret_json["id"])
|
|
cur_id = ret_json["id"]
|
|
else:
|
|
print("Bad status code: %d" % ret.status_code)
|
|
continue
|
|
|
|
if len(cur_id) == 0:
|
|
print("No file ID specified from backend")
|
|
continue
|
|
|
|
new_headers = {
|
|
"Authorization": f"Bearer {self.authorization}",
|
|
}
|
|
|
|
upload_path = "/api/v1/files/%s/upload?execution_id=%s" % (cur_id, full_execution["execution_id"])
|
|
print("Create path: %s" % create_path)
|
|
|
|
files={"shuffle_file": (filename, curfile["data"])}
|
|
#open(filename,'rb')}
|
|
|
|
ret = requests.post("%s%s" % (self.url, upload_path), files=files, headers=new_headers)
|
|
print("Ret UPLOAD: %s" % ret.text)
|
|
print("Ret2 UPLOAD: %d" % ret.status_code)
|
|
|
|
print("IDS TO RETURN: %s" % file_ids)
|
|
return file_ids
|
|
|
|
async def execute_action(self, action):
|
|
|
|
# !!! Let this line stay - its used for some horrible codegeneration / stitching !!! #
|
|
#STARTCOPY
|
|
stream_path = "/api/v1/streams"
|
|
action_result = {
|
|
"action": action,
|
|
"authorization": self.authorization,
|
|
"execution_id": self.current_execution_id,
|
|
"result": "",
|
|
"started_at": int(time.time()),
|
|
"status": "EXECUTING"
|
|
}
|
|
|
|
# Simple validation of parameters in general
|
|
try:
|
|
tmp_parameters = action["parameters"]
|
|
except KeyError:
|
|
action["parameters"] = []
|
|
except TypeError:
|
|
pass
|
|
|
|
self.action = copy.deepcopy(action)
|
|
self.logger.info("Sending starting action result (EXECUTING)")
|
|
|
|
headers = {
|
|
"Content-Type": "application/json",
|
|
"Authorization": "Bearer %s" % self.authorization
|
|
}
|
|
|
|
if len(self.action) == 0:
|
|
print("ACTION env not defined")
|
|
action_result["result"] = "Error in setup ENV: ACTION not defined"
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
if len(self.authorization) == 0:
|
|
print("AUTHORIZATION env not defined")
|
|
action_result["result"] = "Error in setup ENV: AUTHORIZATION not defined"
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
if len(self.current_execution_id) == 0:
|
|
print("EXECUTIONID env not defined")
|
|
action_result["result"] = "Error in setup ENV: EXECUTIONID not defined"
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
|
|
# Add async logger
|
|
# self.console_logger.handlers[0].stream.set_execution_id()
|
|
#self.logger.info("Before initial stream result")
|
|
|
|
# FIXME: Shouldn't skip this, but it's good for minimzing API calls
|
|
#try:
|
|
# ret = requests.post("%s%s" % (self.base_url, stream_path), headers=headers, json=action_result)
|
|
# self.logger.info("Workflow: %d" % ret.status_code)
|
|
# if ret.status_code != 200:
|
|
# self.logger.info(ret.text)
|
|
#except requests.exceptions.ConnectionError as e:
|
|
# print("Connectionerror: %s" % e)
|
|
|
|
# action_result["result"] = "Bad setup during startup: %s" % e
|
|
# self.send_result(action_result, headers, stream_path)
|
|
# return
|
|
|
|
# Verify whether there are any parameters with ACTION_RESULT required
|
|
# If found, we get the full results list from backend
|
|
fullexecution = {}
|
|
if len(self.full_execution) == 0:
|
|
print("NO EXECUTION - LOADING!")
|
|
try:
|
|
tmpdata = {
|
|
"authorization": self.authorization,
|
|
"execution_id": self.current_execution_id
|
|
}
|
|
|
|
self.logger.info("Before FULLEXEC stream result")
|
|
ret = requests.post(
|
|
"%s/api/v1/streams/results" % (self.base_url),
|
|
headers=headers,
|
|
json=tmpdata
|
|
)
|
|
|
|
if ret.status_code == 200:
|
|
fullexecution = ret.json()
|
|
else:
|
|
try:
|
|
self.logger.info("Error: Data: ", ret.json())
|
|
self.logger.info("Error with status code for results. Crashing because ACTION_RESULTS or WORKFLOW_VARIABLE can't be handled. Status: %d" % ret.status_code)
|
|
except json.decoder.JSONDecodeError:
|
|
pass
|
|
|
|
action_result["result"] = "Bad result from backend: %d" % ret.status_code
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
except requests.exceptions.ConnectionError as e:
|
|
self.logger.info("Connectionerror: %s" % e)
|
|
action_result["result"] = "Connection error during startup: %s" % e
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
else:
|
|
try:
|
|
fullexecution = json.loads(self.full_execution)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Json decode execution error: %s" % e)
|
|
action_result["result"] = "Json error during startup: %s" % e
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
print("")
|
|
|
|
|
|
self.full_execution = fullexecution
|
|
self.logger.info("AFTER FULLEXEC stream result (init)")
|
|
|
|
# Gets the value at the parenthesis level you want
|
|
def parse_nested_param(string, level):
|
|
"""
|
|
Generate strings contained in nested (), indexing i = level
|
|
"""
|
|
if len(re.findall("\(", string)) == len(re.findall("\)", string)):
|
|
LeftRightIndex = [x for x in zip(
|
|
[Left.start()+1 for Left in re.finditer('\(', string)],
|
|
reversed([Right.start() for Right in re.finditer('\)', string)]))]
|
|
|
|
elif len(re.findall("\(", string)) > len(re.findall("\)", string)):
|
|
return parse_nested_param(string + ')', level)
|
|
elif len(re.findall("\(", string)) < len(re.findall("\)", string)):
|
|
return parse_nested_param('(' + string, level)
|
|
else:
|
|
return 'Failed to parse params'
|
|
|
|
try:
|
|
return [string[LeftRightIndex[level][0]:LeftRightIndex[level][1]]]
|
|
except IndexError:
|
|
return [string[LeftRightIndex[level+1][0]:LeftRightIndex[level+1][1]]]
|
|
|
|
# Finds the deepest level parenthesis in a string
|
|
def maxDepth(S):
|
|
current_max = 0
|
|
max = 0
|
|
n = len(S)
|
|
|
|
# Traverse the input string
|
|
for i in range(n):
|
|
if S[i] == '(':
|
|
current_max += 1
|
|
|
|
if current_max > max:
|
|
max = current_max
|
|
elif S[i] == ')':
|
|
if current_max > 0:
|
|
current_max -= 1
|
|
else:
|
|
return -1
|
|
|
|
# finally check for unbalanced string
|
|
if current_max != 0:
|
|
return -1
|
|
|
|
return max-1
|
|
|
|
# Specific type parsing
|
|
def parse_type(data, thistype):
|
|
if data == None:
|
|
return "Empty"
|
|
|
|
if "int" in thistype or "number" in thistype:
|
|
try:
|
|
return int(data)
|
|
except ValueError:
|
|
print("ValueError while casting %s to int" % data)
|
|
return data
|
|
if "lower" in thistype:
|
|
return data.lower()
|
|
if "upper" in thistype:
|
|
return data.upper()
|
|
if "trim" in thistype:
|
|
return data.strip()
|
|
if "strip" in thistype:
|
|
return data.strip()
|
|
if "split" in thistype:
|
|
return data.split()
|
|
if "replace" in thistype:
|
|
print("Running replace!")
|
|
splitvalues = data.split(",")
|
|
|
|
if len(splitvalues) > 2:
|
|
for i in range(len(splitvalues)):
|
|
if i != 0:
|
|
if splitvalues[i] == " ":
|
|
splitvalues[i] = " "
|
|
continue
|
|
|
|
splitvalues[i] = splitvalues[i].strip()
|
|
|
|
if splitvalues[i] == "\"\"":
|
|
splitvalues[i] = ""
|
|
if splitvalues[i] == "\" \"":
|
|
splitvalues[i] = " "
|
|
if len(splitvalues[i]) > 2:
|
|
if splitvalues[i][0] == "\"" and splitvalues[i][len(splitvalues[i])-1] == "\"":
|
|
splitvalues[i] = splitvalues[i][1:-1]
|
|
if splitvalues[i][0] == "'" and splitvalues[i][len(splitvalues[i])-1] == "'":
|
|
splitvalues[i] = splitvalues[i][1:-1]
|
|
|
|
|
|
replacementvalue = splitvalues[0]
|
|
return replacementvalue.replace(splitvalues[1], splitvalues[2], -1)
|
|
else:
|
|
return f"replace({data})"
|
|
if "join" in thistype:
|
|
print(f"SHOULD JOIN: {data}")
|
|
try:
|
|
splitvalues = data.split(",")
|
|
if "," not in data:
|
|
return f"join({data})"
|
|
|
|
if len(splitvalues) >= 2:
|
|
print(f"SPLITVALUE: {splitvalues[-1]}")
|
|
|
|
# 1. Take the list and parse it from string
|
|
# 2. Take all the items and join them
|
|
# 3. Parse them back as string and return
|
|
values = ",".join(splitvalues[0:-1])
|
|
print(f"VALUES: {values}")
|
|
tmp = json.loads(values)
|
|
print(f"TMP: {tmp}")
|
|
#tmp = tmp[1:-1]
|
|
#print(f"TMP2: {tmp}")
|
|
try:
|
|
newvalues = splitvalues[-1].join(str(item).strip() for item in tmp)
|
|
except TypeError:
|
|
newvalues = splitvalues[-1].join(json.dumps(item).strip() for item in tmp)
|
|
|
|
print(f"new: {newvalues}")
|
|
return newvalues
|
|
else:
|
|
print("Returning default")
|
|
return f"join({data})"
|
|
|
|
except (KeyError, IndexError) as e:
|
|
print(f"ERROR in join(): {e}")
|
|
except json.decoder.JSONDecodeError as e:
|
|
print(f"JSON ERROR in join(): {e}")
|
|
|
|
if "len" in thistype or "length" in thistype or "lenght" in thistype:
|
|
print(f"Trying to length-parse: {data}")
|
|
try:
|
|
tmp_len = json.loads(data, parse_float=str, parse_int=str, parse_constant=str)
|
|
except (NameError, KeyError, TypeError, json.decoder.JSONDecodeError) as e:
|
|
try:
|
|
print(f"[WARNING] INITIAL Parsing bug for length in app sdk: {e}")
|
|
# data = data.replace("\'", "\"")
|
|
data = data.replace("True", "true")
|
|
data = data.replace("False", "false")
|
|
data = data.replace("None", "null")
|
|
data = data.replace("\"", "\\\"")
|
|
data = data.replace("'", "\"")
|
|
|
|
tmp_len = json.loads(data, parse_float=str, parse_int=str, parse_constant=str)
|
|
except (NameError, KeyError, TypeError, json.decoder.JSONDecodeError) as e:
|
|
tmp_len = str(data)
|
|
|
|
return str(len(tmp_len))
|
|
|
|
if "parse" in thistype:
|
|
splitvalues = []
|
|
default_error = """Error. Expected syntax: parse(["hello","test1"],0:1)"""
|
|
if "," in data:
|
|
splitvalues = data.split(",")
|
|
|
|
for item in range(len(splitvalues)):
|
|
splitvalues[item] = splitvalues[item].strip()
|
|
else:
|
|
return default_error
|
|
|
|
lastsplit = []
|
|
if ":" in splitvalues[-1]:
|
|
lastsplit = splitvalues[-1].split(":")
|
|
else:
|
|
try:
|
|
lastsplit = [int(splitvalues[-1])]
|
|
except ValueError:
|
|
return default_error
|
|
|
|
try:
|
|
parsedlist = ",".join(splitvalues[0:-1])
|
|
if len(lastsplit) > 1:
|
|
tmp = json.loads(parsedlist)[int(lastsplit[0]):int(lastsplit[1])]
|
|
else:
|
|
tmp = json.loads(parsedlist)[lastsplit[0]]
|
|
|
|
#print(tmp)
|
|
return tmp
|
|
except IndexError as e:
|
|
return default_error
|
|
|
|
# Parses the INNER value and recurses until everything is done
|
|
def parse_wrapper(data):
|
|
try:
|
|
if "(" not in data or ")" not in data:
|
|
return data, False
|
|
except TypeError:
|
|
return data, False
|
|
|
|
wrappers = ["int", "number", "lower", "upper", "trim", "strip", "split", "parse", "len", "length", "lenght", "join", "replace"]
|
|
|
|
if not any(wrapper in data for wrapper in wrappers):
|
|
return data, False
|
|
|
|
# Do stuff here.
|
|
inner_value = parse_nested_param(data, maxDepth(data) - 0)
|
|
outer_value = parse_nested_param(data, maxDepth(data) - 1)
|
|
|
|
print("INNER: ", inner_value)
|
|
print("OUTER: ", outer_value)
|
|
|
|
wrapper_group = "|".join(wrappers)
|
|
parse_string = data
|
|
max_depth = maxDepth(parse_string)
|
|
|
|
if outer_value != inner_value:
|
|
for casting_items in reversed(range(max_depth + 1)):
|
|
c_parentheses = parse_nested_param(parse_string, casting_items)[0]
|
|
match_string = re.escape(c_parentheses)
|
|
custom_casting = re.findall(fr"({wrapper_group})\({match_string}", parse_string)
|
|
|
|
# no matching ; go next group
|
|
if len(custom_casting) == 0:
|
|
continue
|
|
|
|
inner_result = parse_type(c_parentheses, custom_casting[0])
|
|
|
|
# if result is a string then parse else return
|
|
if isinstance(inner_result, str):
|
|
parse_string = parse_string.replace(f"{custom_casting[0]}({c_parentheses})", inner_result)
|
|
elif isinstance(inner_result, list):
|
|
parse_string = parse_string.replace(f"{custom_casting[0]}({c_parentheses})",
|
|
json.dumps(inner_result))
|
|
else:
|
|
parse_string = inner_result
|
|
break
|
|
else:
|
|
c_parentheses = parse_nested_param(parse_string, 0)[0]
|
|
match_string = re.escape(c_parentheses)
|
|
custom_casting = re.findall(fr"({wrapper_group})\({match_string}", parse_string)
|
|
|
|
# check if a wrapper was found
|
|
if len(custom_casting) != 0:
|
|
inner_result = parse_type(c_parentheses, custom_casting[0])
|
|
if isinstance(inner_result, str):
|
|
parse_string = parse_string.replace(f"{custom_casting[0]}({c_parentheses})", inner_result)
|
|
elif isinstance(inner_result, list):
|
|
parse_string = parse_string.replace(f"{custom_casting[0]}({c_parentheses})",
|
|
json.dumps(inner_result))
|
|
else:
|
|
parse_string = inner_result
|
|
|
|
return parse_string, True
|
|
|
|
# Looks for parantheses to grab special cases within a string, e.g:
|
|
# int(1) lower(HELLO) or length(what's the length)
|
|
# FIXME:
|
|
# There is an issue in here where it returns data wrong. Example:
|
|
# Authorization=Bearer authkey
|
|
# =
|
|
# Authorization=Bearer authkey
|
|
# ^ Double space.
|
|
def parse_wrapper_start(data):
|
|
if "(" not in data or ")" not in data:
|
|
return data
|
|
|
|
newdata = []
|
|
newstring = ""
|
|
record = True
|
|
paranCnt = 0
|
|
for char in data:
|
|
if char == "(":
|
|
paranCnt += 1
|
|
|
|
if not record:
|
|
record = True
|
|
|
|
if record:
|
|
newstring += char
|
|
|
|
if paranCnt == 0 and char == " ":
|
|
newdata.append(newstring)
|
|
newstring = ""
|
|
record = True
|
|
|
|
if char == ")":
|
|
paranCnt -= 1
|
|
|
|
if paranCnt == 0:
|
|
record = False
|
|
|
|
if len(newstring) > 0:
|
|
newdata.append(newstring)
|
|
|
|
parsedlist = []
|
|
non_string = False
|
|
parsed = False
|
|
for item in newdata:
|
|
ret = parse_wrapper(item)
|
|
if not isinstance(ret[0], str):
|
|
non_string = True
|
|
|
|
parsedlist.append(ret[0])
|
|
if ret[1]:
|
|
parsed = True
|
|
|
|
if not parsed:
|
|
return data
|
|
|
|
if len(parsedlist) > 0 and not non_string:
|
|
#print("Returning parsed list: ", parsedlist)
|
|
return " ".join(parsedlist)
|
|
elif len(parsedlist) == 1 and non_string:
|
|
return parsedlist[0]
|
|
else:
|
|
#print("Casting back to string because multi: ", parsedlist)
|
|
newlist = []
|
|
for item in parsedlist:
|
|
try:
|
|
newlist.append(str(item))
|
|
except ValueError:
|
|
newlist.append("parsing_error")
|
|
|
|
# Does this create the issue?
|
|
return " ".join(newlist)
|
|
|
|
# Parses JSON loops and such down to the item you're looking for
|
|
# $nodename.#.id
|
|
# $nodename.data.#min-max.info.id
|
|
def recurse_json(basejson, parsersplit):
|
|
match = "#([0-9a-z]+):?-?([0-9a-z]+)?#?"
|
|
#print("Split: %s\n%s" % (parsersplit, basejson))
|
|
try:
|
|
outercnt = 0
|
|
|
|
# Loops over split values
|
|
for value in parsersplit:
|
|
#if " " in value:
|
|
# value = value.replace(" ", "_", -1)
|
|
|
|
#print("VALUE: %s\n" % value)
|
|
actualitem = re.findall(match, value, re.MULTILINE)
|
|
#print("ACTUAL RECURSE: (%s) %s" % (value, actualitem))
|
|
if value == "#":
|
|
newvalue = []
|
|
for innervalue in basejson:
|
|
# 1. Check the next item (message)
|
|
# 2. Call this function again
|
|
|
|
try:
|
|
ret, is_loop = recurse_json(innervalue, parsersplit[outercnt+1:])
|
|
except IndexError:
|
|
# Only in here if it's the last loop without anything in it?
|
|
ret, is_loop = recurse_json(innervalue, parsersplit[outercnt:])
|
|
|
|
newvalue.append(ret)
|
|
|
|
# Magical way of returning which makes app sdk identify
|
|
# it as multi execution
|
|
return newvalue, True
|
|
|
|
elif len(actualitem) > 0:
|
|
#print("[INFO] In recursion v2: ", actualitem)
|
|
|
|
is_loop = True
|
|
newvalue = []
|
|
firstitem = actualitem[0][0]
|
|
seconditem = actualitem[0][1]
|
|
print("ACTUAL PARSED: %s" % actualitem)
|
|
|
|
# Means it's a single item -> continue
|
|
if seconditem == "":
|
|
print("[INFO] In first - handling %s. Len: %d" % (firstitem, len(basejson)))
|
|
if firstitem.lower() == "max" or firstitem.lower() == "last":
|
|
firstitem = len(basejson)-1
|
|
elif firstitem.lower() == "min" or firstitem.lower() == "first":
|
|
firstitem = 0
|
|
else:
|
|
firstitem = int(firstitem)
|
|
|
|
#print("Post lower checks")
|
|
tmpitem = basejson[int(firstitem)]
|
|
try:
|
|
newvalue, is_loop = recurse_json(tmpitem, parsersplit[outercnt+1:])
|
|
except IndexError:
|
|
newvalue, is_loop = (tmpitem, parsersplit[outercnt+1:])
|
|
else:
|
|
print("[INFO] In ELSE - handling %s and %s" % (firstitem, seconditem))
|
|
if firstitem.lower() == "max" or firstitem.lower() == "last":
|
|
firstitem = len(basejson)-1
|
|
elif firstitem.lower() == "min" or firstitem.lower() == "first":
|
|
firstitem = 0
|
|
else:
|
|
firstitem = int(firstitem)
|
|
|
|
if seconditem.lower() == "max" or seconditem.lower() == "last":
|
|
seconditem = len(basejson)-1
|
|
elif seconditem.lower() == "min" or seconditem.lower() == "first":
|
|
seconditem = 0
|
|
else:
|
|
seconditem = int(seconditem)
|
|
|
|
print("Post lower checks")
|
|
newvalue = []
|
|
if int(seconditem) > len(basejson):
|
|
seconditem = len(basejson)
|
|
|
|
for i in range(int(firstitem), int(seconditem)+1):
|
|
# 1. Check the next item (message)
|
|
# 2. Call this function again
|
|
#print("Base: %s" % basejson[i])
|
|
|
|
try:
|
|
ret, tmp_loop = recurse_json(basejson[i], parsersplit[outercnt+1:])
|
|
except IndexError:
|
|
print("INDEXERROR: ", parsersplit[outercnt])
|
|
#ret = innervalue
|
|
ret, tmp_loop = recurse_json(innervalue, parsersplit[outercnt:])
|
|
|
|
#print("IN LIST: %s" % ret)
|
|
#exit()
|
|
newvalue.append(ret)
|
|
|
|
#print("Returning %s" % newvalue)
|
|
return newvalue, is_loop
|
|
|
|
else:
|
|
#print("BEFORE NORMAL VALUE: ", basejson, value)
|
|
if len(value) == 0:
|
|
return basejson, False
|
|
|
|
try:
|
|
if isinstance(basejson, list):
|
|
print("[WARNING] VALUE IN ISINSTANCE IS NOT TO BE USED (list): %s" % value)
|
|
return basejson, False
|
|
elif isinstance(basejson[value], str):
|
|
print(f"[INFO] LOADING STRING '%s' AS JSON" % basejson[value])
|
|
try:
|
|
basejson = json.loads(basejson[value])
|
|
print("BASEJSON: %s" % basejson)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("RETURNING BECAUSE '%s' IS A NORMAL STRING" % basejson[value])
|
|
return basejson[value], False
|
|
else:
|
|
basejson = basejson[value]
|
|
except KeyError as e:
|
|
print("[WARNING] Running secondary value check with replacement of underscore in %s: %s" % (value, e))
|
|
if "_" in value:
|
|
value = value.replace("_", " ", -1)
|
|
elif " " in value:
|
|
value = value.replace(" ", "_", -1)
|
|
|
|
if isinstance(basejson, list):
|
|
print("[WARNING] VALUE IN ISINSTANCE IS NOT TO BE USED (list): %s" % value)
|
|
return basejson, False
|
|
elif isinstance(basejson[value], str):
|
|
print(f"[INFO] LOADING STRING '%s' AS JSON" % basejson[value])
|
|
try:
|
|
basejson = json.loads(basejson[value])
|
|
print("BASEJSON: %s" % basejson)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("RETURNING BECAUSE '%s' IS A NORMAL STRING" % basejson[value])
|
|
return basejson[value], False
|
|
else:
|
|
basejson = basejson[value]
|
|
|
|
|
|
#print("Parsed BASEJSON: %s" % basejson)
|
|
outercnt += 1
|
|
|
|
except KeyError as e:
|
|
print("[INFO] Lower keyerror: %s" % e)
|
|
return "", False
|
|
|
|
#return basejson
|
|
#return "KeyError: Couldn't find key: %s" % e
|
|
|
|
return basejson, False
|
|
|
|
# Takes a workflow execution as argument
|
|
# Returns a string if the result is single, or a list if it's a list
|
|
def get_json_value(execution_data, input_data):
|
|
parsersplit = input_data.split(".")
|
|
actionname_lower = parsersplit[0][1:].lower()
|
|
|
|
#Actionname: Start_node
|
|
print(f"\n[INFO] Actionname: {actionname_lower}")
|
|
|
|
# 1. Find the action
|
|
baseresult = ""
|
|
|
|
appendresult = ""
|
|
print("[INFO] Parsersplit length: %d" % len(parsersplit))
|
|
if (actionname_lower.startswith("exec ") or actionname_lower.startswith("webhook ") or actionname_lower.startswith("schedule ") or actionname_lower.startswith("userinput ") or actionname_lower.startswith("email_trigger ") or actionname_lower.startswith("trigger ")) and len(parsersplit) == 1:
|
|
record = False
|
|
for char in actionname_lower:
|
|
if char == " ":
|
|
record = True
|
|
|
|
if record:
|
|
appendresult += char
|
|
|
|
actionname_lower = "exec"
|
|
elif actionname_lower.startswith("shuffle_cache "):
|
|
actionname_lower = "shuffle_cache"
|
|
|
|
actionname_lower = actionname_lower.replace(" ", "_", -1)
|
|
|
|
try:
|
|
if actionname_lower == "exec" or actionname_lower == "webhook" or actionname_lower == "schedule" or actionname_lower == "userinput" or actionname_lower == "email_trigger" or actionname_lower == "trigger":
|
|
baseresult = execution_data["execution_argument"]
|
|
elif actionname_lower == "shuffle_cache":
|
|
print("SHOULD GET CACHE KEY: %s" % parsersplit)
|
|
if len(parsersplit) > 1:
|
|
actual_key = parsersplit[1]
|
|
print("KEY: %s" % actual_key)
|
|
cachedata = self.get_cache(actual_key)
|
|
print("CACHE: %s" % cachedata)
|
|
parsersplit.pop(1)
|
|
try:
|
|
baseresult = json.dumps(cachedata)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Failed json dumping: %s" % e)
|
|
|
|
#returndata = str(baseresult)+str(appendresult)
|
|
else:
|
|
#print("Within execution data check. Execution data: %s", execution_data["results"])
|
|
if execution_data["results"] != None:
|
|
for result in execution_data["results"]:
|
|
resultlabel = result["action"]["label"].replace(" ", "_", -1).lower()
|
|
if resultlabel.lower() == actionname_lower:
|
|
baseresult = result["result"]
|
|
break
|
|
else:
|
|
print("No results to get values from.")
|
|
baseresult = "$" + parsersplit[0][1:]
|
|
|
|
print("BEFORE VARIABLES!")
|
|
if len(baseresult) == 0:
|
|
try:
|
|
#print("WF Variables: %s" % execution_data["workflow"]["workflow_variables"])
|
|
for variable in execution_data["workflow"]["workflow_variables"]:
|
|
variablename = variable["name"].replace(" ", "_", -1).lower()
|
|
|
|
if variablename.lower() == actionname_lower:
|
|
baseresult = variable["value"]
|
|
break
|
|
except KeyError as e:
|
|
print("[INFO] KeyError wf variables: %s" % e)
|
|
pass
|
|
except TypeError as e:
|
|
print("[INFO] TypeError wf variables: %s" % e)
|
|
pass
|
|
|
|
print("BEFORE EXECUTION VAR")
|
|
if len(baseresult) == 0:
|
|
try:
|
|
#print("Execution Variables: %s" % execution_data["execution_variables"])
|
|
for variable in execution_data["execution_variables"]:
|
|
variablename = variable["name"].replace(" ", "_", -1).lower()
|
|
if variablename.lower() == actionname_lower:
|
|
baseresult = variable["value"]
|
|
break
|
|
except KeyError as e:
|
|
print("[INFO] KeyError exec variables: %s" % e)
|
|
pass
|
|
except TypeError as e:
|
|
print("[INFO] TypeError exec variables: %s" % e)
|
|
pass
|
|
|
|
except KeyError as error:
|
|
print(f"KeyError in JSON: {error}")
|
|
|
|
print(f"[INFO] After first trycatch. Baseresult")#, baseresult)
|
|
|
|
# 2. Find the JSON data
|
|
if len(baseresult) == 0:
|
|
return ""+appendresult, False
|
|
|
|
print("[INFO] After second return")
|
|
if len(parsersplit) == 1:
|
|
returndata = str(baseresult)+str(appendresult)
|
|
print("RETURNING!")#: %s" % returndata)
|
|
return returndata, False
|
|
|
|
baseresult = baseresult.replace(" True,", " true,")
|
|
baseresult = baseresult.replace(" False", " false,")
|
|
|
|
print("[INFO] After third parser return - Formatted")#, baseresult)
|
|
basejson = {}
|
|
try:
|
|
basejson = json.loads(baseresult)
|
|
except json.decoder.JSONDecodeError as e:
|
|
try:
|
|
baseresult = baseresult.replace("\'", "\"")
|
|
basejson = json.loads(baseresult)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Parser issue with JSON: %s" % e)
|
|
return str(baseresult)+str(appendresult), False
|
|
|
|
print("[INFO] After fourth parser return as JSON")
|
|
data, is_loop = recurse_json(basejson, parsersplit[1:])
|
|
parseditem = data
|
|
|
|
if isinstance(parseditem, dict) or isinstance(parseditem, list):
|
|
try:
|
|
parseditem = json.dumps(parseditem)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Parseditem issue: %s" % e)
|
|
pass
|
|
|
|
print("DATA: (%s) %s" % (type(data), data))
|
|
if is_loop:
|
|
print("DATA IS A LOOP - SHOULD WRAP")
|
|
if parsersplit[-1] == "#":
|
|
print("SET DATA WRAPPER TO NORMAL!")
|
|
parseditem = "${SHUFFLE_NO_SPLITTER%s}$" % json.dumps(data)
|
|
else:
|
|
# Return value: ${id[12345, 45678]}$
|
|
print("SET DATA WRAPPER TO %s!" % parsersplit[-1])
|
|
parseditem = "${%s%s}$" % (parsersplit[-1], json.dumps(data))
|
|
|
|
|
|
print("Before last return with %s" % appendresult)
|
|
returndata = str(parseditem)+str(appendresult)
|
|
|
|
# New in 0.8.97: Don't return items without lists
|
|
print("RETURNDATA: %s" % returndata)
|
|
#return returndata, is_loop
|
|
try:
|
|
return json.dumps(json.loads(returndata)), is_loop
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Error in decoder: %s" % e)
|
|
return returndata, is_loop
|
|
|
|
def parse_liquid(template, self):
|
|
|
|
#print("Inside liquid with glob: %s" % globals())
|
|
try:
|
|
if len(template) > 5000000:
|
|
print("Skipping liquid - size is %d" % len(template))
|
|
return template
|
|
|
|
#if not "{{" in template or not "}}" in template:
|
|
# if not "{%" in template or not "%}" in template:
|
|
# print("Skipping liquid - missing {{ }} and {% %}")
|
|
# return template
|
|
|
|
#if not "{{" in template or not "}}" in template:
|
|
# return template
|
|
|
|
#print(globals())
|
|
print("Running liquid with data of length %d" % len(template))
|
|
run = Liquid(template, mode="wild", from_file=False)
|
|
|
|
# Can't handle self yet (?)
|
|
ret = run.render(**globals())
|
|
return ret
|
|
#try:
|
|
#run = Liquid(template)
|
|
#return ret
|
|
#except liquid.exceptions.LiquidSyntaxError as e:
|
|
# run = Liquid(template, {'mode': 'python'})
|
|
# ret = run.render(**globals())
|
|
# return ret
|
|
#except liquid.exceptions.LiquidRenderError as e:
|
|
# print("Render error: %s" % e)
|
|
except jinja2.exceptions.TemplateNotFound as e:
|
|
print("[ERROR] Template error: %s" % e)
|
|
except jinja2.exceptions.TemplateSyntaxError as e:
|
|
print("[ERROR] Syntax error: %s" % e)
|
|
except:
|
|
print("[ERROR] General exception for liquid")
|
|
|
|
return template
|
|
|
|
# Parses parameters sent to it and returns whether it did it successfully with the values found
|
|
def parse_params(action, fullexecution, parameter, self):
|
|
# Skip if it starts with $?
|
|
jsonparsevalue = "$."
|
|
is_loop = False
|
|
|
|
# Matches with space in the first part, but not in subsequent parts.
|
|
# JSON / yaml etc shouldn't have spaces in their fields anyway.
|
|
#match = ".*?([$]{1}([a-zA-Z0-9 _-]+\.?){1}([a-zA-Z0-9#_-]+\.?){0,})[$/, ]?"
|
|
#match = ".*?([$]{1}([a-zA-Z0-9 _-]+\.?){1}([a-zA-Z0-9#_-]+\.?){0,})"
|
|
|
|
match = ".*?([$]{1}([a-zA-Z0-9_-]+\.?){1}([a-zA-Z0-9#_-]+\.?){0,})" # Removed space - no longer ok. Force underscore.
|
|
|
|
# Extra replacements for certain scenarios
|
|
escaped_dollar = "\\$"
|
|
escape_replacement = "\\%\\%\\%\\%\\%"
|
|
end_variable = "^_^"
|
|
|
|
#print("Input value: %s" % parameter["value"])
|
|
try:
|
|
parameter["value"] = parameter["value"].replace(escaped_dollar, escape_replacement, -1)
|
|
except:
|
|
print("Error in initial replacement of escaped dollar!")
|
|
|
|
#print("POST input value: %s" % parameter["value"])
|
|
|
|
# Regex to find all the things
|
|
if parameter["variant"] == "STATIC_VALUE":
|
|
data = parameter["value"]
|
|
actualitem = re.findall(match, data, re.MULTILINE)
|
|
#self.logger.debug(f"\n\nHandle static data with JSON: {data}\n\n")
|
|
#self.logger.info("STATIC PARSED: %s" % actualitem)
|
|
if len(actualitem) > 0:
|
|
print("ACTUAL: ", actualitem)
|
|
for replace in actualitem:
|
|
try:
|
|
to_be_replaced = replace[0]
|
|
except IndexError:
|
|
continue
|
|
|
|
# Handles for loops etc.
|
|
# FIXME: Should it dump to string here? Doesn't that defeat the purpose?
|
|
# Trying without string dumping.
|
|
|
|
value, is_loop = get_json_value(fullexecution, to_be_replaced)
|
|
#print("\n\nType of value: %s. Value: %s" % (type(value), value))
|
|
print("\n\nType of value: %s" % type(value))
|
|
if isinstance(value, str):
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, value)
|
|
elif isinstance(value, dict) or isinstance(value, list):
|
|
# Changed from JSON dump to str() 28.05.2021
|
|
# This makes it so the parameters gets lists and dicts straight up
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, json.dumps(value))
|
|
|
|
#try:
|
|
# parameter["value"] = parameter["value"].replace(to_be_replaced, str(value))
|
|
#except:
|
|
# parameter["value"] = parameter["value"].replace(to_be_replaced, json.dumps(value))
|
|
# print("Failed parsing value as string?")
|
|
else:
|
|
print("Unknown type %s" % type(value))
|
|
try:
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, json.dumps(value))
|
|
except json.decoder.JSONDecodeError as e:
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, value)
|
|
|
|
#print("VALUE: %s" % parameter["value"])
|
|
|
|
if parameter["variant"] == "WORKFLOW_VARIABLE":
|
|
print("Handling workflow variable")
|
|
found = False
|
|
try:
|
|
for item in fullexecution["workflow"]["workflow_variables"]:
|
|
if parameter["action_field"] == item["name"]:
|
|
found = True
|
|
parameter["value"] = item["value"]
|
|
break
|
|
except KeyError as e:
|
|
print("KeyError WF variable 1: %s" % e)
|
|
pass
|
|
except TypeError as e:
|
|
print("TypeError WF variables 1: %s" % e)
|
|
pass
|
|
|
|
if not found:
|
|
try:
|
|
for item in fullexecution["execution_variables"]:
|
|
if parameter["action_field"] == item["name"]:
|
|
parameter["value"] = item["value"]
|
|
break
|
|
except KeyError as e:
|
|
print("KeyError WF variable 2: %s" % e)
|
|
pass
|
|
except TypeError as e:
|
|
print("TypeError WF variables 2: %s" % e)
|
|
pass
|
|
|
|
elif parameter["variant"] == "ACTION_RESULT":
|
|
# FIXME - calculate value based on action_field and $if prominent
|
|
# FIND THE RIGHT LABEL
|
|
# GET THE LABEL'S RESULT
|
|
|
|
tmpvalue = ""
|
|
self.logger.info("ACTION FIELD: %s" % parameter["action_field"])
|
|
|
|
fullname = "$"
|
|
if parameter["action_field"] == "Execution Argument":
|
|
tmpvalue = fullexecution["execution_argument"]
|
|
fullname += "exec"
|
|
else:
|
|
fullname += parameter["action_field"]
|
|
|
|
self.logger.info("PRE Fullname: %s" % fullname)
|
|
|
|
if parameter["value"].startswith(jsonparsevalue):
|
|
fullname += parameter["value"][1:]
|
|
#else:
|
|
# fullname = "$%s" % parameter["action_field"]
|
|
|
|
self.logger.info("Fullname: %s" % fullname)
|
|
actualitem = re.findall(match, fullname, re.MULTILINE)
|
|
self.logger.info("ACTION PARSED: %s" % actualitem)
|
|
if len(actualitem) > 0:
|
|
for replace in actualitem:
|
|
try:
|
|
to_be_replaced = replace[0]
|
|
except IndexError:
|
|
print("Nothing to replace?: " % e)
|
|
continue
|
|
|
|
# This will never be a loop aka multi argument
|
|
parameter["value"] = to_be_replaced
|
|
|
|
value, is_loop = get_json_value(fullexecution, to_be_replaced)
|
|
print("Loop: %s" % is_loop)
|
|
if isinstance(value, str):
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, value)
|
|
elif isinstance(value, dict):
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, json.dumps(value))
|
|
else:
|
|
print("Unknown type %s" % type(value))
|
|
try:
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, json.dumps(value))
|
|
except json.decoder.JSONDecodeError as e:
|
|
parameter["value"] = parameter["value"].replace(to_be_replaced, value)
|
|
|
|
#print("PRE Replaced data: %s" % parameter["value"])
|
|
|
|
try:
|
|
parameter["value"] = parameter["value"].replace(end_variable, "", -1)
|
|
parameter["value"] = parameter["value"].replace(escape_replacement, "$", -1)
|
|
except:
|
|
print("Error in datareplacement")
|
|
|
|
# Just here in case it breaks
|
|
# Implemented 02.08.2021
|
|
#print("Pre liquid: %s" % parameter["value"])
|
|
try:
|
|
parameter["value"] = parse_liquid(parameter["value"], self)
|
|
except:
|
|
pass
|
|
|
|
#print("Replaced data: %s" % parameter["value"])
|
|
|
|
#print("POST liquid: %s" % parameter["value"])
|
|
return "", parameter["value"], is_loop
|
|
|
|
def run_validation(sourcevalue, check, destinationvalue):
|
|
self.logger.info("Checking %s %s %s" % (sourcevalue, check, destinationvalue))
|
|
|
|
if check == "=" or check.lower() == "equals":
|
|
if str(sourcevalue).lower() == str(destinationvalue).lower():
|
|
return True
|
|
elif check == "!=" or check.lower() == "does not equal":
|
|
if str(sourcevalue).lower() != str(destinationvalue).lower():
|
|
return True
|
|
elif check.lower() == "startswith":
|
|
if str(sourcevalue).lower().startswith(str(destinationvalue).lower()):
|
|
return True
|
|
elif check.lower() == "endswith":
|
|
if str(sourcevalue).lower().endswith(str(destinationvalue).lower()):
|
|
return True
|
|
elif check.lower() == "contains":
|
|
if destinationvalue.lower() in sourcevalue.lower():
|
|
return True
|
|
|
|
elif check.lower() == "is empty":
|
|
if len(sourcevalue) == 0:
|
|
return True
|
|
|
|
if str(sourcevalue) == 0:
|
|
return True
|
|
|
|
return False
|
|
#if tmp == "[]":
|
|
# tmp = []
|
|
|
|
#if type(tmp) == list and len(tmp) == 0 and not flip:
|
|
# new_list.append(item)
|
|
#elif type(tmp) == list and len(tmp) > 0 and flip:
|
|
# new_list.append(item)
|
|
#elif type(tmp) == str and not tmp and not flip:
|
|
# new_list.append(item)
|
|
#elif type(tmp) == str and tmp and flip:
|
|
# new_list.append(item)
|
|
#else:
|
|
# failed_list.append(item)
|
|
|
|
elif check.lower() == "contains_any_of":
|
|
newvalue = [destinationvalue.lower()]
|
|
if "," in destinationvalue:
|
|
newvalue = destinationvalue.split(",")
|
|
elif ", " in destinationvalue:
|
|
newvalue = destinationvalue.split(", ")
|
|
|
|
for item in newvalue:
|
|
if not item:
|
|
continue
|
|
|
|
if item.strip() in sourcevalue:
|
|
print("[INFO] Found %s in %s" % (item, sourcevalue))
|
|
return True
|
|
|
|
return False
|
|
elif check.lower() == "larger than" or check.lower() == "bigger than":
|
|
try:
|
|
if str(sourcevalue).isdigit() and str(destinationvalue).isdigit():
|
|
if int(sourcevalue) > int(destinationvalue):
|
|
return True
|
|
|
|
except AttributeError as e:
|
|
self.logger.error("[WARNING] Condition larger than failed with values %s and %s: %s" % (sourcevalue, destinationvalue, e))
|
|
return False
|
|
elif check.lower() == "smaller than" or check.lower() == "less than":
|
|
try:
|
|
if str(sourcevalue).isdigit() and str(destinationvalue).isdigit():
|
|
if int(sourcevalue) < int(destinationvalue):
|
|
return True
|
|
|
|
except AttributeError as e:
|
|
self.logger.error("[WARNING] Condition smaller than failed with values %s and %s: %s" % (sourcevalue, destinationvalue, e))
|
|
return False
|
|
elif check.lower() == "re" or check.lower() == "matches regex":
|
|
try:
|
|
found = re.search(destinationvalue, sourcevalue)
|
|
except re.error as e:
|
|
print("[WARNING] Regex error in condition: %s" % e)
|
|
return False
|
|
|
|
if found == None:
|
|
return False
|
|
|
|
return True
|
|
else:
|
|
self.logger.info("Condition: can't handle %s yet. Setting to true" % check)
|
|
|
|
return False
|
|
|
|
def check_branch_conditions(action, fullexecution, self):
|
|
# relevantbranches = workflow.branches where destination = action
|
|
try:
|
|
if fullexecution["workflow"]["branches"] == None or len(fullexecution["workflow"]["branches"]) == 0:
|
|
return True, ""
|
|
except KeyError:
|
|
return True, ""
|
|
|
|
relevantbranches = []
|
|
for branch in fullexecution["workflow"]["branches"]:
|
|
if branch["destination_id"] != action["id"]:
|
|
continue
|
|
|
|
# Remove anything without a condition
|
|
try:
|
|
if (branch["conditions"]) == 0 or branch["conditions"] == None:
|
|
continue
|
|
except KeyError:
|
|
continue
|
|
|
|
self.logger.info("Relevant conditions: %s" % branch["conditions"])
|
|
successful_conditions = []
|
|
failed_conditions = []
|
|
for condition in branch["conditions"]:
|
|
self.logger.info("Getting condition value of %s" % condition)
|
|
|
|
# Parse all values first here
|
|
sourcevalue = condition["source"]["value"]
|
|
check, sourcevalue, is_loop = parse_params(action, fullexecution, condition["source"], self)
|
|
if check:
|
|
return False, {"success": False, "reason": "Failed condition: %s %s %s because %s" % (sourcevalue, condition["condition"]["value"], destinationvalue, check)}
|
|
|
|
|
|
#sourcevalue = sourcevalue.encode("utf-8")
|
|
sourcevalue = parse_wrapper_start(sourcevalue)
|
|
destinationvalue = condition["destination"]["value"]
|
|
|
|
check, destinationvalue, is_loop = parse_params(action, fullexecution, condition["destination"], self)
|
|
if check:
|
|
return False, {"success": False, "reason": "Failed condition: %s %s %s because %s" % (sourcevalue, condition["condition"]["value"], destinationvalue, check)}
|
|
|
|
#destinationvalue = destinationvalue.encode("utf-8")
|
|
destinationvalue = parse_wrapper_start(destinationvalue)
|
|
available_checks = [
|
|
"=",
|
|
"equals",
|
|
"!=",
|
|
"does not equal",
|
|
">",
|
|
"larger than",
|
|
"<",
|
|
"less than",
|
|
">=",
|
|
"<=",
|
|
"startswith",
|
|
"endswith",
|
|
"contains",
|
|
"contains_any_of",
|
|
"re",
|
|
"matches regex",
|
|
]
|
|
|
|
if not condition["condition"]["value"] in available_checks:
|
|
self.logger.warning("Skipping %s %s %s because %s is invalid." % (sourcevalue, condition["condition"]["value"], destinationvalue, condition["condition"]["value"]))
|
|
continue
|
|
|
|
#print(destinationvalue)
|
|
# NEGATE
|
|
|
|
# Configuration = negated because of WorkflowAppActionParam..
|
|
validation = run_validation(sourcevalue, condition["condition"]["value"], destinationvalue)
|
|
try:
|
|
if condition["condition"]["configuration"]:
|
|
validation = not validation
|
|
except KeyError:
|
|
pass
|
|
|
|
if not validation:
|
|
self.logger.info("Failed condition check for %s %s %s." % (sourcevalue, condition["condition"]["value"], destinationvalue))
|
|
return False, {"success": False, "reason": "Failed condition: %s %s %s" % (sourcevalue, condition["condition"]["value"], destinationvalue)}
|
|
|
|
|
|
# Make a general parser here, at least to get param["name"] = param["value"] in maparameter[string]string
|
|
#for condition in branch.conditons:
|
|
|
|
return True, ""
|
|
|
|
|
|
|
|
# THE START IS ACTUALLY RIGHT HERE :O
|
|
# Checks whether conditions are met, otherwise set
|
|
branchcheck, tmpresult = check_branch_conditions(action, fullexecution, self)
|
|
if isinstance(tmpresult, object) or isinstance(tmpresult, list):
|
|
print("Fixing branch return as object -> string")
|
|
try:
|
|
#tmpresult = tmpresult.replace("'", "\"")
|
|
tmpresult = json.dumps(tmpresult)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print(f"[WARNING] Failed condition parsing {tmpresult} to string")
|
|
|
|
if not branchcheck:
|
|
self.logger.info("Failed one or more branch conditions.")
|
|
action_result["result"] = tmpresult
|
|
action_result["status"] = "SKIPPED"
|
|
try:
|
|
ret = requests.post("%s%s" % (self.base_url, stream_path), headers=headers, json=action_result)
|
|
self.logger.info("Result: %d" % ret.status_code)
|
|
if ret.status_code != 200:
|
|
self.logger.info(ret.text)
|
|
except requests.exceptions.ConnectionError as e:
|
|
self.logger.exception(e)
|
|
|
|
print("\n\nRETURNING BECAUSE A BRANCH FAILED: %s\n\n" % tmpresult)
|
|
return
|
|
|
|
# Replace name cus there might be issues
|
|
# Not doing lower() as there might be user-made functions
|
|
actionname = action["name"]
|
|
if " " in actionname:
|
|
actionname.replace(" ", "_", -1)
|
|
|
|
|
|
#if action.generated:
|
|
# actionname = actionname.lower()
|
|
|
|
# Runs the actual functions
|
|
try:
|
|
func = getattr(self, actionname, None)
|
|
if func == None:
|
|
self.logger.debug(f"Failed executing {actionname} because func is None.")
|
|
action_result["status"] = "FAILURE"
|
|
action_result["result"] = "Function %s doesn't exist." % actionname
|
|
elif callable(func):
|
|
try:
|
|
if len(action["parameters"]) < 1:
|
|
result = await func()
|
|
else:
|
|
# Potentially parse JSON here
|
|
# FIXME - add potential authentication as first parameter(s) here
|
|
# params[parameter["name"]] = parameter["value"]
|
|
#print(fullexecution["authentication"]
|
|
# What variables are necessary here tho hmm
|
|
|
|
params = {}
|
|
try:
|
|
for item in action["authentication"]:
|
|
#print("AUTH: ", key, value)
|
|
params[item["key"]] = item["value"]
|
|
except KeyError:
|
|
print("No authentication specified!")
|
|
pass
|
|
#action["authentication"]
|
|
|
|
# Fixes OpenAPI body parameters for later.
|
|
newparams = []
|
|
counter = -1
|
|
bodyindex = -1
|
|
for parameter in action["parameters"]:
|
|
counter += 1
|
|
|
|
# Hack for key:value in options using ||
|
|
try:
|
|
if parameter["options"] != None and len(parameter["options"]) > 0:
|
|
#print(f'OPTIONS: {parameter["options"]}')
|
|
#print(f'OPTIONS VAL: {parameter}')
|
|
if "||" in parameter["value"]:
|
|
splitvalue = parameter["value"].split("||")
|
|
if len(splitvalue) > 1:
|
|
#print(f'[INFO] Parsed split || options of actions["parameters"]["name"]')
|
|
action["parameters"][counter]["value"] = splitvalue[1]
|
|
|
|
except (IndexError, KeyError, TypeError) as e:
|
|
print("[WARNING] Options err: {e}")
|
|
|
|
# This part is purely for OpenAPI accessibility.
|
|
# It replaces the data back into the main item
|
|
# Earlier, we handled each of the items and did later string replacement,
|
|
# but this has changed to do lists within items and such
|
|
if parameter["name"] == "body":
|
|
bodyindex = counter
|
|
#print("PARAM: %s" % parameter)
|
|
try:
|
|
values = parameter["value_replace"]
|
|
if values != None:
|
|
added = 0
|
|
for val in values:
|
|
replace_value = val["value"]
|
|
replace_key = val["key"]
|
|
if (val["value"].startswith("{") and val["value"].endswith("}")) or (val["value"].startswith("[") and val["value"].endswith("]")):
|
|
print(f"""Trying to parse as JSON: {val["value"]}""")
|
|
try:
|
|
value_replace = json.loads(val["value"])
|
|
# If it gets here, remove the "" infront and behind the key as well since this is preventing the JSON from being loaded
|
|
replace_key = f"\"{replace_key}\""
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Failed JSON replacement for OpenAPI %s", val["key"])
|
|
elif val["value"].lower() == "true" or val["value"].lower() == "false":
|
|
replace_key = f"\"{replace_key}\""
|
|
|
|
action["parameters"][counter]["value"] = action["parameters"][counter]["value"].replace(replace_key, replace_value, 1)
|
|
|
|
print(f'[INFO] Added param {val["key"]} for body (using OpenAPI)')
|
|
added += 1
|
|
|
|
#action["parameters"]["body"]
|
|
|
|
print("ADDED %d parameters for body" % added)
|
|
except KeyError as e:
|
|
print("KeyError body OpenAPI: %s" % e)
|
|
pass
|
|
|
|
|
|
print(f"""HANDLING {action["parameters"][counter]["value"]}""")
|
|
try:
|
|
newvalue = json.loads(action["parameters"][counter]["value"])
|
|
deletekeys = []
|
|
for key, value in newvalue.items():
|
|
print(key, value)
|
|
if isinstance(value, str) and len(value) == 0:
|
|
deletekeys.append(key)
|
|
continue
|
|
|
|
if value == "${%s}" % key:
|
|
print("Deleting %s because key = value")
|
|
deletekeys.append(key)
|
|
continue
|
|
|
|
for deletekey in deletekeys:
|
|
del newvalue[deletekey]
|
|
|
|
print("Post delete: %s" % newvalue)
|
|
for key, value in newvalue.items():
|
|
try:
|
|
value = json.loads(value)
|
|
newvalue[key] = value
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Inner overwrite issue: %s" % e)
|
|
|
|
action["parameters"][counter]["value"] = json.dumps(newvalue)
|
|
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("Failed JSON replacement for OpenAPI keys (2) {e}")
|
|
|
|
break
|
|
|
|
#print(action["parameters"])
|
|
for parameter in newparams:
|
|
action["parameters"].append(parameter)
|
|
|
|
# calltimes is used to handle forloops in the app itself.
|
|
# 2 kinds of loop - one in gui with one app each, and one like this,
|
|
# which is super fast, but has a bad overview (potentially good tho)
|
|
calltimes = 1
|
|
result = ""
|
|
|
|
all_executions = []
|
|
|
|
# Multi_parameter has the data for each. variable
|
|
minlength = 0
|
|
multi_parameters = json.loads(json.dumps(params))
|
|
multiexecution = False
|
|
multi_execution_lists = []
|
|
remove_params = []
|
|
for parameter in action["parameters"]:
|
|
check, value, is_loop = parse_params(action, fullexecution, parameter, self)
|
|
if check:
|
|
raise "Value check error: %s" % Exception(check)
|
|
|
|
# Custom format for ${name[0,1,2,...]}$
|
|
#submatch = "([${]{2}([0-9a-zA-Z_-]+)(\[.*\])[}$]{2})"
|
|
#print(f"Returnedvalue: {value}")
|
|
# OLD: Used until 13.03.2021: submatch = "([${]{2}#?([0-9a-zA-Z_-]+)#?(\[.*\])[}$]{2})"
|
|
# \${[0-9a-zA-Z_-]+#?(\[.*?]}\$)
|
|
submatch = "([${]{2}#?([0-9a-zA-Z_-]+)#?(\[.*?]}\$))"
|
|
actualitem = re.findall(submatch, value, re.MULTILINE)
|
|
try:
|
|
if action["skip_multicheck"]:
|
|
print("Skipping multicheck")
|
|
actualitem = []
|
|
except KeyError:
|
|
pass
|
|
|
|
#print("Return value: %s" % value)
|
|
actionname = action["name"]
|
|
#print("Multicheck ", actualitem)
|
|
#print("ITEM LENGTH: %d, Actual item: %s" % (len(actualitem), actualitem))
|
|
if len(actualitem) > 0:
|
|
multiexecution = True
|
|
|
|
# Loop WITHOUT JSON variables go here.
|
|
# Loop WITH variables go in else.
|
|
print("Before first part in multiexec!")
|
|
handled = False
|
|
|
|
# Has a loop without a variable used inside
|
|
if len(actualitem[0]) > 2 and actualitem[0][1] == "SHUFFLE_NO_SPLITTER":
|
|
|
|
print("(1) Pre replacement: %s" % actualitem[0][2])
|
|
tmpitem = value
|
|
|
|
index = 0
|
|
replacement = actualitem[index][2]
|
|
if replacement.endswith("}$"):
|
|
replacement = replacement[:-2]
|
|
|
|
if replacement.startswith("\"") and replacement.endswith("\""):
|
|
replacement = replacement[1:len(replacement)-1]
|
|
|
|
print("POST replacement: %s" % replacement)
|
|
|
|
#json_replacement = tmpitem.replace(actualitem[index][0], replacement, 1)
|
|
#print("AFTER POST replacement: %s" % json_replacement)
|
|
json_replacement = replacement
|
|
try:
|
|
json_replacement = json.loads(replacement)
|
|
except json.decoder.JSONDecodeError as e:
|
|
try:
|
|
replacement = replacement.replace("\'", "\"", -1)
|
|
json_replacement = json.loads(replacement)
|
|
except:
|
|
print("JSON error singular: %s" % e)
|
|
|
|
if len(json_replacement) > minlength:
|
|
minlength = len(json_replacement)
|
|
|
|
print("PRE new_replacement")
|
|
|
|
new_replacement = []
|
|
for i in range(len(json_replacement)):
|
|
if isinstance(json_replacement[i], dict) or isinstance(json_replacement[i], list):
|
|
tmp_replacer = json.dumps(json_replacement[i])
|
|
newvalue = tmpitem.replace(actualitem[index][0], tmp_replacer, 1)
|
|
else:
|
|
newvalue = tmpitem.replace(actualitem[index][0], json_replacement[i], 1)
|
|
|
|
try:
|
|
newvalue = json.loads(newvalue)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("DECODER ERROR: %s" % e)
|
|
pass
|
|
|
|
new_replacement.append(newvalue)
|
|
|
|
print("New replacement: %s" % new_replacement)
|
|
|
|
# New
|
|
tmpitem = tmpitem.replace(actualitem[index][0], replacement, 1)
|
|
|
|
# This code handles files.
|
|
resultarray = []
|
|
isfile = False
|
|
try:
|
|
print("(1) ------------ PARAM: %s" % parameter["schema"]["type"])
|
|
if parameter["schema"]["type"] == "file" and len(value) > 0:
|
|
print("(1) SHOULD HANDLE FILE IN MULTI. Get based on value %s" % tmpitem)
|
|
# This is silly :)
|
|
# Q: Is there something wrong with the download system?
|
|
# It seems to return "FILE CONTENT: %s" with the ID as %s
|
|
for tmp_file_split in json.loads(tmpitem):
|
|
print("(1) PRE GET FILE %s" % tmp_file_split)
|
|
file_value = self.get_file(tmp_file_split)
|
|
print("(1) POST AWAIT %s" % file_value)
|
|
resultarray.append(file_value)
|
|
print("(1) FILE VALUE FOR VAL %s: %s" % (tmp_file_split, file_value))
|
|
|
|
isfile = True
|
|
except NameError as e:
|
|
print("(1) SCHEMA NAMEERROR IN FILE HANDLING: %s" % e)
|
|
except KeyError as e:
|
|
print("(1) SCHEMA KEYERROR IN FILE HANDLING: %s" % e)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("(1) JSON ERROR IN FILE HANDLING: %s" % e)
|
|
|
|
if not isfile:
|
|
print("Resultarray (NOT FILE): %s" % resultarray)
|
|
params[parameter["name"]] = tmpitem
|
|
multi_parameters[parameter["name"]] = new_replacement
|
|
else:
|
|
print("Resultarray (FILE): %s" % resultarray)
|
|
params[parameter["name"]] = resultarray
|
|
multi_parameters[parameter["name"]] = resultarray
|
|
|
|
#if len(resultarray) == 0:
|
|
# print("[WARNING] Returning empty array because the array length to be looped is 0 (1)")
|
|
# action_result["status"] = "SUCCESS"
|
|
# action_result["result"] = "[]"
|
|
# self.send_result(action_result, headers, stream_path)
|
|
# return
|
|
|
|
multi_execution_lists.append(new_replacement)
|
|
#print("MULTI finished: %s" % json_replacement)
|
|
else:
|
|
print(f"(2) Pre replacement (loop with variables). Variables: {actualitem}") #% actualitem)
|
|
# This is here to handle for loops within variables.. kindof
|
|
# 1. Find the length of the longest array
|
|
# 2. Build an array with the base values based on parameter["value"]
|
|
# 3. Get the n'th value of the generated list from values
|
|
# 4. Execute all n answers
|
|
replacements = {}
|
|
curminlength = 0
|
|
for replace in actualitem:
|
|
try:
|
|
to_be_replaced = replace[0]
|
|
actualitem = replace[2]
|
|
if actualitem.endswith("}$"):
|
|
actualitem = actualitem[:-2]
|
|
except IndexError:
|
|
continue
|
|
|
|
#print(f"\n\nTMPITEM: {actualitem}\n\n")
|
|
#actualitem = parse_wrapper_start(actualitem)
|
|
#print(f"\n\nTMPITEM2: {actualitem}\n\n")
|
|
|
|
try:
|
|
itemlist = json.loads(actualitem)
|
|
if len(itemlist) > minlength:
|
|
minlength = len(itemlist)
|
|
|
|
if len(itemlist) > curminlength:
|
|
curminlength = len(itemlist)
|
|
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("JSON Error (replace): %s in %s" % (e, actualitem))
|
|
|
|
replacements[to_be_replaced] = actualitem
|
|
|
|
|
|
# Parses the data as string with length, split etc. before moving on.
|
|
|
|
|
|
#print("In second part of else: %s" % (len(itemlist)))
|
|
# This is a result array for JUST this value..
|
|
# What if there are more?
|
|
resultarray = []
|
|
for i in range(0, curminlength):
|
|
tmpitem = json.loads(json.dumps(parameter["value"]))
|
|
for key, value in replacements.items():
|
|
replacement = json.dumps(json.loads(value)[i])
|
|
if replacement.startswith("\"") and replacement.endswith("\""):
|
|
replacement = replacement[1:len(replacement)-1]
|
|
#except json.decoder.JSONDecodeError as e:
|
|
|
|
#print("REPLACING %s with %s" % (key, replacement))
|
|
#replacement = parse_wrapper_start(replacement)
|
|
tmpitem = tmpitem.replace(key, replacement, -1)
|
|
|
|
|
|
# This code handles files.
|
|
print("(2) ------------ PARAM: %s" % parameter["schema"]["type"])
|
|
isfile = False
|
|
try:
|
|
if parameter["schema"]["type"] == "file" and len(value) > 0:
|
|
print("(2) SHOULD HANDLE FILE IN MULTI. Get based on value %s" % parameter["value"])
|
|
|
|
for tmp_file_split in json.loads(parameter["value"]):
|
|
print("(2) PRE GET FILE %s" % tmp_file_split)
|
|
file_value = self.get_file(tmp_file_split)
|
|
print("(2) POST AWAIT %s" % file_value)
|
|
resultarray.append(file_value)
|
|
print("(2) FILE VALUE FOR VAL %s: %s" % (tmp_file_split, file_value))
|
|
|
|
|
|
isfile = True
|
|
except KeyError as e:
|
|
print("(2) SCHEMA ERROR IN FILE HANDLING: %s" % e)
|
|
except json.decoder.JSONDecodeError as e:
|
|
print("(2) JSON ERROR IN FILE HANDLING: %s" % e)
|
|
|
|
if not isfile:
|
|
resultarray.append(tmpitem)
|
|
|
|
# With this parameter ready, add it to... a greater list of parameters. Rofl
|
|
print("LENGTH OF ARR: %d" % len(resultarray))
|
|
if len(resultarray) == 0:
|
|
print("[WARNING] Returning empty array because the array length to be looped is 0 (0)")
|
|
action_result["status"] = "SUCCESS"
|
|
action_result["result"] = "[]"
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
#print("RESULTARRAY: %s" % resultarray)
|
|
if resultarray not in multi_execution_lists:
|
|
multi_execution_lists.append(resultarray)
|
|
|
|
multi_parameters[parameter["name"]] = resultarray
|
|
|
|
#if parameter["id"] == "body_replacement":
|
|
# print("Should run body MULTI replacement in index %d with %s" % (bodyindex, parameter))
|
|
# try:
|
|
# print("PREBODY: %s" % params["body"])
|
|
|
|
# parsedarray = str(resultarray)
|
|
# try:
|
|
# parsedarray = json.dumps(resultarray)
|
|
# except:
|
|
# pass
|
|
|
|
# if f'\"{parameter["name"]}\"' in params["body"]:
|
|
# params["body"] = params["body"].replace(f'\"{parameter["name"]}\"' , parsedarray, -1)
|
|
# multi_parameters["body"] = multi_parameters["body"].replace(f'\"{parameter["name"]}\"' , parsedarray, -1)
|
|
# else:
|
|
# params["body"] = params["body"].replace(parameter["name"], parsedarray, -1)
|
|
# multi_parameters["body"] = multi_parameters["body"].replace(parameter["name"], parsedarray, -1)
|
|
|
|
# #print("POSTBODY: %s" % params["body"])
|
|
# #if isinstance(multi_parameters, list):
|
|
# # print("MULTIPARAM AS LIST (NOT REPLACING!!)!")
|
|
# # for multiparam in multi_parameters:
|
|
# # print(f"MULTIPARAM: {multiparam}")
|
|
# # #multi_parameters["body"] = multi_parameters["body"].replace(parameter["name"], str(parameter["value"]), -1)
|
|
# #else:
|
|
|
|
# except KeyError as e:
|
|
# print("KEYERROR: %s" % e)
|
|
|
|
# remove_params.append(parameter["name"])
|
|
# #bodyindex = counter
|
|
# continue
|
|
|
|
else:
|
|
# Parses things like int(value)
|
|
print("Normal parsing (not looping)")#with data %s" % value)
|
|
value = parse_wrapper_start(value)
|
|
|
|
#if parameter["id"] == "body_replacement":
|
|
# print("Should run body replacement in index %d with %s" % (bodyindex, parameter))
|
|
# try:
|
|
# print("PREBODY: %s" % params["body"])
|
|
# params["body"] = params["body"].replace(parameter["name"], parameter["value"], -1)
|
|
# print("POSTBODY: %s" % params["body"])
|
|
# except KeyError as e:
|
|
# print("KEYERROR: %s" % e)
|
|
|
|
# #bodyindex = counter
|
|
# continue
|
|
|
|
#for parameter in action["parameters"]:
|
|
#if parameter["name"] == "body":
|
|
# print("PARAM: %s" % parameter)
|
|
#if param.id == "body_replacement":
|
|
|
|
#print("POST data value: %s" % value)
|
|
params[parameter["name"]] = value
|
|
multi_parameters[parameter["name"]] = value
|
|
|
|
# This code handles files.
|
|
try:
|
|
if parameter["schema"]["type"] == "file" and len(value) > 0:
|
|
print("\n SHOULD HANDLE FILE. Get based on value %s. <--- is this a valid ID?" % parameter["value"])
|
|
file_value = self.get_file(value)
|
|
print("FILE VALUE: %s \n" % file_value)
|
|
|
|
params[parameter["name"]] = file_value
|
|
multi_parameters[parameter["name"]] = file_value
|
|
except KeyError as e:
|
|
print("SCHEMA ERROR IN FILE HANDLING: %s" % e)
|
|
|
|
|
|
#remove_params.append(parameter["name"])
|
|
# Fix lists here
|
|
# FIXME: This doesn't really do anything anymore
|
|
print("CHECKING multi execution list!")
|
|
if len(multi_execution_lists) > 0:
|
|
print("\n Multi execution list has more data: %d" % len(multi_execution_lists))
|
|
filteredlist = []
|
|
for listitem in multi_execution_lists:
|
|
if listitem in filteredlist:
|
|
continue
|
|
|
|
# FIXME: Subsub required?. Recursion!
|
|
# Basically multiply what we have with the outer loop?
|
|
#
|
|
#if isinstance(listitem, list):
|
|
# for subitem in listitem:
|
|
# filteredlist.append(subitem)
|
|
#else:
|
|
# filteredlist.append(listitem)
|
|
|
|
#print("New list length: %d" % len(filteredlist))
|
|
if len(filteredlist) > 1:
|
|
print(f"Calculating new multi-loop length with {len(filteredlist)} lists")
|
|
tmplength = 1
|
|
for innerlist in filteredlist:
|
|
tmplength = len(innerlist)*tmplength
|
|
print("List length: %d. %d*%d" % (tmplength, len(innerlist), tmplength))
|
|
|
|
minlength = tmplength
|
|
|
|
print("New multi execution length: %d\n" % tmplength)
|
|
|
|
# Cleaning up extra list params
|
|
for subparam in remove_params:
|
|
#print(f"DELETING {subparam}")
|
|
try:
|
|
del params[subparam]
|
|
except:
|
|
pass
|
|
#print(f"Error with subparam deletion of {subparam} in {params}")
|
|
try:
|
|
del multi_parameters[subparam]
|
|
except:
|
|
#print(f"Error with subparam deletion of {subparam} in {multi_parameters} (2)")
|
|
pass
|
|
|
|
#print()
|
|
#print(f"Param: {params}")
|
|
#print(f"Multiparams: {multi_parameters}")
|
|
#print()
|
|
|
|
if not multiexecution:
|
|
# Runs a single iteration here
|
|
new_params = self.validate_unique_fields(params)
|
|
print(f"Returned with newparams of length {len(new_params)}")
|
|
if isinstance(new_params, list) and len(new_params) == 1:
|
|
params = new_params[0]
|
|
else:
|
|
print("[WARNING] SHOULD STOP EXECUTION BECAUSE FIELDS AREN'T UNIQUE")
|
|
action_result["status"] = "SKIPPED"
|
|
action_result["result"] = f"A non-unique value was found"
|
|
action_result["completed_at"] = int(time.time())
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
print("[INFO] Running normal execution (not loop)\n")
|
|
|
|
#newres = await func(**params)
|
|
#print("PARAMS: %s" % params)
|
|
#newres = ""
|
|
while True:
|
|
try:
|
|
newres = await func(**params)
|
|
break
|
|
except TypeError as e:
|
|
newres = ""
|
|
errorstring = "%s" % e
|
|
if "got an unexpected keyword argument" in errorstring:
|
|
fieldsplit = errorstring.split("'")
|
|
if len(fieldsplit) > 1:
|
|
field = fieldsplit[1]
|
|
|
|
try:
|
|
del params[field]
|
|
print("Removed field invalid field %s" % field)
|
|
except KeyError:
|
|
break
|
|
else:
|
|
raise e
|
|
#break
|
|
|
|
print("\n[INFO] Returned from execution with types %s" % type(newres))
|
|
#print("\n[INFO] Returned from execution with %s of types %s" % (newres, type(newres)))#, newres)
|
|
if isinstance(newres, tuple):
|
|
print("[INFO] Handling return as tuple")
|
|
# Handles files.
|
|
filedata = ""
|
|
file_ids = []
|
|
print("TUPLE: %s" % newres[1])
|
|
if isinstance(newres[1], list):
|
|
print("[INFO] HANDLING LIST FROM RET")
|
|
file_ids = self.set_files(newres[1])
|
|
elif isinstance(newres[1], object):
|
|
print("[INFO] Handling JSON from ret")
|
|
file_ids = self.set_files([newres[1]])
|
|
elif isinstance(newres[1], str):
|
|
print("[INFO] Handling STRING from ret")
|
|
file_ids = self.set_files([newres[1]])
|
|
else:
|
|
print("[INFO] NO FILES TO HANDLE")
|
|
|
|
tmp_result = {
|
|
"result": newres[0],
|
|
"file_ids": file_ids
|
|
}
|
|
|
|
result = json.dumps(tmp_result)
|
|
elif isinstance(newres, str):
|
|
print("[INFO] Handling return as string of length %d" % len(newres))
|
|
result += newres
|
|
elif isinstance(newres, dict) or isinstance(newres, list):
|
|
try:
|
|
result += json.dumps(newres, indent=4)
|
|
except json.JSONDecodeError as e:
|
|
print("Failed decoding result: %s" % e)
|
|
|
|
try:
|
|
result += str(newres)
|
|
except ValueError:
|
|
result += "Failed autocasting. Can't handle %s type from function. Must be string" % type(newres)
|
|
print("Can't handle type %s value from function" % (type(newres)))
|
|
else:
|
|
try:
|
|
result += str(newres)
|
|
except ValueError:
|
|
result += "Failed autocasting. Can't handle %s type from function. Must be string" % type(newres)
|
|
print("Can't handle type %s value from function" % (type(newres)))
|
|
|
|
print("[INFO] POST NEWRES RESULT!")#, result)
|
|
else:
|
|
#print("[INFO] APP_SDK DONE: Starting MULTI execution (length: %d) with values %s" % (minlength, multi_parameters))
|
|
# 1. Use number of executions based on the arrays being similar
|
|
# 2. Find the right value from the parsed multi_params
|
|
|
|
print("[INFO] Running WITHOUT outer loop")
|
|
json_object = False
|
|
results = await self.run_recursed_items(func, multi_parameters, {})
|
|
if isinstance(results, dict) or isinstance(results, list):
|
|
json_object = True
|
|
|
|
#for i in range(0, minlength):
|
|
# # To be able to use the results as a list:
|
|
# print("1: %s" % multi_parameters)
|
|
# #baseparams = json.loads(json.dumps(multi_parameters))
|
|
# baseparams = copy.deepcopy(multi_parameters)
|
|
|
|
# print("2: %s: %s" % (type(baseparams), baseparams))
|
|
|
|
# print("4")
|
|
# print("Running with params (1): %s" % baseparams)
|
|
|
|
# results = await self.run_recursed_items(func, baseparams, {})
|
|
# if isinstance(results, dict) or isinstance(results, list):
|
|
# json_object = True
|
|
|
|
# {'call': ['GoogleSafebrowsing_2_0', 'VirusTotal_GetReport_3_0']}
|
|
# 1. Check if list length is same as minlength
|
|
# 2. If NOT same length, duplicate based on length of array
|
|
# arraylength = 3 ["1", "2", "3"]
|
|
# arraylength = 4 ["1", "2", "3", "4"]
|
|
# minlength = 12 - 12/3 = 4 per item = ["1", "1", "1", "1", "2", "2", ...]
|
|
|
|
#try:
|
|
# firstlist = True
|
|
# for key, value in baseparams.items():
|
|
# print("Itemtype: %s" % type(value))
|
|
# if isinstance(value, list):
|
|
# try:
|
|
# newvalue = value[i]
|
|
# except IndexError:
|
|
# pass
|
|
|
|
# if len(value) != minlength and len(value) > 0:
|
|
# newarray = []
|
|
# print("VALUE: ", value)
|
|
# additiontime = minlength/len(value)
|
|
# print("Bad length for value: %d - should be %d. Additiontime: %d" % (len(value), minlength, additiontime))
|
|
# if firstlist:
|
|
# print("Running normal list (FIRST)")
|
|
# for subvalue in value:
|
|
# for number in range(int(additiontime)):
|
|
# newarray.append(subvalue)
|
|
# else:
|
|
# #print("Running secondary lists")
|
|
# ## 1. Set up length of array
|
|
# ## 2. Put values spread out
|
|
# # FIXME: This works well, except if lists are same length
|
|
# newarray = [""] * minlength
|
|
|
|
# cnt = 0
|
|
# for number in range(int(additiontime)):
|
|
# for subvaluerange in range(len(value)):
|
|
# # newlocation = number+(additiontime*subvaluerange)
|
|
# # print("%d+(%d*%d) = %d. VAL: %s" % (number, additiontime, subvaluerange, newlocation, value[subvaluerange]))
|
|
# # Reverse if same length?
|
|
# if int(minlength/len(value)) == len(value):
|
|
# tmp = int(len(value)-subvaluerange-1)
|
|
# print("NEW: %d" % tmp)
|
|
# newarray[cnt] = value[tmp]
|
|
# else:
|
|
# newarray[cnt] = value[subvaluerange]
|
|
# cnt += 1
|
|
|
|
# #print("Newarray =", newarray)
|
|
# newvalue = newarray[i]
|
|
# firstlist = False
|
|
|
|
# baseparams[key] = newvalue
|
|
|
|
# print("3")
|
|
#except IndexError as e:
|
|
# print("IndexError: %s" % e)
|
|
# baseparams[key] = "IndexError: %s" % e
|
|
#except KeyError as e:
|
|
# print("KeyError: %s" % e)
|
|
# baseparams[key] = "KeyError: %s" % e
|
|
#print("4")
|
|
#print("Running with params (1): %s" % baseparams)
|
|
|
|
#results = await self.run_recursed_items(func, baseparams, {})
|
|
#if isinstance(results, dict) or isinstance(results, list):
|
|
# json_object = True
|
|
|
|
# Check the structure here. If "isloop", try to recurse?
|
|
# ret, is_loop = recurse_json(innervalue, parsersplit[outercnt+1:])
|
|
#ret = await func(**baseparams)
|
|
#print("Return from execution: %s" % ret)
|
|
#if ret == None:
|
|
# results.append("")
|
|
# json_object = False
|
|
#elif isinstance(ret, dict) or isinstance(ret, list):
|
|
# results.append(ret)
|
|
# json_object = True
|
|
#else:
|
|
# ret = ret.replace("\"", "\\\"", -1)
|
|
|
|
# try:
|
|
# results.append(json.loads(ret))
|
|
# json_object = True
|
|
# except json.decoder.JSONDecodeError as e:
|
|
# #print("Json: %s" % e)
|
|
# results.append(ret)
|
|
|
|
#print("Inner ret parsed: %s" % ret)
|
|
|
|
# Dump the result as a string of a list
|
|
#print("RESULTS: %s" % results)
|
|
if isinstance(results, list) or isinstance(results, dict):
|
|
print("JSON OBJECT? ", json_object)
|
|
|
|
# This part is weird lol
|
|
if json_object:
|
|
try:
|
|
result = json.dumps(results)
|
|
except json.JSONDecodeError as e:
|
|
print(f"Failed to decode: {e}")
|
|
result = results
|
|
else:
|
|
result = "["
|
|
for item in results:
|
|
try:
|
|
json.loads(item)
|
|
result += item
|
|
except json.decoder.JSONDecodeError as e:
|
|
# Common nested issue which puts " around everything
|
|
print("Decodingerror: %s" % e)
|
|
try:
|
|
tmpitem = item.replace("\\\"", "\"", -1)
|
|
json.loads(tmpitem)
|
|
result += tmpitem
|
|
|
|
except:
|
|
result += "\"%s\"" % item
|
|
|
|
result += ", "
|
|
|
|
result = result[:-2]
|
|
result += "]"
|
|
else:
|
|
print("Normal result - no list?")
|
|
result = results
|
|
|
|
action_result["status"] = "SUCCESS"
|
|
action_result["result"] = str(result)
|
|
if action_result["result"] == "":
|
|
action_result["result"] = result
|
|
|
|
self.logger.debug(f"Executed {action['label']}-{action['id']}")#with result: {result}")
|
|
#self.logger.debug(f"Data: %s" % action_result)
|
|
except TypeError as e:
|
|
print("TypeError issue: %s" % e)
|
|
action_result["status"] = "FAILURE"
|
|
action_result["result"] = "TypeError: %s" % str(e)
|
|
else:
|
|
print("Function %s doesn't exist?" % action["name"])
|
|
self.logger.error(f"App {self.__class__.__name__}.{action['name']} is not callable")
|
|
action_result["status"] = "FAILURE"
|
|
action_result["result"] = "Function %s is not callable." % actionname
|
|
|
|
# https://ptb.discord.com/channels/747075026288902237/882017498550112286/882043773138382890
|
|
except (requests.exceptions.RequestException, TimeoutError) as e:
|
|
print(f"Failed to execute request: {e}")
|
|
self.logger.exception(f"Failed to execute {e}-{action['id']}")
|
|
action_result["status"] = "SUCCESS"
|
|
try:
|
|
action_result["result"] = json.dumps({
|
|
"success": False,
|
|
"reason": f"Request error - failing silently. Details: {e}"
|
|
})
|
|
except json.decoder.JSONDecodeError as e:
|
|
action_result["result"] = f"Request error: {e}"
|
|
|
|
except Exception as e:
|
|
print(f"Failed to execute: {e}")
|
|
self.logger.exception(f"Failed to execute {e}-{action['id']}")
|
|
action_result["status"] = "FAILURE"
|
|
action_result["result"] = f"General exception: {e}"
|
|
|
|
action_result["completed_at"] = int(time.time())
|
|
|
|
# Send the result :)
|
|
self.send_result(action_result, headers, stream_path)
|
|
return
|
|
|
|
@classmethod
|
|
async def run(cls, action=""):
|
|
logging.basicConfig(format="{asctime} - {name} - {levelname}:{message}", style='{')
|
|
logger = logging.getLogger(f"{cls.__name__}")
|
|
logger.setLevel(logging.DEBUG)
|
|
|
|
#print("Started execution: %s!!" % cls)
|
|
#print("Action: %s" % action)
|
|
#if isinstance(cls, object):
|
|
# self.action = cls
|
|
|
|
app = cls(redis=None, logger=logger, console_logger=logger)
|
|
if isinstance(action, str):
|
|
print("Normal execution. Action is a string.")
|
|
elif isinstance(action, object):
|
|
app.action = action
|
|
|
|
try:
|
|
app.authorization = action["authorization"]
|
|
app.current_execution_id = action["execution_id"]
|
|
except:
|
|
pass
|
|
|
|
try:
|
|
app.url = action["url"]
|
|
except:
|
|
pass
|
|
|
|
try:
|
|
app.base_url = action["base_url"]
|
|
except:
|
|
pass
|
|
else:
|
|
print("ACTION TYPE (unhandled): %s" % type(action))
|
|
|
|
await app.execute_action(app.action)
|