Hooked up special .info values. Special values .info/serverTimeOffset,

.info/authenticated, and  .info/connected can now be queried and will return
the appropriate results.

PiperOrigin-RevId: 256015690

Author: amablue

database/CMakeLists.txt

@@ -82,8 +82,10 @@ set(desktop_SRCS
     src/desktop/connection/web_socket_client_impl.cc
     src/desktop/core/child_event_registration.cc
     src/desktop/core/compound_write.cc
+    src/desktop/core/constants.cc
     src/desktop/core/event_registration.cc
     src/desktop/core/indexed_variant.cc
+    src/desktop/core/info_listen_provider.cc
     src/desktop/core/keep_synced_event_registration.cc
     src/desktop/core/listen_provider.cc
     src/desktop/core/operation.cc

database/src/desktop/connection/persistent_connection.cc

@@ -25,6 +25,7 @@
 #include "app/src/path.h"
 #include "app/src/time.h"
 #include "app/src/variant_util.h"
+#include "database/src/desktop/core/constants.h"
 #include "database/src/desktop/util_desktop.h"
 #include "database/src/include/firebase/database/common.h"
 
@@ -172,7 +173,10 @@ void PersistentConnection::OnReady(int64_t timestamp,
   // Trigger OnServerInfoUpdate based on timestamp delta
   LogDebug("%s Handle timestamp: %lld in ms", log_id_.c_str(), timestamp);
   int64_t time_delta = timestamp - ::firebase::internal::GetTimestampEpoch();
-  event_handler_->OnServerInfoUpdate(time_delta);
+  std::map<Variant, Variant> updates{
+      std::make_pair(kDotInfoServerTimeOffset, time_delta),
+  };
+  event_handler_->OnServerInfoUpdate(updates);
 
   // Send client SDK status
   if (is_first_connection_) {

database/src/desktop/connection/persistent_connection.h

@@ -543,7 +543,8 @@ class PersistentConnectionEventHandler {
 
   virtual void OnAuthStatus(bool auth_ok) = 0;
 
-  virtual void OnServerInfoUpdate(int64_t timestamp_delta) = 0;
+  virtual void OnServerInfoUpdate(
+      const std::map<Variant, Variant>& updates) = 0;
 
   virtual void OnDataUpdate(const Path& path, const Variant& payload_data,
                             bool is_merge,

database/src/desktop/core/constants.cc

@@ -0,0 +1,28 @@
+// Copyright 2019 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include "database/src/desktop/core/constants.h"
+
+namespace firebase {
+namespace database {
+namespace internal {
+
+const char kDotInfo[] = ".info";
+const char kDotInfoServerTimeOffset[] = "serverTimeOffset";
+const char kDotInfoAuthenticated[] = "authenticated";
+const char kDotInfoConnected[] = "connected";
+
+}  // namespace internal
+}  // namespace database
+}  // namespace firebase

database/src/desktop/core/constants.h

@@ -0,0 +1,31 @@
+// Copyright 2019 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#ifndef FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_CONSTANTS_H_
+#define FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_CONSTANTS_H_
+
+namespace firebase {
+namespace database {
+namespace internal {
+
+extern const char kDotInfo[];
+extern const char kDotInfoServerTimeOffset[];
+extern const char kDotInfoAuthenticated[];
+extern const char kDotInfoConnected[];
+
+}  // namespace internal
+}  // namespace database
+}  // namespace firebase
+
+#endif  // FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_CONSTANTS_H_

database/src/desktop/core/info_listen_provider.cc

@@ -0,0 +1,42 @@
+// Copyright 2019 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include "database/src/desktop/core/info_listen_provider.h"
+
+#include "database/src/common/query_spec.h"
+#include "database/src/desktop/connection/persistent_connection.h"
+#include "database/src/desktop/core/listen_provider.h"
+#include "database/src/desktop/util_desktop.h"
+#include "database/src/desktop/view/view.h"
+
+namespace firebase {
+namespace database {
+namespace internal {
+
+void InfoListenProvider::StartListening(const QuerySpec& query_spec,
+                                        const View* view) {
+  repo_->scheduler().Schedule([this, query_spec]() {
+    const Variant& value = VariantGetChild(info_data_, query_spec.path);
+    if (!VariantIsEmpty(value)) {
+      repo_->PostEvents(
+          sync_tree_->ApplyServerOverwrite(query_spec.path, value));
+    }
+  });
+}
+
+void InfoListenProvider::StopListening(const QuerySpec& query_spec) {}
+
+}  // namespace internal
+}  // namespace database
+}  // namespace firebase

database/src/desktop/core/info_listen_provider.h

@@ -0,0 +1,50 @@
+// Copyright 2019 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#ifndef FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_INFO_LISTEN_PROVIDER_H_
+#define FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_INFO_LISTEN_PROVIDER_H_
+
+#include "database/src/common/query_spec.h"
+#include "database/src/desktop/connection/persistent_connection.h"
+#include "database/src/desktop/core/listen_provider.h"
+#include "database/src/desktop/core/repo.h"
+
+namespace firebase {
+namespace database {
+namespace internal {
+
+class InfoListenProvider : public ListenProvider {
+ public:
+  InfoListenProvider(Repo* repo, Variant* info_data)
+      : repo_(repo), info_data_(info_data), sync_tree_(nullptr) {}
+
+  ~InfoListenProvider() override {}
+
+  void set_sync_tree(SyncTree* sync_tree) { sync_tree_ = sync_tree; }
+
+  void StartListening(const QuerySpec& query_spec, const View* view) override;
+
+  void StopListening(const QuerySpec& query_spec) override;
+
+ private:
+  Repo* repo_;
+  Variant* info_data_;
+  SyncTree* sync_tree_;
+};
+
+}  // namespace internal
+}  // namespace database
+}  // namespace firebase
+
+#endif  // FIREBASE_DATABASE_CLIENT_CPP_SRC_DESKTOP_CORE_INFO_LISTEN_PROVIDER_H_