package luan.modules;

import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintStream;
import java.io.Reader;
import java.io.Writer;
import java.io.StringReader;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.StringWriter;
import java.io.IOException;
import java.io.FileNotFoundException;
import java.net.URL;
import java.net.Socket;
import java.net.ServerSocket;
import java.net.InetAddress;
import java.net.Inet4Address;
import java.net.NetworkInterface;
import java.net.MalformedURLException;
import java.net.UnknownHostException;
import java.util.Enumeration;
import java.util.List;
import java.util.Map;
import luan.Luan;
import luan.LuanState;
import luan.LuanTable;
import luan.LuanFunction;
import luan.LuanJavaFunction;
import luan.LuanException;
import luan.modules.url.LuanUrl;


public final class IoLuan {

	private static void add(LuanTable t,String method,Class... parameterTypes) throws NoSuchMethodException {
		t.rawPut( method, new LuanJavaFunction(IoLuan.class.getMethod(method,parameterTypes),null) );
	}

	public static String read_console_line(String prompt) throws IOException {
		if( prompt==null )
			prompt = "> ";
		return System.console().readLine(prompt);
	}


	public interface LuanWriter {
		public Object out();
		public void write(LuanState luan,Object... args) throws LuanException, IOException;
		public void close() throws IOException;
	}

	private static LuanWriter luanWriter(final PrintStream out) {
		return new LuanWriter() {

			public Object out() {
				return out;
			}

			public void write(LuanState luan,Object... args) throws LuanException {
				for( Object obj : args ) {
					out.print( luan.toString(obj) );
				}
			}

			public void close() {
				out.close();
			}
		};
	}

	public static LuanTable textWriter(LuanState luan,final PrintStream out) {
		return writer(luan,luanWriter(out));
	}

	private static LuanWriter luanWriter(final Writer out) {
		return new LuanWriter() {

			public Object out() {
				return out;
			}

			public void write(LuanState luan,Object... args) throws LuanException, IOException {
				for( Object obj : args ) {
					out.write( luan.toString(obj) );
				}
			}

			public void close() throws IOException {
				out.close();
			}
		};
	}

	public static LuanTable textWriter(LuanState luan,final Writer out) {
		return writer(luan,luanWriter(out));
	}

	private static LuanTable writer(LuanState luan,LuanWriter luanWriter) {
		LuanTable writer = new LuanTable(luan);
		writer.rawPut( "java", luanWriter.out() );
		try {
			writer.rawPut( "write", new LuanJavaFunction(
				LuanWriter.class.getMethod( "write", LuanState.class, new Object[0].getClass() ), luanWriter
			) );
			writer.rawPut( "close", new LuanJavaFunction(
				LuanWriter.class.getMethod( "close" ), luanWriter
			) );
		} catch(NoSuchMethodException e) {
			throw new RuntimeException(e);
		}
		return writer;
	}


	public static LuanTable binaryWriter(LuanState luan,final OutputStream out) {
		LuanTable writer = new LuanTable(luan);
		writer.rawPut( "java", out );
		try {
			writer.rawPut( "write", new LuanJavaFunction(
				OutputStream.class.getMethod( "write", new byte[0].getClass() ), out
			) );
			writer.rawPut( "close", new LuanJavaFunction(
				OutputStream.class.getMethod( "close" ), out
			) );
		} catch(NoSuchMethodException e) {
			throw new RuntimeException(e);
		}
		return writer;
	}

	static LuanFunction lines(final BufferedReader in) {
		return new LuanFunction() {
			@Override public Object call(LuanState luan,Object[] args) throws LuanException {
				try {
					if( args.length > 0 ) {
						if( args.length > 1 || !"close".equals(args[0]) )
							throw new LuanException( "the only argument allowed is 'close'" );
						in.close();
						return null;
					}
					String rtn = in.readLine();
					if( rtn==null )
						in.close();
					return rtn;
				} catch(IOException e) {
					throw new LuanException(e);
				}
			}
		};
	}

	static LuanFunction blocks(final InputStream in,final int blockSize) {
		return new LuanFunction() {
			final byte[] a = new byte[blockSize];

			@Override public Object call(LuanState luan,Object[] args) throws LuanException {
				try {
					if( args.length > 0 ) {
						if( args.length > 1 || !"close".equals(args[0]) )
							throw new LuanException( "the only argument allowed is 'close'" );
						in.close();
						return null;
					}
					if( in.read(a) == -1 ) {
						in.close();
						return null;
					}
					return a;
				} catch(IOException e) {
					throw new LuanException(e);
				}
			}
		};
	}


