testrouteadv.java

JXTA&#8482 is a set of open, generalized peer-to-peer (P2P) protocols that allow any networked devi

        // test to remove access point
        route.removeDestEndpointAddresses(newaddresses);
        addresses.remove("TCP:222.123.123.123");
        addresses.remove("TCP:222.134.134.134");
        
        // verify advertisement
        e1 = Collections.enumeration(addresses);
        for (Enumeration e = route.getDest().getEndpointAddresses(); e.hasMoreElements();) {
            assertEquals(e.nextElement(), e1.nextElement());
        }
    }
    
    public void testDestDisplay() {
        // create access point advertisment for destination
        System.out.println("Test debug route display");
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();

        addresses.add("TCP:123.123.123.123");
        addresses.add("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
                AdvertisementFactory.newAdvertisement(RouteAdvertisement.getAdvertisementType());

        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:666.666.666.666");
        addresses.add("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:888.888.888.888");
        addresses.add("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();

        hops.add(ap2);
        hops.add(ap4);
        route.setHops(hops);
        route.setHops(hops);
        System.out.println(route.display());
    }
    
    public void testHops() {
        System.out.println("Test hops");
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());
        PeerID pid = IDFactory.newPeerID(IDFactory.newPeerGroupID());

        ap.setPeerID(pid);
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
                AdvertisementFactory.newAdvertisement(RouteAdvertisement.getAdvertisementType());

        route.setDest(ap);
        assertEquals(pid, route.getDestPeerID());
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap4.setPeerID(ap.getPeerID());
        Vector hops = new Vector();

        hops.add(ap2);
        hops.add(ap4);
        route.setHops(hops);
        
        assertEquals(true, route.containsHop(ap.getPeerID()));
        
    }
    
    public void testRouteQuery() {
        
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();

        addresses.add("TCP:123.123.123.123");
        addresses.add("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
                AdvertisementFactory.newAdvertisement(RouteAdvertisement.getAdvertisementType());

        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:666.666.666.666");
        addresses.add("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:888.888.888.888");
        addresses.add("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();

        hops.add(ap2);
        hops.add(ap4);
        route.setHops(hops);
        
        PeerID pid = IDFactory.newPeerID(IDFactory.newPeerGroupID());
        Set badHops = new HashSet();
        RouteQuery query = new RouteQuery();
        query.setDestPeerID(pid);
        query.setSrcRoute(route);
        query.setBadHops(badHops);
        
        // write to a file
        try {
            ByteArrayOutputStream fp = new ByteArrayOutputStream();

            fp.write(query.toString().getBytes());
            fp.close();
            
            Reader is = new InputStreamReader(new ByteArrayInputStream(fp.toByteArray()));
            RouteQuery query1 = null;
            
            XMLDocument doc = (XMLDocument)
                    StructuredDocumentFactory.newStructuredDocument(MimeMediaType.XMLUTF8, is);
            
            query1 = new RouteQuery(doc);
            is.close();
            assertEquals(query.getDestPeerID().toString(), query1.getDestPeerID().toString());
            // verify advertisement
            ap = query.getSrcRoute().getDest();
            AccessPointAdvertisement ap1 = query1.getSrcRoute().getDest();

            assertEquals(ap.getPeerID(), ap1.getPeerID());
            Enumeration e1 = ap1.getEndpointAddresses();

            for (Enumeration e = ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            
            Enumeration r1 = query.getSrcRoute().getHops();

            for (Enumeration e = query1.getSrcRoute().getHops(); e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 = ap1.getEndpointAddresses();
                for (Enumeration e2 = ap.getEndpointAddresses(); e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            System.out.println(query1.toString());
        } catch (Exception ex) {
            ex.printStackTrace();
            fail("Error constructing advertisement");
        }
    }
    
    public void testRouteResponse() {        
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();

        addresses.add("TCP:123.123.123.123");
        addresses.add("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
                AdvertisementFactory.newAdvertisement(RouteAdvertisement.getAdvertisementType());

        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:666.666.666.666");
        addresses.add("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:888.888.888.888");
        addresses.add("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();

        hops.add(ap2);
        hops.add(ap4);
        route.setHops(hops);
        
        AccessPointAdvertisement apDst = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        apDst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:234.234.234.234");
        addresses.add("TCP:256.256.278.256");
        apDst.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement routeDst = (RouteAdvertisement)
                AdvertisementFactory.newAdvertisement(RouteAdvertisement.getAdvertisementType());

        routeDst.setDest(apDst);
        
        AccessPointAdvertisement ap2Dst = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap2Dst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:166.166.166.166");
        addresses.add("TCP:277.277.277.277");
        ap2Dst.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4Dst = (AccessPointAdvertisement)
                AdvertisementFactory.newAdvertisement(AccessPointAdvertisement.getAdvertisementType());

        ap4Dst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.add("TCP:188.188.818.818");
        addresses.add("TCP:929.929.929.929");
        ap4Dst.setEndpointAddresses(addresses);
        
        Vector hopsDst = new Vector();

        hopsDst.add(ap2Dst);
        hopsDst.add(ap4Dst);
        routeDst.setHops(hopsDst);
        
        RouteResponse response = new RouteResponse();

        response.setDestRoute(routeDst);
        response.setSrcRoute(route);
        
        // write to a file
        try {
            FileOutputStream fp = new FileOutputStream("routeresponse.msg");

            fp.write(response.toString().getBytes("UTF-8"));
            fp.close();
            
            FileInputStream is = new FileInputStream("routeresponse.msg");
            RouteResponse response1 = null;
            
            XMLDocument asDoc = (XMLDocument)
                    StructuredDocumentFactory.newStructuredDocument(MimeMediaType.XMLUTF8, is);

            is.close();
            
            response1 = new RouteResponse(asDoc);
            
            // verify advertisement
            ap = response.getSrcRoute().getDest();
            AccessPointAdvertisement ap1 = response1.getSrcRoute().getDest();

            assertEquals(ap.getPeerID(), ap1.getPeerID());
            Enumeration e1 = ap1.getEndpointAddresses();

            for (Enumeration e = ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            Enumeration r1 = response.getSrcRoute().getHops();

            for (Enumeration e = response.getSrcRoute().getHops(); e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 = ap1.getEndpointAddresses();
                for (Enumeration e2 = ap.getEndpointAddresses(); e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            
            ap = response.getDestRoute().getDest();
            ap1 = response1.getDestRoute().getDest();
            assertEquals(ap.getPeerID(), ap1.getPeerID());
            e1 = ap1.getEndpointAddresses();
            for (Enumeration e = ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            r1 = response.getDestRoute().getHops();
            for (Enumeration e = response.getDestRoute().getHops(); e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 = ap1.getEndpointAddresses();
                for (Enumeration e2 = ap.getEndpointAddresses(); e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            
            System.out.println(response1.toString());
        } catch (Exception ex) {
            ex.printStackTrace();
            fail("Error constructing advertisement");
        }
        
    }
    
}