TestRegisterRoute.java

/**
 * Copyright (C) 2015-2018 Regents of the University of California.
 * @author: Jeff Thompson <jefft0@remap.ucla.edu>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 * A copy of the GNU Lesser General Public License is in the file COPYING.
 */

package net.named_data.jndn.tests;

import com.google.protobuf.ByteString;
import java.nio.ByteBuffer;
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.OnData;
import net.named_data.jndn.OnTimeout;
import net.named_data.jndn.encoding.EncodingException;
import net.named_data.jndn.encoding.ProtobufTlv;
import net.named_data.jndn.security.KeyChain;
import net.named_data.jndn.security.KeyType;
import net.named_data.jndn.security.identity.IdentityManager;
import net.named_data.jndn.security.identity.MemoryIdentityStorage;
import net.named_data.jndn.security.identity.MemoryPrivateKeyStorage;
import net.named_data.jndn.security.policy.SelfVerifyPolicyManager;
import net.named_data.jndn.util.Blob;
import net.named_data.jndn.tests.FaceQueryFilterProto.FaceQueryFilterMessage;
import net.named_data.jndn.tests.FaceStatusProto.FaceStatusMessage;
import net.named_data.jndn.tests.ControlParametersProto.ControlParametersTypes;
import net.named_data.jndn.tests.ControlParametersProto.ControlParametersTypes.ControlParametersMessage;
import net.named_data.jndn.tests.ControlParametersProto.ControlParametersTypes.ControlParametersResponseMessage;
import net.named_data.jndn.tests.ControlParametersProto.ControlParametersTypes.ControlParametersResponse;
import net.named_data.jndn.util.SegmentFetcher;

/**
 * This sends a /localhost/nfd/faces/query command to the local NFD to get the
 * face ID for a face url, and creates the face if it doesn't exist. Then this sends
 * a /localhost/nfd/rib/register command to register a prefix to the face ID.
 * This is equivalent to the NFD command line command "nfdc register".
 * See http://redmine.named-data.net/projects/nfd/wiki/Management .
 */
public class TestRegisterRoute {
  // Convert the int array to a ByteBuffer.
  private static ByteBuffer
  toBuffer(int[] array)
  {
    ByteBuffer result = ByteBuffer.allocate(array.length);
    for (int i = 0; i < array.length; ++i)
      result.put((byte)(array[i] & 0xff));

    result.flip();
    return result;
  }

