import java.util.*; import java.util.zip.*; import java.util.List; import java.util.regex.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; import java.util.concurrent.locks.*; import javax.swing.*; import javax.swing.event.*; import javax.swing.text.*; import javax.swing.table.*; import java.io.*; import java.net.*; import java.lang.reflect.*; import java.lang.ref.*; import java.lang.management.*; import java.security.*; import java.security.spec.*; import java.awt.*; import java.awt.event.*; import java.awt.image.*; import javax.imageio.*; import java.math.*; import android.app.*; import java.text.NumberFormat; import javax.net.ssl.*; import java.security.SecureRandom; import java.security.cert.X509Certificate; import java.text.SimpleDateFormat; import java.util.*; import java.util.zip.*; import java.util.List; import java.util.regex.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; import java.io.*; import java.net.*; import java.lang.reflect.*; import java.lang.ref.*; import java.lang.management.*; import java.security.*; import java.security.spec.*; import java.math.*; import android.widget.*; import android.view.*; import android.view.View; import android.view.Menu; import android.view.MenuItem; import android.widget.Button; import android.content.Context; import android.app.Activity; import android.view.KeyEvent; import android.view.inputmethod.*; import android.content.*; import android.text.*; public class main { static String awarenessID = "#1004078", catEarID = "#1014854"; static volatile Class x30; static volatile boolean x30loading, x30loadingFailed; static List programsStarted = new ArrayList(); static File defSnip, defargs; static volatile Class visibleProgram; static boolean dontSwitchToRunningProgram; static ReliableSingleThread snippetTitleFinder; static class Prog { String snippetID; Thread thread; } static class Lg { static int maxBufferLength = 2048; Activity context; ScrollView sv; TextView tv; EditText inputView; LinearLayout ll; StringBuffer buf = new StringBuffer(); Lg(Activity context) { this.context = context; sv = new ScrollView(context); tv = new TextView(context); tv.setText(buf.toString()); sv.addView(tv); sv.setLayoutParams(new LinearLayout.LayoutParams( LinearLayout.LayoutParams.MATCH_PARENT, LinearLayout.LayoutParams.MATCH_PARENT, 1.0f)); inputView = new EditText(context); inputView.setInputType(InputType.TYPE_CLASS_TEXT); // turn off multiline inputView.setOnEditorActionListener(new TextView.OnEditorActionListener() { public boolean onEditorAction(TextView v, int actionId, KeyEvent event) { if ((event != null && (event.getKeyCode() == KeyEvent.KEYCODE_ENTER)) || (actionId == EditorInfo.IME_ACTION_DONE)) { String line = inputView.getText().toString(); try { pout3.write((line + "\n").getBytes("UTF-8")); pout3.flush(); } catch (Exception e) {} inputView.selectAll(); } return false; } }); ll = new LinearLayout(context); ll.setOrientation(ll.VERTICAL); ll.addView(sv); ll.addView(inputView); } View getView() { return ll; } void shortenBuffer() { while (buf.length() > maxBufferLength) { String s = buf.toString(); int i = s.indexOf('\n'); if (i < 0) return; buf = new StringBuffer(s.substring(i+1)); } } // TODO: coalesce void print(final String s) { androidUI_noWait(new Runnable() { public void run() { try { buf.append(s); shortenBuffer(); tv.setText(buf.toString()); sv.post(new Runnable() { public void run() { // This method works but animates the scrolling // which looks weird on first load sv.fullScroll(View.FOCUS_DOWN); // This method works even better because there are no animations. //sv.scrollTo(0, sv.getBottom()); } }); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "buf.append(s);\r\n shortenBuffer();\r\n tv.setText(buf.toString());..."; }}); } void println(String s) { print(s + "\n"); } } public static String snippetToRun; static TextView statusView; public static View main(final Context _context) throws Exception { final Activity context = _context instanceof Activity ? (Activity) _context : null; visibleProgram = null; //System.out.println("676 context: " + _context); androidContext = _context; if (context == null) { // I guess this is for boot time execution if (snippetToRun != null) { new Thread() { public void run() { String[] a = { snippetToRun }; callx30(a); } }.start(); } return null; } statusView = aTextView(); preloadx30(); while (x30 == null && !x30loading && !x30loadingFailed) sleep(10); int nInjections = l(injections()); if (dontSwitchToRunningProgram) dontSwitchToRunningProgram = false; else if (nInjections > 0) { try { return getRunningProgramView(nInjections-1); } catch (Throwable __e) { _handleException(__e); }} prepareOptionsMenu(); defSnip = new File(userHome(), ".javax/defsnip"); String id = loadTextFile(defSnip.getPath(), "636"); defargs = new File(userHome(), ".javax/defargs"); String arg = loadTextFile(defargs.getPath(), ""); ScrollView sv = new ScrollView(context); LinearLayout ll = new LinearLayout(context); ll.setOrientation(LinearLayout.VERTICAL); ll.addView(statusView); for (int i = 0; i < nInjections; i++) { final int _i = i; ll.addView(aButton("Back to running program " + (i+1), new Runnable() { public void run() { try { showRunningProgram(_i) ; } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "showRunningProgram(_i)"; }})); } for (int i = 0; i < nInjections; i++) { final int _i = i; ll.addView(aButton("Kill running program " + (i+1), new Runnable() { public void run() { try { killRunningProgram(_i) ; } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "killRunningProgram(_i)"; }})); } LinearLayout line1 = new LinearLayout(context); line1.addView(aTextView("Snippet ID:")); final EditText tv = new EditText(context); // BAD - tv.setInputType(InputType.TYPE_NUMBER_FLAG_DECIMAL); tv.setInputType(InputType.TYPE_CLASS_TEXT | InputType.TYPE_CLASS_NUMBER); tv.setText(id); line1.addView(tv); snippetTitleFinder = new ReliableSingleThread(new Runnable() { public void run() { try { String id = aGetText(tv); if (isSnippetID(id)) aSetText(statusView, snippetTitle(id)); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "String id = aGetText(tv);\r\n if (isSnippetID(id))\r\n aSetText(statu..."; }}); aOnChange(tv, snippetTitleFinder); Button btnRun = new Button(context); btnRun.setText("Run"); line1.addView(btnRun); ll.addView(line1); LinearLayout line2 = new LinearLayout(context); line2.addView(aTextView("Program arguments:")); final EditText tvArgs = new EditText(context); tvArgs.setText(arg); line2.addView(tvArgs); ll.addView(line2); LinearLayout line3 = new LinearLayout(context); /*Button btnLeo = new Button(context); btnLeo.setText("Sprechen mit Leo"); line3.addView(btnLeo);*/ line3.addView(aButton("Cat Ear", new Runnable() { public void run() { try { main.run(context, catEarID, new String[0]); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "main.run(context, catEarID, new String[0]);"; }})); line3.addView(aButton("Start Awareness [" + awarenessID + "]", new Runnable() { public void run() { try { saveDef(awarenessID, ""); main.run(context, awarenessID, new String[0]); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "saveDef(awarenessID, \"\");\r\n main.run(context, awarenessID, new String[0]);"; }})); ll.addView(line3); btnRun.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { hideKeyboard(context); String snippetID = tv.getText().toString(); String text = "Running: " + snippetID; Toast.makeText(context, text, 2000).show(); saveDef(snippetID, tvArgs.getText().toString()); // TODO: quoted args run(context, snippetID, tvArgs.getText().toString().split(" +")); } }); // Show initial status for 1 second, then snippet title aLater(1000, snippetTitleFinder); sv.addView(ll); return sv; } static void saveDef(String snippetID, String args) { try { saveTextFile(defSnip.getPath(), snippetID); saveTextFile(defargs.getPath(), args); } catch (IOException e) { } } static Lg lg; static int systemInPipeSize = 4*1024; // 4 K static PipedInputStream pin3; static PipedOutputStream pout3; public static void run(final Activity context, final String mainSnippet, final String[] args) { try { pin3 = new PipedInputStream(systemInPipeSize); pout3 = new PipedOutputStream(pin3); } catch (IOException e) {} lg = new Lg(context); OutputStream outputStream = new OutputStream() { public void write(int b) { try { lg.print(new String(new byte[] {(byte) b}, "UTF-8")); // This is crap } catch (UnsupportedEncodingException e) {} } @Override public void write(byte[] b, int off, int len) { try { lg.print(new String(b, off, len, "UTF-8")); // This is crap } catch (UnsupportedEncodingException e) {} } }; PrintStream ps = new PrintStream(outputStream, true); System.setOut(ps); System.setErr(ps); System.setIn(pin3); Prog prog = new Prog(); prog.snippetID = mainSnippet; prog.thread = new Thread() { public void run() { try { String[] a = new String[args.length+1]; System.arraycopy(args, 0, a, 1, args.length); a[0] = mainSnippet; callx30(a); } catch (Throwable e) { System.out.println("Whoa!"); e.printStackTrace(); } } }; programsStarted.add(prog); prog.thread.start(); context.setContentView(lg.getView()); } static void setContentViewInUIThread(final View view) { androidUI(new Runnable() { public void run() { try { androidActivity().setContentView(view); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "androidActivity().setContentView(view);"; }}); } public static void hideKeyboard(Activity context) { View view = context.getCurrentFocus(); if (view != null) { InputMethodManager inputManager = (InputMethodManager) context.getSystemService(Context.INPUT_METHOD_SERVICE); inputManager.hideSoftInputFromWindow(view.getWindowToken(), InputMethodManager.HIDE_NOT_ALWAYS); } } static void onActivityResult(int requestCode, int resultCode, Intent data) { /* TODO? if (x30.mainClass != null) x30.call(x30.mainClass, "onActivityResult", requestCode, resultCode, data);*/ } static void onPrepareOptionsPanel(View view, Menu menu) { /* TODO if (x30.mainClass != null) x30.call(x30.mainClass, "onPrepareOptionsPanel", view, menu);*/ } static boolean onOptionsItemSelected(MenuItem item) { /* TODO if (x30.mainClass != null) return (boolean) x30.call(x30.mainClass, "onOptionsItemSelected", item);*/ String s = str(item.getTitle()); print("Item title: " + quote(s)); if (eq(s, "Settings")) showStartScreen(); else if (eqic(s, "Show Console")) { visibleProgram = null; androidActivity().setContentView(lg.getView()); } callOpt(visibleProgram, "onMenuCommand", s); return true; } static void callx30(String[] args) { while (x30 == null) if (x30loadingFailed) throw fail("x30 load failed"); else sleep(10); // guess it's loading print("Calling x30 " + join(" ", args)); try { set(x30, "androidContext", androidContext); ((ThreadLocal) get(x30, "onProgramLoad")).set(new VF1() { public void get(Object paa) { try { visibleProgram = (Class) getOpt(paa, "mainClass"); //print("Have visible program: " + visibleProgram); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "visibleProgram = (Class) getOpt(paa, 'mainClass);\r\n //print(\"Have visi..."; }}); callMain(x30, args); List injections = injections(); //visibleProgram = (Class) getOpt(last(injections), 'mainClass); // TODO: imprecise if main program tempers with injections //print("Have " + l(injections) + " injections, visibleProgram=" + visibleProgram); //print("x30 done"); } catch (Throwable __e) { _handleException(__e); } } static void preloadx30() { startThread(new Runnable() { public void run() { try { getx30(); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "getx30();"; }}); } static void getx30() { try { String status = ""; if (x30 != null) status = "Have x30."; else { Object dataStore = null; try { dataStore = Class.forName("de.tinybrain.javax_allperms.DataStore"); } catch (Throwable __e) { _handleException(__e); } if (dataStore != null) { x30 = (Class) call(dataStore, "get", "x30"); if (x30 != null) status = "Have x30 from data store."; } if (x30 == null) { x30loading = true; status("Loading x30"); Class x30 = loadx30("#1004182"); callOpt(dataStore, "put", "x30", x30); setOpt(x30, "bootUpClass", main.class); main.x30 = x30; status = "x30 loaded."; } } List injections = injections(); if (nempty(injections)) status += " " + n2(injections, "injection"); status(status); } catch (Throwable e) { printStackTrace(e); x30loadingFailed = true; } finally { x30loading = false; } } static List injections() { return (List) callOpt(x30, "getInjections"); } static void killRunningProgram(int i) { try { Object paa = get(injections(), i); if (paa == null) return; call(x30, "removeInjection", paa); showStartScreen(); } catch (Throwable e) { printStackTrace(e); status(str(e)); } } static void showStartScreen() { androidUI(new Runnable() { public void run() { try { dontSwitchToRunningProgram = true; androidActivity().setContentView(main(androidContext())); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "dontSwitchToRunningProgram = true;\r\n androidActivity().setContentView(ma..."; }}); } static void showRunningProgram(int i) { View v = getRunningProgramView(i); if (v != null) setContentViewInUIThread(v); } static View getRunningProgramView(int i) { Object paa = get(injections(), i); if (paa == null) { status("No running program to show"); return null; } Class mainClass = (Class) (getOpt(paa, "mainClass")); View view = (View) (getOpt(mainClass, "androidShow_view")); if (view == null) //ret null with status("Program has no view to show"); view = lg.getView(); // show log instead print("Switched to program " + get(paa, "progID")); visibleProgram = mainClass; ViewGroup group = (ViewGroup) view.getParent(); if (group != null) group.removeView(view); return view; } static void status(String s) { aSetText(statusView, s); print(s); } static Class loadx30(String programID) { try { System.out.println("Program ID: " + programID); String url = "http://tinybrain.de:8080/dexcompile.php?id=" + parseSnippetID(programID); byte[] dexData = loadBinaryPage(url); if (!isDex(dexData)) throw new RuntimeException("Dex generation error"); System.out.println("Dex loaded: " + dexData.length + "b"); File dexDir = makeAndroidTempDir(); File dexFile = new File(dexDir, System.currentTimeMillis() + ".dex"); File dexOutputDir = makeAndroidTempDir(); System.out.println("Saving dex to: " + dexDir.getAbsolutePath()); try { saveBinaryFile(dexFile.getPath(), dexData); } catch (Throwable e) { System.out.println("Whoa!"); throw new RuntimeException(e); } System.out.println("Getting parent class loader."); ClassLoader parentClassLoader = main.class.getClassLoader().getParent(); //System.out.println("Making DexClassLoader."); //DexClassLoader classLoader = new DexClassLoader(dexFile.getAbsolutePath(), dexOutputDir.getAbsolutePath(), null, // parentClassLoader); Class dcl = Class.forName("dalvik.system.DexClassLoader"); Object classLoader = dcl.getConstructors()[0].newInstance(dexFile.getAbsolutePath(), dexOutputDir.getAbsolutePath(), null, parentClassLoader); System.out.println("Loading main class."); Class theClass = (Class) call(classLoader, "loadClass", "x30"); System.out.println("Main class loaded."); try { set(theClass, "androidContext", androidContext); } catch (Throwable e) {} setVars(theClass, programID); hotwire_copyOver(theClass); return theClass; } catch (Exception __e) { throw rethrow(__e); } } static void setVars(Class theClass, String programID) { try { set(theClass, "programID", programID); } catch (Throwable e) {} try { set(theClass, "__javax", x30); } catch (Throwable e) {} } static String getConsoleOutput() { return lg.buf.toString(); } static void prepareOptionsMenu() { try { Menu menu = (Menu) (getOpt(androidActivity(), "optionsMenu")); if (menu == null) return; if (menu.size() < 2) menu.add("Show Console"); } catch (Throwable __e) { _handleException(__e); } } static void androidUI_noWait(final Object r) { androidActivity().runOnUiThread(toRunnable(r)); } static RuntimeException rethrow(Throwable t) { if (t instanceof Error) _handleError((Error) t); throw t instanceof RuntimeException ? (RuntimeException) t : new RuntimeException(t); } static RuntimeException rethrow(String msg, Throwable t) { throw new RuntimeException(msg, t); } static volatile StringBuffer local_log = new StringBuffer(); // not redirected static volatile Appendable print_log = local_log; // might be redirected, e.g. to main bot // in bytes - will cut to half that static volatile int print_log_max = 1024*1024; static volatile int local_log_max = 100*1024; static boolean print_silent; // total mute if set static Object print_byThread_lock = new Object(); static volatile ThreadLocal print_byThread; // special handling by thread - prefers F1 static volatile Object print_allThreads; static volatile Object print_preprocess; static void print() { print(""); } static A print(String s, A o) { print((endsWithLetterOrDigit(s) ? s + ": " : s) + o); return o; } // slightly overblown signature to return original object... static A print(A o) { ping_okInCleanUp(); if (print_silent) return o; String s = String.valueOf(o) + "\n"; print_noNewLine(s); return o; } static void print_noNewLine(String s) { Object f = getThreadLocal(print_byThread_dontCreate()); if (f == null) f = print_allThreads; if (f != null) // We do need the general callF machinery here as print_byThread is sometimes shared between modules if (isFalse( callF(f, s))) return; print_raw(s); } static void print_raw(String s) { if (print_preprocess != null) s = (String) callF(print_preprocess, s); s = fixNewLines(s); Appendable loc = local_log; Appendable buf = print_log; int loc_max = print_log_max; if (buf != loc && buf != null) { print_append(buf, s, print_log_max); loc_max = local_log_max; } if (loc != null) print_append(loc, s, loc_max); System.out.print(s); } static TextView aTextView(String text) { TextView tv = aTextView(); tv.setText(text); return tv; } static TextView aTextView() { return androidUI(new F0() { TextView get() { try { return new TextView(androidActivity()); } catch (Exception __e) { throw rethrow(__e); } } public String toString() { return "ret new TextView(androidActivity());"; }}); } static volatile boolean sleep_noSleep; static void sleep(long ms) { ping(); if (ms < 0) return; // allow spin locks if (isAWTThread() && ms > 100) throw fail("Should not sleep on AWT thread"); try { Thread.sleep(ms); } catch (Exception e) { throw new RuntimeException(e); } } static void sleep() { try { if (sleep_noSleep) throw fail("nosleep"); print("Sleeping."); sleepQuietly(); } catch (Exception __e) { throw rethrow(__e); } } static int l(Object[] a) { return a == null ? 0 : a.length; } static int l(boolean[] a) { return a == null ? 0 : a.length; } static int l(byte[] a) { return a == null ? 0 : a.length; } static int l(short[] a) { return a == null ? 0 : a.length; } static int l(long[] a) { return a == null ? 0 : a.length; } static int l(int[] a) { return a == null ? 0 : a.length; } static int l(float[] a) { return a == null ? 0 : a.length; } static int l(double[] a) { return a == null ? 0 : a.length; } static int l(char[] a) { return a == null ? 0 : a.length; } static int l(Collection c) { return c == null ? 0 : c.size(); } static int l(Map m) { return m == null ? 0 : m.size(); } static int l(CharSequence s) { return s == null ? 0 : s.length(); } static long l(File f) { return f == null ? 0 : f.length(); } static int l(Object o) { return o == null ? 0 : o instanceof String ? l((String) o) : o instanceof Map ? l((Map) o) : o instanceof Collection ? l((Collection) o) : o instanceof Object[] ? l((Object[]) o) : o instanceof boolean[] ? l((boolean[]) o) : o instanceof byte[] ? l((byte[]) o) : o instanceof char[] ? l((char[]) o) : o instanceof short[] ? l((short[]) o) : o instanceof int[] ? l((int[]) o) : o instanceof float[] ? l((float[]) o) : o instanceof double[] ? l((double[]) o) : o instanceof long[] ? l((long[]) o) : (Integer) call(o, "size"); } static volatile PersistableThrowable _handleException_lastException; static List _handleException_onException = synchroList(ll("printStackTrace2")); static void _handleException(Throwable e) { _handleException_lastException = persistableThrowable(e); Throwable e2 = innerException(e); if (e2.getClass() == RuntimeException.class && eq(e2.getMessage(), "Thread cancelled.") || e2 instanceof InterruptedException) return; for (Object f : cloneList(_handleException_onException)) try { callF(f, e); } catch (Throwable e3) { printStackTrace2(e3); // not using pcall here - it could lead to endless loops } } static String _userHome; static String userHome() { if (_userHome == null) return actualUserHome(); return _userHome; } static File userHome(String path) { return new File(userDir(), path); } static String loadTextFile(String fileName) { return loadTextFile(fileName, null); } static String loadTextFile(File f, String defaultContents) { try { checkFileNotTooBigToRead(f); if (f == null || !f.exists()) return defaultContents; FileInputStream fileInputStream = new FileInputStream(f); InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "UTF-8"); return loadTextFile(inputStreamReader); } catch (Exception __e) { throw rethrow(__e); } } public static String loadTextFile(File fileName) { return loadTextFile(fileName, null); } static String loadTextFile(String fileName, String defaultContents) { return fileName == null ? defaultContents : loadTextFile(newFile(fileName), defaultContents); } static String loadTextFile(Reader reader) throws IOException { StringBuilder builder = new StringBuilder(); try { char[] buffer = new char[1024]; int n; while (-1 != (n = reader.read(buffer))) builder.append(buffer, 0, n); } finally { reader.close(); } return str(builder); } static Button aButton(String text, final Object action) { final Button b = aButton(text); if (action != null) b.setOnClickListener(new View.OnClickListener() { public void onClick(View v) { AutoCloseable __8 = holdInstance(b); try { pcallF(action); } finally { _close(__8); }} }); return b; } static Button aButton(String text) { Button b = aButton(); b.setText(text); return b; } static Button aButton() { return androidUI(new F0