Clear everything, start over using Driver API
This commit is contained in:
Tobe O
parent
51c605cf4c
commit
841cd8b552
23 changed files with 234 additions and 1653 deletions
2
.gitignore
vendored
2
.gitignore
vendored
|
|
@ -22,6 +22,6 @@ doc/api/
|
||||||
|
|
||||||
*.o
|
*.o
|
||||||
#*.dylib
|
#*.dylib
|
||||||
*.a
|
#*.a
|
||||||
*.lib
|
*.lib
|
||||||
*.obj
|
*.obj
|
||||||
|
|
@ -1,43 +1,7 @@
|
||||||
import 'dart:async';
|
|
||||||
import 'dart:io';
|
|
||||||
import 'dart:isolate';
|
|
||||||
import 'package:angel_framework/angel_framework.dart';
|
import 'package:angel_framework/angel_framework.dart';
|
||||||
import 'package:angel_static/angel_static.dart';
|
|
||||||
import 'package:angel_wings/angel_wings.dart';
|
import 'package:angel_wings/angel_wings.dart';
|
||||||
import 'package:file/local.dart';
|
|
||||||
|
|
||||||
main() async {
|
main() async {
|
||||||
for (int i = 1; i < Platform.numberOfProcessors; i++) {
|
var app = Angel();
|
||||||
var onError = new ReceivePort();
|
var wings = AngelWings(app);
|
||||||
Isolate.spawn(isolateMain, i, onError: onError.sendPort);
|
|
||||||
onError.listen((e) => Zone.current
|
|
||||||
.handleUncaughtError(e[0], new StackTrace.fromString(e[1].toString())));
|
|
||||||
}
|
|
||||||
|
|
||||||
isolateMain(0);
|
|
||||||
}
|
|
||||||
|
|
||||||
void isolateMain(int id) {
|
|
||||||
var app = new Angel();
|
|
||||||
var wings = new AngelWings(app, shared: true, useZone: false);
|
|
||||||
|
|
||||||
app.injectEncoders({'gzip': gzip.encoder, 'deflate': zlib.encoder});
|
|
||||||
|
|
||||||
var old = app.errorHandler;
|
|
||||||
app.errorHandler = (e, req, res) {
|
|
||||||
print(e);
|
|
||||||
print(e.stackTrace);
|
|
||||||
return old(e, req, res);
|
|
||||||
};
|
|
||||||
|
|
||||||
app.get('/hello', 'Hello, native world! This is isolate #$id.');
|
|
||||||
|
|
||||||
var fs = const LocalFileSystem();
|
|
||||||
var vDir = new VirtualDirectory(app, fs, source: fs.directory('web'));
|
|
||||||
app.use(vDir.handleRequest);
|
|
||||||
|
|
||||||
wings.startServer('127.0.0.1', 3000).then((_) {
|
|
||||||
print(
|
|
||||||
'Instance #$id listening at http://${wings.address.address}:${wings.port}');
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
@ -1,22 +1,5 @@
|
||||||
library angel_wings;
|
export 'src/angel_wings.dart';
|
||||||
|
export 'src/native_socket.dart';
|
||||||
import 'dart:async';
|
export 'src/wings_driver.dart';
|
||||||
import 'dart:convert';
|
export 'src/wings_request.dart';
|
||||||
import 'dart:io';
|
export 'src/wings_response.dart';
|
||||||
import 'dart:isolate';
|
|
||||||
import 'dart:typed_data';
|
|
||||||
import 'dart-ext:src/wings';
|
|
||||||
import 'package:angel_framework/angel_framework.dart';
|
|
||||||
import 'package:body_parser/body_parser.dart';
|
|
||||||
import 'package:combinator/combinator.dart';
|
|
||||||
import 'package:http_parser/http_parser.dart';
|
|
||||||
import 'package:json_god/json_god.dart' as god;
|
|
||||||
import 'package:mock_request/mock_request.dart';
|
|
||||||
import 'package:pool/pool.dart';
|
|
||||||
import 'package:pooled_map/pooled_map.dart';
|
|
||||||
import 'package:stack_trace/stack_trace.dart';
|
|
||||||
import 'package:tuple/tuple.dart';
|
|
||||||
import 'package:uuid/uuid.dart';
|
|
||||||
part 'src/wings_request.dart';
|
|
||||||
part 'src/wings_response.dart';
|
|
||||||
part 'src/wings.dart';
|
|
||||||
42
lib/src/angel_wings.cc
Normal file
42
lib/src/angel_wings.cc
Normal file
|
|
@ -0,0 +1,42 @@
|
||||||
|
#include <cstdlib>
|
||||||
|
#include <iostream>
|
||||||
|
#include <string.h>
|
||||||
|
#include <dart_api.h>
|
||||||
|
|
||||||
|
// Forward declaration of ResolveName function.
|
||||||
|
Dart_NativeFunction ResolveName(Dart_Handle name, int argc, bool* auto_setup_scope);
|
||||||
|
|
||||||
|
// The name of the initialization function is the extension name followed
|
||||||
|
// by _Init.
|
||||||
|
DART_EXPORT Dart_Handle angel_wings_Init(Dart_Handle parent_library) {
|
||||||
|
if (Dart_IsError(parent_library)) return parent_library;
|
||||||
|
|
||||||
|
Dart_Handle result_code =
|
||||||
|
Dart_SetNativeResolver(parent_library, ResolveName, NULL);
|
||||||
|
if (Dart_IsError(result_code)) return result_code;
|
||||||
|
|
||||||
|
return Dart_Null();
|
||||||
|
}
|
||||||
|
|
||||||
|
Dart_Handle HandleError(Dart_Handle handle) {
|
||||||
|
if (Dart_IsError(handle)) Dart_PropagateError(handle);
|
||||||
|
return handle;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Native functions get their arguments in a Dart_NativeArguments structure
|
||||||
|
// and return their results with Dart_SetReturnValue.
|
||||||
|
void SayHello(Dart_NativeArguments arguments) {
|
||||||
|
std::cout << "Hello, native world!" << std::endl;
|
||||||
|
Dart_SetReturnValue(arguments, Dart_Null());
|
||||||
|
}
|
||||||
|
|
||||||
|
Dart_NativeFunction ResolveName(Dart_Handle name, int argc, bool* auto_setup_scope) {
|
||||||
|
// If we fail, we return NULL, and Dart throws an exception.
|
||||||
|
if (!Dart_IsString(name)) return NULL;
|
||||||
|
Dart_NativeFunction result = NULL;
|
||||||
|
const char* cname;
|
||||||
|
HandleError(Dart_StringToCString(name, &cname));
|
||||||
|
|
||||||
|
if (strcmp("SayHello", cname) == 0) result = SayHello;
|
||||||
|
return result;
|
||||||
|
}
|
||||||
3
lib/src/angel_wings.dart
Normal file
3
lib/src/angel_wings.dart
Normal file
|
|
@ -0,0 +1,3 @@
|
||||||
|
import 'dart-ext:angel_wings';
|
||||||
|
|
||||||
|
void sayHello() native "SayHello";
|
||||||
|
|
@ -1,205 +0,0 @@
|
||||||
#include <cstring>
|
|
||||||
#include <mutex>
|
|
||||||
#include <vector>
|
|
||||||
#include "wings.h"
|
|
||||||
|
|
||||||
std::vector<WingsServerInfo *> serverInfoVector;
|
|
||||||
std::mutex serverInfoVectorMutex;
|
|
||||||
|
|
||||||
void wings_BindSocket(Dart_NativeArguments arguments)
|
|
||||||
{
|
|
||||||
// Uint8List address, String addressString, int port, int backlog, bool shared
|
|
||||||
Dart_Handle addressHandle = Dart_GetNativeArgument(arguments, 0);
|
|
||||||
Dart_Handle addressStringHandle = Dart_GetNativeArgument(arguments, 1);
|
|
||||||
Dart_Handle portHandle = Dart_GetNativeArgument(arguments, 2);
|
|
||||||
Dart_Handle backlogHandle = Dart_GetNativeArgument(arguments, 3);
|
|
||||||
Dart_Handle sharedHandle = Dart_GetNativeArgument(arguments, 4);
|
|
||||||
Dart_TypedData_Type addressType;
|
|
||||||
void *addressData;
|
|
||||||
intptr_t addressLength;
|
|
||||||
const char *addressString;
|
|
||||||
uint64_t port, backlog;
|
|
||||||
bool shared;
|
|
||||||
|
|
||||||
// Read the arguments...
|
|
||||||
HandleError(Dart_TypedDataAcquireData(addressHandle, &addressType, &addressData, &addressLength));
|
|
||||||
HandleError(Dart_TypedDataReleaseData(addressHandle));
|
|
||||||
HandleError(Dart_StringToCString(addressStringHandle, &addressString));
|
|
||||||
HandleError(Dart_IntegerToUint64(portHandle, &port));
|
|
||||||
HandleError(Dart_IntegerToUint64(backlogHandle, &backlog));
|
|
||||||
HandleError(Dart_BooleanValue(sharedHandle, &shared));
|
|
||||||
|
|
||||||
// See if there is already a server bound to the port.
|
|
||||||
long existingIndex = -1;
|
|
||||||
std::string addressStringInstance(addressString);
|
|
||||||
std::lock_guard<std::mutex> lock(serverInfoVectorMutex);
|
|
||||||
|
|
||||||
|
|
||||||
if (shared)
|
|
||||||
{
|
|
||||||
//#if __APPLE__
|
|
||||||
//#else
|
|
||||||
for (unsigned long i = 0; i < serverInfoVector.size(); i++)
|
|
||||||
{
|
|
||||||
WingsServerInfo *server_info = serverInfoVector.at(i);
|
|
||||||
|
|
||||||
if (server_info->addressString == addressStringInstance && server_info->port == port)
|
|
||||||
{
|
|
||||||
existingIndex = (long)i;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
//#endif
|
|
||||||
}
|
|
||||||
|
|
||||||
if (existingIndex > -1)
|
|
||||||
{
|
|
||||||
// We found an existing socket, just return a reference to it.
|
|
||||||
Dart_SetReturnValue(arguments, Dart_NewIntegerFromUint64(existingIndex));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
// There's no existing server, so bind a new one, and add it to the serverInfoVector.
|
|
||||||
#ifndef WIN32
|
|
||||||
int sockfd;
|
|
||||||
#else
|
|
||||||
WSADATA wsaData;
|
|
||||||
SOCKET ConnectSocket = INVALID_SOCKET;
|
|
||||||
|
|
||||||
// Initialize Winsock
|
|
||||||
iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
|
|
||||||
if (iResult != 0)
|
|
||||||
{
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(2);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("WSAStartup failed."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewInteger(iResult));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
// TODO: Rest of Windows config:
|
|
||||||
// https://docs.microsoft.com/en-us/windows/desktop/winsock/complete-client-code
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if (addressLength == 4)
|
|
||||||
{
|
|
||||||
// IPv4
|
|
||||||
sockfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
// IPv6
|
|
||||||
sockfd = socket(AF_INET6, SOCK_STREAM, IPPROTO_TCP);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (sockfd < 0)
|
|
||||||
{
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(3);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("Failed to create socket."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewStringFromCString(strerror(errno)));
|
|
||||||
Dart_ListSetAt(errorHandle, 2, Dart_NewInteger(errno));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
int i = 1;
|
|
||||||
int ret = setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &i, sizeof(i));
|
|
||||||
|
|
||||||
if (ret < 0)
|
|
||||||
{
|
|
||||||
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(3);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("Cannot reuse address for socket."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewStringFromCString(strerror(errno)));
|
|
||||||
Dart_ListSetAt(errorHandle, 2, Dart_NewInteger(errno));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/*
|
|
||||||
#if __APPLE__
|
|
||||||
ret = setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &i, sizeof(i));
|
|
||||||
|
|
||||||
if (ret < 0)
|
|
||||||
{
|
|
||||||
Dart_ThrowException(Dart_NewStringFromCString("Cannot reuse port for socket."));
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
#endif
|
|
||||||
*/
|
|
||||||
|
|
||||||
if (addressLength > 4)
|
|
||||||
{
|
|
||||||
struct sockaddr_in6 v6
|
|
||||||
{
|
|
||||||
};
|
|
||||||
memset(&v6, 0, sizeof(v6));
|
|
||||||
v6.sin6_family = AF_INET6;
|
|
||||||
v6.sin6_port = htons((uint16_t)port);
|
|
||||||
ret = inet_pton(v6.sin6_family, addressString, &v6.sin6_addr.s6_addr);
|
|
||||||
|
|
||||||
if (ret >= 0)
|
|
||||||
ret = bind(sockfd, (const sockaddr *)&v6, sizeof(v6));
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
struct sockaddr_in v4
|
|
||||||
{
|
|
||||||
};
|
|
||||||
memset(&v4, 0, sizeof(v4));
|
|
||||||
v4.sin_family = AF_INET;
|
|
||||||
v4.sin_port = htons((uint16_t)port);
|
|
||||||
v4.sin_addr.s_addr = inet_addr(addressString);
|
|
||||||
|
|
||||||
if (ret >= 0)
|
|
||||||
ret = bind(sockfd, (const sockaddr *)&v4, sizeof(v4));
|
|
||||||
//ret = inet_pton(family, host, &v4.sin_addr);
|
|
||||||
}
|
|
||||||
|
|
||||||
/*if (ret < 1) {
|
|
||||||
Dart_ThrowException(Dart_NewStringFromCString("Cannot parse IP address."));
|
|
||||||
return;
|
|
||||||
}*/
|
|
||||||
|
|
||||||
//if (bind(sock, (const sockaddr *) &serveraddr, sizeof(serveraddr)) < 0) {
|
|
||||||
if (ret < 0)
|
|
||||||
{
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(3);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("Failed to bind socket."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewStringFromCString(strerror(errno)));
|
|
||||||
Dart_ListSetAt(errorHandle, 2, Dart_NewInteger(errno));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (listen(sockfd, SOMAXCONN) < 0)
|
|
||||||
{
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(3);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("Failed to listen to bound socket."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewStringFromCString(strerror(errno)));
|
|
||||||
Dart_ListSetAt(errorHandle, 2, Dart_NewInteger(errno));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (listen(sockfd, (int)backlog) < 0)
|
|
||||||
{
|
|
||||||
Dart_Handle errorHandle = Dart_NewList(3);
|
|
||||||
Dart_ListSetAt(errorHandle, 0, Dart_NewStringFromCString("Failed to listen to bound socket."));
|
|
||||||
Dart_ListSetAt(errorHandle, 1, Dart_NewStringFromCString(strerror(errno)));
|
|
||||||
Dart_ListSetAt(errorHandle, 2, Dart_NewInteger(errno));
|
|
||||||
Dart_ThrowException(errorHandle);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Now that we've bound the socket, let's add it to the list.
|
|
||||||
auto *server_info = new WingsServerInfo;
|
|
||||||
server_info->sockfd = sockfd;
|
|
||||||
server_info->port = port;
|
|
||||||
server_info->ipv6 = addressLength > 4;
|
|
||||||
server_info->addressString += addressStringInstance;
|
|
||||||
Dart_SetReturnValue(arguments, Dart_NewIntegerFromUint64(serverInfoVector.size()));
|
|
||||||
serverInfoVector.push_back(server_info);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,27 +0,0 @@
|
||||||
#ifdef __cplusplus
|
|
||||||
#include <cstdio>
|
|
||||||
#else
|
|
||||||
#include <stdio.h>
|
|
||||||
#endif
|
|
||||||
#include <dart_api.h>
|
|
||||||
|
|
||||||
Dart_Handle ToCString(Dart_Handle obj, const char** out) {
|
|
||||||
Dart_Handle toStringMethod = Dart_NewStringFromCString("toString");
|
|
||||||
Dart_Handle string = Dart_Invoke(obj, toStringMethod, 0, nullptr);
|
|
||||||
return Dart_StringToCString(string, out);
|
|
||||||
}
|
|
||||||
|
|
||||||
Dart_Handle Dart_//printToFile(Dart_Handle obj, FILE* stream) {
|
|
||||||
const char *toString;
|
|
||||||
Dart_Handle result = ToCString(obj, &toString);
|
|
||||||
|
|
||||||
if (Dart_IsError(result))
|
|
||||||
return result;
|
|
||||||
|
|
||||||
f//printf(stream, "%s\n", toString);
|
|
||||||
return Dart_Null();
|
|
||||||
}
|
|
||||||
|
|
||||||
Dart_Handle Dart_//print(Dart_Handle obj) {
|
|
||||||
return Dart_//printToFile(obj, stdout);
|
|
||||||
}
|
|
||||||
|
|
@ -1,99 +0,0 @@
|
||||||
#include <dart_native_api.h>
|
|
||||||
#include <thread>
|
|
||||||
#include <iostream>
|
|
||||||
#include <cstdio>
|
|
||||||
#include "wings.h"
|
|
||||||
#include "wings_thread.h"
|
|
||||||
|
|
||||||
void handleMessage(Dart_Port destPortId, Dart_CObject *message);
|
|
||||||
|
|
||||||
void wings_StartHttpListener(Dart_NativeArguments arguments)
|
|
||||||
{
|
|
||||||
Dart_Port port = Dart_NewNativePort("angel_wings", handleMessage, true);
|
|
||||||
Dart_SetReturnValue(arguments, Dart_NewSendPort(port));
|
|
||||||
}
|
|
||||||
|
|
||||||
int64_t get_int(Dart_CObject *obj)
|
|
||||||
{
|
|
||||||
if (obj == nullptr)
|
|
||||||
return 0;
|
|
||||||
switch (obj->type)
|
|
||||||
{
|
|
||||||
case Dart_CObject_kInt32:
|
|
||||||
return (int64_t)obj->value.as_int32;
|
|
||||||
case Dart_CObject_kInt64:
|
|
||||||
return obj->value.as_int64;
|
|
||||||
default:
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void handleMessage(Dart_Port destPortId, Dart_CObject *message)
|
|
||||||
{
|
|
||||||
if (message->type != Dart_CObject_kArray) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// We always expect an array to be sent.
|
|
||||||
Dart_CObject_Type firstType = message->value.as_array.values[0]->type;
|
|
||||||
|
|
||||||
// If it's a SendPort, then start a new thread that listens for incoming connections.
|
|
||||||
if (firstType == Dart_CObject_kSendPort)
|
|
||||||
{
|
|
||||||
std::lock_guard<std::mutex> lock(serverInfoVectorMutex);
|
|
||||||
auto *threadInfo = new wings_thread_info;
|
|
||||||
threadInfo->port = message->value.as_array.values[0]->value.as_send_port.id;
|
|
||||||
threadInfo->serverInfo = serverInfoVector.at((unsigned long)get_int(message->value.as_array.values[1]));
|
|
||||||
std::thread workerThread(wingsThreadMain, threadInfo);
|
|
||||||
workerThread.detach();
|
|
||||||
}
|
|
||||||
else if (firstType == Dart_CObject_kBool)
|
|
||||||
{
|
|
||||||
// The Dart world is trying to close this port.
|
|
||||||
Dart_Port port = message->value.as_array.values[1]->value.as_send_port.id;
|
|
||||||
//Dart_CloseNativePort(port);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
// This is either a send or close message.
|
|
||||||
//std::cout << "NVALUES: " << message->value.as_array.length << std::endl;
|
|
||||||
int sockfd = (int)get_int(message->value.as_array.values[0]);
|
|
||||||
//printf("FD: %d\n", sockfd);
|
|
||||||
|
|
||||||
if (message->value.as_array.length >= 2)
|
|
||||||
{
|
|
||||||
auto *msg = message->value.as_array.values[1];
|
|
||||||
|
|
||||||
if (msg != nullptr)
|
|
||||||
{
|
|
||||||
|
|
||||||
if (msg->type == Dart_CObject_kExternalTypedData)
|
|
||||||
{
|
|
||||||
//std::cout << "ext typed data" << std::endl;
|
|
||||||
//printf("Length: %ld\n", msg->value.as_external_typed_data.length);
|
|
||||||
//std::cout << "ptr: " << msg->value.as_typed_data.values << std::endl;
|
|
||||||
write(sockfd, msg->value.as_external_typed_data.data, (size_t)msg->value.as_external_typed_data.length);
|
|
||||||
}
|
|
||||||
else if (msg->type == Dart_CObject_kTypedData)
|
|
||||||
{
|
|
||||||
//std::cout << "regular typed data" << std::endl;
|
|
||||||
//printf("Length: %ld\n", msg->value.as_typed_data.length);
|
|
||||||
write(sockfd, msg->value.as_typed_data.values, (size_t)msg->value.as_typed_data.length);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
//std::cout << "unknown type: " << ((Dart_CObject_Type) msg->type) << std::endl;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
//std::cout << "null msg!!!" << std::endl;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
//printf("Close!\n");
|
|
||||||
close(sockfd);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
2
lib/src/libangel_wings.build_native.yaml
Normal file
2
lib/src/libangel_wings.build_native.yaml
Normal file
|
|
@ -0,0 +1,2 @@
|
||||||
|
sources:
|
||||||
|
- angel_wings|lib/src/angel_wings.cc
|
||||||
|
|
@ -1,18 +0,0 @@
|
||||||
include:
|
|
||||||
- angel_wings|lib/src/wings.h
|
|
||||||
- angel_wings|lib/src/wings_thread.h
|
|
||||||
sources:
|
|
||||||
- angel_wings|lib/src/bind_socket.cc
|
|
||||||
- angel_wings|lib/src/http_listener.cc
|
|
||||||
- angel_wings|lib/src/send.cc
|
|
||||||
- angel_wings|lib/src/util.cc
|
|
||||||
- angel_wings|lib/src/wings.cc
|
|
||||||
- angel_wings|lib/src/worker_thread.cc
|
|
||||||
third_party:
|
|
||||||
http_parser:
|
|
||||||
git: https://github.com/nodejs/http-parser.git
|
|
||||||
commit: 5b76466
|
|
||||||
include:
|
|
||||||
- .
|
|
||||||
sources:
|
|
||||||
- http_parser.c
|
|
||||||
Binary file not shown.
27
lib/src/native_socket.dart
Normal file
27
lib/src/native_socket.dart
Normal file
|
|
@ -0,0 +1,27 @@
|
||||||
|
import 'dart:async';
|
||||||
|
import 'dart:isolate';
|
||||||
|
import 'dart:typed_data';
|
||||||
|
import 'dart-ext:angel_wings';
|
||||||
|
|
||||||
|
int bindNativeServerSocket(String addr, int port, SendPort sendPort)
|
||||||
|
native 'Dart_NativeSocket_bind';
|
||||||
|
|
||||||
|
void writeToNativeSocket(int fd, Uint8List data)
|
||||||
|
native 'Dart_NativeSocket_write';
|
||||||
|
|
||||||
|
void closeNativeSocket(int fd) native 'Dart_NativeSocket_close';
|
||||||
|
|
||||||
|
class NativeSocket extends Stream<int> {
|
||||||
|
final StreamController<int> _ctrl = StreamController();
|
||||||
|
final int _pointer;
|
||||||
|
bool _open = true;
|
||||||
|
|
||||||
|
NativeSocket._(this._pointer);
|
||||||
|
|
||||||
|
@override
|
||||||
|
StreamSubscription<int> listen(void Function(int event) onData,
|
||||||
|
{Function onError, void Function() onDone, bool cancelOnError}) {
|
||||||
|
return _ctrl.stream
|
||||||
|
.listen(onData, onError: onError, cancelOnError: cancelOnError);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -1,24 +0,0 @@
|
||||||
#include "wings.h"
|
|
||||||
|
|
||||||
void wings_CloseSocket(Dart_NativeArguments arguments)
|
|
||||||
{
|
|
||||||
Dart_Handle sockfdHandle = Dart_GetNativeArgument(arguments, 0);
|
|
||||||
uint64_t sockfd;
|
|
||||||
HandleError(Dart_IntegerToUint64(sockfdHandle, &sockfd));
|
|
||||||
close((int)sockfd);
|
|
||||||
}
|
|
||||||
|
|
||||||
void wings_Send(Dart_NativeArguments arguments)
|
|
||||||
{
|
|
||||||
Dart_Handle sockfdHandle = Dart_GetNativeArgument(arguments, 0);
|
|
||||||
Dart_Handle dataHandle = Dart_GetNativeArgument(arguments, 1);
|
|
||||||
uint64_t sockfd;
|
|
||||||
Dart_TypedData_Type dataType;
|
|
||||||
void *dataBytes;
|
|
||||||
intptr_t dataLength;
|
|
||||||
|
|
||||||
HandleError(Dart_IntegerToUint64(sockfdHandle, &sockfd));
|
|
||||||
HandleError(Dart_TypedDataAcquireData(dataHandle, &dataType, &dataBytes, &dataLength));
|
|
||||||
write((int)sockfd, dataBytes, (size_t)dataLength);
|
|
||||||
HandleError(Dart_TypedDataReleaseData(dataHandle));
|
|
||||||
}
|
|
||||||
|
|
@ -1,36 +0,0 @@
|
||||||
#include <dart_api.h>
|
|
||||||
#include "wings.h"
|
|
||||||
|
|
||||||
void wings_AddressToString(Dart_NativeArguments arguments) {
|
|
||||||
char *address;
|
|
||||||
void *data;
|
|
||||||
intptr_t length;
|
|
||||||
bool ipv6;
|
|
||||||
Dart_TypedData_Type type;
|
|
||||||
|
|
||||||
Dart_Handle address_handle = Dart_GetNativeArgument(arguments, 0);
|
|
||||||
Dart_Handle ipv6_handle = Dart_GetNativeArgument(arguments, 1);
|
|
||||||
HandleError(Dart_BooleanValue(ipv6_handle, &ipv6));
|
|
||||||
sa_family_t family;
|
|
||||||
|
|
||||||
if (ipv6) {
|
|
||||||
family = AF_INET6;
|
|
||||||
address = (char *) Dart_ScopeAllocate(INET6_ADDRSTRLEN);
|
|
||||||
} else {
|
|
||||||
family = AF_INET;
|
|
||||||
address = (char *) Dart_ScopeAllocate(INET_ADDRSTRLEN);
|
|
||||||
}
|
|
||||||
|
|
||||||
HandleError(Dart_TypedDataAcquireData(address_handle, &type, &data, &length));
|
|
||||||
auto *ptr = inet_ntop(family, data, address, INET_ADDRSTRLEN);
|
|
||||||
HandleError(Dart_TypedDataReleaseData(address_handle));
|
|
||||||
|
|
||||||
if (ptr == nullptr) {
|
|
||||||
if (ipv6)
|
|
||||||
Dart_ThrowException(Dart_NewStringFromCString("Invalid IPV6 address."));
|
|
||||||
else
|
|
||||||
Dart_ThrowException(Dart_NewStringFromCString("Invalid IPV4 address."));
|
|
||||||
} else {
|
|
||||||
Dart_SetReturnValue(arguments, Dart_NewStringFromCString(address));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,69 +0,0 @@
|
||||||
#include <cstdlib>
|
|
||||||
#include <iostream>
|
|
||||||
#include <string.h>
|
|
||||||
#include <dart_api.h>
|
|
||||||
#include "wings.h"
|
|
||||||
|
|
||||||
// Forward declaration of ResolveName function.
|
|
||||||
Dart_NativeFunction ResolveName(Dart_Handle name, int argc, bool *auto_setup_scope);
|
|
||||||
|
|
||||||
// The name of the initialization function is the extension name followed
|
|
||||||
// by _Init.
|
|
||||||
DART_EXPORT Dart_Handle wings_Init(Dart_Handle parent_library)
|
|
||||||
{
|
|
||||||
if (Dart_IsError(parent_library))
|
|
||||||
return parent_library;
|
|
||||||
|
|
||||||
Dart_Handle result_code =
|
|
||||||
Dart_SetNativeResolver(parent_library, ResolveName, NULL);
|
|
||||||
if (Dart_IsError(result_code))
|
|
||||||
return result_code;
|
|
||||||
|
|
||||||
return Dart_Null();
|
|
||||||
}
|
|
||||||
|
|
||||||
Dart_Handle HandleError(Dart_Handle handle)
|
|
||||||
{
|
|
||||||
if (Dart_IsError(handle))
|
|
||||||
{
|
|
||||||
#ifdef DEBUG
|
|
||||||
Dart_DumpNativeStackTrace(NULL);
|
|
||||||
#endif
|
|
||||||
Dart_PropagateError(handle);
|
|
||||||
}
|
|
||||||
|
|
||||||
return handle;
|
|
||||||
}
|
|
||||||
|
|
||||||
Dart_NativeFunction ResolveName(Dart_Handle name, int argc, bool *auto_setup_scope)
|
|
||||||
{
|
|
||||||
// If we fail, we return NULL, and Dart throws an exception.
|
|
||||||
if (!Dart_IsString(name))
|
|
||||||
return NULL;
|
|
||||||
Dart_NativeFunction result = NULL;
|
|
||||||
const char *cname;
|
|
||||||
HandleError(Dart_StringToCString(name, &cname));
|
|
||||||
|
|
||||||
if (strcmp(cname, "AddressToString") == 0)
|
|
||||||
{
|
|
||||||
result = wings_AddressToString;
|
|
||||||
}
|
|
||||||
else if (strcmp(cname, "BindSocket") == 0)
|
|
||||||
{
|
|
||||||
result = wings_BindSocket;
|
|
||||||
}
|
|
||||||
else if (strcmp(cname, "CloseSocket") == 0)
|
|
||||||
{
|
|
||||||
result = wings_CloseSocket;
|
|
||||||
}
|
|
||||||
else if (strcmp(cname, "Send") == 0)
|
|
||||||
{
|
|
||||||
result = wings_Send;
|
|
||||||
}
|
|
||||||
else if (strcmp(cname, "StartHttpListener") == 0)
|
|
||||||
{
|
|
||||||
result = wings_StartHttpListener;
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
@ -1,535 +0,0 @@
|
||||||
part of angel_wings;
|
|
||||||
|
|
||||||
class AngelWings {
|
|
||||||
static const int messageBegin = 0,
|
|
||||||
messageComplete = 1,
|
|
||||||
url = 2,
|
|
||||||
headerField = 3,
|
|
||||||
headerValue = 4,
|
|
||||||
body = 5,
|
|
||||||
upgrade = 6,
|
|
||||||
upgradedMessage = 7;
|
|
||||||
|
|
||||||
static const int DELETE = 0,
|
|
||||||
GET = 1,
|
|
||||||
HEAD = 2,
|
|
||||||
POST = 3,
|
|
||||||
PUT = 4,
|
|
||||||
CONNECT = 5,
|
|
||||||
OPTIONS = 6,
|
|
||||||
TRACE = 7,
|
|
||||||
COPY = 8,
|
|
||||||
LOCK = 9,
|
|
||||||
MKCOL = 10,
|
|
||||||
MOVE = 11,
|
|
||||||
PROPFIND = 12,
|
|
||||||
PROPPATCH = 13,
|
|
||||||
SEARCH = 14,
|
|
||||||
UNLOCK = 15,
|
|
||||||
BIND = 16,
|
|
||||||
REBIND = 17,
|
|
||||||
UNBIND = 18,
|
|
||||||
ACL = 19,
|
|
||||||
REPORT = 20,
|
|
||||||
MKACTIVITY = 21,
|
|
||||||
CHECKOUT = 22,
|
|
||||||
MERGE = 23,
|
|
||||||
MSEARCH = 24,
|
|
||||||
NOTIFY = 25,
|
|
||||||
SUBSCRIBE = 26,
|
|
||||||
UNSUBSCRIBE = 27,
|
|
||||||
PATCH = 28,
|
|
||||||
PURGE = 29,
|
|
||||||
MKCALENDAR = 30,
|
|
||||||
LINK = 31,
|
|
||||||
UNLINK = 32,
|
|
||||||
SOURCE = 33;
|
|
||||||
|
|
||||||
static String methodToString(int method) {
|
|
||||||
switch (method) {
|
|
||||||
case DELETE:
|
|
||||||
return 'DELETE';
|
|
||||||
case GET:
|
|
||||||
return 'GET';
|
|
||||||
case HEAD:
|
|
||||||
return 'HEAD';
|
|
||||||
case POST:
|
|
||||||
return 'POST';
|
|
||||||
case PUT:
|
|
||||||
return 'PUT';
|
|
||||||
case CONNECT:
|
|
||||||
return 'CONNECT';
|
|
||||||
case OPTIONS:
|
|
||||||
return 'OPTIONS';
|
|
||||||
case PATCH:
|
|
||||||
return 'PATCH';
|
|
||||||
case PURGE:
|
|
||||||
return 'PURGE';
|
|
||||||
default:
|
|
||||||
throw new ArgumentError('Unknown method $method.');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
final Angel app;
|
|
||||||
final bool shared;
|
|
||||||
final bool useZone;
|
|
||||||
|
|
||||||
final RawReceivePort _recv = new RawReceivePort();
|
|
||||||
final Map<String, MockHttpSession> _sessions = {};
|
|
||||||
//final Map<int, WingsRequestContext> _staging = <int, WingsRequestContext>{};
|
|
||||||
final PooledMap<int, WingsRequestContext> _staging =
|
|
||||||
new PooledMap<int, WingsRequestContext>();
|
|
||||||
final PooledMap<int, WingsRequestContext> _live =
|
|
||||||
new PooledMap<int, WingsRequestContext>();
|
|
||||||
final Uuid _uuid = new Uuid();
|
|
||||||
InternetAddress _address;
|
|
||||||
int _port;
|
|
||||||
SendPort _sendPort;
|
|
||||||
|
|
||||||
static int _bindSocket(Uint8List address, String addressString, int port,
|
|
||||||
int backlog, bool shared) native "BindSocket";
|
|
||||||
|
|
||||||
static SendPort _startHttpListener() native "StartHttpListener";
|
|
||||||
|
|
||||||
//final Pool _pool = new Pool(1);
|
|
||||||
|
|
||||||
static void __send(int sockfd, Uint8List data) native "Send";
|
|
||||||
|
|
||||||
static void __closeSocket(int sockfd) native "CloseSocket";
|
|
||||||
|
|
||||||
void _send(WingsRequestContext req, Uint8List data) {
|
|
||||||
_live.update(req._sockfd, (_) {
|
|
||||||
//print('Sending ${[req._sockfd, data]}');
|
|
||||||
__send(req._sockfd, data);
|
|
||||||
return req;
|
|
||||||
});
|
|
||||||
// _pool.withResource(() {
|
|
||||||
////print('Sending ${[sockfd, data]}');
|
|
||||||
//_sendPort.send([sockfd, data]);
|
|
||||||
//});
|
|
||||||
//_pool.withResource(() => __send(sockfd, data));
|
|
||||||
}
|
|
||||||
|
|
||||||
void _closeSocket(WingsRequestContext req) {
|
|
||||||
_live.remove(req._sockfd).then((_) {
|
|
||||||
if (!req._closed) {
|
|
||||||
req._closed = true;
|
|
||||||
//print('Closing ${[req._sockfd]}');
|
|
||||||
__closeSocket(req._sockfd);
|
|
||||||
}
|
|
||||||
return req;
|
|
||||||
});
|
|
||||||
//_pool.withResource(() {
|
|
||||||
//if (!req._closed) {
|
|
||||||
// req._closed = true;
|
|
||||||
// var sockfd = req._sockfd;
|
|
||||||
// //print('Sending ${[sockfd]}');
|
|
||||||
// _sendPort.send([sockfd]);
|
|
||||||
//}
|
|
||||||
//});
|
|
||||||
//_pool.withResource(() => __closeSocket(sockfd));
|
|
||||||
}
|
|
||||||
|
|
||||||
AngelWings(this.app, {this.shared: false, this.useZone: true}) {
|
|
||||||
_recv.handler = _handleMessage;
|
|
||||||
}
|
|
||||||
|
|
||||||
InternetAddress get address => _address;
|
|
||||||
|
|
||||||
int get port => _port;
|
|
||||||
|
|
||||||
Future startServer([host, int port, int backlog = 10]) {
|
|
||||||
Future<InternetAddress> _addr = host is InternetAddress
|
|
||||||
? host
|
|
||||||
: InternetAddress.lookup(host?.toString() ?? '127.0.0.1').then((list) =>
|
|
||||||
list.isNotEmpty
|
|
||||||
? list.first
|
|
||||||
: throw new StateError('IP lookup failed.'));
|
|
||||||
|
|
||||||
return _addr.then((address) {
|
|
||||||
try {
|
|
||||||
var serverInfoIndex = _bindSocket(
|
|
||||||
new Uint8List.fromList(address.rawAddress),
|
|
||||||
address.address,
|
|
||||||
port ?? 0,
|
|
||||||
backlog,
|
|
||||||
shared);
|
|
||||||
_sendPort = _startHttpListener();
|
|
||||||
_sendPort.send([_recv.sendPort, serverInfoIndex]);
|
|
||||||
_address = address;
|
|
||||||
_port = port;
|
|
||||||
} on List catch (osError) {
|
|
||||||
if (osError.length == 3) {
|
|
||||||
throw new SocketException(osError[0] as String,
|
|
||||||
osError: new OSError(osError[1] as String, osError[2] as int));
|
|
||||||
} else {
|
|
||||||
throw new SocketException('Could not start Wings server.',
|
|
||||||
osError: new OSError(osError[0] as String, osError[1] as int));
|
|
||||||
}
|
|
||||||
} on String catch (message) {
|
|
||||||
throw new SocketException(message);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
Future close() {
|
|
||||||
_sendPort.send([true, _sendPort]);
|
|
||||||
_recv.close();
|
|
||||||
return new Future.value();
|
|
||||||
}
|
|
||||||
|
|
||||||
void _handleMessage(x) {
|
|
||||||
//print('INPUT: $x');
|
|
||||||
if (x is String) {
|
|
||||||
close();
|
|
||||||
throw new StateError(x);
|
|
||||||
} else if (x is List && x.length >= 2) {
|
|
||||||
int sockfd = x[0], command = x[1];
|
|
||||||
|
|
||||||
WingsRequestContext _newRequest() =>
|
|
||||||
new WingsRequestContext._(this, sockfd, app);
|
|
||||||
//print(x);
|
|
||||||
|
|
||||||
switch (command) {
|
|
||||||
case messageBegin:
|
|
||||||
//print('BEGIN $sockfd');
|
|
||||||
_staging.putIfAbsent(sockfd, _newRequest);
|
|
||||||
//_staging[sockfd] = new WingsRequestContext._(this, sockfd, app);
|
|
||||||
break;
|
|
||||||
case messageComplete:
|
|
||||||
_staging.remove(sockfd).then((rq) {
|
|
||||||
if (rq != null) {
|
|
||||||
rq._method = methodToString(x[2] as int);
|
|
||||||
rq._addressBytes = x[5] as Uint8List;
|
|
||||||
_live.put(sockfd, rq).then((_) => _handleRequest(rq));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
/*
|
|
||||||
//print('$sockfd in $_staging???');
|
|
||||||
var rq = _staging.remove(sockfd);
|
|
||||||
if (rq != null) {
|
|
||||||
rq._method = methodToString(x[2] as int);
|
|
||||||
rq._addressBytes = x[5] as Uint8List;
|
|
||||||
_handleRequest(rq);
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
break;
|
|
||||||
case body:
|
|
||||||
_staging.update(sockfd, (rq) {
|
|
||||||
(rq._body ??= new StreamController<Uint8List>())
|
|
||||||
.add(x[2] as Uint8List);
|
|
||||||
return rq;
|
|
||||||
}, defaultValue: _newRequest);
|
|
||||||
/*
|
|
||||||
var rq = _staging[sockfd];
|
|
||||||
if (rq != null) {
|
|
||||||
(rq._body ??= new StreamController<Uint8List>())
|
|
||||||
.add(x[2] as Uint8List);
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
break;
|
|
||||||
//case upgrade:
|
|
||||||
// TODO: Handle WebSockets...?
|
|
||||||
// if (onUpgrade != null) onUpgrade(sockfd);
|
|
||||||
// break;
|
|
||||||
//case upgradedMessage:
|
|
||||||
// TODO: Handle upgrade
|
|
||||||
// onUpgradedMessage(sockfd, x[2]);
|
|
||||||
// break;
|
|
||||||
case url:
|
|
||||||
_staging.update(sockfd, (rq) {
|
|
||||||
rq?.__url = x[2] as String;
|
|
||||||
return rq;
|
|
||||||
}, defaultValue: _newRequest);
|
|
||||||
//_staging[sockfd]?.__url = x[2] as String;
|
|
||||||
break;
|
|
||||||
case headerField:
|
|
||||||
_staging.update(sockfd, (rq) {
|
|
||||||
rq?._headerField = x[2] as String;
|
|
||||||
return rq;
|
|
||||||
}, defaultValue: _newRequest);
|
|
||||||
//_staging[sockfd]?._headerField = x[2] as String;
|
|
||||||
break;
|
|
||||||
case headerValue:
|
|
||||||
_staging.update(sockfd, (rq) {
|
|
||||||
rq?._headerValue = x[2] as String;
|
|
||||||
return rq;
|
|
||||||
}, defaultValue: _newRequest);
|
|
||||||
//_staging[sockfd]?._headerValue = x[2] as String;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Future _handleRequest(WingsRequestContext req) {
|
|
||||||
//print('req: $req');
|
|
||||||
if (req == null) return new Future.value();
|
|
||||||
var res = new WingsResponseContext._(req)
|
|
||||||
..app = app
|
|
||||||
..serializer = (app.serializer ?? god.serialize)
|
|
||||||
..encoders.addAll(app.encoders);
|
|
||||||
//print('Handling fd: ${req._sockfd}');
|
|
||||||
|
|
||||||
handle() {
|
|
||||||
var path = req.path;
|
|
||||||
if (path == '/') path = '';
|
|
||||||
|
|
||||||
Tuple3<List, Map, ParseResult<Map<String, dynamic>>> resolveTuple() {
|
|
||||||
Router r = app.optimizedRouter;
|
|
||||||
var resolved =
|
|
||||||
r.resolveAbsolute(path, method: req.method, strip: false);
|
|
||||||
|
|
||||||
return new Tuple3(
|
|
||||||
new MiddlewarePipeline(resolved).handlers,
|
|
||||||
resolved.fold<Map>({}, (out, r) => out..addAll(r.allParams)),
|
|
||||||
resolved.isEmpty ? null : resolved.first.parseResult,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
var cacheKey = req.method + path;
|
|
||||||
var tuple = app.isProduction
|
|
||||||
? app.handlerCache.putIfAbsent(cacheKey, resolveTuple)
|
|
||||||
: resolveTuple();
|
|
||||||
|
|
||||||
req.params.addAll(tuple.item2);
|
|
||||||
req.inject(ParseResult, tuple.item3);
|
|
||||||
|
|
||||||
if (!app.isProduction && app.logger != null)
|
|
||||||
req.inject(Stopwatch, new Stopwatch()..start());
|
|
||||||
|
|
||||||
var pipeline = tuple.item1;
|
|
||||||
|
|
||||||
Future<bool> Function() runPipeline;
|
|
||||||
|
|
||||||
//print('Pipeline: $pipeline');
|
|
||||||
for (var handler in pipeline) {
|
|
||||||
if (handler == null) break;
|
|
||||||
|
|
||||||
if (runPipeline == null)
|
|
||||||
runPipeline = () => app.executeHandler(handler, req, res);
|
|
||||||
else {
|
|
||||||
var current = runPipeline;
|
|
||||||
runPipeline = () => current().then((result) => !result
|
|
||||||
? new Future.value(result)
|
|
||||||
: app.executeHandler(handler, req, res));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return runPipeline == null
|
|
||||||
? sendResponse(req, res)
|
|
||||||
: runPipeline().then((_) => sendResponse(req, res));
|
|
||||||
}
|
|
||||||
|
|
||||||
if (useZone == false) {
|
|
||||||
return handle().catchError((e, StackTrace st) {
|
|
||||||
if (e is FormatException)
|
|
||||||
throw new AngelHttpException.badRequest(message: e.message)
|
|
||||||
..stackTrace = st;
|
|
||||||
throw new AngelHttpException(e, stackTrace: st, statusCode: 500);
|
|
||||||
}, test: (e) => e is! AngelHttpException).catchError(
|
|
||||||
(AngelHttpException e, StackTrace st) {
|
|
||||||
return handleAngelHttpException(e, e.stackTrace ?? st, req, res);
|
|
||||||
}).whenComplete(() => res.dispose());
|
|
||||||
} else {
|
|
||||||
var zoneSpec = new ZoneSpecification(
|
|
||||||
print: (self, parent, zone, line) {
|
|
||||||
if (app.logger != null)
|
|
||||||
app.logger.info(line);
|
|
||||||
else
|
|
||||||
parent.print(zone, line);
|
|
||||||
},
|
|
||||||
handleUncaughtError: (self, parent, zone, error, stackTrace) {
|
|
||||||
var trace = new Trace.from(stackTrace ?? StackTrace.current).terse;
|
|
||||||
|
|
||||||
return new Future(() {
|
|
||||||
AngelHttpException e;
|
|
||||||
|
|
||||||
if (error is FormatException) {
|
|
||||||
e = new AngelHttpException.badRequest(message: error.message);
|
|
||||||
} else if (error is AngelHttpException) {
|
|
||||||
e = error;
|
|
||||||
} else {
|
|
||||||
e = new AngelHttpException(error,
|
|
||||||
stackTrace: stackTrace, message: error?.toString());
|
|
||||||
}
|
|
||||||
|
|
||||||
if (app.logger != null) {
|
|
||||||
app.logger.severe(e.message ?? e.toString(), error, trace);
|
|
||||||
}
|
|
||||||
|
|
||||||
return handleAngelHttpException(e, trace, req, res);
|
|
||||||
}).catchError((e, StackTrace st) {
|
|
||||||
var trace = new Trace.from(st ?? StackTrace.current).terse;
|
|
||||||
_closeSocket(req);
|
|
||||||
// Ideally, we won't be in a position where an absolutely fatal error occurs,
|
|
||||||
// but if so, we'll need to log it.
|
|
||||||
if (app.logger != null) {
|
|
||||||
app.logger.severe(
|
|
||||||
'Fatal error occurred when processing ${req.uri}.', e, trace);
|
|
||||||
} else {
|
|
||||||
stderr
|
|
||||||
..writeln('Fatal error occurred when processing '
|
|
||||||
'${req.uri}:')
|
|
||||||
..writeln(e)
|
|
||||||
..writeln(trace);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
},
|
|
||||||
);
|
|
||||||
|
|
||||||
var zone = Zone.current.fork(specification: zoneSpec);
|
|
||||||
req.inject(Zone, zone);
|
|
||||||
req.inject(ZoneSpecification, zoneSpec);
|
|
||||||
return zone.run(handle).whenComplete(() {
|
|
||||||
res.dispose();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Handles an [AngelHttpException].
|
|
||||||
Future handleAngelHttpException(AngelHttpException e, StackTrace st,
|
|
||||||
WingsRequestContext req, WingsResponseContext res,
|
|
||||||
{bool ignoreFinalizers: false}) {
|
|
||||||
if (req == null || res == null) {
|
|
||||||
try {
|
|
||||||
app.logger?.severe(e, st);
|
|
||||||
var b = new StringBuffer();
|
|
||||||
b.writeln('HTTP/1.1 500 Internal Server Error');
|
|
||||||
b.writeln();
|
|
||||||
|
|
||||||
_send(req, _coerceUint8List(b.toString().codeUnits));
|
|
||||||
_closeSocket(req);
|
|
||||||
} finally {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
Future handleError;
|
|
||||||
|
|
||||||
if (!res.isOpen)
|
|
||||||
handleError = new Future.value();
|
|
||||||
else {
|
|
||||||
res.statusCode = e.statusCode;
|
|
||||||
handleError =
|
|
||||||
new Future.sync(() => app.errorHandler(e, req, res)).then((result) {
|
|
||||||
return app.executeHandler(result, req, res).then((_) => res.end());
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
return handleError.then((_) =>
|
|
||||||
sendResponse(req, res, ignoreFinalizers: ignoreFinalizers == true));
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Sends a response.
|
|
||||||
Future sendResponse(WingsRequestContext req, WingsResponseContext res,
|
|
||||||
{bool ignoreFinalizers: false}) {
|
|
||||||
//print('Closing: ${req._sockfd}');
|
|
||||||
if (res.willCloseItself) return new Future.value();
|
|
||||||
//print('Not self-closing: ${req._sockfd}');
|
|
||||||
|
|
||||||
Future finalizers = ignoreFinalizers == true
|
|
||||||
? new Future.value()
|
|
||||||
: app.responseFinalizers.fold<Future>(
|
|
||||||
new Future.value(), (out, f) => out.then((_) => f(req, res)));
|
|
||||||
|
|
||||||
if (res.isOpen) res.end();
|
|
||||||
|
|
||||||
var headers = <String, String>{};
|
|
||||||
headers.addAll(res.headers);
|
|
||||||
|
|
||||||
headers['content-length'] = res.buffer.length.toString();
|
|
||||||
|
|
||||||
// Ignore chunked transfer encoding
|
|
||||||
//request.response.headers.chunkedTransferEncoding = res.chunked ?? true;
|
|
||||||
// TODO: Is there a need to support this?
|
|
||||||
|
|
||||||
//print('Buffer: ${res.buffer}');
|
|
||||||
List<int> outputBuffer = res.buffer.toBytes();
|
|
||||||
|
|
||||||
if (res.encoders.isNotEmpty) {
|
|
||||||
var allowedEncodings = req.headers
|
|
||||||
.value('accept-encoding')
|
|
||||||
?.split(',')
|
|
||||||
?.map((s) => s.trim())
|
|
||||||
?.where((s) => s.isNotEmpty)
|
|
||||||
?.map((str) {
|
|
||||||
// Ignore quality specifications in accept-encoding
|
|
||||||
// ex. gzip;q=0.8
|
|
||||||
if (!str.contains(';')) return str;
|
|
||||||
return str.split(';')[0];
|
|
||||||
});
|
|
||||||
|
|
||||||
if (allowedEncodings != null) {
|
|
||||||
for (var encodingName in allowedEncodings) {
|
|
||||||
Converter<List<int>, List<int>> encoder;
|
|
||||||
String key = encodingName;
|
|
||||||
|
|
||||||
if (res.encoders.containsKey(encodingName))
|
|
||||||
encoder = res.encoders[encodingName];
|
|
||||||
else if (encodingName == '*') {
|
|
||||||
encoder = res.encoders[key = res.encoders.keys.first];
|
|
||||||
}
|
|
||||||
|
|
||||||
if (encoder != null) {
|
|
||||||
headers['content-encoding'] = key;
|
|
||||||
outputBuffer = res.encoders[key].convert(outputBuffer);
|
|
||||||
|
|
||||||
headers['content-length'] = outputBuffer.length.toString();
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//print('Create string buffer');
|
|
||||||
var b = new StringBuffer();
|
|
||||||
b.writeln('HTTP/1.1 ${res.statusCode}');
|
|
||||||
|
|
||||||
res.headers.forEach((k, v) {
|
|
||||||
b.writeln('$k: $v');
|
|
||||||
});
|
|
||||||
|
|
||||||
// Persist session ID
|
|
||||||
if (res.correspondingRequest._session != null) {
|
|
||||||
res.cookies
|
|
||||||
.add(new Cookie('DARTSESSID', res.correspondingRequest._session.id));
|
|
||||||
}
|
|
||||||
|
|
||||||
// Send all cookies
|
|
||||||
for (var cookie in res.cookies) {
|
|
||||||
var value = cookie.toString();
|
|
||||||
b.writeln('set-cookie: $value');
|
|
||||||
}
|
|
||||||
|
|
||||||
b.writeln();
|
|
||||||
//print(b);
|
|
||||||
|
|
||||||
var bb = new BytesBuilder(copy: false)
|
|
||||||
..add(b.toString().codeUnits)
|
|
||||||
..add(outputBuffer);
|
|
||||||
var buf = _coerceUint8List(bb.takeBytes());
|
|
||||||
//print('Output: $buf');
|
|
||||||
|
|
||||||
return finalizers.then((_) {
|
|
||||||
//print('A');
|
|
||||||
_send(req, buf);
|
|
||||||
//print('B');
|
|
||||||
_closeSocket(req);
|
|
||||||
//print('C');
|
|
||||||
|
|
||||||
if (req.injections.containsKey(PoolResource)) {
|
|
||||||
req.injections[PoolResource].release();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!app.isProduction && app.logger != null) {
|
|
||||||
var sw = req.grab<Stopwatch>(Stopwatch);
|
|
||||||
|
|
||||||
if (sw.isRunning) {
|
|
||||||
sw?.stop();
|
|
||||||
app.logger.info("${res.statusCode} ${req.method} ${req.uri} (${sw
|
|
||||||
?.elapsedMilliseconds ?? 'unknown'} ms)");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,45 +0,0 @@
|
||||||
#ifndef ANGEL_WINGS_H
|
|
||||||
#define ANGEL_WINGS_H
|
|
||||||
#ifndef WIN32
|
|
||||||
#include <sys/socket.h>
|
|
||||||
#include <netinet/in.h>
|
|
||||||
#include <arpa/inet.h>
|
|
||||||
#include <unistd.h>
|
|
||||||
#else
|
|
||||||
#include <windows.h>
|
|
||||||
#include <winsock2.h>
|
|
||||||
#include <ws2tcpip.h>
|
|
||||||
#include <sstream>
|
|
||||||
// Need to link with Ws2_32.lib, Mswsock.lib, and Advapi32.lib
|
|
||||||
#pragma comment(lib, "Ws2_32.lib")
|
|
||||||
#pragma comment(lib, "Mswsock.lib")
|
|
||||||
#pragma comment(lib, "AdvApi32.lib")
|
|
||||||
#endif
|
|
||||||
#include <cstdint>
|
|
||||||
#include <mutex>
|
|
||||||
#include <string>
|
|
||||||
#include <vector>
|
|
||||||
#include <dart_api.h>
|
|
||||||
|
|
||||||
class WingsServerInfo
|
|
||||||
{
|
|
||||||
public:
|
|
||||||
std::mutex mutex;
|
|
||||||
std::string addressString;
|
|
||||||
uint64_t port;
|
|
||||||
int sockfd;
|
|
||||||
bool ipv6;
|
|
||||||
};
|
|
||||||
|
|
||||||
extern std::mutex serverInfoVectorMutex;
|
|
||||||
extern std::vector<WingsServerInfo *> serverInfoVector;
|
|
||||||
|
|
||||||
Dart_Handle HandleError(Dart_Handle handle);
|
|
||||||
|
|
||||||
void wings_AddressToString(Dart_NativeArguments arguments);
|
|
||||||
void wings_BindSocket(Dart_NativeArguments arguments);
|
|
||||||
void wings_CloseSocket(Dart_NativeArguments arguments);
|
|
||||||
void wings_Send(Dart_NativeArguments arguments);
|
|
||||||
void wings_StartHttpListener(Dart_NativeArguments arguments);
|
|
||||||
|
|
||||||
#endif
|
|
||||||
87
lib/src/wings_driver.dart
Normal file
87
lib/src/wings_driver.dart
Normal file
|
|
@ -0,0 +1,87 @@
|
||||||
|
import 'dart:async';
|
||||||
|
import 'dart:convert';
|
||||||
|
import 'dart:io' show Cookie;
|
||||||
|
import 'dart:typed_data';
|
||||||
|
import 'package:angel_framework/angel_framework.dart';
|
||||||
|
import 'package:angel_framework/http.dart';
|
||||||
|
import 'native_socket.dart';
|
||||||
|
import 'wings_request.dart';
|
||||||
|
import 'wings_response.dart';
|
||||||
|
|
||||||
|
class AngelWings extends Driver<int, int, NativeSocket, WingsRequestContext,
|
||||||
|
WingsResponseContext> {
|
||||||
|
factory AngelWings(Angel app) {
|
||||||
|
return AngelWings._(app, null);
|
||||||
|
}
|
||||||
|
|
||||||
|
AngelWings._(
|
||||||
|
Angel app, Future<NativeSocket> Function(dynamic, int) serverGenerator)
|
||||||
|
: super(app, serverGenerator);
|
||||||
|
|
||||||
|
@override
|
||||||
|
void addCookies(int response, Iterable<Cookie> cookies) {
|
||||||
|
for (var cookie in cookies) {
|
||||||
|
setHeader(response, 'set-cookie', cookie.toString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
Future closeResponse(int response) {
|
||||||
|
closeNativeSocket(response);
|
||||||
|
return Future.value();
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
Future<WingsRequestContext> createRequestContext(int request, int response) {
|
||||||
|
// TODO: implement createRequestContext
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
Future<WingsResponseContext> createResponseContext(int request, int response,
|
||||||
|
[WingsRequestContext correspondingRequest]) {
|
||||||
|
// TODO: implement createResponseContext
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
Stream<int> createResponseStreamFromRawRequest(int request) {
|
||||||
|
return Stream.fromIterable([request]);
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void setChunkedEncoding(int response, bool value) {
|
||||||
|
// TODO: implement setChunkedEncoding
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void setContentLength(int response, int length) {
|
||||||
|
writeStringToResponse(response, 'content-length: $length\r\n');
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void setHeader(int response, String key, String value) {
|
||||||
|
writeStringToResponse(response, '$key: $value\r\n');
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void setStatusCode(int response, int value) {
|
||||||
|
// HTTP-Version SP Status-Code SP Reason-Phrase CRLF
|
||||||
|
writeStringToResponse(response, 'HTTP/1.1 $value\r\n');
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
// TODO: implement uri
|
||||||
|
Uri get uri => null;
|
||||||
|
|
||||||
|
@override
|
||||||
|
void writeStringToResponse(int response, String value) {
|
||||||
|
writeToResponse(response, utf8.encode(value));
|
||||||
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void writeToResponse(int response, List<int> data) {
|
||||||
|
var buf = data is Uint8List ? data : Uint8List.fromList(data);
|
||||||
|
writeToNativeSocket(response, buf);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -1,158 +1,53 @@
|
||||||
part of angel_wings;
|
import 'dart:io';
|
||||||
|
import 'package:angel_container/src/container.dart';
|
||||||
|
import 'package:angel_framework/angel_framework.dart';
|
||||||
|
|
||||||
class WingsRequestContext extends RequestContext {
|
class WingsRequestContext extends RequestContext<int> {
|
||||||
final AngelWings _wings;
|
@override
|
||||||
final int _sockfd;
|
// TODO: implement body
|
||||||
bool _closed = false;
|
Stream<List<int>> get body => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Angel app;
|
// TODO: implement container
|
||||||
|
Container get container => null;
|
||||||
WingsRequestContext._(this._wings, this._sockfd, Angel app) : this.app = app;
|
|
||||||
|
|
||||||
static final RegExp _straySlashes = new RegExp(r'(^/+)|(/+$)');
|
|
||||||
|
|
||||||
final Map<String, String> _headers = {};
|
|
||||||
|
|
||||||
String __contentTypeString;
|
|
||||||
//String __path;
|
|
||||||
String __url;
|
|
||||||
|
|
||||||
Uint8List _addressBytes;
|
|
||||||
StreamController<Uint8List> _body;
|
|
||||||
ContentType _contentType;
|
|
||||||
List<Cookie> _cookies;
|
|
||||||
String _headerField, _hostname, _originalMethod, _method, _path;
|
|
||||||
HttpHeaders _httpHeaders;
|
|
||||||
InternetAddress _remoteAddress;
|
|
||||||
HttpSession _session;
|
|
||||||
Uri _uri;
|
|
||||||
|
|
||||||
static String _addressToString(Uint8List bytes, bool ipV6)
|
|
||||||
native "AddressToString";
|
|
||||||
|
|
||||||
String get _contentTypeString =>
|
|
||||||
__contentTypeString ??= _headers['content-type']?.toString();
|
|
||||||
|
|
||||||
void set _headerValue(String value) {
|
|
||||||
if (_headerField != null) {
|
|
||||||
_headers[_headerField.toLowerCase()] = value;
|
|
||||||
_headerField = null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
ContentType get contentType => _contentType ??= (_contentTypeString == null
|
// TODO: implement cookies
|
||||||
? ContentType.binary
|
List<Cookie> get cookies => null;
|
||||||
: ContentType.parse(_contentTypeString));
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
List<Cookie> get cookies {
|
// TODO: implement headers
|
||||||
if (_cookies != null) {
|
HttpHeaders get headers => null;
|
||||||
return _cookies;
|
|
||||||
}
|
|
||||||
|
|
||||||
var cookies = <Cookie>[];
|
|
||||||
|
|
||||||
return _cookies = new List<Cookie>.unmodifiable(cookies);
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
HttpHeaders get headers => _httpHeaders ??= new _WingsIncomingHeaders(this);
|
// TODO: implement hostname
|
||||||
|
String get hostname => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
String get hostname => _hostname ??=
|
// TODO: implement method
|
||||||
(_headers['host'] ?? '${_wings.address.address}:${_wings.port}');
|
String get method => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
HttpRequest get io => null;
|
// TODO: implement originalMethod
|
||||||
|
String get originalMethod => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
String get method =>
|
// TODO: implement path
|
||||||
_method ??= (_headers['x-http-method-override'] ?? originalMethod);
|
String get path => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
String get originalMethod => _originalMethod;
|
// TODO: implement rawRequest
|
||||||
|
int get rawRequest => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Future<BodyParseResult> parseOnce() {
|
// TODO: implement remoteAddress
|
||||||
return parseBodyFromStream(
|
InternetAddress get remoteAddress => null;
|
||||||
_body?.stream ?? new Stream<List<int>>.empty(),
|
|
||||||
contentType == null ? null : new MediaType.parse(contentType.toString()),
|
|
||||||
uri,
|
|
||||||
storeOriginalBuffer: app.storeOriginalBuffer,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
String get path {
|
// TODO: implement session
|
||||||
if (_path != null) {
|
HttpSession get session => null;
|
||||||
return _path;
|
|
||||||
} else {
|
|
||||||
var path = __url?.replaceAll(_straySlashes, '') ?? '';
|
|
||||||
if (path.isEmpty) path = '/';
|
|
||||||
return _path = path;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
InternetAddress get remoteAddress => _remoteAddress ??= new InternetAddress(
|
// TODO: implement uri
|
||||||
_addressToString(_addressBytes, _addressBytes.length > 4));
|
Uri get uri => null;
|
||||||
|
|
||||||
@override
|
|
||||||
HttpSession get session {
|
|
||||||
if (_session != null) return _session;
|
|
||||||
var dartSessIdCookie = cookies.firstWhere((c) => c.name == 'DARTSESSID',
|
|
||||||
orElse: () => new Cookie('DARTSESSID', _wings._uuid.v4().toString()));
|
|
||||||
return _session = _wings._sessions.putIfAbsent(dartSessIdCookie.value,
|
|
||||||
() => new MockHttpSession(id: dartSessIdCookie.value));
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
Uri get uri => _uri ??= Uri.parse(__url);
|
|
||||||
|
|
||||||
@override
|
|
||||||
bool get xhr =>
|
|
||||||
_headers['x-requested-with']?.trim()?.toLowerCase() == 'xmlhttprequest';
|
|
||||||
}
|
|
||||||
|
|
||||||
class _WingsIncomingHeaders extends HttpHeaders {
|
|
||||||
final WingsRequestContext request;
|
|
||||||
|
|
||||||
_WingsIncomingHeaders(this.request);
|
|
||||||
|
|
||||||
UnsupportedError _unsupported() =>
|
|
||||||
new UnsupportedError('Cannot modify incoming HTTP headers.');
|
|
||||||
|
|
||||||
@override
|
|
||||||
List<String> operator [](String name) {
|
|
||||||
return value(name)?.split(',')?.map((s) => s.trim())?.toList();
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
void add(String name, Object value) => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
void clear() => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
void forEach(void Function(String name, List<String> values) f) {
|
|
||||||
request._headers.forEach((name, value) =>
|
|
||||||
f(name, value.split(',').map((s) => s.trim()).toList()));
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
void noFolding(String name) => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
void remove(String name, Object value) => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
void removeAll(String name) => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
void set(String name, Object value) => throw _unsupported();
|
|
||||||
|
|
||||||
@override
|
|
||||||
String value(String name) => request._headers[name.toLowerCase()];
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,156 +1,50 @@
|
||||||
part of angel_wings;
|
import 'dart:async';
|
||||||
|
|
||||||
|
import 'dart:io';
|
||||||
|
|
||||||
|
import 'package:angel_framework/angel_framework.dart';
|
||||||
|
|
||||||
class WingsResponseContext extends ResponseContext {
|
class WingsResponseContext extends ResponseContext {
|
||||||
final WingsRequestContext correspondingRequest;
|
|
||||||
bool _isClosed = false, _useStream = false;
|
|
||||||
|
|
||||||
WingsResponseContext._(this.correspondingRequest);
|
|
||||||
|
|
||||||
AngelWings get _wings => correspondingRequest._wings;
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void add(List<int> data) {
|
void add(List<int> event) {
|
||||||
if (_isClosed && !_useStream)
|
// TODO: implement add
|
||||||
throw ResponseContext.closed();
|
|
||||||
else if (_useStream)
|
|
||||||
_wings._send(correspondingRequest, _coerceUint8List(data));
|
|
||||||
else
|
|
||||||
buffer.add(data);
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
Future close() {
|
|
||||||
_wings._closeSocket(correspondingRequest);
|
|
||||||
_isClosed = true;
|
|
||||||
_useStream = false;
|
|
||||||
return super.close();
|
|
||||||
}
|
|
||||||
|
|
||||||
@override
|
|
||||||
void end() {
|
|
||||||
_isClosed = true;
|
|
||||||
super.end();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Future addStream(Stream<List<int>> stream) {
|
Future addStream(Stream<List<int>> stream) {
|
||||||
if (_isClosed && !_useStream) throw ResponseContext.closed();
|
// TODO: implement addStream
|
||||||
var firstStream = useStream();
|
return null;
|
||||||
|
|
||||||
Stream<List<int>> output = stream;
|
|
||||||
|
|
||||||
if ((firstStream || !headers.containsKey('content-encoding')) &&
|
|
||||||
encoders.isNotEmpty &&
|
|
||||||
correspondingRequest != null) {
|
|
||||||
var allowedEncodings =
|
|
||||||
(correspondingRequest.headers['accept-encoding'] ?? []).map((str) {
|
|
||||||
// Ignore quality specifications in accept-encoding
|
|
||||||
// ex. gzip;q=0.8
|
|
||||||
if (!str.contains(';')) return str;
|
|
||||||
return str.split(';')[0];
|
|
||||||
});
|
|
||||||
|
|
||||||
for (var encodingName in allowedEncodings) {
|
|
||||||
Converter<List<int>, List<int>> encoder;
|
|
||||||
String key = encodingName;
|
|
||||||
|
|
||||||
if (encoders.containsKey(encodingName))
|
|
||||||
encoder = encoders[encodingName];
|
|
||||||
else if (encodingName == '*') {
|
|
||||||
encoder = encoders[key = encoders.keys.first];
|
|
||||||
}
|
|
||||||
|
|
||||||
if (encoder != null) {
|
|
||||||
/*
|
|
||||||
if (firstStream) {
|
|
||||||
this.stream.sendHeaders([
|
|
||||||
new Header.ascii(
|
|
||||||
'content-encoding', headers['content-encoding'] = key)
|
|
||||||
]);
|
|
||||||
}
|
|
||||||
*/
|
|
||||||
|
|
||||||
output = encoders[key].bind(output);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return output.forEach(
|
|
||||||
((data) => _wings._send(correspondingRequest, _coerceUint8List(data))));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
HttpResponse get io => null;
|
// TODO: implement buffer
|
||||||
|
BytesBuilder get buffer => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
bool get isOpen => !_isClosed;
|
// TODO: implement correspondingRequest
|
||||||
|
RequestContext get correspondingRequest => null;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
bool get streaming => _useStream;
|
FutureOr detach() {
|
||||||
|
// TODO: implement detach
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
bool useStream() {
|
// TODO: implement isBuffered
|
||||||
if (!_useStream) {
|
bool get isBuffered => null;
|
||||||
// If this is the first stream added to this response,
|
|
||||||
// then add headers, status code, etc.
|
|
||||||
_finalize();
|
|
||||||
|
|
||||||
willCloseItself = _useStream = _isClosed = true;
|
@override
|
||||||
releaseCorrespondingRequest();
|
// TODO: implement isOpen
|
||||||
return true;
|
bool get isOpen => null;
|
||||||
|
|
||||||
|
@override
|
||||||
|
// TODO: implement rawResponse
|
||||||
|
get rawResponse => null;
|
||||||
|
|
||||||
|
@override
|
||||||
|
void useBuffer() {
|
||||||
|
// TODO: implement useBuffer
|
||||||
}
|
}
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Write headers, status, etc. to the underlying [stream].
|
|
||||||
void _finalize() {
|
|
||||||
var b = new StringBuffer();
|
|
||||||
b.writeln('HTTP/1.1 $statusCode');
|
|
||||||
headers['date'] ??= HttpDate.format(new DateTime.now());
|
|
||||||
|
|
||||||
if (encoders.isNotEmpty && correspondingRequest != null) {
|
|
||||||
var allowedEncodings =
|
|
||||||
(correspondingRequest.headers['accept-encoding'] ?? []).map((str) {
|
|
||||||
// Ignore quality specifications in accept-encoding
|
|
||||||
// ex. gzip;q=0.8
|
|
||||||
if (!str.contains(';')) return str;
|
|
||||||
return str.split(';')[0];
|
|
||||||
});
|
|
||||||
|
|
||||||
for (var encodingName in allowedEncodings) {
|
|
||||||
String key = encodingName;
|
|
||||||
|
|
||||||
if (encoders.containsKey(encodingName)) {
|
|
||||||
this.headers['content-encoding'] = key;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Add all normal headers
|
|
||||||
this.headers.forEach((k, v) {
|
|
||||||
b.writeln('$k: $v');
|
|
||||||
});
|
|
||||||
|
|
||||||
// Persist session ID
|
|
||||||
if (correspondingRequest._session != null) {
|
|
||||||
cookies.add(new Cookie('DARTSESSID', correspondingRequest._session.id));
|
|
||||||
}
|
|
||||||
|
|
||||||
// Send all cookies
|
|
||||||
for (var cookie in cookies) {
|
|
||||||
var value = cookie.toString();
|
|
||||||
b.writeln('set-cookie: $value');
|
|
||||||
}
|
|
||||||
|
|
||||||
b.writeln();
|
|
||||||
|
|
||||||
_wings._send(
|
|
||||||
correspondingRequest, _coerceUint8List(b.toString().codeUnits));
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Uint8List _coerceUint8List(List<int> list) =>
|
|
||||||
list is Uint8List ? list : new Uint8List.fromList(list);
|
|
||||||
|
|
|
||||||
|
|
@ -1,25 +0,0 @@
|
||||||
#ifndef ANGEL_WINGS_THREAD_H
|
|
||||||
#define ANGEL_WINGS_THREAD_H
|
|
||||||
#include <dart_api.h>
|
|
||||||
#include <http_parser.h>
|
|
||||||
#include "wings.h"
|
|
||||||
|
|
||||||
typedef struct
|
|
||||||
{
|
|
||||||
Dart_Port port;
|
|
||||||
WingsServerInfo *serverInfo;
|
|
||||||
} wings_thread_info;
|
|
||||||
|
|
||||||
typedef struct
|
|
||||||
{
|
|
||||||
bool ipv6;
|
|
||||||
int sock;
|
|
||||||
sockaddr addr;
|
|
||||||
socklen_t addr_len;
|
|
||||||
Dart_Port port;
|
|
||||||
} requestInfo;
|
|
||||||
|
|
||||||
void wingsThreadMain(wings_thread_info *info);
|
|
||||||
void handleRequest(requestInfo *rq);
|
|
||||||
|
|
||||||
#endif
|
|
||||||
|
|
@ -1,229 +0,0 @@
|
||||||
#include <memory>
|
|
||||||
#include <iostream>
|
|
||||||
#include <utility>
|
|
||||||
#include <dart_native_api.h>
|
|
||||||
#include "wings_thread.h"
|
|
||||||
|
|
||||||
void wingsThreadMain(wings_thread_info *info)
|
|
||||||
{
|
|
||||||
auto *serverInfo = std::move(info->serverInfo);
|
|
||||||
Dart_Port port = std::move(info->port);
|
|
||||||
//delete info;
|
|
||||||
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
//std::unique_lock<std::mutex> lock(serverInfo->mutex, std::defer_lock);
|
|
||||||
std::lock_guard<std::mutex> lock(serverInfo->mutex);
|
|
||||||
|
|
||||||
sockaddr client_addr{};
|
|
||||||
socklen_t client_addr_len;
|
|
||||||
|
|
||||||
//if (lock.try_lock())
|
|
||||||
//{
|
|
||||||
int client = accept(serverInfo->sockfd, &client_addr, &client_addr_len);
|
|
||||||
//lock.unlock();
|
|
||||||
|
|
||||||
if (client < 0)
|
|
||||||
{
|
|
||||||
// send_error(info->port, "Failed to accept client socket.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
//auto rq = std::make_shared<requestInfo>();
|
|
||||||
auto *rq = new requestInfo;
|
|
||||||
rq->ipv6 = serverInfo->ipv6;
|
|
||||||
rq->sock = client;
|
|
||||||
rq->addr = client_addr;
|
|
||||||
rq->addr_len = client_addr_len;
|
|
||||||
rq->port = port;
|
|
||||||
handleRequest(rq);
|
|
||||||
//}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
int send_notification(http_parser *parser, int code)
|
|
||||||
{
|
|
||||||
//if (parser == nullptr) return 0;
|
|
||||||
auto *rq = (requestInfo *)parser->data;
|
|
||||||
//if (rq == nullptr) return 0;
|
|
||||||
|
|
||||||
Dart_CObject first{};
|
|
||||||
Dart_CObject second{};
|
|
||||||
first.type = second.type = Dart_CObject_kInt64;
|
|
||||||
first.value.as_int64 = rq->sock;
|
|
||||||
second.value.as_int64 = code;
|
|
||||||
|
|
||||||
Dart_CObject *list[2]{&first, &second};
|
|
||||||
Dart_CObject obj{};
|
|
||||||
obj.type = Dart_CObject_kArray;
|
|
||||||
obj.value.as_array.length = 2;
|
|
||||||
obj.value.as_array.values = list;
|
|
||||||
Dart_PostCObject(rq->port, &obj);
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
int send_string(http_parser *parser, char *str, size_t length, int code, bool as_typed_data = false)
|
|
||||||
{
|
|
||||||
//if (parser == nullptr) return 0;
|
|
||||||
auto *rq = (requestInfo *)parser->data;
|
|
||||||
char *s = nullptr;
|
|
||||||
//if (rq == nullptr) return 0;
|
|
||||||
|
|
||||||
Dart_CObject first{};
|
|
||||||
Dart_CObject second{};
|
|
||||||
Dart_CObject third{};
|
|
||||||
first.type = second.type = Dart_CObject_kInt32;
|
|
||||||
first.value.as_int32 = rq->sock;
|
|
||||||
second.value.as_int32 = code;
|
|
||||||
|
|
||||||
if (!as_typed_data)
|
|
||||||
{
|
|
||||||
s = new char[length + 1];
|
|
||||||
memset(s, 0, length + 1);
|
|
||||||
third.type = Dart_CObject_kString;
|
|
||||||
//strcpy(s, str);
|
|
||||||
memcpy(s, str, length);
|
|
||||||
third.value.as_string = s;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
third.type = Dart_CObject_kTypedData;
|
|
||||||
third.type = Dart_CObject_kTypedData;
|
|
||||||
third.value.as_typed_data.type = Dart_TypedData_kUint8;
|
|
||||||
third.value.as_typed_data.length = length;
|
|
||||||
third.value.as_typed_data.values = (uint8_t *)str;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Post the string back to Dart...
|
|
||||||
Dart_CObject *list[3]{&first, &second, &third};
|
|
||||||
Dart_CObject obj{};
|
|
||||||
obj.type = Dart_CObject_kArray;
|
|
||||||
obj.value.as_array.length = 3;
|
|
||||||
obj.value.as_array.values = list;
|
|
||||||
Dart_PostCObject(rq->port, &obj);
|
|
||||||
if (s != nullptr)
|
|
||||||
delete s;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
int send_oncomplete(http_parser *parser, int code)
|
|
||||||
{
|
|
||||||
//if (parser == nullptr) return 0;
|
|
||||||
auto *rq = (requestInfo *)parser->data;
|
|
||||||
//if (rq == nullptr) return 0;
|
|
||||||
|
|
||||||
Dart_CObject sockfd{};
|
|
||||||
Dart_CObject command{};
|
|
||||||
Dart_CObject method{};
|
|
||||||
Dart_CObject major{};
|
|
||||||
Dart_CObject minor{};
|
|
||||||
Dart_CObject addr{};
|
|
||||||
sockfd.type = command.type = method.type = major.type = minor.type = Dart_CObject_kInt32;
|
|
||||||
addr.type = Dart_CObject_kTypedData;
|
|
||||||
sockfd.value.as_int32 = rq->sock;
|
|
||||||
command.value.as_int32 = code;
|
|
||||||
method.value.as_int32 = parser->method;
|
|
||||||
major.value.as_int32 = parser->http_major;
|
|
||||||
minor.value.as_int32 = parser->http_minor;
|
|
||||||
addr.value.as_typed_data.type = Dart_TypedData_kUint8;
|
|
||||||
addr.value.as_typed_data.length = rq->addr_len;
|
|
||||||
|
|
||||||
if (rq->ipv6)
|
|
||||||
{
|
|
||||||
auto *v6 = (sockaddr_in6 *)&rq->addr;
|
|
||||||
addr.value.as_typed_data.values = (uint8_t *)v6->sin6_addr.s6_addr;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
auto *v4 = (sockaddr_in *)&rq->addr;
|
|
||||||
addr.value.as_typed_data.values = (uint8_t *)&v4->sin_addr.s_addr;
|
|
||||||
}
|
|
||||||
|
|
||||||
Dart_CObject *list[6]{&sockfd, &command, &method, &major, &minor, &addr};
|
|
||||||
Dart_CObject obj{};
|
|
||||||
obj.type = Dart_CObject_kArray;
|
|
||||||
obj.value.as_array.length = 6;
|
|
||||||
obj.value.as_array.values = list;
|
|
||||||
Dart_PostCObject(rq->port, &obj);
|
|
||||||
//delete parser;
|
|
||||||
return 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
//void handleRequest(const std::shared_ptr<requestInfo> &rq)
|
|
||||||
void handleRequest(requestInfo *rq)
|
|
||||||
{
|
|
||||||
size_t len = 100 * 1024, nparsed;
|
|
||||||
char buf[len];
|
|
||||||
ssize_t recved;
|
|
||||||
memset(buf, 0, len);
|
|
||||||
|
|
||||||
http_parser parser{};
|
|
||||||
parser.data = rq; //rq.get();
|
|
||||||
http_parser_init(&parser, HTTP_REQUEST);
|
|
||||||
|
|
||||||
http_parser_settings settings{};
|
|
||||||
|
|
||||||
settings.on_message_begin = [](http_parser *parser) {
|
|
||||||
//std::cout << "mb" << std::endl;
|
|
||||||
return send_notification(parser, 0);
|
|
||||||
};
|
|
||||||
|
|
||||||
settings.on_message_complete = [](http_parser *parser) {
|
|
||||||
//std::cout << "mc" << std::endl;
|
|
||||||
send_oncomplete(parser, 1);
|
|
||||||
delete (requestInfo *)parser->data;
|
|
||||||
//std::cout << "deleted rq!" << std::endl;
|
|
||||||
return 0;
|
|
||||||
};
|
|
||||||
|
|
||||||
settings.on_url = [](http_parser *parser, const char *at, size_t length) {
|
|
||||||
// //std::cout << "url" << std::endl;
|
|
||||||
return send_string(parser, (char *)at, length, 2);
|
|
||||||
};
|
|
||||||
|
|
||||||
settings.on_header_field = [](http_parser *parser, const char *at, size_t length) {
|
|
||||||
//std::cout << "hf" << std::endl;
|
|
||||||
return send_string(parser, (char *)at, length, 3);
|
|
||||||
};
|
|
||||||
|
|
||||||
settings.on_header_value = [](http_parser *parser, const char *at, size_t length) {
|
|
||||||
//std::cout << "hv" << std::endl;
|
|
||||||
return send_string(parser, (char *)at, length, 4);
|
|
||||||
};
|
|
||||||
|
|
||||||
settings.on_body = [](http_parser *parser, const char *at, size_t length) {
|
|
||||||
//std::cout << "body" << std::endl;
|
|
||||||
return send_string(parser, (char *)at, length, 5, true);
|
|
||||||
};
|
|
||||||
|
|
||||||
unsigned int isUpgrade = 0;
|
|
||||||
|
|
||||||
//std::cout << "start" << std::endl;
|
|
||||||
while ((recved = recv(rq->sock, buf, len, 0)) >= 0)
|
|
||||||
{
|
|
||||||
if (isUpgrade)
|
|
||||||
{
|
|
||||||
send_string(&parser, buf, (size_t)recved, 7, true);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
/* Start up / continue the parser.
|
|
||||||
* Note we pass recved==0 to signal that EOF has been received.
|
|
||||||
*/
|
|
||||||
nparsed = http_parser_execute(&parser, &settings, buf, (size_t)recved);
|
|
||||||
|
|
||||||
if ((isUpgrade = parser.upgrade) == 1)
|
|
||||||
{
|
|
||||||
send_notification(&parser, 6);
|
|
||||||
}
|
|
||||||
else if (nparsed != recved)
|
|
||||||
{
|
|
||||||
//std::cout << "Hm what" << std::endl;
|
|
||||||
close(rq->sock);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
memset(buf, 0, len);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
16
pubspec.yaml
16
pubspec.yaml
|
|
@ -1,14 +1,10 @@
|
||||||
name: angel_wings
|
name: angel_wings
|
||||||
|
environment:
|
||||||
|
sdk: ">=2.0.0-dev <3.0.0"
|
||||||
dependencies:
|
dependencies:
|
||||||
angel_framework: ^1.0.0
|
angel_framework: ^2.0.0-alpha
|
||||||
build_native: ^0.0.9
|
build_native: ^0.0.11
|
||||||
mock_request: ^1.0.0
|
mock_request: ^1.0.0
|
||||||
pooled_map: ^1.0.0
|
|
||||||
uuid: ^1.0.0
|
|
||||||
dev_dependencies:
|
dev_dependencies:
|
||||||
angel_static: ^1.3.0
|
angel_static: ^2.0.0
|
||||||
build_runner:
|
build_runner: ^1.0.0
|
||||||
git:
|
|
||||||
url: https://github.com/thosakwe/build.git
|
|
||||||
path: build_runner
|
|
||||||
ref: experimental-hot-reloading
|
|
||||||
Loading…
Reference in a new issue