Fixed HTML message formatting, Extended resolver for get, construct and transform functions, Added entire message history with aliasing for personal matrix account
This commit is contained in:
Binary file not shown.
@@ -7,11 +7,11 @@ def buildAction (action, outputs):
|
||||
|
||||
if hasattr(action, "recursive"):
|
||||
items = outputs[action.recursive["source"]]
|
||||
reverse = action.recursive.get("reversed", False)
|
||||
reverse = action.recursive.get("reverse", False)
|
||||
|
||||
if reverse:
|
||||
items = reversed(items)
|
||||
|
||||
|
||||
for item in items:
|
||||
outputs[action.recursive["label"]] = item
|
||||
outputs, resolved = buildPreRuntimeAttr(action, outputs)
|
||||
|
||||
Binary file not shown.
@@ -1,11 +1,29 @@
|
||||
def resolveItem(action, item):
|
||||
resolved = {}
|
||||
if hasattr(action, "resolve"):
|
||||
for label, keys in action.resolve.items():
|
||||
for label, keys in action.resolve["get"].items():
|
||||
target = item
|
||||
|
||||
for key in keys:
|
||||
target = target[key]
|
||||
|
||||
resolved[label] = target
|
||||
if "construct" in action.resolve:
|
||||
for label2, piece in action.resolve["construct"].items():
|
||||
constructed = ""
|
||||
|
||||
for item in piece:
|
||||
if isinstance(item, dict):
|
||||
for key, value in item.items():
|
||||
item = resolved[value]
|
||||
|
||||
constructed += str(item)
|
||||
|
||||
resolved[label2] = constructed
|
||||
if "transform" in action.resolve:
|
||||
for source, mutation in action.resolve["transform"].items():
|
||||
for key, value in mutation.items():
|
||||
if resolved[source] == key:
|
||||
resolved[source] = value
|
||||
|
||||
return resolved
|
||||
|
||||
Binary file not shown.
+21
-4
@@ -8,7 +8,28 @@ from .createresponse import buildResponse
|
||||
|
||||
port = int(os.environ.get("SERVER_PORT", 19001))
|
||||
|
||||
from http.server import HTTPServer, BaseHTTPRequestHandler
|
||||
|
||||
class RequestHandler(BaseHTTPRequestHandler):
|
||||
def do_POST(self):
|
||||
print("POST request received")
|
||||
|
||||
self.send_response(200)
|
||||
self.send_header("Content-Type", "application/json")
|
||||
self.end_headers()
|
||||
|
||||
self.wfile.write(b'{"status": "ok"}')
|
||||
|
||||
def startServer():
|
||||
server = HTTPServer(("127.0.0.1", port), RequestHandler)
|
||||
|
||||
print(f"Server listening on port {port}")
|
||||
|
||||
server.serve_forever()
|
||||
|
||||
|
||||
|
||||
def startServer2():
|
||||
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
|
||||
server.bind(("0.0.0.0", port))
|
||||
@@ -22,10 +43,6 @@ def startServer():
|
||||
print("Accepting connections")
|
||||
connection.settimeout(30)
|
||||
|
||||
class RequestHandler(BaseHTTPRequestHandler):
|
||||
def do_POST(self):
|
||||
print("POST request received")
|
||||
|
||||
try:
|
||||
while True:
|
||||
data = connection.recv(4096)
|
||||
|
||||
Reference in New Issue
Block a user