cory/tildefriends
4
5
Fork 1
Code Issues 31 Pull Requests 1 Actions Releases 24 Wiki Activity

Make it possible to submit data to a task through a POST to /~user/task/submit.

Browse Source 
git-svn-id: https://www.unprompted.com/svn/projects/tildefriends/trunk@3171 ed5197a5-7fde-0310-b194-c3ffbd925b24
This commit is contained in:
Cory McWilliams 2016-03-17 01:07:54 +00:00
parent a9879b7c8a
commit 9f23147678
2 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
core/httpd.js
View File

@ -147,7 +147,6 @@ function handleRequest(request, response) {
var promise = handler.invoke(request, response);
if (promise) {
promise.catch(function(error) {
print(error);
response.reportError(error);
});
}

32
core/terminal.js
View File

@ -201,13 +201,17 @@ function handler(request, response, packageOwner, packageName, uri) {
options.userName = credentials.session.name;
}
options.credentials = credentials;
var sessionId = form.decodeForm(request.query).sessionId;
var isNewSession = false;
if (!getSessionProcess(packageOwner, packageName, sessionId, {create: false})) {
sessionId = makeSessionId();
isNewSession = true;
if (uri == "/submit") {
process = getServiceProcess(packageOwner, packageName, "submit");
} else {
var sessionId = form.decodeForm(request.query).sessionId;
var isNewSession = false;
if (!getSessionProcess(packageOwner, packageName, sessionId, {create: false})) {
sessionId = makeSessionId();
isNewSession = true;
}
process = getSessionProcess(packageOwner, packageName, sessionId, options);
}
process = getSessionProcess(packageOwner, packageName, sessionId, options);
process.lastActive = Date.now();
if (uri === "/send") {
@ -243,14 +247,10 @@ function handler(request, response, packageOwner, packageName, uri) {
process.terminal.print(error);
});
}
} else if (uri === "/post") {
if (isNewSession) {
response.writeHead(403, {"Content-Type": "text/plain; charset=utf-8"});
print("post too soon");
response.end("Too soon.");
} else {
var payload = JSON.parse(request.body);
return invoke(process.eventHandlers['onPost'], [payload]).then(function() {
} else if (uri === "/submit") {
return process.ready.then(function() {
var payload = form.decodeForm(request.body, form.decodeForm(request.query));
return invoke(process.eventHandlers['onSubmit'], [payload]).then(function() {
response.writeHead(200, {
"Content-Type": "text/plain; charset=utf-8",
"Content-Length": "0",
@ -258,9 +258,9 @@ function handler(request, response, packageOwner, packageName, uri) {
"Pragma": "no-cache",
"Expires": "0",
});
response.end("");
return response.end("");
});
}
});
} else if (uri === "/receive") {
if (isNewSession) {
var data = JSON.stringify({