index server and view server split

.env

···
-JETSTREAM_URL="wss://jetstream2.us-east.bsky.network"
+# main indexers
+JETSTREAM_URL="wss://jetstream.whey.party"
 SPACEDUST_URL="wss://spacedust.microcosm.blue"
+
+# for backfill (useless if you just started the instance right now)
 CONSTELLATION_URL="https://constellation.microcosm.blue"
+# i dont actually know why i need this
 SLINGSHOT_URL="https://slingshot.microcosm.blue"
 
 SERVICE_DID="did:web:local3768forumtest.whey.party"

index/onboardingBackfill.ts

···
-import { db, handleIndex } from "../main.ts"
+import { systemDB, handleIndex } from "../main.ts"
 import { FINEPDSAndHandleFromDid } from "../utils/identity.ts";
 
 

indexclient/index.ts

···
   XrpcClient,
   type FetchHandler,
   type FetchHandlerOptions,
-} from '@atproto/xrpc'
-import { schemas } from './lexicons.js'
-import { CID } from 'multiformats/cid'
-import { type OmitKey, type Un$Typed } from './util.js'
-import * as AppBskyActorDefs from './types/app/bsky/actor/defs.js'
-import * as AppBskyActorGetProfile from './types/app/bsky/actor/getProfile.js'
-import * as AppBskyActorGetProfiles from './types/app/bsky/actor/getProfiles.js'
-import * as AppBskyEmbedDefs from './types/app/bsky/embed/defs.js'
-import * as AppBskyEmbedExternal from './types/app/bsky/embed/external.js'
-import * as AppBskyEmbedImages from './types/app/bsky/embed/images.js'
-import * as AppBskyEmbedRecord from './types/app/bsky/embed/record.js'
-import * as AppBskyEmbedRecordWithMedia from './types/app/bsky/embed/recordWithMedia.js'
-import * as AppBskyEmbedVideo from './types/app/bsky/embed/video.js'
-import * as AppBskyFeedDefs from './types/app/bsky/feed/defs.js'
-import * as AppBskyFeedGetActorFeeds from './types/app/bsky/feed/getActorFeeds.js'
-import * as AppBskyFeedGetFeedGenerator from './types/app/bsky/feed/getFeedGenerator.js'
-import * as AppBskyFeedGetFeedGenerators from './types/app/bsky/feed/getFeedGenerators.js'
-import * as AppBskyFeedGetPosts from './types/app/bsky/feed/getPosts.js'
-import * as AppBskyFeedPostgate from './types/app/bsky/feed/postgate.js'
-import * as AppBskyFeedThreadgate from './types/app/bsky/feed/threadgate.js'
-import * as AppBskyGraphDefs from './types/app/bsky/graph/defs.js'
-import * as AppBskyNotificationDefs from './types/app/bsky/notification/defs.js'
-import * as AppBskyRichtextFacet from './types/app/bsky/richtext/facet.js'
-import * as ComAtprotoLabelDefs from './types/com/atproto/label/defs.js'
-import * as ComAtprotoRepoStrongRef from './types/com/atproto/repo/strongRef.js'
-import * as PartyWheyAppBskyActorDefs from './types/party/whey/app/bsky/actor/defs.js'
-import * as PartyWheyAppBskyFeedDefs from './types/party/whey/app/bsky/feed/defs.js'
-import * as PartyWheyAppBskyFeedGetActorLikesPartial from './types/party/whey/app/bsky/feed/getActorLikesPartial.js'
-import * as PartyWheyAppBskyFeedGetAuthorFeedPartial from './types/party/whey/app/bsky/feed/getAuthorFeedPartial.js'
-import * as PartyWheyAppBskyFeedGetLikesPartial from './types/party/whey/app/bsky/feed/getLikesPartial.js'
-import * as PartyWheyAppBskyFeedGetListFeedPartial from './types/party/whey/app/bsky/feed/getListFeedPartial.js'
-import * as PartyWheyAppBskyFeedGetPostThreadPartial from './types/party/whey/app/bsky/feed/getPostThreadPartial.js'
-import * as PartyWheyAppBskyFeedGetQuotesPartial from './types/party/whey/app/bsky/feed/getQuotesPartial.js'
-import * as PartyWheyAppBskyFeedGetRepostedByPartial from './types/party/whey/app/bsky/feed/getRepostedByPartial.js'
+} from 'npm:@atproto/xrpc'
+import { schemas } from './lexicons.ts'
+import { CID } from 'npm:multiformats/cid'
+import { type OmitKey, type Un$Typed } from './util.ts'
+import * as AppBskyActorDefs from './types/app/bsky/actor/defs.ts'
+import * as AppBskyActorGetProfile from './types/app/bsky/actor/getProfile.ts'
+import * as AppBskyActorGetProfiles from './types/app/bsky/actor/getProfiles.ts'
+import * as AppBskyEmbedDefs from './types/app/bsky/embed/defs.ts'
+import * as AppBskyEmbedExternal from './types/app/bsky/embed/external.ts'
+import * as AppBskyEmbedImages from './types/app/bsky/embed/images.ts'
+import * as AppBskyEmbedRecord from './types/app/bsky/embed/record.ts'
+import * as AppBskyEmbedRecordWithMedia from './types/app/bsky/embed/recordWithMedia.ts'
+import * as AppBskyEmbedVideo from './types/app/bsky/embed/video.ts'
+import * as AppBskyFeedDefs from './types/app/bsky/feed/defs.ts'
+import * as AppBskyFeedGetActorFeeds from './types/app/bsky/feed/getActorFeeds.ts'
+import * as AppBskyFeedGetFeedGenerator from './types/app/bsky/feed/getFeedGenerator.ts'
+import * as AppBskyFeedGetFeedGenerators from './types/app/bsky/feed/getFeedGenerators.ts'
+import * as AppBskyFeedGetPosts from './types/app/bsky/feed/getPosts.ts'
+import * as AppBskyFeedPostgate from './types/app/bsky/feed/postgate.ts'
+import * as AppBskyFeedThreadgate from './types/app/bsky/feed/threadgate.ts'
+import * as AppBskyGraphDefs from './types/app/bsky/graph/defs.ts'
+import * as AppBskyNotificationDefs from './types/app/bsky/notification/defs.ts'
+import * as AppBskyRichtextFacet from './types/app/bsky/richtext/facet.ts'
+import * as ComAtprotoLabelDefs from './types/com/atproto/label/defs.ts'
+import * as ComAtprotoRepoStrongRef from './types/com/atproto/repo/strongRef.ts'
+import * as PartyWheyAppBskyActorDefs from './types/party/whey/app/bsky/actor/defs.ts'
+import * as PartyWheyAppBskyFeedDefs from './types/party/whey/app/bsky/feed/defs.ts'
+import * as PartyWheyAppBskyFeedGetActorLikesPartial from './types/party/whey/app/bsky/feed/getActorLikesPartial.ts'
+import * as PartyWheyAppBskyFeedGetAuthorFeedPartial from './types/party/whey/app/bsky/feed/getAuthorFeedPartial.ts'
+import * as PartyWheyAppBskyFeedGetLikesPartial from './types/party/whey/app/bsky/feed/getLikesPartial.ts'
+import * as PartyWheyAppBskyFeedGetListFeedPartial from './types/party/whey/app/bsky/feed/getListFeedPartial.ts'
+import * as PartyWheyAppBskyFeedGetPostThreadPartial from './types/party/whey/app/bsky/feed/getPostThreadPartial.ts'
+import * as PartyWheyAppBskyFeedGetQuotesPartial from './types/party/whey/app/bsky/feed/getQuotesPartial.ts'
+import * as PartyWheyAppBskyFeedGetRepostedByPartial from './types/party/whey/app/bsky/feed/getRepostedByPartial.ts'
 
