2016-10-12 17:58:32 +00:00
|
|
|
import 'extensible.dart';
|
|
|
|
import 'route.dart';
|
2016-10-19 22:04:06 +00:00
|
|
|
import 'routing_exception.dart';
|
2016-10-12 17:58:32 +00:00
|
|
|
|
|
|
|
final RegExp _straySlashes = new RegExp(r'(^/+)|(/+$)');
|
|
|
|
|
2016-10-19 22:04:06 +00:00
|
|
|
/// An abstraction over complex [Route] trees. Use this instead of the raw API. :)
|
2016-10-12 17:58:32 +00:00
|
|
|
class Router extends Extensible {
|
2016-10-21 03:13:13 +00:00
|
|
|
Route _root;
|
|
|
|
|
2016-10-19 22:04:06 +00:00
|
|
|
/// Set to `true` to print verbose debug output when interacting with this route.
|
|
|
|
bool debug = false;
|
|
|
|
|
2016-10-12 17:58:32 +00:00
|
|
|
/// Additional filters to be run on designated requests.
|
|
|
|
Map<String, dynamic> requestMiddleware = {};
|
|
|
|
|
|
|
|
/// The single [Route] that serves as the root of the hierarchy.
|
2016-10-21 03:13:13 +00:00
|
|
|
Route get root => _root;
|
2016-10-12 17:58:32 +00:00
|
|
|
|
2016-10-19 22:04:06 +00:00
|
|
|
/// Provide a `root` to make this Router revolve around a pre-defined route.
|
|
|
|
/// Not recommended.
|
2016-10-21 03:13:13 +00:00
|
|
|
Router({this.debug: false, Route root}) {
|
|
|
|
_root = (_root = root ?? new _RootRoute())..debug = debug;
|
|
|
|
}
|
2016-10-12 17:58:32 +00:00
|
|
|
|
2016-10-19 22:04:06 +00:00
|
|
|
void _printDebug(msg) {
|
2016-10-21 03:13:13 +00:00
|
|
|
if (debug) print(msg);
|
2016-10-19 22:04:06 +00:00
|
|
|
}
|
|
|
|
|
2016-10-12 17:58:32 +00:00
|
|
|
/// Adds a route that responds to the given path
|
|
|
|
/// for requests with the given method (case-insensitive).
|
|
|
|
/// Provide '*' as the method to respond to all methods.
|
|
|
|
Route addRoute(String method, Pattern path, Object handler,
|
|
|
|
{List middleware}) {
|
|
|
|
List handlers = [];
|
|
|
|
|
|
|
|
handlers
|
|
|
|
..addAll(middleware ?? [])
|
|
|
|
..add(handler);
|
|
|
|
|
2016-10-19 22:04:06 +00:00
|
|
|
if (path is RegExp) {
|
2016-10-21 03:13:13 +00:00
|
|
|
return root.child(path, debug: debug, handlers: handlers, method: method);
|
2016-10-19 22:04:06 +00:00
|
|
|
} else if (path.toString().replaceAll(_straySlashes, '').isEmpty) {
|
2016-10-21 03:13:13 +00:00
|
|
|
return root.child(path.toString(),
|
|
|
|
debug: debug, handlers: handlers, method: method);
|
2016-10-19 22:04:06 +00:00
|
|
|
} else {
|
|
|
|
var segments = path
|
|
|
|
.toString()
|
|
|
|
.split('/')
|
|
|
|
.where((str) => str.isNotEmpty)
|
|
|
|
.toList(growable: false);
|
|
|
|
Route result;
|
|
|
|
|
|
|
|
if (segments.isEmpty) {
|
2016-10-21 03:13:13 +00:00
|
|
|
return new Route('/', debug: debug, handlers: handlers, method: method)
|
|
|
|
..debug = debug;
|
2016-10-19 22:04:06 +00:00
|
|
|
} else {
|
2016-10-22 18:39:23 +00:00
|
|
|
result = resolve(segments[0], (route) => route.method == method || route.method == '*');
|
2016-10-19 22:04:06 +00:00
|
|
|
|
|
|
|
if (result != null) {
|
|
|
|
if (segments.length > 1) {
|
|
|
|
_printDebug('Resolved: ${result} for "${segments[0]}"');
|
|
|
|
segments = segments.skip(1).toList(growable: false);
|
|
|
|
|
|
|
|
Route existing;
|
|
|
|
|
|
|
|
do {
|
2016-10-22 18:39:23 +00:00
|
|
|
existing = result.resolve(segments[0], filter: (route) => route.method == method || route.method == '*');
|
2016-10-19 22:04:06 +00:00
|
|
|
|
|
|
|
if (existing != null) {
|
|
|
|
result = existing;
|
|
|
|
}
|
|
|
|
} while (existing != null);
|
2016-10-21 03:13:13 +00:00
|
|
|
} else
|
|
|
|
throw new RoutingException(
|
|
|
|
"Cannot overwrite existing route '${segments[0]}'.");
|
2016-10-19 22:04:06 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
for (int i = 0; i < segments.length; i++) {
|
|
|
|
final segment = segments[i];
|
|
|
|
|
|
|
|
if (i == segments.length - 1) {
|
|
|
|
if (result == null) {
|
2016-10-21 03:13:13 +00:00
|
|
|
result = root.child(segment,
|
|
|
|
debug: debug, handlers: handlers, method: method);
|
2016-10-19 22:04:06 +00:00
|
|
|
} else {
|
2016-10-21 03:13:13 +00:00
|
|
|
result = result.child(segment,
|
|
|
|
debug: debug, handlers: handlers, method: method);
|
2016-10-19 22:04:06 +00:00
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if (result == null) {
|
2016-10-21 03:13:13 +00:00
|
|
|
result = root.child(segment, debug: debug, method: "*");
|
2016-10-19 22:04:06 +00:00
|
|
|
} else {
|
2016-10-21 03:13:13 +00:00
|
|
|
result = result.child(segment, debug: debug, method: "*");
|
2016-10-19 22:04:06 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-10-20 09:21:59 +00:00
|
|
|
return result..debug = debug;
|
2016-10-19 22:04:06 +00:00
|
|
|
}
|
2016-10-12 17:58:32 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/// Creates a visual representation of the route hierarchy and
|
|
|
|
/// passes it to a callback. If none is provided, `print` is called.
|
|
|
|
void dumpTree(
|
|
|
|
{callback(String tree), header: 'Dumping route tree:', tab: ' '}) {
|
|
|
|
var tabs = 0;
|
|
|
|
final buf = new StringBuffer();
|
|
|
|
|
|
|
|
void dumpRoute(Route route, {String replace: null}) {
|
|
|
|
for (var i = 0; i < tabs; i++) buf.write(tab);
|
2016-10-20 09:21:59 +00:00
|
|
|
|
|
|
|
if (route == root)
|
|
|
|
buf.write('(root) ${route.method} ');
|
2016-10-21 03:13:13 +00:00
|
|
|
else
|
|
|
|
buf.write('- ${route.method} ');
|
2016-10-12 17:58:32 +00:00
|
|
|
|
|
|
|
final p =
|
|
|
|
replace != null ? route.path.replaceAll(replace, '') : route.path;
|
|
|
|
|
|
|
|
if (p.isEmpty)
|
|
|
|
buf.write("'/'");
|
|
|
|
else
|
|
|
|
buf.write("'${p.replaceAll(_straySlashes, '')}'");
|
|
|
|
|
|
|
|
if (route.handlers.isNotEmpty)
|
2016-10-19 22:04:06 +00:00
|
|
|
buf.writeln(' => ${route.handlers.length} handler(s)');
|
2016-10-12 17:58:32 +00:00
|
|
|
else
|
|
|
|
buf.writeln();
|
|
|
|
|
|
|
|
tabs++;
|
|
|
|
route.children.forEach((r) => dumpRoute(r, replace: route.path));
|
|
|
|
tabs--;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (header != null && header.isNotEmpty) buf.writeln(header);
|
|
|
|
|
|
|
|
dumpRoute(root);
|
2016-10-19 22:04:06 +00:00
|
|
|
(callback ?? print)(buf.toString());
|
2016-10-12 17:58:32 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/// Creates a route, and allows you to add child routes to it
|
|
|
|
/// via a [Router] instance.
|
|
|
|
///
|
|
|
|
/// Returns the created route.
|
|
|
|
/// You can also register middleware within the router.
|
|
|
|
Route group(Pattern path, void callback(Router router),
|
|
|
|
{Iterable middleware: const [],
|
|
|
|
String method: "*",
|
|
|
|
String name: null,
|
|
|
|
String namespace: null}) {
|
|
|
|
final route =
|
|
|
|
root.child(path, handlers: middleware, method: method, name: name);
|
2016-10-21 03:13:13 +00:00
|
|
|
final router = new Router(root: route);
|
2016-10-12 17:58:32 +00:00
|
|
|
callback(router);
|
|
|
|
|
|
|
|
// Let's copy middleware, heeding the optional middleware namespace.
|
|
|
|
String middlewarePrefix = namespace != null ? "$namespace." : "";
|
|
|
|
|
|
|
|
Map copiedMiddleware = new Map.from(router.requestMiddleware);
|
|
|
|
for (String middlewareName in copiedMiddleware.keys) {
|
|
|
|
requestMiddleware["$middlewarePrefix$middlewareName"] =
|
|
|
|
copiedMiddleware[middlewareName];
|
|
|
|
}
|
|
|
|
|
|
|
|
return route;
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Assigns a middleware to a name for convenience.
|
|
|
|
registerMiddleware(String name, middleware) {
|
|
|
|
requestMiddleware[name] = middleware;
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Finds the first [Route] that matches the given path.
|
|
|
|
///
|
|
|
|
/// You can pass an additional filter to determine which
|
|
|
|
/// routes count as matches.
|
|
|
|
Route resolve(String path, [bool filter(Route route)]) =>
|
2016-10-15 00:45:22 +00:00
|
|
|
root.resolve(path, filter: filter);
|
2016-10-12 17:58:32 +00:00
|
|
|
|
|
|
|
/// Incorporates another [Router]'s routes into this one's.
|
|
|
|
///
|
|
|
|
/// If `hooked` is set to `true` and a [Service] is provided,
|
|
|
|
/// then that service will be wired to a [HookedService] proxy.
|
|
|
|
/// If a `namespace` is provided, then any middleware
|
|
|
|
/// from the provided [Router] will be prefixed by that namespace,
|
|
|
|
/// with a dot.
|
|
|
|
/// For example, if the [Router] has a middleware 'y', and the `namespace`
|
|
|
|
/// is 'x', then that middleware will be available as 'x.y' in the main router.
|
|
|
|
/// These namespaces can be nested.
|
2016-10-22 15:21:04 +00:00
|
|
|
void mount(Pattern path, Router router,
|
2016-10-12 17:58:32 +00:00
|
|
|
{bool hooked: true, String namespace: null}) {
|
|
|
|
// Let's copy middleware, heeding the optional middleware namespace.
|
|
|
|
String middlewarePrefix = namespace != null ? "$namespace." : "";
|
|
|
|
|
|
|
|
Map copiedMiddleware = new Map.from(router.requestMiddleware);
|
|
|
|
for (String middlewareName in copiedMiddleware.keys) {
|
|
|
|
requestMiddleware["$middlewarePrefix$middlewareName"] =
|
|
|
|
copiedMiddleware[middlewareName];
|
|
|
|
}
|
|
|
|
|
2016-10-21 03:13:13 +00:00
|
|
|
root.child(path, debug: debug).addChild(router.root);
|
2016-10-12 17:58:32 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to any request matching the given path.
|
|
|
|
Route all(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('*', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a DELETE request.
|
|
|
|
Route delete(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('DELETE', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a GET request.
|
|
|
|
Route get(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('GET', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a HEAD request.
|
|
|
|
Route head(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('HEAD', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a OPTIONS request.
|
|
|
|
Route options(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('OPTIONS', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a POST request.
|
|
|
|
Route post(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('POST', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a PATCH request.
|
|
|
|
Route patch(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('PATCH', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Adds a route that responds to a PUT request.
|
|
|
|
Route put(Pattern path, Object handler, {List middleware}) {
|
|
|
|
return addRoute('PUT', path, handler, middleware: middleware);
|
|
|
|
}
|
|
|
|
}
|
2016-10-20 09:21:59 +00:00
|
|
|
|
|
|
|
class _RootRoute extends Route {
|
2016-10-21 03:13:13 +00:00
|
|
|
_RootRoute() : super("/", name: "<root>");
|
2016-10-20 09:21:59 +00:00
|
|
|
|
|
|
|
@override
|
|
|
|
String toString() => "ROOT";
|
2016-10-21 03:13:13 +00:00
|
|
|
}
|