fix(save-user-data): Fix updating favorite aggregations for Compass Web

Author: myang1220

packages/compass-user-data/src/user-data.ts

@@ -373,7 +373,6 @@ export class AtlasUserData<T extends z.Schema> extends IUserData<T> {
       data: [],
       errors: [],
     };
-    // debugger;
     try {
       const response = await this.authenticatedFetch(
         this.getResourceUrl(

packages/my-queries-storage/src/compass-pipeline-storage.ts

@@ -48,8 +48,6 @@ export class CompassPipelineStorage implements PipelineStorage {
     try {
       const { data } = await this.userData.readAll();
       return data;
-      const { data } = await this.userData.readAll();
-      return data;
     } catch {
       return [];
     }
@@ -73,31 +71,17 @@ export class CompassPipelineStorage implements PipelineStorage {
   }
 
   async create(data: Omit<SavedPipeline, 'lastModified'>): Promise<boolean> {
-    try {
-      await this.userData.write(data.id, {
-        ...data,
-        lastModified: Date.now(),
-      });
-      return true;
-    } catch {
-      return false;
-    }
+    return await this.userData.write(data.id, {
+      ...data,
+      lastModified: Date.now(),
+    });
   }
 
   async updateAttributes(
     id: string,
     attributes: Partial<SavedPipeline>
   ): Promise<boolean> {
-    try {
-      await this.userData.write(id, {
-        ...(await this.userData.readOne(id)),
-        ...attributes,
-        lastModified: Date.now(),
-      });
-      return true;
-    } catch {
-      return false;
-    }
+    return await this.userData.updateAttributes(id, attributes);
   }
 
   async delete(id: string) {

packages/my-queries-storage/src/pipeline-storage-schema.ts

@@ -61,8 +61,7 @@ export const PipelineSchema = z.preprocess(
     host: z.string().nullable().optional(),
     pipelineText: z.string(),
     lastModified: z
-      .number()
-      .default(0)
+      .union([z.coerce.date(), z.number()])
       .transform((x) => new Date(x)),
   })
 );