[READ ONLY MIRROR] Spark Social AppView Server github.com/sprksocial/server
atproto deno hono lexicon
1
fork

Configure Feed

Select the types of activity you want to include in your feed.

refactor: put ingester back

+10 -10
+1 -1
data-plane/index.ts
··· 23 23 import { PushTokens } from "./routes/push-tokens.ts"; 24 24 import { CrosspostThread } from "./routes/crosspost-threads.ts"; 25 25 26 - export { RepoSubscription } from "./subscription/index.ts"; 26 + export { RepoSubscription } from "./subscription.ts"; 27 27 28 28 export type ServerContext = { 29 29 db: Database;
+6 -6
data-plane/subscription/index.ts data-plane/subscription.ts
··· 1 1 import { IdResolver } from "@atp/identity"; 2 2 import { WriteOpAction } from "@atp/repo"; 3 3 import { Event as FirehoseEvent, Firehose, MemoryRunner } from "@atp/sync"; 4 - import { BackgroundQueue } from "../background.ts"; 5 - import { Database } from "../db/index.ts"; 6 - import { IndexingService } from "../indexing/index.ts"; 7 - import { ServerConfig } from "../../config.ts"; 8 - import { PushService } from "../../utils/push.ts"; 9 - import { PushTokens } from "../routes/push-tokens.ts"; 4 + import { BackgroundQueue } from "./background.ts"; 5 + import { Database } from "./db/index.ts"; 6 + import { IndexingService } from "./indexing/index.ts"; 7 + import { ServerConfig } from "./../config.ts"; 8 + import { PushService } from "./../utils/push.ts"; 9 + import { PushTokens } from "./routes/push-tokens.ts"; 10 10 11 11 export class RepoSubscription { 12 12 firehose: Firehose;
+3 -3
ingest/index.ts ingest.ts
··· 1 - import { RepoSubscription } from "../data-plane/subscription/index.ts"; 1 + import { RepoSubscription } from "./data-plane/subscription.ts"; 2 2 import { IdResolver } from "@atp/identity"; 3 - import { ServerConfig } from "../config.ts"; 4 - import { Database } from "../data-plane/db/index.ts"; 3 + import { ServerConfig } from "./config.ts"; 4 + import { Database } from "./data-plane/db/index.ts"; 5 5 6 6 const cfg = ServerConfig.readEnv(); 7 7