  private static final ByteBuffer DEFAULT_RSA_PUBLIC_KEY_DER = toBuffer(new int[] {
    0x30, 0x82, 0x01, 0x22, 0x30, 0x0d, 0x06, 0x09, 0x2a, 0x86, 0x48, 0x86, 0xf7, 0x0d, 0x01, 0x01,
    0x01, 0x05, 0x00, 0x03, 0x82, 0x01, 0x0f, 0x00, 0x30, 0x82, 0x01, 0x0a, 0x02, 0x82, 0x01, 0x01,
    0x00, 0xb8, 0x09, 0xa7, 0x59, 0x82, 0x84, 0xec, 0x4f, 0x06, 0xfa, 0x1c, 0xb2, 0xe1, 0x38, 0x93,
    0x53, 0xbb, 0x7d, 0xd4, 0xac, 0x88, 0x1a, 0xf8, 0x25, 0x11, 0xe4, 0xfa, 0x1d, 0x61, 0x24, 0x5b,
    0x82, 0xca, 0xcd, 0x72, 0xce, 0xdb, 0x66, 0xb5, 0x8d, 0x54, 0xbd, 0xfb, 0x23, 0xfd, 0xe8, 0x8e,
    0xaf, 0xa7, 0xb3, 0x79, 0xbe, 0x94, 0xb5, 0xb7, 0xba, 0x17, 0xb6, 0x05, 0xae, 0xce, 0x43, 0xbe,
    0x3b, 0xce, 0x6e, 0xea, 0x07, 0xdb, 0xbf, 0x0a, 0x7e, 0xeb, 0xbc, 0xc9, 0x7b, 0x62, 0x3c, 0xf5,
    0xe1, 0xce, 0xe1, 0xd9, 0x8d, 0x9c, 0xfe, 0x1f, 0xc7, 0xf8, 0xfb, 0x59, 0xc0, 0x94, 0x0b, 0x2c,
    0xd9, 0x7d, 0xbc, 0x96, 0xeb, 0xb8, 0x79, 0x22, 0x8a, 0x2e, 0xa0, 0x12, 0x1d, 0x42, 0x07, 0xb6,
    0x5d, 0xdb, 0xe1, 0xf6, 0xb1, 0x5d, 0x7b, 0x1f, 0x54, 0x52, 0x1c, 0xa3, 0x11, 0x9b, 0xf9, 0xeb,
    0xbe, 0xb3, 0x95, 0xca, 0xa5, 0x87, 0x3f, 0x31, 0x18, 0x1a, 0xc9, 0x99, 0x01, 0xec, 0xaa, 0x90,
    0xfd, 0x8a, 0x36, 0x35, 0x5e, 0x12, 0x81, 0xbe, 0x84, 0x88, 0xa1, 0x0d, 0x19, 0x2a, 0x4a, 0x66,
    0xc1, 0x59, 0x3c, 0x41, 0x83, 0x3d, 0x3d, 0xb8, 0xd4, 0xab, 0x34, 0x90, 0x06, 0x3e, 0x1a, 0x61,
    0x74, 0xbe, 0x04, 0xf5, 0x7a, 0x69, 0x1b, 0x9d, 0x56, 0xfc, 0x83, 0xb7, 0x60, 0xc1, 0x5e, 0x9d,
    0x85, 0x34, 0xfd, 0x02, 0x1a, 0xba, 0x2c, 0x09, 0x72, 0xa7, 0x4a, 0x5e, 0x18, 0xbf, 0xc0, 0x58,
    0xa7, 0x49, 0x34, 0x46, 0x61, 0x59, 0x0e, 0xe2, 0x6e, 0x9e, 0xd2, 0xdb, 0xfd, 0x72, 0x2f, 0x3c,
    0x47, 0xcc, 0x5f, 0x99, 0x62, 0xee, 0x0d, 0xf3, 0x1f, 0x30, 0x25, 0x20, 0x92, 0x15, 0x4b, 0x04,
    0xfe, 0x15, 0x19, 0x1d, 0xdc, 0x7e, 0x5c, 0x10, 0x21, 0x52, 0x21, 0x91, 0x54, 0x60, 0x8b, 0x92,
    0x41, 0x02, 0x03, 0x01, 0x00, 0x01
  });

