big websocket change

api/src/rpc.ts

@@ -8,6 +8,7 @@ import type { Want, Offer, User } from '@prisma/client';
 
 import { Pg } from './pg';
 import { Status } from './offers';
+import { isAdmin } from './utils';
 
 function checkMsgType(msgType: RpcMessageType): msgType is RpcMessageType {
     if (RpcMessageType[msgType]) {
@@ -28,7 +29,9 @@ export default function createRpc(log: Log, pg: Pg, user: User, ws, discogs, off
         assert(Status[status], 'unknown status');
 
         const offer = await offers.statusSet(user, id, status);
-        return [RpcMessageType.Offers, []]
+        const userOffers = await pg.userOffers(user);
+
+        return [RpcMessageType.Offers, userOffers]
     }
 
     async function wantRm(params: WantRmParams): Promise<WantsMessage> {
@@ -41,6 +44,22 @@ export default function createRpc(log: Log, pg: Pg, user: User, ws, discogs, off
         return [RpcMessageType.Wants, wants];
     }
 
+    async function acpOfferStatusSet(params: OfferStatusSetParams): Promise<AcpOffersMessage> {
+        const { id, status } = params;
+        assert(isAdmin(user), 'not authorised');
+        assert(id, 'no id supplied');
+        assert(Status[status], 'unknown status');
+
+        const offer = await offers.statusSet(user, id, status);
+
+        return [RpcMessageType.AcpOffers, await offers.acpOffers()]
+    }
+
+    async function acpOffers(): Promise<AcpOffersMessage> {
+        assert(isAdmin(user), 'not authorised');
+        return [RpcMessageType.AcpOffers, await offers.acpOffers()];
+    }
+
     async function receive(message: any): Promise<RpcMessage> {
         const [msgType, params] = message;
 
@@ -53,6 +72,10 @@ export default function createRpc(log: Log, pg: Pg, user: User, ws, discogs, off
                 return ping();
             case RpcMessageType.OfferStatusSet:
                 return offerStatusSet(params);
+            case RpcMessageType.AcpOfferStatusSet:
+                return acpOfferStatusSet(params);
+            case RpcMessageType.AcpOffers:
+                return acpOffers();
             case RpcMessageType.WantRm:
                 return wantRm(params);
             default:
@@ -103,6 +126,9 @@ export enum RpcMessageType {
 
     OfferStatusSet = 'OfferStatusSet',
 
+    AcpOfferStatusSet = 'AcpOfferStatusSet',
+    AcpOffers = 'AcpOffers',
+
     WantRm = 'WantRm',
 }
 
@@ -114,6 +140,9 @@ type WantsMessage = [RpcMessageType.Wants, Want[]];
 type OffersMessage = [RpcMessageType.Offers, Offer[]];
 type OfferStatusSetMessage = [RpcMessageType.OfferStatusSet, Offer[]];
 
+type AcpOfferStatusSetMessage = [RpcMessageType.AcpOfferStatusSet, Offer[]];
+type AcpOffersMessage = [RpcMessageType.AcpOffers, Offer[]];
+
 export type RpcMessage =
     PingMessage |
     PongMessage |
@@ -124,6 +153,10 @@ export type RpcMessage =
 
     OffersMessage |
     OfferStatusSetMessage |
+
+    AcpOfferStatusSetMessage |
+    AcpOffersMessage |
+
     ErrorMessage;