full profile doc and support 'terms'

config.json

···
 {
   "jetstream_url": "wss://jetstream2.us-west.bsky.network/subscribe",
   "es_url": "http://localhost:9200",
-  "record_types": ["xyz.statusphere.status", "com.example.test.esav"],
+  "record_types": [
+  	"xyz.statusphere.status", 
+  	"com.example.test.esav", 
+  	"party.whey.ft.topic.post", 
+  	"party.whey.ft.topic.reaction", 
+  	"party.whey.ft.topic.moderation", 
+  	"party.whey.ft.forum.definition", 
+  	"party.whey.ft.forum.layout", 
+  	"party.whey.ft.forum.request", 
+  	"party.whey.ft.forum.accept", 
+  	"party.whey.ft.forum.category",
+  	"party.whey.ft.user.profile"
+  	],
   "index_name": "appview-poc",
   "serve_port": "8370",
   "index_fields": {
+    "party.whey.ft.topic.reaction": {
+      "subject": {
+        "id": "reactionSubject",
+        "type": "keyword"
+      },
+      "reactionEmoji": {
+        "id": "reactionEmoji",
+        "type": "keyword"
+      }
+    },
+    "party.whey.ft.topic.post": {
+      "text": {
+      	"id": "text",
+      	"type": "text"
+      },
+      "title": {
+      	"id": "title",
+      	"type": "text"
+      },
+      "reply.root.uri": {
+      	"id": "root",
+      	"type": "keyword"
+      },
+      "reply.parent.uri": {
+      	"id": "parent",
+      	"type": "keyword"
+      },
+      "forum": {
+      	"id": "forum",
+      	"type": "keyword"
+      }
+    },
+    "party.whey.ft.forum.definition": {
+      "description": {
+      	"id": "description",
+      	"type": "text"
+      },
+      "displayName": {
+      	"id": "displayName",
+      	"type": "text"
+      }
+    },
     "xyz.statusphere.status": {
       "status": {
         "id": "status",
-        "type": "text"
+        "type": "keyword"
       }
     },
     "com.example.test.esav": {

readme.md

···
 with these params:
     -   `did`: The DID of the user.
     -   `handle`: The handle of the user.
-    -   `includePfp` (optional): `true` to include the PFP URL.
+    -   `includeBskyProfile` (optional): `true` to include the the entire bsky profile object as well.
 
 **Example Request:**
 
-`https://esav.whey.party/xrpc/party.whey.esav.resolveIdentity?did=did:web:did12.whey.party&includePfp=true`
+`https://esav.whey.party/xrpc/party.whey.esav.resolveIdentity?did=did:plc:cjfima2v3vnyfuzieu7bvjx7&includeBskyProfile=true`
 
 gets me
 
···
 
 ```json
 {
-  "did":"did:web:did12.whey.party",
+  "did":"did:plc:cjfima2v3vnyfuzieu7bvjx7",
   "pdsUrl":"https://pds-nd.whey.party",
-  "handle":"dw.whey.party",
-  "pfp":"https://pds-nd.whey.party/xrpc/com.atproto.sync.getBlob?did=did:web:did12.whey.party&cid=bafkreibesqir3254ee3natyi3tadhmcjqyyeukoiqxsctsru7z3j4ws4mm"
+  "handle":"forumtest.whey.party",
+  "profile": {
+    "$type": "app.bsky.actor.profile",
+    "avatar": {
+      "$type": "blob",
+      "ref": {
+        "$link": "bafkreiabb6nrbpgguh5xaake3shoyxh2i7lyj7nj7j3ejk77hdlvt4lhmu"
+      },
+      "mimeType": "image/png",
+      "size": 35262
+    },
+    "banner": {
+      "$type": "blob",
+      "ref": {
+        "$link": "bafkreieupktgazj4vxuxbj6dyf4trvltgok5ukdsnvvblsqqw26cmsvn7y"
+      },
+      "mimeType": "image/jpeg",
+      "size": 931415
+    },
+    "createdAt": "2025-08-04T06:27:34.561Z",
+    "description": "ForumTest discussion and development",
+    "displayName": "ForumTest"
+  }
 }
 ```
 

src/firehose.ts

···
 interface FirehoseOptions {
   config: AppConfig;
   onEvent: OnEventCallback;
+  forcedCursor?: string;
 }
 
-export function startFirehose({ config, onEvent }: FirehoseOptions) {
+export function startFirehose({ config, onEvent, forcedCursor }: FirehoseOptions) {
   let lastCursor: number | null = null;
 
   const connect = () => {
     const url = new URL(config.jetstream_url);
     if (lastCursor !== null) {
       url.searchParams.set("cursor", lastCursor.toString());
+    }
+    if (forcedCursor) {
+      console.log("using forced cursor: ", forcedCursor)
+      url.searchParams.set("cursor", forcedCursor);
     }
 
     const ws = new WebSocket(url.toString());

src/live-utils.ts

···
         break;
       }
 
+      case 'terms': {
+          const [field, queryValues] = Object.entries(clauseValue as object)[0];
+          if (!Array.isArray(queryValues)) return false; 
+
+          const docValue = getSafeField(doc, field);
+          if (docValue === undefined) return false;
+
+          if (Array.isArray(docValue)) {
+              return docValue.some(v => queryValues.includes(v));
+          } else {
+              return queryValues.includes(docValue);
+          }
+      }
+
       case 'match': {
         const [field, value] = Object.entries(clauseValue as object)[0];
         const fieldValue = getSafeField(doc, field);

src/main.ts

···
 import { ensureIndexMapping, type IndexerEvent } from "./indexer.ts";
 import { setupXRPCServer } from "./xrpc.ts";
 import { processEventForSync } from "./sync.ts";
+import { parseArgs } from "jsr:@std/cli";
 
 async function main() {
   const config = await readConfig("./config.json");
+
+  const args = parseArgs(Deno.args)
 
   // prepare indexes
   await ensureIndexMapping(config);
···
     onEvent: (event: IndexerEvent) => {
       // ESAV Live !!!
       return processEventForSync(event);
-    }
+    },
+    forcedCursor: args["force-cursor"]
   });
 
   console.log("Server started and listening for events");

src/xrpc.ts

···
           const handle = searchParams.get("handle");
           const did = searchParams.get("did");
           const clientCid = searchParams.get("cid");
-          const includePfp = searchParams.get("includePfp");
+          const includeBskyProfile = searchParams.get("includeBskyProfile");
 
           if (!handle && !did) {
             return new Response("handle or did parameter is required", {
···
             ...identity,
           };
 
-          if (includePfp) {
-            finalResponse.pfp = await getPfpUrl(identity.pdsUrl, identity.did);
+          if (includeBskyProfile) {
+            finalResponse.profile = await getProfileRecord(identity.pdsUrl, identity.did);
           }
 
           const newCid = await computeCid(finalResponse);
···
   }
 }
 
-async function getPfpUrl(
+async function getProfileRecord(
   pdsUrl: string,
   did: string
 ): Promise<string | undefined> {
···
       return undefined;
     }
     const data = await response.json();
-    const cid = data?.value?.avatar?.ref?.["$link"];
-    const pfpurl = `${pdsUrl}/xrpc/com.atproto.sync.getBlob?did=${did}&cid=${cid}`;
-    return pfpurl;
+    //const cid = data?.value?.avatar?.ref?.["$link"];
+    //const pfpurl = `${pdsUrl}/xrpc/com.atproto.sync.getBlob?did=${did}&cid=${cid}`;
+    return data.value;
   } catch (error) {
-    console.error(`Error fetching PFP for ${did}:`, error);
+    console.error(`Error fetching profile record for ${did}:`, error);
     return undefined;
   }
 }