  // Java uses an unencrypted PKCS #8 PrivateKeyInfo, not a PKCS #1 RSAPrivateKey.
  private static final ByteBuffer DEFAULT_RSA_PRIVATE_KEY_DER = toBuffer(new int[] {
    0x30, 0x82, 0x04, 0xbf, 0x02, 0x01, 0x00, 0x30, 0x0d, 0x06, 0x09, 0x2a, 0x86, 0x48, 0x86, 0xf7,
    0x0d, 0x01, 0x01, 0x01, 0x05, 0x00, 0x04, 0x82, 0x04, 0xa9, 0x30, 0x82, 0x04, 0xa5, 0x02, 0x01,
    0x00, 0x02, 0x82, 0x01, 0x01, 0x00, 0xb8, 0x09, 0xa7, 0x59, 0x82, 0x84, 0xec, 0x4f, 0x06, 0xfa,
    0x1c, 0xb2, 0xe1, 0x38, 0x93, 0x53, 0xbb, 0x7d, 0xd4, 0xac, 0x88, 0x1a, 0xf8, 0x25, 0x11, 0xe4,
    0xfa, 0x1d, 0x61, 0x24, 0x5b, 0x82, 0xca, 0xcd, 0x72, 0xce, 0xdb, 0x66, 0xb5, 0x8d, 0x54, 0xbd,
    0xfb, 0x23, 0xfd, 0xe8, 0x8e, 0xaf, 0xa7, 0xb3, 0x79, 0xbe, 0x94, 0xb5, 0xb7, 0xba, 0x17, 0xb6,
    0x05, 0xae, 0xce, 0x43, 0xbe, 0x3b, 0xce, 0x6e, 0xea, 0x07, 0xdb, 0xbf, 0x0a, 0x7e, 0xeb, 0xbc,
    0xc9, 0x7b, 0x62, 0x3c, 0xf5, 0xe1, 0xce, 0xe1, 0xd9, 0x8d, 0x9c, 0xfe, 0x1f, 0xc7, 0xf8, 0xfb,
    0x59, 0xc0, 0x94, 0x0b, 0x2c, 0xd9, 0x7d, 0xbc, 0x96, 0xeb, 0xb8, 0x79, 0x22, 0x8a, 0x2e, 0xa0,
    0x12, 0x1d, 0x42, 0x07, 0xb6, 0x5d, 0xdb, 0xe1, 0xf6, 0xb1, 0x5d, 0x7b, 0x1f, 0x54, 0x52, 0x1c,
    0xa3, 0x11, 0x9b, 0xf9, 0xeb, 0xbe, 0xb3, 0x95, 0xca, 0xa5, 0x87, 0x3f, 0x31, 0x18, 0x1a, 0xc9,
    0x99, 0x01, 0xec, 0xaa, 0x90, 0xfd, 0x8a, 0x36, 0x35, 0x5e, 0x12, 0x81, 0xbe, 0x84, 0x88, 0xa1,
    0x0d, 0x19, 0x2a, 0x4a, 0x66, 0xc1, 0x59, 0x3c, 0x41, 0x83, 0x3d, 0x3d, 0xb8, 0xd4, 0xab, 0x34,
    0x90, 0x06, 0x3e, 0x1a, 0x61, 0x74, 0xbe, 0x04, 0xf5, 0x7a, 0x69, 0x1b, 0x9d, 0x56, 0xfc, 0x83,
    0xb7, 0x60, 0xc1, 0x5e, 0x9d, 0x85, 0x34, 0xfd, 0x02, 0x1a, 0xba, 0x2c, 0x09, 0x72, 0xa7, 0x4a,
    0x5e, 0x18, 0xbf, 0xc0, 0x58, 0xa7, 0x49, 0x34, 0x46, 0x61, 0x59, 0x0e, 0xe2, 0x6e, 0x9e, 0xd2,
    0xdb, 0xfd, 0x72, 0x2f, 0x3c, 0x47, 0xcc, 0x5f, 0x99, 0x62, 0xee, 0x0d, 0xf3, 0x1f, 0x30, 0x25,
    0x20, 0x92, 0x15, 0x4b, 0x04, 0xfe, 0x15, 0x19, 0x1d, 0xdc, 0x7e, 0x5c, 0x10, 0x21, 0x52, 0x21,
    0x91, 0x54, 0x60, 0x8b, 0x92, 0x41, 0x02, 0x03, 0x01, 0x00, 0x01, 0x02, 0x82, 0x01, 0x01, 0x00,
    0x8a, 0x05, 0xfb, 0x73, 0x7f, 0x16, 0xaf, 0x9f, 0xa9, 0x4c, 0xe5, 0x3f, 0x26, 0xf8, 0x66, 0x4d,
    0xd2, 0xfc, 0xd1, 0x06, 0xc0, 0x60, 0xf1, 0x9f, 0xe3, 0xa6, 0xc6, 0x0a, 0x48, 0xb3, 0x9a, 0xca,
    0x21, 0xcd, 0x29, 0x80, 0x88, 0x3d, 0xa4, 0x85, 0xa5, 0x7b, 0x82, 0x21, 0x81, 0x28, 0xeb, 0xf2,
    0x43, 0x24, 0xb0, 0x76, 0xc5, 0x52, 0xef, 0xc2, 0xea, 0x4b, 0x82, 0x41, 0x92, 0xc2, 0x6d, 0xa6,
    0xae, 0xf0, 0xb2, 0x26, 0x48, 0xa1, 0x23, 0x7f, 0x02, 0xcf, 0xa8, 0x90, 0x17, 0xa2, 0x3e, 0x8a,
    0x26, 0xbd, 0x6d, 0x8a, 0xee, 0xa6, 0x0c, 0x31, 0xce, 0xc2, 0xbb, 0x92, 0x59, 0xb5, 0x73, 0xe2,
    0x7d, 0x91, 0x75, 0xe2, 0xbd, 0x8c, 0x63, 0xe2, 0x1c, 0x8b, 0xc2, 0x6a, 0x1c, 0xfe, 0x69, 0xc0,
    0x44, 0xcb, 0x58, 0x57, 0xb7, 0x13, 0x42, 0xf0, 0xdb, 0x50, 0x4c, 0xe0, 0x45, 0x09, 0x8f, 0xca,
    0x45, 0x8a, 0x06, 0xfe, 0x98, 0xd1, 0x22, 0xf5, 0x5a, 0x9a, 0xdf, 0x89, 0x17, 0xca, 0x20, 0xcc,
    0x12, 0xa9, 0x09, 0x3d, 0xd5, 0xf7, 0xe3, 0xeb, 0x08, 0x4a, 0xc4, 0x12, 0xc0, 0xb9, 0x47, 0x6c,
    0x79, 0x50, 0x66, 0xa3, 0xf8, 0xaf, 0x2c, 0xfa, 0xb4, 0x6b, 0xec, 0x03, 0xad, 0xcb, 0xda, 0x24,
    0x0c, 0x52, 0x07, 0x87, 0x88, 0xc0, 0x21, 0xf3, 0x02, 0xe8, 0x24, 0x44, 0x0f, 0xcd, 0xa0, 0xad,
    0x2f, 0x1b, 0x79, 0xab, 0x6b, 0x49, 0x4a, 0xe6, 0x3b, 0xd0, 0xad, 0xc3, 0x48, 0xb9, 0xf7, 0xf1,
    0x34, 0x09, 0xeb, 0x7a, 0xc0, 0xd5, 0x0d, 0x39, 0xd8, 0x45, 0xce, 0x36, 0x7a, 0xd8, 0xde, 0x3c,
    0xb0, 0x21, 0x96, 0x97, 0x8a, 0xff, 0x8b, 0x23, 0x60, 0x4f, 0xf0, 0x3d, 0xd7, 0x8f, 0xf3, 0x2c,
    0xcb, 0x1d, 0x48, 0x3f, 0x86, 0xc4, 0xa9, 0x00, 0xf2, 0x23, 0x2d, 0x72, 0x4d, 0x66, 0xa5, 0x01,
    0x02, 0x81, 0x81, 0x00, 0xdc, 0x4f, 0x99, 0x44, 0x0d, 0x7f, 0x59, 0x46, 0x1e, 0x8f, 0xe7, 0x2d,
    0x8d, 0xdd, 0x54, 0xc0, 0xf7, 0xfa, 0x46, 0x0d, 0x9d, 0x35, 0x03, 0xf1, 0x7c, 0x12, 0xf3, 0x5a,
    0x9d, 0x83, 0xcf, 0xdd, 0x37, 0x21, 0x7c, 0xb7, 0xee, 0xc3, 0x39, 0xd2, 0x75, 0x8f, 0xb2, 0x2d,
    0x6f, 0xec, 0xc6, 0x03, 0x55, 0xd7, 0x00, 0x67, 0xd3, 0x9b, 0xa2, 0x68, 0x50, 0x6f, 0x9e, 0x28,
    0xa4, 0x76, 0x39, 0x2b, 0xb2, 0x65, 0xcc, 0x72, 0x82, 0x93, 0xa0, 0xcf, 0x10, 0x05, 0x6a, 0x75,
    0xca, 0x85, 0x35, 0x99, 0xb0, 0xa6, 0xc6, 0xef, 0x4c, 0x4d, 0x99, 0x7d, 0x2c, 0x38, 0x01, 0x21,
    0xb5, 0x31, 0xac, 0x80, 0x54, 0xc4, 0x18, 0x4b, 0xfd, 0xef, 0xb3, 0x30, 0x22, 0x51, 0x5a, 0xea,
    0x7d, 0x9b, 0xb2, 0x9d, 0xcb, 0xba, 0x3f, 0xc0, 0x1a, 0x6b, 0xcd, 0xb0, 0xe6, 0x2f, 0x04, 0x33,
    0xd7, 0x3a, 0x49, 0x71, 0x02, 0x81, 0x81, 0x00, 0xd5, 0xd9, 0xc9, 0x70, 0x1a, 0x13, 0xb3, 0x39,
    0x24, 0x02, 0xee, 0xb0, 0xbb, 0x84, 0x17, 0x12, 0xc6, 0xbd, 0x65, 0x73, 0xe9, 0x34, 0x5d, 0x43,
    0xff, 0xdc, 0xf8, 0x55, 0xaf, 0x2a, 0xb9, 0xe1, 0xfa, 0x71, 0x65, 0x4e, 0x50, 0x0f, 0xa4, 0x3b,
    0xe5, 0x68, 0xf2, 0x49, 0x71, 0xaf, 0x15, 0x88, 0xd7, 0xaf, 0xc4, 0x9d, 0x94, 0x84, 0x6b, 0x5b,
    0x10, 0xd5, 0xc0, 0xaa, 0x0c, 0x13, 0x62, 0x99, 0xc0, 0x8b, 0xfc, 0x90, 0x0f, 0x87, 0x40, 0x4d,
    0x58, 0x88, 0xbd, 0xe2, 0xba, 0x3e, 0x7e, 0x2d, 0xd7, 0x69, 0xa9, 0x3c, 0x09, 0x64, 0x31, 0xb6,
    0xcc, 0x4d, 0x1f, 0x23, 0xb6, 0x9e, 0x65, 0xd6, 0x81, 0xdc, 0x85, 0xcc, 0x1e, 0xf1, 0x0b, 0x84,
    0x38, 0xab, 0x93, 0x5f, 0x9f, 0x92, 0x4e, 0x93, 0x46, 0x95, 0x6b, 0x3e, 0xb6, 0xc3, 0x1b, 0xd7,
    0x69, 0xa1, 0x0a, 0x97, 0x37, 0x78, 0xed, 0xd1, 0x02, 0x81, 0x80, 0x33, 0x18, 0xc3, 0x13, 0x65,
    0x8e, 0x03, 0xc6, 0x9f, 0x90, 0x00, 0xae, 0x30, 0x19, 0x05, 0x6f, 0x3c, 0x14, 0x6f, 0xea, 0xf8,
    0x6b, 0x33, 0x5e, 0xee, 0xc7, 0xf6, 0x69, 0x2d, 0xdf, 0x44, 0x76, 0xaa, 0x32, 0xba, 0x1a, 0x6e,
    0xe6, 0x18, 0xa3, 0x17, 0x61, 0x1c, 0x92, 0x2d, 0x43, 0x5d, 0x29, 0xa8, 0xdf, 0x14, 0xd8, 0xff,
    0xdb, 0x38, 0xef, 0xb8, 0xb8, 0x2a, 0x96, 0x82, 0x8e, 0x68, 0xf4, 0x19, 0x8c, 0x42, 0xbe, 0xcc,
    0x4a, 0x31, 0x21, 0xd5, 0x35, 0x6c, 0x5b, 0xa5, 0x7c, 0xff, 0xd1, 0x85, 0x87, 0x28, 0xdc, 0x97,
    0x75, 0xe8, 0x03, 0x80, 0x1d, 0xfd, 0x25, 0x34, 0x41, 0x31, 0x21, 0x12, 0x87, 0xe8, 0x9a, 0xb7,
    0x6a, 0xc0, 0xc4, 0x89, 0x31, 0x15, 0x45, 0x0d, 0x9c, 0xee, 0xf0, 0x6a, 0x2f, 0xe8, 0x59, 0x45,
    0xc7, 0x7b, 0x0d, 0x6c, 0x55, 0xbb, 0x43, 0xca, 0xc7, 0x5a, 0x01, 0x02, 0x81, 0x81, 0x00, 0xab,
    0xf4, 0xd5, 0xcf, 0x78, 0x88, 0x82, 0xc2, 0xdd, 0xbc, 0x25, 0xe6, 0xa2, 0xc1, 0xd2, 0x33, 0xdc,
    0xef, 0x0a, 0x97, 0x2b, 0xdc, 0x59, 0x6a, 0x86, 0x61, 0x4e, 0xa6, 0xc7, 0x95, 0x99, 0xa6, 0xa6,
    0x55, 0x6c, 0x5a, 0x8e, 0x72, 0x25, 0x63, 0xac, 0x52, 0xb9, 0x10, 0x69, 0x83, 0x99, 0xd3, 0x51,
    0x6c, 0x1a, 0xb3, 0x83, 0x6a, 0xff, 0x50, 0x58, 0xb7, 0x28, 0x97, 0x13, 0xe2, 0xba, 0x94, 0x5b,
    0x89, 0xb4, 0xea, 0xba, 0x31, 0xcd, 0x78, 0xe4, 0x4a, 0x00, 0x36, 0x42, 0x00, 0x62, 0x41, 0xc6,
    0x47, 0x46, 0x37, 0xea, 0x6d, 0x50, 0xb4, 0x66, 0x8f, 0x55, 0x0c, 0xc8, 0x99, 0x91, 0xd5, 0xec,
    0xd2, 0x40, 0x1c, 0x24, 0x7d, 0x3a, 0xff, 0x74, 0xfa, 0x32, 0x24, 0xe0, 0x11, 0x2b, 0x71, 0xad,
    0x7e, 0x14, 0xa0, 0x77, 0x21, 0x68, 0x4f, 0xcc, 0xb6, 0x1b, 0xe8, 0x00, 0x49, 0x13, 0x21, 0x02,
    0x81, 0x81, 0x00, 0xb6, 0x18, 0x73, 0x59, 0x2c, 0x4f, 0x92, 0xac, 0xa2, 0x2e, 0x5f, 0xb6, 0xbe,
    0x78, 0x5d, 0x47, 0x71, 0x04, 0x92, 0xf0, 0xd7, 0xe8, 0xc5, 0x7a, 0x84, 0x6b, 0xb8, 0xb4, 0x30,
    0x1f, 0xd8, 0x0d, 0x58, 0xd0, 0x64, 0x80, 0xa7, 0x21, 0x1a, 0x48, 0x00, 0x37, 0xd6, 0x19, 0x71,
    0xbb, 0x91, 0x20, 0x9d, 0xe2, 0xc3, 0xec, 0xdb, 0x36, 0x1c, 0xca, 0x48, 0x7d, 0x03, 0x32, 0x74,
    0x1e, 0x65, 0x73, 0x02, 0x90, 0x73, 0xd8, 0x3f, 0xb5, 0x52, 0x35, 0x79, 0x1c, 0xee, 0x93, 0xa3,
    0x32, 0x8b, 0xed, 0x89, 0x98, 0xf1, 0x0c, 0xd8, 0x12, 0xf2, 0x89, 0x7f, 0x32, 0x23, 0xec, 0x67,
    0x66, 0x52, 0x83, 0x89, 0x99, 0x5e, 0x42, 0x2b, 0x42, 0x4b, 0x84, 0x50, 0x1b, 0x3e, 0x47, 0x6d,
    0x74, 0xfb, 0xd1, 0xa6, 0x10, 0x20, 0x6c, 0x6e, 0xbe, 0x44, 0x3f, 0xb9, 0xfe, 0xbc, 0x8d, 0xda,
    0xcb, 0xea, 0x8f
  });

