navbar and notifications

api/prisma/schema.prisma

@@ -11,6 +11,11 @@ datasource db {
 }
 
 model Listing {
+
+    // example listingId 2148851036
+    // works fine as a JS number
+    // but JS numbers are cast to int4 for pg by prisma
+    // becomes -2146116260
     id         BigInt      @id
     seller     BigInt
     data       Json

api/src/api.ts

@@ -63,16 +63,6 @@ export default function createApi(log: Log, pg: Pg, discogs: Discogs, offers: Of
         ctx.status = 200;
     });
 
-    router.post('/want', async function wantPost(ctx, next) {
-        ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
-        const { releaseId } = ctx.request.body;
-        const user = await pg.userFindId(ctx.state.user.id);
-        const release = await discogs.release(releaseId);
-        const want = await pg.wantCreate(release, user);
-        events.emit(Events.WantsAdded, [want]);
-        ctx.response.body = [want];
-    });
-
     router.post('/want/discogs', async function wantListPost(ctx, next) {
         ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
         const { username } = ctx.request.body;

api/src/events.ts

@@ -12,11 +12,11 @@ import routerAuth from './routers/router.auth';
 export enum Events {
     WantsAdded = 'WantsAdded',
     Sync = 'Sync',
-    ListingsUpdated = 'ListingsUpdated',
     Connection = 'Connection',
 
-    OfferUpdated = 'OfferUpdated',
-    WantUpdated = 'WantUpdated',
+    ListingsUpdated = 'ListingsUpdated',
+    OffersUpdated = 'OffersUpdated',
+    WantsUpdated = 'WantsUpdated',
 }
 
 export default function createEvents(log: Log, pg: Pg, discogs, offers) {
@@ -68,6 +68,10 @@ export default function createEvents(log: Log, pg: Pg, discogs, offers) {
     events.on(Events.ListingsUpdated, async function listingsUpdated() {
         const updatedOffers = await offers.generate()
         log.debug({ offers: updatedOffers.length }, 'offers up to date');
+
+        for (const [id, rpc] of connections) {
+            rpc.pushUserOffers();
+        }
     });
 
     events.on(Events.Connection, async function onConnection({ rpc, id }) {
@@ -75,17 +79,17 @@ export default function createEvents(log: Log, pg: Pg, discogs, offers) {
         connections.set(id, rpc);
     })
 
-    events.on(Events.OfferUpdated, async function onOfferUpdated(offer: Offer) {
+    events.on(Events.OffersUpdated, async function onOffersUpdated(offer: Offer) {
         const rpc = connections.get(offer.userId);
         if (!rpc) return null;
-        log.debug({ event: Events.OfferUpdated, rpc, offer });
+        log.debug({ event: Events.OffersUpdated, rpc, offer });
         return rpc.pushUserOffers();
     });
 
-    events.on(Events.WantUpdated, async function onWantUpdated(want: Want) {
+    events.on(Events.WantsUpdated, async function onWantsUpdated(want: Want) {
         const rpc = connections.get(want.userId);
         if (!rpc) return null;
-        log.debug({ event: Events.WantUpdated, rpc, want });
+        log.debug({ event: Events.WantsUpdated, rpc, want });
         return rpc.pushUserWants();
     });
 

api/src/notify.ts

@@ -21,8 +21,8 @@ export default function createNotify(log: Log, pg: Pg, events) {
         log.debug({ channel: OFFERS_CHANNEL, action, id });
         if (action === 'DELETE') return null;
 
-        const offer = await pg.offerFindId(id);
-        // events.emit(Events.OfferUpdated, offer);
+        // const offer = await pg.offerFindId(id);
+        // events.emit(Events.OffersUpdated, offer);
     }
 
     async function handleUsers(payload) {
@@ -37,6 +37,7 @@ export default function createNotify(log: Log, pg: Pg, events) {
 
     async function handleWants(payload) {
         const { action, id } = payload;
+        // const want = await pg.offerFindId(id);
         log.debug({ channel: WANTS_CHANNEL, action, id });
     }
 

api/src/pg.ts

@@ -98,6 +98,12 @@ export default function createPg(log: Log, prisma: PrismaClient) {
         });
     }
 
+    async function wantFindId(id: UUID) {
+        return prisma.want.findFirstOrThrow({
+            where: { id },
+        });
+    }
+
     async function wantList(user: User) {
         return prisma.want.findMany({
             where: { userId: user.id },

api/src/rpc.ts

@@ -37,6 +37,7 @@ export enum RpcMessageType {
     AcpListingsSync = 'AcpListingsSync',
 
     WantRm = 'WantRm',
+    WantAdd = 'WantAdd',
 }
 
 type ErrorMessage = [RpcMessageType.Error, string];
@@ -82,6 +83,10 @@ type WantRmParams = {
     id: UUID,
 };
 
+type WantAddParams = {
+    releaseId: number,
+};
+
 function checkMsgType(msgType: RpcMessageType): msgType is RpcMessageType {
     if (RpcMessageType[msgType]) {
         return true;
@@ -124,6 +129,18 @@ export default function createRpc(log: Log, pg: Pg, ws, discogs: Discogs, offers
         return [RpcMessageType.Wants, wants];
     }
 
+    async function wantAdd(params: WantAddParams): Promise<WantsMessage> {
+        const { releaseId } = params;
+        assert(releaseId, 'no id supplied');
+
+        const release = await discogs.release(releaseId);
+        const want = await pg.wantCreate(release, user);
+        events.emit(Events.WantsAdded, [want]);
+
+        const wants = await pg.userWants(user);
+        return [RpcMessageType.Wants, wants];
+    }
+
     async function acpOfferStatusSet(params: OfferStatusSetParams): Promise<AcpOffersMessage> {
         const { id, status } = params;
         assert(isAdmin(user), 'not authorised');
@@ -171,6 +188,8 @@ export default function createRpc(log: Log, pg: Pg, ws, discogs: Discogs, offers
 
             case RpcMessageType.WantRm:
                 return wantRm(params);
+            case RpcMessageType.WantAdd:
+                return wantAdd(params);
 
             case RpcMessageType.AcpOfferStatusSet:
                 return acpOfferStatusSet(params);