import org.asamk.signal.manager.util.Utils;
import org.signal.libsignal.metadata.certificate.CertificateValidator;
import org.signal.libsignal.net.Network;
+import org.signal.libsignal.protocol.UsePqRatchet;
import org.signal.libsignal.zkgroup.profiles.ClientZkProfileOperations;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
() -> pushServiceSocket = new PushServiceSocket(serviceEnvironmentConfig.signalServiceConfiguration(),
credentialsProvider,
userAgent,
- getClientZkProfileOperations(),
ServiceConfig.AUTOMATIC_NETWORK_RETRY));
}
Optional.of(credentialsProvider),
userAgent,
healthMonitor,
- allowStories), timer, TimeUnit.SECONDS.toMillis(10));
+ allowStories), () -> true, timer, TimeUnit.SECONDS.toMillis(10));
healthMonitor.monitor(authenticatedSignalWebSocket);
});
}
Optional.empty(),
userAgent,
healthMonitor,
- allowStories), timer, TimeUnit.SECONDS.toMillis(10));
+ allowStories), () -> true, timer, TimeUnit.SECONDS.toMillis(10));
healthMonitor.monitor(unauthenticatedSignalWebSocket);
});
}
getKeysApi(),
Optional.empty(),
executor,
- ServiceConfig.MAX_ENVELOPE_SIZE));
+ ServiceConfig.MAX_ENVELOPE_SIZE,
+ () -> true,
+ UsePqRatchet.NO));
}
public List<SecureValueRecovery> getSecureValueRecovery() {
public ProfileApi getProfileApi() {
return getOrCreate(() -> profileApi,
- () -> profileApi = new ProfileApi(getAuthenticatedSignalWebSocket(), getPushServiceSocket()));
+ () -> profileApi = new ProfileApi(getAuthenticatedSignalWebSocket(),
+ getUnauthenticatedSignalWebSocket(),
+ getPushServiceSocket(),
+ getClientZkProfileOperations()));
}
public ProfileService getProfileService() {