Sync: pass through websocket opts (bluesky-social#2992)

* pass through websocket options in firehose

* changeset

* import type

.changeset/wicked-clouds-glow.md

@@ -0,0 +1,5 @@
+---
+"@atproto/sync": patch
+---
+
+Pass through options to websocket

packages/sync/package.json

@@ -29,7 +29,8 @@
     "@atproto/syntax": "workspace:^",
     "@atproto/xrpc-server": "workspace:^",
     "multiformats": "^9.9.0",
-    "p-queue": "^6.6.2"
+    "p-queue": "^6.6.2",
+    "ws": "^8.12.0"
   },
   "devDependencies": {
     "jest": "^28.1.2",

packages/sync/src/firehose/index.ts

@@ -14,6 +14,7 @@ import {
 } from '@atproto/repo'
 import { AtUri } from '@atproto/syntax'
 import { Subscription } from '@atproto/xrpc-server'
+import type { ClientOptions } from 'ws'
 import {
   type Account,
   type Commit,
@@ -37,7 +38,7 @@ import { CID } from 'multiformats/cid'
 import { EventRunner } from '../runner'
 import { didAndSeqForEvt } from '../util'
 
-export type FirehoseOptions = {
+export type FirehoseOptions = ClientOptions & {
   idResolver: IdResolver
 
   handleEvent: (evt: Event) => Awaited<void>
@@ -70,6 +71,7 @@ export class Firehose {
       throw new Error('Must set only `getCursor` or `runner`')
     }
     this.sub = new Subscription({
+      ...opts,
       service: opts.service ?? 'wss://bsky.network',
       method: 'com.atproto.sync.subscribeRepos',
       signal: this.abortController.signal,