import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public IqPacket publishBundles(final SignedPreKeyRecord signedPreKeyRecord, final IdentityKey identityKey,
                               final Set<PreKeyRecord> preKeyRecords, final int deviceId) {
	final Element item = new Element("item");
	final Element bundle = item.addChild("bundle", AxolotlService.PEP_PREFIX);
	final Element signedPreKeyPublic = bundle.addChild("signedPreKeyPublic");
	signedPreKeyPublic.setAttribute("signedPreKeyId", signedPreKeyRecord.getId());
	ECPublicKey publicKey = signedPreKeyRecord.getKeyPair().getPublicKey();
	signedPreKeyPublic.setContent(Base64.encodeToString(publicKey.serialize(),Base64.DEFAULT));
	final Element signedPreKeySignature = bundle.addChild("signedPreKeySignature");
	signedPreKeySignature.setContent(Base64.encodeToString(signedPreKeyRecord.getSignature(),Base64.DEFAULT));
	final Element identityKeyElement = bundle.addChild("identityKey");
	identityKeyElement.setContent(Base64.encodeToString(identityKey.serialize(), Base64.DEFAULT));

	final Element prekeys = bundle.addChild("prekeys", AxolotlService.PEP_PREFIX);
	for(PreKeyRecord preKeyRecord:preKeyRecords) {
		final Element prekey = prekeys.addChild("preKeyPublic");
		prekey.setAttribute("preKeyId", preKeyRecord.getId());
		prekey.setContent(Base64.encodeToString(preKeyRecord.getKeyPair().getPublicKey().serialize(), Base64.DEFAULT));
	}

	return publish(AxolotlService.PEP_BUNDLES+":"+deviceId, item);
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public Set<IdentityKey> loadIdentityKeys(Account account, String name, XmppAxolotlSession.Trust trust) {
	Set<IdentityKey> identityKeys = new HashSet<>();
	Cursor cursor = getIdentityKeyCursor(account, name, false);

	while (cursor.moveToNext()) {
		if (trust != null &&
				cursor.getInt(cursor.getColumnIndex(SQLiteAxolotlStore.TRUSTED))
						!= trust.getCode()) {
			continue;
		}
		try {
			identityKeys.add(new IdentityKey(Base64.decode(cursor.getString(cursor.getColumnIndex(SQLiteAxolotlStore.KEY)), Base64.DEFAULT), 0));
		} catch (InvalidKeyException e) {
			Log.d(Config.LOGTAG, AxolotlService.getLogprefix(account) + "Encountered invalid IdentityKey in database for account" + account.getJid().toBareJid() + ", address: " + name);
		}
	}
	cursor.close();

	return identityKeys;
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private IdentityKey getIdentityKey(IncomingKeyExchangeMessage message)
    throws InvalidKeyException, InvalidVersionException,
           InvalidMessageException, LegacyMessageException
{
  try {
    if (message.isIdentityUpdate()) {
      return new IdentityKey(Base64.decodeWithoutPadding(message.getMessageBody()), 0);
    } else if (message.isPreKeyBundle()) {
      boolean isPush = getIntent().getBooleanExtra("is_push", false);

      if (isPush) return new PreKeyWhisperMessage(Base64.decode(message.getMessageBody())).getIdentityKey();
      else        return new PreKeyWhisperMessage(Base64.decodeWithoutPadding(message.getMessageBody())).getIdentityKey();
    } else {
      return new KeyExchangeMessage(Base64.decodeWithoutPadding(message.getMessageBody())).getIdentityKey();
    }
  } catch (IOException e) {
    throw new AssertionError(e);
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public void saveIdentity(MasterSecret masterSecret, long recipientId, IdentityKey identityKey)
{
  SQLiteDatabase database   = databaseHelper.getWritableDatabase();
  MasterCipher masterCipher = new MasterCipher(masterSecret);
  String identityKeyString  = Base64.encodeBytes(identityKey.serialize());
  String macString          = Base64.encodeBytes(masterCipher.getMacFor(recipientId +
                                                                            identityKeyString));

  ContentValues contentValues = new ContentValues();
  contentValues.put(RECIPIENT, recipientId);
  contentValues.put(IDENTITY_KEY, identityKeyString);
  contentValues.put(MAC, macString);

  database.replace(TABLE_NAME, null, contentValues);

  context.getContentResolver().notifyChange(CHANGE_URI, null);
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private void initializeRemoteIdentityKey() {
  IdentityKeyParcelable identityKeyParcelable = getIntent().getParcelableExtra("remote_identity");
  IdentityKey           identityKey           = null;

  if (identityKeyParcelable != null) {
    identityKey = identityKeyParcelable.get();
  }

  if (identityKey == null) {
    identityKey = getRemoteIdentityKey(masterSecret, recipient);
  }

  if (identityKey == null) {
    remoteIdentityFingerprint.setText(R.string.VerifyIdentityActivity_recipient_has_no_identity_key);
  } else {
    remoteIdentityFingerprint.setText(identityKey.getFingerprint());
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public static IdentityKeyPair getIdentityKeyPair(Context context,
                                                 MasterSecret masterSecret)
{
  if (!hasIdentityKey(context))
    return null;

  try {
    MasterCipher masterCipher = new MasterCipher(masterSecret);
    IdentityKey  publicKey    = getIdentityKey(context);
    ECPrivateKey privateKey   = masterCipher.decryptKey(Base64.decode(retrieve(context, IDENTITY_PRIVATE_KEY_DJB_PREF)));

    return new IdentityKeyPair(publicKey, privateKey);
  } catch (IOException | InvalidKeyException e) {
    throw new AssertionError(e);
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public void registerPreKeys(IdentityKey identityKey,
                            PreKeyRecord lastResortKey,
                            SignedPreKeyRecord signedPreKey,
                            List<PreKeyRecord> records)
    throws IOException
{
  List<PreKeyEntity> entities = new LinkedList<>();

  for (PreKeyRecord record : records) {
    PreKeyEntity entity = new PreKeyEntity(record.getId(),
                                           record.getKeyPair().getPublicKey());

    entities.add(entity);
  }

  PreKeyEntity lastResortEntity = new PreKeyEntity(lastResortKey.getId(),
                                                   lastResortKey.getKeyPair().getPublicKey());

  SignedPreKeyEntity signedPreKeyEntity = new SignedPreKeyEntity(signedPreKey.getId(),
                                                                 signedPreKey.getKeyPair().getPublicKey(),
                                                                 signedPreKey.getSignature());

  makeRequest(String.format(PREKEY_PATH, ""), "PUT",
              PreKeyState.toJson(new PreKeyState(entities, lastResortEntity,
                                                 signedPreKeyEntity, identityKey)));
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
@Override
public boolean isTrustedIdentity(final String name, final IdentityKey identityKey) {
	IdentityKey storedKey;
	try {
		storedKey = IdentityKeyTable.getInstance().getIdentity(name);
		if (storedKey != null) {
			return storedKey.equals(identityKey);
		}
		return true;

	} catch (final SQLException e) {
		LOGGER.error("Error while looking up identity trust. ", e);
		Errors.showError(translate("databaseError"));
		Errors.stopApplication();
		throw new UnreachableCodeException();
	}
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public IdentityKey getIdentity(final String name) throws SQLException {
	final String query = "SELECT identity_key FROM identity_keystore WHERE user_id = ?";

	try (PreparedStatement stmt = Database.ensureTableExists(this).prepareStatement(query)) {

		stmt.setString(1, name);
		final ResultSet result = stmt.executeQuery();
		if (result.first()) {
			try {
				return new IdentityKey(result.getBytes(1), 0);
			} catch (final InvalidKeyException e) {
				throw new SQLException(
						"IdentityKeyTable: Value of identity_key for user_id [" + name + "] is invalid.", e);
			}
		} else {
			return null;
		}
	}
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
@Test
public void isTrustedIdentity() throws InterruptedException {
	final IdentityKey key = KeyHelper.generateIdentityKeyPair().getPublicKey();
	Thread.sleep(1000);
	final IdentityKey wrongKey = KeyHelper.generateIdentityKeyPair().getPublicKey();
	assertNotEquals(key, wrongKey);

	// Case: Correct Name and Key
	store.saveIdentity("TestName", key);
	assertTrue(store.isTrustedIdentity("TestName", key));

	// Case: Unknown Key (remember: TextSecure uses Trust On First Use!)
	assertTrue(store.isTrustedIdentity("UnseenName", key));

	// Case: Wrong Key
	assertFalse(store.isTrustedIdentity("TestName", wrongKey));
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public void setMismatchedIdentity(long messageId, final long recipientId, final IdentityKey identityKey) {
  List<IdentityKeyMismatch> items = new ArrayList<IdentityKeyMismatch>() {{
    add(new IdentityKeyMismatch(recipientId, identityKey));
  }};

  IdentityKeyMismatchList document = new IdentityKeyMismatchList(items);

  SQLiteDatabase database = databaseHelper.getWritableDatabase();
  database.beginTransaction();

  try {
    setDocument(database, messageId, MISMATCHED_IDENTITIES, document);

    database.setTransactionSuccessful();
  } catch (IOException ioe) {
    Log.w(TAG, ioe);
  } finally {
    database.endTransaction();
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public WhisperMessage(int messageVersion, SecretKeySpec macKey, ECPublicKey senderRatchetKey,
                      int counter, int previousCounter, byte[] ciphertext,
                      IdentityKey senderIdentityKey,
                      IdentityKey receiverIdentityKey)
{
  byte[] version = {ByteUtil.intsToByteHighAndLow(messageVersion, CURRENT_VERSION)};
  byte[] message = WhisperProtos.WhisperMessage.newBuilder()
                                 .setRatchetKey(ByteString.copyFrom(senderRatchetKey.serialize()))
                                 .setCounter(counter)
                                 .setPreviousCounter(previousCounter)
                                 .setCiphertext(ByteString.copyFrom(ciphertext))
                                 .build().toByteArray();

  byte[] mac     = getMac(messageVersion, senderIdentityKey, receiverIdentityKey, macKey,
                          ByteUtil.combine(version, message));

  this.serialized       = ByteUtil.combine(version, message, mac);
  this.senderRatchetKey = senderRatchetKey;
  this.counter          = counter;
  this.previousCounter  = previousCounter;
  this.ciphertext       = ciphertext;
  this.messageVersion   = messageVersion;
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private byte[] getMac(int messageVersion,
                      IdentityKey senderIdentityKey,
                      IdentityKey receiverIdentityKey,
                      SecretKeySpec macKey, byte[] serialized)
{
  try {
    Mac mac = Mac.getInstance("HmacSHA256");
    mac.init(macKey);

    if (messageVersion >= 3) {
      mac.update(senderIdentityKey.getPublicKey().serialize());
      mac.update(receiverIdentityKey.getPublicKey().serialize());
    }

    byte[] fullMac = mac.doFinal(serialized);
    return ByteUtil.trim(fullMac, MAC_LENGTH);
  } catch (NoSuchAlgorithmException | java.security.InvalidKeyException e) {
    throw new AssertionError(e);
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private AliceAxolotlParameters(IdentityKeyPair ourIdentityKey, ECKeyPair ourBaseKey,
                               IdentityKey theirIdentityKey, ECPublicKey theirSignedPreKey,
                               ECPublicKey theirRatchetKey, Optional<ECPublicKey> theirOneTimePreKey)
{
  this.ourIdentityKey     = ourIdentityKey;
  this.ourBaseKey         = ourBaseKey;
  this.theirIdentityKey   = theirIdentityKey;
  this.theirSignedPreKey  = theirSignedPreKey;
  this.theirRatchetKey    = theirRatchetKey;
  this.theirOneTimePreKey = theirOneTimePreKey;

  if (ourIdentityKey == null || ourBaseKey == null || theirIdentityKey == null ||
      theirSignedPreKey == null || theirRatchetKey == null || theirOneTimePreKey == null)
  {
    throw new IllegalArgumentException("Null values!");
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
SymmetricAxolotlParameters(ECKeyPair ourBaseKey, ECKeyPair ourRatchetKey,
                           IdentityKeyPair ourIdentityKey, ECPublicKey theirBaseKey,
                           ECPublicKey theirRatchetKey, IdentityKey theirIdentityKey)
{
  this.ourBaseKey       = ourBaseKey;
  this.ourRatchetKey    = ourRatchetKey;
  this.ourIdentityKey   = ourIdentityKey;
  this.theirBaseKey     = theirBaseKey;
  this.theirRatchetKey  = theirRatchetKey;
  this.theirIdentityKey = theirIdentityKey;

  if (ourBaseKey == null || ourRatchetKey == null || ourIdentityKey == null ||
      theirBaseKey == null || theirRatchetKey == null || theirIdentityKey == null)
  {
    throw new IllegalArgumentException("Null values!");
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
BobAxolotlParameters(IdentityKeyPair ourIdentityKey, ECKeyPair ourSignedPreKey,
                     ECKeyPair ourRatchetKey, Optional<ECKeyPair> ourOneTimePreKey,
                     IdentityKey theirIdentityKey, ECPublicKey theirBaseKey)
{
  this.ourIdentityKey   = ourIdentityKey;
  this.ourSignedPreKey  = ourSignedPreKey;
  this.ourRatchetKey    = ourRatchetKey;
  this.ourOneTimePreKey = ourOneTimePreKey;
  this.theirIdentityKey = theirIdentityKey;
  this.theirBaseKey     = theirBaseKey;

  if (ourIdentityKey == null || ourSignedPreKey == null || ourRatchetKey == null ||
      ourOneTimePreKey == null || theirIdentityKey == null || theirBaseKey == null)
  {
    throw new IllegalArgumentException("Null value!");
  }
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
public void registerPreKeys(IdentityKey identityKey,
                            PreKeyRecord lastResortKey,
                            SignedPreKeyRecord signedPreKey,
                            List<PreKeyRecord> records)
        throws IOException
{
    List<PreKeyEntity> entities = new LinkedList<>();

    for (PreKeyRecord record : records) {
        PreKeyEntity entity = new PreKeyEntity(record.getId(),
                record.getKeyPair().getPublicKey());

        entities.add(entity);
    }

    PreKeyEntity lastResortEntity = new PreKeyEntity(lastResortKey.getId(),
            lastResortKey.getKeyPair().getPublicKey());

    SignedPreKeyEntity signedPreKeyEntity = new SignedPreKeyEntity(signedPreKey.getId(),
            signedPreKey.getKeyPair().getPublicKey(),
            signedPreKey.getSignature());

    makeRequest(String.format(PREKEY_PATH, ""), "PUT",
            PreKeyState.toJson(new PreKeyState(entities, lastResortEntity,
                    signedPreKeyEntity, identityKey)));
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private void putDevicesForJid(String bareJid, List<Integer> deviceIds, SQLiteAxolotlStore store) {
	for (Integer deviceId : deviceIds) {
		AxolotlAddress axolotlAddress = new AxolotlAddress(bareJid, deviceId);
		Log.d(Config.LOGTAG, AxolotlService.getLogprefix(account) + "Building session for remote address: " + axolotlAddress.toString());
		IdentityKey identityKey = store.loadSession(axolotlAddress).getSessionState().getRemoteIdentityKey();
		if(Config.X509_VERIFICATION) {
			X509Certificate certificate = store.getFingerprintCertificate(identityKey.getFingerprint().replaceAll("\\s", ""));
			if (certificate != null) {
				Bundle information = CryptoHelper.extractCertificateInformation(certificate);
				try {
					final String cn = information.getString("subject_cn");
					final Jid jid = Jid.fromString(bareJid);
					Log.d(Config.LOGTAG,"setting common name for "+jid+" to "+cn);
					account.getRoster().getContact(jid).setCommonName(cn);
				} catch (final InvalidJidException ignored) {
					//ignored
				}
			}
		}
		this.put(axolotlAddress, new XmppAxolotlSession(account, store, axolotlAddress, identityKey));
	}
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
private void putDevicesForJid(String bareJid, List<Integer> deviceIds, SQLiteAxolotlStore store) {
	for (Integer deviceId : deviceIds) {
		AxolotlAddress axolotlAddress = new AxolotlAddress(bareJid, deviceId);
		Log.d(Config.LOGTAG, AxolotlService.getLogprefix(account) + "Building session for remote address: " + axolotlAddress.toString());
		IdentityKey identityKey = store.loadSession(axolotlAddress).getSessionState().getRemoteIdentityKey();
		this.put(axolotlAddress, new XmppAxolotlSession(account, store, axolotlAddress, identityKey));
	}
}
 

import org.whispersystems.libaxolotl.IdentityKey; //导入依赖的package包/类
@Override
protected void initiateScan() {
  IdentityKey identityKey = getRemoteIdentityKey(masterSecret, recipient);

  if (identityKey == null) {
    Toast.makeText(this, R.string.VerifyIdentityActivity_recipient_has_no_identity_key_exclamation,
                   Toast.LENGTH_LONG).show();
  } else {
    super.initiateScan();
  }
}