	private static File objToFile(Object obj) {
		if( obj instanceof String ) {
			return new File((String)obj);
		}
		if( obj instanceof LuanTable ) {
			LuanTable t = (LuanTable)obj;
			Object java = t.rawGet("java");
			if( java instanceof LuanFile ) {
				LuanFile luanFile = (LuanFile)java;
				return luanFile.file;
			}
		}
		return null;
	}


	public static abstract class LuanIn {
		public abstract InputStream inputStream(LuanState luan) throws IOException, LuanException;
		public abstract String to_string();
		public abstract String to_uri_string();

		public Reader reader(LuanState luan) throws IOException, LuanException {
			return new InputStreamReader(inputStream(luan));
		}

		public String read_text(LuanState luan) throws IOException, LuanException {
			Reader in = reader(luan);
			String s = Utils.readAll(in);
			in.close();
			return s;
		}

		public byte[] read_binary(LuanState luan) throws IOException, LuanException {
			InputStream in = inputStream(luan);
			byte[] a = Utils.readAll(in);
			in.close();
			return a;
		}

		public LuanFunction read_lines(LuanState luan) throws IOException, LuanException {
			return lines(new BufferedReader(reader(luan)));
		}

		public LuanFunction read_blocks(LuanState luan,Integer blockSize) throws IOException, LuanException {
			int n = blockSize!=null ? blockSize : Utils.bufSize;
			return blocks(inputStream(luan),n);
		}

		public boolean exists(LuanState luan) throws IOException, LuanException {
			try {
				inputStream(luan).close();
				return true;
			} catch(FileNotFoundException e) {
				return false;
			} catch(UnknownHostException e) {
				return false;
			}
		}

		public long checksum(LuanState luan) throws IOException, LuanException {
			long cs = 0;
			InputStream in = new BufferedInputStream(inputStream(luan));
			int c;
			while( (c=in.read()) != -1 ) {
				cs = 31 * cs + c;
			}
			in.close();
			return cs;
		}

		public LuanTable table(LuanState luan) {
			LuanTable tbl = new LuanTable(luan);
			try {
				tbl.rawPut( "java", this );
				tbl.rawPut( "to_string", new LuanJavaFunction(
					LuanIn.class.getMethod( "to_string" ), this
				) );
				tbl.rawPut( "to_uri_string", new LuanJavaFunction(
					LuanIn.class.getMethod( "to_uri_string" ), this
				) );
				tbl.rawPut( "read_text", new LuanJavaFunction(
					LuanIn.class.getMethod( "read_text", LuanState.class ), this
				) );
				tbl.rawPut( "read_binary", new LuanJavaFunction(
					LuanIn.class.getMethod( "read_binary", LuanState.class ), this
				) );
				tbl.rawPut( "read_lines", new LuanJavaFunction(
					LuanIn.class.getMethod( "read_lines", LuanState.class ), this
				) );
				tbl.rawPut( "read_blocks", new LuanJavaFunction(
					LuanIn.class.getMethod( "read_blocks", LuanState.class, Integer.class ), this
				) );
				tbl.rawPut( "exists", new LuanJavaFunction(
					LuanIn.class.getMethod( "exists", LuanState.class ), this
				) );
				tbl.rawPut( "checksum", new LuanJavaFunction(
					LuanIn.class.getMethod( "checksum", LuanState.class ), this
				) );
			} catch(NoSuchMethodException e) {
				throw new RuntimeException(e);
			}
			return tbl;
		}
	}

	public static final LuanIn defaultStdin = new LuanIn() {

		@Override public InputStream inputStream(LuanState luan) {
			return System.in;
		}

		@Override public String to_string() {
			return "<stdin>";
		}

		@Override public String to_uri_string() {
			return "stdin:";
		}

		@Override public String read_text(LuanState luan) throws IOException {
			return Utils.readAll(new InputStreamReader(System.in));
		}

		@Override public byte[] read_binary(LuanState luan) throws IOException {
			return Utils.readAll(System.in);
		}

		@Override public boolean exists(LuanState luan) {
			return true;
		}
	};