  public static void
  main(String[] args) throws EncodingException
  {
    try {
      // Silence the warning from Interest wire encode.
      Interest.setDefaultCanBePrefix(true);

      final Name prefix = new Name("/nfd/edu/ucla/remap/test");
      // Route to aleph.ndn.ucla.edu.  Have to use the canonical name with
      // an IP address and port.
      final String uri = "udp4://128.97.98.7:6363";

      // The default Face connects to the local NFD.
      final Face face = new Face();

      // For now, when setting face.setCommandSigningInfo, use a key chain with
      //   a default private key instead of the system default key chain. This
      //   is OK for now because NFD is configured to skip verification, so it
      //   ignores the system default key chain.
      // On a platform which supports it, it would be better to use the default
      //   KeyChain constructor.
      MemoryIdentityStorage identityStorage = new MemoryIdentityStorage();
      MemoryPrivateKeyStorage privateKeyStorage = new MemoryPrivateKeyStorage();
      KeyChain keyChain = new KeyChain
        (new IdentityManager(identityStorage, privateKeyStorage),
         new SelfVerifyPolicyManager(identityStorage));
      keyChain.setFace(face);

      // Initialize the storage.
      Name keyName = new Name("/testname/DSK-123");
      Name certificateName = keyName.getSubName(0, keyName.size() - 1).append
        ("KEY").append(keyName.get(-1)).append("ID-CERT").append("0");
      identityStorage.addKey(keyName, KeyType.RSA, new Blob(DEFAULT_RSA_PUBLIC_KEY_DER, false));
      privateKeyStorage.setKeyPairForKeyName
        (keyName, KeyType.RSA, DEFAULT_RSA_PUBLIC_KEY_DER, DEFAULT_RSA_PRIVATE_KEY_DER);

      face.setCommandSigningInfo(keyChain, certificateName);

      // Create the /localhost/nfd/faces/query command interest, including the
      // FaceQueryFilter. Construct the FaceQueryFilter using the structure in
      // FaceQueryFilterProto.java which was produced by protoc.
      FaceQueryFilterMessage.Builder builder = FaceQueryFilterMessage.newBuilder();
      FaceQueryFilterMessage.FaceQueryFilter.Builder filterBuilder =
        builder.addFaceQueryFilterBuilder();
      filterBuilder.setUri(uri);
      Blob encodedFilter = ProtobufTlv.encode(builder.build());

      Interest interest = new Interest(new Name("/localhost/nfd/faces/query"));
      interest.getName().append(encodedFilter);

      final boolean[] enabled = new boolean[] { true };
      SegmentFetcher.fetch
        (face, interest, (KeyChain)null,
         new SegmentFetcher.OnComplete() {
           public void onComplete(Blob content) {
             processFaceStatus(content, prefix, uri, face, enabled);
           }},
         new SegmentFetcher.OnError() {
           public void onError(SegmentFetcher.ErrorCode errorCode, String message) {
             enabled[0] = false;
             System.out.println(message);
           }});

      // Loop calling processEvents until a callback sets enabled[0] = false.
      while (enabled[0]) {
        face.processEvents();

        // We need to sleep for a few milliseconds so we don't use 100% of
        //   the CPU.
        Thread.sleep(5);
      }
    }
    catch (Exception e) {
      System.out.println("exception: " + e.getMessage());
    }
  }

