]> nmode's Git Repositories - signal-cli/blobdiff - src/main/java/org/asamk/textsecure/JsonPreKeyStore.java
Rename to signal-cli
[signal-cli] / src / main / java / org / asamk / textsecure / JsonPreKeyStore.java
diff --git a/src/main/java/org/asamk/textsecure/JsonPreKeyStore.java b/src/main/java/org/asamk/textsecure/JsonPreKeyStore.java
deleted file mode 100644 (file)
index a522f17..0000000
+++ /dev/null
@@ -1,97 +0,0 @@
-package org.asamk.textsecure;
-
-import com.fasterxml.jackson.core.JsonGenerator;
-import com.fasterxml.jackson.core.JsonParser;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.*;
-import org.whispersystems.libsignal.InvalidKeyIdException;
-import org.whispersystems.libsignal.state.PreKeyRecord;
-import org.whispersystems.libsignal.state.PreKeyStore;
-
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-
-class JsonPreKeyStore implements PreKeyStore {
-
-    private final Map<Integer, byte[]> store = new HashMap<>();
-
-
-    public JsonPreKeyStore() {
-
-    }
-
-    public void addPreKeys(Map<Integer, byte[]> preKeys) {
-        store.putAll(preKeys);
-    }
-
-    @Override
-    public PreKeyRecord loadPreKey(int preKeyId) throws InvalidKeyIdException {
-        try {
-            if (!store.containsKey(preKeyId)) {
-                throw new InvalidKeyIdException("No such prekeyrecord!");
-            }
-
-            return new PreKeyRecord(store.get(preKeyId));
-        } catch (IOException e) {
-            throw new AssertionError(e);
-        }
-    }
-
-    @Override
-    public void storePreKey(int preKeyId, PreKeyRecord record) {
-        store.put(preKeyId, record.serialize());
-    }
-
-    @Override
-    public boolean containsPreKey(int preKeyId) {
-        return store.containsKey(preKeyId);
-    }
-
-    @Override
-    public void removePreKey(int preKeyId) {
-        store.remove(preKeyId);
-    }
-
-    public static class JsonPreKeyStoreDeserializer extends JsonDeserializer<JsonPreKeyStore> {
-
-        @Override
-        public JsonPreKeyStore deserialize(JsonParser jsonParser, DeserializationContext deserializationContext) throws IOException, JsonProcessingException {
-            JsonNode node = jsonParser.getCodec().readTree(jsonParser);
-
-
-            Map<Integer, byte[]> preKeyMap = new HashMap<>();
-            if (node.isArray()) {
-                for (JsonNode preKey : node) {
-                    Integer preKeyId = preKey.get("id").asInt();
-                    try {
-                        preKeyMap.put(preKeyId, Base64.decode(preKey.get("record").asText()));
-                    } catch (IOException e) {
-                        System.out.println(String.format("Error while decoding prekey for: %s", preKeyId));
-                    }
-                }
-            }
-
-            JsonPreKeyStore keyStore = new JsonPreKeyStore();
-            keyStore.addPreKeys(preKeyMap);
-
-            return keyStore;
-
-        }
-    }
-
-    public static class JsonPreKeyStoreSerializer extends JsonSerializer<JsonPreKeyStore> {
-
-        @Override
-        public void serialize(JsonPreKeyStore jsonPreKeyStore, JsonGenerator json, SerializerProvider serializerProvider) throws IOException, JsonProcessingException {
-            json.writeStartArray();
-            for (Map.Entry<Integer, byte[]> preKey : jsonPreKeyStore.store.entrySet()) {
-                json.writeStartObject();
-                json.writeNumberField("id", preKey.getKey());
-                json.writeStringField("record", Base64.encodeBytes(preKey.getValue()));
-                json.writeEndObject();
-            }
-            json.writeEndArray();
-        }
-    }
-}