mirror/fastwsgi
1
0
Fork 0
mirror of https://github.com/jamesroberts/fastwsgi.git synced 2025-12-30 18:59:53 -06:00
Code Issues Packages Projects Releases Wiki Activity

Setup basic WSGI environ vars

Browse Source
This commit is contained in:
James Roberts
2021-08-19 22:57:24 +02:00
parent 5d08fc3446
commit 015c365be0
2 changed files with 38 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
fast-wsgi/request.c
View File

@@ -19,7 +19,7 @@ int on_message_begin(llhttp_t* parser) {
int on_url(llhttp_t* parser, const char* url, size_t length) {
printf("on url\n");
Request* request = (Request*)parser->data;
PyObject* header = Py_BuildValue("s", "url");
PyObject* header = Py_BuildValue("s", "PATH_INFO");
Py_INCREF(header);
set_header(request->headers, header, url, length);
@@ -38,7 +38,15 @@ int on_body(llhttp_t* parser, const char* body, size_t length) {
int on_header_field(llhttp_t* parser, const char* header, size_t length) {
printf("on header field\n");
Request* request = (Request*)parser->data;
current_header = PyUnicode_FromStringAndSize(header, length);
PyObject* HTTP_ = PyUnicode_FromString("HTTP_");
char upperHeader[length];
for (int i = 0; i < length; i++) {
upperHeader[i] = toupper(header[i]);
}
PyObject* uppercaseHeader = PyUnicode_FromStringAndSize(upperHeader, length);
current_header = PyUnicode_Concat(HTTP_, uppercaseHeader);
Py_INCREF(current_header);
return 0;
};
@@ -53,12 +61,34 @@ int on_header_value(llhttp_t* parser, const char* value, size_t length) {
int on_message_complete(llhttp_t* parser) {
printf("on message complete\n");
Request* request = (Request*)parser->data;
build_wsgi_environ(parser);
PyObject_CallFunctionObjArgs(
wsgi_app, request->headers, NULL
);
return 0;
};
void build_wsgi_environ(llhttp_t* parser) {
Request* request = (Request*)parser->data;
char* method = llhttp_method_name(parser->method);
char* protocol = parser->http_minor == 1 ? "HTTP/1.1" : "HTTP/1.0";
PyObject* wsgi_version = PyTuple_Pack(2, PyLong_FromLong(1), PyLong_FromLong(0));
// Find a better way to set these
// https://www.python.org/dev/peps/pep-3333/#specification-details
PyDict_SetItemString(request->headers, "REQUEST_METHOD", PyUnicode_FromString(method));
PyDict_SetItemString(request->headers, "SCRIPT_NAME", PyUnicode_FromString(""));
PyDict_SetItemString(request->headers, "SERVER_NAME", PyUnicode_FromString(host));
PyDict_SetItemString(request->headers, "SERVER_PORT", PyUnicode_FromString("port"));
PyDict_SetItemString(request->headers, "SERVER_PROTOCOL", PyUnicode_FromString(protocol));
PyDict_SetItemString(request->headers, "wsgi.version", wsgi_version);
PyDict_SetItemString(request->headers, "wsgi.url_scheme", PyUnicode_FromString("http"));
PyDict_SetItemString(request->headers, "wsgi.errors", PySys_GetObject("stderr"));
PyDict_SetItemString(request->headers, "wsgi.run_once", Py_False);
PyDict_SetItemString(request->headers, "wsgi.multithread", Py_False);
PyDict_SetItemString(request->headers, "wsgi.multiprocess", Py_True);
}
void configure_parser_settings() {
llhttp_settings_init(&parser_settings);
parser_settings.on_url = on_url;

7
fast_wsgi.py
View File

@@ -9,7 +9,12 @@ def run(wsgi_app, host, port, backlog=256):
print("Closing...")
def callback(environ):
print("Callback invoked")
print(environ)
print("Running...")
run({}, "0.0.0.0", 5000)
run(callback, "0.0.0.0", 5000)
# TODO: Shutdown on Ctrl-C somehow
print("Done")