  /**
   * This is called when all the segments are received to decode the
   * encodedFaceStatus as a TLV FaceStatus message. If the face ID exists for
   * the face URL, use it to call registerRoute(), otherwise send a
   * /localhost/nfd/faces/create command to create the face.
   * @param encodedFaceStatus The TLV-encoded FaceStatus.
   * @param prefix The prefix name to register.
   * @param uri The remote URI in case we need to tell NFD to create a face.
   * @param face The Face which is used to sign the command interest and call
   * expressInterest.
   * @param enabled On success or error, set enabled[0] = false.
   */
  private static void
  processFaceStatus
    (Blob encodedFaceStatus, final Name prefix, String uri, final Face face,
     final boolean[] enabled)
  {
    try {
      if (encodedFaceStatus.size() == 0) {
        // No result, so we need to tell NFD to create the face.
        // Encode the ControlParameters.
        ControlParametersMessage.Builder builder = ControlParametersMessage.newBuilder();
        builder.getControlParametersBuilder().setUri(uri);
        Blob encodedControlParameters = ProtobufTlv.encode(builder.build());

        Interest interest = new Interest(new Name("/localhost/nfd/faces/create"));
        interest.getName().append(encodedControlParameters);
        interest.setInterestLifetimeMilliseconds(10000);

        // Sign and express the interest.
        face.makeCommandInterest(interest);
        face.expressInterest
          (interest,
           new OnData() {
             public void onData(Interest interest, Data data) {
               processCreateFaceResponse(data.getContent(), prefix, face, enabled);
             }},
           new OnTimeout() {
             public void onTimeout(Interest interest) {
               enabled[0] = false;
               System.out.println("Face create command timed out.");
             }});
      }
      else {
        FaceStatusMessage.Builder decodedFaceStatus = FaceStatusMessage.newBuilder();
        ProtobufTlv.decode(decodedFaceStatus, encodedFaceStatus);

        long faceId = decodedFaceStatus.getFaceStatus(0).getFaceId();

        System.out.println("Found face ID " + faceId);
        registerRoute(prefix, faceId, face, enabled);
      }
    }
    catch (Exception e) {
      System.out.println("exception: " + e.getMessage());
      enabled[0] = false;
    }
  }

