-
- Get started by editing
- src/app/page.tsx
-
-
- By{" "}
-
+ >
+ > = {};
+ for (const signerFid of signerFidsUnique) {
+ signerProfiles[signerFid.toString()] = await getUserData(signerFid);
+ }
+
+ return {
+ casts: await getAllCastsByFid(fid),
+ reactions: await getAllReactionsByFid(fid),
+ links: await getAllLinksByFid(fid),
+ userData,
+ userDataAggregated: aggregateUserData(userData),
+ verifications: verifications,
+ signers,
+ signerProfiles,
+
+ // Onchain events
+ // registrations: getAllRegistrationsByFid(_fid),
+ // storage: getAllStorageByFid(_fid),
+ };
+}
+
+function aggregateUserData(messagesJson: unknown[]) {
+ return messagesJson.reduce(
+ (acc: Partial>, messageJson) => {
+ const decodedMessage = Message.fromJSON(messageJson);
+
+ if (!isUserDataAddMessage(decodedMessage)) {
+ return acc;
+ }
+
+ return {
+ ...acc,
+ [decodedMessage.data.userDataBody.type]:
+ decodedMessage.data.userDataBody.value,
+ };
+ },
+ {} as Partial>
+ );
+}
+
+async function getUserData(fid: number) {
+ const userData = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/userDataByFid",
+ fid,
+ });
+
+ return aggregateUserData(userData);
+}
+
+export type UserDataAggType = ReturnType;
diff --git a/src/components/UserData.tsx b/src/components/UserData.tsx
new file mode 100644
index 0000000..3e67d59
--- /dev/null
+++ b/src/components/UserData.tsx
@@ -0,0 +1,20 @@
+import { UserDataType } from "@farcaster/hub-web";
+import { UserDataAggType } from "../app/utils";
+
+export function UserAccount({ data }: { data: UserDataAggType }) {
+ return (
+
+
-
-
+ {`${data.casts.length} casts, ${data.reactions.length} reactions, ${data.links.length} links, ${data.signers.length} signers, ${data.verifications.length} verifications`}
-
-
-
-
-
);
}
diff --git a/src/app/paginate.ts b/src/app/paginate.ts
new file mode 100644
index 0000000..bd74c64
--- /dev/null
+++ b/src/app/paginate.ts
@@ -0,0 +1,157 @@
+import { FidRequest, OnChainEvent, SignerEventType } from "@farcaster/hub-web";
+
+import { bytesToHex, decodeAbiParameters } from "viem";
+import { MAX_PAGE_SIZE } from "./utils";
+
+export const signedKeyRequestAbi = [
+ {
+ components: [
+ {
+ name: "requestFid",
+ type: "uint256",
+ },
+ {
+ name: "requestSigner",
+ type: "address",
+ },
+ {
+ name: "signature",
+ type: "bytes",
+ },
+ {
+ name: "deadline",
+ type: "uint256",
+ },
+ ],
+ name: "SignedKeyRequest",
+ type: "tuple",
+ },
+] as const;
+
+export async function getAllMessagesFromHubEndpoint({
+ endpoint,
+ fid,
+}: {
+ endpoint: string;
+ fid: number;
+}) {
+ const messages: unknown[] = new Array();
+ let nextPageToken: string | undefined;
+
+ while (true) {
+ const params = new URLSearchParams({
+ fid: fid.toString(),
+ pageSize: MAX_PAGE_SIZE.toString(),
+ });
+
+ if (nextPageToken) {
+ params.append("pageToken", nextPageToken);
+ }
+
+ const url = `${process.env.NEXT_PUBLIC_HUB_REST_URL}${endpoint}?${params}`;
+
+ const res = await fetch(url);
+ const { messages: resMessages, nextPageToken: _nextPageToken } =
+ await res.json();
+
+ nextPageToken = _nextPageToken;
+
+ messages.push(...resMessages);
+
+ if (resMessages.length < MAX_PAGE_SIZE) {
+ break;
+ }
+ }
+
+ return messages;
+}
+
+export async function getAllCastsByFid(fid: FidRequest) {
+ const casts: unknown[] = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/castsByFid",
+ fid: fid.fid,
+ });
+
+ return casts;
+}
+
+export async function getAllReactionsByFid(fid: FidRequest) {
+ const reactions: unknown[] = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/reactionsByFid",
+ fid: fid.fid,
+ });
+
+ return reactions;
+}
+
+export async function getAllLinksByFid(fid: FidRequest) {
+ const links: unknown[] = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/linksByFid",
+ fid: fid.fid,
+ });
+
+ return links;
+}
+
+export function decodeSignedKeyRequestMetadata(metadata: Uint8Array) {
+ return decodeAbiParameters(signedKeyRequestAbi, bytesToHex(metadata))[0];
+}
+
+export async function getAllSignersByFid(fid: FidRequest) {
+ const events: unknown[] = new Array();
+ let nextPageToken: string | undefined;
+
+ while (true) {
+ const params = new URLSearchParams({
+ fid: fid.fid.toString(),
+ pageSize: MAX_PAGE_SIZE.toString(),
+ });
+
+ if (nextPageToken) {
+ params.append("pageToken", nextPageToken);
+ }
+
+ const res = await fetch(
+ `${process.env.NEXT_PUBLIC_HUB_REST_URL}/v1/onChainSignersByFid?${params}`
+ );
+ const { events: resEvents, ..._nextPageToken } = await res.json();
+
+ nextPageToken = _nextPageToken;
+
+ for (const signerJson of resEvents) {
+ const signer = OnChainEvent.fromJSON(signerJson);
+ const body = signer.signerEventBody;
+ const timestamp = new Date(signer.blockTimestamp * 1000);
+
+ switch (body?.eventType) {
+ case SignerEventType.ADD: {
+ const signedKeyRequestMetadata = decodeSignedKeyRequestMetadata(
+ body.metadata
+ );
+ const metadataJson = {
+ requestFid: Number(signedKeyRequestMetadata.requestFid),
+ requestSigner: signedKeyRequestMetadata.requestSigner,
+ signature: signedKeyRequestMetadata.signature,
+ deadline: Number(signedKeyRequestMetadata.deadline),
+ };
+
+ events.push({
+ ...signerJson,
+ metadata: metadataJson,
+ });
+
+ break;
+ }
+ case SignerEventType.REMOVE: {
+ break;
+ }
+ }
+ }
+
+ if (resEvents.length < MAX_PAGE_SIZE) {
+ break;
+ }
+ }
+
+ return events;
+}
diff --git a/src/app/utils.ts b/src/app/utils.ts
new file mode 100644
index 0000000..94a347b
--- /dev/null
+++ b/src/app/utils.ts
@@ -0,0 +1,96 @@
+import {
+ FidRequest,
+ Message,
+ UserDataType,
+ isUserDataAddMessage,
+} from "@farcaster/hub-web";
+import {
+ getAllCastsByFid,
+ getAllLinksByFid,
+ getAllMessagesFromHubEndpoint,
+ getAllReactionsByFid,
+ getAllSignersByFid,
+} from "./paginate";
+
+export const MAX_PAGE_SIZE = 1_000;
+
+/**
+ * Index all messages from a profile
+ * @param fid Farcaster ID
+ */
+export async function getFullProfileFromHub(_fid: number) {
+ const fid = FidRequest.create({ fid: _fid });
+
+ const verifications = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/verificationsByFid",
+ fid: fid.fid,
+ });
+
+ const signers = await getAllSignersByFid(fid);
+
+ const userData = await getAllMessagesFromHubEndpoint({
+ endpoint: "/v1/userDataByFid",
+ fid: fid.fid,
+ });
+
+ const signerFidsUnique = Array.from(
+ new Set(
+ signers.map(
+ (s) => (s as { metadata: { requestFid: number } }).metadata.requestFid
+ )
+ )
+ );
+
+ const signerProfiles: Record<
+ string,
+ Awaited- Docs{" "} - - -> - -
-- Find in-depth information about Next.js features and API. -
- - - -- Learn{" "} - - -> - -
-- Learn about Next.js in an interactive course with quizzes! -
- - - -- Templates{" "} - - -> - -
-- Explore starter templates for Next.js. -
- - - -- Deploy{" "} - - -> - -
-- Instantly deploy your Next.js site to a shareable URL with Vercel. -
- +
+ {Object.entries(signersByFid.fidToSigner).map(([fid, signers], i) => (
+
-
+
+
+ ))}
+
+ {`${signers.length} signers`}
+ {/* {`${messageCountsByFid?.[fid].casts} casts, ${messageCountsByFid?.[fid].reactions} reactions, ${messageCountsByFid?.[fid].links} links, ${messageCountsByFid?.[fid].verifications} verifications`}
*/}
+
+
+ );
+}
+ 
+
+
+
+ {data[UserDataType.DISPLAY]}
+ @{data[UserDataType.USERNAME]}
+ {data[UserDataType.BIO]}
+