src/test/java/com/intel/jndn/management/FibEntryTest.java

/*
 * File name: FibEntryTest.java
 * 
 * Purpose: Test encode/decode of FibEntry and NextHopRecord
 * 
 * © Copyright Intel Corporation. All rights reserved.
 * Intel Corporation, 2200 Mission College Boulevard,
 * Santa Clara, CA 95052-8119, USA
 */
package com.intel.jndn.management;

import com.intel.jndn.management.types.StatusDataset;
import com.intel.jndn.management.types.NextHopRecord;
import com.intel.jndn.management.types.FibEntry;
import com.intel.jndn.utils.Client;
import java.util.List;
import junit.framework.Assert;
import net.named_data.jndn.Data;
import net.named_data.jndn.Face;
import net.named_data.jndn.Interest;
import net.named_data.jndn.Name;
import net.named_data.jndn.encoding.EncodingException;
import net.named_data.jndn.util.Blob;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import org.junit.Test;

/**
 * Test encode/decode of FibEntry and NextHopRecord
 *
 * @author Andrew Brown <andrew.brown@intel.com>
 */
public class FibEntryTest {

	/**
	 * Test encoding/decoding
	 *
	 * @throws java.lang.Exception
	 */
	@Test
	public void testEncodeDecode() throws Exception {
		NextHopRecord nextHopRecord = new NextHopRecord();
		nextHopRecord.setFaceId(42);
		nextHopRecord.setCost(100);
		FibEntry entry = new FibEntry();
		entry.setName(new Name("/fib/entry/test"));
		entry.getRecords().add(nextHopRecord);

		// encode
		Blob encoded = entry.wireEncode();

		// decode
		FibEntry decoded = new FibEntry();
		decoded.wireDecode(encoded.buf());

		// test
		Assert.assertEquals(entry.getName().toUri(), decoded.getName().toUri());
		Assert.assertEquals(entry.getRecords().get(0).getFaceId(), decoded.getRecords().get(0).getFaceId());
		Assert.assertEquals(entry.getRecords().get(0).getCost(), decoded.getRecords().get(0).getCost());
	}

	/**
	 * Integration test to run on actual system
	 *
	 * @param args
	 * @throws EncodingException
	 */
	public static void main(String[] args) throws Exception {
		Face forwarder = new Face("localhost");

		// build management Interest packet; see http://redmine.named-data.net/projects/nfd/wiki/StatusDataset
		Interest interest = new Interest(new Name("/localhost/nfd/fib/list"));
		interest.setMustBeFresh(true);
		interest.setChildSelector(Interest.CHILD_SELECTOR_RIGHT);
		interest.setInterestLifetimeMilliseconds(2000.0);

		// send packet
		Data data = Client.getDefault().getSync(forwarder, interest);

		// decode results
		List<FibEntry> results = StatusDataset.wireDecode(data.getContent(), FibEntry.class);
		assertTrue(results.size() > 0);
		assertEquals("/localhost/nfd", results.get(0).getName().toUri());
	}
}