package com.gentics.mesh.core.endpoint.navroot;

import static com.gentics.mesh.core.data.relationship.GraphPermission.READ_PUBLISHED_PERM;
import static com.gentics.mesh.core.rest.error.Errors.error;
import static com.gentics.mesh.util.URIUtils.decodeSegment;
import static io.netty.handler.codec.http.HttpResponseStatus.FORBIDDEN;
import static io.netty.handler.codec.http.HttpResponseStatus.NOT_FOUND;
import static io.netty.handler.codec.http.HttpResponseStatus.OK;

import javax.inject.Inject;

import com.gentics.mesh.context.InternalActionContext;
import com.gentics.mesh.context.impl.InternalRoutingActionContextImpl;
import com.gentics.mesh.core.data.MeshAuthUser;
import com.gentics.mesh.core.data.NodeGraphFieldContainer;
import com.gentics.mesh.core.data.node.Node;
import com.gentics.mesh.core.data.service.WebRootServiceImpl;
import com.gentics.mesh.core.verticle.handler.HandlerUtilities;
import com.gentics.mesh.path.Path;
import com.gentics.mesh.path.PathSegment;

import io.vertx.ext.web.RoutingContext;

public class NavRootHandler {

	private WebRootServiceImpl webrootService;
	private HandlerUtilities utils;

	@Inject
	public NavRootHandler(WebRootServiceImpl webRootService, HandlerUtilities utils) {
		this.webrootService = webRootService;
		this.utils = utils;
	}

	/**
	 * Handle navigation request.
	 * 
	 * @param rc
	 */
	public void handleGetPath(RoutingContext rc) {
		InternalActionContext ac = new InternalRoutingActionContextImpl(rc);
		String path = rc.request().path().substring(
			rc.mountPoint().length());
		MeshAuthUser requestUser = ac.getUser();

		utils.syncTx(ac, tx -> {
			Path nodePath = webrootService.findByProjectPath(ac, path);
			PathSegment lastSegment = nodePath.getLast();

			if (lastSegment == null) {
				throw error(NOT_FOUND, "node_not_found_for_path", decodeSegment(path));
			}
			NodeGraphFieldContainer container = lastSegment.getContainer();
			if (container == null) {
				throw error(NOT_FOUND, "node_not_found_for_path", decodeSegment(path));
			}
			Node node = container.getParentNode();
			if (!requestUser.hasPermission(node, READ_PUBLISHED_PERM)) {
				throw error(FORBIDDEN, "error_missing_perm", node.getUuid(), READ_PUBLISHED_PERM.getRestPerm().getName());
			}
			return node.transformToNavigation(ac).blockingGet();
		}, model -> ac.send(model, OK));

	}
}

@@ -2242,16 +2242,35 @@
 %09%09return
+ node;%0A%09%09%7D, node -%3E
  node.tr
@@ -2297,23 +2297,60 @@
 ac).
-blockingGet(
+subscribe(model -%3E ac.send(model, OK), ac::fail)
 );%0A
+%0A
 %09%09%7D,

Update core/src/main/java/com/gentics/mesh/core/endpoint/navroot/NavRootHandler.java