Custom auth

 useEffect(() => {
    const fetchToken: AuthTokenFetcher = async (args) => {
      console.log("args", args);
      const { data } = await axios.get<{ token: string | null }>(
        `/api/session/token?force=${args.forceRefreshToken}`
      );

      console.log("data", data);
      return data.token;
    };

    convex.setAuth(fetchToken, (isAuthenticated) => {
      console.log("Auth status changed:", isAuthenticated);
    });
  }, []);

 useEffect(() => {
    const fetchToken: AuthTokenFetcher = async (args) => {
      console.log("args", args);
      const { data } = await axios.get<{ token: string | null }>(
        `/api/session/token?force=${args.forceRefreshToken}`
      );

      console.log("data", data);
      return data.token;
    };

    convex.setAuth(fetchToken, (isAuthenticated) => {
      console.log("Auth status changed:", isAuthenticated);
    });
  }, []);

import Google from "@auth/core/providers/google";

// eslint-disable-next-line import/no-anonymous-default-export
export default {
  providers: [Google],
};

import Google from "@auth/core/providers/google";

// eslint-disable-next-line import/no-anonymous-default-export
export default {
  providers: [Google],
};

export default {
  providers: [
    {
      type: "customJwt",
      applicationID: "tuagye",
      issuer: "https://firstly-many-jackal.ngrok-free.app",
      audience: "tuagye",
      jwks: "https://firstly-many-jackal.ngrok-free.app/.well-known/jwks.json",
      algorithm: "ES256",
    },
  ],
};

export default {
  providers: [
    {
      type: "customJwt",
      applicationID: "tuagye",
      issuer: "https://firstly-many-jackal.ngrok-free.app",
      audience: "tuagye",
      jwks: "https://firstly-many-jackal.ngrok-free.app/.well-known/jwks.json",
      algorithm: "ES256",
    },
  ],
};

{
  "alg": "ES256",
  "typ": "JWT"
}

{
  "sub": "684ff7bb48e115fab0a1d418",
  "email": "XXXXX@gmail.com",
  "iat": 1750701737,
  "exp": 1750788137,
  "aud": "tuagye",
  "iss": "https://firstly-many-jackal.ngrok-free.app"
}

{
  "alg": "ES256",
  "typ": "JWT"
}

{
  "sub": "684ff7bb48e115fab0a1d418",
  "email": "XXXXX@gmail.com",
  "iat": 1750701737,
  "exp": 1750788137,
  "aud": "tuagye",
  "iss": "https://firstly-many-jackal.ngrok-free.app"
}

fastify.get("/.well-known/jwks.json", async () => {
    const keyEscaped = env.JWT_PUBLIC_KEY;
    const publicKey = keyEscaped.replace(/\\n/g, "\n") || "";
    // Extract coordinates from PEM
    const keyObject = crypto.createPublicKey(publicKey);
    const jwk = keyObject.export({ format: "jwk" });

    return {
      keys: [
        {
          ...jwk,
          use: "sig",
          kid: "tuagye-main",
          alg: "ES256",
        },
      ],
    };
  });

fastify.get("/.well-known/jwks.json", async () => {
    const keyEscaped = env.JWT_PUBLIC_KEY;
    const publicKey = keyEscaped.replace(/\\n/g, "\n") || "";
    // Extract coordinates from PEM
    const keyObject = crypto.createPublicKey(publicKey);
    const jwk = keyObject.export({ format: "jwk" });

    return {
      keys: [
        {
          ...jwk,
          use: "sig",
          kid: "tuagye-main",
          alg: "ES256",
        },
      ],
    };
  });

{
  ...jwk,
  use: "sig",
  kid: "tuagye-main",
  alg: "ES256",
}

{
  ...jwk,
  use: "sig",
  kid: "tuagye-main",
  alg: "ES256",
}

