additional typing

api/index.ts

@@ -28,7 +28,7 @@ async function start() {
         events,
     } = createServices(log);
 
-    // events.emit(Events.StartupSync);
+    events.emit(Events.StartupSync);
     // events.emit(Events.ListingsUpdated);
 
     api.listen();

api/src/api.ts

@@ -13,9 +13,11 @@ import Bluebird from 'bluebird';
 import type Log from 'bunyan';
 import type { Listing, User, Want, Prisma } from '@prisma/client';
 
-import { Pg } from './pg';
+import type { Pg } from './pg';
-import { Discogs } from './discogs';
+import type { Discogs } from './discogs';
-import { Offers } from './offers';
+import type { Offers } from './offers';
+import type { Rpc } from './rpc';
+
 import routerAuth from './routers/router.auth';
 import { Events } from './events';
 import createRpc, { RpcMessageType } from './rpc';
@@ -120,7 +122,7 @@ export default function createApi(log: Log, pg: Pg, discogs: Discogs, offers: Of
             // log.child...
 
             const ws = ctx.websocket;
-            const rpc = createRpc(log, pg, ws, discogs, offers, ctx.state.user);
+            const rpc = createRpc(log, pg, ws, discogs, offers, ctx.state.user as User | null);
 
             if (ctx.state.user) events.emit(Events.Connection, { ws, id: ctx.state.user.id });
             ws.on('message', async function incoming(message) {

api/src/offers.ts

@@ -51,7 +51,7 @@ export default function createOffers(log: Log, pg: Pg) {
         // TODO probably need to take one of each condition of record from a store
         // eg. they have a VG+ and a M we should make offers for each
 
-        log.info(sorted);
+        // log.info(sorted);
 
         const inserts = await pg.offersUpdate(sorted);
 

api/src/pg.ts

@@ -169,6 +169,8 @@ export default function createPg(log: Log, prisma: PrismaClient) {
                 }
             });
 
+            log.info({ count }, 'second stage open offers removed');
+
             return count;
         });
     }

api/src/rpc.ts

@@ -141,6 +141,8 @@ export default function createRpc(log: Log, pg: Pg, ws, discogs: Discogs, offers
     }
 }
 
+export type Rpc = ReturnType<typeof createRpc>;
+
 export enum RpcMessageType {
     Ping = 'Ping',
     Pong = 'Pong',