+
+ public static class JsonIdentityKeyStoreDeserializer extends JsonDeserializer<JsonIdentityKeyStore> {
+
+ @Override
+ public JsonIdentityKeyStore deserialize(JsonParser jsonParser, DeserializationContext deserializationContext) throws IOException, JsonProcessingException {
+ JsonNode node = jsonParser.getCodec().readTree(jsonParser);
+
+ try {
+ int localRegistrationId = node.get("registrationId").asInt();
+ IdentityKeyPair identityKeyPair = new IdentityKeyPair(Base64.decode(node.get("identityKey").asText()));
+
+
+ Map<String, IdentityKey> trustedKeyMap = new HashMap<>();
+ JsonNode trustedKeysNode = node.get("trustedKeys");
+ if (trustedKeysNode.isArray()) {
+ for (JsonNode trustedKey : trustedKeysNode) {
+ String trustedKeyName = trustedKey.get("name").asText();
+ try {
+ trustedKeyMap.put(trustedKeyName, new IdentityKey(Base64.decode(trustedKey.get("identityKey").asText()), 0));
+ } catch (InvalidKeyException | IOException e) {
+ System.out.println(String.format("Error while decoding key for: %s", trustedKeyName));
+ }
+ }
+ }
+
+ JsonIdentityKeyStore keyStore = new JsonIdentityKeyStore(identityKeyPair, localRegistrationId);
+ keyStore.addTrustedKeys(trustedKeyMap);
+
+ return keyStore;
+
+ } catch (InvalidKeyException e) {
+ throw new IOException(e);
+ }
+ }
+ }
+
+ public static class JsonIdentityKeyStoreSerializer extends JsonSerializer<JsonIdentityKeyStore> {
+
+ @Override
+ public void serialize(JsonIdentityKeyStore jsonIdentityKeyStore, JsonGenerator json, SerializerProvider serializerProvider) throws IOException, JsonProcessingException {
+ json.writeStartObject();
+ json.writeNumberField("registrationId", jsonIdentityKeyStore.getLocalRegistrationId());
+ json.writeStringField("identityKey", Base64.encodeBytes(jsonIdentityKeyStore.getIdentityKeyPair().serialize()));
+ json.writeArrayFieldStart("trustedKeys");
+ for (Map.Entry<String, IdentityKey> trustedKey : jsonIdentityKeyStore.trustedKeys.entrySet()) {
+ json.writeStartObject();
+ json.writeStringField("name", trustedKey.getKey());
+ json.writeStringField("identityKey", Base64.encodeBytes(trustedKey.getValue().serialize()));
+ json.writeEndObject();
+ }
+ json.writeEndArray();
+ json.writeEndObject();
+ }
+ }