chore: add copywrite declarations

Author: cabljac

packages/auth/src/mutations.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import {
   ActionCodeInfo,
   ActionCodeSettings,

packages/auth/src/useAuthFetchSignInMethodsForEmail.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import {
   QueryKey,
   useQuery,

packages/auth/src/useAuthGetRedirectResult.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import {
   QueryKey,
   useQuery,

packages/auth/src/useAuthIdToken.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import { QueryKey, UseQueryOptions, UseQueryResult } from "react-query";
 import { Auth, AuthError, IdTokenResult } from "firebase/auth";
 import { useSubscription } from "../../utils/src/useSubscription";

packages/auth/src/useAuthUser.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import { QueryKey, UseQueryOptions, UseQueryResult } from "react-query";
 import { Auth, AuthError, NextOrObserver, User } from "firebase/auth";
 import { useSubscription } from "../../utils/src/useSubscription";

packages/database/__test__/useDatabaseSnapshot.test.ts

@@ -166,7 +166,6 @@ describe("Database", () => {
       await hook2.waitFor(() => hook2.result.current.isSuccess, {
         timeout: 5000,
       });
-      console.log(mock2.mock.calls.map((call) => call[0]));
 
       expect(mock1.mock.calls.length).toBe(1);
 
@@ -395,7 +394,6 @@ describe("Database", () => {
       await hook2.waitFor(() => hook2.result.current.isSuccess, {
         timeout: 5000,
       });
-      console.log(mock2.mock.calls.map((call) => call[0]));
 
       expect(mock1.mock.calls.length).toBe(1);
 

packages/database/src/useDatabaseMutation.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import {
   useMutation,
   UseMutationOptions,

packages/database/src/useDatabaseSnapshot.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import { QueryKey, UseQueryOptions, UseQueryResult } from "react-query";
 import { DatabaseReference, onValue, DataSnapshot } from "firebase/database";
 import { useCallback } from "react";

packages/firestore/src/namedQuery.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import {
   Firestore,
   Query,

packages/utils/src/useSubscription.ts

@@ -1,3 +1,19 @@
+/*
+ * Copyright (c) 2016-present Invertase Limited & Contributors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this library 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.
+ *
+ */
 import { Unsubscribe as AuthUnsubscribe } from "firebase/auth";
 import { Unsubscribe as FirestoreUnsubscribe } from "firebase/firestore";
 import { Unsubscribe as DatabaseUnsubscribe } from "firebase/database";
@@ -31,31 +47,29 @@ type UseSubscriptionOptions<TData, TError, R> = UseQueryOptions<
   fetchFn?: () => Promise<TData>;
 };
 
+/**
+ * Utility hook to subscribe to events, given a function that returns an observer callback.
+ * @param queryKey The react-query queryKey
+ * @param subscriptionKey A hashable key to store the subscription
+ * @param subscribeFn Returns an unsubscribe function to the event, the argument of subscribeFn is a callback to set data.
+ * @param options
+ * @returns
+ */
 export function useSubscription<TData, TError, R = TData>(
   queryKey: QueryKey,
   subscriptionKey: QueryKey,
   subscribeFn: (cb: (data: TData | null) => Promise<void>) => Unsubscribe,
   options?: UseSubscriptionOptions<TData, TError, R>
 ): UseQueryResult<R, TError> {
-  useEffect(() => {
-    if (!options?.onlyOnce) {
-      observerCount[subscriptionHash] += 1;
-      return () => {
-        observerCount[subscriptionHash] -= 1;
-        cleanupSubscription(subscriptionHash);
-      };
-    }
-  }, []);
-
   const hashFn = options?.queryKeyHashFn || hashQueryKey;
   const subscriptionHash = hashFn(subscriptionKey);
+  const queryClient = useQueryClient();
 
   if (!options?.onlyOnce) {
+    // if it's a subscription, we have at least one observer now
     observerCount[subscriptionHash] ??= 1;
   }
 
-  const queryClient = useQueryClient();
-
   function cleanupSubscription(subscriptionHash: string) {
     if (observerCount[subscriptionHash] === 1) {
       const unsubscribe = unsubscribes[subscriptionHash];
@@ -64,6 +78,16 @@ export function useSubscription<TData, TError, R = TData>(
     }
   }
 
+  useEffect(() => {
+    if (!options?.onlyOnce) {
+      observerCount[subscriptionHash] += 1;
+      return () => {
+        observerCount[subscriptionHash] -= 1;
+        cleanupSubscription(subscriptionHash);
+      };
+    }
+  }, []);
+
   let resolvePromise: (data: TData | null) => void = () => null;
 
   const result: CancellablePromise<TData | null> = new Promise<TData | null>(