  /**
   * This is called when the face create command responds to decode the
   * encodedControlResonse as a TLV ControlResponse message containing one
   * ControlParameters. Get the face ID and call registerRoute().
   * @param encodedControlResponse The TLV-encoded ControlResponse.
   * @param prefix The prefix name to register.
   * @param face The Face which is used to sign the command interest and call
   * expressInterest.
   * @param enabled On success or error, set enabled[0] = false.
   */
  private static void
  processCreateFaceResponse
    (Blob encodedControlResponse, Name prefix, Face face, final boolean[] enabled)
  {
    try {
      ControlParametersResponseMessage.Builder decodedControlResponse =
        ControlParametersResponseMessage.newBuilder();
      ProtobufTlv.decode(decodedControlResponse, encodedControlResponse);
      ControlParametersResponse controlResponse =
        decodedControlResponse.getControlResponse();

      final int lowestErrorCode = 400;
      if (controlResponse.getStatusCode() >= lowestErrorCode) {
        System.out.println
          ("Face create command got error, code " + controlResponse.getStatusCode() +
           ": " + controlResponse.getStatusText());
        enabled[0] = false;
        return;
      }
      if (controlResponse.getControlParametersCount() != 1) {
        System.out.println
          ("Face create command response does not have one ControlParameters");
        enabled[0] = false;
        return;
      }

      long faceId = controlResponse.getControlParameters(0).getFaceId();

      System.out.println("Created face ID " + faceId);
      registerRoute(prefix, faceId, face, enabled);
    }
    catch (Exception e) {
      System.out.println("exception: " + e.getMessage());
      enabled[0] = false;
    }
  }

