mrpastewart/platform
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
platform/lib/src/http/server.dart

260 lines
8 KiB
Dart
Raw Normal View History

Bless up
2016-02-28 13:11:17 +00:00
part of angel_framework.http;
Almost done.
2016-04-18 03:27:23 +00:00
/// A function that binds an [Angel] server to an Internet address and port.
Bless up
2016-02-28 13:11:17 +00:00
typedef Future<HttpServer> ServerGenerator(InternetAddress address, int port);
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
/// Handles an [AngelHttpException].
onService, onController
2016-07-05 22:11:54 +00:00
typedef Future AngelErrorHandler(AngelHttpException err, RequestContext req,
ResponseContext res);
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
Almost done.
2016-04-18 03:27:23 +00:00
/// A function that configures an [Angel] server in some way.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
typedef Future AngelConfigurer(Angel app);
Almost done.
2016-04-18 03:27:23 +00:00
Bless up
2016-02-28 13:11:17 +00:00
/// A powerful real-time/REST/MVC server class.
class Angel extends Routable {
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
var _beforeProcessed = new StreamController<HttpRequest>();
var _afterProcessed = new StreamController<HttpRequest>();
onService, onController
2016-07-05 22:11:54 +00:00
var _onController = new StreamController<Controller>.broadcast();
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
onService, onController
2016-07-05 22:11:54 +00:00
/// Fired before a request is processed. Always runs.
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
Stream<HttpRequest> get beforeProcessed => _beforeProcessed.stream;
onService, onController
2016-07-05 22:11:54 +00:00
/// Fired after a request is processed. Always runs.
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
Stream<HttpRequest> get afterProcessed => _afterProcessed.stream;
onService, onController
2016-07-05 22:11:54 +00:00
/// Fired whenever a controller is added to this instance.
///
/// **NOTE**: This is a broadcast stream.
Stream<Controller> get onController => _onController.stream;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
ServerGenerator _serverGenerator =
(address, port) async => await HttpServer.bind(address, port);
/// Default error handler, show HTML error page
onService, onController
2016-07-05 22:11:54 +00:00
AngelErrorHandler _errorHandler = (AngelHttpException e, req,
ResponseContext res) {
F**K 12
2016-05-01 02:03:31 +00:00
res.header(HttpHeaders.CONTENT_TYPE, ContentType.HTML.toString());
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
res.status(e.statusCode);
DOCTYPE -> !DOCTYPE
2016-07-03 22:23:55 +00:00
res.write("<!DOCTYPE html><html><head><title>${e.message}</title>");
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
res.write("</head><body><h1>${e.message}</h1><ul>");
for (String error in e.errors) {
res.write("<li>$error</li>");
}
res.write("</ul></body></html>");
res.end();
};
1.0.0-dev!
2016-06-21 22:56:04 +00:00
/// A function that renders views.
///
/// Called by [ResponseContext]@`render`.
onService, onController
2016-07-05 22:11:54 +00:00
ViewGenerator viewGenerator = (String view,
[Map data]) async => "No view engine has been configured yet.";
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
/// [RequestMiddleware] to be run before all requests.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
List before = [];
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
/// [RequestMiddleware] to be run after all requests.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
List after = [];
Almost done.
2016-04-18 03:27:23 +00:00
1.0.0-dev!
2016-06-21 22:56:04 +00:00
/// The native HttpServer running this instancce.
Almost done.
2016-04-18 03:27:23 +00:00
HttpServer httpServer;
1.0.0-dev!
2016-06-21 22:56:04 +00:00
/// Starts the server.
///
/// Returns false on failure; otherwise, returns the HttpServer.
Almost done.
2016-04-18 03:27:23 +00:00
startServer(InternetAddress address, int port) async {
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
var server =
onService, onController
2016-07-05 22:11:54 +00:00
await _serverGenerator(address ?? InternetAddress.LOOPBACK_IP_V4, port);
Almost done.
2016-04-18 03:27:23 +00:00
this.httpServer = server;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
server.listen(handleRequest);
return server;
}
Future handleRequest(HttpRequest request) async {
_beforeProcessed.add(request);
String req_url =
onService, onController
2016-07-05 22:11:54 +00:00
request.uri.toString().replaceAll("?" + request.uri.query, "").replaceAll(
new RegExp(r'\/+$'), '');
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
if (req_url.isEmpty) req_url = '/';
RequestContext req = await RequestContext.from(request, {}, this, null);
ResponseContext res = await ResponseContext.from(request.response, this);
bool canContinue = true;
var execHandler = (handler, req) async {
if (canContinue) {
canContinue = await new Future.sync(() async {
return _applyHandler(handler, req, res);
}).catchError((e, [StackTrace stackTrace]) async {
if (e is AngelHttpException) {
// Special handling for AngelHttpExceptions :)
try {
res.status(e.statusCode);
String accept = request.headers.value(HttpHeaders.ACCEPT);
if (accept == "*/*" ||
accept.contains("application/json") ||
accept.contains("application/javascript")) {
res.json(e.toMap());
} else {
await _errorHandler(e, req, res);
}
_finalizeResponse(request, res);
} catch (_) {}
}
_onError(e, stackTrace);
canContinue = false;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
return false;
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
});
} else
return false;
};
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
for (var handler in before) {
await execHandler(handler, req);
}
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
for (Route route in routes) {
if (!canContinue) break;
if (route.matcher.hasMatch(req_url) &&
(request.method == route.method || route.method == '*')) {
req.params = route.parseParameters(req_url);
req.route = route;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
for (var handler in route.handlers) {
await execHandler(handler, req);
Almost done.
2016-04-18 03:27:23 +00:00
}
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
}
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
}
Almost done.
2016-04-18 03:27:23 +00:00
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
for (var handler in after) {
await execHandler(handler, req);
}
_finalizeResponse(request, res);
Almost done.
2016-04-18 03:27:23 +00:00
}
onService, onController
2016-07-05 22:11:54 +00:00
Future<bool> _applyHandler(handler, RequestContext req,
ResponseContext res) async {
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
if (handler is RequestMiddleware) {
It's getting there. Slowly, but surely.
2016-04-21 20:37:02 +00:00
var result = await handler(req, res);
if (result is bool)
return result == true;
else if (result != null) {
res.json(result);
return false;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
} else
return res.isOpen;
Almost done.
2016-04-18 03:27:23 +00:00
}
It's getting there. Slowly, but surely.
2016-04-21 20:37:02 +00:00
if (handler is RequestHandler) {
Almost done.
2016-04-18 03:27:23 +00:00
await handler(req, res);
return res.isOpen;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
} else if (handler is RawRequestHandler) {
Almost done.
2016-04-18 03:27:23 +00:00
var result = await handler(req.underlyingRequest);
It's getting there. Slowly, but surely.
2016-04-21 20:37:02 +00:00
if (result is bool)
return result == true;
else if (result != null) {
res.json(result);
return false;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
} else
return true;
} else if (handler is Function || handler is Future) {
Almost done.
2016-04-18 03:27:23 +00:00
var result = await handler();
It's getting there. Slowly, but surely.
2016-04-21 20:37:02 +00:00
if (result is bool)
return result == true;
else if (result != null) {
res.json(result);
return false;
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
} else
return true;
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
} else if (requestMiddleware.containsKey(handler)) {
return await _applyHandler(requestMiddleware[handler], req, res);
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
} else {
Almost done.
2016-04-18 03:27:23 +00:00
res.willCloseItself = true;
res.underlyingResponse.write(god.serialize(handler));
await res.underlyingResponse.close();
return false;
}
}
dev.2
2016-04-22 01:42:39 +00:00
_finalizeResponse(HttpRequest request, ResponseContext res) async {
Error HTML rendering
2016-05-01 01:42:52 +00:00
try {
if (!res.willCloseItself) {
res.responseData.forEach((blob) => request.response.add(blob));
await request.response.close();
Controllers should be able to handle errors themselves
2016-07-04 18:06:31 +00:00
_afterProcessed.add(request);
Error HTML rendering
2016-05-01 01:42:52 +00:00
}
} catch (e) {
// Remember: This fails silently
dev.2
2016-04-22 01:42:39 +00:00
}
}
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
String _randomString(int length) {
var rand = new Random();
var codeUnits = new List.generate(length, (index) {
return rand.nextInt(33) + 89;
});
return new String.fromCharCodes(codeUnits);
}
Almost done.
2016-04-18 03:27:23 +00:00
/// Applies an [AngelConfigurer] to this instance.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
Future configure(AngelConfigurer configurer) async {
await configurer(this);
onService, onController
2016-07-05 22:11:54 +00:00
if (configurer is Controller)
_onController.add(configurer);
Bless up
2016-02-28 13:11:17 +00:00
}
/// Starts the server.
void listen({InternetAddress address, int port: 3000}) {
runZoned(() async {
Almost done.
2016-04-18 03:27:23 +00:00
await startServer(address, port);
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
}, onError: _onError);
}
@override
@Middleware, @Hooked, .use-> services, middleware
2016-05-02 22:28:14 +00:00
use(Pattern path, Routable routable,
Hooks redesigned
2016-06-21 04:19:43 +00:00
{bool hooked: true, String middlewareNamespace: null}) {
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
if (routable is Service) {
routable.app = this;
}
Fixed more bugs with hooked services
2016-06-24 19:19:02 +00:00
return super.use(path, routable,
Need to migrate to JSON God v2, this is a breaking change
2016-06-21 20:34:31 +00:00
hooked: hooked, middlewareNamespace: middlewareNamespace);
Bless up
2016-02-28 13:11:17 +00:00
}
1.0.0-dev!
2016-06-21 22:56:04 +00:00
/// Registers a callback to run upon errors.
onError(AngelErrorHandler handler) {
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
_errorHandler = handler;
}
dev.2
2016-04-22 01:42:39 +00:00
Bless up
2016-02-28 13:11:17 +00:00
/// Handles a server error.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
_onError(e, [StackTrace stackTrace]) {
Almost done.
2016-04-18 03:27:23 +00:00
stderr.write(e.toString());
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
if (stackTrace != null) stderr.write(stackTrace.toString());
dev.2
2016-04-22 01:42:39 +00:00
}
Almost done.
2016-04-18 03:27:23 +00:00
Need to migrate to JSON God v2, this is a breaking change
2016-06-21 20:34:31 +00:00
Angel() : super() {}
Bless up
2016-02-28 13:11:17 +00:00
Almost done.
2016-04-18 03:27:23 +00:00
/// Creates an HTTPS server.
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
/// Provide paths to a certificate chain and server key (both .pem).
/// If no password is provided, a random one will be generated upon running
/// the server.
Need to migrate to JSON God v2, this is a breaking change
2016-06-21 20:34:31 +00:00
Angel.secure(String certificateChainPath, String serverKeyPath,
{String password})
: super() {
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
_serverGenerator = (InternetAddress address, int port) async {
var certificateChain =
onService, onController
2016-07-05 22:11:54 +00:00
Platform.script.resolve('server_chain.pem').toFilePath();
Angel.secure, fallback routes, 404, app.addRoute, app.all, services are a go (just missing params, i.e. $sort?), now have service.app, app.before, app.after, angel.configure now uses futures, errors are implemented
2016-04-29 00:01:58 +00:00
var serverKey = Platform.script.resolve('server_key.pem').toFilePath();
var serverContext = new SecurityContext();
serverContext.useCertificateChain(certificateChain);
serverContext.usePrivateKey(serverKey,
password: password ?? _randomString(8));
return await HttpServer.bindSecure(address, port, serverContext);
};
}
}
Reference in a new issue Copy permalink