	public static abstract class LuanIO extends LuanIn {
		abstract OutputStream outputStream() throws IOException;

		public void write(LuanState luan,Object obj) throws LuanException, IOException {
			if( obj instanceof String ) {
				String s = (String)obj;
				Writer out = new OutputStreamWriter(outputStream());
				out.write(s);
				out.close();
				return;
			}
			if( obj instanceof byte[] ) {
				byte[] a = (byte[])obj;
				OutputStream out = outputStream();
				Utils.copyAll(new ByteArrayInputStream(a),out);
				out.close();
				return;
			}
			if( obj instanceof LuanTable ) {
				LuanTable t = (LuanTable)obj;
				Object java = t.rawGet("java");
				if( java instanceof LuanIn ) {
					LuanIn luanIn = (LuanIn)java;
					InputStream in = luanIn.inputStream(luan);
					OutputStream out = outputStream();
					Utils.copyAll(in,out);
					out.close();
					in.close();
					return;
				}
			}
			throw new LuanException( "bad argument #1 to 'write' (string or binary or Io.uri expected)" );
		}

		public LuanTable text_writer(LuanState luan) throws IOException {
			return textWriter(luan,new BufferedWriter(new OutputStreamWriter(outputStream())));
		}

		public LuanTable binary_writer(LuanState luan) throws IOException {
			return binaryWriter(luan,new BufferedOutputStream(outputStream()));
		}

		public void write_text(LuanState luan,Object... args) throws LuanException, IOException {
			LuanWriter luanWriter = luanWriter(new BufferedWriter(new OutputStreamWriter(outputStream())));
			luanWriter.write(luan,args);
			luanWriter.close();
		}

		@Override public LuanTable table(LuanState luan) {
			LuanTable tbl = super.table(luan);
			try {
				tbl.rawPut( "write", new LuanJavaFunction(
					LuanIO.class.getMethod( "write", LuanState.class, Object.class ), this
				) );
				tbl.rawPut( "text_writer", new LuanJavaFunction(
					LuanIO.class.getMethod( "text_writer", LuanState.class ), this
				) );
				tbl.rawPut( "binary_writer", new LuanJavaFunction(
					LuanIO.class.getMethod( "binary_writer", LuanState.class ), this
				) );
				tbl.rawPut( "write_text", new LuanJavaFunction(
					LuanIO.class.getMethod( "write_text", LuanState.class, new Object[0].getClass() ), this
				) );
			} catch(NoSuchMethodException e) {
				throw new RuntimeException(e);
			}
			return tbl;
		}
	}

	private static final LuanIO nullIO = new LuanIO() {
		private final InputStream in = new InputStream() {
			@Override public int read() {
				return -1;
			}
		};
		private final OutputStream out = new OutputStream() {
			@Override public void write(int b) {}
		};

		@Override public InputStream inputStream(LuanState luan) {
			return in;
		}

		@Override OutputStream outputStream() {
			return out;
		}

		@Override public String to_string() {
			return "<null>";
		}

		@Override public String to_uri_string() {
			return "null:";
		}

	};

	public static final class LuanString extends LuanIO {
		private String s;

		private LuanString(String s) {
			this.s = s;
		}

		@Override public InputStream inputStream(LuanState luan) {
			throw new UnsupportedOperationException();
		}

		@Override OutputStream outputStream() {
			throw new UnsupportedOperationException();
		}

		@Override public String to_string() {
			return "<string>";
		}

		@Override public String to_uri_string() {
			return "string:" + s;
		}

		@Override public Reader reader(LuanState luan) {
			return new StringReader(s);
		}

		@Override public String read_text(LuanState luan) {
			return s;
		}

		@Override public boolean exists(LuanState luan) {
			return true;
		}

		@Override public LuanTable text_writer(LuanState luan) throws IOException {
			LuanWriter luanWriter = new LuanWriter() {
				private final Writer out = new StringWriter();

				public Object out() {
					return out;
				}
	
				public void write(LuanState luan,Object... args) throws LuanException, IOException {
					for( Object obj : args ) {
						out.write( luan.toString(obj) );
					}
				}
	
				public void close() throws IOException {
					s = out.toString();
				}
			};
			return writer(luan,luanWriter);
		}
	}