export const list = query({
  args: {},
  handler: async (ctx) => {
    const userId = await getAuthUserId(ctx);
    if (!userId) throw new Error("Unauthorized");

    const chats = await ctx.db.query("chats").collect();
    const userChats = chats.filter(
      (chat) => chat.participants.includes(userId) && chat.lastMessageId
    );

    // Batch fetch all last messages in one go
    const lastMessageIds = userChats
      .map((chat) => chat.lastMessageId)
      .filter((id) => id !== undefined);

    // Create a map of message ID -> message content
    const messagesMap = {};
    for (const msgId of lastMessageIds) {
      try {
        const message = await ctx.db.get(msgId);
        if (message) messagesMap[msgId] = message;
      } catch (e) {
        // Skip failed lookups
      }
    }

export const list = query({
  args: {},
  handler: async (ctx) => {
    const userId = await getAuthUserId(ctx);
    if (!userId) throw new Error("Unauthorized");

    const chats = await ctx.db.query("chats").collect();
    const userChats = chats.filter(
      (chat) => chat.participants.includes(userId) && chat.lastMessageId
    );

    // Batch fetch all last messages in one go
    const lastMessageIds = userChats
      .map((chat) => chat.lastMessageId)
      .filter((id) => id !== undefined);

    // Create a map of message ID -> message content
    const messagesMap = {};
    for (const msgId of lastMessageIds) {
      try {
        const message = await ctx.db.get(msgId);
        if (message) messagesMap[msgId] = message;
      } catch (e) {
        // Skip failed lookups
      }
    }

    // Batch fetch all other users
    const otherUserIds = userChats
      .map((chat) => chat.participants.find((id) => id !== userId))
      .filter((id) => id !== undefined);

    const userProfiles = {};
    for (const id of otherUserIds) {
      try {
        const user = await ctx.db
          .query("userCache")
          .filter((q) => q.eq(q.field("userId"), id))
          .first();
        if (user) userProfiles[id] = user;
      } catch (e) {
        // Skip failed lookups
      }
    }

    // Build complete chat objects
    const processedChats = userChats.map((chat) => {
      const otherUserId = chat.participants.find((id) => id !== userId);
      if (!otherUserId)
        throw new ConvexError(ErrorCodes.PARTICIPANT_NOT_FOUND_ERROR);
      const unreadCount = chat.unreadCounts?.[userId] || 0;
      const lastMessage = chat.lastMessageId
        ? messagesMap[chat.lastMessageId]
        : null;

      return {
        ...chat,
        unreadCount,
        otherUser: userProfiles[otherUserId] || null,
        lastMessage,
      };
    });

    // Sort by recent activity
    return processedChats.sort((a, b) => {
      const aTime = a.lastMessageAt ?? a._creationTime;
      const bTime = b.lastMessageAt ?? b._creationTime;
      return bTime - aTime;
    });
  },
});

    // Batch fetch all other users
    const otherUserIds = userChats
      .map((chat) => chat.participants.find((id) => id !== userId))
      .filter((id) => id !== undefined);

    const userProfiles = {};
    for (const id of otherUserIds) {
      try {
        const user = await ctx.db
          .query("userCache")
          .filter((q) => q.eq(q.field("userId"), id))
          .first();
        if (user) userProfiles[id] = user;
      } catch (e) {
        // Skip failed lookups
      }
    }

    // Build complete chat objects
    const processedChats = userChats.map((chat) => {
      const otherUserId = chat.participants.find((id) => id !== userId);
      if (!otherUserId)
        throw new ConvexError(ErrorCodes.PARTICIPANT_NOT_FOUND_ERROR);
      const unreadCount = chat.unreadCounts?.[userId] || 0;
      const lastMessage = chat.lastMessageId
        ? messagesMap[chat.lastMessageId]
        : null;

      return {
        ...chat,
        unreadCount,
        otherUser: userProfiles[otherUserId] || null,
        lastMessage,
      };
    });

    // Sort by recent activity
    return processedChats.sort((a, b) => {
      const aTime = a.lastMessageAt ?? a._creationTime;
      const bTime = b.lastMessageAt ?? b._creationTime;
      return bTime - aTime;
    });
  },
});

 * `forceRefreshToken` is `true` if the server rejected a previously
 * returned token, and the client should try to fetch a new one.

 * `forceRefreshToken` is `true` if the server rejected a previously
 * returned token, and the client should try to fetch a new one.

// Some loose vision from the top of my head 

<ConvexAuthenticationProvider
    initialToken?: async () => string | string,
    onRefreshToken: () => getToken({ ignoreCache: true }),
    onStateUpdate: () => {}
    refreshOptions: { ... }
/>

// Something like that would be nice to have to actually 
const [isAuthenticating, setIsAuthenticating] = useState(false);

useEffect(() => {
   const unsubscribe = convex.auth.observe(() => {})

   return () => unsubscribe()
}, [convex])

// Easy to compose style extensible IMO

// Some loose vision from the top of my head 

<ConvexAuthenticationProvider
    initialToken?: async () => string | string,
    onRefreshToken: () => getToken({ ignoreCache: true }),
    onStateUpdate: () => {}
    refreshOptions: { ... }
/>

// Something like that would be nice to have to actually 
const [isAuthenticating, setIsAuthenticating] = useState(false);

useEffect(() => {
   const unsubscribe = convex.auth.observe(() => {})

   return () => unsubscribe()
}, [convex])

// Easy to compose style extensible IMO