  /**
   * Use /localhost/nfd/rib/register to register the prefix to the faceId.
   * @param prefix The prefix name to register.
   * @param faceId The face ID.
   * @param face The Face which is used to sign the command interest and call
   * expressInterest.
   * @param enabled On success or error, set enabled[0] = false.
   */
  private static void
  registerRoute(Name prefix, long faceId, Face face, final boolean[] enabled)
  {
    // Use default values;
    long origin = 255;
    long cost = 0;
    final long CHILD_INHERIT = 1;
    long flags = CHILD_INHERIT;

    try {
      ControlParametersMessage.Builder builder = ControlParametersMessage.newBuilder();
      ControlParametersTypes.Name.Builder nameBuilder =
        builder.getControlParametersBuilder().getNameBuilder();
      for (int i = 0; i < prefix.size(); ++i)
        nameBuilder.addComponent(ByteString.copyFrom(prefix.get(i).getValue().buf()));
      builder.getControlParametersBuilder().setFaceId(faceId);
      builder.getControlParametersBuilder().setOrigin(origin);
      builder.getControlParametersBuilder().setCost(cost);
      builder.getControlParametersBuilder().setFlags(flags);
      Blob encodedControlParameters = ProtobufTlv.encode(builder.build());

      Interest interest = new Interest(new Name("/localhost/nfd/rib/register"));
      interest.getName().append(encodedControlParameters);
      interest.setInterestLifetimeMilliseconds(10000);

      // Sign and express the interest.
      face.makeCommandInterest(interest);
      face.expressInterest
        (interest,
         new OnData() {
           public void onData(Interest interest, Data data) {
             enabled[0] = false;
             processRegisterResponse(data.getContent());
           }},
         new OnTimeout() {
           public void onTimeout(Interest interest) {
             enabled[0] = false;
             System.out.println("Register route command timed out.");
           }});
    }
    catch (Exception e) {
      System.out.println("exception: " + e.getMessage());
      enabled[0] = false;
    }
  }

