getParserForType() {
- return PARSER;
- }
-
- private int bitField0_;
- // optional bytes publicKey = 1;
- public static final int PUBLICKEY_FIELD_NUMBER = 1;
- private com.google.protobuf.ByteString publicKey_;
- /**
- * optional bytes publicKey = 1;
- */
- public boolean hasPublicKey() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * optional bytes publicKey = 1;
- */
- public com.google.protobuf.ByteString getPublicKey() {
- return publicKey_;
- }
-
- // optional bytes body = 2;
- public static final int BODY_FIELD_NUMBER = 2;
- private com.google.protobuf.ByteString body_;
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public boolean hasBody() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public com.google.protobuf.ByteString getBody() {
- return body_;
- }
-
- private void initFields() {
- publicKey_ = com.google.protobuf.ByteString.EMPTY;
- body_ = com.google.protobuf.ByteString.EMPTY;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeBytes(1, publicKey_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeBytes(2, body_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(1, publicKey_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(2, body_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code signalservice.ProvisionEnvelope}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder
- implements org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelopeOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionEnvelope_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionEnvelope_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope.class, org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope.Builder.class);
- }
-
- // Construct using org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
- }
- }
- private static Builder create() {
- return new Builder();
- }
-
- public Builder clear() {
- super.clear();
- publicKey_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000001);
- body_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000002);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionEnvelope_descriptor;
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope getDefaultInstanceForType() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope.getDefaultInstance();
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope build() {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope buildPartial() {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope result = new org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
- }
- result.publicKey_ = publicKey_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
- }
- result.body_ = body_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
-
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope) {
- return mergeFrom((org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope other) {
- if (other == org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope.getDefaultInstance()) return this;
- if (other.hasPublicKey()) {
- setPublicKey(other.getPublicKey());
- }
- if (other.hasBody()) {
- setBody(other.getBody());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionEnvelope) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // optional bytes publicKey = 1;
- private com.google.protobuf.ByteString publicKey_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * optional bytes publicKey = 1;
- */
- public boolean hasPublicKey() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * optional bytes publicKey = 1;
- */
- public com.google.protobuf.ByteString getPublicKey() {
- return publicKey_;
- }
- /**
- * optional bytes publicKey = 1;
- */
- public Builder setPublicKey(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000001;
- publicKey_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bytes publicKey = 1;
- */
- public Builder clearPublicKey() {
- bitField0_ = (bitField0_ & ~0x00000001);
- publicKey_ = getDefaultInstance().getPublicKey();
- onChanged();
- return this;
- }
-
- // optional bytes body = 2;
- private com.google.protobuf.ByteString body_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public boolean hasBody() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public com.google.protobuf.ByteString getBody() {
- return body_;
- }
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public Builder setBody(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000002;
- body_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bytes body = 2;
- *
- *
- * Encrypted ProvisionMessage
- *
- */
- public Builder clearBody() {
- bitField0_ = (bitField0_ & ~0x00000002);
- body_ = getDefaultInstance().getBody();
- onChanged();
- return this;
- }
-
- // @@protoc_insertion_point(builder_scope:signalservice.ProvisionEnvelope)
- }
-
- static {
- defaultInstance = new ProvisionEnvelope(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:signalservice.ProvisionEnvelope)
- }
-
- public interface ProvisionMessageOrBuilder
- extends com.google.protobuf.MessageOrBuilder {
-
- // optional bytes identityKeyPublic = 1;
- /**
- * optional bytes identityKeyPublic = 1;
- */
- boolean hasIdentityKeyPublic();
- /**
- * optional bytes identityKeyPublic = 1;
- */
- com.google.protobuf.ByteString getIdentityKeyPublic();
-
- // optional bytes identityKeyPrivate = 2;
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- boolean hasIdentityKeyPrivate();
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- com.google.protobuf.ByteString getIdentityKeyPrivate();
-
- // optional string number = 3;
- /**
- * optional string number = 3;
- */
- boolean hasNumber();
- /**
- * optional string number = 3;
- */
- java.lang.String getNumber();
- /**
- * optional string number = 3;
- */
- com.google.protobuf.ByteString
- getNumberBytes();
-
- // optional string provisioningCode = 4;
- /**
- * optional string provisioningCode = 4;
- */
- boolean hasProvisioningCode();
- /**
- * optional string provisioningCode = 4;
- */
- java.lang.String getProvisioningCode();
- /**
- * optional string provisioningCode = 4;
- */
- com.google.protobuf.ByteString
- getProvisioningCodeBytes();
-
- // optional string userAgent = 5;
- /**
- * optional string userAgent = 5;
- */
- boolean hasUserAgent();
- /**
- * optional string userAgent = 5;
- */
- java.lang.String getUserAgent();
- /**
- * optional string userAgent = 5;
- */
- com.google.protobuf.ByteString
- getUserAgentBytes();
-
- // optional bytes profileKey = 6;
- /**
- * optional bytes profileKey = 6;
- */
- boolean hasProfileKey();
- /**
- * optional bytes profileKey = 6;
- */
- com.google.protobuf.ByteString getProfileKey();
-
- // optional bool readReceipts = 7;
- /**
- * optional bool readReceipts = 7;
- */
- boolean hasReadReceipts();
- /**
- * optional bool readReceipts = 7;
- */
- boolean getReadReceipts();
- }
- /**
- * Protobuf type {@code signalservice.ProvisionMessage}
- */
- public static final class ProvisionMessage extends
- com.google.protobuf.GeneratedMessage
- implements ProvisionMessageOrBuilder {
- // Use ProvisionMessage.newBuilder() to construct.
- private ProvisionMessage(com.google.protobuf.GeneratedMessage.Builder builder) {
- super(builder);
- this.unknownFields = builder.getUnknownFields();
- }
- private ProvisionMessage(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
-
- private static final ProvisionMessage defaultInstance;
- public static ProvisionMessage getDefaultInstance() {
- return defaultInstance;
- }
-
- public ProvisionMessage getDefaultInstanceForType() {
- return defaultInstance;
- }
-
- private final com.google.protobuf.UnknownFieldSet unknownFields;
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private ProvisionMessage(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- initFields();
- int mutable_bitField0_ = 0;
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- default: {
- if (!parseUnknownField(input, unknownFields,
- extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- case 10: {
- bitField0_ |= 0x00000001;
- identityKeyPublic_ = input.readBytes();
- break;
- }
- case 18: {
- bitField0_ |= 0x00000002;
- identityKeyPrivate_ = input.readBytes();
- break;
- }
- case 26: {
- bitField0_ |= 0x00000004;
- number_ = input.readBytes();
- break;
- }
- case 34: {
- bitField0_ |= 0x00000008;
- provisioningCode_ = input.readBytes();
- break;
- }
- case 42: {
- bitField0_ |= 0x00000010;
- userAgent_ = input.readBytes();
- break;
- }
- case 50: {
- bitField0_ |= 0x00000020;
- profileKey_ = input.readBytes();
- break;
- }
- case 56: {
- bitField0_ |= 0x00000040;
- readReceipts_ = input.readBool();
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e.getMessage()).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionMessage_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionMessage_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.class, org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.Builder.class);
- }
-
- public static com.google.protobuf.Parser PARSER =
- new com.google.protobuf.AbstractParser() {
- public ProvisionMessage parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new ProvisionMessage(input, extensionRegistry);
- }
- };
-
- @java.lang.Override
- public com.google.protobuf.Parser getParserForType() {
- return PARSER;
- }
-
- private int bitField0_;
- // optional bytes identityKeyPublic = 1;
- public static final int IDENTITYKEYPUBLIC_FIELD_NUMBER = 1;
- private com.google.protobuf.ByteString identityKeyPublic_;
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public boolean hasIdentityKeyPublic() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public com.google.protobuf.ByteString getIdentityKeyPublic() {
- return identityKeyPublic_;
- }
-
- // optional bytes identityKeyPrivate = 2;
- public static final int IDENTITYKEYPRIVATE_FIELD_NUMBER = 2;
- private com.google.protobuf.ByteString identityKeyPrivate_;
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public boolean hasIdentityKeyPrivate() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public com.google.protobuf.ByteString getIdentityKeyPrivate() {
- return identityKeyPrivate_;
- }
-
- // optional string number = 3;
- public static final int NUMBER_FIELD_NUMBER = 3;
- private java.lang.Object number_;
- /**
- * optional string number = 3;
- */
- public boolean hasNumber() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * optional string number = 3;
- */
- public java.lang.String getNumber() {
- java.lang.Object ref = number_;
- if (ref instanceof java.lang.String) {
- return (java.lang.String) ref;
- } else {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- if (bs.isValidUtf8()) {
- number_ = s;
- }
- return s;
- }
- }
- /**
- * optional string number = 3;
- */
- public com.google.protobuf.ByteString
- getNumberBytes() {
- java.lang.Object ref = number_;
- if (ref instanceof java.lang.String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- number_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
-
- // optional string provisioningCode = 4;
- public static final int PROVISIONINGCODE_FIELD_NUMBER = 4;
- private java.lang.Object provisioningCode_;
- /**
- * optional string provisioningCode = 4;
- */
- public boolean hasProvisioningCode() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * optional string provisioningCode = 4;
- */
- public java.lang.String getProvisioningCode() {
- java.lang.Object ref = provisioningCode_;
- if (ref instanceof java.lang.String) {
- return (java.lang.String) ref;
- } else {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- if (bs.isValidUtf8()) {
- provisioningCode_ = s;
- }
- return s;
- }
- }
- /**
- * optional string provisioningCode = 4;
- */
- public com.google.protobuf.ByteString
- getProvisioningCodeBytes() {
- java.lang.Object ref = provisioningCode_;
- if (ref instanceof java.lang.String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- provisioningCode_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
-
- // optional string userAgent = 5;
- public static final int USERAGENT_FIELD_NUMBER = 5;
- private java.lang.Object userAgent_;
- /**
- * optional string userAgent = 5;
- */
- public boolean hasUserAgent() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * optional string userAgent = 5;
- */
- public java.lang.String getUserAgent() {
- java.lang.Object ref = userAgent_;
- if (ref instanceof java.lang.String) {
- return (java.lang.String) ref;
- } else {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- if (bs.isValidUtf8()) {
- userAgent_ = s;
- }
- return s;
- }
- }
- /**
- * optional string userAgent = 5;
- */
- public com.google.protobuf.ByteString
- getUserAgentBytes() {
- java.lang.Object ref = userAgent_;
- if (ref instanceof java.lang.String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- userAgent_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
-
- // optional bytes profileKey = 6;
- public static final int PROFILEKEY_FIELD_NUMBER = 6;
- private com.google.protobuf.ByteString profileKey_;
- /**
- * optional bytes profileKey = 6;
- */
- public boolean hasProfileKey() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * optional bytes profileKey = 6;
- */
- public com.google.protobuf.ByteString getProfileKey() {
- return profileKey_;
- }
-
- // optional bool readReceipts = 7;
- public static final int READRECEIPTS_FIELD_NUMBER = 7;
- private boolean readReceipts_;
- /**
- * optional bool readReceipts = 7;
- */
- public boolean hasReadReceipts() {
- return ((bitField0_ & 0x00000040) == 0x00000040);
- }
- /**
- * optional bool readReceipts = 7;
- */
- public boolean getReadReceipts() {
- return readReceipts_;
- }
-
- private void initFields() {
- identityKeyPublic_ = com.google.protobuf.ByteString.EMPTY;
- identityKeyPrivate_ = com.google.protobuf.ByteString.EMPTY;
- number_ = "";
- provisioningCode_ = "";
- userAgent_ = "";
- profileKey_ = com.google.protobuf.ByteString.EMPTY;
- readReceipts_ = false;
- }
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized != -1) return isInitialized == 1;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- getSerializedSize();
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeBytes(1, identityKeyPublic_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- output.writeBytes(2, identityKeyPrivate_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- output.writeBytes(3, getNumberBytes());
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- output.writeBytes(4, getProvisioningCodeBytes());
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- output.writeBytes(5, getUserAgentBytes());
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- output.writeBytes(6, profileKey_);
- }
- if (((bitField0_ & 0x00000040) == 0x00000040)) {
- output.writeBool(7, readReceipts_);
- }
- getUnknownFields().writeTo(output);
- }
-
- private int memoizedSerializedSize = -1;
- public int getSerializedSize() {
- int size = memoizedSerializedSize;
- if (size != -1) return size;
-
- size = 0;
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(1, identityKeyPublic_);
- }
- if (((bitField0_ & 0x00000002) == 0x00000002)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(2, identityKeyPrivate_);
- }
- if (((bitField0_ & 0x00000004) == 0x00000004)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(3, getNumberBytes());
- }
- if (((bitField0_ & 0x00000008) == 0x00000008)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(4, getProvisioningCodeBytes());
- }
- if (((bitField0_ & 0x00000010) == 0x00000010)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(5, getUserAgentBytes());
- }
- if (((bitField0_ & 0x00000020) == 0x00000020)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBytesSize(6, profileKey_);
- }
- if (((bitField0_ & 0x00000040) == 0x00000040)) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(7, readReceipts_);
- }
- size += getUnknownFields().getSerializedSize();
- memoizedSerializedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- protected java.lang.Object writeReplace()
- throws java.io.ObjectStreamException {
- return super.writeReplace();
- }
-
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseDelimitedFrom(input, extensionRegistry);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return PARSER.parseFrom(input);
- }
- public static org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return PARSER.parseFrom(input, extensionRegistry);
- }
-
- public static Builder newBuilder() { return Builder.create(); }
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage prototype) {
- return newBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() { return newBuilder(this); }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code signalservice.ProvisionMessage}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessage.Builder
- implements org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessageOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionMessage_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionMessage_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.class, org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.Builder.class);
- }
-
- // Construct using org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessage.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
- }
- }
- private static Builder create() {
- return new Builder();
- }
-
- public Builder clear() {
- super.clear();
- identityKeyPublic_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000001);
- identityKeyPrivate_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000002);
- number_ = "";
- bitField0_ = (bitField0_ & ~0x00000004);
- provisioningCode_ = "";
- bitField0_ = (bitField0_ & ~0x00000008);
- userAgent_ = "";
- bitField0_ = (bitField0_ & ~0x00000010);
- profileKey_ = com.google.protobuf.ByteString.EMPTY;
- bitField0_ = (bitField0_ & ~0x00000020);
- readReceipts_ = false;
- bitField0_ = (bitField0_ & ~0x00000040);
- return this;
- }
-
- public Builder clone() {
- return create().mergeFrom(buildPartial());
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.internal_static_signalservice_ProvisionMessage_descriptor;
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage getDefaultInstanceForType() {
- return org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.getDefaultInstance();
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage build() {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage buildPartial() {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage result = new org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
- to_bitField0_ |= 0x00000001;
- }
- result.identityKeyPublic_ = identityKeyPublic_;
- if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
- to_bitField0_ |= 0x00000002;
- }
- result.identityKeyPrivate_ = identityKeyPrivate_;
- if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
- to_bitField0_ |= 0x00000004;
- }
- result.number_ = number_;
- if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
- to_bitField0_ |= 0x00000008;
- }
- result.provisioningCode_ = provisioningCode_;
- if (((from_bitField0_ & 0x00000010) == 0x00000010)) {
- to_bitField0_ |= 0x00000010;
- }
- result.userAgent_ = userAgent_;
- if (((from_bitField0_ & 0x00000020) == 0x00000020)) {
- to_bitField0_ |= 0x00000020;
- }
- result.profileKey_ = profileKey_;
- if (((from_bitField0_ & 0x00000040) == 0x00000040)) {
- to_bitField0_ |= 0x00000040;
- }
- result.readReceipts_ = readReceipts_;
- result.bitField0_ = to_bitField0_;
- onBuilt();
- return result;
- }
-
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage) {
- return mergeFrom((org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage other) {
- if (other == org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage.getDefaultInstance()) return this;
- if (other.hasIdentityKeyPublic()) {
- setIdentityKeyPublic(other.getIdentityKeyPublic());
- }
- if (other.hasIdentityKeyPrivate()) {
- setIdentityKeyPrivate(other.getIdentityKeyPrivate());
- }
- if (other.hasNumber()) {
- bitField0_ |= 0x00000004;
- number_ = other.number_;
- onChanged();
- }
- if (other.hasProvisioningCode()) {
- bitField0_ |= 0x00000008;
- provisioningCode_ = other.provisioningCode_;
- onChanged();
- }
- if (other.hasUserAgent()) {
- bitField0_ |= 0x00000010;
- userAgent_ = other.userAgent_;
- onChanged();
- }
- if (other.hasProfileKey()) {
- setProfileKey(other.getProfileKey());
- }
- if (other.hasReadReceipts()) {
- setReadReceipts(other.getReadReceipts());
- }
- this.mergeUnknownFields(other.getUnknownFields());
- return this;
- }
-
- public final boolean isInitialized() {
- return true;
- }
-
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.session.libsignal.service.internal.push.ProvisioningProtos.ProvisionMessage) e.getUnfinishedMessage();
- throw e;
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- // optional bytes identityKeyPublic = 1;
- private com.google.protobuf.ByteString identityKeyPublic_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public boolean hasIdentityKeyPublic() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
- }
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public com.google.protobuf.ByteString getIdentityKeyPublic() {
- return identityKeyPublic_;
- }
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public Builder setIdentityKeyPublic(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000001;
- identityKeyPublic_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bytes identityKeyPublic = 1;
- */
- public Builder clearIdentityKeyPublic() {
- bitField0_ = (bitField0_ & ~0x00000001);
- identityKeyPublic_ = getDefaultInstance().getIdentityKeyPublic();
- onChanged();
- return this;
- }
-
- // optional bytes identityKeyPrivate = 2;
- private com.google.protobuf.ByteString identityKeyPrivate_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public boolean hasIdentityKeyPrivate() {
- return ((bitField0_ & 0x00000002) == 0x00000002);
- }
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public com.google.protobuf.ByteString getIdentityKeyPrivate() {
- return identityKeyPrivate_;
- }
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public Builder setIdentityKeyPrivate(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000002;
- identityKeyPrivate_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bytes identityKeyPrivate = 2;
- */
- public Builder clearIdentityKeyPrivate() {
- bitField0_ = (bitField0_ & ~0x00000002);
- identityKeyPrivate_ = getDefaultInstance().getIdentityKeyPrivate();
- onChanged();
- return this;
- }
-
- // optional string number = 3;
- private java.lang.Object number_ = "";
- /**
- * optional string number = 3;
- */
- public boolean hasNumber() {
- return ((bitField0_ & 0x00000004) == 0x00000004);
- }
- /**
- * optional string number = 3;
- */
- public java.lang.String getNumber() {
- java.lang.Object ref = number_;
- if (!(ref instanceof java.lang.String)) {
- java.lang.String s = ((com.google.protobuf.ByteString) ref)
- .toStringUtf8();
- number_ = s;
- return s;
- } else {
- return (java.lang.String) ref;
- }
- }
- /**
- * optional string number = 3;
- */
- public com.google.protobuf.ByteString
- getNumberBytes() {
- java.lang.Object ref = number_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- number_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
- /**
- * optional string number = 3;
- */
- public Builder setNumber(
- java.lang.String value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000004;
- number_ = value;
- onChanged();
- return this;
- }
- /**
- * optional string number = 3;
- */
- public Builder clearNumber() {
- bitField0_ = (bitField0_ & ~0x00000004);
- number_ = getDefaultInstance().getNumber();
- onChanged();
- return this;
- }
- /**
- * optional string number = 3;
- */
- public Builder setNumberBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000004;
- number_ = value;
- onChanged();
- return this;
- }
-
- // optional string provisioningCode = 4;
- private java.lang.Object provisioningCode_ = "";
- /**
- * optional string provisioningCode = 4;
- */
- public boolean hasProvisioningCode() {
- return ((bitField0_ & 0x00000008) == 0x00000008);
- }
- /**
- * optional string provisioningCode = 4;
- */
- public java.lang.String getProvisioningCode() {
- java.lang.Object ref = provisioningCode_;
- if (!(ref instanceof java.lang.String)) {
- java.lang.String s = ((com.google.protobuf.ByteString) ref)
- .toStringUtf8();
- provisioningCode_ = s;
- return s;
- } else {
- return (java.lang.String) ref;
- }
- }
- /**
- * optional string provisioningCode = 4;
- */
- public com.google.protobuf.ByteString
- getProvisioningCodeBytes() {
- java.lang.Object ref = provisioningCode_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- provisioningCode_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
- /**
- * optional string provisioningCode = 4;
- */
- public Builder setProvisioningCode(
- java.lang.String value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000008;
- provisioningCode_ = value;
- onChanged();
- return this;
- }
- /**
- * optional string provisioningCode = 4;
- */
- public Builder clearProvisioningCode() {
- bitField0_ = (bitField0_ & ~0x00000008);
- provisioningCode_ = getDefaultInstance().getProvisioningCode();
- onChanged();
- return this;
- }
- /**
- * optional string provisioningCode = 4;
- */
- public Builder setProvisioningCodeBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000008;
- provisioningCode_ = value;
- onChanged();
- return this;
- }
-
- // optional string userAgent = 5;
- private java.lang.Object userAgent_ = "";
- /**
- * optional string userAgent = 5;
- */
- public boolean hasUserAgent() {
- return ((bitField0_ & 0x00000010) == 0x00000010);
- }
- /**
- * optional string userAgent = 5;
- */
- public java.lang.String getUserAgent() {
- java.lang.Object ref = userAgent_;
- if (!(ref instanceof java.lang.String)) {
- java.lang.String s = ((com.google.protobuf.ByteString) ref)
- .toStringUtf8();
- userAgent_ = s;
- return s;
- } else {
- return (java.lang.String) ref;
- }
- }
- /**
- * optional string userAgent = 5;
- */
- public com.google.protobuf.ByteString
- getUserAgentBytes() {
- java.lang.Object ref = userAgent_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- userAgent_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
- /**
- * optional string userAgent = 5;
- */
- public Builder setUserAgent(
- java.lang.String value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000010;
- userAgent_ = value;
- onChanged();
- return this;
- }
- /**
- * optional string userAgent = 5;
- */
- public Builder clearUserAgent() {
- bitField0_ = (bitField0_ & ~0x00000010);
- userAgent_ = getDefaultInstance().getUserAgent();
- onChanged();
- return this;
- }
- /**
- * optional string userAgent = 5;
- */
- public Builder setUserAgentBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000010;
- userAgent_ = value;
- onChanged();
- return this;
- }
-
- // optional bytes profileKey = 6;
- private com.google.protobuf.ByteString profileKey_ = com.google.protobuf.ByteString.EMPTY;
- /**
- * optional bytes profileKey = 6;
- */
- public boolean hasProfileKey() {
- return ((bitField0_ & 0x00000020) == 0x00000020);
- }
- /**
- * optional bytes profileKey = 6;
- */
- public com.google.protobuf.ByteString getProfileKey() {
- return profileKey_;
- }
- /**
- * optional bytes profileKey = 6;
- */
- public Builder setProfileKey(com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- bitField0_ |= 0x00000020;
- profileKey_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bytes profileKey = 6;
- */
- public Builder clearProfileKey() {
- bitField0_ = (bitField0_ & ~0x00000020);
- profileKey_ = getDefaultInstance().getProfileKey();
- onChanged();
- return this;
- }
-
- // optional bool readReceipts = 7;
- private boolean readReceipts_ ;
- /**
- * optional bool readReceipts = 7;
- */
- public boolean hasReadReceipts() {
- return ((bitField0_ & 0x00000040) == 0x00000040);
- }
- /**
- * optional bool readReceipts = 7;
- */
- public boolean getReadReceipts() {
- return readReceipts_;
- }
- /**
- * optional bool readReceipts = 7;
- */
- public Builder setReadReceipts(boolean value) {
- bitField0_ |= 0x00000040;
- readReceipts_ = value;
- onChanged();
- return this;
- }
- /**
- * optional bool readReceipts = 7;
- */
- public Builder clearReadReceipts() {
- bitField0_ = (bitField0_ & ~0x00000040);
- readReceipts_ = false;
- onChanged();
- return this;
- }
-
- // @@protoc_insertion_point(builder_scope:signalservice.ProvisionMessage)
- }
-
- static {
- defaultInstance = new ProvisionMessage(true);
- defaultInstance.initFields();
- }
-
- // @@protoc_insertion_point(class_scope:signalservice.ProvisionMessage)
- }
-
- private static com.google.protobuf.Descriptors.Descriptor
- internal_static_signalservice_ProvisionEnvelope_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_signalservice_ProvisionEnvelope_fieldAccessorTable;
- private static com.google.protobuf.Descriptors.Descriptor
- internal_static_signalservice_ProvisionMessage_descriptor;
- private static
- com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_signalservice_ProvisionMessage_fieldAccessorTable;
-
- public static com.google.protobuf.Descriptors.FileDescriptor
- getDescriptor() {
- return descriptor;
- }
- private static com.google.protobuf.Descriptors.FileDescriptor
- descriptor;
- static {
- java.lang.String[] descriptorData = {
- "\n\022Provisioning.proto\022\rsignalservice\"4\n\021P" +
- "rovisionEnvelope\022\021\n\tpublicKey\030\001 \001(\014\022\014\n\004b" +
- "ody\030\002 \001(\014\"\260\001\n\020ProvisionMessage\022\031\n\021identi" +
- "tyKeyPublic\030\001 \001(\014\022\032\n\022identityKeyPrivate\030" +
- "\002 \001(\014\022\016\n\006number\030\003 \001(\t\022\030\n\020provisioningCod" +
- "e\030\004 \001(\t\022\021\n\tuserAgent\030\005 \001(\t\022\022\n\nprofileKey" +
- "\030\006 \001(\014\022\024\n\014readReceipts\030\007 \001(\010BA\n+org.sess" +
- "ion.libsignal.service.internal.pushB\022Pro" +
- "visioningProtos"
- };
- com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
- new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
- public com.google.protobuf.ExtensionRegistry assignDescriptors(
- com.google.protobuf.Descriptors.FileDescriptor root) {
- descriptor = root;
- internal_static_signalservice_ProvisionEnvelope_descriptor =
- getDescriptor().getMessageTypes().get(0);
- internal_static_signalservice_ProvisionEnvelope_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_signalservice_ProvisionEnvelope_descriptor,
- new java.lang.String[] { "PublicKey", "Body", });
- internal_static_signalservice_ProvisionMessage_descriptor =
- getDescriptor().getMessageTypes().get(1);
- internal_static_signalservice_ProvisionMessage_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_signalservice_ProvisionMessage_descriptor,
- new java.lang.String[] { "IdentityKeyPublic", "IdentityKeyPrivate", "Number", "ProvisioningCode", "UserAgent", "ProfileKey", "ReadReceipts", });
- return null;
- }
- };
- com.google.protobuf.Descriptors.FileDescriptor
- .internalBuildGeneratedFileFrom(descriptorData,
- new com.google.protobuf.Descriptors.FileDescriptor[] {
- }, assigner);
- }
-
- // @@protoc_insertion_point(outer_class_scope)
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/PushServiceSocket.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/PushServiceSocket.java
deleted file mode 100644
index 3d5272fe12..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/PushServiceSocket.java
+++ /dev/null
@@ -1,669 +0,0 @@
-/*
- * Copyright (C) 2014-2017 Open Whisper Systems
- *
- * Licensed according to the LICENSE file in this repository.
- */
-
-package org.session.libsignal.service.internal.push;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.JsonProcessingException;
-
-import org.session.libsignal.libsignal.IdentityKey;
-import org.session.libsignal.libsignal.ecc.ECPublicKey;
-import org.session.libsignal.utilities.logging.Log;
-import org.session.libsignal.libsignal.util.Pair;
-import org.session.libsignal.libsignal.util.guava.Optional;
-import org.session.libsignal.service.api.crypto.UnidentifiedAccess;
-import org.session.libsignal.service.api.messages.SignalServiceAttachment.ProgressListener;
-import org.session.libsignal.service.api.profiles.SignalServiceProfile;
-import org.session.libsignal.service.api.push.ContactTokenDetails;
-import org.session.libsignal.service.api.push.SignalServiceAddress;
-import org.session.libsignal.service.api.push.SignedPreKeyEntity;
-import org.session.libsignal.service.api.push.exceptions.AuthorizationFailedException;
-import org.session.libsignal.service.api.push.exceptions.CaptchaRequiredException;
-import org.session.libsignal.service.api.push.exceptions.ExpectationFailedException;
-import org.session.libsignal.service.api.push.exceptions.NonSuccessfulResponseCodeException;
-import org.session.libsignal.service.api.push.exceptions.NotFoundException;
-import org.session.libsignal.service.api.push.exceptions.PushNetworkException;
-import org.session.libsignal.service.api.push.exceptions.RateLimitException;
-import org.session.libsignal.service.api.push.exceptions.RemoteAttestationResponseExpiredException;
-import org.session.libsignal.service.api.push.exceptions.UnregisteredUserException;
-import org.session.libsignal.service.api.util.CredentialsProvider;
-import org.session.libsignal.service.api.util.Tls12SocketFactory;
-import org.session.libsignal.service.internal.configuration.SignalServiceConfiguration;
-import org.session.libsignal.service.internal.configuration.SignalUrl;
-import org.session.libsignal.service.internal.contacts.entities.DiscoveryRequest;
-import org.session.libsignal.service.internal.contacts.entities.DiscoveryResponse;
-import org.session.libsignal.service.internal.contacts.entities.RemoteAttestationRequest;
-import org.session.libsignal.service.internal.contacts.entities.RemoteAttestationResponse;
-import org.session.libsignal.service.internal.push.exceptions.MismatchedDevicesException;
-import org.session.libsignal.service.internal.push.exceptions.StaleDevicesException;
-import org.session.libsignal.service.internal.push.http.DigestingRequestBody;
-import org.session.libsignal.service.internal.push.http.OutputStreamFactory;
-import org.session.libsignal.utilities.Base64;
-import org.session.libsignal.service.internal.util.BlacklistingTrustManager;
-import org.session.libsignal.utilities.Hex;
-import org.session.libsignal.utilities.JsonUtil;
-import org.session.libsignal.service.internal.util.Util;
-
-import java.io.ByteArrayOutputStream;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
-import java.security.KeyManagementException;
-import java.security.KeyStore;
-import java.security.KeyStoreException;
-import java.security.NoSuchAlgorithmException;
-import java.security.SecureRandom;
-import java.util.Collections;
-import java.util.HashSet;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Locale;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.TimeUnit;
-
-import javax.net.ssl.SSLContext;
-import javax.net.ssl.TrustManager;
-import javax.net.ssl.TrustManagerFactory;
-import javax.net.ssl.X509TrustManager;
-
-import okhttp3.Call;
-import okhttp3.ConnectionSpec;
-import okhttp3.Credentials;
-import okhttp3.MediaType;
-import okhttp3.MultipartBody;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.RequestBody;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-
-/**
- * @author Moxie Marlinspike
- */
-public class PushServiceSocket {
-
- private static final String TAG = PushServiceSocket.class.getSimpleName();
-
- private static final String CREATE_ACCOUNT_SMS_PATH = "/v1/accounts/sms/code/%s?client=%s";
- private static final String CREATE_ACCOUNT_VOICE_PATH = "/v1/accounts/voice/code/%s";
- private static final String VERIFY_ACCOUNT_CODE_PATH = "/v1/accounts/code/%s";
- private static final String REGISTER_GCM_PATH = "/v1/accounts/gcm/";
- private static final String TURN_SERVER_INFO = "/v1/accounts/turn";
- private static final String SET_ACCOUNT_ATTRIBUTES = "/v1/accounts/attributes/";
- private static final String PIN_PATH = "/v1/accounts/pin/";
-
- private static final String PREKEY_METADATA_PATH = "/v2/keys/";
- private static final String PREKEY_PATH = "/v2/keys/%s";
- private static final String PREKEY_DEVICE_PATH = "/v2/keys/%s/%s";
- private static final String SIGNED_PREKEY_PATH = "/v2/keys/signed";
-
- private static final String PROVISIONING_CODE_PATH = "/v1/devices/provisioning/code";
- private static final String PROVISIONING_MESSAGE_PATH = "/v1/provisioning/%s";
- private static final String DEVICE_PATH = "/v1/devices/%s";
-
- private static final String DIRECTORY_TOKENS_PATH = "/v1/directory/tokens";
- private static final String DIRECTORY_VERIFY_PATH = "/v1/directory/%s";
- private static final String DIRECTORY_AUTH_PATH = "/v1/directory/auth";
- private static final String DIRECTORY_FEEDBACK_PATH = "/v1/directory/feedback-v3/%s";
- private static final String MESSAGE_PATH = "/v1/messages/%s";
- private static final String SENDER_ACK_MESSAGE_PATH = "/v1/messages/%s/%d";
- private static final String UUID_ACK_MESSAGE_PATH = "/v1/messages/uuid/%s";
- private static final String ATTACHMENT_PATH = "/v2/attachments/form/upload";
-
- private static final String PROFILE_PATH = "/v1/profile/%s";
-
- private static final String SENDER_CERTIFICATE_PATH = "/v1/certificate/delivery";
-
- private static final String ATTACHMENT_DOWNLOAD_PATH = "attachments/%d";
- private static final String ATTACHMENT_UPLOAD_PATH = "attachments/";
-
- private static final String STICKER_MANIFEST_PATH = "stickers/%s/manifest.proto";
- private static final String STICKER_PATH = "stickers/%s/full/%d";
-
- private static final Map NO_HEADERS = Collections.emptyMap();
- private static final ResponseCodeHandler NO_HANDLER = new EmptyResponseCodeHandler();
-
- private long soTimeoutMillis = TimeUnit.SECONDS.toMillis(30);
- private final Set connections = new HashSet();
-
- private final ServiceConnectionHolder[] serviceClients;
- private final ConnectionHolder[] cdnClients;
- private final ConnectionHolder[] contactDiscoveryClients;
- private final OkHttpClient attachmentClient;
-
- private final CredentialsProvider credentialsProvider;
- private final String userAgent;
- private final SecureRandom random;
-
- public PushServiceSocket(SignalServiceConfiguration signalServiceConfiguration, CredentialsProvider credentialsProvider, String userAgent) {
- this.credentialsProvider = credentialsProvider;
- this.userAgent = userAgent;
- this.serviceClients = createServiceConnectionHolders(signalServiceConfiguration.getSignalServiceUrls());
- this.cdnClients = createConnectionHolders(signalServiceConfiguration.getSignalCdnUrls());
- this.contactDiscoveryClients = createConnectionHolders(signalServiceConfiguration.getSignalContactDiscoveryUrls());
- this.attachmentClient = createAttachmentClient();
- this.random = new SecureRandom();
- }
-
- public List getMessages() throws IOException {
- String responseText = makeServiceRequest(String.format(MESSAGE_PATH, ""), "GET", null);
- return JsonUtil.fromJson(responseText, SignalServiceEnvelopeEntityList.class).getMessages();
- }
-
- public void acknowledgeMessage(String sender, long timestamp) throws IOException {
- makeServiceRequest(String.format(SENDER_ACK_MESSAGE_PATH, sender, timestamp), "DELETE", null);
- }
-
- public byte[] retrieveSticker(byte[] packId, int stickerId)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- String hexPackId = Hex.toStringCondensed(packId);
- ByteArrayOutputStream output = new ByteArrayOutputStream();
-
- downloadFromCdn(output, String.format(STICKER_PATH, hexPackId, stickerId), 1024 * 1024, null);
-
- return output.toByteArray();
- }
-
- public byte[] retrieveStickerManifest(byte[] packId)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- String hexPackId = Hex.toStringCondensed(packId);
- ByteArrayOutputStream output = new ByteArrayOutputStream();
-
- downloadFromCdn(output, String.format(STICKER_MANIFEST_PATH, hexPackId), 1024 * 1024, null);
-
- return output.toByteArray();
- }
-
- public SignalServiceProfile retrieveProfile(SignalServiceAddress target, Optional unidentifiedAccess)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- try {
- String response = makeServiceRequest(String.format(PROFILE_PATH, target.getNumber()), "GET", null, NO_HEADERS, unidentifiedAccess);
- return JsonUtil.fromJson(response, SignalServiceProfile.class);
- } catch (IOException e) {
- Log.w(TAG, e);
- throw new NonSuccessfulResponseCodeException("Unable to parse entity");
- }
- }
-
- private void downloadFromCdn(OutputStream outputStream, String path, int maxSizeBytes, ProgressListener listener)
- throws PushNetworkException, NonSuccessfulResponseCodeException
- {
- ConnectionHolder connectionHolder = getRandom(cdnClients, random);
- OkHttpClient okHttpClient = connectionHolder.getClient()
- .newBuilder()
- .connectTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .readTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .build();
-
- Request.Builder request = new Request.Builder().url(connectionHolder.getUrl() + "/" + path).get();
-
- if (connectionHolder.getHostHeader().isPresent()) {
- request.addHeader("Host", connectionHolder.getHostHeader().get());
- }
-
- Call call = okHttpClient.newCall(request.build());
-
- synchronized (connections) {
- connections.add(call);
- }
-
- Response response;
-
- try {
- response = call.execute();
-
- if (response.isSuccessful()) {
- ResponseBody body = response.body();
-
- if (body == null) throw new PushNetworkException("No response body!");
- if (body.contentLength() > maxSizeBytes) throw new PushNetworkException("Response exceeds max size!");
-
- InputStream in = body.byteStream();
- byte[] buffer = new byte[32768];
-
- int read, totalRead = 0;
-
- while ((read = in.read(buffer, 0, buffer.length)) != -1) {
- outputStream.write(buffer, 0, read);
- if ((totalRead += read) > maxSizeBytes) throw new PushNetworkException("Response exceeded max size!");
-
- if (listener != null) {
- listener.onAttachmentProgress(body.contentLength(), totalRead);
- }
- }
-
- return;
- }
- } catch (IOException e) {
- throw new PushNetworkException(e);
- } finally {
- synchronized (connections) {
- connections.remove(call);
- }
- }
-
- throw new NonSuccessfulResponseCodeException("Response: " + response);
- }
-
- private String makeServiceRequest(String urlFragment, String method, String body)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- return makeServiceRequest(urlFragment, method, body, NO_HEADERS, NO_HANDLER, Optional.absent());
- }
-
- private String makeServiceRequest(String urlFragment, String method, String body, Map headers)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- return makeServiceRequest(urlFragment, method, body, headers, NO_HANDLER, Optional.absent());
- }
-
- private String makeServiceRequest(String urlFragment, String method, String body, Map headers, ResponseCodeHandler responseCodeHandler)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- return makeServiceRequest(urlFragment, method, body, headers, responseCodeHandler, Optional.absent());
- }
-
- private String makeServiceRequest(String urlFragment, String method, String body, Map headers, Optional unidentifiedAccessKey)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- return makeServiceRequest(urlFragment, method, body, headers, NO_HANDLER, unidentifiedAccessKey);
- }
-
- private String makeServiceRequest(String urlFragment, String method, String body, Map headers, ResponseCodeHandler responseCodeHandler, Optional unidentifiedAccessKey)
- throws NonSuccessfulResponseCodeException, PushNetworkException
- {
- Response response = getServiceConnection(urlFragment, method, body, headers, unidentifiedAccessKey);
-
- int responseCode;
- String responseMessage;
- String responseBody;
-
- try {
- responseCode = response.code();
- responseMessage = response.message();
- responseBody = response.body().string();
- } catch (IOException ioe) {
- throw new PushNetworkException(ioe);
- }
-
- responseCodeHandler.handle(responseCode);
-
- switch (responseCode) {
- case 413:
- throw new RateLimitException("Rate limit exceeded: " + responseCode);
- case 401:
- case 403:
- throw new AuthorizationFailedException("Authorization failed!");
- case 404:
- throw new NotFoundException("Not found");
- case 409:
- MismatchedDevices mismatchedDevices;
-
- try {
- mismatchedDevices = JsonUtil.fromJson(responseBody, MismatchedDevices.class);
- } catch (JsonProcessingException e) {
- Log.w(TAG, e);
- throw new NonSuccessfulResponseCodeException("Bad response: " + responseCode + " " + responseMessage);
- } catch (IOException e) {
- throw new PushNetworkException(e);
- }
-
- throw new MismatchedDevicesException(mismatchedDevices);
- case 410:
- StaleDevices staleDevices;
-
- try {
- staleDevices = JsonUtil.fromJson(responseBody, StaleDevices.class);
- } catch (JsonProcessingException e) {
- throw new NonSuccessfulResponseCodeException("Bad response: " + responseCode + " " + responseMessage);
- } catch (IOException e) {
- throw new PushNetworkException(e);
- }
-
- throw new StaleDevicesException(staleDevices);
- case 411:
- DeviceLimit deviceLimit;
-
- try {
- deviceLimit = JsonUtil.fromJson(responseBody, DeviceLimit.class);
- } catch (JsonProcessingException e) {
- throw new NonSuccessfulResponseCodeException("Bad response: " + responseCode + " " + responseMessage);
- } catch (IOException e) {
- throw new PushNetworkException(e);
- }
-
- throw new DeviceLimitExceededException(deviceLimit);
- case 417:
- throw new ExpectationFailedException();
- case 423:
- RegistrationLockFailure accountLockFailure;
-
- try {
- accountLockFailure = JsonUtil.fromJson(responseBody, RegistrationLockFailure.class);
- } catch (JsonProcessingException e) {
- Log.w(TAG, e);
- throw new NonSuccessfulResponseCodeException("Bad response: " + responseCode + " " + responseMessage);
- } catch (IOException e) {
- throw new PushNetworkException(e);
- }
-
- throw new LockedException(accountLockFailure.length, accountLockFailure.timeRemaining);
- }
-
- if (responseCode != 200 && responseCode != 204) {
- throw new NonSuccessfulResponseCodeException("Bad response: " + responseCode + " " +
- responseMessage);
- }
-
- return responseBody;
- }
-
- private Response getServiceConnection(String urlFragment, String method, String body, Map headers, Optional unidentifiedAccess)
- throws PushNetworkException
- {
- try {
- ServiceConnectionHolder connectionHolder = (ServiceConnectionHolder) getRandom(serviceClients, random);
- OkHttpClient baseClient = unidentifiedAccess.isPresent() ? connectionHolder.getUnidentifiedClient() : connectionHolder.getClient();
- OkHttpClient okHttpClient = baseClient.newBuilder()
- .connectTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .readTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .build();
-
- Log.w(TAG, "Push service URL: " + connectionHolder.getUrl());
- Log.w(TAG, "Opening URL: " + String.format("%s%s", connectionHolder.getUrl(), urlFragment));
-
- Request.Builder request = new Request.Builder();
- request.url(String.format("%s%s", connectionHolder.getUrl(), urlFragment));
-
- if (body != null) {
- request.method(method, RequestBody.create(MediaType.parse("application/json"), body));
- } else {
- request.method(method, null);
- }
-
- for (Map.Entry header : headers.entrySet()) {
- request.addHeader(header.getKey(), header.getValue());
- }
-
- if (unidentifiedAccess.isPresent()) {
- request.addHeader("Unidentified-Access-Key", Base64.encodeBytes(unidentifiedAccess.get().getUnidentifiedAccessKey()));
- } else if (credentialsProvider.getPassword() != null) {
- request.addHeader("Authorization", getAuthorizationHeader(credentialsProvider));
- }
-
- if (userAgent != null) {
- request.addHeader("X-Signal-Agent", userAgent);
- }
-
- if (connectionHolder.getHostHeader().isPresent()) {
- request.addHeader("Host", connectionHolder.getHostHeader().get());
- }
-
- Call call = okHttpClient.newCall(request.build());
-
- synchronized (connections) {
- connections.add(call);
- }
-
- try {
- return call.execute();
- } finally {
- synchronized (connections) {
- connections.remove(call);
- }
- }
- } catch (IOException e) {
- throw new PushNetworkException(e);
- }
- }
-
- private Response makeContactDiscoveryRequest(String authorization, List cookies, String path, String method, String body)
- throws PushNetworkException, NonSuccessfulResponseCodeException
- {
- ConnectionHolder connectionHolder = getRandom(contactDiscoveryClients, random);
- OkHttpClient okHttpClient = connectionHolder.getClient()
- .newBuilder()
- .connectTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .readTimeout(soTimeoutMillis, TimeUnit.MILLISECONDS)
- .build();
-
- Request.Builder request = new Request.Builder().url(connectionHolder.getUrl() + path);
-
- if (body != null) {
- request.method(method, RequestBody.create(MediaType.parse("application/json"), body));
- } else {
- request.method(method, null);
- }
-
- if (connectionHolder.getHostHeader().isPresent()) {
- request.addHeader("Host", connectionHolder.getHostHeader().get());
- }
-
- if (authorization != null) {
- request.addHeader("Authorization", authorization);
- }
-
- if (cookies != null && !cookies.isEmpty()) {
- request.addHeader("Cookie", Util.join(cookies, "; "));
- }
-
- Call call = okHttpClient.newCall(request.build());
-
- synchronized (connections) {
- connections.add(call);
- }
-
- Response response;
-
- try {
- response = call.execute();
-
- if (response.isSuccessful()) {
- return response;
- }
- } catch (IOException e) {
- throw new PushNetworkException(e);
- } finally {
- synchronized (connections) {
- connections.remove(call);
- }
- }
-
- switch (response.code()) {
- case 401:
- case 403:
- throw new AuthorizationFailedException("Authorization failed!");
- case 409:
- throw new RemoteAttestationResponseExpiredException("Remote attestation response expired");
- case 429:
- throw new RateLimitException("Rate limit exceeded: " + response.code());
- }
-
- throw new NonSuccessfulResponseCodeException("Response: " + response);
- }
-
- private ServiceConnectionHolder[] createServiceConnectionHolders(SignalUrl[] urls) {
- List serviceConnectionHolders = new LinkedList();
-
- for (SignalUrl url : urls) {
- serviceConnectionHolders.add(new ServiceConnectionHolder(createConnectionClient(url),
- createConnectionClient(url),
- url.getUrl(), url.getHostHeader()));
- }
-
- return serviceConnectionHolders.toArray(new ServiceConnectionHolder[0]);
- }
-
- private ConnectionHolder[] createConnectionHolders(SignalUrl[] urls) {
- List connectionHolders = new LinkedList();
-
- for (SignalUrl url : urls) {
- connectionHolders.add(new ConnectionHolder(createConnectionClient(url), url.getUrl(), url.getHostHeader()));
- }
-
- return connectionHolders.toArray(new ConnectionHolder[0]);
- }
-
- private OkHttpClient createConnectionClient(SignalUrl url) {
- try {
- TrustManager[] trustManagers = BlacklistingTrustManager.createFor(url.getTrustStore());
-
- SSLContext context = SSLContext.getInstance("TLS");
- context.init(null, trustManagers, null);
-
- return new OkHttpClient.Builder()
- .sslSocketFactory(new Tls12SocketFactory(context.getSocketFactory()), (X509TrustManager)trustManagers[0])
- .connectionSpecs(url.getConnectionSpecs().or(Util.immutableList(ConnectionSpec.RESTRICTED_TLS)))
- .build();
- } catch (NoSuchAlgorithmException e) {
- throw new AssertionError(e);
- } catch (KeyManagementException e) {
- throw new AssertionError(e);
- }
- }
-
- private OkHttpClient createAttachmentClient() {
- try {
- SSLContext context = SSLContext.getInstance("TLS");
- context.init(null, null, null);
-
- TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
- trustManagerFactory.init((KeyStore)null);
-
- return new OkHttpClient.Builder()
- .sslSocketFactory(new Tls12SocketFactory(context.getSocketFactory()),
- (X509TrustManager)trustManagerFactory.getTrustManagers()[0])
- .connectionSpecs(Util.immutableList(ConnectionSpec.RESTRICTED_TLS))
- .build();
- } catch (NoSuchAlgorithmException e) {
- throw new AssertionError(e);
- } catch (KeyManagementException e) {
- throw new AssertionError(e);
- } catch (KeyStoreException e) {
- throw new AssertionError(e);
- }
- }
-
- private String getAuthorizationHeader(CredentialsProvider credentialsProvider) {
- try {
- return "Basic " + Base64.encodeBytes((credentialsProvider.getUser() + ":" + credentialsProvider.getPassword()).getBytes("UTF-8"));
- } catch (UnsupportedEncodingException e) {
- throw new AssertionError(e);
- }
- }
-
- private ConnectionHolder getRandom(ConnectionHolder[] connections, SecureRandom random) {
- return connections[random.nextInt(connections.length)];
- }
-
- private static class GcmRegistrationId {
-
- @JsonProperty
- private String gcmRegistrationId;
-
- @JsonProperty
- private boolean webSocketChannel;
-
- public GcmRegistrationId() {}
-
- public GcmRegistrationId(String gcmRegistrationId, boolean webSocketChannel) {
- this.gcmRegistrationId = gcmRegistrationId;
- this.webSocketChannel = webSocketChannel;
- }
- }
-
- private static class RegistrationLock {
- @JsonProperty
- private String pin;
-
- public RegistrationLock() {}
-
- public RegistrationLock(String pin) {
- this.pin = pin;
- }
- }
-
- private static class RegistrationLockFailure {
- @JsonProperty
- private int length;
-
- @JsonProperty
- private long timeRemaining;
- }
-
- private static class AttachmentDescriptor {
- @JsonProperty
- private long id;
-
- @JsonProperty
- private String location;
-
- public long getId() {
- return id;
- }
-
- public String getLocation() {
- return location;
- }
- }
-
-
- private static class ConnectionHolder {
-
- private final OkHttpClient client;
- private final String url;
- private final Optional hostHeader;
-
- private ConnectionHolder(OkHttpClient client, String url, Optional hostHeader) {
- this.client = client;
- this.url = url;
- this.hostHeader = hostHeader;
- }
-
- OkHttpClient getClient() {
- return client;
- }
-
- public String getUrl() {
- return url;
- }
-
- Optional getHostHeader() {
- return hostHeader;
- }
- }
-
- private static class ServiceConnectionHolder extends ConnectionHolder {
-
- private final OkHttpClient unidentifiedClient;
-
- private ServiceConnectionHolder(OkHttpClient identifiedClient, OkHttpClient unidentifiedClient, String url, Optional hostHeader) {
- super(identifiedClient, url, hostHeader);
- this.unidentifiedClient = unidentifiedClient;
- }
-
- OkHttpClient getUnidentifiedClient() {
- return unidentifiedClient;
- }
- }
-
- private interface ResponseCodeHandler {
- void handle(int responseCode) throws NonSuccessfulResponseCodeException, PushNetworkException;
- }
-
- private static class EmptyResponseCodeHandler implements ResponseCodeHandler {
- @Override
- public void handle(int responseCode) { }
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SendMessageResponse.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/SendMessageResponse.java
deleted file mode 100644
index b7ff39de67..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SendMessageResponse.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package org.session.libsignal.service.internal.push;
-
-public class SendMessageResponse {
-
- private boolean needsSync;
-
- public SendMessageResponse() {}
-
- public SendMessageResponse(boolean needsSync) {
- this.needsSync = needsSync;
- }
-
- public boolean getNeedsSync() {
- return needsSync;
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SenderCertificate.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/SenderCertificate.java
deleted file mode 100644
index 3765ac9893..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SenderCertificate.java
+++ /dev/null
@@ -1,45 +0,0 @@
-package org.session.libsignal.service.internal.push;
-
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.core.JsonGenerator;
-import com.fasterxml.jackson.core.JsonParser;
-import com.fasterxml.jackson.databind.DeserializationContext;
-import com.fasterxml.jackson.databind.JsonDeserializer;
-import com.fasterxml.jackson.databind.JsonSerializer;
-import com.fasterxml.jackson.databind.SerializerProvider;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
-import com.fasterxml.jackson.databind.annotation.JsonSerialize;
-
-import org.session.libsignal.utilities.Base64;
-
-import java.io.IOException;
-
-public class SenderCertificate {
-
- @JsonProperty
- @JsonDeserialize(using = ByteArrayDesieralizer.class)
- @JsonSerialize(using = ByteArraySerializer.class)
- private byte[] certificate;
-
- public SenderCertificate() {}
-
- public byte[] getCertificate() {
- return certificate;
- }
-
- public static class ByteArraySerializer extends JsonSerializer {
- @Override
- public void serialize(byte[] value, JsonGenerator gen, SerializerProvider serializers) throws IOException {
- gen.writeString(Base64.encodeBytes(value));
- }
- }
-
- public static class ByteArrayDesieralizer extends JsonDeserializer {
-
- @Override
- public byte[] deserialize(JsonParser p, DeserializationContext ctxt) throws IOException {
- return Base64.decode(p.getValueAsString());
- }
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntity.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntity.java
deleted file mode 100644
index 4c0424d92e..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntity.java
+++ /dev/null
@@ -1,57 +0,0 @@
-package org.session.libsignal.service.internal.push;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-public class SignalServiceEnvelopeEntity {
-
- @JsonProperty
- private int type;
-
- @JsonProperty
- private String relay;
-
- @JsonProperty
- private long timestamp;
-
- @JsonProperty
- private String source;
-
- @JsonProperty
- private int sourceDevice;
-
- @JsonProperty
- private byte[] content;
-
- @JsonProperty
- private long serverTimestamp;
-
- public SignalServiceEnvelopeEntity() {}
-
- public int getType() {
- return type;
- }
-
- public String getRelay() {
- return relay;
- }
-
- public long getTimestamp() {
- return timestamp;
- }
-
- public String getSource() {
- return source;
- }
-
- public int getSourceDevice() {
- return sourceDevice;
- }
-
- public byte[] getContent() {
- return content;
- }
-
- public long getServerTimestamp() {
- return serverTimestamp;
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntityList.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntityList.java
deleted file mode 100644
index 52b49d02e1..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/SignalServiceEnvelopeEntityList.java
+++ /dev/null
@@ -1,14 +0,0 @@
-package org.session.libsignal.service.internal.push;
-
-import java.util.List;
-
-public class SignalServiceEnvelopeEntityList {
-
- private List messages;
-
- public SignalServiceEnvelopeEntityList() {}
-
- public List getMessages() {
- return messages;
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/StaleDevices.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/StaleDevices.java
deleted file mode 100644
index bcce154c43..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/StaleDevices.java
+++ /dev/null
@@ -1,21 +0,0 @@
-/**
- * Copyright (C) 2014-2016 Open Whisper Systems
- *
- * Licensed according to the LICENSE file in this repository.
- */
-
-package org.session.libsignal.service.internal.push;
-
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-import java.util.List;
-
-public class StaleDevices {
-
- @JsonProperty
- private List staleDevices;
-
- public List getStaleDevices() {
- return staleDevices;
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/MismatchedDevicesException.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/MismatchedDevicesException.java
deleted file mode 100644
index 31a06266d2..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/MismatchedDevicesException.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/**
- * Copyright (C) 2014-2016 Open Whisper Systems
- *
- * Licensed according to the LICENSE file in this repository.
- */
-
-package org.session.libsignal.service.internal.push.exceptions;
-
-import org.session.libsignal.service.api.push.exceptions.NonSuccessfulResponseCodeException;
-import org.session.libsignal.service.internal.push.MismatchedDevices;
-
-public class MismatchedDevicesException extends NonSuccessfulResponseCodeException {
-
- private final MismatchedDevices mismatchedDevices;
-
- public MismatchedDevicesException(MismatchedDevices mismatchedDevices) {
- this.mismatchedDevices = mismatchedDevices;
- }
-
- public MismatchedDevices getMismatchedDevices() {
- return mismatchedDevices;
- }
-}
diff --git a/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/StaleDevicesException.java b/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/StaleDevicesException.java
deleted file mode 100644
index ea1c9efdc2..0000000000
--- a/libsignal/src/main/java/org/session/libsignal/service/internal/push/exceptions/StaleDevicesException.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/**
- * Copyright (C) 2014-2016 Open Whisper Systems
- *
- * Licensed according to the LICENSE file in this repository.
- */
-
-package org.session.libsignal.service.internal.push.exceptions;
-
-import org.session.libsignal.service.api.push.exceptions.NonSuccessfulResponseCodeException;
-import org.session.libsignal.service.internal.push.StaleDevices;
-
-public class StaleDevicesException extends NonSuccessfulResponseCodeException {
-
- private final StaleDevices staleDevices;
-
- public StaleDevicesException(StaleDevices staleDevices) {
- this.staleDevices = staleDevices;
- }
-
- public StaleDevices getStaleDevices() {
- return staleDevices;
- }
-}