	public static final class LuanFile extends LuanIO {
		public final File file;

		private LuanFile(LuanState luan,File file) throws LuanException {
			this(file);
			check(luan,"file:"+file.toString());
		}

		private LuanFile(File file) {
			this.file = file;
		}

		@Override public InputStream inputStream(LuanState luan) throws IOException {
			return new FileInputStream(file);
		}

		@Override OutputStream outputStream() throws IOException {
			return new FileOutputStream(file);
		}

		@Override public String to_string() {
			return file.toString();
		}

		@Override public String to_uri_string() {
			return "file:" + file.toString();
		}

		public LuanTable child(LuanState luan,String name) throws LuanException {
			return new LuanFile(luan,new File(file,name)).table(luan);
		}

		public LuanTable children(LuanState luan) throws LuanException {
			File[] files = file.listFiles();
			if( files==null )
				return null;
			LuanTable list = new LuanTable(luan);
			for( File f : files ) {
				list.rawPut(list.rawLength()+1,new LuanFile(luan,f).table(luan));
			}
			return list;
		}

		public LuanTable parent(LuanState luan) throws LuanException, IOException {
			File parent = file.getParentFile();
			if( parent==null )
				parent = file.getCanonicalFile().getParentFile();
			return new LuanFile(luan,parent).table(luan);
		}

		@Override public boolean exists(LuanState luan) {
			return file.exists();
		}

		public void rename_to(Object destObj) throws LuanException {
			File dest = objToFile(destObj);
			if( dest==null )
				throw new LuanException( "bad argument #1 to 'objToFile' (string or file table expected)" );
			if( !file.renameTo(dest) )
				throw new LuanException("couldn't rename file "+file+" to "+dest);
		}

		public LuanTable canonical(LuanState luan) throws LuanException, IOException {
			return new LuanFile(luan,file.getCanonicalFile()).table(luan);
		}

		public LuanTable create_temp_file(LuanState luan,String prefix,String suffix) throws LuanException, IOException {
			File tmp = File.createTempFile(prefix,suffix,file);
			return new LuanFile(luan,tmp).table(luan);
		}

		public void delete() throws LuanException {
			if( file.exists() )
				delete(file);
		}

		private static void delete(File file) throws LuanException {
			File[] children = file.listFiles();
			if( children != null ) {
				for( File child : children ) {
					delete(child);
				}
			}
			if( !file.delete() )
				throw new LuanException("couldn't delete file "+file);
		}

		public void mkdir() throws LuanException {
			if( !file.isDirectory() ) {
				if( !file.mkdirs() )
					throw new LuanException("couldn't make directory "+file);
			}
		}

		public void set_last_modified(long time) throws LuanException {
			if( !file.setLastModified(time) )
				throw new LuanException("couldn't set_last_modified on "+file);
		}

		@Override public LuanTable table(LuanState luan) {
			LuanTable tbl = super.table(luan);
			try {
				tbl.rawPut( "name", new LuanJavaFunction(
					File.class.getMethod( "getName" ), file
				) );
				tbl.rawPut( "is_directory", new LuanJavaFunction(
					File.class.getMethod( "isDirectory" ), file
				) );
				tbl.rawPut( "is_file", new LuanJavaFunction(
					File.class.getMethod( "isFile" ), file
				) );
				tbl.rawPut( "delete", new LuanJavaFunction(
					LuanFile.class.getMethod( "delete" ), this
				) );
				tbl.rawPut( "delete_on_exit", new LuanJavaFunction(
					File.class.getMethod( "deleteOnExit" ), file
				) );
				tbl.rawPut( "mkdir", new LuanJavaFunction(
					LuanFile.class.getMethod( "mkdir" ), this
				) );
				tbl.rawPut( "last_modified", new LuanJavaFunction(
					File.class.getMethod( "lastModified" ), file
				) );
				tbl.rawPut( "set_last_modified", new LuanJavaFunction(
					LuanFile.class.getMethod( "set_last_modified", Long.TYPE ), this
				) );
				tbl.rawPut( "length", new LuanJavaFunction(
					File.class.getMethod( "length" ), file
				) );
				tbl.rawPut( "child", new LuanJavaFunction(
					LuanFile.class.getMethod( "child", LuanState.class, String.class ), this
				) );
				tbl.rawPut( "children", new LuanJavaFunction(
					LuanFile.class.getMethod( "children", LuanState.class ), this
				) );
				tbl.rawPut( "parent", new LuanJavaFunction(
					LuanFile.class.getMethod( "parent", LuanState.class ), this
				) );
				tbl.rawPut( "rename_to", new LuanJavaFunction(
					LuanFile.class.getMethod( "rename_to", Object.class ), this
				) );
				tbl.rawPut( "canonical", new LuanJavaFunction(
					LuanFile.class.getMethod( "canonical", LuanState.class ), this
				) );
				tbl.rawPut( "create_temp_file", new LuanJavaFunction(
					LuanFile.class.getMethod( "create_temp_file", LuanState.class, String.class, String.class ), this
				) );
			} catch(NoSuchMethodException e) {
				throw new RuntimeException(e);
			}
			return tbl;
		}
	}

