ws for sinkingYachts

src/BaseClient/ClientHelperModules/cache/urls/sinkingYachts.ts

@@ -1,16 +1,9 @@
-import * as Jobs from 'node-schedule';
 import fetch from 'node-fetch';
 import constants from '../../../Other/constants.js';
-
 /**
  * Interface for the SinkingYachts cache module.
  */
 export interface SinkingYachts {
- /**
-  * The refresh job for the cache.
-  */
- refreshJob: Jobs.Job | null;
-
  /**
   * Starts the cache module.
   */
@@ -29,7 +22,6 @@ export interface SinkingYachts {
 }
 
 const self: SinkingYachts = {
- refreshJob: null,
  start: async () => {
   const res = await fetch('https://phish.sinking.yachts/v2/all', {
    headers: {
@@ -39,13 +31,18 @@ const self: SinkingYachts = {
 
   if (!res.ok) throw new Error('Failed to fetch Sinking Yachts API');
 
-  self.refreshJob = Jobs.scheduleJob(new Date(Date.now() + 3600000), () => {
-   self.start();
-  });
-
   self.cache = new Set();
   const data = (await res.json()) as string[];
   data.forEach((d) => self.cache.add(d));
+
+  const ws = new WebSocket('wss://phish.sinking.yachts/feed');
+  ws.onmessage = (message) => {
+   const msg = JSON.parse(message.data) as { type: 'add' | 'remove'; domains: string[] };
+   console.log(msg);
+
+   if (msg.type === 'add') msg.domains.forEach((d) => self.cache.add(d));
+   else msg.domains.forEach((d) => self.cache.delete(d));
+  };
  },
  toArray: () => [...self.cache],
  cache: new Set(),

src/index.ts

@@ -22,7 +22,7 @@ const manager = new Discord.ShardingManager(
  {
   token: auth.token,
   shardArgs: process.argv,
-  execArgv: ['--experimental-wasm-modules'],
+  execArgv: ['--experimental-wasm-modules', '--experimental-websocket'],
  },
 );