  /**
   * This is called when the register route command responds to decode the
   * encodedControlResponse as a TLV ControlParametersResponse message
   * containing one ControlParameters. On success, print the ControlParameters
   * values which should be the same as requested.
   * @param encodedControlResponse The TLV-encoded ControlParametersResponse.
   */
  private static void
  processRegisterResponse(Blob encodedControlResponse)
  {
    try {
      ControlParametersResponseMessage.Builder decodedControlResponse =
        ControlParametersResponseMessage.newBuilder();
      ProtobufTlv.decode(decodedControlResponse, encodedControlResponse);
      ControlParametersResponse controlResponse =
        decodedControlResponse.getControlResponse();

      final int lowestErrorCode = 400;
      if (controlResponse.getStatusCode() >= lowestErrorCode) {
        System.out.println
          ("Face create command got error, code " + controlResponse.getStatusCode() +
           ": " + controlResponse.getStatusText());
        return;
      }
      if (controlResponse.getControlParametersCount() != 1) {
        System.out.println
          ("Face create command response does not have one ControlParameters");
        return;
      }

      // Success. Print the ControlParameters response.
      ControlParametersTypes.ControlParameters controlParameters =
        controlResponse.getControlParameters(0);
      System.out.println
        ("Successful in name registration: ControlParameters(Name: " +
         ProtobufTlv.toName(controlParameters.getName()).toUri() +
         ", FaceId: " + controlParameters.getFaceId() +
         ", Origin: " + controlParameters.getOrigin() +
         ", Cost: " + controlParameters.getCost() +
         ", Flags: " + controlParameters.getFlags() + ")");
    }
    catch (Exception e) {
      System.out.println("exception: " + e.getMessage());
    }
  }
}