1 package org
.asamk
.signal
.manager
.storage
.protocol
;
3 import com
.fasterxml
.jackson
.annotation
.JsonIgnoreProperties
;
4 import com
.fasterxml
.jackson
.annotation
.JsonProperty
;
5 import com
.fasterxml
.jackson
.databind
.annotation
.JsonDeserialize
;
6 import com
.fasterxml
.jackson
.databind
.annotation
.JsonSerialize
;
8 import org
.asamk
.signal
.manager
.TrustLevel
;
9 import org
.whispersystems
.libsignal
.IdentityKey
;
10 import org
.whispersystems
.libsignal
.IdentityKeyPair
;
11 import org
.whispersystems
.libsignal
.InvalidKeyIdException
;
12 import org
.whispersystems
.libsignal
.SignalProtocolAddress
;
13 import org
.whispersystems
.libsignal
.state
.PreKeyRecord
;
14 import org
.whispersystems
.libsignal
.state
.PreKeyStore
;
15 import org
.whispersystems
.libsignal
.state
.SessionRecord
;
16 import org
.whispersystems
.libsignal
.state
.SignedPreKeyRecord
;
17 import org
.whispersystems
.signalservice
.api
.SignalServiceProtocolStore
;
18 import org
.whispersystems
.signalservice
.api
.SignalServiceSessionStore
;
19 import org
.whispersystems
.signalservice
.api
.push
.SignalServiceAddress
;
21 import java
.util
.List
;
23 @JsonIgnoreProperties(value
= {"sessionStore", "preKeys"}, allowSetters
= true)
24 public class JsonSignalProtocolStore
implements SignalServiceProtocolStore
{
26 @JsonProperty("preKeys")
27 @JsonDeserialize(using
= LegacyJsonPreKeyStore
.JsonPreKeyStoreDeserializer
.class)
28 private LegacyJsonPreKeyStore legacyPreKeyStore
;
30 @JsonProperty("sessionStore")
31 @JsonDeserialize(using
= LegacyJsonSessionStore
.JsonSessionStoreDeserializer
.class)
32 private LegacyJsonSessionStore legacySessionStore
;
34 @JsonProperty("signedPreKeyStore")
35 @JsonDeserialize(using
= JsonSignedPreKeyStore
.JsonSignedPreKeyStoreDeserializer
.class)
36 @JsonSerialize(using
= JsonSignedPreKeyStore
.JsonSignedPreKeyStoreSerializer
.class)
37 private JsonSignedPreKeyStore signedPreKeyStore
;
39 @JsonProperty("identityKeyStore")
40 @JsonDeserialize(using
= JsonIdentityKeyStore
.JsonIdentityKeyStoreDeserializer
.class)
41 @JsonSerialize(using
= JsonIdentityKeyStore
.JsonIdentityKeyStoreSerializer
.class)
42 private JsonIdentityKeyStore identityKeyStore
;
44 private PreKeyStore preKeyStore
;
45 private SignalServiceSessionStore sessionStore
;
47 public JsonSignalProtocolStore() {
50 public JsonSignalProtocolStore(
51 IdentityKeyPair identityKeyPair
,
53 PreKeyStore preKeyStore
,
54 SignalServiceSessionStore sessionStore
56 this.preKeyStore
= preKeyStore
;
57 this.sessionStore
= sessionStore
;
58 signedPreKeyStore
= new JsonSignedPreKeyStore();
59 this.identityKeyStore
= new JsonIdentityKeyStore(identityKeyPair
, registrationId
);
62 public void setResolver(final SignalServiceAddressResolver resolver
) {
63 identityKeyStore
.setResolver(resolver
);
66 public void setPreKeyStore(final PreKeyStore preKeyStore
) {
67 this.preKeyStore
= preKeyStore
;
70 public void setSessionStore(final SignalServiceSessionStore sessionStore
) {
71 this.sessionStore
= sessionStore
;
74 public LegacyJsonPreKeyStore
getLegacyPreKeyStore() {
75 return legacyPreKeyStore
;
78 public LegacyJsonSessionStore
getLegacySessionStore() {
79 return legacySessionStore
;
83 public IdentityKeyPair
getIdentityKeyPair() {
84 return identityKeyStore
.getIdentityKeyPair();
88 public int getLocalRegistrationId() {
89 return identityKeyStore
.getLocalRegistrationId();
93 public boolean saveIdentity(SignalProtocolAddress address
, IdentityKey identityKey
) {
94 return identityKeyStore
.saveIdentity(address
, identityKey
);
97 public void saveIdentity(SignalServiceAddress serviceAddress
, IdentityKey identityKey
, TrustLevel trustLevel
) {
98 identityKeyStore
.saveIdentity(serviceAddress
, identityKey
, trustLevel
, null);
101 public void setIdentityTrustLevel(
102 SignalServiceAddress serviceAddress
, IdentityKey identityKey
, TrustLevel trustLevel
104 identityKeyStore
.setIdentityTrustLevel(serviceAddress
, identityKey
, trustLevel
);
107 public void removeIdentity(SignalServiceAddress serviceAddress
, IdentityKey identityKey
) {
108 identityKeyStore
.removeIdentity(serviceAddress
, identityKey
);
111 public List
<IdentityInfo
> getIdentities() {
112 return identityKeyStore
.getIdentities();
115 public List
<IdentityInfo
> getIdentities(SignalServiceAddress serviceAddress
) {
116 return identityKeyStore
.getIdentities(serviceAddress
);
120 public boolean isTrustedIdentity(SignalProtocolAddress address
, IdentityKey identityKey
, Direction direction
) {
121 return identityKeyStore
.isTrustedIdentity(address
, identityKey
, direction
);
125 public IdentityKey
getIdentity(SignalProtocolAddress address
) {
126 return identityKeyStore
.getIdentity(address
);
129 public IdentityInfo
getIdentity(SignalServiceAddress serviceAddress
) {
130 return identityKeyStore
.getIdentity(serviceAddress
);
134 public PreKeyRecord
loadPreKey(int preKeyId
) throws InvalidKeyIdException
{
135 return preKeyStore
.loadPreKey(preKeyId
);
139 public void storePreKey(int preKeyId
, PreKeyRecord
record) {
140 preKeyStore
.storePreKey(preKeyId
, record);
144 public boolean containsPreKey(int preKeyId
) {
145 return preKeyStore
.containsPreKey(preKeyId
);
149 public void removePreKey(int preKeyId
) {
150 preKeyStore
.removePreKey(preKeyId
);
154 public SessionRecord
loadSession(SignalProtocolAddress address
) {
155 return sessionStore
.loadSession(address
);
159 public List
<Integer
> getSubDeviceSessions(String name
) {
160 return sessionStore
.getSubDeviceSessions(name
);
164 public void storeSession(SignalProtocolAddress address
, SessionRecord
record) {
165 sessionStore
.storeSession(address
, record);
169 public boolean containsSession(SignalProtocolAddress address
) {
170 return sessionStore
.containsSession(address
);
174 public void deleteSession(SignalProtocolAddress address
) {
175 sessionStore
.deleteSession(address
);
179 public void deleteAllSessions(String name
) {
180 sessionStore
.deleteAllSessions(name
);
184 public void archiveSession(final SignalProtocolAddress address
) {
185 sessionStore
.archiveSession(address
);
189 public SignedPreKeyRecord
loadSignedPreKey(int signedPreKeyId
) throws InvalidKeyIdException
{
190 return signedPreKeyStore
.loadSignedPreKey(signedPreKeyId
);
194 public List
<SignedPreKeyRecord
> loadSignedPreKeys() {
195 return signedPreKeyStore
.loadSignedPreKeys();
199 public void storeSignedPreKey(int signedPreKeyId
, SignedPreKeyRecord
record) {
200 signedPreKeyStore
.storeSignedPreKey(signedPreKeyId
, record);
204 public boolean containsSignedPreKey(int signedPreKeyId
) {
205 return signedPreKeyStore
.containsSignedPreKey(signedPreKeyId
);
209 public void removeSignedPreKey(int signedPreKeyId
) {
210 signedPreKeyStore
.removeSignedPreKey(signedPreKeyId
);