-export * as AppBskyActorDefs from './types/app/bsky/actor/defs.js'
-export * as AppBskyActorGetProfile from './types/app/bsky/actor/getProfile.js'
-export * as AppBskyActorGetProfiles from './types/app/bsky/actor/getProfiles.js'
-export * as AppBskyEmbedDefs from './types/app/bsky/embed/defs.js'
-export * as AppBskyEmbedExternal from './types/app/bsky/embed/external.js'
-export * as AppBskyEmbedImages from './types/app/bsky/embed/images.js'
-export * as AppBskyEmbedRecord from './types/app/bsky/embed/record.js'
-export * as AppBskyEmbedRecordWithMedia from './types/app/bsky/embed/recordWithMedia.js'
-export * as AppBskyEmbedVideo from './types/app/bsky/embed/video.js'
-export * as AppBskyFeedDefs from './types/app/bsky/feed/defs.js'
-export * as AppBskyFeedGetActorFeeds from './types/app/bsky/feed/getActorFeeds.js'
-export * as AppBskyFeedGetFeedGenerator from './types/app/bsky/feed/getFeedGenerator.js'
-export * as AppBskyFeedGetFeedGenerators from './types/app/bsky/feed/getFeedGenerators.js'
-export * as AppBskyFeedGetPosts from './types/app/bsky/feed/getPosts.js'
-export * as AppBskyFeedPostgate from './types/app/bsky/feed/postgate.js'
-export * as AppBskyFeedThreadgate from './types/app/bsky/feed/threadgate.js'
-export * as AppBskyGraphDefs from './types/app/bsky/graph/defs.js'
-export * as AppBskyNotificationDefs from './types/app/bsky/notification/defs.js'
-export * as AppBskyRichtextFacet from './types/app/bsky/richtext/facet.js'
-export * as ComAtprotoLabelDefs from './types/com/atproto/label/defs.js'
-export * as ComAtprotoRepoStrongRef from './types/com/atproto/repo/strongRef.js'
-export * as PartyWheyAppBskyActorDefs from './types/party/whey/app/bsky/actor/defs.js'
-export * as PartyWheyAppBskyFeedDefs from './types/party/whey/app/bsky/feed/defs.js'
-export * as PartyWheyAppBskyFeedGetActorLikesPartial from './types/party/whey/app/bsky/feed/getActorLikesPartial.js'
-export * as PartyWheyAppBskyFeedGetAuthorFeedPartial from './types/party/whey/app/bsky/feed/getAuthorFeedPartial.js'
-export * as PartyWheyAppBskyFeedGetLikesPartial from './types/party/whey/app/bsky/feed/getLikesPartial.js'
-export * as PartyWheyAppBskyFeedGetListFeedPartial from './types/party/whey/app/bsky/feed/getListFeedPartial.js'
-export * as PartyWheyAppBskyFeedGetPostThreadPartial from './types/party/whey/app/bsky/feed/getPostThreadPartial.js'
-export * as PartyWheyAppBskyFeedGetQuotesPartial from './types/party/whey/app/bsky/feed/getQuotesPartial.js'
-export * as PartyWheyAppBskyFeedGetRepostedByPartial from './types/party/whey/app/bsky/feed/getRepostedByPartial.js'
+export * as AppBskyActorDefs from './types/app/bsky/actor/defs.ts'
+export * as AppBskyActorGetProfile from './types/app/bsky/actor/getProfile.ts'
+export * as AppBskyActorGetProfiles from './types/app/bsky/actor/getProfiles.ts'
+export * as AppBskyEmbedDefs from './types/app/bsky/embed/defs.ts'
+export * as AppBskyEmbedExternal from './types/app/bsky/embed/external.ts'
+export * as AppBskyEmbedImages from './types/app/bsky/embed/images.ts'
+export * as AppBskyEmbedRecord from './types/app/bsky/embed/record.ts'
+export * as AppBskyEmbedRecordWithMedia from './types/app/bsky/embed/recordWithMedia.ts'
+export * as AppBskyEmbedVideo from './types/app/bsky/embed/video.ts'
+export * as AppBskyFeedDefs from './types/app/bsky/feed/defs.ts'
+export * as AppBskyFeedGetActorFeeds from './types/app/bsky/feed/getActorFeeds.ts'
+export * as AppBskyFeedGetFeedGenerator from './types/app/bsky/feed/getFeedGenerator.ts'
+export * as AppBskyFeedGetFeedGenerators from './types/app/bsky/feed/getFeedGenerators.ts'
+export * as AppBskyFeedGetPosts from './types/app/bsky/feed/getPosts.ts'
+export * as AppBskyFeedPostgate from './types/app/bsky/feed/postgate.ts'
+export * as AppBskyFeedThreadgate from './types/app/bsky/feed/threadgate.ts'
+export * as AppBskyGraphDefs from './types/app/bsky/graph/defs.ts'
+export * as AppBskyNotificationDefs from './types/app/bsky/notification/defs.ts'
+export * as AppBskyRichtextFacet from './types/app/bsky/richtext/facet.ts'
+export * as ComAtprotoLabelDefs from './types/com/atproto/label/defs.ts'
+export * as ComAtprotoRepoStrongRef from './types/com/atproto/repo/strongRef.ts'
+export * as PartyWheyAppBskyActorDefs from './types/party/whey/app/bsky/actor/defs.ts'
+export * as PartyWheyAppBskyFeedDefs from './types/party/whey/app/bsky/feed/defs.ts'
+export * as PartyWheyAppBskyFeedGetActorLikesPartial from './types/party/whey/app/bsky/feed/getActorLikesPartial.ts'
+export * as PartyWheyAppBskyFeedGetAuthorFeedPartial from './types/party/whey/app/bsky/feed/getAuthorFeedPartial.ts'
+export * as PartyWheyAppBskyFeedGetLikesPartial from './types/party/whey/app/bsky/feed/getLikesPartial.ts'
+export * as PartyWheyAppBskyFeedGetListFeedPartial from './types/party/whey/app/bsky/feed/getListFeedPartial.ts'
+export * as PartyWheyAppBskyFeedGetPostThreadPartial from './types/party/whey/app/bsky/feed/getPostThreadPartial.ts'
+export * as PartyWheyAppBskyFeedGetQuotesPartial from './types/party/whey/app/bsky/feed/getQuotesPartial.ts'
+export * as PartyWheyAppBskyFeedGetRepostedByPartial from './types/party/whey/app/bsky/feed/getRepostedByPartial.ts'
 
 export const APP_BSKY_FEED = {
   DefsRequestLess: 'app.bsky.feed.defs#requestLess',

indexclient/lexicons.ts

···
   Lexicons,
   ValidationError,
   type ValidationResult,
-} from '@atproto/lexicon'
-import { type $Typed, is$typed, maybe$typed } from './util.js'
+} from 'npm:@atproto/lexicon'
+import { type $Typed, is$typed, maybe$typed } from './util.ts'
 
 export const schemaDict = {
   AppBskyActorDefs: {

indexclient/types/app/bsky/actor/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.js'
-import type * as AppBskyGraphDefs from '../graph/defs.js'
-import type * as ComAtprotoRepoStrongRef from '../../../com/atproto/repo/strongRef.js'
-import type * as AppBskyNotificationDefs from '../notification/defs.js'
-import type * as AppBskyFeedThreadgate from '../feed/threadgate.js'
-import type * as AppBskyFeedPostgate from '../feed/postgate.js'
-import type * as AppBskyEmbedExternal from '../embed/external.js'
+} from '../../../../util.ts'
+import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.ts'
+import type * as AppBskyGraphDefs from '../graph/defs.ts'
+import type * as ComAtprotoRepoStrongRef from '../../../com/atproto/repo/strongRef.ts'
+import type * as AppBskyNotificationDefs from '../notification/defs.ts'
+import type * as AppBskyFeedThreadgate from '../feed/threadgate.ts'
+import type * as AppBskyFeedPostgate from '../feed/postgate.ts'
+import type * as AppBskyEmbedExternal from '../embed/external.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/actor/getProfile.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyActorDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyActorDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/actor/getProfiles.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyActorDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyActorDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/external.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/images.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyEmbedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyEmbedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/record.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as ComAtprotoRepoStrongRef from '../../../com/atproto/repo/strongRef.js'
-import type * as AppBskyFeedDefs from '../feed/defs.js'
-import type * as AppBskyGraphDefs from '../graph/defs.js'
-import type * as AppBskyLabelerDefs from '../labeler/defs.js'
-import type * as AppBskyActorDefs from '../actor/defs.js'
-import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.js'
-import type * as AppBskyEmbedImages from './images.js'
-import type * as AppBskyEmbedVideo from './video.js'
-import type * as AppBskyEmbedExternal from './external.js'
-import type * as AppBskyEmbedRecordWithMedia from './recordWithMedia.js'
+} from '../../../../util.ts'
+import type * as ComAtprotoRepoStrongRef from '../../../com/atproto/repo/strongRef.ts'
+import type * as AppBskyFeedDefs from '../feed/defs.ts'
+import type * as AppBskyGraphDefs from '../graph/defs.ts'
+import type * as AppBskyLabelerDefs from '../labeler/defs.ts'
+import type * as AppBskyActorDefs from '../actor/defs.ts'
+import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.ts'
+import type * as AppBskyEmbedImages from './images.ts'
+import type * as AppBskyEmbedVideo from './video.ts'
+import type * as AppBskyEmbedExternal from './external.ts'
+import type * as AppBskyEmbedRecordWithMedia from './recordWithMedia.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/recordWithMedia.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyEmbedRecord from './record.js'
-import type * as AppBskyEmbedImages from './images.js'
-import type * as AppBskyEmbedVideo from './video.js'
-import type * as AppBskyEmbedExternal from './external.js'
+} from '../../../../util.ts'
+import type * as AppBskyEmbedRecord from './record.ts'
+import type * as AppBskyEmbedImages from './images.ts'
+import type * as AppBskyEmbedVideo from './video.ts'
+import type * as AppBskyEmbedExternal from './external.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/embed/video.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyEmbedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyEmbedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyActorDefs from '../actor/defs.js'
-import type * as AppBskyEmbedImages from '../embed/images.js'
-import type * as AppBskyEmbedVideo from '../embed/video.js'
-import type * as AppBskyEmbedExternal from '../embed/external.js'
-import type * as AppBskyEmbedRecord from '../embed/record.js'
-import type * as AppBskyEmbedRecordWithMedia from '../embed/recordWithMedia.js'
-import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.js'
-import type * as AppBskyRichtextFacet from '../richtext/facet.js'
-import type * as AppBskyGraphDefs from '../graph/defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyActorDefs from '../actor/defs.ts'
+import type * as AppBskyEmbedImages from '../embed/images.ts'
+import type * as AppBskyEmbedVideo from '../embed/video.ts'
+import type * as AppBskyEmbedExternal from '../embed/external.ts'
+import type * as AppBskyEmbedRecord from '../embed/record.ts'
+import type * as AppBskyEmbedRecordWithMedia from '../embed/recordWithMedia.ts'
+import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.ts'
+import type * as AppBskyRichtextFacet from '../richtext/facet.ts'
+import type * as AppBskyGraphDefs from '../graph/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/getActorFeeds.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyFeedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyFeedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/getFeedGenerator.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyFeedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyFeedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/getFeedGenerators.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyFeedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyFeedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/getPosts.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as AppBskyFeedDefs from './defs.js'
+} from '../../../../util.ts'
+import type * as AppBskyFeedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/postgate.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/feed/threadgate.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/graph/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
-import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.js'
-import type * as AppBskyActorDefs from '../actor/defs.js'
-import type * as AppBskyRichtextFacet from '../richtext/facet.js'
-import type * as AppBskyFeedDefs from '../feed/defs.js'
+} from '../../../../util.ts'
+import type * as ComAtprotoLabelDefs from '../../../com/atproto/label/defs.ts'
+import type * as AppBskyActorDefs from '../actor/defs.ts'
+import type * as AppBskyRichtextFacet from '../richtext/facet.ts'
+import type * as AppBskyFeedDefs from '../feed/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/notification/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/app/bsky/richtext/facet.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/com/atproto/label/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/com/atproto/repo/strongRef.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../util'
+} from '../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/actor/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
+} from '../../../../../../util.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/defs.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.js'
-import type * as PartyWheyAppBskyActorDefs from '../actor/defs.js'
-import type * as AppBskyActorDefs from '../../../../../app/bsky/actor/defs.js'
+} from '../../../../../../util.ts'
+import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.ts'
+import type * as PartyWheyAppBskyActorDefs from '../actor/defs.ts'
+import type * as AppBskyActorDefs from '../../../../../app/bsky/actor/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getActorLikesPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyFeedDefs from './defs.js'
-import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyFeedDefs from './defs.ts'
+import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getAuthorFeedPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyFeedDefs from './defs.js'
-import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyFeedDefs from './defs.ts'
+import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getLikesPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyActorDefs from '../actor/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyActorDefs from '../actor/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getListFeedPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyFeedDefs from './defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyFeedDefs from './defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getPostThreadPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyFeedDefs from './defs.js'
-import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyFeedDefs from './defs.ts'
+import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getQuotesPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyFeedDefs from './defs.js'
-import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyFeedDefs from './defs.ts'
+import type * as AppBskyFeedDefs from '../../../../../app/bsky/feed/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/types/party/whey/app/bsky/feed/getRepostedByPartial.ts

···
 /**
  * GENERATED CODE - DO NOT MODIFY
  */
-import { HeadersMap, XRPCError } from '@atproto/xrpc'
-import { type ValidationResult, BlobRef } from '@atproto/lexicon'
-import { CID } from 'multiformats/cid'
-import { validate as _validate } from '../../../../../../lexicons'
+import { HeadersMap, XRPCError } from 'npm:@atproto/xrpc'
+import { type ValidationResult, BlobRef } from 'npm:@atproto/lexicon'
+import { CID } from 'npm:multiformats/cid'
+import { validate as _validate } from '../../../../../../lexicons.ts'
 import {
   type $Typed,
   is$typed as _is$typed,
   type OmitKey,
-} from '../../../../../../util'
-import type * as PartyWheyAppBskyActorDefs from '../actor/defs.js'
-import type * as AppBskyActorDefs from '../../../../../app/bsky/actor/defs.js'
+} from '../../../../../../util.ts'
+import type * as PartyWheyAppBskyActorDefs from '../actor/defs.ts'
+import type * as AppBskyActorDefs from '../../../../../app/bsky/actor/defs.ts'
 
 const is$typed = _is$typed,
   validate = _validate

indexclient/util.ts

···
  * GENERATED CODE - DO NOT MODIFY
  */
 
