Add GMPID setting

Author: schmidt-sebastian

firebase-database/CHANGELOG.md

@@ -1,4 +1,8 @@
 # Unreleased
+
+- [changed] Added internal HTTP header to the WebChannel connection.
+
+# 19.3.0
 - [feature] Added ServerValue.increment() to support atomic field value increments
   without transactions.
 

firebase-database/src/main/java/com/google/firebase/database/connection/ConnectionContext.java

@@ -24,6 +24,7 @@ public class ConnectionContext {
   private final boolean persistenceEnabled;
   private final String clientSdkVersion;
   private final String userAgent;
+  private final String applicationId;
   private final String sslCacheDirectory;
 
   public ConnectionContext(
@@ -33,13 +34,15 @@ public ConnectionContext(
       boolean persistenceEnabled,
       String clientSdkVersion,
       String userAgent,
+      String applicationId,
       String sslCacheDirectory) {
     this.logger = logger;
     this.authTokenProvider = authTokenProvider;
     this.executorService = executorService;
     this.persistenceEnabled = persistenceEnabled;
     this.clientSdkVersion = clientSdkVersion;
     this.userAgent = userAgent;
+    this.applicationId = applicationId;
     this.sslCacheDirectory = sslCacheDirectory;
   }
 
@@ -70,4 +73,8 @@ public String getUserAgent() {
   public String getSslCacheDirectory() {
     return sslCacheDirectory;
   }
+
+  public String getApplicationId() {
+    return applicationId;
+  }
 }

firebase-database/src/main/java/com/google/firebase/database/connection/PersistentConnectionImpl.java

@@ -244,6 +244,7 @@ private enum ConnectionState {
   private final Delegate delegate;
   private final HostInfo hostInfo;
   private String cachedHost;
+  private String applicationId;
   private HashSet<String> interruptReasons = new HashSet<String>();
   private boolean firstConnection = true;
   private long lastConnectionEstablishedTime;
@@ -280,6 +281,7 @@ public PersistentConnectionImpl(
     this.context = context;
     this.executorService = context.getExecutorService();
     this.authTokenProvider = context.getAuthTokenProvider();
+    this.applicationId = context.getApplicationId();
     this.hostInfo = info;
     this.listens = new HashMap<ListenQuerySpec, OutstandingListen>();
     this.requestCBHash = new HashMap<Long, ConnectionRequestCallback>();

firebase-database/src/main/java/com/google/firebase/database/connection/WebsocketConnection.java

@@ -186,6 +186,8 @@ private WSClient createConnection(
             host, hostInfo.isSecure(), hostInfo.getNamespace(), optLastSessionId);
     Map<String, String> extraHeaders = new HashMap<String, String>();
     extraHeaders.put("User-Agent", this.connectionContext.getUserAgent());
+    extraHeaders.put("X-Firebase-GMPID", this.connectionContext.getApplicationId());
+
     WebSocket ws = new WebSocket(this.connectionContext, uri, /*protocol=*/ null, extraHeaders);
     WSClientTubesock client = new WSClientTubesock(ws);
     return client;

firebase-database/src/main/java/com/google/firebase/database/core/Context.java

@@ -145,6 +145,7 @@ public ConnectionContext getConnectionContext() {
         this.isPersistenceEnabled(),
         FirebaseDatabase.getSdkVersion(),
         this.getUserAgent(),
+        firebaseApp.getOptions().getApplicationId(),
         this.getSSLCacheDirectory().getAbsolutePath());
   }