view src/luan/modules/http/HttpServicer.java @ 1263:382c444a6c77

add Http.eval_in_root and Http.handle_error
author Franklin Schmidt <fschmidt@gmail.com>
date Mon, 24 Sep 2018 22:06:25 -0600
parents c147e2e877e3
children 3f4644246e39
line wrap: on
line source

package luan.modules.http;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import luan.webserver.Request;
import luan.webserver.Response;
import luan.webserver.Status;
import luan.LuanState;
import luan.LuanFunction;
import luan.LuanException;
import luan.LuanTable;
import luan.LuanCloner;
import luan.modules.PackageLuan;


public final class HttpServicer {
	private static final Logger logger = LoggerFactory.getLogger(HttpServicer.class);

	public static Response service(LuanState luan,Request request,String modName) {
		try {
			return serviceLuan(luan,request,modName);
		} catch(LuanException e) {
			return handleError(luan,request,e);
		}
	}

	private static Response handleError(LuanState luan,Request request,LuanException e) {
//e.printStackTrace();
/*
		String err = e.getLuanStackTraceString();
		logger.error(err+"\n"+request.rawHead.trim()+"\n");
		String msg = "Internel Server Error\n\n" + err;
		return Response.errorResponse( Status.INTERNAL_SERVER_ERROR, msg );
*/
		synchronized(luan) {
			LuanCloner cloner = new LuanCloner(LuanCloner.Type.INCREMENTAL);
			luan = (LuanState)cloner.clone(luan);
		}
		try {
			LuanTable module = (LuanTable)PackageLuan.require(luan,"luan:http/Http.luan");
			LuanFunction fn = (LuanFunction)module.rawGet("handle_error");
			return (Response)fn.call( luan, new Object[]{request,e.table()} );
		} catch(LuanException e2) {
			throw new RuntimeException(e2);
		}
	}

	private static Response serviceLuan(LuanState luan,Request request,String modName)
		throws LuanException
	{
		LuanFunction fn;
		synchronized(luan) {
			PackageLuan.enableLoad(luan,"luan:http/Http.luan",modName);
			PackageLuan.require(luan,"luan:http/Http.luan");
			Object mod = PackageLuan.load(luan,modName);
			if( mod.equals(Boolean.FALSE) )
				return null;
			if( !(mod instanceof LuanFunction) )
				throw new LuanException( "module '"+modName+"' must return a function" );
			LuanCloner cloner = new LuanCloner(LuanCloner.Type.INCREMENTAL);
			luan = (LuanState)cloner.clone(luan);
			fn = (LuanFunction)cloner.get(mod);
		}

		LuanTable module = (LuanTable)PackageLuan.require(luan,"luan:http/Http.luan");

		// request
		LuanFunction newRequestFn = (LuanFunction)module.rawGet("new_request");
		newRequestFn.call( luan, new Object[]{request} );

		// response
		LuanFunction newResponseFn = (LuanFunction)module.rawGet("new_response");
		newResponseFn.call(luan);

		fn.call(luan);

		LuanFunction finishFn = (LuanFunction)module.rawGet("finish");
		Response response = (Response)finishFn.call(luan);
		return response;
	}

	private HttpServicer() {}  // never
}