	public static LuanTable null_(LuanState luan,String ignore) {
		return nullIO.table(luan);
	}

	public static LuanTable string(LuanState luan,String s) throws LuanException {
		Utils.checkNotNull(s);
		return new LuanString(s).table(luan);
	}

	public static LuanTable file(LuanState luan,String name) throws LuanException {
		File file = new File(name);
		return new LuanFile(luan,file).table(luan);
	}

	public static LuanTable classpath(LuanState luan,String name) throws LuanException {
		if( name.contains("//") )
			return null;
		String path = name;
		check(luan,"classpath:"+path);
		URL url;
		if( !path.contains("#") ) {
			url = ClassLoader.getSystemResource(path);
		} else {
			String[] a = path.split("#");
			url = ClassLoader.getSystemResource(a[0]);
			if( url==null ) {
				for( int i=1; i<a.length; i++ ) {
					url = ClassLoader.getSystemResource(a[0]+"/"+a[i]);
					if( url != null ) {
						try {
							url = new URL(url,".");
						} catch(MalformedURLException e) {
							throw new RuntimeException(e);
						}
						break;
					}
				}
			}
		}
		if( url != null )
			return new LuanUrl(url,null).table(luan);

		return null;
	}

	private static LuanTable url(LuanState luan,String url,LuanTable options) throws IOException, LuanException {
		return new LuanUrl(new URL(url),options).table(luan);
	}

	public static LuanTable http(LuanState luan,String path,LuanTable options) throws IOException, LuanException {
		return url(luan,"http:"+path,options);
	}

	public static LuanTable https(LuanState luan,String path,LuanTable options) throws IOException, LuanException {
		return url(luan,"https:"+path,options);
	}

	public static LuanTable luan(LuanState luan,String path) throws LuanException {
		return classpath( luan, "luan/modules/" + path );
	}

	public static LuanTable stdin(LuanState luan) throws LuanException {
		LuanTable io = (LuanTable)PackageLuan.require(luan,"luan:Io.luan");
		return (LuanTable)io.get("stdin");
	}

	public static LuanTable newSchemes(LuanState luan) {
		LuanTable schemes = new LuanTable(luan);
		try {
			schemes.rawPut( "null", new LuanJavaFunction(IoLuan.class.getMethod("null_",LuanState.class,String.class),null) );
			add( schemes, "string", LuanState.class, String.class );
			add( schemes, "file", LuanState.class, String.class );
			add( schemes, "classpath", LuanState.class, String.class );
//			add( schemes, "socket", String.class );
			add( schemes, "http", LuanState.class, String.class, LuanTable.class );
			add( schemes, "https", LuanState.class, String.class, LuanTable.class );
			add( schemes, "luan", LuanState.class, String.class );
			add( schemes, "stdin", LuanState.class );
			add( schemes, "os", LuanState.class, String.class, LuanTable.class );
			add( schemes, "bash", LuanState.class, String.class, LuanTable.class );
		} catch(NoSuchMethodException e) {
			throw new RuntimeException(e);
		}
		return schemes;
	}

	private static LuanTable schemes(LuanState luan) throws LuanException {
		LuanTable t = (LuanTable)PackageLuan.loaded(luan).rawGet("luan:Io.luan");
		if( t == null )
			return newSchemes(luan);
		t = (LuanTable)t.get("schemes");
		if( t == null )
			return newSchemes(luan);
		return t;
	}

