VisClient/org/hfbk/vis/UdpListener.java

Go to the documentation of this file.

package org.hfbk.vis;


import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketAddress;
import java.util.Arrays;

import org.hfbk.util.Scripter;
import org.hfbk.vis.visnode.VisNode;
import org.hfbk.vis.visnode.VisScale;
import org.hfbk.vis.visnode.VisUeberwach;

class UdpListener extends Thread {
        static int udpport = 7778;
        DatagramSocket socket = null;
        DatagramPacket paket = null;
        VisClient client;
        
        
        ScriptRouter router;
        
        
        UdpListener(VisClient client) {
                super("UdpListener, port "+udpport); //name this thread
                setDaemon(true);
                
                paket = new DatagramPacket(new byte[256], 256);
                this.client=client;
                try {
                        socket = new DatagramSocket(udpport);
                } catch (IOException e) {
                        System.err.println("UdpListener: " + e.getClass());
                }
                
                try{
                        router=new ScriptRouter(client);
                }catch(Exception e){
                        e.printStackTrace();
                }
                setPriority(Thread.MIN_PRIORITY); // don't slow down animation
                start();
        }

        public void run() {
                while (true) {
                        try {
                                socket.receive(paket);
                                //InetSocketAddress add = (InetSocketAddress) paket.getSocketAddress();
                        
                                // Text aus Paket extrahieren
                                String text = new String(paket.getData(), 0, paket.getLength());
                                if(Prefs.current.verbose) 
                                        System.out.println(text);
                                
                                if (text.equals("PING\n")) { //answer a VisMCP ping attempt. 
                                        SocketAddress mcp=paket.getSocketAddress();
                                        byte[] pong="PONG\n".getBytes();
                                        socket.send(new DatagramPacket(pong, pong.length, mcp));
                                }
                                
                                if (text.startsWith("javascript:")) {
                                        SocketAddress mcp=paket.getSocketAddress();
                                        String result=script(text.substring(11));
                                        byte[] answer=result.getBytes();
                                        socket.send(new DatagramPacket(answer, answer.length, mcp));
                                }
                                
                                if (text.indexOf('[')>-1 && text.indexOf('[')<2)
                                        parseMsg(text);
                                
                        }catch (IOException e) { //common reason is that we ourselves 
                                                                        //closed this connection so fail silently                               
                                //System.err.println("Ausnahmefehler: " + e);
                                return;
                        }
                }
        }
        
        public void close(){
                if (socket!=null)
                        socket.close();
        }
        
        float nickNeutral=0x160, rollNeutral=0x160;
        //float nickNeutral=344, rollNeutral=348; //Floß
        
        void parseMsg(String msg){
                try{
                        //gracefully ignore extra chars
                        int start=msg.indexOf('['); 
                        int end=msg.lastIndexOf(']');
                        
                        if(end<1)
                                throw new RuntimeException("No correct ] delimiter!");
                        msg=msg.substring(start+1, end);
                        String[] args=msg.split(",");
                        
                        MouseViewpoint vp=client.mouseViewpoint;
                        
                        String cmd=args[0];
                        if (cmd.equals("scale")){
                                float value=Long.decode(args[2])/(float)0x3FF;
                
                                //router.dispatch(Arrays.copyOfRange(args, 1, args.length));
                                router.dispatch(args[1], Arrays.copyOfRange(args, 2, args.length));
                                
                                if (args[1].matches("sonar.*")){
                                        VisNode n=client.root.findNode(VisUeberwach.class);
                                        ((VisUeberwach)n).parseMsg(args);
                                }
                                
                                /*if (args[1].equals("poti1")) //poti1 controls timescale..
                                        client.timescale=value*5;
                                else if (args[1].equals("poti3")){
                                        vp.tfov=3.15f-value*3;  
                                }
                                else if (args[1].equals("poti4")){
                                        vp.tfov=2.15f-value*2;
                                }*/
                                
                                        //client.background=new Color(value,value,value);
                                //all others control a visual scale
                                VisScale.scaleIt(args[1], value, 1f, client.root);
                        }else if (cmd.equals("view2")){
                                //harte Steuerung für Handschuh
                                
                                final float CONTROL=4;
                                
                                float nick=(Long.decode(args[3])-nickNeutral )/70f;
                                float roll=(Long.decode(args[2])-rollNeutral)/70f;
                                nickNeutral+=nick*0.01f; rollNeutral+=roll*0.01f;
                                vp.dangle=vp.roll;
                                vp.dforward=-(vp.elevation*100-30)*(float)Math.cos(vp.elevation);
                                vp.dlift=(float)Math.sin(vp.elevation)*100;
                                vp.delevation=(-roll-vp.elevation)* CONTROL;
                                vp.droll=(-nick-vp.roll)* CONTROL;
                                
                                /*Floß usw. sensible, langsame Steuerung
                                 *
                                final float CONTROL=2;
                                float nick=(Long.decode(args[3])-nickNeutral )/20f;
                                float roll=(Long.decode(args[2])-rollNeutral)/20f;
                                nickNeutral+=nick*0.01f; rollNeutral+=roll*0.01f;
                                System.out.println(nickNeutral+" "+rollNeutral);
                                vp.dangle=vp.roll;
                                //vp.dforward=(vp.elevation*100-30)*(float)Math.cos(vp.elevation);
                                vp.dforward=(vp.elevation*100);//*(float)Math.cos(vp.elevation);
                                //vp.dlift=(float)Math.sin(vp.elevation)*100;
                                vp.delevation=(-nick-vp.elevation)*2;
                                vp.droll=(-roll-vp.roll)*2;*/
                        }else if (cmd.equals("top") && args[1].equals("get") && args[2].equals("files")){
                                //quick dirty handler for portramat
                                // [top,get,files,faces/face195435415_426_568.jpg]
                        
                                String path=args[3];
                                if (!path.matches("http://"))
                                        path="http://vis.hfbk.net/"+path;
                                
                        //      VisNode n=findNode(findNode(client.root,VisStructure.class),VisUeberwach.class);
                                //((VisUeberwach)n).addPortrait(path, paket.getAddress().getHostAddress());
                                client.panel.allesfresser.friss(path);
                        }
                                
                }catch(Throwable t){ //could happen often with wireless incoming 
                        if(Prefs.current.verbose) System.out.println("UdpListener parseMsg:"+t);
                }
        }
        
        String script(String js){
                Scripter engine=new VisClientScripter(client);
        
                Object result;
                
        try {
                        result = engine.evaluate(js);
                        if (result!=null)       return result.toString();
                        else                            return "(null)";
                } catch (Exception e) {
                        return "Client Script Error: "+e;
                }
                
        }
}

---