From 0a28420175f229f8c1684e1773e0095567982536 Mon Sep 17 00:00:00 2001
From: Ruben De Smet <ruben.de.smet@rubdos.be>
Date: Thu, 9 Jul 2020 18:56:16 +0200
Subject: [PATCH] Add is_signal_key_encrypted, is_signal_service_envelope.

---
 libsignal-service/src/proto.rs | 39 ++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)

diff --git a/libsignal-service/src/proto.rs b/libsignal-service/src/proto.rs
index af7dd6d2f..1cc94ea92 100644
--- a/libsignal-service/src/proto.rs
+++ b/libsignal-service/src/proto.rs
@@ -1 +1,40 @@
 include!(concat!(env!("OUT_DIR"), "/signalservice.rs"));
+
+use std::ops::Deref;
+
+impl WebSocketRequestMessage {
+    /// Equivalent of
+    /// `SignalServiceMessagePipe::isSignalServiceEnvelope(WebSocketMessage)`.
+    fn is_signal_service_envelope(&self) -> bool {
+        self.verb.as_ref().map(Deref::deref) == Some("PUT")
+            && self.path.as_ref().map(Deref::deref) == Some("/api/v1/message")
+    }
+
+    /// Equivalent of
+    /// `SignalServiceMessagePipe::isSignalKeyEncrypted(WebSocketMessage)`.
+    fn is_signal_key_encrypted(&self) -> bool {
+        if self.headers.len() == 0 {
+            return true;
+        }
+
+        for header in &self.headers {
+            let parts: Vec<_> = header.split(':').collect();
+            if parts.len() != 2 {
+                log::warn!(
+                    "Got a weird header: {:?}, split in {:?}",
+                    header,
+                    parts
+                );
+                continue;
+            }
+
+            if parts[0].trim().eq_ignore_ascii_case("X-Signal-Key") {
+                if parts[1].trim().eq_ignore_ascii_case("false") {
+                    return false;
+                }
+            }
+        }
+
+        false
+    }
+}