view src/luan/modules/http/HttpServicer.java @ 1265:3f4644246e39

LuanHandler cleanup and add Server.serve_for_proxy
author Franklin Schmidt <fschmidt@gmail.com>
date Tue, 25 Sep 2018 19:51:34 -0600
parents 382c444a6c77
children 9fa8b8389578
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.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)
		throws LuanException
	{
		try {
			return serviceLuan(luan,request,modName);
		} catch(LuanException e) {
			return handleError(luan,request,e);
		}
	}

	private static Response handleError(LuanState luan,Request request,LuanException e)
		throws LuanException
	{
//e.printStackTrace();
		synchronized(luan) {
			LuanCloner cloner = new LuanCloner(LuanCloner.Type.INCREMENTAL);
			luan = (LuanState)cloner.clone(luan);
		}
		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()} );
	}

	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
}