	public static LuanTable uri(LuanState luan,String name,LuanTable options) throws LuanException {
		int i = name.indexOf(':');
		if( i == -1 )
			throw new LuanException( "invalid Io.uri name '"+name+"', missing scheme" );
		String scheme = name.substring(0,i);
		String location = name.substring(i+1);
		LuanTable schemes = schemes(luan);
		LuanFunction opener = (LuanFunction)schemes.get(scheme);
		if( opener == null )
			throw new LuanException( "invalid scheme '"+scheme+"' in '"+name+"'" );
		return (LuanTable)Luan.first(opener.call(luan,new Object[]{location,options}));
	}
/*
	public static final class LuanSocket extends LuanIO {
		public final Socket socket;

		private LuanSocket(String host,int port) throws LuanException {
			try {
				this.socket = new Socket(host,port);
			} catch(IOException e) {
				throw new LuanException(e.toString());
			}
		}

		private LuanSocket(Socket socket) {
			this.socket = socket;
		}

		@Override public InputStream inputStream() throws IOException {
			return socket.getInputStream();
		}

		@Override OutputStream outputStream() throws IOException {
			return socket.getOutputStream();
		}

		@Override public String to_string() {
			return socket.toString();
		}

		@Override public String to_uri_string() {
			throw new UnsupportedOperationException();
		}
	}

	public static LuanTable socket(String name) throws LuanException, IOException {
		int i = name.indexOf(':');
		if( i == -1 )
			throw new LuanException( "invalid socket '"+name+"', format is: <host>:<port>" );
		String host = name.substring(0,i);
		String portStr = name.substring(i+1);
		int port = Integer.parseInt(portStr);
		return new LuanSocket(host,port).table();
	}

	public static LuanFunction socket_server(int port) throws IOException {
		final ServerSocket ss = new ServerSocket(port);
		return new LuanFunction() {
			@Override public Object call(LuanState luan,Object[] args) throws LuanException {
				try {
					if( args.length > 0 ) {
						if( args.length > 1 || !"close".equals(args[0]) )
							throw new LuanException( "the only argument allowed is 'close'" );
						ss.close();
						return null;
					}
					return new LuanSocket(ss.accept()).table();
				} catch(IOException e) {
					throw new LuanException(e);
				}
			}
		};
	}
*/

	public static class BaseOs extends LuanIO {
		private final String cmd;
		final File dir;
		Process proc;

		private BaseOs(String cmd,LuanTable options) throws IOException, LuanException {
			this.cmd = cmd;
			File dir = null;
			if( options != null ) {
				Map map = options.asMap();
				Object obj = map.remove("dir");
				dir = objToFile(obj);
				if( dir==null )
					throw new LuanException( "bad option 'dir' (string or file table expected)" );
				if( !map.isEmpty() )
					throw new LuanException( "unrecognized options: "+map );
			}
			this.dir = dir;
		}

		@Override public InputStream inputStream(LuanState luan) throws IOException {
			return proc.getInputStream();
		}

		@Override OutputStream outputStream() throws IOException {
			return proc.getOutputStream();
		}

		@Override public String to_string() {
			return proc.toString();
		}

		@Override public String to_uri_string() {
			throw new UnsupportedOperationException();
		}

		@Override public boolean exists(LuanState luan) {
			return true;
		}

		public void wait_for()
			throws IOException, LuanException
		{
			try {
				proc.waitFor();
			} catch(InterruptedException e) {
				throw new RuntimeException(e);
			}
			int exitVal = proc.exitValue();
			if( exitVal != 0 ) {
				Reader err = new InputStreamReader(proc.getErrorStream());
				String error = "exit value "+exitVal+" in: "+cmd+"\n"+Utils.readAll(err);
				err.close();
				throw new LuanException(error);
			}
		}

		@Override public String read_text(LuanState luan) throws IOException, LuanException {
			String s = super.read_text(luan);
			wait_for();
			return s;
		}

		@Override public LuanTable table(LuanState luan) {
			LuanTable tbl = super.table(luan);
			try {
				tbl.rawPut( "wait_for", new LuanJavaFunction(
					BaseOs.class.getMethod( "wait_for" ), this
				) );
			} catch(NoSuchMethodException e) {
				throw new RuntimeException(e);
			}
			return tbl;
		}
	}

