Added event-driven server.

[jagi.git] / src / jagi / scgi / Jagi.java

package jagi.scgi;

import jagi.*;
import java.util.*;
import java.io.*;
import java.nio.*;
import java.nio.channels.*;
import java.nio.charset.*;

public class Jagi {
    public static void decodehead(Map<? super String, ? super String> into, Map<ByteBuffer, ByteBuffer> head, Charset coding) throws CharacterCodingException {
	for(Map.Entry<ByteBuffer, ByteBuffer> h : head.entrySet())
	    into.put(coding.newDecoder().decode(h.getKey()).toString(), coding.decode(h.getValue()).toString());
    }

    public static Map<Object, Object> mkenv(Map<ByteBuffer, ByteBuffer> rawhead, ReadableByteChannel input) throws IOException {
	Map<Object, Object> env;
	try {
	    env = new HashMap<>();
	    decodehead(env, rawhead, Utils.UTF8);
	    env.put("jagi.uri_encoding", "utf-8");
	} catch(CharacterCodingException e) {
	    env = new HashMap<>();
	    decodehead(env, rawhead, Utils.LATIN1);
	    env.put("jagi.uri_encoding", "latin-1");
	}
	env.put("jagi.version.major", 1);
	env.put("jagi.version.minor", 0);
	if(env.containsKey("HTTP_X_ASH_PROTOCOL"))
	    env.put("jagi.url_scheme", env.get("HTTP_X_ASH_PROTOCOL"));
	else if(env.containsKey("HTTPS"))
	    env.put("jagi.url_scheme", "https");
	else
	    env.put("jagi.url_scheme", "http");
	env.put("jagi.input", input);
	env.put("jagi.errors", System.err);
	env.put("jagi.multithread", true);
	env.put("jagi.multiprocess", false);
	env.put("jagi.run_once", false);
	env.put("jagi.cleanup", new HashSet<>());
	return(env);
    }

    public static Map<Object, Object> mkenv(ReadableByteChannel sk) throws IOException {
	return(mkenv(Scgi.readhead(sk), sk));
    }
}