package org.kde.kjas.server; import java.io.*; import java.util.*; import java.awt.*; import java.net.*; /** * Encapsulates the KJAS protocol and manages the contexts * */ public class KJASProtocolHandler { // Command codes- always need to be synced up with // what's in kjavaappletserver.cpp private static final int CreateContextCode = 1; private static final int DestroyContextCode = 2; private static final int CreateAppletCode = 3; private static final int DestroyAppletCode = 4; private static final int StartAppletCode = 5; private static final int StopAppletCode = 6; private static final int InitAppletCode = 7; private static final int ShowDocumentCode = 8; private static final int ShowURLInFrameCode = 9; private static final int ShowStatusCode = 10; private static final int ResizeAppletCode = 11; private static final int GetURLDataCode = 12; private static final int URLDataCode = 13; private static final int ShutdownServerCode = 14; private static final int JavaScriptEvent = 15; static final int GetMember = 16; static final int CallMember = 17; private static final int PutMember = 18; private static final int DerefObject = 19; private static final int AudioClipPlayCode = 20; private static final int AudioClipLoopCode = 21; private static final int AudioClipStopCode = 22; private static final int AppletStateNotificationCode = 23; private static final int AppletFailedCode = 24; private static final int DataCommand = 25; private static final int PutURLDataCode = 26; private static final int PutDataCode = 27; private static final int SecurityConfirmCode = 28; private static final int ShowConsole = 29; //Holds contexts in contextID-context pairs private Hashtable contexts; private PushbackInputStream commands; //Stream for reading in commands private PrintStream signals; //Stream for writing out callbacks //used for parsing each command as it comes in private int cmd_index; private final static char sep = (char) 0; public KJASProtocolHandler( InputStream _commands, OutputStream _signals ) { commands = new PushbackInputStream( _commands ); signals = new PrintStream( _signals ); contexts = new Hashtable(); } public void commandLoop() { try { while( true ) { try { int cmd_length = readPaddedLength( 8 ); Main.debug( "PH: cmd_length = " + cmd_length ); //We need to have this while loop since we're not guaranteed to get //all the bytes we want back, especially with large jars byte[] cmd_data = new byte[cmd_length]; int total_read = 0; while( total_read < cmd_length ) { int numread = commands.read( cmd_data, total_read, cmd_length-total_read ); Main.debug( "PH: read in " + numread + " bytes for command" ); total_read += numread; } //parse the rest of the command and execute it processCommand( cmd_data ); } catch( NumberFormatException e ) { Main.kjas_err( "Could not parse out message length", e ); e.printStackTrace(); System.exit( 1 ); } catch( Throwable t ) { Main.debug( "commandLoop caught a throwable, still going" ); t.printStackTrace(); } } } catch( Exception i ) { Main.kjas_err( "commandLoop exited on exception: ", i ); i.printStackTrace(); System.exit( 1 ); } } public void processCommand( byte[] command ) { // Sanity checks if ( command == null ) return; //do all the parsing here and pass arguments as individual variables to the //handler functions int cmd_length = command.length; cmd_index = 0; int cmd_code_value = (int) command[cmd_index++]; if( cmd_code_value == CreateContextCode ) { //parse out contextID- 1 argument String contextID = getArg( command ); Main.debug( "createContext, id = " + contextID ); KJASAppletContext context = new KJASAppletContext( contextID ); contexts.put( contextID, context ); } else if( cmd_code_value == DestroyContextCode ) { //parse out contextID- 1 argument String contextID = getArg( command ); Main.debug( "destroyContext, id = " + contextID ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if( contexts != null ) { context.destroy(); contexts.remove( contextID ); } } else if( cmd_code_value == CreateAppletCode ) { //9 arguments- this order is important... final String contextID = getArg( command ); final String appletID = getArg( command ); final String appletName = getArg( command ); final String className = getArg( command ); final String baseURL = getArg( command ); final String username = getArg( command ); final String password = getArg( command ); final String authname = getArg( command ); final String codeBase = getArg( command ); final String archives = getArg( command ); final String width = getArg( command ); final String height = getArg( command ); final String title = getArg( command ); //get the number of parameter pairs... String str_params = getArg( command ); int num_params = Integer.parseInt( str_params.trim() ); final Hashtable params = new Hashtable(); for( int i = 0; i < num_params; i++ ) { String name = getArg( command ); // note name is in uppercase if( name == null ) name = new String(); String value = getArg( command ); if( value == null ) value = new String(); params.put( name, value ); //Main.debug( "parameter, name = " + name + ", value = " + value ); } Main.debug( "createApplet, context = " + contextID + ", applet = " + appletID ); Main.debug( " name = " + appletName + ", classname = " + className ); Main.debug( " baseURL = " + baseURL + ", codeBase = " + codeBase ); Main.debug( " archives = " + archives + ", width = " + width + ", height = " + height ); final KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if( context != null ) { context.createApplet( appletID, appletName, className, baseURL, username, password, authname, codeBase, archives, width, height, title, params ); } } else if( cmd_code_value == DestroyAppletCode ) { //2 arguments String contextID = getArg( command ); String appletID = getArg( command ); Main.debug( "destroyApplet, context = " + contextID + ", applet = " + appletID ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context != null ) context.destroyApplet( appletID ); } else if( cmd_code_value == StartAppletCode ) { //2 arguments String contextID = getArg( command ); String appletID = getArg( command ); Main.debug( "startApplet, context = " + contextID + ", applet = " + appletID ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context != null ) context.startApplet( appletID ); } else if( cmd_code_value == StopAppletCode ) { //2 arguments String contextID = getArg( command ); String appletID = getArg( command ); Main.debug( "stopApplet, context = " + contextID + ", applet = " + appletID ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context != null ) context.stopApplet( appletID ); } else if( cmd_code_value == ShutdownServerCode ) { Main.debug( "shutDownServer received" ); KJASAppletStub.waitForAppletThreads(); System.exit( 1 ); } else if( cmd_code_value == URLDataCode ) { String id = getArg( command ); String code = getArg( command ); Main.debug( "KIO URLData received(" + id + ") code:" + code ); //rest of the command should be the data... byte[] data = null; if (cmd_length - cmd_index > 0) { data = new byte[ cmd_length - cmd_index ]; System.arraycopy( command, cmd_index, data, 0, data.length ); } KIOConnection.setData(id, Integer.parseInt(code), data); } else if (cmd_code_value == GetMember) { int ticketnr = Integer.parseInt( getArg( command ) ); String contextID = getArg( command ); String appletID = getArg( command ); int objid = Integer.parseInt( getArg( command ) ); String name = getArg( command ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context == null || !context.getMember(appletID, ticketnr, objid, name)) sendMemberValue(contextID, GetMember, ticketnr, -1, 0, ""); } else if (cmd_code_value == PutMember) { int ticketnr = Integer.parseInt( getArg( command ) ); String contextID = getArg( command ); String appletID = getArg( command ); int objid = Integer.parseInt( getArg( command ) ); String name = getArg( command ); String value = getArg( command ); boolean ret = false; KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if (context == null || !context.putMember(appletID, ticketnr, objid, name, value)) sendPutMember(contextID, ticketnr, false); } else if (cmd_code_value == CallMember) { int ticketnr = Integer.parseInt( getArg( command ) ); String contextID = getArg( command ); String appletID = getArg( command ); int objid = Integer.parseInt( getArg( command ) ); String name = getArg( command ); int arg_count = Integer.parseInt( getArg( command ) ); java.util.List args = new java.util.Vector(); try { // fix getArg String param = getArg(command); while (arg_count-- > 0) { if (param == null) param = new String(); args.add(param); param = getArg(command); } } catch (Exception e) {} KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context == null || !context.callMember(appletID, ticketnr, objid, name, args)) Main.protocol.sendMemberValue(contextID, CallMember, ticketnr, -1, 0, ""); } else if (cmd_code_value == DerefObject) { String contextID = getArg( command ); String appletID = getArg( command ); String objid = getArg( command ); KJASAppletContext context = (KJASAppletContext) contexts.get( contextID ); if ( context != null ) context.derefObject(appletID, Integer.parseInt(objid)); Main.debug( "DerefObject " + objid); } else if (cmd_code_value == SecurityConfirmCode) { String id = getArg( command ); String confirm = getArg( command ); Thread t = (Thread) KJASSecurityManager.confirmRequests.get(id); Main.debug( "SecurityConfirmCode " + id + " confirm:" + confirm ); if (t != null) { KJASSecurityManager.confirmRequests.put(id, confirm); try { t.interrupt(); } catch (SecurityException se) {} } } else if (cmd_code_value == ShowConsole) { Main.console.setVisible(true); } else { throw new IllegalArgumentException( "Unknown command code" ); } } /************************************************************** ***** Methods for talking to the applet server ************** **************************************************************/ /** * sends get url request */ public void sendGetURLDataCmd( String jobid, String url ) { Main.debug( "sendGetURLCmd(" + jobid + ") url = " + url ); //length = length of args plus 1 for code, 2 for seps and 1 for end byte [] url_bytes = url.getBytes(); int length = jobid.length() + url_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) GetURLDataCode; bytes[index++] = sep; tmp_bytes = jobid.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( url_bytes, 0, bytes, index, url_bytes.length ); index += url_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } /** * sends command for get url request (stop/hold/resume) or put (stop) */ public void sendDataCmd( String id, int cmd ) { Main.debug( "sendDataCmd(" + id + ") command = " + cmd ); byte [] cmd_bytes = String.valueOf( cmd ).getBytes(); int length = id.length() + cmd_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) DataCommand; bytes[index++] = sep; tmp_bytes = id.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( cmd_bytes, 0, bytes, index, cmd_bytes.length ); index += cmd_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } /** * sends put url request */ public void sendPutURLDataCmd( String jobid, String url ) { Main.debug( "sendPutURLCmd(" + jobid + ") url = " + url ); //length = length of args plus 1 for code, 2 for seps and 1 for end byte [] url_bytes = url.getBytes(); int length = jobid.length() + url_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) PutURLDataCode; bytes[index++] = sep; tmp_bytes = jobid.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( url_bytes, 0, bytes, index, url_bytes.length ); index += url_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } /** * sends put data */ public void sendPutData( String jobid, byte [] b, int off, int len ) { Main.debug( "sendPutData(" + jobid + ") len = " + len ); //length = length of args plus 1 for code, 2 for seps and 1 for end int length = jobid.length() + len + 4; byte [] bytes = new byte[ length + 8 ]; byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) PutDataCode; bytes[index++] = sep; tmp_bytes = jobid.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( b, off, bytes, index, len ); index += len; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } /** * sends notification about the state of the applet. * @see org.kde.kjas.server.KJASAppletStub for valid states */ public void sendAppletStateNotification( String contextID, String appletID, int state ) { Main.debug( "sendAppletStateNotification, contextID = " + contextID + ", appletID = " + appletID + ", state=" + state ); byte [] state_bytes = String.valueOf( state ).getBytes(); int length = contextID.length() + appletID.length() + state_bytes.length + 5; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) AppletStateNotificationCode; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = appletID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( state_bytes, 0, bytes, index, state_bytes.length ); index += state_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } /** * sends notification about applet failure. * This can happen in any state. * @param contextID context ID of the applet's context * @param appletID ID of the applet * @param errorMessage any message */ public void sendAppletFailed ( String contextID, String appletID, String errorMessage) { Main.debug( "sendAppletFailed, contextID = " + contextID + ", appletID = " + appletID + ", errorMessage=" + errorMessage ); byte [] msg_bytes = errorMessage.getBytes(); int length = contextID.length() + appletID.length() + msg_bytes.length + 5; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) AppletFailedCode; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = appletID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( msg_bytes, 0, bytes, index, msg_bytes.length ); index += msg_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendShowDocumentCmd( String loaderKey, String url ) { Main.debug( "sendShowDocumentCmd from context#" + loaderKey + " url = " + url ); //length = length of args + 2 for seps + 1 for end + 1 for code byte [] url_bytes = url.getBytes(); byte [] key_bytes = loaderKey.getBytes(); int length = key_bytes.length + url_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; //8 for the length of this message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) ShowDocumentCode; bytes[index++] = sep; System.arraycopy( key_bytes, 0, bytes, index, key_bytes.length ); index += key_bytes.length; bytes[index++] = sep; System.arraycopy( url_bytes, 0, bytes, index, url_bytes.length ); index += url_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendShowDocumentCmd( String contextID, String url, String frame) { Main.debug( "sendShowDocumentCmd from context#" + contextID + " url = " + url + ", frame = " + frame ); //length = length of args plus code, 3 seps, end byte [] url_bytes = url.getBytes(); byte [] frame_bytes = frame.getBytes(); int length = contextID.length() + url_bytes.length + frame_bytes.length + 5; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) ShowURLInFrameCode; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( url_bytes, 0, bytes, index, url_bytes.length ); index += url_bytes.length; bytes[index++] = sep; System.arraycopy( frame_bytes, 0, bytes, index, frame_bytes.length ); index += frame_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendShowStatusCmd( String contextID, String msg ) { Main.debug( "sendShowStatusCmd, contextID = " + contextID + " msg = " + msg ); byte [] msg_bytes = msg.getBytes(); int length = contextID.length() + msg_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; //for length of message int index = 0; byte [] tmp_bytes = getPaddedLengthBytes( length ); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) ShowStatusCode; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( msg_bytes, 0, bytes, index, msg_bytes.length ); index += msg_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendResizeAppletCmd( String contextID, String appletID, int width, int height ) { Main.debug( "sendResizeAppletCmd, contextID = " + contextID + ", appletID = " + appletID + ", width = " + width + ", height = " + height ); byte [] width_bytes = String.valueOf( width ).getBytes(); byte [] height_bytes = String.valueOf( height ).getBytes(); //length = length of args plus code, 4 seps, end int length = contextID.length() + appletID.length() + width_bytes.length + height_bytes.length + 6; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) ResizeAppletCode; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = appletID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( width_bytes, 0, bytes, index, width_bytes.length ); index += width_bytes.length; bytes[index++] = sep; System.arraycopy( height_bytes, 0, bytes, index, height_bytes.length ); index += height_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendJavaScriptEventCmd( String contextID, String appletID, int objid, String event, int [] types, String [] args ) { Main.debug( "sendJavaScriptEventCmd, contextID = " + contextID + " event = " + event ); String objstr = new String("" + objid); int length = contextID.length() + appletID.length() + event.length() + objstr.length() + 6; byte [][][] arglist = null; if (types != null) { arglist = new byte[args.length][2][]; for (int i = 0; i < types.length; i++) { arglist[i][0] = (new String("" + types[i])).getBytes(); arglist[i][1] = args[i].getBytes(); length += 2 + arglist[i][0].length + arglist[i][1].length; } } byte [] bytes = new byte[ length + 8 ]; //for length of message int index = 0; byte [] tmp_bytes = getPaddedLengthBytes( length ); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) JavaScriptEvent; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = appletID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = objstr.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = event.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; if (types != null) for (int i = 0; i < types.length; i++) { System.arraycopy( arglist[i][0], 0, bytes, index, arglist[i][0].length ); index += arglist[i][0].length; bytes[index++] = sep; System.arraycopy( arglist[i][1], 0, bytes, index, arglist[i][1].length ); index += arglist[i][1].length; bytes[index++] = sep; } signals.write( bytes, 0, bytes.length ); } public void sendMemberValue( String contextID, int cmd, int ticketnr, int type, int rid, String value ) { Main.debug( "sendMemberValue, contextID = " + contextID + " value = " + value + " type=" + type + " rid=" + rid ); String strticket = String.valueOf( ticketnr ); String strtype = String.valueOf( type ); String strobj = String.valueOf( rid ); byte [] value_bytes = value.getBytes(); int length = contextID.length() + value_bytes.length + strtype.length() + strobj.length() + strticket.length() + 7; byte [] bytes = new byte[ length + 8 ]; //for length of message int index = 0; byte [] tmp_bytes = getPaddedLengthBytes( length ); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) cmd; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = strticket.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = strtype.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; tmp_bytes = strobj.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( value_bytes, 0, bytes, index, value_bytes.length ); index += value_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } private void sendAudioClipCommand(String contextId, String url, int cmd) { byte [] url_bytes = url.getBytes(); int length = contextId.length() + url_bytes.length + 4; byte [] bytes = new byte[ length + 8 ]; byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) cmd; bytes[index++] = sep; tmp_bytes = contextId.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( url_bytes, 0, bytes, index, url_bytes.length ); index += url_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendAudioClipPlayCommand(String contextId, String url) { sendAudioClipCommand(contextId, url, AudioClipPlayCode); } public void sendAudioClipLoopCommand(String contextId, String url) { sendAudioClipCommand(contextId, url, AudioClipLoopCode); } public void sendAudioClipStopCommand(String contextId, String url) { sendAudioClipCommand(contextId, url, AudioClipStopCode); } public void sendPutMember( String contextID, int ticketnr, boolean success ) { Main.debug("sendPutMember, contextID = " + contextID + " success = " + success); byte [] ticket_bytes = String.valueOf( ticketnr ).getBytes(); byte [] ret_bytes = String.valueOf( success ? "1" : "0" ).getBytes(); int length = contextID.length() + ret_bytes.length + ticket_bytes.length + 5; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) PutMember; bytes[index++] = sep; tmp_bytes = contextID.getBytes(); System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = sep; System.arraycopy( ticket_bytes, 0, bytes, index, ticket_bytes.length ); index += ticket_bytes.length; bytes[index++] = sep; System.arraycopy( ret_bytes, 0, bytes, index, ret_bytes.length ); index += ret_bytes.length; bytes[index++] = sep; signals.write( bytes, 0, bytes.length ); } public void sendSecurityConfirm( String [] certs, int certsnr, String perm, String id ) { Main.debug("sendSecurityConfirm, ID = " + id + " certsnr = " + certsnr); byte [] id_bytes = id.getBytes(); byte [] perm_bytes = perm.getBytes(); byte [] certsnr_bytes = String.valueOf( certsnr ).getBytes(); int length = perm_bytes.length + id_bytes.length + certsnr_bytes.length + 5; for (int i = 0; i < certsnr; i++) length += certs[i].length() + 1; byte [] bytes = new byte[ length + 8 ]; //for length of message byte [] tmp_bytes = getPaddedLengthBytes( length ); int index = 0; System.arraycopy( tmp_bytes, 0, bytes, index, tmp_bytes.length ); index += tmp_bytes.length; bytes[index++] = (byte) SecurityConfirmCode; bytes[index++] = sep; System.arraycopy( id_bytes, 0, bytes, index, id_bytes.length ); index += id_bytes.length; bytes[index++] = sep; System.arraycopy( perm_bytes, 0, bytes, index, perm_bytes.length ); index += perm_bytes.length; bytes[index++] = sep; System.arraycopy( certsnr_bytes, 0, bytes, index, certsnr_bytes.length ); index += certsnr_bytes.length; bytes[index++] = sep; for (int i = 0; i < certsnr; i++) { byte [] cert_bytes = certs[i].getBytes(); System.arraycopy( cert_bytes, 0, bytes, index, cert_bytes.length ); index += cert_bytes.length; bytes[index++] = sep; } signals.write( bytes, 0, bytes.length ); } /************************************************************** ***** Utility functions for parsing commands **************** **************************************************************/ private String getArg( byte[] command ) { int begin = cmd_index; while( 0 != ((int) command[cmd_index++]) ); if( cmd_index > (begin + 1) ) { String rval = new String( command, begin, (cmd_index - begin - 1) ); return rval; } else return null; } private byte[] getPaddedLengthBytes( int length ) { byte[] length_bytes = String.valueOf( length ).getBytes(); if( length_bytes.length > 8 ) throw new IllegalArgumentException( "can't create string number of length = 8" ); byte [] bytes = { (byte) ' ', (byte) ' ', (byte) ' ', (byte) ' ', (byte) ' ', (byte) ' ', (byte) ' ', (byte) ' '}; System.arraycopy( length_bytes, 0, bytes, 0, length_bytes.length ); return bytes; } private int readPaddedLength( int string_size ) throws IOException { //read in 8 bytes for command length- length will be sent as a padded string byte[] length = new byte[string_size]; commands.read( length, 0, string_size ); String length_str = new String( length ); return Integer.parseInt( length_str.trim() ); } }