	public static final class LuanOs extends BaseOs {
		private LuanOs(LuanState luan,String cmd,LuanTable options) throws IOException, LuanException {
			super(cmd,options);
			check(luan,"os:"+cmd);
			this.proc = Runtime.getRuntime().exec(cmd,null,dir);
		}
	}

	public static LuanTable os(LuanState luan,String cmd,LuanTable options) throws IOException, LuanException {
		return new LuanOs(luan,cmd,options).table(luan);
	}

	public static final class LuanBash extends BaseOs {
		private LuanBash(LuanState luan,String cmd,LuanTable options) throws IOException, LuanException {
			super(cmd,options);
			check(luan,"bash:"+cmd);
			this.proc = Runtime.getRuntime().exec(new String[]{"bash","-c",cmd},null,dir);
		}
	}

	public static LuanTable bash(LuanState luan,String cmd,LuanTable options) throws IOException, LuanException {
		return new LuanBash(luan,cmd,options).table(luan);
	}



	public static class LuanInput extends LuanIn {
		private final InputStream in;

		public LuanInput(InputStream in) {
			this.in = in;
		}

		@Override public InputStream inputStream(LuanState luan) {
			return in;
		}

		@Override public String to_string() {
			return "<input_stream>";
		}

		@Override public String to_uri_string() {
			throw new UnsupportedOperationException();
		}

		@Override public boolean exists(LuanState luan) {
			return true;
		}
	};


	public static String ip(String domain) {
		try {
			return InetAddress.getByName(domain).getHostAddress();
		} catch(UnknownHostException e) {
			return null;
		}
	}

	public static LuanTable my_ips(LuanState luan) throws IOException {
		LuanTable tbl = new LuanTable(luan);
		for( Enumeration<NetworkInterface> e1 = NetworkInterface.getNetworkInterfaces(); e1.hasMoreElements(); ) {
			NetworkInterface ni = e1.nextElement();
			for( Enumeration<InetAddress> e2 = ni.getInetAddresses(); e2.hasMoreElements(); ) {
				InetAddress ia = e2.nextElement();
				if( ia instanceof Inet4Address )
					tbl.rawPut(ia.getHostAddress(),true);
			}
		}
		return tbl;
	}

/*
	// files maps zip name to uri
	public static void zip(LuanState luan,String zipUri,LuanTable files) throws LuanException, IOException {
		Object obj = uri(luan,zipUri,null).rawGet("java");
		if( !(obj instanceof LuanIO) )
			throw new LuanException("invalid uri for zip");
		LuanIO zipIo = (LuanIO)obj;
		ZipOutputStream out = new ZipOutputStream(zipIo.outputStream());
		for( Map.Entry<Object,Object> entry : files.iterable(luan) ) {
			obj = entry.getKey();
			if( !(obj instanceof String) )
				throw new LuanException("zip file table keys must be strings");
			String fileName = (String)obj;
			obj = entry.getValue();
			if( !(obj instanceof String) )
				throw new LuanException("zip file table values must be strings");
			String uriStr = (String)obj;
			out.putNextEntry(new ZipEntry(fileName));
			obj = uri(luan,uriStr,null).rawGet("java");
			if( !(obj instanceof LuanIn) )
				throw new LuanException("invalid uri for zip");
			LuanIn zipIn = (LuanIn)obj;
			InputStream in = zipIn.inputStream();
			Utils.copyAll(in,out);
			in.close();
			out.closeEntry();
		}
		out.close();
	}
*/

	// security

	public static void unrestricted(LuanState luan) throws LuanException {
		JavaLuan.check(luan);
		luan.javaOk.unrestrictedIo = true;
	}

	public interface Security {
		public void check(LuanState luan,String name) throws LuanException;
	}

	private static String SECURITY_KEY = "Io.Security";

	private static void check(LuanState luan,String name) throws LuanException {
		if( luan.javaOk.unrestrictedIo )
			return;
		Security s = (Security)luan.registry().get(SECURITY_KEY);
		if( s!=null )
			s.check(luan,name);
	}

	public static void setSecurity(LuanState luan,Security s) {
		luan.registry().put(SECURITY_KEY,s);
	}

	private void IoLuan() {}  // never
}