-import { type ValidationResult } from '@atproto/lexicon'
+import { type ValidationResult } from 'npm:@atproto/lexicon'
 
 export type OmitKey<T, K extends keyof T> = {
   [K2 in keyof T as K2 extends K ? never : K2]: T[K2]

indexserver.ts

···
+export async function indexServerHandler(req: Request): Promise<Response> {
+  const url = new URL(req.url);
+  
+  if (url.pathname === "/ping") {
+    return new Response("pong", { status: 200 });
+  }
+
+  return new Response("Not Found", { status: 404 });
+}

main.ts

···
 import { setupAuth, getAuthenticatedDid, authVerifier } from "./utils/auth.ts";
 import { JetstreamManager, SpacedustManager } from "./utils/sharders.ts";
 import { resolveRecordFromURI, validateRecord } from "./utils/records.ts";
-import dbsetup from "./utils/dbsetup.ts";
+import { setupSystemDb } from "./utils/dbsystem.ts";
+import { setupUserDb } from "./utils/dbuser.ts";
 import { handleSpacedust, startSpacedust } from "./index/spacedust.ts";
 import { handleJetstream, startJetstream } from "./index/jetstream.ts";
 import { Database } from "jsr:@db/sqlite@0.11";
 //import express from "npm:express";
 //import { createServer } from "./xrpc/index.ts";
 import { indexHandlerContext } from "./index/types.ts";
-import * as XRPCTypes from "./utils/viewserver.ts";
+import * as IndexServerTypes from "./utils/indexservertypes.ts";
+import * as ViewServerTypes from "./utils/viewservertypes.ts";
 import * as ATPAPI from "npm:@atproto/api";
 import { didDocument } from "./utils/diddoc.ts";
-
-import ky from "npm:ky";
-import QuickLRU from "npm:quick-lru";
-import { isGeneratorView } from "./viewserver/types/app/bsky/feed/defs.ts";
-import { createHash } from "node:crypto";
-
-const cache = new QuickLRU({ maxSize: 10000 });
-
-function simpleHashAuth(auth: string): string {
-  return createHash("sha256").update(auth).digest("hex");
-}
-export async function cachedFetch(url: string, auth?: string) {
-  const cacheKey = auth ? `${url}|${simpleHashAuth(auth)}` : url;
-  if (cache.has(cacheKey)) return cache.get(cacheKey);
-
-  const data = await ky
-    .get(url, {
-      headers: {
-        Authorization: `${auth}`, // or `Basic`, etc. depending on your needs
-      },
-    })
-    .json();
-
-  cache.set(cacheKey, data);
-  return data;
-}
+import { cachedFetch, searchParamsToJson } from "./utils/server.ts";
+import { indexServerHandler } from "./indexserver.ts";
+import { viewServerHandler } from "./viewserver.ts";
 
-const slingshoturl = Deno.env.get("SLINGSHOT_URL");
-const constellationurl = Deno.env.get("CONSTELLATION_URL");
-const spacedusturl = Deno.env.get("SPACEDUST_URL");
+export const slingshoturl = Deno.env.get("SLINGSHOT_URL");
+export const constellationurl = Deno.env.get("CONSTELLATION_URL");
+export const spacedusturl = Deno.env.get("SPACEDUST_URL");
 
 // ------------------------------------------
 //               AppView Setup
 // ------------------------------------------
 
-export const db = new Database("whatever.db");
-dbsetup();
+export const systemDB = new Database("system.db");
+setupSystemDb(systemDB);
+
 export const spacedustManager = new SpacedustManager((msg) =>
   handleSpacedust(msg)
 );
···
 //         XRPC Method Implementations
 // ------------------------------------------
 
-// begin the hell of implementing api requests and incoming records
-//const seenStrings = new Set<string>();
-
-type SlingshotMiniDoc = {
-  did: string;
-  handle: string;
-  pds: string;
-  signing_key: string;
-};
-type ConstellationDistinctDids = {
-  total: number;
-  linking_dids: string[];
-  cursor: string;
-};
-type GetRecord = {
-  uri: string;
-  cid: string;
-  value: Record<string, unknown>;
-};
-let preferences: any = undefined;
-
-function searchParamsToJson(params: URLSearchParams): Record<string, unknown> {
-  const result: Record<string, string | string[]> = {};
-
-  for (const [key, value] of params.entries()) {
-    if (result.hasOwnProperty(key)) {
-      const existing = result[key];
-      if (Array.isArray(existing)) {
-        existing.push(value);
-      } else {
-        result[key] = [existing, value];
-      }
-    } else {
-      result[key] = value;
-    }
-  }
-
-  return result;
-}
-
-async function resolveIdentity(actor: string): Promise<SlingshotMiniDoc> {
-  const url = `${slingshoturl}/xrpc/com.bad-example.identity.resolveMiniDoc?identifier=${actor}`;
-  return (await cachedFetch(url)) as SlingshotMiniDoc;
-}
-async function getRecord({
-  pds,
-  did,
-  collection,
-  rkey,
-}: {
-  pds: string;
-  did: string;
-  collection: string;
-  rkey: string;
-}): Promise<{ cursor?: string; records: GetRecord[] }> {
-  const url = `${pds}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=${collection}&rkey=${rkey}`;
-  const result = (await cachedFetch(url)) as {
-    cursor?: string;
-    records: GetRecord[];
-  };
-  return result as {
-    cursor?: string;
-    records: {
-      uri: string;
-      cid: string;
-      value: ATPAPI.AppBskyFeedPost.Record;
-    }[];
-  };
-}
-
-async function listPostRecords({
-  pds,
-  did,
-  limit = 50,
-  cursor,
-}: {
-  pds: string;
-  did: string;
-  limit: number;
-  cursor?: string;
-}): Promise<{
-  cursor?: string;
-  records: { uri: string; cid: string; value: ATPAPI.AppBskyFeedPost.Record }[];
-}> {
-  const url = `${pds}/xrpc/com.atproto.repo.listRecords?repo=${did}&collection=app.bsky.feed.post&limit=${limit}${
-    cursor ? `&cursor=${cursor}` : ""
-  }`;
-  const result = (await cachedFetch(url)) as {
-    cursor?: string;
-    records: GetRecord[];
-  };
-  return result as {
-    cursor?: string;
-    records: {
-      uri: string;
-      cid: string;
-      value: ATPAPI.AppBskyFeedPost.Record;
-    }[];
-  };
-}
-
-async function getSlingshotRecord(
-  did: string,
-  collection: string,
-  rkey: string
-): Promise<GetRecord> {
-  const url = `${slingshoturl}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=${collection}&rkey=${rkey}`;
-  const result = (await cachedFetch(url)) as GetRecord;
-  return result as GetRecord;
-}
-
-// async function getProfileRecord(did: string): Promise<ATPAPI.AppBskyActorProfile.Record> {
-//   const url = `${slingshoturl}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=app.bsky.actor.profile&rkey=self`;
-//   const result = await cachedFetch(url) as GetRecord;
-//   return result.value as ATPAPI.AppBskyActorProfile.Record;
-// }
-
-async function getUniqueCount({
-  did,
-  collection,
-  path,
-}: {
-  did: string;
-  collection: string;
-  path: string;
-}): Promise<number> {
-  const url = `${constellationurl}/links/count/distinct-dids?target=${did}&collection=${collection}&path=${path}`;
-  const result = (await cachedFetch(url)) as ConstellationDistinctDids;
-  return result.total;
-}
-
-function buildBlobUrl(
-  pds: string,
-  did: string,
-  cid: string
-): string | undefined {
-  if (!pds || !did || !cid) return undefined;
-  return `${pds}/xrpc/com.atproto.sync.getBlob?did=${did}&cid=${cid}`;
-}
-
-function didWebToHttps(did: string) {
-  if (!did.startsWith("did:web:")) return null;
-  const parts = did.slice("did:web:".length).split(":");
-  const [domain, ...path] = parts;
-  return `https://${domain}${path.length ? "/" + path.join("/") : ""}`;
-}
-
-async function sendItToApiBskyApp(req: Request): Promise<Response> {
-  const url = new URL(req.url);
-  const pathname = url.pathname;
-  const searchParams = searchParamsToJson(url.searchParams);
-  let reqBody: undefined | string;
-  let jsonbody: undefined | Record<string, unknown>;
-  if (req.body) {
-    const body = await req.json();
-    jsonbody = body;
-    // console.log(
-    //   `called at euh reqreqreqreq: ${pathname}\n\n${JSON.stringify(body)}`
-    // );
-    reqBody = JSON.stringify(body, null, 2);
-  }
-  const bskyUrl = `https://api.bsky.app${pathname}${url.search}`;
-  const proxyHeaders = new Headers(req.headers);
-
-  // Remove Authorization and set browser-like User-Agent
-  proxyHeaders.delete("authorization");
-  proxyHeaders.delete("Access-Control-Allow-Origin"),
-    proxyHeaders.set(
-      "user-agent",
-      "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36"
-    );
-  proxyHeaders.set("Access-Control-Allow-Origin", "*");
-
-  const proxyRes = await fetch(bskyUrl, {
-    method: req.method,
-    headers: proxyHeaders,
-    body: ["GET", "HEAD"].includes(req.method.toUpperCase())
-      ? undefined
-      : reqBody,
-  });
-
-  const resBody = await proxyRes.text();
-
-  // console.log(
-  //   "← Response:",
-  //   JSON.stringify(await JSON.parse(resBody), null, 2)
-  // );
-
-  return new Response(resBody, {
-    status: proxyRes.status,
-    headers: proxyRes.headers,
-  });
-}
+const indexServerRoutes = new Set([
+  "/xrpc/app.bsky.actor.getProfile",
+  "/xrpc/app.bsky.actor.getProfiles",
+  "/xrpc/app.bsky.feed.getActorFeeds",
+  "/xrpc/app.bsky.feed.getFeedGenerator",
+  "/xrpc/app.bsky.feed.getFeedGenerators",
+  "/xrpc/app.bsky.feed.getPosts",
+  "/xrpc/party.whey.app.bsky.feed.getActorLikesPartial",
+  "/xrpc/party.whey.app.bsky.feed.getAuthorFeedPartial",
+  "/xrpc/party.whey.app.bsky.feed.getLikesPartial",
+  "/xrpc/party.whey.app.bsky.feed.getPostThreadPartial",
+  "/xrpc/party.whey.app.bsky.feed.getQuotesPartial",
+  "/xrpc/party.whey.app.bsky.feed.getRepostedByPartial",
+]);
 
 Deno.serve(
   { port: Number(`${Deno.env.get("SERVER_PORT")}`) },
   async (req: Request): Promise<Response> => {
     const url = new URL(req.url);
     const pathname = url.pathname;
-    const searchParams = searchParamsToJson(url.searchParams);
-    let reqBody: undefined | string;
-    let jsonbody: undefined | Record<string, unknown>;
-    try {
-      const clone = req.clone();
-      jsonbody = await clone.json();
-    } catch (e) {
-      console.warn("Request body is not valid JSON:", e);
-    }
+    // const searchParams = searchParamsToJson(url.searchParams);
+    // let reqBody: undefined | string;
+    // let jsonbody: undefined | Record<string, unknown>;
+    // try {
+    //   const clone = req.clone();
+    //   jsonbody = await clone.json();
+    // } catch (e) {
+    //   console.warn("Request body is not valid JSON:", e);
+    // }
     if (pathname === "/.well-known/did.json") {
       return new Response(JSON.stringify(didDocument), {
         headers: withCors({ "Content-Type": "application/json" }),
···
         },
       });
     }
-
-    // if (seenStrings.has(url.hash)) {
-    //   // The string has been seen before
-    //   seenStrings.delete(url.hash);
-    //   return new Response("OK", {
-    //     status: 204,
-    //     headers: withCors({
-    //       "Content-Type": "text/plain",
-    //     }),
-    //   });
-    // }
-    // seenStrings.add(url.hash);
-    //const reqBody = req.body ? await req.text() : null;
-
-    console.log("→ Path:", pathname);
-    console.log("→ Auth:", req.headers.get("authorization"));
-    console.log("→ Body:", reqBody);
-    console.log("→ Params:", searchParams);
-
-    const bskyUrl = `https://api.bsky.app${pathname}${url.search}`;
-    const hasAuth = req.headers.has("authorization");
-    const xrpcMethod = pathname.startsWith("/xrpc/")
-      ? pathname.slice("/xrpc/".length)
-      : null;
-
-    if (xrpcMethod === "app.bsky.unspecced.getTrendingTopics") {
-      // const jsonTyped =
-      //   jsonUntyped as XRPCTypes.AppBskyUnspeccedGetTrendingTopics.QueryParams;
-
-      const faketopics: ATPAPI.AppBskyUnspeccedDefs.TrendingTopic[] = [
-        {
-          $type: "app.bsky.unspecced.defs#trendingTopic",
-          topic: "Git Repo",
-          displayName: "Git Repo",
-          description: "Git Repo",
-          link: "https://tangled.sh/@whey.party/skylite",
-        },
-        {
-          $type: "app.bsky.unspecced.defs#trendingTopic",
-          topic: "Red Dwarf Lite",
-          displayName: "Red Dwarf Lite",
-          description: "Red Dwarf Lite",
-          link: "https://reddwarflite.whey.party/",
-        },
-        {
-          $type: "app.bsky.unspecced.defs#trendingTopic",
-          topic: "whey dot party",
-          displayName: "whey dot party",
-          description: "whey dot party",
-          link: "https://whey.party/",
-        },
-      ];
-
-      const response: XRPCTypes.AppBskyUnspeccedGetTrendingTopics.OutputSchema =
-        {
-          topics: faketopics,
-          suggested: faketopics,
-        };
-
-      return new Response(JSON.stringify(response), {
-        headers: withCors({ "Content-Type": "application/json" }),
-      });
-    }
-
-    //if (xrpcMethod !== 'app.bsky.actor.getPreferences' && xrpcMethod !== 'app.bsky.notification.listNotifications') {
-    if (
-      !hasAuth
-      // (!hasAuth ||
-      //   xrpcMethod === "app.bsky.labeler.getServices" ||
-      //   xrpcMethod === "app.bsky.unspecced.getConfig") &&
-      // xrpcMethod !== "app.bsky.notification.putPreferences"
-    ) {
-      return new Response(
-        JSON.stringify({
-          error: "XRPCNotSupported",
-          message:
-            "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
-        }),
-        {
-          status: 404,
-          headers: withCors({ "Content-Type": "application/json" }),
-        }
-      );
-      //return await sendItToApiBskyApp(req);
-    }
-    if (
-      // !hasAuth ||
-      xrpcMethod === "app.bsky.labeler.getServices" ||
-      xrpcMethod === "app.bsky.unspecced.getConfig" //&&
-      //xrpcMethod !== "app.bsky.notification.putPreferences"
-    ) {
-      return new Response(
-        JSON.stringify({
-          error: "XRPCNotSupported",
-          message:
-            "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
-        }),
-        {
-          status: 404,
-          headers: withCors({ "Content-Type": "application/json" }),
-        }
-      );
-      //return await sendItToApiBskyApp(req);
-    }
-
-    const authDID = "did:plc:mn45tewwnse5btfftvd3powc"; //getAuthenticatedDid(req);
-
-    const jsonUntyped = searchParams;
-
-    switch (xrpcMethod) {
-      case "app.bsky.feed.getFeedGenerators": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyFeedGetFeedGenerators.QueryParams;
-
-        const feeds: ATPAPI.AppBskyFeedDefs.GeneratorView[] = (
-          await Promise.all(
-            jsonTyped.feeds.map(async (feed) => {
-              try {
-                const did = new ATPAPI.AtUri(feed).hostname;
-                const rkey = new ATPAPI.AtUri(feed).rkey;
-                const identity = await resolveIdentity(did);
-                const feedgetRecord = await getSlingshotRecord(
-                  identity.did,
-                  "app.bsky.feed.generator",
-                  rkey
-                );
-                const profile = (
-                  await getSlingshotRecord(
-                    identity.did,
-                    "app.bsky.actor.profile",
-                    "self"
-                  )
-                ).value as ATPAPI.AppBskyActorProfile.Record;
-                const anyprofile = profile as any;
-                const value =
-                  feedgetRecord.value as ATPAPI.AppBskyFeedGenerator.Record;
-
-                return {
-                  $type: "app.bsky.feed.defs#generatorView",
-                  uri: feed,
-                  cid: feedgetRecord.cid,
-                  did: identity.did,
-                  creator: /*AppBskyActorDefs.ProfileView*/ {
-                    $type: "app.bsky.actor.defs#profileView",
-                    did: identity.did,
-                    handle: identity.handle,
-                    displayName: profile.displayName,
-                    description: profile.description,
-                    avatar: buildBlobUrl(
-                      identity.pds,
-                      identity.did,
-                      anyprofile.avatar.ref["$link"]
-                    ),
-                    //associated?: ProfileAssociated
-                    //indexedAt?: string
-                    //createdAt?: string
-                    //viewer?: ViewerState
-                    //labels?: ComAtprotoLabelDefs.Label[]
-                    //verification?: VerificationState
-                    //status?: StatusView
-                  },
-                  displayName: value.displayName,
-                  description: value.description,
-                  //descriptionFacets?: AppBskyRichtextFacet.Main[]
-                  avatar: buildBlobUrl(
-                    identity.pds,
-                    identity.did,
-                    (value as any).avatar.ref["$link"]
-                  ),
-                  //likeCount?: number
-                  //acceptsInteractions?: boolean
-                  //labels?: ComAtprotoLabelDefs.Label[]
-                  //viewer?: GeneratorViewerState
-                  contentMode: value.contentMode,
-                  indexedAt: new Date().toISOString(),
-                };
-              } catch (err) {
-                return undefined;
-              }
-            })
-          )
-        ).filter(isGeneratorView);
-
-        const response: XRPCTypes.AppBskyFeedGetFeedGenerators.OutputSchema = {
-          feeds: feeds ? feeds : [],
-        };
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.feed.getFeed": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyFeedGetFeed.QueryParams;
-        const cursor = jsonTyped.cursor;
-        const feed = jsonTyped.feed;
-        const limit = jsonTyped.limit;
-        const proxyauth = req.headers.get("authorization") || "";
-
-        const did = new ATPAPI.AtUri(feed).hostname;
-        const rkey = new ATPAPI.AtUri(feed).rkey;
-        const identity = await resolveIdentity(did);
-        const feedgetRecord = (
-          await getSlingshotRecord(
-            identity.did,
-            "app.bsky.feed.generator",
-            rkey
-          )
-        ).value as ATPAPI.AppBskyFeedGenerator.Record;
-
-        const skeleton = (await cachedFetch(
-          `${didWebToHttps(
-            feedgetRecord.did
-          )}/xrpc/app.bsky.feed.getFeedSkeleton?feed=${jsonTyped.feed}${
-            cursor ? `&cursor=${cursor}` : ""
-          }${limit ? `&limit=${limit}` : ""}`,
-          proxyauth
-        )) as ATPAPI.AppBskyFeedGetFeedSkeleton.OutputSchema;
-
-        const nextcursor = skeleton.cursor;
-        const dbgrqstid = skeleton.reqId;
-        const uriarray = skeleton.feed;
-
-        // Step 1: Chunk into 25 max
-        const chunks = [];
-        for (let i = 0; i < uriarray.length; i += 25) {
-          chunks.push(uriarray.slice(i, i + 25));
-        }
-
-        // Step 2: Hydrate via getPosts
-        const hydratedPosts: ATPAPI.AppBskyFeedDefs.FeedViewPost[] = [];
-
-        for (const chunk of chunks) {
-          const searchParams = new URLSearchParams();
-          for (const uri of chunk.map((item) => item.post)) {
-            searchParams.append("uris", uri);
-          }
-
-          const postResp = await ky
-            .get(`https://api.bsky.app/xrpc/app.bsky.feed.getPosts`, {
-              // headers: {
-              //   Authorization: proxyauth,
-              // },
-              searchParams,
-            })
-            .json<ATPAPI.AppBskyFeedGetPosts.OutputSchema>();
-
-          for (const post of postResp.posts) {
-            const matchingSkeleton = uriarray.find(
-              (item) => item.post === post.uri
-            );
-            if (matchingSkeleton) {
-              //post.author.handle = post.author.handle + ".percent40.api.bsky.app"; // or any logic to modify it
-              hydratedPosts.push({
-                post,
-                reason: matchingSkeleton.reason,
-                //reply: matchingSkeleton,
-              });
-            }
-          }
-        }
-
-        // Step 3: Compose final response
-        const response: XRPCTypes.AppBskyFeedGetFeed.OutputSchema = {
-          feed: hydratedPosts,
-          cursor: nextcursor,
-        };
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.actor.getProfile": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyActorGetProfile.QueryParams;
-
-        const userindexservice = "";
-        const isbskyfallback = true;
-        if (isbskyfallback) {
-          return sendItToApiBskyApp(req);
-        }
-
-        const response: XRPCTypes.AppBskyActorGetProfile.OutputSchema = {};
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-
-      case "app.bsky.actor.getProfiles": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyActorGetProfiles.QueryParams;
-
-        const userindexservice = "";
-        const isbskyfallback = true;
-        if (isbskyfallback) {
-          return sendItToApiBskyApp(req);
-        }
-
-        const response: XRPCTypes.AppBskyActorGetProfiles.OutputSchema = {};
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.feed.getAuthorFeed": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyFeedGetAuthorFeed.QueryParams;
-
-        const userindexservice = "";
-        const isbskyfallback = true;
-        if (isbskyfallback) {
-          return sendItToApiBskyApp(req);
-        }
-
-        const response: XRPCTypes.AppBskyFeedGetAuthorFeed.OutputSchema = {};
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.feed.getPostThread": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyFeedGetPostThread.QueryParams;
-
-        const userindexservice = "";
-        const isbskyfallback = true;
-        if (isbskyfallback) {
-          return sendItToApiBskyApp(req);
-        }
-
-        const response: XRPCTypes.AppBskyFeedGetPostThread.OutputSchema = {};
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.unspecced.getPostThreadV2": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyUnspeccedGetPostThreadV2.QueryParams;
-
-        const userindexservice = "";
-        const isbskyfallback = true;
-        if (isbskyfallback) {
-          return sendItToApiBskyApp(req);
-        }
-
-        const response: XRPCTypes.AppBskyUnspeccedGetPostThreadV2.OutputSchema =
-          {};
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-
-      // case "app.bsky.actor.getProfile": {
-      //   const jsonTyped =
-      //     jsonUntyped as XRPCTypes.AppBskyActorGetProfile.QueryParams;
-
-      //   const response: XRPCTypes.AppBskyActorGetProfile.OutputSchema= {};
-
-      //   return new Response(JSON.stringify(response), {
-      //     headers: withCors({ "Content-Type": "application/json" }),
-      //   });
-      // }
-      // case "app.bsky.actor.getProfiles": {
-      //   const jsonTyped = jsonUntyped as XRPCTypes.AppBskyActorGetProfiles.QueryParams;
-
-      //   const response: XRPCTypes.AppBskyActorGetProfiles.OutputSchema = {};
-
-      //   return new Response(JSON.stringify(response), {
-      //     headers: withCors({ "Content-Type": "application/json" }),
-      //   });
-      // }
-      // case "whatever": {
-      //   const jsonTyped = jsonUntyped as XRPCTypes.AppBskyFeedGetAuthorFeed.QueryParams;
-
-      //   const response: XRPCTypes.AppBskyFeedGetAuthorFeed.OutputSchema = {}
-
-      //   return new Response(JSON.stringify(response), {
-      //     headers: withCors({ "Content-Type": "application/json" }),
-      //   });
-      // }
-      // case "app.bsky.notification.listNotifications": {
-      //   const jsonTyped =
-      //     jsonUntyped as XRPCTypes.AppBskyNotificationListNotifications.QueryParams;
-
-      //   const response: XRPCTypes.AppBskyNotificationListNotifications.OutputSchema = {};
-
-      //   return new Response(JSON.stringify(response), {
-      //     headers: withCors({ "Content-Type": "application/json" }),
-      //   });
-      // }
-
-      case "app.bsky.unspecced.getConfig": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyUnspeccedGetConfig.QueryParams;
-
-        const response: XRPCTypes.AppBskyUnspeccedGetConfig.OutputSchema = {
-          checkEmailConfirmed: true,
-          liveNow: [
-            {
-              $type: "app.bsky.unspecced.getConfig#liveNowConfig",
-              did: "did:plc:mn45tewwnse5btfftvd3powc",
-              domains: ["local3768forumtest.whey.party"],
-            },
-          ],
-        };
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      case "app.bsky.graph.getLists": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyGraphGetLists.QueryParams;
-
-        const response: XRPCTypes.AppBskyGraphGetLists.OutputSchema = {
-          lists: [],
-        };
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      //https://shimeji.us-east.host.bsky.network/xrpc/app.bsky.unspecced.getTrendingTopics?limit=14
-      case "app.bsky.unspecced.getTrendingTopics": {
-        const jsonTyped =
-          jsonUntyped as XRPCTypes.AppBskyUnspeccedGetTrendingTopics.QueryParams;
-
-        const faketopics: ATPAPI.AppBskyUnspeccedDefs.TrendingTopic[] = [
-          {
-            $type: "app.bsky.unspecced.defs#trendingTopic",
-            topic: "Git Repo",
-            displayName: "Git Repo",
-            description: "Git Repo",
-            link: "https://tangled.sh/@whey.party/skylite",
-          },
-          {
-            $type: "app.bsky.unspecced.defs#trendingTopic",
-            topic: "Red Dwarf Lite",
-            displayName: "Red Dwarf Lite",
-            description: "Red Dwarf Lite",
-            link: "https://reddwarf.whey.party/",
-          },
-          {
-            $type: "app.bsky.unspecced.defs#trendingTopic",
-            topic: "whey dot party",
-            displayName: "whey dot party",
-            description: "whey dot party",
-            link: "https://whey.party/",
-          },
-        ];
-
-        const response: XRPCTypes.AppBskyUnspeccedGetTrendingTopics.OutputSchema =
-          {
-            topics: faketopics,
-            suggested: faketopics,
-          };
-
-        return new Response(JSON.stringify(response), {
-          headers: withCors({ "Content-Type": "application/json" }),
-        });
-      }
-      default: {
-        return new Response(
-          JSON.stringify({
-            error: "XRPCNotSupported",
-            message:
-              "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
-          }),
-          {
-            status: 404,
-            headers: withCors({ "Content-Type": "application/json" }),
-          }
-        );
-      }
+    // const bskyUrl = `https://api.bsky.app${pathname}${url.search}`;
+    // const hasAuth = req.headers.has("authorization");
+    // const xrpcMethod = pathname.startsWith("/xrpc/")
+    //   ? pathname.slice("/xrpc/".length)
+    //   : null;
+    
+    if (indexServerRoutes.has(pathname)) {
+      return await indexServerHandler(req);
+    } else {
+      return await viewServerHandler(req);
     }
   }
 );
 
-function withCors(headers: HeadersInit = {}) {
+export function withCors(headers: HeadersInit = {}) {
   return {
     "Access-Control-Allow-Origin": "*",
     ...headers,

utils/dbsetup.ts

···
-import { db } from "../main.ts"
-
-export default function dbsetup(){
-
-  const baseColumns = `
-      uri TEXT PRIMARY KEY NOT NULL,
-      did TEXT NOT NULL,
-      cid TEXT,
-      rev TEXT,
-      createdat INTEGER,
-      indexedat INTEGER NOT NULL,
-      json TEXT
-  `;
-  
-  const innerArrayID = "id INTEGER PRIMARY KEY AUTOINCREMENT";
-  const createTableINE = "CREATE TABLE IF NOT EXISTS";
-  const createIndexINE = "CREATE INDEX IF NOT EXISTS";
-  
-  db.exec(`
-    ${createTableINE} users (
-      did TEXT PRIMARY KEY NOT NULL,
-      role TEXT,
-      registrationdate TEXT,
-      onboardingstatus TEXT
-    );
-
-    ${createTableINE} remoteprofileview (
-      did TEXT PRIMARY KEY NOT NULL,
-      handle TEXT,
-      displayname TEXT,
-      description TEXT,
-      avatar TEXT,
-      banner TEXT
-    );
-
-    ${createTableINE} did (
-      did TEXT PRIMARY KEY NOT NULL,
-      method TEXT,
-      string TEXT,
-      doc TEXT,
-      pds TEXT,
-      handle TEXT
-    );
-    ${createIndexINE} idx_did_handle ON did(handle);
-
-    ${createTableINE} prefs (
-      did TEXT PRIMARY KEY NOT NULL,
-      json TEXT
-    );
-    ${createIndexINE} idx_prefs_did ON prefs(did);
-
-    ${createTableINE} backlink_skeleton (
-      id INTEGER PRIMARY KEY AUTOINCREMENT,
-      srcuri TEXT,
-      srcdid TEXT,
-      srcfield TEXT,
-      srccol TEXT,
-      suburi TEXT,
-      subdid TEXT,
-      subcol TEXT
-    );
-    ${createIndexINE} idx_backlink_subdid_mod ON backlink_skeleton(subdid, srcdid);
-    ${createIndexINE} idx_backlink_suburi_mod ON backlink_skeleton(suburi, srcdid);
-    ${createIndexINE} idx_backlink_subdid_filter_mod ON backlink_skeleton(subdid, srccol, srcdid);
-    ${createIndexINE} idx_backlink_suburi_filter_mod ON backlink_skeleton(suburi, srccol, srcdid);
-  
-    ${createTableINE} app_bsky_actor_profile (
-      ${baseColumns},
-      displayname TEXT,
-      description TEXT,
-      avatarcid TEXT,
-      avatarmime TEXT,
-      bannercid TEXT,
-      bannermime TEXT
-    );
-    ${createIndexINE} idx_actor_profile_did ON app_bsky_actor_profile(did);
-  
-    ${createTableINE} app_bsky_feed_post (
-      ${baseColumns},
-      text TEXT,
-      replyroot TEXT,
-      replyparent TEXT,
-      quote TEXT,
-      imagecount INTEGER,
-      image1cid TEXT,
-      image1mime TEXT,
-      image1aspect TEXT,
-      image2cid TEXT,
-      image2mime TEXT,
-      image2aspect TEXT,
-      image3cid TEXT,
-      image3mime TEXT,
-      image3aspect TEXT,
-      image4cid TEXT,
-      image4mime TEXT,
-      image4aspect TEXT,
-      videocount INTEGER,
-      videocid TEXT,
-      videomime TEXT,
-      videoaspect TEXT
-    );
-
-    ${createIndexINE} idx_post_author_timeline ON app_bsky_feed_post(did, createdat DESC);
-    ${createIndexINE} idx_post_global_timeline ON app_bsky_feed_post(indexedat DESC);
-    ${createIndexINE} idx_post_replyroot ON app_bsky_feed_post(replyroot);
-    ${createIndexINE} idx_post_replyparent ON app_bsky_feed_post(replyparent);
-    ${createIndexINE} idx_post_quote ON app_bsky_feed_post(quote);
-  
-    ${createTableINE} app_bsky_feed_post_langs (
-      ${innerArrayID},
-      post TEXT NOT NULL,
-      lang TEXT NOT NULL
-    );
-    ${createIndexINE} idx_post_langs_lang ON app_bsky_feed_post_langs(lang);
-    ${createIndexINE} idx_post_langs_post ON app_bsky_feed_post_langs(post);
-  
-    ${createTableINE} app_bsky_feed_post_hashtags (
-      ${innerArrayID},
-      post TEXT NOT NULL,
-      hashtag TEXT NOT NULL
-    );
-    ${createIndexINE} idx_post_hashtags_hashtag ON app_bsky_feed_post_hashtags(hashtag);
-    ${createIndexINE} idx_post_hashtags_post ON app_bsky_feed_post_hashtags(post);
-  
-    ${createTableINE} app_bsky_feed_post_mentions (
-      ${innerArrayID},
-      post TEXT NOT NULL,
-      mention TEXT NOT NULL
-    );
-    ${createIndexINE} idx_post_mentions_mention ON app_bsky_feed_post_mentions(mention);
-    ${createIndexINE} idx_post_mentions_post ON app_bsky_feed_post_mentions(post);
-
-  
-    ${createTableINE} app_bsky_feed_like (
-      ${baseColumns},
-      subject TEXT NOT NULL,
-      subjectcid TEXT
-    );
-    ${createIndexINE} idx_like_author_timeline ON app_bsky_feed_like(did, createdat DESC);
-    ${createIndexINE} idx_like_subject ON app_bsky_feed_like(subject);
-  
-    ${createTableINE} app_bsky_feed_repost (
-      ${baseColumns},
-      subject TEXT NOT NULL,
-      subjectcid TEXT
-    );
-    ${createIndexINE} idx_repost_author_timeline ON app_bsky_feed_repost(did, createdat DESC);
-    ${createIndexINE} idx_repost_subject ON app_bsky_feed_repost(subject);
-    
-
-    ${createTableINE} app_bsky_graph_follow (
-      ${baseColumns},
-      subject TEXT NOT NULL
-    );
-    ${createIndexINE} idx_follow_author_timeline ON app_bsky_graph_follow(did, createdat DESC);
-    ${createIndexINE} idx_follow_subject_timeline ON app_bsky_graph_follow(subject, createdat DESC);
-  
-    ${createTableINE} app_bsky_graph_block (
-      ${baseColumns},
-      subject TEXT NOT NULL
-    );
-    ${createIndexINE} idx_block_author ON app_bsky_graph_block(did);
-    ${createIndexINE} idx_block_subject ON app_bsky_graph_block(subject);
-  
-    ${createTableINE} app_bsky_graph_list (
-      ${baseColumns},
-      name TEXT,
-      description TEXT,
-      purpose TEXT,
-      avatarcid TEXT,
-      avatarmime TEXT
-    );
-    ${createIndexINE} idx_list_author ON app_bsky_graph_list(did);
-    ${createIndexINE} idx_list_purpose ON app_bsky_graph_list(purpose);
-  
-    ${createTableINE} app_bsky_graph_listitem (
-      ${baseColumns},
-      list TEXT NOT NULL,
-      subject TEXT NOT NULL
-    );
-    ${createIndexINE} idx_listitem_list ON app_bsky_graph_listitem(list);
-    ${createIndexINE} idx_listitem_subject ON app_bsky_graph_listitem(subject);
-    ${createIndexINE} idx_listitem_author ON app_bsky_graph_listitem(did);
-  
-  
-  
-    ${createTableINE} app_bsky_feed_generator (
-      ${baseColumns},
-      displayname TEXT,
-      description TEXT,
-      avatarcid TEXT,
-      avatarmime TEXT
-    );
-    ${createIndexINE} idx_feed_generator_author ON app_bsky_feed_generator(did);
-  
-    ${createTableINE} app_bsky_feed_threadgate (
-      ${baseColumns},
-      post TEXT NOT NULL
-    );
-    ${createIndexINE} idx_threadgate_post ON app_bsky_feed_threadgate(post);
-    ${createIndexINE} idx_threadgate_author ON app_bsky_feed_threadgate(did);
-    
-
-    ${createTableINE} app_bsky_feed_threadgate_hiddenreplies (
-      ${innerArrayID},
-      threadgate TEXT NOT NULL,
-      reply TEXT NOT NULL
-    );
-    ${createIndexINE} idx_threadgate_hiddenreplies_gate ON app_bsky_feed_threadgate_hiddenreplies(threadgate);
-  
-    ${createTableINE} app_bsky_graph_listblock (
-      ${baseColumns},
-      subject TEXT NOT NULL
-    );
-    ${createIndexINE} idx_listblock_subject ON app_bsky_graph_listblock(subject);
-    ${createIndexINE} idx_listblock_author ON app_bsky_graph_listblock(did);
-  
-    ${createTableINE} app_bsky_notification_declaration (
-      ${baseColumns},
-      allowSubscriptions TEXT
-    );
-    ${createIndexINE} idx_notification_declaration_author ON app_bsky_notification_declaration(did);
-  
-  `);
-}

utils/dbsystem.ts

···
+import { Database } from "jsr:@db/sqlite@0.11";
+
+export function setupSystemDb(db: Database) {
+  const createTableINE = "CREATE TABLE IF NOT EXISTS";
+  const createIndexINE = "CREATE INDEX IF NOT EXISTS";
+
+  db.exec(`
+    -- Master list of all users known to the system
+    ${createTableINE} users (
+      did TEXT PRIMARY KEY NOT NULL,
+      role TEXT,
+      registrationdate TEXT,
+      onboardingstatus TEXT
+    );
+
+    -- Cache of profiles for *other* users, prevents storing this in every user's DB
+    ${createTableINE} remoteprofileview (
+      did TEXT PRIMARY KEY NOT NULL,
+      handle TEXT,
+      displayname TEXT,
+      description TEXT,
+      avatar TEXT,
+      banner TEXT
+    );
+
+    -- Central DID document cache and handle resolution
+    ${createTableINE} did (
+      did TEXT PRIMARY KEY NOT NULL,
+      method TEXT,
+      string TEXT,
+      doc TEXT,
+      pds TEXT,
+      handle TEXT
+    );
+    ${createIndexINE} idx_did_handle ON did(handle);
+
+    -- A global index for relationships between any two pieces of content
+    ${createTableINE} backlink_skeleton (
+      id INTEGER PRIMARY KEY AUTOINCREMENT,
+      srcuri TEXT,
+      srcdid TEXT,
+      srcfield TEXT,
+      srccol TEXT,
+      suburi TEXT,
+      subdid TEXT,
+      subcol TEXT
+    );
+    ${createIndexINE} idx_backlink_subdid_mod ON backlink_skeleton(subdid, srcdid);
+    ${createIndexINE} idx_backlink_suburi_mod ON backlink_skeleton(suburi, srcdid);
+    ${createIndexINE} idx_backlink_subdid_filter_mod ON backlink_skeleton(subdid, srccol, srcdid);
+    ${createIndexINE} idx_backlink_suburi_filter_mod ON backlink_skeleton(suburi, srccol, srcdid);
+  `);
+}

utils/dbuser.ts

···
+import { Database } from "jsr:@db/sqlite@0.11";
+
+export function setupUserDb(db: Database) {
+
+  const baseColumns = `
+      uri TEXT PRIMARY KEY NOT NULL,
+      did TEXT NOT NULL,
+      cid TEXT,
+      rev TEXT,
+      createdat INTEGER,
+      indexedat INTEGER NOT NULL,
+      json TEXT
+  `;
+  
+  const innerArrayID = "id INTEGER PRIMARY KEY AUTOINCREMENT";
+  const createTableINE = "CREATE TABLE IF NOT EXISTS";
+  const createIndexINE = "CREATE INDEX IF NOT EXISTS";
+  
+  db.exec(`
+    -- User's own personal preferences
+    ${createTableINE} prefs (
+      did TEXT PRIMARY KEY NOT NULL,
+      json TEXT
+    );
+    ${createIndexINE} idx_prefs_did ON prefs(did);
+
+    -- The user's own profile record
+    ${createTableINE} app_bsky_actor_profile (
+      ${baseColumns},
+      displayname TEXT,
+      description TEXT,
+      avatarcid TEXT,
+      avatarmime TEXT,
+      bannercid TEXT,
+      bannermime TEXT
+    );
+    ${createIndexINE} idx_actor_profile_did ON app_bsky_actor_profile(did);
+  
+    -- All posts created by the user
+    ${createTableINE} app_bsky_feed_post (
+      ${baseColumns},
+      text TEXT,
+      replyroot TEXT,
+      replyparent TEXT,
+      quote TEXT,
+      imagecount INTEGER,
+      image1cid TEXT,
+      image1mime TEXT,
+      image1aspect TEXT,
+      image2cid TEXT,
+      image2mime TEXT,
+      image2aspect TEXT,
+      image3cid TEXT,
+      image3mime TEXT,
+      image3aspect TEXT,
+      image4cid TEXT,
+      image4mime TEXT,
+      image4aspect TEXT,
+      videocount INTEGER,
+      videocid TEXT,
+      videomime TEXT,
+      videoaspect TEXT
+    );
+    ${createIndexINE} idx_post_author_timeline ON app_bsky_feed_post(did, createdat DESC);
+    ${createIndexINE} idx_post_global_timeline ON app_bsky_feed_post(indexedat DESC);
+    ${createIndexINE} idx_post_replyroot ON app_bsky_feed_post(replyroot);
+    ${createIndexINE} idx_post_replyparent ON app_bsky_feed_post(replyparent);
+    ${createIndexINE} idx_post_quote ON app_bsky_feed_post(quote);
+  
+    -- Data related to the user's posts
+    ${createTableINE} app_bsky_feed_post_langs ( ${innerArrayID}, post TEXT NOT NULL, lang TEXT NOT NULL );
+    ${createIndexINE} idx_post_langs_lang ON app_bsky_feed_post_langs(lang);
+    ${createIndexINE} idx_post_langs_post ON app_bsky_feed_post_langs(post);
+  
+    ${createTableINE} app_bsky_feed_post_hashtags ( ${innerArrayID}, post TEXT NOT NULL, hashtag TEXT NOT NULL );
+    ${createIndexINE} idx_post_hashtags_hashtag ON app_bsky_feed_post_hashtags(hashtag);
+    ${createIndexINE} idx_post_hashtags_post ON app_bsky_feed_post_hashtags(post);
+  
+    ${createTableINE} app_bsky_feed_post_mentions ( ${innerArrayID}, post TEXT NOT NULL, mention TEXT NOT NULL );
+    ${createIndexINE} idx_post_mentions_mention ON app_bsky_feed_post_mentions(mention);
+    ${createIndexINE} idx_post_mentions_post ON app_bsky_feed_post_mentions(post);
+
+    -- All likes created by the user
+    ${createTableINE} app_bsky_feed_like ( ${baseColumns}, subject TEXT NOT NULL, subjectcid TEXT );
+    ${createIndexINE} idx_like_author_timeline ON app_bsky_feed_like(did, createdat DESC);
+    ${createIndexINE} idx_like_subject ON app_bsky_feed_like(subject);
+  
+    -- All reposts created by the user
+    ${createTableINE} app_bsky_feed_repost ( ${baseColumns}, subject TEXT NOT NULL, subjectcid TEXT );
+    ${createIndexINE} idx_repost_author_timeline ON app_bsky_feed_repost(did, createdat DESC);
+    ${createIndexINE} idx_repost_subject ON app_bsky_feed_repost(subject);
+
+    -- All follows created by the user
+    ${createTableINE} app_bsky_graph_follow ( ${baseColumns}, subject TEXT NOT NULL );
+    ${createIndexINE} idx_follow_author_timeline ON app_bsky_graph_follow(did, createdat DESC);
+    ${createIndexINE} idx_follow_subject_timeline ON app_bsky_graph_follow(subject, createdat DESC);
+  
+    -- All blocks created by the user
+    ${createTableINE} app_bsky_graph_block ( ${baseColumns}, subject TEXT NOT NULL );
+    ${createIndexINE} idx_block_author ON app_bsky_graph_block(did);
+    ${createIndexINE} idx_block_subject ON app_bsky_graph_block(subject);
+  
+    -- All lists created by the user
+    ${createTableINE} app_bsky_graph_list ( ${baseColumns}, name TEXT, description TEXT, purpose TEXT, avatarcid TEXT, avatarmime TEXT );
+    ${createIndexINE} idx_list_author ON app_bsky_graph_list(did);
+    ${createIndexINE} idx_list_purpose ON app_bsky_graph_list(purpose);
+  
+    -- All list items created by the user
+    ${createTableINE} app_bsky_graph_listitem ( ${baseColumns}, list TEXT NOT NULL, subject TEXT NOT NULL );
+    ${createIndexINE} idx_listitem_list ON app_bsky_graph_listitem(list);
+    ${createIndexINE} idx_listitem_subject ON app_bsky_graph_listitem(subject);
+    ${createIndexINE} idx_listitem_author ON app_bsky_graph_listitem(did);
+  
+    -- All feed generators created by the user
+    ${createTableINE} app_bsky_feed_generator ( ${baseColumns}, displayname TEXT, description TEXT, avatarcid TEXT, avatarmime TEXT );
+    ${createIndexINE} idx_feed_generator_author ON app_bsky_feed_generator(did);
+  
+    -- All threadgates created by the user
+    ${createTableINE} app_bsky_feed_threadgate ( ${baseColumns}, post TEXT NOT NULL );
+    ${createIndexINE} idx_threadgate_post ON app_bsky_feed_threadgate(post);
+    ${createIndexINE} idx_threadgate_author ON app_bsky_feed_threadgate(did);
+
+    ${createTableINE} app_bsky_feed_threadgate_hiddenreplies ( ${innerArrayID}, threadgate TEXT NOT NULL, reply TEXT NOT NULL );
+    ${createIndexINE} idx_threadgate_hiddenreplies_gate ON app_bsky_feed_threadgate_hiddenreplies(threadgate);
+  
+    -- All list blocks created by the user
+    ${createTableINE} app_bsky_graph_listblock ( ${baseColumns}, subject TEXT NOT NULL );
+    ${createIndexINE} idx_listblock_subject ON app_bsky_graph_listblock(subject);
+    ${createIndexINE} idx_listblock_author ON app_bsky_graph_listblock(did);
+  
+    -- User's notification settings declaration
+    ${createTableINE} app_bsky_notification_declaration ( ${baseColumns}, allowSubscriptions TEXT );
+    ${createIndexINE} idx_notification_declaration_author ON app_bsky_notification_declaration(did);
+  `);
+}

utils/identity.ts

···
 
 import { DidResolver, HandleResolver } from "npm:@atproto/identity";
-import { db } from "../main.ts";
+import { systemDB } from "../main.ts";
 type DidMethod = "web" | "plc";
 type DidDoc = {
   "@context"?: unknown;
···
 }
 
 function getDidFromHandle(handle: string): { did: string } | null {
-  const row = db.prepare("SELECT did FROM did WHERE handle = ?").get(handle);
+  const row = systemDB.prepare("SELECT did FROM did WHERE handle = ?").get(handle);
   if (!row) return null;
 
   try {
···
 function getDidDoc(
   did: string
 ): { method: "web" | "plc"; doc: DidDoc } | null {
-  const row = db.prepare("SELECT method, doc FROM did WHERE did = ?").get(did);
+  const row = systemDB.prepare("SELECT method, doc FROM did WHERE did = ?").get(did);
   if (!row) return null;
 
   try {
···
 function getPDSAndHandleFromDid(
   did: string
 ): { pds: string; handle?: string } | null {
-  const row = db.prepare("SELECT pds, handle FROM did WHERE did = ?").get(did);
+  const row = systemDB.prepare("SELECT pds, handle FROM did WHERE did = ?").get(did);
 
   if (!row) return null;
   return {
···
     const { did } = await resolveDidFromHandle(handle);
     const { diddoc, didmethod } = await resolveDidDoc(did);
 
-    db.prepare(
+    systemDB.prepare(
       "INSERT OR REPLACE INTO did (did, handle, doc, method) VALUES (?, ?, ?, ?)"
     ).run(did, handle, JSON.stringify(diddoc), didmethod);
 
···
   try {
     const { diddoc, didmethod } = await resolveDidDoc(did);
 
-    db.prepare(
+    systemDB.prepare(
       "INSERT OR REPLACE INTO did (did, doc, method) VALUES (?, ?, ?)"
     ).run(did, JSON.stringify(diddoc), didmethod);
 
···
       if (aka) handle = aka.slice("at://".length);
     }
 
-    db.prepare(
+    systemDB.prepare(
       "INSERT OR REPLACE INTO did (did, pds, handle) VALUES (?, ?, ?)"
     ).run(did, serviceEndpoint, handle ?? null);
 

utils/indexservertypes.ts

···
+export * as AppBskyActorGetProfile from '../indexserver/types/app/bsky/actor/getProfile.ts'
+export * as AppBskyActorGetProfiles from '../indexserver/types/app/bsky/actor/getProfiles.ts'
+export * as AppBskyFeedGetActorFeeds from '../indexserver/types/app/bsky/feed/getActorFeeds.ts'
+export * as AppBskyFeedGetFeedGenerator from '../indexserver/types/app/bsky/feed/getFeedGenerator.ts'
+export * as AppBskyFeedGetFeedGenerators from '../indexserver/types/app/bsky/feed/getFeedGenerators.ts'
+export * as AppBskyFeedGetPosts from '../indexserver/types/app/bsky/feed/getPosts.ts'
+export * as PartyWheyAppBskyFeedGetActorLikesPartial from '../indexserver/types/party/whey/app/bsky/feed/getActorLikesPartial.ts'
+export * as PartyWheyAppBskyFeedGetAuthorFeedPartial from '../indexserver/types/party/whey/app/bsky/feed/getAuthorFeedPartial.ts'
+export * as PartyWheyAppBskyFeedGetLikesPartial from '../indexserver/types/party/whey/app/bsky/feed/getLikesPartial.ts'
+export * as PartyWheyAppBskyFeedGetListFeedPartial from '../indexserver/types/party/whey/app/bsky/feed/getListFeedPartial.ts'
+export * as PartyWheyAppBskyFeedGetPostThreadPartial from '../indexserver/types/party/whey/app/bsky/feed/getPostThreadPartial.ts'
+export * as PartyWheyAppBskyFeedGetQuotesPartial from '../indexserver/types/party/whey/app/bsky/feed/getQuotesPartial.ts'
+export * as PartyWheyAppBskyFeedGetRepostedByPartial from '../indexserver/types/party/whey/app/bsky/feed/getRepostedByPartial.ts'

utils/server.ts

···
+import ky from "npm:ky";
+import QuickLRU from "npm:quick-lru";
+import { createHash } from "node:crypto";
+import { slingshoturl, constellationurl } from "../main.ts";
+import * as ATPAPI from "npm:@atproto/api";
+
+const cache = new QuickLRU({ maxSize: 10000 });
+
+function simpleHashAuth(auth: string): string {
+  return createHash("sha256").update(auth).digest("hex");
+}
+export async function cachedFetch(url: string, auth?: string) {
+  const cacheKey = auth ? `${url}|${simpleHashAuth(auth)}` : url;
+  if (cache.has(cacheKey)) return cache.get(cacheKey);
+
+  const data = await ky
+    .get(url, {
+      headers: {
+        Authorization: `${auth}`,
+      },
+    })
+    .json();
+
+  cache.set(cacheKey, data);
+  return data;
+}
+
+export type SlingshotMiniDoc = {
+  did: string;
+  handle: string;
+  pds: string;
+  signing_key: string;
+};
+let preferences: any = undefined;
+
+export function searchParamsToJson(
+  params: URLSearchParams
+): Record<string, unknown> {
+  const result: Record<string, string | string[]> = {};
+
+  for (const [key, value] of params.entries()) {
+    if (result.hasOwnProperty(key)) {
+      const existing = result[key];
+      if (Array.isArray(existing)) {
+        existing.push(value);
+      } else {
+        result[key] = [existing, value];
+      }
+    } else {
+      result[key] = value;
+    }
+  }
+
+  return result;
+}
+
+export async function resolveIdentity(
+  actor: string
+): Promise<SlingshotMiniDoc> {
+  const url = `${slingshoturl}/xrpc/com.bad-example.identity.resolveMiniDoc?identifier=${actor}`;
+  return (await cachedFetch(url)) as SlingshotMiniDoc;
+}
+export async function getRecord({
+  pds,
+  did,
+  collection,
+  rkey,
+}: {
+  pds: string;
+  did: string;
+  collection: string;
+  rkey: string;
+}): Promise<{ cursor?: string; records: GetRecord[] }> {
+  const url = `${pds}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=${collection}&rkey=${rkey}`;
+  const result = (await cachedFetch(url)) as {
+    cursor?: string;
+    records: GetRecord[];
+  };
+  return result as {
+    cursor?: string;
+    records: {
+      uri: string;
+      cid: string;
+      value: ATPAPI.AppBskyFeedPost.Record;
+    }[];
+  };
+}
+
+export async function listPostRecords({
+  pds,
+  did,
+  limit = 50,
+  cursor,
+}: {
+  pds: string;
+  did: string;
+  limit: number;
+  cursor?: string;
+}): Promise<{
+  cursor?: string;
+  records: { uri: string; cid: string; value: ATPAPI.AppBskyFeedPost.Record }[];
+}> {
+  const url = `${pds}/xrpc/com.atproto.repo.listRecords?repo=${did}&collection=app.bsky.feed.post&limit=${limit}${
+    cursor ? `&cursor=${cursor}` : ""
+  }`;
+  const result = (await cachedFetch(url)) as {
+    cursor?: string;
+    records: GetRecord[];
+  };
+  return result as {
+    cursor?: string;
+    records: {
+      uri: string;
+      cid: string;
+      value: ATPAPI.AppBskyFeedPost.Record;
+    }[];
+  };
+}
+
+// async function getProfileRecord(did: string): Promise<ATPAPI.AppBskyActorProfile.Record> {
+//   const url = `${slingshoturl}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=app.bsky.actor.profile&rkey=self`;
+//   const result = await cachedFetch(url) as GetRecord;
+//   return result.value as ATPAPI.AppBskyActorProfile.Record;
+// }
+
+export function buildBlobUrl(
+  pds: string,
+  did: string,
+  cid: string
+): string | undefined {
+  if (!pds || !did || !cid) return undefined;
+  return `${pds}/xrpc/com.atproto.sync.getBlob?did=${did}&cid=${cid}`;
+}
+
+export type ConstellationDistinctDids = {
+  total: number;
+  linking_dids: string[];
+  cursor: string;
+};
+export type GetRecord = {
+  uri: string;
+  cid: string;
+  value: Record<string, unknown>;
+};
+
+export function didWebToHttps(did: string) {
+  if (!did.startsWith("did:web:")) return null;
+  const parts = did.slice("did:web:".length).split(":");
+  const [domain, ...path] = parts;
+  return `https://${domain}${path.length ? "/" + path.join("/") : ""}`;
+}
+
+export async function getSlingshotRecord(
+  did: string,
+  collection: string,
+  rkey: string
+): Promise<GetRecord> {
+  const url = `${slingshoturl}/xrpc/com.atproto.repo.getRecord?repo=${did}&collection=${collection}&rkey=${rkey}`;
+  const result = (await cachedFetch(url)) as GetRecord;
+  return result as GetRecord;
+}
+
+export async function getUniqueCount({
+  did,
+  collection,
+  path,
+}: {
+  did: string;
+  collection: string;
+  path: string;
+}): Promise<number> {
+  const url = `${constellationurl}/links/count/distinct-dids?target=${did}&collection=${collection}&path=${path}`;
+  const result = (await cachedFetch(url)) as ConstellationDistinctDids;
+  return result.total;
+}

viewserver.ts

···
+import ky from "npm:ky";
+import { isGeneratorView } from "./indexserver/types/app/bsky/feed/defs.ts";
+import { withCors } from "./main.ts";
+import * as ViewServerTypes from "./utils/viewservertypes.ts";
+import * as ATPAPI from "npm:@atproto/api";
+import {
+  searchParamsToJson,
+  resolveIdentity,
+  buildBlobUrl,
+  cachedFetch,
+  didWebToHttps,
+  getSlingshotRecord,
+} from "./utils/server.ts";
+
+export async function viewServerHandler(req: Request): Promise<Response> {
+  const url = new URL(req.url);
+  const pathname = url.pathname;
+  const bskyUrl = `https://api.bsky.app${pathname}${url.search}`;
+  const hasAuth = req.headers.has("authorization");
+  const xrpcMethod = pathname.startsWith("/xrpc/")
+    ? pathname.slice("/xrpc/".length)
+    : null;
+  const searchParams = searchParamsToJson(url.searchParams);
+  const jsonUntyped = searchParams;
+
+  if (xrpcMethod === "app.bsky.unspecced.getTrendingTopics") {
+    // const jsonTyped =
+    //   jsonUntyped as ViewServerTypes.AppBskyUnspeccedGetTrendingTopics.QueryParams;
+
+    const faketopics: ATPAPI.AppBskyUnspeccedDefs.TrendingTopic[] = [
+      {
+        $type: "app.bsky.unspecced.defs#trendingTopic",
+        topic: "Git Repo",
+        displayName: "Git Repo",
+        description: "Git Repo",
+        link: "https://tangled.sh/@whey.party/skylite",
+      },
+      {
+        $type: "app.bsky.unspecced.defs#trendingTopic",
+        topic: "Red Dwarf Lite",
+        displayName: "Red Dwarf Lite",
+        description: "Red Dwarf Lite",
+        link: "https://reddwarflite.whey.party/",
+      },
+      {
+        $type: "app.bsky.unspecced.defs#trendingTopic",
+        topic: "whey dot party",
+        displayName: "whey dot party",
+        description: "whey dot party",
+        link: "https://whey.party/",
+      },
+    ];
+
+    const response: ViewServerTypes.AppBskyUnspeccedGetTrendingTopics.OutputSchema =
+      {
+        topics: faketopics,
+        suggested: faketopics,
+      };
+
+    return new Response(JSON.stringify(response), {
+      headers: withCors({ "Content-Type": "application/json" }),
+    });
+  }
+
+  //if (xrpcMethod !== 'app.bsky.actor.getPreferences' && xrpcMethod !== 'app.bsky.notification.listNotifications') {
+  if (
+    !hasAuth
+    // (!hasAuth ||
+    //   xrpcMethod === "app.bsky.labeler.getServices" ||
+    //   xrpcMethod === "app.bsky.unspecced.getConfig") &&
+    // xrpcMethod !== "app.bsky.notification.putPreferences"
+  ) {
+    return new Response(
+      JSON.stringify({
+        error: "XRPCNotSupported",
+        message:
+          "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
+      }),
+      {
+        status: 404,
+        headers: withCors({ "Content-Type": "application/json" }),
+      }
+    );
+    //return await sendItToApiBskyApp(req);
+  }
+  if (
+    // !hasAuth ||
+    xrpcMethod === "app.bsky.labeler.getServices" ||
+    xrpcMethod === "app.bsky.unspecced.getConfig" //&&
+    //xrpcMethod !== "app.bsky.notification.putPreferences"
+  ) {
+    return new Response(
+      JSON.stringify({
+        error: "XRPCNotSupported",
+        message:
+          "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
+      }),
+      {
+        status: 404,
+        headers: withCors({ "Content-Type": "application/json" }),
+      }
+    );
+    //return await sendItToApiBskyApp(req);
+  }
+
+  const authDID = "did:plc:mn45tewwnse5btfftvd3powc"; //getAuthenticatedDid(req);
+
+  switch (xrpcMethod) {
+    case "app.bsky.feed.getFeedGenerators": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyFeedGetFeedGenerators.QueryParams;
+
+      const feeds: ATPAPI.AppBskyFeedDefs.GeneratorView[] = (
+        await Promise.all(
+          jsonTyped.feeds.map(async (feed) => {
+            try {
+              const did = new ATPAPI.AtUri(feed).hostname;
+              const rkey = new ATPAPI.AtUri(feed).rkey;
+              const identity = await resolveIdentity(did);
+              const feedgetRecord = await getSlingshotRecord(
+                identity.did,
+                "app.bsky.feed.generator",
+                rkey
+              );
+              const profile = (
+                await getSlingshotRecord(
+                  identity.did,
+                  "app.bsky.actor.profile",
+                  "self"
+                )
+              ).value as ATPAPI.AppBskyActorProfile.Record;
+              const anyprofile = profile as any;
+              const value =
+                feedgetRecord.value as ATPAPI.AppBskyFeedGenerator.Record;
+
+              return {
+                $type: "app.bsky.feed.defs#generatorView",
+                uri: feed,
+                cid: feedgetRecord.cid,
+                did: identity.did,
+                creator: /*AppBskyActorDefs.ProfileView*/ {
+                  $type: "app.bsky.actor.defs#profileView",
+                  did: identity.did,
+                  handle: identity.handle,
+                  displayName: profile.displayName,
+                  description: profile.description,
+                  avatar: buildBlobUrl(
+                    identity.pds,
+                    identity.did,
+                    anyprofile.avatar.ref["$link"]
+                  ),
+                  //associated?: ProfileAssociated
+                  //indexedAt?: string
+                  //createdAt?: string
+                  //viewer?: ViewerState
+                  //labels?: ComAtprotoLabelDefs.Label[]
+                  //verification?: VerificationState
+                  //status?: StatusView
+                },
+                displayName: value.displayName,
+                description: value.description,
+                //descriptionFacets?: AppBskyRichtextFacet.Main[]
+                avatar: buildBlobUrl(
+                  identity.pds,
+                  identity.did,
+                  (value as any).avatar.ref["$link"]
+                ),
+                //likeCount?: number
+                //acceptsInteractions?: boolean
+                //labels?: ComAtprotoLabelDefs.Label[]
+                //viewer?: GeneratorViewerState
+                contentMode: value.contentMode,
+                indexedAt: new Date().toISOString(),
+              };
+            } catch (err) {
+              return undefined;
+            }
+          })
+        )
+      ).filter(isGeneratorView);
+
+      const response: ViewServerTypes.AppBskyFeedGetFeedGenerators.OutputSchema =
+        {
+          feeds: feeds ? feeds : [],
+        };
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.feed.getFeed": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyFeedGetFeed.QueryParams;
+      const cursor = jsonTyped.cursor;
+      const feed = jsonTyped.feed;
+      const limit = jsonTyped.limit;
+      const proxyauth = req.headers.get("authorization") || "";
+
+      const did = new ATPAPI.AtUri(feed).hostname;
+      const rkey = new ATPAPI.AtUri(feed).rkey;
+      const identity = await resolveIdentity(did);
+      const feedgetRecord = (
+        await getSlingshotRecord(identity.did, "app.bsky.feed.generator", rkey)
+      ).value as ATPAPI.AppBskyFeedGenerator.Record;
+
+      const skeleton = (await cachedFetch(
+        `${didWebToHttps(
+          feedgetRecord.did
+        )}/xrpc/app.bsky.feed.getFeedSkeleton?feed=${jsonTyped.feed}${
+          cursor ? `&cursor=${cursor}` : ""
+        }${limit ? `&limit=${limit}` : ""}`,
+        proxyauth
+      )) as ATPAPI.AppBskyFeedGetFeedSkeleton.OutputSchema;
+
+      const nextcursor = skeleton.cursor;
+      const dbgrqstid = skeleton.reqId;
+      const uriarray = skeleton.feed;
+
+      // Step 1: Chunk into 25 max
+      const chunks = [];
+      for (let i = 0; i < uriarray.length; i += 25) {
+        chunks.push(uriarray.slice(i, i + 25));
+      }
+
+      // Step 2: Hydrate via getPosts
+      const hydratedPosts: ATPAPI.AppBskyFeedDefs.FeedViewPost[] = [];
+
+      for (const chunk of chunks) {
+        const searchParams = new URLSearchParams();
+        for (const uri of chunk.map((item) => item.post)) {
+          searchParams.append("uris", uri);
+        }
+
+        const postResp = await ky
+          .get(`https://api.bsky.app/xrpc/app.bsky.feed.getPosts`, {
+            // headers: {
+            //   Authorization: proxyauth,
+            // },
+            searchParams,
+          })
+          .json<ATPAPI.AppBskyFeedGetPosts.OutputSchema>();
+
+        for (const post of postResp.posts) {
+          const matchingSkeleton = uriarray.find(
+            (item) => item.post === post.uri
+          );
+          if (matchingSkeleton) {
+            //post.author.handle = post.author.handle + ".percent40.api.bsky.app"; // or any logic to modify it
+            hydratedPosts.push({
+              post,
+              reason: matchingSkeleton.reason,
+              //reply: matchingSkeleton,
+            });
+          }
+        }
+      }
+
+      // Step 3: Compose final response
+      const response: ViewServerTypes.AppBskyFeedGetFeed.OutputSchema = {
+        feed: hydratedPosts,
+        cursor: nextcursor,
+      };
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.actor.getProfile": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyActorGetProfile.QueryParams;
+
+      const userindexservice = "";
+      const isbskyfallback = true;
+      if (isbskyfallback) {
+        return sendItToApiBskyApp(req);
+      }
+
+      const response: ViewServerTypes.AppBskyActorGetProfile.OutputSchema = {};
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+
+    case "app.bsky.actor.getProfiles": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyActorGetProfiles.QueryParams;
+
+      const userindexservice = "";
+      const isbskyfallback = true;
+      if (isbskyfallback) {
+        return sendItToApiBskyApp(req);
+      }
+
+      const response: ViewServerTypes.AppBskyActorGetProfiles.OutputSchema = {};
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.feed.getAuthorFeed": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyFeedGetAuthorFeed.QueryParams;
+
+      const userindexservice = "";
+      const isbskyfallback = true;
+      if (isbskyfallback) {
+        return sendItToApiBskyApp(req);
+      }
+
+      const response: ViewServerTypes.AppBskyFeedGetAuthorFeed.OutputSchema =
+        {};
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.feed.getPostThread": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyFeedGetPostThread.QueryParams;
+
+      const userindexservice = "";
+      const isbskyfallback = true;
+      if (isbskyfallback) {
+        return sendItToApiBskyApp(req);
+      }
+
+      const response: ViewServerTypes.AppBskyFeedGetPostThread.OutputSchema =
+        {};
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.unspecced.getPostThreadV2": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyUnspeccedGetPostThreadV2.QueryParams;
+
+      const userindexservice = "";
+      const isbskyfallback = true;
+      if (isbskyfallback) {
+        return sendItToApiBskyApp(req);
+      }
+
+      const response: ViewServerTypes.AppBskyUnspeccedGetPostThreadV2.OutputSchema =
+        {};
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+
+    // case "app.bsky.actor.getProfile": {
+    //   const jsonTyped =
+    //     jsonUntyped as ViewServerTypes.AppBskyActorGetProfile.QueryParams;
+
+    //   const response: ViewServerTypes.AppBskyActorGetProfile.OutputSchema= {};
+
+    //   return new Response(JSON.stringify(response), {
+    //     headers: withCors({ "Content-Type": "application/json" }),
+    //   });
+    // }
+    // case "app.bsky.actor.getProfiles": {
+    //   const jsonTyped = jsonUntyped as ViewServerTypes.AppBskyActorGetProfiles.QueryParams;
+
+    //   const response: ViewServerTypes.AppBskyActorGetProfiles.OutputSchema = {};
+
+    //   return new Response(JSON.stringify(response), {
+    //     headers: withCors({ "Content-Type": "application/json" }),
+    //   });
+    // }
+    // case "whatever": {
+    //   const jsonTyped = jsonUntyped as ViewServerTypes.AppBskyFeedGetAuthorFeed.QueryParams;
+
+    //   const response: ViewServerTypes.AppBskyFeedGetAuthorFeed.OutputSchema = {}
+
+    //   return new Response(JSON.stringify(response), {
+    //     headers: withCors({ "Content-Type": "application/json" }),
+    //   });
+    // }
+    // case "app.bsky.notification.listNotifications": {
+    //   const jsonTyped =
+    //     jsonUntyped as ViewServerTypes.AppBskyNotificationListNotifications.QueryParams;
+
+    //   const response: ViewServerTypes.AppBskyNotificationListNotifications.OutputSchema = {};
+
+    //   return new Response(JSON.stringify(response), {
+    //     headers: withCors({ "Content-Type": "application/json" }),
+    //   });
+    // }
+
+    case "app.bsky.unspecced.getConfig": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyUnspeccedGetConfig.QueryParams;
+
+      const response: ViewServerTypes.AppBskyUnspeccedGetConfig.OutputSchema = {
+        checkEmailConfirmed: true,
+        liveNow: [
+          {
+            $type: "app.bsky.unspecced.getConfig#liveNowConfig",
+            did: "did:plc:mn45tewwnse5btfftvd3powc",
+            domains: ["local3768forumtest.whey.party"],
+          },
+        ],
+      };
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    case "app.bsky.graph.getLists": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyGraphGetLists.QueryParams;
+
+      const response: ViewServerTypes.AppBskyGraphGetLists.OutputSchema = {
+        lists: [],
+      };
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    //https://shimeji.us-east.host.bsky.network/xrpc/app.bsky.unspecced.getTrendingTopics?limit=14
+    case "app.bsky.unspecced.getTrendingTopics": {
+      const jsonTyped =
+        jsonUntyped as ViewServerTypes.AppBskyUnspeccedGetTrendingTopics.QueryParams;
+
+      const faketopics: ATPAPI.AppBskyUnspeccedDefs.TrendingTopic[] = [
+        {
+          $type: "app.bsky.unspecced.defs#trendingTopic",
+          topic: "Git Repo",
+          displayName: "Git Repo",
+          description: "Git Repo",
+          link: "https://tangled.sh/@whey.party/skylite",
+        },
+        {
+          $type: "app.bsky.unspecced.defs#trendingTopic",
+          topic: "Red Dwarf Lite",
+          displayName: "Red Dwarf Lite",
+          description: "Red Dwarf Lite",
+          link: "https://reddwarf.whey.party/",
+        },
+        {
+          $type: "app.bsky.unspecced.defs#trendingTopic",
+          topic: "whey dot party",
+          displayName: "whey dot party",
+          description: "whey dot party",
+          link: "https://whey.party/",
+        },
+      ];
+
+      const response: ViewServerTypes.AppBskyUnspeccedGetTrendingTopics.OutputSchema =
+        {
+          topics: faketopics,
+          suggested: faketopics,
+        };
+
+      return new Response(JSON.stringify(response), {
+        headers: withCors({ "Content-Type": "application/json" }),
+      });
+    }
+    default: {
+      return new Response(
+        JSON.stringify({
+          error: "XRPCNotSupported",
+          message:
+            "HEY hello there my name is whey dot party and you have used my custom appview that is very cool but have you considered that XRPC Not Supported",
+        }),
+        {
+          status: 404,
+          headers: withCors({ "Content-Type": "application/json" }),
+        }
+      );
+    }
+  }
+
+  return new Response("Not Found", { status: 404 });
+}
+
+async function sendItToApiBskyApp(req: Request): Promise<Response> {
+  const url = new URL(req.url);
+  const pathname = url.pathname;
+  const searchParams = searchParamsToJson(url.searchParams);
+  let reqBody: undefined | string;
+  let jsonbody: undefined | Record<string, unknown>;
+  if (req.body) {
+    const body = await req.json();
+    jsonbody = body;
+    // console.log(
+    //   `called at euh reqreqreqreq: ${pathname}\n\n${JSON.stringify(body)}`
+    // );
+    reqBody = JSON.stringify(body, null, 2);
+  }
+  const bskyUrl = `https://api.bsky.app${pathname}${url.search}`;
+  const proxyHeaders = new Headers(req.headers);
+
+  // Remove Authorization and set browser-like User-Agent
+  proxyHeaders.delete("authorization");
+  proxyHeaders.delete("Access-Control-Allow-Origin"),
+    proxyHeaders.set(
+      "user-agent",
+      "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/116.0.0.0 Safari/537.36"
+    );
+  proxyHeaders.set("Access-Control-Allow-Origin", "*");
+
+  const proxyRes = await fetch(bskyUrl, {
+    method: req.method,
+    headers: proxyHeaders,
+    body: ["GET", "HEAD"].includes(req.method.toUpperCase())
+      ? undefined
+      : reqBody,
+  });
+
+  const resBody = await proxyRes.text();
+
+  // console.log(
+  //   "← Response:",
+  //   JSON.stringify(await JSON.parse(resBody), null, 2)
+  // );
+
+  return new Response(resBody, {
+    status: proxyRes.status,
+    headers: proxyRes.headers,
+  });
+}