Merge pull request #201 from supabase/chore/firebase-test-cases

chore(firebase_fdw): align firebase test cases with docs

Author: burmecia

wrappers/dockerfiles/firebase/baseline-data/auth_export/accounts.json

@@ -1 +1 @@
-{"kind":"identitytoolkit#DownloadAccountResponse","users":[{"localId":"JeXJ2gUHCpYSQV6zXlRYfRYHUfMl","createdAt":"1668488830314","lastLoginAt":"1668488830310","displayName":"Bo Lu","photoUrl":"","passwordHash":"fakeHash:salt=fakeSaltNZhRYxXIjWaiXB75SD8z:password=adsf123","salt":"fakeSaltNZhRYxXIjWaiXB75SD8z","passwordUpdatedAt":1701484518847,"providerUserInfo":[{"providerId":"password","email":"[email protected]","federatedId":"[email protected]","rawId":"[email protected]","displayName":"Bo Lu","photoUrl":""}],"validSince":"1701484518","email":"[email protected]","emailVerified":false,"disabled":false},{"localId":"eUHS9EaQS2lZO0zbyMq28m02SUGP","createdAt":"1668488839113","lastLoginAt":"1668488839111","displayName":"Copple","photoUrl":"","passwordHash":"fakeHash:salt=fakeSaltL62cBYW58puy9DarO9TO:password=asdf123","salt":"fakeSaltL62cBYW58puy9DarO9TO","passwordUpdatedAt":1701484518848,"providerUserInfo":[{"providerId":"password","email":"[email protected]","federatedId":"[email protected]","rawId":"[email protected]","displayName":"Copple","photoUrl":""}],"validSince":"1701484518","email":"[email protected]","emailVerified":false,"disabled":false}]}
+{"kind":"identitytoolkit#DownloadAccountResponse","users":[{"localId":"JeXJ2gUHCpYSQV6zXlRYfRYHUfMl","createdAt":"1668488830314","lastLoginAt":"1668488830310","displayName":"Yoda","photoUrl":"","passwordHash":"fakeHash:salt=fakeSaltNZhRYxXIjWaiXB75SD8z:password=adsf123","salt":"fakeSaltNZhRYxXIjWaiXB75SD8z","passwordUpdatedAt":1701484518847,"providerUserInfo":[{"providerId":"password","email":"[email protected]","federatedId":"[email protected]","rawId":"[email protected]","displayName":"Yoda","photoUrl":""}],"validSince":"1701484518","email":"[email protected]","emailVerified":false,"disabled":false},{"localId":"eUHS9EaQS2lZO0zbyMq28m02SUGP","createdAt":"1668488839113","lastLoginAt":"1668488839111","displayName":"Luck","photoUrl":"","passwordHash":"fakeHash:salt=fakeSaltL62cBYW58puy9DarO9TO:password=asdf123","salt":"fakeSaltL62cBYW58puy9DarO9TO","passwordUpdatedAt":1701484518848,"providerUserInfo":[{"providerId":"password","email":"[email protected]","federatedId":"[email protected]","rawId":"[email protected]","displayName":"Luke","photoUrl":""}],"validSince":"1701484518","email":"[email protected]","emailVerified":false,"disabled":false}]}

wrappers/src/fdw/firebase_fdw/tests.rs

@@ -38,9 +38,10 @@ mod tests {
             c.update(
                 r#"
                   CREATE FOREIGN TABLE firebase_users (
-                    local_id text,
+                    uid text,
                     email text,
-                    fields jsonb
+                    created_at timestamp,
+                    attrs jsonb
                   )
                  SERVER my_firebase_server
                  OPTIONS (
@@ -54,20 +55,24 @@ mod tests {
             .unwrap();
 
             let results = c
-                .select("SELECT email FROM firebase_users", None, None)
+                .select(
+                    "SELECT email FROM firebase_users order by email",
+                    None,
+                    None,
+                )
                 .unwrap()
                 .filter_map(|r| r.get_by_name::<&str, _>("email").unwrap())
                 .collect::<Vec<_>>();
 
-            assert_eq!(results, vec!["[email protected]", "[email protected]"]);
+            assert_eq!(results, vec!["[email protected]", "[email protected]"]);
 
             c.update(
                 r#"
                 CREATE FOREIGN TABLE firebase_docs (
                   name text,
-                  fields jsonb,
-                  create_time timestamp,
-                  update_time timestamp
+                  created_at timestamp,
+                  updated_at timestamp,
+                  attrs jsonb
                 )
                 SERVER my_firebase_server
                 OPTIONS (
@@ -81,28 +86,34 @@ mod tests {
             .unwrap();
 
             let results = c
-                .select("SELECT name,fields FROM firebase_docs", None, None)
+                .select("SELECT name,attrs FROM firebase_docs", None, None)
                 .unwrap()
                 .filter_map(|r| {
-                    r.get_by_name::<&str, _>("name")
-                        .unwrap()
-                        .zip(r.get_by_name::<JsonB, _>("fields").unwrap().map(|j| j.0))
+                    r.get_by_name::<&str, _>("name").unwrap().zip(
+                        r.get_by_name::<JsonB, _>("attrs")
+                            .unwrap()
+                            .map(|j| j.0.get("fields").unwrap().clone()),
+                    )
                 })
                 .collect::<Vec<_>>();
 
             assert_eq!(
                 results,
                 vec![
                 ("projects/supa/databases/(default)/documents/my-collection/bSMScXpZHMJe9ilE9Yqs",
-                 serde_json::json!({"id": {"integerValue": "1"}, "name": {"stringValue": "hello"}}))]);
+                 serde_json::json!({
+                     "id": { "integerValue": "1" },
+                     "name": { "stringValue": "hello" }
+                 }))]
+            );
 
             c.update(
                 r#"
                 CREATE FOREIGN TABLE firebase_docs_nested (
                   name text,
-                  fields jsonb,
-                  create_time timestamp,
-                  update_time timestamp
+                  created_at timestamp,
+                  updated_at timestamp,
+                  attrs jsonb
                 )
                 SERVER my_firebase_server
                 OPTIONS (
@@ -116,20 +127,22 @@ mod tests {
             .unwrap();
 
             let results = c
-                .select("SELECT name,fields FROM firebase_docs_nested", None, None)
+                .select("SELECT name,attrs FROM firebase_docs_nested", None, None)
                 .unwrap()
                 .filter_map(|r| {
-                    r.get_by_name::<&str, _>("name")
-                        .unwrap()
-                        .zip(r.get_by_name::<JsonB, _>("fields").unwrap().map(|j| j.0))
+                    r.get_by_name::<&str, _>("name").unwrap().zip(
+                        r.get_by_name::<JsonB, _>("attrs")
+                            .unwrap()
+                            .map(|j| j.0.get("fields").unwrap().clone()),
+                    )
                 })
                 .collect::<Vec<_>>();
 
             assert_eq!(
                 results,
                 vec![
                 ("projects/supa/databases/(default)/documents/my-collection/bSMScXpZHMJe9ilE9Yqs/my-collection2/fkSWL4hNJ3lRc1ZIorPm",
-                 serde_json::json!({"foo": {"stringValue": "bar"}}))]);
+                 serde_json::json!({ "foo": { "stringValue": "bar" } }))]);
         });
     }
 }