feat(farcaster): enhance sync functionality by adding linkedAccountId to mutations and updating user profile with Farcaster data

Author: mavix21

packages/app/screens/profile/profile-screen.tsx

@@ -334,7 +334,15 @@ export const ProfileScreen = ({ id }: { id: string }) => {
                                 @{linkedAccount.account.username}
                               </SizableText>
                             </YStack>
-                            <Button onPress={handleSyncWithFarcaster} disabled={isSyncing}>
+                            <Button
+                              onPress={handleSyncWithFarcaster}
+                              disabled={
+                                (linkedAccount.account.lastSyncedAt !== undefined &&
+                                  linkedAccount.account.lastSyncedAt <
+                                    Date.now() - 1000 * 60 * 60 * 1) ||
+                                isSyncing
+                              }
+                            >
                               {isSyncing ? 'Syncing...' : 'Sync using Farcaster'}
                             </Button>
                           </XStack>

packages/backend/convex/farcaster.ts

@@ -62,6 +62,7 @@ export const syncWithFarcaster = mutation({
     await ctx.scheduler.runAfter(0, internal.farcaster.syncUserInformationWithFarcaster, {
       userId: args.userId,
       fid: linkedAccount.account.fid,
+      linkedAccountId: linkedAccount._id,
     });
   },
 });
@@ -70,6 +71,7 @@ export const syncUserInformationWithFarcaster = internalAction({
   args: {
     userId: v.id('users'),
     fid: v.number(),
+    linkedAccountId: v.id('linkedAccounts'),
   },
   handler: async (ctx, args) => {
     if (!process.env.NEYNAR_API_KEY) {
@@ -133,8 +135,10 @@ export const syncUserInformationWithFarcaster = internalAction({
       }
 
       // Use internal mutation to update user profile since this is an internalAction
-      await ctx.runMutation(internal.users.updateUserProfileInternal, {
+      await ctx.runMutation(internal.users.updateUserProfileInternalWithFarcaster, {
         userId: args.userId,
+        fid: args.fid,
+        linkedAccountId: args.linkedAccountId,
         ...fieldsToUpdate,
       });
 

packages/backend/convex/users.ts

@@ -200,25 +200,18 @@ export const updateUserSocials = mutation({
  * Internal mutation to update user profile with Neynar data
  * This is specifically for syncing user information from Farcaster/Neynar
  */
-export const updateUserProfileInternal = internalMutation({
+export const updateUserProfileInternalWithFarcaster = internalMutation({
   args: {
     userId: v.id('users'),
+    fid: v.number(),
     bio: v.optional(v.string()),
     displayName: v.optional(v.string()),
     username: v.optional(v.string()),
     pfpUrl: v.optional(v.string()),
+    linkedAccountId: v.id('linkedAccounts'),
   },
   handler: async (ctx, args) => {
-    const { userId, ...updateFields } = args;
-
-    // Check if user exists
-    const existingUser = await ctx.db.get(userId);
-    if (!existingUser) {
-      throw new ConvexError({
-        message: 'User not found',
-        code: 'USER_NOT_FOUND',
-      });
-    }
+    const { userId, linkedAccountId, ...updateFields } = args;
 
     // Filter out undefined values to avoid removing fields unintentionally
     const fieldsToUpdate = Object.fromEntries(
@@ -231,6 +224,14 @@ export const updateUserProfileInternal = internalMutation({
       return;
     }
 
+    await ctx.db.patch(linkedAccountId, {
+      account: {
+        protocol: 'farcaster',
+        fid: args.fid,
+        ...fieldsToUpdate,
+        lastSyncedAt: Date.now(),
+      },
+    });
     await ctx.db.patch(userId, fieldsToUpdate);
   },
 });