bundle offers grouped

TODO.md

@@ -0,0 +1,14 @@
+# TODO
+
+status stepper
+
+queue up wantlist adds to gracefully handle rate limiting
+
+push offers
+cover off admin routes and commands
+
+listen / notify
+    on offers
+        notify admins
+
+

api/.mocharc.json

@@ -0,0 +1,8 @@
+{
+  "extension": ["ts"],
+  "spec": "src/**/*.test.ts",
+  "require": "ts-node/register",
+
+  "watch-files": "**/*.ts",
+  "watch-ignore": ["db"]
+}

api/global.d.ts

@@ -1,9 +1,11 @@
 // global type aliases and whatnot
 
 type UUID = string;
+type Email = string;
 
 type DiscogsName = string;
 type DiscogsListing = number;
+type DiscogsRelease = number;
 type DiscogsSeller = number;
 
 type BundleCandidate = {

api/index.ts

@@ -0,0 +1,37 @@
+import createServices from './src/services';
+import createLog from './src/log';
+import { Events } from './src/events';
+
+async function start() {
+    const log = createLog();
+
+    // process.on('uncaughtException', (err, origin) => {
+    //     log.error({ err, origin }, 'uncaughtException');
+    //     process.exit(1);
+    // });
+
+    // process.on('unhandledRejection', (reason, promise) => {
+    //     log.error({ reason, promise }, 'unhandledRejection');
+    //     process.exit(1);
+    // });
+
+    process.on('SIGTERM', () => {
+      log.debug('SIGTERM received, exiting');
+      process.exit(0);
+    });
+
+    const {
+        prisma,
+        pg,
+        discogs,
+        api,
+        events,
+    } = createServices(log);
+
+    events.emit(Events.StartupSync);
+    // events.emit(Events.ListingsUpdated);
+
+    api.listen();
+}
+
+start();

api/package.json

@@ -0,0 +1,50 @@
+{
+  "name": "mates-crates",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "mocha",
+    "test:watch": "mocha --watch",
+    "migrate": "knex migrate:latest",
+    "migrate:make": "prisma migrate dev --name",
+    "start": "ts-node-dev --respawn --transpile-only index.ts | bunyan -o short"
+  },
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "@types/bcrypt": "^5.0.0",
+    "@types/bluebird": "^3.5.36",
+    "@types/koa": "^2.13.5",
+    "@types/lodash": "^4.14.182",
+    "@types/mocha": "^9.1.1",
+    "axios": "^0.27.2",
+    "mocha": "^10.0.0",
+    "node-dev": "^7.4.3",
+    "prisma": "^4.5.0",
+    "ts-node-dev": "^2.0.0",
+    "typescript": "^4.7.4"
+  },
+  "dependencies": {
+    "@koa/cors": "^3.3.0",
+    "@koa/router": "^12.0.0",
+    "@prisma/client": "^4.5.0",
+    "bcrypt": "^5.0.1",
+    "bluebird": "^3.7.2",
+    "bunyan": "^1.8.15",
+    "cheerio": "^1.0.0-rc.12",
+    "koa": "^2.13.4",
+    "koa-body": "^5.0.0",
+    "koa-passport": "^5.0.0",
+    "koa-session": "^6.2.0",
+    "koa-websocket": "^7.0.0",
+    "koa-ws": "^1.0.1",
+    "lodash": "^4.17.21",
+    "passport-local": "^1.0.0"
+  },
+  "overrides": {
+    "koa-passport": {
+      "passport": "^0.5"
+    }
+  }
+}

api/prisma/schema.prisma

@@ -0,0 +1,89 @@
+generator client {
+    provider = "prisma-client-js"
+    // include for node docker image
+    binaryTargets = ["native", "debian-openssl-1.1.x"]
+    previewFeatures = ["interactiveTransactions"]
+}
+
+datasource db {
+    provider = "postgresql"
+    url      = env("DATABASE_URL")
+}
+
+model Listing {
+    id         Int      @id
+    seller     Int
+    data       Json
+
+    wantId     String   @db.Uuid
+    want       Want     @relation(fields: [wantId], references: [id], onDelete: Cascade, onUpdate: Cascade)
+
+    offers     Offer[]
+
+    createdAt  DateTime @default(now())
+    updatedAt  DateTime @updatedAt
+
+    @@index([seller])
+    @@map("listings")
+}
+
+model User {
+    id         String     @id       @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+    email      String     @unique
+    password   String
+
+    createdAt  DateTime   @default(now())
+    updatedAt  DateTime   @updatedAt
+
+    wants      Want[]
+    offers     Offer[]
+
+    @@map("users")
+}
+
+model Want {
+    id         String     @id       @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+    release    Int
+    data       Json
+
+    userId     String     @db.Uuid
+    user       User       @relation(fields: [userId], references: [id], onDelete: Cascade, onUpdate: Cascade)
+
+    createdAt  DateTime   @default(now())
+    updatedAt  DateTime   @updatedAt
+
+    listings   Listing[]
+    offers     Offer[]
+
+    @@unique([userId, release])
+    @@index([release])
+
+    @@map("wants")
+}
+
+model Offer {
+    id              String     @id       @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+
+    status          String
+    condition       String               @default("")
+
+    item            Decimal    @db.Money
+    // markup          Decimal    @db.Money
+    shipping        Decimal    @db.Money
+    total           Decimal    @db.Money
+    comparison      Decimal    @db.Money
+
+    listingId       Int
+    listing         Listing    @relation(fields: [listingId], references: [id])
+
+    userId          String     @db.Uuid
+    user            User       @relation(fields: [userId], references: [id], onDelete: Cascade)
+
+    wantId          String     @db.Uuid
+    want            Want       @relation(fields: [wantId], references: [id], onDelete: Cascade)
+
+    // only one offer per want for a user
+    // @@unique([userId, wantId])
+    @@unique([listingId])
+    @@map("offers")
+}

api/src/api.test.ts

@@ -0,0 +1,59 @@
+import assert from 'assert/strict';
+import axios from 'axios';
+
+import createServices from './services';
+import createLog from './log';
+
+const log = createLog();
+log.level('debug');
+const services = createServices(log);
+
+const api = axios.create({
+  baseURL: 'http://localhost:41337',
+  withCredentials: true
+});
+
+let server;
+before(function setup() {
+    server = services.api.listen();
+});
+
+after(function teardown(done) {
+    server.close(done)
+});
+
+describe('api', function apiTests() {
+    describe.skip('auth', function authTests() {
+        it('listens', async function listenTest() {
+            const res = await api.get('/health');
+            assert.equal(res.status, 200);
+        });
+
+        it('register', async function register() {
+            const body = {
+                email: `test+${Date.now()}@user.com`,
+                password: 'woaaah theres no limit',
+            };
+            const { data } = await api.post('/auth/register', body);
+            assert.equal(data.email, body.email);
+        });
+
+        it('login', async function login() {
+            const body = {
+                email: `test+${Date.now()}@user.com`,
+                password: 'woaaah theres no limit',
+            };
+            await api.post('/auth/register', body);
+            const res = await api.post('/auth/login', body);
+            assert(res.headers['set-cookie']);
+        })
+    });
+
+    describe('offers', function offerTests() {
+        it('create offers', async function createOffersTest() {
+            const { data: bundles } = await api.get('/bundles');
+            const listingIds = bundles[0].items.map(i => i.id);
+            const { data } = await api.post('/offers', { listingIds, shipping: 50.0, baseShipping: 15.0 });
+        });
+    });
+});

api/src/api.ts

@@ -0,0 +1,146 @@
+import http from 'http';
+
+import koa from 'koa';
+import koaWebsocket from 'koa-websocket';
+import bodyParser from 'koa-body';
+import session from 'koa-session';
+import koaRouter from '@koa/router'
+import cors from '@koa/cors';
+
+import { groupBy, sortBy } from 'lodash';
+import Bluebird from 'bluebird';
+
+import type Log from 'bunyan';
+import type { Listing, User, Want, Prisma } from '@prisma/client';
+
+import { Pg } from './pg';
+import routerAuth from './routers/router.auth';
+import { Events } from './events';
+import createRpc, { RpcMessageType } from './rpc';
+
+export default function createApi(log: Log, pg: Pg, discogs, offers, events) {
+    const PORT = 41337;
+    const WS_PORT = 40055;
+    const SECRET = 'ohja4Eif9eidah3aj5ta2haa4iemooth';
+
+    const app = koaWebsocket(new koa());
+
+    app.use(async (ctx, next) => {
+        try {
+            await next();
+        } catch (err) {
+            log.error(err);
+            ctx.status = err.statusCode || err.status || 500;
+            ctx.body = {
+                  error: err.message
+            };
+        }
+    });
+
+    const router = koaRouter();
+
+    function listen() {
+        const server = app.listen(PORT);
+        log.info({ PORT }, 'listening');
+    }
+
+    app.use(cors({ credentials: true }));
+    app.use(bodyParser())
+
+    app.keys = [SECRET];
+    app.use(session(app));
+
+    const { authRouter, passport } = routerAuth(log, pg);
+    app.use(passport.initialize());
+    app.use(passport.session())
+    app.use(authRouter.routes());
+
+    router.get('/health', async function health(ctx) {
+        ctx.status = 200;
+    });
+
+    router.get('/user/offers', async function userOffersGet(ctx, next) {
+        ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
+        const user = ctx.state.user;
+        const offers = await pg.userOffers(user);
+        ctx.response.body = offers;
+    });
+
+    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;
+        const user = await pg.userFindId(ctx.state.user.id);
+        const wants = await discogs.wantListSync(username, user);
+        events.emit(Events.WantsAdded, [wants]);
+        ctx.response.body = wants;
+    });
+
+    router.get('/want/all', async function wantGet(ctx, next) {
+        ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
+        const user = ctx.state.user;
+        const wants = await pg.wantList(user);
+
+        ctx.response.body = wants;
+    });
+
+    router.post('/want/search', async function wantPost(ctx, next) {
+        const { artist, title } = ctx.request.body;
+        const results = await discogs.search(artist, title);
+        ctx.response.body = results;
+    });
+
+    router.post('/auth/logout', async (ctx, next) => {
+        ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
+        ctx.logout();
+        ctx.status = 200;
+        ctx.body = { success: true };
+    });
+
+    app.use(router.routes());
+
+    app.ws.use(passport.initialize());
+    app.ws.use(passport.session());
+    app.ws.use(async (ctx, next) => {
+        log.info('new ws connection', { user: ctx.state.user });
+
+        // log.child...
+
+        const ws = ctx.websocket;
+        const rpc = createRpc(log, pg, ctx.state.user, ws, discogs, offers);
+
+        if (ctx.state.user) events.emit(Events.Connection, { ws, id: ctx.state.user.id });
+        ws.on('message', async function incoming(message) {
+            try {
+                const parsed = JSON.parse(message.toString());
+                const response = await rpc.receive(parsed);
+                rpc.send(response);
+            } catch (e) {
+                log.warn(e);
+                log.warn(message.toString());
+                rpc.send([RpcMessageType.Error, e.message || e.msg]);
+            }
+            return true;
+        });
+
+        ws.on('close', function onClose() {
+            log.info('ws disconnected', { user: ctx.state.user });
+        });
+
+        await rpc.onConnection();
+    });
+
+    return {
+        app,
+        listen,
+    };
+}

api/src/discogs.ts

@@ -7,11 +7,15 @@ import Bluebird from 'bluebird';
 import type Log from 'bunyan';
 import type { PrismaClient, Want, User, Listing } from '@prisma/client';
 
-import { logAxiosError } from './utils';
+import { logAxiosError, wantDetails } from './utils';
 import { Pg } from './pg';
 
-export default function discogs(log: Log, pg: Pg) {
+// margh
-    const TOKEN = 'wRTXuYZGOPsIQgKRGKCAkUkidGtvpSfQgPWkYIpD';
+// vanderbabe
+// jmcdermid1
+
+export default function createDiscogs(log: Log, pg: Pg) {
+    const TOKEN = 'Discogs token=wRTXuYZGOPsIQgKRGKCAkUkidGtvpSfQgPWkYIpD';
     const apiBase = 'https://api.discogs.com'
     const discogsBase = 'https://www.discogs.com'
 
@@ -31,24 +35,37 @@ export default function discogs(log: Log, pg: Pg) {
         return null;
     }
 
-    async function user(discogs: string) {
+    async function wantListSync(username: string, user: User): Promise<Want[]> {
-        const user = await pg.userFindName(discogs);
-        if (user) return user;
-        log.debug('fetching user', discogs);
-        const res = await api.get(`${apiBase}/users/${discogs}`);
-        return pg.userUpsert(res.data);
-    }
-
-    async function wantlist(user: User): Promise<Want[]> {
-        const stored = await pg.userWants(user);
-        if (stored.length) return stored;
-        return wantlistLatest(user);
-    }
-
-    async function wantlistLatest(user: User): Promise<Want[]> {
-        const { username } = user.data as { username: string };
         const { data: { wants, pagination }} = await api.get(`${apiBase}/users/${username}/wants`);
-        return Bluebird.mapSeries(wants, async r => pg.wantUpsert(r, user));
+        const releases = await Promise.all(wants.map(want => release(want.id)));
+
+        log.info({ wants: wants.length, user: username, userId: user.id }, 'fetched discogs wantlist');
+
+        // TODO filter releases to be vinyl format only
+
+        // convert want object to actual release and ignore duplicate errors
+        const results = await Promise.allSettled(releases.map(release => pg.wantCreate(release, user)));
+        // @ts-ignore
+        const additions = results.filter(r => r.status === 'fulfilled').map(r => r.value);
+
+        log.info(additions);
+
+        return additions;
+    }
+
+    async function release(id: DiscogsRelease): Promise<any> {
+        const { data } = await api.get(`${apiBase}/releases/${id}`);
+        return data;
+    }
+
+    async function search(artist: string, title: string) {
+        const url = new URL(`${apiBase}/database/search`);
+        url.searchParams.append('artist', artist);
+        url.searchParams.append('title', title);
+        url.searchParams.append('type', 'release');
+        url.searchParams.append('format', 'vinyl');
+        const { data: { results } } = await api.get(url.href);
+        return results;
     }
 
     async function inventory(user: string) {
@@ -67,7 +84,9 @@ export default function discogs(log: Log, pg: Pg) {
             .get();
 
         const unlisted = await pg.listingRmUnlisted(want, ids);
-        if (unlisted) log.info({ wantId: want.id, unlisted: unlisted }, 'missing listings removed');
+        if (unlisted) log.info({ unlisted: unlisted, ...wantDetails(want) }, 'missing listings removed');
+
+        // preferentially take listings from sellers if we hit req limits
         return Bluebird.mapSeries(ids, async id => listing(id, want));
     }
 
@@ -78,6 +97,7 @@ export default function discogs(log: Log, pg: Pg) {
         try {
             log.debug('fetching listing', id);
             const res = await api.get(`${apiBase}/marketplace/listings/${id}`);
+            log.debug(res.data);
             return pg.listingUpsert(res.data, want);
         } catch (e) {
             return handleApiError(e);
@@ -85,11 +105,11 @@ export default function discogs(log: Log, pg: Pg) {
     }
 
     return {
-        user,
+        wantListSync,
-        wantlist,
-        wantlistLatest,
         inventory,
         listings,
         listing,
+        release,
+        search,
     };
 }

api/src/events.ts

@@ -0,0 +1,82 @@
+import { EventEmitter } from 'node:events';
+import { setTimeout } from 'timers/promises';
+
+import type Log from 'bunyan';
+import type { Want } from '@prisma/client';
+
+import { Pg } from './pg';
+import { wantDetails } from './utils';
+import routerAuth from './routers/router.auth';
+
+export enum Events {
+    WantsAdded = 'WantsAdded',
+    StartupSync = 'StartupSync',
+    ListingsUpdated = 'ListingsUpdated',
+    Connection = 'Connection',
+}
+
+export default function createEvents(log: Log, pg: Pg, discogs, offers) {
+    const events = new EventEmitter({ captureRejections: true });
+    const connections = new Map();
+
+    async function populateListings(want: Want) {
+        try {
+            const listings = await discogs.listings(want);
+            return listings;
+        } catch (e) {
+            if (e.message === 'rate limited') {
+                log.warn('rate limited, trying again in 60s');
+                await setTimeout(60 * 1000);
+                return populateListings(want);
+            }
+            throw e;
+        }
+    }
+
+    events.on('error', function eventError(e) {
+        log.error('event error', e);
+    });
+
+    async function updateWantListings(wants: Want[]) {
+        for (const want of wants) {
+            const listings = await populateListings(want);
+            log.info({ listings: listings.length, ...wantDetails(want) }, 'listings added');
+            events.emit(Events.ListingsUpdated);
+        }
+
+        log.info({ wants: wants.length }, 'finished syncing');
+    }
+
+    events.on(Events.WantsAdded, async function wantsAdded(wants: Want[]) {
+        log.info({ event: Events.WantsAdded, wants: wants.map(w => wantDetails(w)) }, 'starting listings population');
+        await updateWantListings(wants);
+        log.info({ event: Events.WantsAdded, wants: wants.map(w => wantDetails(w)) }, 'finished populating listings');
+    });
+
+    events.on(Events.StartupSync, async function startupSync() {
+        const wants = await pg.wantsToSync();
+        log.info({ event: Events.StartupSync, wants: wants.length });
+        await updateWantListings(wants);
+        events.emit(Events.ListingsUpdated);
+    });
+
+    events.on(Events.ListingsUpdated, async function listingsUpdated() {
+        const bundles = await offers.bundles();
+        log.info({ event: Events.ListingsUpdated, bundles: bundles.length });
+
+        for (const bundle of bundles) {
+            log.info({ seller: bundle.seller, items: bundle.items.length }, 'generating offers...');
+            const listingIds = bundle.items.map(i => i.id);
+            const updatedOffers = await offers.generate(listingIds, 100, 30)
+            log.info({ offers: updatedOffers.length }, 'offers set');
+        }
+
+        log.info('offers up to date');
+    });
+
+    events.on(Events.Connection, async function onConnection({ ws, id }) {
+        connections.set(id, ws);
+    })
+
+    return events;
+}

api/src/offers.ts

@@ -0,0 +1,163 @@
+import type Log from 'bunyan';
+import type { PrismaClient, Want, User, Listing, Offer, } from '@prisma/client';
+import assert from 'assert/strict';
+import groupBy from 'lodash/groupBy';
+import sortBy from 'lodash/sortBy';
+import { Context } from 'koa';
+
+import { logAxiosError, wantDetails } from './utils';
+import { Pg } from './pg';
+
+export enum Status {
+    Complete     = 'Complete',
+    Confirmed    = 'Confirmed',
+    Accepted     = 'Accepted',
+    Pending      = 'Pending',
+    Declined     = 'Declined',
+}
+
+function sortOffers(o) {
+    return Object.values(Status).indexOf(o.status);
+}
+
+export default function createOffers(log: Log, pg: Pg) {
+    async function generate(listingIds: DiscogsListing[], bulkShipping: number, baseShipping: number) {
+        log.info('generateOffers', { listingIds, bulkShipping, baseShipping });
+        const listings = await pg.listingByIds(listingIds);
+
+        // log.info({ listings }, 'creating offers for listings')
+
+        const shipping = 7.5; // yolt
+
+        // const shipping = bulkShipping / listings.length;
+        // how to deal with users who don't want all items in a bundle...
+
+        const offers = listings.map(l => ({
+            userId: l.want.user.id,
+            listingId: l.id,
+            wantId: l.want.id,
+
+            // sellerId: l.seller,
+
+            status: Status.Pending,
+
+            condition: l.data.condition,
+
+            item: l.data.price.value,
+            shipping,
+            total: l.data.price.value + shipping,
+
+            // without mcrates...
+            comparison: l.data.price.value + baseShipping,
+        }))
+
+        // we must sort the offers by price,
+        // sometimes a seller has multiples of a want
+        // to deal with this we just ignore duplicates on insert
+        // and ensure the cheapest one goes in first
+        const sorted = sortBy(offers, ['item']);
+        const inserts = await pg.offersCreate(sorted);
+
+        return inserts;
+    }
+
+    async function accept(ctx: Context) {
+        const { id } = ctx.request.body;
+        ctx.assert(id, 401, 'no id supplied');
+
+        // check the user actually has this offer
+        const offer = await pg.userOfferFind(ctx.state.user, id);
+        return pg.offerStatusSet(offer.id, Status.Accepted);
+    }
+
+    async function statusSet(user: User, id: UUID, status: Status) {
+        log.info({ status, id }, 'setting offer status');
+
+        const offer = await pg.offerFindId(id);
+        const update = await pg.offerStatusSet(offer.id, status);
+
+        if (status === Status.Complete) {
+            log.info({ id, status }, 'completed offer, removing want...');
+            await pg.wantRm(offer.wantId);
+        }
+
+        return update;
+    }
+
+    async function bundles() {
+        const bundles = await pg.bundleCandidates();
+
+        interface ListingData extends Listing {
+            data: any,
+            want: { user: User },
+        };
+
+        return bundles.map((b: ListingData[]) => {
+            const total = b.reduce((acc, l) => acc + l.data.price.value, 0);
+            const items = b.map(l => ({
+                id: l.data.id,
+                description: l.data.release.description,
+                originalPrice: l.data.original_price.value,
+                originalCurrency: l.data.original_price.curr_abbr,
+                price: l.data.price.value,
+                currency: l.data.price.currency,
+                condition: l.data.condition,
+                uri: l.data.uri,
+                user: l.want.user,
+            }));
+
+            const shipping = b[0]?.data.seller.shipping;
+
+            const bundle = {
+                username: b[0]?.data.seller.username,
+                seller: b[0]?.data.seller.id,
+                shipsFrom: b[0]?.data.ships_from,
+                total,
+                currency: b[0]?.data.price.currency,
+                shipping: '...',
+                items,
+                mentionsAustralia: shipping.toLowerCase().includes('australia'),
+                mentionsWorldwide: shipping.toLowerCase().includes('world'),
+            }
+
+            return bundle;
+        });
+    }
+
+    async function acpOffers() {
+        const offers = await pg.offersAdmin();
+
+        const grouped = groupBy(offers, o => o.listing.data.seller.id);
+
+        const sellerOffers = sortBy(Object.values(grouped).map(offers => {
+            const shipping = offers[0]?.listing.data.seller.shipping;
+            const bundle = {
+                username: offers[0]?.listing.data.seller.username,
+                seller: offers[0]?.listing.data.seller.id,
+                shipsFrom: offers[0]?.listing.data.ships_from,
+                shipping,
+                offers: sortBy(offers, sortOffers),
+                mentionsAustralia: shipping.toLowerCase().includes('australia'),
+                mentionsWorldwide: shipping.toLowerCase().includes('world'),
+            }
+
+            return bundle;
+        }), bundle => -bundle.offers.length);
+
+        return sellerOffers;
+    }
+
+    async function userOffers(user: User) {
+        const offers = await pg.userOffers(user);
+        return groupBy(offers, (o) => o.wantId);
+    }
+
+    return {
+        generate,
+        accept,
+        bundles,
+        statusSet,
+        acpOffers,
+        userOffers,
+    };
+}

api/src/pg.ts

@@ -0,0 +1,326 @@
+import bcrypt from 'bcrypt';
+import type Log from 'bunyan';
+import type { PrismaClient, Want, User, Listing, Offer, Prisma } from '@prisma/client';
+import * as Bluebird from 'bluebird';
+import _ from 'lodash';
+
+import { Status } from './offers';
+
+export interface UserCreateParams {
+    email: string,
+    password: string,
+}
+
+export interface Pg {
+    userFindId:         (id: UUID) => Promise<User>,
+    userFindEmail:      (email: Email) => Promise<User>,
+    userCreate:         (params: UserCreateParams) => Promise<User>,
+    userWants:          (user: User) => Promise<Want[]>,
+    userOffers:         (user: User) => Promise<Offer[]>,
+    userOfferFind:      (user: User, id: UUID) => Promise<Offer>,
+
+    listingUpsert:      (listing: Listing, want: Want) => Promise<Listing>,
+    listingFind:        (id: DiscogsListing) => Promise<Listing>,
+    listingByIds:       (ids: DiscogsListing[]) => Promise<Listing[]>,
+    listingRmUnlisted:  (want: Want, ids: DiscogsListing[]) => Promise<number>,
+
+    wantCreate:         (discogsWant: any, user: User) => Promise<Want>,
+    wantList:           (user: User) => Promise<Want[]>,
+    wantsToSync:        () => Promise<Want[]>,
+    wantRm:             (id: UUID) => Promise<void>,
+
+    bundleCandidates:   () => Promise<Listing[][]>,
+
+    offersCreate:       (offers: Offer[]) => Promise<Offer[]>,
+    offerStatusSet:     (id: UUID, status: Status) => Promise<Offer>,
+    offersAdmin:        () => Promise<Offer[]>,
+    offerFindId:        (id: UUID) => Promise<Offer>,
+}
+
+export default function createPg(log: Log, prisma: PrismaClient): Pg {
+    async function userFindId(id: UUID) {
+        return prisma.user.findUnique({ where: { id }});
+    }
+
+    async function userFindEmail(email: Email) {
+        return prisma.user.findUnique({ where: { email }});
+    }
+
+    async function userWants(user: User) {
+        return prisma.want.findMany({ where: { userId: user.id }});
+    }
+
+    async function userOffers(user: User) {
+        return prisma.offer.findMany({
+            where: {
+                userId: user.id,
+                status: { not: Status.Declined }
+            },
+            include: {
+                want: true,
+            },
+            orderBy: {
+                total: 'asc',
+            },
+        });
+    }
+
+    async function offerFindId(id: UUID) {
+        return prisma.offer.findFirstOrThrow({
+            where: { id },
+            include: {
+                want: true,
+            }
+        });
+    }
+
+    async function userOfferFind(user: User, id: UUID) {
+        return prisma.offer.findFirstOrThrow({
+            where: {
+                userId: user.id,
+                id,
+            },
+            include: {
+                want: true,
+            }
+        });
+    }
+
+    async function userCreate(params: UserCreateParams) {
+        const hashRounds = 10;
+        const password = await bcrypt.hash(params.password, hashRounds);
+
+        const data = {
+            email: params.email,
+            password,
+        };
+
+        return prisma.user.create({
+            data,
+        });
+    }
+
+    // userUpdate({ email: 'jen@vdk.com', password: 'jen' });
+    // userUpdate({ email: 'james@mcd', password: 'james' });
+
+    async function userUpdate(params: UserCreateParams) {
+        const hashRounds = 10;
+        const password = await bcrypt.hash(params.password, hashRounds);
+
+        const data = {
+            email: params.email,
+            password,
+        };
+
+        return prisma.user.update({
+            where: { email: params.email },
+            data,
+        });
+    }
+
+    async function wantList(user: User) {
+        return prisma.want.findMany({
+            where: { userId: user.id },
+        });
+    }
+
+    async function wantsToSync() {
+        return prisma.want.findMany({});
+    }
+
+    async function wantRm(id: UUID) {
+        await prisma.want.delete({
+            where: { id },
+        });
+    }
+
+    async function wantCreate(discogsRelease, user) {
+        const data: { userId: UUID, release: DiscogsListing, data: any } = {
+            data: discogsRelease,
+            release: discogsRelease.id,
+            userId: user.id,
+        };
+
+        return prisma.want.create({
+            data,
+        });
+    }
+
+    async function listingRmUnlisted(want: Want, currentListingIds: DiscogsListing[]) {
+        return prisma.$transaction(async (prisma) => {
+            log.debug({ currentListingIds });
+
+            const protectedOfferStatuses = [Status.Confirmed, Status.Complete];
+
+            // can't delete a listing with an open offer
+            // so delete those offers first
+            const { count: offersRemoved } = await prisma.offer.deleteMany({
+                where: {
+                    wantId: want.id,
+                    listingId: {
+                        notIn: currentListingIds,
+                    },
+                    status: {
+                        notIn: protectedOfferStatuses,
+                    },
+                }
+            });
+
+            if (offersRemoved > 0) log.info({ offersRemoved }, 'open offers removed');
+
+            // now we have to filter listingIds with confirmed offers
+            // and get their listingIds to filter out
+            const confirmedListingIds = (await prisma.offer.findMany({
+                where: {
+                    wantId: want.id,
+                    status: {
+                        in: protectedOfferStatuses,
+                    }
+                },
+                select: {
+                    listingId: true,
+                }
+            })).map(r => r.listingId);
+            const removalIds = _.without(currentListingIds, ...confirmedListingIds);
+
+            // finally we delete listings that aren't related
+            // to a historical offer
+            const { count } = await prisma.listing.deleteMany({
+                where: {
+                    wantId: want.id,
+                    id: {
+                        notIn: currentListingIds,
+                    }
+                }
+            });
+
+            return count;
+        });
+    }
+
+    async function listingUpsert(listing, want) {
+        const values = {
+            id: listing.id,
+            wantId: want.id,
+            seller: listing.seller.id,
+            data: listing,
+        };
+
+        return prisma.listing.upsert({
+            where: {
+                id: listing.id
+            },
+            update: values,
+            create: values,
+        });
+    }
+
+    async function listingFind(id: DiscogsListing) {
+        return prisma.listing.findUnique({
+            where: {
+                id,
+            },
+            include: {
+                want: {
+                    include: { user: true },
+                }
+            }
+        });
+    }
+
+    async function listingByIds(ids: DiscogsListing[]) {
+        return prisma.listing.findMany({
+            where: {
+                id: { in: ids },
+            },
+            include: {
+                want: {
+                    include: { user: true },
+                }
+            }
+        });
+    }
+
+    async function bundleCandidates(): Promise<Listing[][]> {
+        const candidates = await prisma.$queryRaw`
+            select
+                seller, count(distinct("wantId")), array_agg(id) as listings
+            from
+                listings
+            where
+                seller not in (3709203)
+            group by
+                seller
+            order by
+                count desc
+            limit 5;
+        ` as BundleCandidate[];
+
+        return Promise.all(candidates.map(async c => prisma.listing.findMany({
+            where: {
+                id: { in: c.listings }
+            },
+            include: {
+                want: {
+                    include: { user: true },
+                }
+            },
+            distinct: ['wantId'],
+        })));
+    }
+
+    async function offersCreate(offers: Offer[]) {
+        return await prisma.$transaction(
+            offers.map(offer => prisma.offer.upsert({
+                where: {
+                    listingId: offer.listingId,
+                },
+                create: offer,
+                update: _.omit(offer, ['status']),
+            }))
+        );
+    }
+
+    async function offerStatusSet(id: UUID, status: Status) {
+        return prisma.offer.update({
+            where: { id: id },
+            data: { status },
+        });
+    }
+
+    async function offersAdmin() {
+        return prisma.offer.findMany({
+            include: {
+                listing: true,
+                user: true,
+                want: true,
+            },
+        });
+    }
+
+    return {
+        userFindId,
+        userFindEmail,
+        userCreate,
+        userWants,
+        userOffers,
+        userOfferFind,
+
+        wantCreate,
+        wantList,
+        wantsToSync,
+        wantRm,
+
+        listingUpsert,
+        listingFind,
+        listingRmUnlisted,
+        listingByIds,
+
+        bundleCandidates,
+
+        offersCreate,
+        offerStatusSet,
+        offersAdmin,
+        offerFindId,
+    };
+}

api/src/routers/router.auth.ts

@@ -0,0 +1,75 @@
+import bcrypt from 'bcrypt';
+import { KoaPassport } from 'koa-passport';
+import { Strategy as LocalStrategy } from 'passport-local';
+import Router from '@koa/router'
+
+import type { Pg } from './../pg';
+
+export default function authRouter(log, pg: Pg) {
+    const passport = new KoaPassport();
+
+    async function verifyPassword(user, password) {
+        const match = await bcrypt.compare(password, user.password);
+        return match;
+    }
+
+    passport.use(new LocalStrategy(
+        { usernameField: 'email' },
+        function localStrategy(email, password, done) {
+            pg.userFindEmail(email)
+                .then(async user => {
+                    if (!user) return done(null, false);
+                    const passwordMatch = await verifyPassword(user, password);
+                    if (!passwordMatch) return done(null, false);
+                    return done(null, user);
+                })
+                .catch(e => done(e, null));
+        }
+    ));
+
+    passport.serializeUser((user, done) => done(null, user.id));
+    passport.deserializeUser((id, done) => {
+        pg.userFindId(id)
+            .then(u => done(null, u))
+            .catch(e => done(e, null));
+    })
+
+    const authRouter = new Router({ prefix: '/auth' });
+
+    authRouter.post('/login', async (ctx, next) => {
+        await passport.authenticate('local', (err, user, info, status) => {
+            ctx.assert(user, 401, 'incorrect login');
+            ctx.login(user);
+            ctx.status = 200;
+            ctx.body = {
+                email: user.email,
+            };
+        })(ctx, next);
+    });
+
+    authRouter.get('/login', async (ctx, next) => {
+        ctx.assert(ctx.isAuthenticated(), 401, 'log in required');
+
+        const user = ctx.state.user;
+        ctx.status = 200;
+        ctx.body = {
+            id: user.id,
+            email: user.email,
+        };
+    });
+
+    authRouter.post('/register', async (ctx, next) => {
+        const { discogs, email, password } = ctx.request.body;
+        // fetch discogs data if they have it
+        const params = { discogs, email, password, data: {} };
+        const user = await pg.userCreate(params)
+        ctx.login(user);
+        ctx.status = 200;
+        ctx.body = {
+            id: user.id,
+            email: user.email,
+        };
+    });
+
+    return { authRouter, passport };
+}

api/src/rpc.ts

@@ -0,0 +1,196 @@
+import { EventEmitter } from 'node:events';
+import { setTimeout } from 'timers/promises';
+import assert from 'assert/strict';
+
+import type Log from 'bunyan';
+
+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]) {
+        return true;
+    }
+    return false;
+}
+
+// rpc is created per connection from the api
+export default function createRpc(log: Log, pg: Pg, user: User, ws, discogs, offers) {
+    async function ping(): Promise<PongMessage> {
+        return [RpcMessageType.Pong, []];
+    }
+
+    async function userOffers(): Promise<OffersMessage> {
+        return [RpcMessageType.Offers, await offers.userOffers(user)];
+    }
+
+    async function userWants(): Promise<WantsMessage> {
+        return [RpcMessageType.Wants, await pg.userWants(user)];
+    }
+
+    async function offerStatusSet(params: OfferStatusSetParams): Promise<OffersMessage> {
+        const { id, status } = params;
+        assert(id, 'no id supplied');
+        assert(Status[status], 'unknown status');
+
+        const offer = await offers.statusSet(user, id, status);
+        const userOffers = await offers.userOffers(user);
+
+        return [RpcMessageType.Offers, userOffers]
+    }
+
+    async function wantRm(params: WantRmParams): Promise<WantsMessage> {
+        const { id } = params;
+        assert(id, 'no id supplied');
+
+        await pg.wantRm(id);
+
+        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');
+        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;
+
+        if (!user) {
+            log.debug('anon rpc call');
+            return [RpcMessageType.WhoDis, []];
+        }
+
+        if (msgType !== RpcMessageType.Ping) log.info({ msgType, params }, 'rpc message');
+
+        // // this sucks but can't figure out how to convince typescript to agree yet
+        if (checkMsgType(msgType)) {
+            switch (msgType) {
+            case RpcMessageType.Ping:
+                return ping();
+
+            case RpcMessageType.Offers:
+                return userOffers();
+            case RpcMessageType.Wants:
+                return userWants();
+            case RpcMessageType.OfferStatusSet:
+                return offerStatusSet(params);
+
+            case RpcMessageType.WantRm:
+                return wantRm(params);
+
+            case RpcMessageType.AcpOfferStatusSet:
+                return acpOfferStatusSet(params);
+            case RpcMessageType.AcpOffers:
+                return acpOffers();
+
+            default:
+                throw new Error(`Message type ${msgType} is known but unhandled`);
+            }
+        } else {
+            throw new Error(`Unknown message type ${msgType}`);
+        }
+
+        throw new Error(`Invalid parameters for message type ${msgType}: ${JSON.stringify(message)}`);
+    }
+
+    async function onConnection() {
+        const userMsg: UserMessage = [RpcMessageType.User, user];
+        send(userMsg);
+
+        const wants = await pg.userWants(user);
+        const wantsMsg: WantsMessage = [RpcMessageType.Wants, wants];
+        send(wantsMsg);
+    }
+
+    function send(msg: RpcMessage) {
+        ws.send(JSON.stringify(msg, (key, value) =>
+            typeof value === 'bigint'
+                ? value.toString()
+                : value // return everything else unchanged
+        ))
+    }
+
+    return {
+        receive,
+        send,
+        onConnection,
+    }
+}
+
+export enum RpcMessageType {
+    Ping = 'Ping',
+    Pong = 'Pong',
+
+    // points out user is anon
+    WhoDis = 'WhoDis',
+
+    Bundles = 'Bundles',
+    Offers = 'Offers',
+    List = 'List',
+    Wants = 'Wants',
+    User = 'User',
+
+    Error = 'Error',
+
+    OfferStatusSet = 'OfferStatusSet',
+
+    AcpOfferStatusSet = 'AcpOfferStatusSet',
+    AcpOffers = 'AcpOffers',
+
+    WantRm = 'WantRm',
+}
+
+type ErrorMessage = [RpcMessageType.Error, string];
+type PongMessage = [RpcMessageType.Pong, []];
+type PingMessage = [RpcMessageType.Ping, []];
+type WhoDisMessage = [RpcMessageType.WhoDis, []];
+type UserMessage = [RpcMessageType.User, User];
+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 |
+    WhoDisMessage |
+
+    UserMessage |
+
+    WantsMessage |
+
+    OffersMessage |
+    OfferStatusSetMessage |
+
+    AcpOfferStatusSetMessage |
+    AcpOffersMessage |
+
+    ErrorMessage;
+
+
+type OfferStatusSetParams = {
+    id: UUID,
+    status: Status,
+};
+
+type WantRmParams = {
+    id: UUID,
+};

api/src/services.ts

@@ -0,0 +1,25 @@
+import { PrismaClient } from '@prisma/client'
+
+import createDiscogs from './discogs';
+import createOffers from './offers';
+import createLog from './log';
+import createApi from './api';
+import createEvents from './events';
+import createPg from './pg';
+
+export default function creates(log) {
+    const prisma = new PrismaClient();
+    const pg = createPg(log, prisma);
+    const discogs = createDiscogs(log, pg);
+    const offers = createOffers(log, pg);
+    const events = createEvents(log, pg, discogs, offers);
+    const api = createApi(log, pg, discogs, offers, events);
+
+    return {
+        api,
+        discogs,
+        events,
+        pg,
+        prisma,
+    };
+}

api/src/utils.ts

@@ -1,3 +1,5 @@
+import type { Want, User } from '@prisma/client';
+
 export function logAxiosError(e) {
     console.warn({
         status: e.response.status,
@@ -11,3 +13,20 @@ export function logAxiosError(e) {
         },
     });
 }
+
+export function wantDetails(want: Want) {
+    const data = want.data as any;
+
+    return {
+        title: data.title,
+        release: data.id,
+        artist: data.artists_sort,
+        id: want.id
+    }
+}
+
+export function isAdmin(user: User) {
+    return user.email === 'ntr@mnml.gg';
+}
+
+export function offerDetails() {}

api/tsconfig.json

@@ -33,7 +33,8 @@
     // "rootDirs": [],                                   /* Allow multiple folders to be treated as one when resolving modules. */
     // "typeRoots": [],                                  /* Specify multiple folders that act like './node_modules/@types'. */
     "types": [
-      "./index.d.ts"
+      "./index.d.ts",
+      "mocha"
     ],                                      /* Specify type package names to be included without being referenced in a source file. */
     // "allowUmdGlobalAccess": true,                     /* Allow accessing UMD globals from modules. */
     // "moduleSuffixes": [],                             /* List of file name suffixes to search when resolving a module. */
@@ -101,5 +102,10 @@
     /* Completeness */
     // "skipDefaultLibCheck": true,                      /* Skip type checking .d.ts files that are included with TypeScript. */
     "skipLibCheck": true                                 /* Skip type checking all .d.ts files. */
-  }
+  },
+
+  "ts-node": {
+    // strict mode gtfo
+    "transpileOnly": true,
+  },
 }

client/.babelrc.js

@@ -0,0 +1,4 @@
+module.exports = {
+  parserOpts: { strictMode: false },
+  plugins: ['@babel/plugin-transform-react-jsx-source']
+};

client/.eslintrc.js

@@ -0,0 +1,31 @@
+module.exports = {
+    parser: "@typescript-eslint/parser",
+    extends: [
+        "preact",
+        "plugin:@typescript-eslint/recommended"
+    ],
+    ignorePatterns: [
+        "build/"
+    ],
+    rules: {
+        // prevents stupid complaints a la
+        // (req) {
+        //   req.something = x;
+        // }
+        'no-param-reassign': [2, { props: false }],
+        'no-multi-spaces': [0],
+        'max-len': ['error', 120],
+        'import/no-extraneous-dependencies': [0],
+        'prefer-arrow-callback': [0],
+        'arrow-body-style': [0],
+        'no-return-assign': 0,
+        'no-console': [0],
+        // i like loops
+        'no-plusplus': [0],
+
+        'no-await-in-loop': [0],
+        indent: ['error', 4],
+        'keyword-spacing': ['error'],
+        'key-spacing': ['error'],
+    },
+};

client/.gitignore

@@ -1,3 +1,5 @@
 node_modules
 /build
 /*.log
+
+size-plugin.json

client/disclaimers.txt

@@ -0,0 +1,2 @@
+This application uses Discogs’ API but is not affiliated with, sponsored or endorsed by Discogs. ‘Discogs’ is a trademark of Zink Media, LLC.
+Data provided by Discogs.

client/package-lock.json

@@ -9,14 +9,18 @@
             "version": "0.1.0",
             "license": "MIT",
             "dependencies": {
+                "@reduxjs/toolkit": "^1.8.5",
+                "lodash": "^4.17.21",
+                "logrocket": "^3.0.1",
                 "preact": "^10.10.0",
                 "preact-render-to-string": "^5.2.1",
                 "preact-router": "^3.2.1",
+                "react-feather": "^2.0.10",
                 "react-redux": "^8.0.2",
-                "redux": "^4.2.0",
+                "redux": "^4.2.0"
-                "unistore": "^3.5.2"
             },
             "devDependencies": {
+                "@babel/plugin-transform-react-jsx-source": "^7.18.6",
                 "@typescript-eslint/eslint-plugin": "^5.30.6",
                 "@typescript-eslint/parser": "^5.30.6",
                 "eslint": "^8.20.0",
@@ -1596,6 +1600,21 @@
                 "@babel/core": "^7.0.0-0"
             }
         },
+        "node_modules/@babel/plugin-transform-react-jsx-source": {
+            "version": "7.18.6",
+            "resolved": "https://registry.npmjs.org/@babel/plugin-transform-react-jsx-source/-/plugin-transform-react-jsx-source-7.18.6.tgz",
+            "integrity": "sha512-utZmlASneDfdaMh0m/WausbjUjEdGrQJz0vFK93d7wD3xf5wBtX219+q6IlCNZeguIcxS2f/CvLZrlLSvSHQXw==",
+            "dev": true,
+            "dependencies": {
+                "@babel/helper-plugin-utils": "^7.18.6"
+            },
+            "engines": {
+                "node": ">=6.9.0"
+            },
+            "peerDependencies": {
+                "@babel/core": "^7.0.0-0"
+            }
+        },
         "node_modules/@babel/plugin-transform-regenerator": {
             "version": "7.18.6",
             "resolved": "https://registry.npmjs.org/@babel/plugin-transform-regenerator/-/plugin-transform-regenerator-7.18.6.tgz",
@@ -2645,6 +2664,29 @@
                 "webpack": "^4.0.0 || ^5.0.0"
             }
         },
+        "node_modules/@reduxjs/toolkit": {
+            "version": "1.8.5",
+            "resolved": "https://registry.npmjs.org/@reduxjs/toolkit/-/toolkit-1.8.5.tgz",
+            "integrity": "sha512-f4D5EXO7A7Xq35T0zRbWq5kJQyXzzscnHKmjnu2+37B3rwHU6mX9PYlbfXdnxcY6P/7zfmjhgan0Z+yuOfeBmA==",
+            "dependencies": {
+                "immer": "^9.0.7",
+                "redux": "^4.1.2",
+                "redux-thunk": "^2.4.1",
+                "reselect": "^4.1.5"
+            },
+            "peerDependencies": {
+                "react": "^16.9.0 || ^17.0.0 || ^18",
+                "react-redux": "^7.2.1 || ^8.0.2"
+            },
+            "peerDependenciesMeta": {
+                "react": {
+                    "optional": true
+                },
+                "react-redux": {
+                    "optional": true
+                }
+            }
+        },
         "node_modules/@rollup/plugin-babel": {
             "version": "5.3.1",
             "resolved": "https://registry.npmjs.org/@rollup/plugin-babel/-/plugin-babel-5.3.1.tgz",
@@ -10045,6 +10087,15 @@
                 "node": ">=0.10.0"
             }
         },
+        "node_modules/immer": {
+            "version": "9.0.15",
+            "resolved": "https://registry.npmjs.org/immer/-/immer-9.0.15.tgz",
+            "integrity": "sha512-2eB/sswms9AEUSkOm4SbV5Y7Vmt/bKRwByd52jfLkW4OLYeaTP3EEiJ9agqU0O/tq6Dk62Zfj+TJSqfm1rLVGQ==",
+            "funding": {
+                "type": "opencollective",
+                "url": "https://opencollective.com/immer"
+            }
+        },
         "node_modules/import-fresh": {
             "version": "3.3.0",
             "resolved": "https://registry.npmjs.org/import-fresh/-/import-fresh-3.3.0.tgz",
@@ -11860,8 +11911,7 @@
         "node_modules/lodash": {
             "version": "4.17.21",
             "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.21.tgz",
-            "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg==",
+            "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg=="
-            "dev": true
         },
         "node_modules/lodash.debounce": {
             "version": "4.0.8",
@@ -11909,6 +11959,11 @@
                 "url": "https://github.com/sponsors/sindresorhus"
             }
         },
+        "node_modules/logrocket": {
+            "version": "3.0.1",
+            "resolved": "https://registry.npmjs.org/logrocket/-/logrocket-3.0.1.tgz",
+            "integrity": "sha512-jOWG+jEzobKVxGytzZ+4KGm2kiMQMRTHab2uDWQyVZcHfEF38BlCH1yjQVY4LCmuQUwZitP9biMzJZnyUQ0dtQ=="
+        },
         "node_modules/loose-envify": {
             "version": "1.4.0",
             "resolved": "https://registry.npmjs.org/loose-envify/-/loose-envify-1.4.0.tgz",
@@ -12778,7 +12833,6 @@
             "version": "4.1.1",
             "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz",
             "integrity": "sha512-rJgTQnkUnH1sFw8yT6VSU3zD3sWmu6sZhIseY8VX+GRu3P6F7Fu+JNDoXfklElbLJSnc3FUQHVe4cU5hj+BcUg==",
-            "dev": true,
             "engines": {
                 "node": ">=0.10.0"
             }
@@ -15798,7 +15852,6 @@
             "version": "15.8.1",
             "resolved": "https://registry.npmjs.org/prop-types/-/prop-types-15.8.1.tgz",
             "integrity": "sha512-oj87CgZICdulUohogVAR7AjlC0327U4el4L6eAvOqCeudMDVU0NThNaV+b9Df4dXgSP1gXMTnPdhfe/2qDH5cg==",
-            "dev": true,
             "dependencies": {
                 "loose-envify": "^1.4.0",
                 "object-assign": "^4.1.1",
@@ -15808,8 +15861,7 @@
         "node_modules/prop-types/node_modules/react-is": {
             "version": "16.13.1",
             "resolved": "https://registry.npmjs.org/react-is/-/react-is-16.13.1.tgz",
-            "integrity": "sha512-24e6ynE2H+OKt4kqsOvNd8kBpV65zoxbA4BVsEOB3ARVWQki/DHzaUoC5KuON/BiccDaCCTZBuOcfZs70kR8bQ==",
+            "integrity": "sha512-24e6ynE2H+OKt4kqsOvNd8kBpV65zoxbA4BVsEOB3ARVWQki/DHzaUoC5KuON/BiccDaCCTZBuOcfZs70kR8bQ=="
-            "dev": true
         },
         "node_modules/proxy-addr": {
             "version": "2.0.7",
@@ -16113,6 +16165,17 @@
                 "node": ">=0.10.0"
             }
         },
+        "node_modules/react-feather": {
+            "version": "2.0.10",
+            "resolved": "https://registry.npmjs.org/react-feather/-/react-feather-2.0.10.tgz",
+            "integrity": "sha512-BLhukwJ+Z92Nmdcs+EMw6dy1Z/VLiJTzEQACDUEnWMClhYnFykJCGWQx+NmwP/qQHGX/5CzQ+TGi8ofg2+HzVQ==",
+            "dependencies": {
+                "prop-types": "^15.7.2"
+            },
+            "peerDependencies": {
+                "react": ">=16.8.6"
+            }
+        },
         "node_modules/react-is": {
             "version": "18.2.0",
             "resolved": "https://registry.npmjs.org/react-is/-/react-is-18.2.0.tgz",
@@ -16199,6 +16262,14 @@
                 "@babel/runtime": "^7.9.2"
             }
         },
+        "node_modules/redux-thunk": {
+            "version": "2.4.1",
+            "resolved": "https://registry.npmjs.org/redux-thunk/-/redux-thunk-2.4.1.tgz",
+            "integrity": "sha512-OOYGNY5Jy2TWvTL1KgAlVy6dcx3siPJ1wTq741EPyUKfn6W6nChdICjZwCd0p8AZBs5kWpZlbkXW2nE/zjUa+Q==",
+            "peerDependencies": {
+                "redux": "^4"
+            }
+        },
         "node_modules/regenerate": {
             "version": "1.4.2",
             "resolved": "https://registry.npmjs.org/regenerate/-/regenerate-1.4.2.tgz",
@@ -16498,6 +16569,11 @@
             "integrity": "sha512-KigOCHcocU3XODJxsu8i/j8T9tzT4adHiecwORRQ0ZZFcp7ahwXuRU1m+yuO90C5ZUyGeGfocHDI14M3L3yDAQ==",
             "dev": true
         },
+        "node_modules/reselect": {
+            "version": "4.1.6",
+            "resolved": "https://registry.npmjs.org/reselect/-/reselect-4.1.6.tgz",
+            "integrity": "sha512-ZovIuXqto7elwnxyXbBtCPo9YFEr3uJqj2rRbcOOog1bmu2Ag85M4hixSwFWyaBMKXNgvPaJ9OSu9SkBPIeJHQ=="
+        },
         "node_modules/resolve": {
             "version": "2.0.0-next.4",
             "resolved": "https://registry.npmjs.org/resolve/-/resolve-2.0.0-next.4.tgz",
@@ -18988,19 +19064,6 @@
                 "node": ">=8"
             }
         },
-        "node_modules/unistore": {
-            "version": "3.5.2",
-            "resolved": "https://registry.npmjs.org/unistore/-/unistore-3.5.2.tgz",
-            "integrity": "sha512-2Aa4eX0Ua1umyiI3Eai6Li+wXYOHgaDBGOPB3Hvw7PAVuD30TAyh5kS4yNKb2fLDbQgizvPhKQRcYnOdfsm4VQ==",
-            "peerDependenciesMeta": {
-                "preact": {
-                    "optional": true
-                },
-                "react": {
-                    "optional": true
-                }
-            }
-        },
         "node_modules/universalify": {
             "version": "2.0.0",
             "resolved": "https://registry.npmjs.org/universalify/-/universalify-2.0.0.tgz",
@@ -22241,6 +22304,15 @@
                 "@babel/types": "^7.18.6"
             }
         },
+        "@babel/plugin-transform-react-jsx-source": {
+            "version": "7.18.6",
+            "resolved": "https://registry.npmjs.org/@babel/plugin-transform-react-jsx-source/-/plugin-transform-react-jsx-source-7.18.6.tgz",
+            "integrity": "sha512-utZmlASneDfdaMh0m/WausbjUjEdGrQJz0vFK93d7wD3xf5wBtX219+q6IlCNZeguIcxS2f/CvLZrlLSvSHQXw==",
+            "dev": true,
+            "requires": {
+                "@babel/helper-plugin-utils": "^7.18.6"
+            }
+        },
         "@babel/plugin-transform-regenerator": {
             "version": "7.18.6",
             "resolved": "https://registry.npmjs.org/@babel/plugin-transform-regenerator/-/plugin-transform-regenerator-7.18.6.tgz",
@@ -23068,6 +23140,17 @@
                 "@prefresh/utils": "^1.1.2"
             }
         },
+        "@reduxjs/toolkit": {
+            "version": "1.8.5",
+            "resolved": "https://registry.npmjs.org/@reduxjs/toolkit/-/toolkit-1.8.5.tgz",
+            "integrity": "sha512-f4D5EXO7A7Xq35T0zRbWq5kJQyXzzscnHKmjnu2+37B3rwHU6mX9PYlbfXdnxcY6P/7zfmjhgan0Z+yuOfeBmA==",
+            "requires": {
+                "immer": "^9.0.7",
+                "redux": "^4.1.2",
+                "redux-thunk": "^2.4.1",
+                "reselect": "^4.1.5"
+            }
+        },
         "@rollup/plugin-babel": {
             "version": "5.3.1",
             "resolved": "https://registry.npmjs.org/@rollup/plugin-babel/-/plugin-babel-5.3.1.tgz",
@@ -28941,6 +29024,11 @@
             "dev": true,
             "optional": true
         },
+        "immer": {
+            "version": "9.0.15",
+            "resolved": "https://registry.npmjs.org/immer/-/immer-9.0.15.tgz",
+            "integrity": "sha512-2eB/sswms9AEUSkOm4SbV5Y7Vmt/bKRwByd52jfLkW4OLYeaTP3EEiJ9agqU0O/tq6Dk62Zfj+TJSqfm1rLVGQ=="
+        },
         "import-fresh": {
             "version": "3.3.0",
             "resolved": "https://registry.npmjs.org/import-fresh/-/import-fresh-3.3.0.tgz",
@@ -30310,8 +30398,7 @@
         "lodash": {
             "version": "4.17.21",
             "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.21.tgz",
-            "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg==",
+            "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg=="
-            "dev": true
         },
         "lodash.debounce": {
             "version": "4.0.8",
@@ -30353,6 +30440,11 @@
                 "is-unicode-supported": "^0.1.0"
             }
         },
+        "logrocket": {
+            "version": "3.0.1",
+            "resolved": "https://registry.npmjs.org/logrocket/-/logrocket-3.0.1.tgz",
+            "integrity": "sha512-jOWG+jEzobKVxGytzZ+4KGm2kiMQMRTHab2uDWQyVZcHfEF38BlCH1yjQVY4LCmuQUwZitP9biMzJZnyUQ0dtQ=="
+        },
         "loose-envify": {
             "version": "1.4.0",
             "resolved": "https://registry.npmjs.org/loose-envify/-/loose-envify-1.4.0.tgz",
@@ -31062,8 +31154,7 @@
         "object-assign": {
             "version": "4.1.1",
             "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz",
-            "integrity": "sha512-rJgTQnkUnH1sFw8yT6VSU3zD3sWmu6sZhIseY8VX+GRu3P6F7Fu+JNDoXfklElbLJSnc3FUQHVe4cU5hj+BcUg==",
+            "integrity": "sha512-rJgTQnkUnH1sFw8yT6VSU3zD3sWmu6sZhIseY8VX+GRu3P6F7Fu+JNDoXfklElbLJSnc3FUQHVe4cU5hj+BcUg=="
-            "dev": true
         },
         "object-copy": {
             "version": "0.1.0",
@@ -33326,7 +33417,6 @@
             "version": "15.8.1",
             "resolved": "https://registry.npmjs.org/prop-types/-/prop-types-15.8.1.tgz",
             "integrity": "sha512-oj87CgZICdulUohogVAR7AjlC0327U4el4L6eAvOqCeudMDVU0NThNaV+b9Df4dXgSP1gXMTnPdhfe/2qDH5cg==",
-            "dev": true,
             "requires": {
                 "loose-envify": "^1.4.0",
                 "object-assign": "^4.1.1",
@@ -33336,8 +33426,7 @@
                 "react-is": {
                     "version": "16.13.1",
                     "resolved": "https://registry.npmjs.org/react-is/-/react-is-16.13.1.tgz",
-                    "integrity": "sha512-24e6ynE2H+OKt4kqsOvNd8kBpV65zoxbA4BVsEOB3ARVWQki/DHzaUoC5KuON/BiccDaCCTZBuOcfZs70kR8bQ==",
+                    "integrity": "sha512-24e6ynE2H+OKt4kqsOvNd8kBpV65zoxbA4BVsEOB3ARVWQki/DHzaUoC5KuON/BiccDaCCTZBuOcfZs70kR8bQ=="
-                    "dev": true
                 }
             }
         },
@@ -33580,6 +33669,14 @@
                 "loose-envify": "^1.1.0"
             }
         },
+        "react-feather": {
+            "version": "2.0.10",
+            "resolved": "https://registry.npmjs.org/react-feather/-/react-feather-2.0.10.tgz",
+            "integrity": "sha512-BLhukwJ+Z92Nmdcs+EMw6dy1Z/VLiJTzEQACDUEnWMClhYnFykJCGWQx+NmwP/qQHGX/5CzQ+TGi8ofg2+HzVQ==",
+            "requires": {
+                "prop-types": "^15.7.2"
+            }
+        },
         "react-is": {
             "version": "18.2.0",
             "resolved": "https://registry.npmjs.org/react-is/-/react-is-18.2.0.tgz",
@@ -33632,6 +33729,12 @@
                 "@babel/runtime": "^7.9.2"
             }
         },
+        "redux-thunk": {
+            "version": "2.4.1",
+            "resolved": "https://registry.npmjs.org/redux-thunk/-/redux-thunk-2.4.1.tgz",
+            "integrity": "sha512-OOYGNY5Jy2TWvTL1KgAlVy6dcx3siPJ1wTq741EPyUKfn6W6nChdICjZwCd0p8AZBs5kWpZlbkXW2nE/zjUa+Q==",
+            "requires": {}
+        },
         "regenerate": {
             "version": "1.4.2",
             "resolved": "https://registry.npmjs.org/regenerate/-/regenerate-1.4.2.tgz",
@@ -33864,6 +33967,11 @@
             "integrity": "sha512-KigOCHcocU3XODJxsu8i/j8T9tzT4adHiecwORRQ0ZZFcp7ahwXuRU1m+yuO90C5ZUyGeGfocHDI14M3L3yDAQ==",
             "dev": true
         },
+        "reselect": {
+            "version": "4.1.6",
+            "resolved": "https://registry.npmjs.org/reselect/-/reselect-4.1.6.tgz",
+            "integrity": "sha512-ZovIuXqto7elwnxyXbBtCPo9YFEr3uJqj2rRbcOOog1bmu2Ag85M4hixSwFWyaBMKXNgvPaJ9OSu9SkBPIeJHQ=="
+        },
         "resolve": {
             "version": "2.0.0-next.4",
             "resolved": "https://registry.npmjs.org/resolve/-/resolve-2.0.0-next.4.tgz",
@@ -35867,11 +35975,6 @@
                 "crypto-random-string": "^2.0.0"
             }
         },
-        "unistore": {
-            "version": "3.5.2",
-            "resolved": "https://registry.npmjs.org/unistore/-/unistore-3.5.2.tgz",
-            "integrity": "sha512-2Aa4eX0Ua1umyiI3Eai6Li+wXYOHgaDBGOPB3Hvw7PAVuD30TAyh5kS4yNKb2fLDbQgizvPhKQRcYnOdfsm4VQ=="
-        },
         "universalify": {
             "version": "2.0.0",
             "resolved": "https://registry.npmjs.org/universalify/-/universalify-2.0.0.tgz",

client/package.json

@@ -4,29 +4,23 @@
     "version": "0.1.0",
     "license": "MIT",
     "scripts": {
-        "build": "preact build",
+        "build": "preact build --no-prerender",
-        "start": "preact watch",
+        "start": "preact --no-clear watch",
         "lint": "eslint src"
     },
-    "eslintConfig": {
-        "parser": "@typescript-eslint/parser",
-        "extends": [
-            "preact",
-            "plugin:@typescript-eslint/recommended"
-        ],
-        "ignorePatterns": [
-            "build/"
-        ]
-    },
     "dependencies": {
+        "@reduxjs/toolkit": "^1.8.5",
+        "lodash": "^4.17.21",
+        "logrocket": "^3.0.1",
         "preact": "^10.10.0",
         "preact-render-to-string": "^5.2.1",
         "preact-router": "^3.2.1",
+        "react-feather": "^2.0.10",
         "react-redux": "^8.0.2",
-        "redux": "^4.2.0",
+        "redux": "^4.2.0"
-        "unistore": "^3.5.2"
     },
     "devDependencies": {
+        "@babel/plugin-transform-react-jsx-source": "^7.18.6",
         "@typescript-eslint/eslint-plugin": "^5.30.6",
         "@typescript-eslint/parser": "^5.30.6",
         "eslint": "^8.20.0",

client/src/actions.ts

@@ -1,9 +1,23 @@
-import axios from 'axios';
+import { route } from 'preact-router';
+import http from './http';
 
 const actions = store => ({
-    getBundles: async () => {
+    setWs: function setWs(state, ws) {
-        const { data: bundles } = await axios.get('http://localhost:41337/bundles');
+        return { ws };
-        return { bundles };
+    },
+
+    setUser: function setUser(state, user) {
+        return { user };
+    },
+
+    setOffers: function setOffers(state, offers) {
+        return { offers };
+    },
+
+    logout: async function logout() {
+        await http.postLogout();
+        route('/login');
+        return { user: null };
     },
 });
 

client/src/app.tsx

@@ -1,30 +1,64 @@
 import { h } from 'preact';
-import { Route, Router } from 'preact-router';
+import { useEffect } from 'preact/hooks';
-import { Provider } from 'unistore/preact'
+import { useDispatch, Provider } from 'react-redux'
+import { Route, Router, } from 'preact-router';
+import LogRocket from 'logrocket';
 
-import mcratesStore from './store';
+import createWs from './ws';
-import actions from './actions';
+import store, {  wsState } from './store'
 
-import Header from './components/header';
+import Nav from './components/nav';
 
-import Home from './routes/home';
+import Offers from './routes/offers';
-import Profile from './routes/profile';
+import Acp from './routes/acp';
+import Login from './routes/login';
+import Search from './routes/search';
+import List from './routes/list';
+import Info from './routes/info';
 
-const store = mcratesStore();
+if (window.location.host === 'matescrates.au') LogRocket.init('yh0dy3/mcrates');
 
-console.log(Home);
+const Main = () => {
+    const dispatch = useDispatch()
 
-const App = () => (
+    // i have no idea why this is needed,
-    <Provider store={store}>
+    // but it makes sure the user changes actually rerender
-        <div id="app">
+    useEffect(() => {
-            <Header />
+        const ws = createWs(dispatch);
-            <Router>
+        ws.connect();
-                <Route path="/" component={Home} />
+        dispatch(wsState.actions.set(ws));
-                <Route path="/profile/" component={Profile} user="me" />
+    }, [dispatch])
-                <Route path="/profile/:user" component={Profile} />
+
+    function routeChange(e) {
+        const { ws } = store.getState();
+        if (!ws) return null;
+        if (e.url === '/acp') return ws.sendAcpOffers();
+    }
+
+    return (
+        <main id="app">
+            <Nav />
+            <Router onChange={routeChange}>
+                <Route path="/" component={Offers} />
+                <Route path="/login" component={Login} mode="login" />
+                <Route path="/register" component={Login} mode="register" />
+                <Route path="/search" component={Search} />
+                <Route path="/list" component={List} />
+                <Route path="/info" component={Info} />
+
+                {/* ACP */}
+                <Route path="/acp" component={Acp} />
             </Router>
-        </div>
+        </main>
+    );
+};
+
+const App = () => {
+    return (
+        <Provider store={store}>
+            <Main />
         </Provider>
-);
+    );
+}
 
 export default App;

client/src/components/header.tsx

@@ -1,15 +0,0 @@
-import { h } from 'preact';
-import { Link } from 'preact-router/match';
-
-const Header = () => (
-    <header class={'header'}>
-        <h1>Mates Crates</h1>
-        <nav>
-            <Link activeClassName={'active'} href="/">Home</Link>
-            <Link activeClassName={'active'} href="/profile">Me</Link>
-            <Link activeClassName={'active'} href="/profile/john">John</Link>
-        </nav>
-    </header>
-);
-
-export default Header;

client/src/components/nav.tsx

@@ -0,0 +1,79 @@
+import { h } from 'preact';
+import { route } from 'preact-router';
+import { useEffect } from 'preact/hooks';
+import { useSelector } from 'react-redux'
+import LogRocket from 'logrocket';
+
+import http from './../http';
+import { State } from './../store';
+
+function showAdmin(user) {
+    return user && user.email === 'ntr@mnml.gg';
+}
+
+const DEFAULT_ROUTE = '/';
+
+const Nav = () => {
+    const user = useSelector((state: State) => state.user);
+
+    useEffect(() => {
+        if (!user) {
+            route('/login');
+            return;
+        }
+        route(DEFAULT_ROUTE)
+
+        if (window.location.host === 'matescrates.au') {
+            LogRocket.identify(user.id, {
+                name: user.email,
+                email: user.email,
+            });
+        }
+
+        return;
+    }, [user])
+
+    async function logoutClick(e) {
+        e.preventDefault();
+        await http.postLogout();
+        window.location.reload();
+    }
+
+    const nav = () => (
+        <nav>
+            <a href="/">Offers</a>
+            <a href='/list'>List</a>
+            <a href="/search">Search</a>
+        </nav>
+    );
+
+    const anonNav = () => (
+        <nav>
+            <a href="/login">Login</a>
+            <a href="/register">Register</a>
+        </nav>
+    );
+
+    const adminNav = () => (
+        <nav>
+            <a href='/acp'>Offers ACP</a>
+        </nav>
+    )
+
+    const userNav = () => (
+        <nav>
+            <a href="/info">Info</a>
+            <a href="/auth/logout" onClick={logoutClick}>Logout</a>
+        </nav>
+    )
+
+    return (
+        <header>
+            {user ? nav() : anonNav()}
+            {showAdmin(user) ? adminNav() : <div></div>}
+            {user ? userNav() : null}
+        </header>
+    );
+}
+
+export default Nav;

client/src/components/offer.tsx

@@ -0,0 +1,43 @@
+import { h } from 'preact';
+import { ExternalLink, Check } from 'react-feather';
+import { useState } from 'preact/hooks';
+
+import { useSelector, useDispatch } from 'react-redux'
+import { State } from './../store';
+
+import http from '../http';
+
+export default function Offer(offer) {
+    const ws = useSelector((state: State) => state.ws);
+
+    const { want: { data: details } } = offer;
+
+    function setStatus(status) {
+        ws.sendOfferStatusSet(offer.id, status);
+    }
+
+    const accepted = offer.status === 'Accepted';
+    const classes = `${accepted ? 'accepted' : ''}`;
+    const btnText = accepted
+        ? offer.status
+        : 'Accept';
+
+    const negBtn = accepted
+        ? <button onClick={() => setStatus('Pending')} class='neg'>Cancel</button>
+        : <button onClick={() => setStatus('Declined')} class='neg'>Decline</button>;
+
+    return (
+        <div class="offer">
+            <section>
+                <h3>{details.artists_sort} - {details.title} <a href={details.uri} target="_blank"><ExternalLink /></a></h3>
+                <div class='alt-text' >{details.year}</div>
+                <div class='alt-text'>{details.formats[0].descriptions.join(' ')}</div>
+                <div class='number'>mcrates price: ${offer.total}</div>
+                <div class='number'>shipped by itself: ${offer.comparison}</div>
+            </section>
+            <img src={details.thumb} />
+            <button onClick={() => setStatus('Accepted')} disabled={accepted} class={classes} >{btnText}</button>
+            {negBtn}
+        </div>
+    )
+}

client/src/components/want.offers.tsx

@@ -0,0 +1,75 @@
+import { h } from 'preact';
+import { ExternalLink, Check } from 'react-feather';
+import { useState } from 'preact/hooks';
+
+import { useSelector, useDispatch } from 'react-redux'
+import { State } from './../store';
+
+import http from '../http';
+
+function OfferLine(offer) {
+    const ws = useSelector((state: State) => state.ws);
+
+    function setStatus(status) {
+        ws.sendOfferStatusSet(offer.id, status);
+    }
+
+    const accepted = offer.status === 'Accepted';
+    const classes = `${accepted ? 'accepted' : ''}`;
+    const btnText = accepted
+        ? offer.status
+        : 'Accept';
+
+    const negBtn = accepted
+        ? <button onClick={() => setStatus('Pending')} class='neg'>Cancel</button>
+        : <button onClick={() => setStatus('Declined')} class='neg'>Decline</button>;
+
+    return (
+        <div class="line">
+            <span class='number'>${offer.total}</span>
+            <button onClick={() => setStatus('Accepted')} disabled={accepted} class={classes} >{btnText}</button>
+            {negBtn}
+        </div>
+    )
+}
+
+function OfferPriceBtn(offer) {
+    const ws = useSelector((state: State) => state.ws);
+    const accepted = offer.status === 'Accepted';
+    const confirmed = offer.status === 'Confirmed';
+
+    function setStatus() {
+        if (accepted) return ws.sendOfferStatusSet(offer.id, 'Pending')
+        ws.sendOfferStatusSet(offer.id, 'Accepted');
+    }
+
+    const classes = `${accepted ? 'accepted' : ''} ${confirmed ? 'confirmed' : ''}`;
+    const btnText = accepted
+        ? offer.status
+        : 'Accept';
+
+    return (
+        <button disabled={confirmed} onClick={() => setStatus()} class={classes}>${offer.total} {offer.condition}</button>
+    )
+}
+
+
+export default function WantOffers(wantOffers) {
+    const ws = useSelector((state: State) => state.ws);
+
+    const details = wantOffers[0].want.data;
+
+    return (
+        <div class="offer">
+            <section>
+                <h3>{details.artists_sort} - {details.title} <a href={details.uri} target="_blank"><ExternalLink /></a></h3>
+                <div class='alt-text' >{details.year}</div>
+                <div class='alt-text'>{details.formats.map(f => f.descriptions.join(' ')).join(' ')}</div>
+            </section>
+            <img src={details.thumb} />
+            <div class="lines">
+                {wantOffers.map(o => OfferPriceBtn(o))}
+            </div>
+        </div>
+    )
+}

client/src/components/want.tsx

@@ -0,0 +1,41 @@
+import { h } from 'preact';
+import { useState, useCallback } from 'preact/hooks';
+import { ExternalLink } from 'react-feather';
+
+import { useSelector } from 'react-redux'
+import { State } from './../store'
+
+import http from './../http';
+
+function Want(want) {
+    const r = want.data;
+
+    const ws = useSelector((state: State) => state.ws);
+    const [confirm, setConfirm] = useState(false);
+
+    function onClick() {
+        if (confirm) return ws.sendWantRm(want.id);
+        setTimeout(() => setConfirm(false), 2500);
+        return setConfirm(true);
+    };
+
+    const text = confirm
+        ? 'confirm'
+        : 'remove';
+
+    return (
+        <article key={r.id}>
+            <div>
+                <h3>{r.artists_sort} - {r.title} <a href={r.uri} target="_blank"><ExternalLink /></a></h3>
+            </div>
+            <img src={r.thumb} />
+            <div class='details'>
+                <div class='alt'>{r.year}</div>
+                <div class='alt'>{r.formats[0].descriptions.join(' ')}</div>
+            </div>
+            <button onClick={onClick} >{text}</button>
+        </article>
+    );
+}
+
+export default Want;

client/src/http.ts

@@ -0,0 +1,95 @@
+import axios, { AxiosInstance } from 'axios';
+
+type ApiResponse = [string | null, any | null];
+
+declare module 'axios' {
+  export interface AxiosInstance {
+    request(config: AxiosRequestConfig): Promise<ApiResponse>;
+    get(url: string, config?: AxiosRequestConfig): Promise<ApiResponse>;
+    delete(url: string, config?: AxiosRequestConfig): Promise<ApiResponse>;
+    head(url: string, config?: AxiosRequestConfig): Promise<ApiResponse>;
+    post(url: string, data?: any, config?: AxiosRequestConfig): Promise<ApiResponse>;
+    put(url: string, data?: any, config?: AxiosRequestConfig): Promise<ApiResponse>;
+    patch(url: string, data?: any, config?: AxiosRequestConfig): Promise<ApiResponse>;
+  }
+}
+
+const api = axios.create({
+  baseURL: '/api',
+  withCredentials: true
+});
+
+function onSuccess(response) {
+    return [null, response.data];
+}
+
+function onError(error) {
+    if (error.response) return [error.response.data.error, null];
+    if (error.request) return ['Network Error', null];
+    return ['Unknown Error', null];
+}
+
+api.interceptors.response.use(onSuccess, onError);
+
+const actions = {
+    getBundles: async function getBundles() {
+        return api.get('/acp/bundles');
+    },
+
+    getOffers: async function getOffers() {
+        return api.get('/user/offers');
+    },
+
+    getOffersAcp: async function getOffersAcp() {
+        return api.get('/acp/offers');
+    },
+
+    getWants: async function getWants() {
+        return api.get('/want/all');
+    },
+
+    postWantSearch: async function postWantSearch(artist, title) {
+        return api.post('/want/search', { artist, title });
+    },
+
+    postWant: async function postWant(releaseId) {
+        return api.post('/want', { releaseId });
+    },
+
+    postDiscogs: async function postDiscogs(username) {
+        return api.post('/want/discogs', { username });
+    },
+
+    getLogin: async function getLogin() {
+        return api.get('/auth/login')
+    },
+
+    postLogin: async function postLogin(email, password) {
+        return api.post('/auth/login', {
+            email,
+            password,
+            // discogs,
+        });
+    },
+
+    postLogout: async function postLogout() {
+        return api.post('/auth/logout', {});
+    },
+
+    postRegister: async function postRegister(email, password) {
+        return api.post('/auth/register', {
+            email,
+            password,
+        });
+    },
+
+    postOffers: async function postOffers(listingIds, shipping, baseShipping) {
+        return api.post('/offers', {
+            listingIds,
+            shipping,
+            baseShipping,
+        });
+    },
+};
+
+export default actions;

client/src/routes/acp.tsx

@@ -0,0 +1,92 @@
+import { h } from 'preact';
+import { useState, useEffect } from 'preact/hooks';
+
+import http from './../http';
+
+import { useSelector, useDispatch } from 'react-redux'
+import { State } from './../store';
+
+enum Status {
+    Accepted     = 'Accepted',
+    Pending      = 'Pending',
+    Declined     = 'Declined',
+    Confirmed    = 'Confirmed',
+    Complete     = 'Complete',
+}
+
+const POSITIVE_STATUS = [Status.Accepted, Status.Confirmed, Status.Complete];
+
+function Item({ item }) {
+    const ws = useSelector((state: State) => state.ws);
+    console.log(item);
+
+    const statuses = Object.entries(Status).map(([label, value]) => (
+        <option selected={item.status === value} value={value}>{value}</option>
+    ));
+
+    function onChange(e) {
+        ws.sendAcpOfferStatusSet(item.id, e.target.value);
+    }
+
+    const bold = POSITIVE_STATUS.includes(item.status)
+        ? 'bold'
+        : '';
+
+    return (
+        <div key={item.id} class={bold}>
+            <a href={item.listing.data.uri} target="_blank" >
+                <h4>{item.listing.data.release.description}</h4>
+            </a>
+            <h5>{item.user.email}</h5>
+            <h5 class='alt-text'>{item.total}</h5>
+            <h5>{item.status}</h5>
+            <label>Set Status:</label>
+            <select onChange={onChange}>
+                {statuses}
+            </select>
+        </div>
+    );
+}
+
+function SellerGroup(group) {
+    const ready = group.offers.filter(item => POSITIVE_STATUS.includes(item.status)).length;
+
+    return (
+        <div class="bundle">
+           <section>
+                <h2>{group.username} - {group.seller}</h2>
+                <h3>{ready} / {group.offers.length} offers</h3>
+                <h4>Ships: {group.mentionsAustralia && 'AU'} {group.mentionsWorldwide && 'WORLD'}</h4>
+            </section>
+
+            <div class='items'>
+                {group.offers.map(i => <Item item={i} />)}
+            </div>
+        </div>
+    )
+}
+
+function Home() {
+    const offers = useSelector((state: State) => state.acpOffers);
+    const ws = useSelector((state: State) => state.ws);
+
+    // useEffect(() => {
+    //     ws.sendAcpOffers();
+    // }, [offers, ws]);
+
+    if (!offers.length) {
+        return (
+            <div class={'offers'}>
+                loading...
+            </div>
+        );
+    }
+
+    return (
+        <div class='bundles'>
+            {offers.map(SellerGroup)}
+        </div>
+    );
+}
+
+export default Home;

client/src/routes/home.tsx

@@ -1,49 +0,0 @@
-import { h } from 'preact';
-import { connect } from 'unistore/preact'
-
-import actions from './../actions';
-
-// import Bundle from './../components/bundle';
-
-interface Props {
-    bundles: any[];
-    getBundles: () => void,
-}
-
-function Bundle(bundle) {
-	return (
-		<div class="bundle">
-			<h2>{bundle.username} - {bundle.seller}</h2>
-			<h3>{bundle.total} {bundle.currency}</h3>
-			{bundle.items.map(i => (
-				<div key={i.id}>
-					<a href={i.uri}>
-						<h4>{i.description}</h4>
-					</a>
-					<h5>{i.price} {i.currency}</h5>
-				</div>
-			))}
-		</div>
-	)
-}
-
-
-function Home({ bundles, getBundles }: Props) {
-	if (!bundles.length) {
-		getBundles();
-
-		return (
-			<div class={'home'}>
-				loading...
-			</div>
-		);
-	}
-
-	return (
-		<div class={'home'}>
-			{bundles.map(Bundle)}
-		</div>
-	);
-}
-
-export default connect('bundles', actions)(Home);

client/src/routes/info.tsx

@@ -0,0 +1,52 @@
+import { h } from 'preact';
+
+const Info = () => {
+    return (
+        <div class='info'>
+            <div class='words'>
+                <section>
+                    <h1>Info</h1>
+                    <p> Thanks for signing up! </p>
+                    <p> Mates Crates is a record importing service in alpha. </p>
+                    <p> Its purpose is to reduce the cost of shipping vinyl records to Melbourne, Australia. </p>
+                </section>
+
+                <section>
+                    <h2>How It Works</h2>
+                    <p> First, add some records to your <span class='alt'>List</span> on the <a href='/search'>Search Page</a>. </p>
+                    <p> Mates Crates will then make <span class='alt'>Offers</span> to you for releases you add to your <a href='/list'>List</a>. </p>
+                    <p> Select all <span class='alt'>Offers</span> you are interested in, the more you accept the more likely the item will be <span class='alt-text'>Confirmed</span>.</p>
+                    <p> Check back regularly for updated <span class='alt'>Offers</span>, the global record marketplace is a living thing. </p>
+                </section>
+
+                <section>
+                    <h2>Offers</h2>
+                    <p> Not all items on your <span class='alt'>List</span> will have offers. However, as new users join the site the number of offers we can make increases, so be sure to tell your friends!</p>
+                    <p> Think of offers like an expression of interest, they are not confirmed until they are set to <span class='alt-text'>Confirmed</span> status. </p>
+                    <p> After that they will be shipped to Melbourne and ready for pick up. </p>
+                </section>
+
+                <section>
+                    <h2>Pick Up</h2>
+                    <p> Use the contact options to get in touch. </p>
+                    <p> Payment is cash on delivery. </p>
+                </section>
+
+                <section>
+                    <h2>FAQ</h2>
+                    <h3> Delivery Times </h3>
+                    <p> Records are usually available for pickup within a week. We order in bulk, which often means express, insured shipping to Melbourne. </p>
+                    <h3> Friends </h3>
+                    <p> Please invite other collectors to the site. More users means offers can become cheaper and shipped sooner. </p>
+                </section>
+            </div>
+            <section class='contact'>
+                <h2>Contact</h2>
+                <p><a href='mailto:ntr@mnml.gg?subject=Mates%20Crates%20Enquiry'>Email</a></p>
+                <p><a href='https://discord.gg/QfjY8WNQyx'>Discord</a></p>
+            </section>
+        </div>
+    );
+};
+
+export default Info;

client/src/routes/list.tsx

@@ -0,0 +1,28 @@
+import { h } from 'preact';
+
+import { useSelector } from 'react-redux'
+import { State } from './../store'
+
+import Want from './../components/want';
+
+interface Props {
+    user: any,
+    wants: any[],
+    getUserOffers: (userId: string) => void,
+}
+
+const List = ({ user }: Props) => {
+    const wants = useSelector((state: State) => state.wants);
+
+    if (!wants.length) {
+        return <div> loading... </div>;
+    }
+
+    return (
+        <div class="list">
+            {wants.map(Want)}
+        </div>
+    );
+};
+
+export default List;

client/src/routes/login.tsx

@@ -0,0 +1,109 @@
+import { h } from 'preact';
+import { route } from 'preact-router';
+import { useState, useEffect, useRef } from 'preact/hooks';
+import { useSelector, useDispatch } from 'react-redux'
+
+import http from './../http';
+import { State, userState } from './../store';
+
+const Login = ({ mode }) => {
+    const dispatch = useDispatch()
+    const user = useSelector((state: State) => state.user);
+    const ws = useSelector((state: State) => state.ws);
+
+    const [email, setEmail] = useState('')
+    const [password, setPassword] = useState('');
+    const [confirmPassword, setConfirmPassword] = useState('');
+    const [error, setError] = useState('');
+
+    async function postLogin() {
+        const [error, user] = await http.postLogin(email, password);
+        if (error) return setError(error);
+        route('/');
+        dispatch(userState.actions.set(user));
+        // reconnect ws to get logged in methods
+        ws.connect();
+    }
+
+    async function postRegister() {
+        const [error, user] = await http.postRegister(email, password);
+        if (error) return setError(error);
+        route('/search');
+        dispatch(userState.actions.set(user));
+    }
+
+    function handleSubmit(e) {
+        e.preventDefault();
+        if (mode === 'login') return postLogin()
+        if (mode === 'register') return postRegister();
+    }
+
+    const emailRef = useRef<HTMLInputElement>()
+    useEffect(() => {
+        emailRef.current.focus()
+    }, [])
+
+
+    const errorEl = error
+        ? <div class='alt-text'>{error}</div>
+        : null;
+
+    if (mode === 'register') return (
+        <div class="login">
+            {errorEl}
+            <form action="">
+                <div class="item">
+                    <label for="email">email</label>
+                    <input type="email" name="email" id="email" ref={emailRef} value={email} required onInput={(e) => setEmail((e.target as HTMLInputElement).value)} />
+                </div>
+                <div class="item">
+                    <label for="password">password</label>
+                    <input type="password" name="password" id="password" value={password} required onInput={(e) => setPassword((e.target as HTMLInputElement).value)} />
+                </div>
+                <div class="item">
+                    <label for="password">confirm password</label>
+                    <input type="password" name="password" id="password" value={confirmPassword} required onInput={(e) => setConfirmPassword((e.target as HTMLInputElement).value)} />
+                </div>
+                <div class="item">
+                    <input type="submit" value="register" onClick={handleSubmit} />
+                </div>
+            </form>
+        </div>
+
+    );
+
+    return (
+        <div class="login">
+            {errorEl}
+            <form action="">
+                <div class="item">
+                    <label for="email">email</label>
+                    <input type="email" name="email" id="email" ref={emailRef} value={email} required onInput={(e) => setEmail((e.target as HTMLInputElement).value)} />
+                </div>
+                <div class="item">
+                    <label for="password">password</label>
+                    <input type="password" name="password" id="password" value={password} required onInput={(e) => setPassword((e.target as HTMLInputElement).value)} />
+                </div>
+                <div class="item">
+                    <input type="submit" value="login" onClick={handleSubmit} />
+                </div>
+            </form>
+        </div>
+    );
+};
+
+function LoginPage({ mode }) {
+    return (
+        <div class="landing">
+            <Login mode={mode} />
+            <div></div>
+            <div>
+                <p>Mates Crates is a record importing service.</p>
+                <p>We bundle orders together from thousands of online stores to reduce the cost of shipping vinyl.</p>
+                <p>Based in Preston.</p>
+            </div>
+        </div>
+    )
+}
+
+export default LoginPage;

client/src/routes/offers.tsx

@@ -0,0 +1,30 @@
+import { h } from 'preact';
+import { useState, useEffect } from 'preact/hooks';
+import { route } from 'preact-router';
+import { useSelector, useDispatch } from 'react-redux'
+
+import http from './../http';
+import { State, offersState } from './../store';
+
+import WantOffers from './../components/want.offers';
+
+function Home() {
+    const dispatch = useDispatch()
+    const offers = useSelector((state: State) => state.offers);
+
+    // if (!offers.length) {
+    //     return (
+    //         <div class={'offers'}>
+    //             loading...
+    //         </div>
+    //     );
+    // }
+
+    return (
+        <div class={'offers'}>
+            {Object.values(offers).map(WantOffers)}
+        </div>
+    );
+}
+
+export default Home;

client/src/routes/profile.tsx

@@ -1,35 +0,0 @@
-import { h } from 'preact';
-import { useEffect, useState } from 'preact/hooks';
-import style from './style.less';
-
-interface Props {
-    user: string;
-}
-
-const Profile = ({ user }: Props) => {
-    const [time, setTime] = useState<number>(Date.now());
-    const [count, setCount] = useState<number>(0);
-
-
-    useEffect(() => {
-		let timer = setInterval(() => setTime(Date.now()), 1000);
-		return () => clearInterval(timer);
-	}, []);
-
-    return (
-		<div class={'profile'}>
-			<h1>Profile: {user}</h1>
-			<p>This is the user profile for a user named { user }.</p>
-
-			<div>Current time: {new Date(time).toLocaleString()}</div>
-
-			<p>
-				<button onClick={() => setCount((count) => count + 1)}>Click Me</button>
-				{' '}
-				Clicked {count} times.
-			</p>
-		</div>
-	);
-};
-
-export default Profile;

client/src/routes/search.tsx

@@ -0,0 +1,119 @@
+import { h } from 'preact';
+import { useState, useRef, useEffect } from 'preact/hooks';
+import { ExternalLink, Check } from 'react-feather';
+
+import http from '../http';
+
+function Result(r) {
+    const [added, setAdded] = useState(false)
+
+    async function onClick() {
+        const [error, want] = await http.postWant(r.id);
+        if (error) return false;
+        setAdded(true);
+    }
+
+    const classes = `${added ? 'added' : ''}`;
+    const btnText = added
+        ? <Check />
+        : '+';
+
+    return (
+        <article key={r.id}>
+            <button onClick={onClick} disabled={added} class={classes} >{btnText}</button>
+            <div>
+                <h3>{r.title} <a href={`https://discogs.com${r.uri}`} target="_blank"><ExternalLink /></a></h3>
+                <h5 class='alt-text' >{r.year}</h5>
+                <h5 class='alt-text'>{r.country}</h5>
+                <h5 class='alt-text'>{r.format.join(' ')}</h5>
+            </div>
+            <img src={r.thumb} />
+        </article>
+    );
+}
+
+const User = () => {
+    const [artist, setArtist] = useState('')
+    const [title, setTitle] = useState('');
+    const [username, setUsername] = useState('');
+    const [results, setResults] = useState([]);
+    const [infoText, setInfoText] = useState('');
+
+    async function fetchResults() {
+        const [error, results] = await http.postWantSearch(artist, title);
+
+        if (results.length === 0) {
+            setResults([]);
+            return setInfoText('No results');
+        }
+
+        setInfoText('');
+        setResults(results);
+    }
+
+    async function submitWantlist() {
+        const [error, wants] = await http.postDiscogs(username);
+        if (wants.length === 0) {
+            setResults([]);
+            return setInfoText('No new additions');
+        }
+
+        setInfoText(`Added ${wants.length} items to your list.`);
+    }
+
+    const searchRef = useRef<HTMLInputElement>()
+
+    useEffect(() => {
+        searchRef.current.focus()
+    }, [])
+
+    function handleSubmit(e) {
+        e.preventDefault();
+        fetchResults();
+    }
+
+    function handleDiscogsSubmit(e) {
+        e.preventDefault();
+        submitWantlist();
+    }
+
+    const topEl = results.length
+        ? <button onClick={() => window.scrollTo(0, 0)}> top </button>
+        : null;
+
+    const infoEl = infoText
+        ? <article><div></div><div>{infoText}</div></article>
+        : null;
+
+    return (
+        <div class='search'>
+            <div>
+                <form action="" method="get">
+                    <label for="artist">Artist</label>
+                    <input type="text" name="artist" ref={searchRef} placeholder="Ben Klock" id="artist" value={artist} onChange={e => setArtist((e.target as HTMLInputElement).value) } required />
+                    <label for="title">Title</label>
+                    <input type="text" name="title" placeholder="Subzero" id="title" value={title} onChange={e => setTitle((e.target as HTMLInputElement).value)} required />
+                    <input type="submit" value="Search" onClick={handleSubmit} />
+                </form>
+                <hr />
+                <div>
+                    <form action="" method="get">
+                        <label for="Discogs">Discogs Username</label>
+                        <input type="text" name="username" placeholder="Discogs Username" id="username" value={username} onChange={e => setUsername((e.target as HTMLInputElement).value) } required />
+                        <input type="submit" value="Sync" onClick={handleDiscogsSubmit} />
+                    </form>
+                </div>
+                <hr />
+                <p>Data provided by Discogs.</p>
+            </div>
+            <div />
+            <div>
+                {infoEl}
+                {results.map(Result)}
+                {topEl}
+            </div>
+        </div>
+    );
+};
+
+export default User;

client/src/store.tsx

@@ -1,6 +1,61 @@
-import createStore from 'unistore'
+import { createStore, combineReducers } from 'redux'
+import { configureStore, createSlice } from '@reduxjs/toolkit'
 
-export default function mcratesStore() {
+export const userState = createSlice({
-  return createStore({ bundles: [] })
+  name: 'user',
-}
+  initialState: null,
+  reducers: {
+    set: (state, action) => action.payload
+  },
+});
 
+export const offersState = createSlice({
+  name: 'offers',
+  initialState: [],
+  reducers: {
+    set: (state, action) => action.payload
+  },
+});
+
+export const acpOffersState = createSlice({
+  name: 'acpOffers',
+  initialState: [],
+  reducers: {
+    set: (state, action) => action.payload
+  },
+});
+
+export const wantsState = createSlice({
+  name: 'wants',
+  initialState: [],
+  reducers: {
+    set: (state, action) => action.payload
+  },
+});
+
+export const wsState = createSlice({
+  name: 'ws',
+  initialState: null,
+  reducers: {
+    set: (state, action) => action.payload
+  },
+});
+
+const reducer = combineReducers({
+  offers: offersState.reducer,
+  wants: wantsState.reducer,
+  ws: wsState.reducer,
+  user: userState.reducer,
+
+  acpOffers: acpOffersState.reducer,
+});
+
+const store = createStore(
+  reducer,
+  window.__REDUX_DEVTOOLS_EXTENSION__ && window.__REDUX_DEVTOOLS_EXTENSION__()
+);
+
+export default store;
+
+export type State = ReturnType<typeof store.getState>
+export type Dispatch = typeof store.dispatch

client/src/style/index.less

@@ -1,90 +1,446 @@
-html, body {
+// Digital Ocean reset
-	height: 100%;
+html {
-	width: 100%;
-	padding: 0;
-	margin: 0;
-	background: #FAFAFA;
-	font-family: 'Helvetica Neue', arial, sans-serif;
-	font-weight: 400;
-	color: #444;
-	-webkit-font-smoothing: antialiased;
-	-moz-osx-font-smoothing: grayscale;
-}
-
-* {
   box-sizing: border-box;
+  font-size: 16px;
 }
 
-#app {
+*, *:before, *:after {
-	height: 100%;
+  box-sizing: inherit;
 }
 
-.home {
+body, h4, h5, h6, p, ol, ul {
-	padding: 56px 20px;
+  margin: 0;
-	min-height: 100%;
+  padding: 0;
+  font-weight: normal;
+}
+
+ol, ul {
+  list-style: none;
+}
+
+img {
+  // max-width: 100%;
+  height: auto;
+}
+
+/* latin */
+@font-face {
+  font-family: 'Raleway';
+  font-style: normal;
+  font-weight: 400;
+  src: url(https://fonts.gstatic.com/s/raleway/v28/1Ptxg8zYS_SKggPN4iEgvnHyvveLxVvaorCIPrE.woff2) format('woff2');
+  unicode-range: U+0000-00FF, U+0131, U+0152-0153, U+02BB-02BC, U+02C6, U+02DA, U+02DC, U+2000-206F, U+2074, U+20AC, U+2122, U+2191, U+2193, U+2212, U+2215, U+FEFF, U+FFFD;
+}
+
+@font-face {
+  font-family: 'Source Code Pro';
+  font-style: normal;
+  font-weight: 400;
+  src: url(https://fonts.gstatic.com/s/sourcecodepro/v21/HI_diYsKILxRpg3hIP6sJ7fM7PqPMcMnZFqUwX28DMyQtMlrTA.woff2) format('woff2');
+  unicode-range: U+0000-00FF, U+0131, U+0152-0153, U+02BB-02BC, U+02C6, U+02DA, U+02DC, U+2000-206F, U+2074, U+20AC, U+2122, U+2191, U+2193, U+2212, U+2215, U+FEFF, U+FFFD;
+}
+
+@font-face {
+  font-family: 'Noto Sans Mono';
+  font-style: normal;
+  font-weight: 400;
+  font-stretch: normal;
+  src: url(https://fonts.gstatic.com/s/notosansmono/v20/BngrUXNETWXI6LwhGYvaxZikqZqK6fBq6kPvUce2oAZcdthSBUsYck4-_FNJ093dVQ.woff2) format('woff2');
+  unicode-range: U+0000-00FF, U+0131, U+0152-0153, U+02BB-02BC, U+02C6, U+02DA, U+02DC, U+2000-206F, U+2074, U+20AC, U+2122, U+2191, U+2193, U+2212, U+2215, U+FEFF, U+FFFD;
+}
+
+// stuff from UX laws
+html {
+    color:var(--base-font-color);
+    font-size:clamp(var(--min-font-size),calc(50% + 1vw),var(--max-font-size));
+    font-family:var(--base-font-family);
+    line-height:var(--base-line-height);
+    -webkit-text-size-adjust:100%;
+    background:var(--background-0);
+    box-sizing:border-box
+}
+
+// @charset "UTF-8";
+:root {
+    --breakpoint-medium: 35em;
+    --breakpoint-large: 56em;
+
+    --small-font-size: 0.75em;
+    --base-font-size: 1em;
+    --smedium-font-size: 1.333em;
+    --medium-font-size: 1.777em;
+    --large-font-size: 2.369em;
+    --xlarge-font-size: 3.157em;
+    --base-font-family: 'Raleway', Arial, Sans-Serif;
+    --secondary-font-family: 'Noto Sans Mono', monospace;
+    --base-font-color: var(--color-off-white);
+    --secondary-font-color: var(--color-mid-grey);
+
+    --base-line-height: 1.4;
+    --header-line-height: 1.2;
+
+    --base-border-color: var(--secondary-font-color);
+    --base-border: 2px solid var(--base-border-color);
+    --hover-border: 2px solid var(--base-font-color);
+    --focus-border: 2px solid var(--base-font-color);
+    --base-border-radius: .2rem;
+    --base-focus: 2px solid var(--base-accent-color);
+    --base-outline-offset: 0.25em;
+
+    --min-font-size: var(--base-font-size);
+    --max-font-size: var(--large-font-size);
+
+    --color-dark-blue: #101014;
+    --color-mid-blue: #16171d;
+    --color-light-blue: #1f2128;
+    --color-mid-grey: #9BA0B3;
+    --color-off-white: #F4F1D0;
+    --color-accent-blue: #5E9ED6;
+
+    --color-blue-gray: #506485;
+
+    --color-blue: #475977;
+    --color-green: #476d4a;
+
+    --color-accepted: var(--color-blue);
+    --color-confirmed: var(--color-green);
+
+    --base-accent-color: var(--color-accent-blue);
+    --fg-color: var(--color-off-white);
+    --hover-link-color: var(--color-off-white);
+
+    --background-0: var(--color-dark-blue);
+    --background-1: var(--color-mid-blue);
+    --background-2: var(--color-light-blue);
+
+    --spacing: 1rem;
+    --spacing-half: calc(var(--spacing)/2);
+    --spacing-double: calc(var(--spacing)*2);
+
+    --utility-bar-header-height: calc(var(--spacing) * 1.5);
+}
+
+button, input, optgroup, select, textarea {
+    margin:0;
+    border:var(--base-border);
+    border-radius:var(--base-border-radius);
+    background:0 0;
+    font-family:inherit;
+    font-size:100%;
+    color:inherit;
+    line-height:var(--base-line-height);
+}
+
+input:hover, textarea:hover {
+    color:var(--base-font-color);
+    border:var(--hover-border)
+}
+
+input:focus, textarea:focus {
+    border:var(--focus-border);
+    outline:0
+}
+
+button, input {
+    overflow:visible;
+}
+
+button, select {
+    text-transform: none;
+}
+
+button, [type=button], [type=reset], [type=submit] {
+    -webkit-appearance:button;
+    border-color: transparent;
+    cursor:pointer;
+
+    font-family: var(--secondary-font-family);
+    font-size: var(--small-font-size);
+    font-weight: bold;
+    text-transform: uppercase;
+
+    &:hover {
+        background: var(--background-2);
+        border-color: transparent;
+    }
+}
+
+h1, h2, h3, h4, h5, h6 {
+    margin-top:0;
+    line-height:var(--header-line-height);
+}
+
+h1 {
+    margin-bottom:var(--spacing);
+    font-size:var(--large-font-size)
+}
+
+h2 {
+    margin-bottom:var(--spacing);
+    font-size:var(--medium-font-size);
+}
+
+h3 {
+    margin-bottom:calc(var(--spacing)/2);
+    font-size:var(--smedium-font-size)
+}
+
+h4 {
+    margin-bottom:calc(var(--spacing)/3);
+    font-size:var(--base-font-size)
+}
+
+p {
+    margin:0 0 var(--spacing)
+}
+
+// ok actual styles
+
+body {
+    padding-top: calc(var(--spacing)/2);
+}
+
+main {
+    padding: 0 5% 0 5%;
+}
+
+button, [type=submit] {
+    padding: var(--spacing-half);
+    background: var(--background-1);
+
+}
+
+.landing {
+    display: grid;
+    grid-template-columns: 1fr 0.5fr 2fr;
+
+    .login {
+        button {
             width: 100%;
+        }
+    }
 
-	display: flex;
+
+}
+
+.info {
+    display: grid;
+    grid-template-columns: 1fr 1fr;
+
+    section {
+        margin-bottom: var(--spacing);
+    }
+
+    .contact {
+        text-align: center;
+    }
+}
+
+.alt-text, .alt {
+    font-family: var(--secondary-font-family);
+    // font-size: var(--small-font-size);
+    text-transform: uppercase;
+}
+
+article {
+    background-color: var(--background-1);
+
+    button {
+        border-color: var(--background-2);
+    }
+}
+
+.search {
+    display: grid;
+    grid-template-columns: 1fr 0.5fr 2fr;
+
+    article {
+        display: grid;
+        padding: var(--spacing);
+        margin-bottom: var(--spacing);
+        grid-template-columns: 1fr 4fr 1fr;
+    }
+
+    button {
+        margin-right: var(--spacing);
+        background: var(--background-2);
+        border-color: var(--background-1);
+
+        &.added {
+            background: var(--color-green);
+            cursor: auto;
+        }
+    }
+}
+
+.list {
+    display: grid;
+    grid-template-columns:
+        1fr 1fr 1fr;
+
+    grid-row-gap: var(--spacing);
+    grid-column-gap: var(--spacing);
+
+    article {
+        display: grid;
+
+        // grid-template-rows:
+        //     1fr min-content min-content;
+
+        grid-template-areas:
+            "title img"
+            "details details"
+            "remove remove";
+
+        button {
+            margin-top: var(--spacing-half);
+            grid-area: remove
+        }
+
+        .details {
+            grid-area: details;
+        }
+
+        padding: var(--spacing);
+    }
+}
+
+form {
+    margin-bottom: var(--spacing);
+
+    label, input {
+        display: block;
+    }
+
+    input, button {
+        width: 100%;
+    }
+
+    input {
+        padding: var(--spacing-half);
+        margin-bottom: var(--spacing);
+    }
+
+    label {
+        font-family: var(--secondary-font-family);
+        font-size: var(--small-font-size);
+        text-transform: uppercase;
+        margin-bottom: var(--spacing-half);
+    }
+
+}
+
+a {
+    color: var(--secondary-font-color);
+    font-family: var(--secondary-font-family);
+    text-transform: uppercase;
+
+    &:hover {
+        color: var(--fg-color);
+    }
+}
+
+nav {
+    a {
+        font-size: var(--small-font-size);
+        margin-right: var(--spacing);
+    }
+}
+
+
+header {
+    display: grid;
+    grid-template-columns: 1fr 1fr min-content;
+    padding-bottom: var(--spacing);
+
+    a {
+        white-space: nowrap;
+    }
+}
+
+.bundles {
+    flex-flow: row;
 
     .bundle {
-		flex: 1;
+        margin-bottom: var(--spacing-double);
+
+        section {
+            margin-bottom: var(--spacing);
+        }
+
+        .items {
+            display: grid;
+            grid-template-columns: repeat(5, 1fr);
+
+            div {
+                margin-right: var(--spacing);
+                margin-bottom: var(--spacing);
+
+                display: grid;
+
+                &.bold {
+                    font-weight: bold;
+                    background: var(--background-2);
+                }
+            }
+        }
     }
 }
 
-.profile {
+.offers {
-	padding: 56px 20px;
+    display: grid;
-	min-height: 100%;
+    grid-template-columns: 1fr 1fr;
-	width: 100%;
-}
 
-.header {
+    .offer {
-	position: fixed;
+        display: grid;
-	left: 0;
+        grid-template-columns: 1fr min-content;
-	top: 0;
+        grid-template-rows: 1fr min-content;
-	width: 100%;
+        grid-template-areas:
-	height: 56px;
+            "details img"
-	padding: 0;
+            "lines lines";
-	background: #673AB7;
-	box-shadow: 0 0 5px rgba(0, 0, 0, 0.5);
-	z-index: 50;
-}
 
-.header {
+        padding: var(--spacing);
-	h1 {
+        margin: var(--spacing-half);
-		float: left;
+        background: var(--background-1);
-		margin: 0;
+
-		padding: 0 15px;
+        section {
-		font-size: 24px;
+            grid-area: details;
-		line-height: 56px;
-		font-weight: 400;
-		color: #FFF;
         }
 
-	nav {
+        img {
-		float: right;
+            grid-area: img;
-		font-size: 100%;
+            justify-self: end;
+            margin-left: var(--spacing-half);
         }
 
-	nav a {
+        .lines {
-		display: inline-block;
+            grid-area: lines;
-		height: 56px;
+            display: flex;
-		line-height: 56px;
+            flex-wrap: wrap;
-		padding: 0 15px;
+            column-gap: var(--spacing-half);
-		min-width: 50px;
+
-		text-align: center;
+            button {
-		background: rgba(255,255,255,0);
+                margin-top: var(--spacing-half);
-		text-decoration: none;
+                border-color: var(--background-2);
-		color: #FFF;
+
-		will-change: background-color;
+                &.accepted {
+                    background: var(--color-accepted);
                 }
 
-	nav a:hover,
+                &.confirmed {
-	nav a:active {
+                    cursor: auto;
-		background: rgba(0,0,0,0.2);
+                    background: var(--color-confirmed);
                 }
 
-	nav a.active {
+                &.neg {
-		background: rgba(0,0,0,0.4);
+                    margin-left: var(--spacing-half);
+                }
+            }
+        }
     }
 }
 
+.number {
+    font-family: var(--secondary-font-family);
+    text-transform: uppercase;
+}

client/src/ws.ts

@@ -0,0 +1,161 @@
+import { wantsState, wsState, userState, offersState, acpOffersState } from './store'
+
+const SOCKET_URL = `${window.location.protocol === 'https:' ? 'wss://' : 'ws://'}${window.location.host}/api/ws`;
+
+export default function createSocket(dispatch) {
+    let ws;
+
+    // -------------
+    //   Outgoing
+    // -------------
+    function send(msg) {
+        if (msg[0] !== 'Ping') console.log('outgoing msg', msg);
+        if (ws.readyState !== 1) return false;
+        try {
+            ws.send(JSON.stringify(msg));
+        } catch (e) {
+            console.warn(e);
+        }
+    }
+
+    // let ping;
+    function sendPing() {
+        // ping = Date.now();
+        send(['Ping', {}]);
+
+        // setTimeout(sendPing, 50);
+    }
+
+    function sendOfferStatusSet(id, status) {
+        send(['OfferStatusSet', { id, status }]);
+    }
+
+    function sendWantRm(id) {
+        send(['WantRm', { id }]);
+    }
+
+    function sendOffers() {
+        send(['Offers', {}]);
+    }
+
+    function sendWants() {
+        send(['Wants', {}]);
+    }
+
+    function sendAcpOffers() {
+        send(['AcpOffers', {}]);
+    }
+
+    function sendAcpOfferStatusSet(id, status) {
+        send(['AcpOfferStatusSet', { id, status }]);
+    }
+
+    let pongTimeout;
+    function onPong() {
+        pongTimeout = setTimeout(sendPing, 5000);
+    }
+
+    // -------------
+    //   Incoming
+    // -------------
+    function onUser(user) {
+        dispatch(userState.actions.set(user));
+    }
+
+    function onWants(wants) {
+        dispatch(wantsState.actions.set(wants));
+    }
+
+    function onOffers(offers) {
+        dispatch(offersState.actions.set(offers));
+    }
+
+    function onAcpOffers(offers) {
+        dispatch(acpOffersState.actions.set(offers));
+    }
+
+    // -------------
+    //   Setup
+    // -------------
+    // when the server sends a reply it will have one of these message types
+    // this object wraps the reply types to a function
+    const handlers = {
+        Wants: onWants,
+        Offers: onOffers,
+        User: onUser,
+
+        AcpOffers: onAcpOffers,
+
+        Pong: onPong,
+        Error: errHandler,
+    };
+
+    function errHandler(error) {
+        // store.dispatch(http.LIBRARY_EVENT, { level: 'error', log: error });
+        console.error(error);
+    }
+
+    function onMessage(event) {
+        const res = event.data;
+        const [msgType, params] = JSON.parse(res);
+        if (msgType !== 'Pong') {
+            console.log(msgType, params);
+        }
+
+        // check for error and split into response type and data
+        if (!handlers[msgType]) return console.error(`${msgType} handler missing`);
+        return handlers[msgType](params);
+    }
+
+    // Connection opened
+    function onOpen() {
+        console.log('websocket connected', SOCKET_URL)
+        sendPing();
+        sendAcpOffers();
+        sendOffers();
+        sendWants();
+    }
+
+    function onError(event) {
+        console.error('WebSocket error', event);
+    }
+
+    function onClose(event) {
+        console.error('WebSocket closed', event);
+        return setTimeout(connect, 2000);
+    }
+
+    function connect() {
+        if (ws) {
+            clearTimeout(pongTimeout);
+            ws.removeEventListener('open', onOpen);
+            ws.removeEventListener('message', onMessage);
+            ws.removeEventListener('error', onError);
+            ws.removeEventListener('close', onClose);
+            ws = null;
+        }
+
+        console.log('connecting to websocket', SOCKET_URL);
+        ws = new WebSocket(SOCKET_URL);
+
+        // Listen for messages
+        ws.addEventListener('open', onOpen);
+        ws.addEventListener('message', onMessage);
+        ws.addEventListener('error', onError);
+        ws.addEventListener('close', onClose);
+
+        return ws;
+    }
+
+    return {
+        connect,
+
+        sendOfferStatusSet,
+        sendWantRm,
+
+        sendOffers,
+
+        sendAcpOffers,
+        sendAcpOfferStatusSet,
+    };
+}

docker-compose.MCRATES.yaml

@@ -0,0 +1,35 @@
+version: "3.3"
+
+services:
+  pg:
+    image: postgres:latest
+    environment:
+      POSTGRES_USER: 'mcrates'
+      POSTGRES_DB: 'mcrates'
+      POSTGRES_PASSWORD: 'digdeep'
+
+    # allow prisma client to push changes from outside docker etc
+    # ufw blocks this from being publicly accessible
+    ports:
+      - '45432:5432'
+    volumes:
+      - "./db:/var/lib/postgresql/data"
+
+  api:
+    image: node:16
+    working_dir: /opt/mcrates/api
+    entrypoint: npm start
+    environment:
+      DATABASE_URL: 'postgresql://mcrates:digdeep@pg:5432/mcrates?schema=public'
+    volumes:
+      - "./api:/opt/mcrates/api"
+
+  nginx:
+    image: nginx:latest
+    volumes:
+      - './nginx/matescrates.au.nginx.conf:/etc/nginx/conf.d/default.conf'
+      - './client/build:/srv/matescrates'
+      - '/etc/letsencrypt:/etc/letsencrypt'
+    ports:
+      - '80:80'
+      - '443:443'

docker-compose.TEST.yaml

@@ -0,0 +1,21 @@
+version: "3.3"
+
+services:
+  pg:
+    image: postgres:latest
+    environment:
+      POSTGRES_USER: 'mcrates'
+      POSTGRES_DB: 'test'
+      POSTGRES_PASSWORD: 'digdeep'
+
+  api:
+    image: node:16
+    working_dir: /opt/mcrates/api
+    entrypoint: npm run test:watch
+    depends_on:
+      - pg
+    environment:
+      DATABASE_URL: "postgresql://mcrates:digdeep@pg:5432/test?schema=public"
+    volumes:
+      - "./api:/opt/mcrates/api"
+

docker-compose.yaml

@@ -0,0 +1,43 @@
+version: "3.3"
+
+services:
+  pg:
+    image: postgres:latest
+    environment:
+      POSTGRES_USER: 'mcrates'
+      POSTGRES_DB: 'mcrates'
+      POSTGRES_PASSWORD: 'digdeep'
+    ports:
+      - '45432:5432'
+    volumes:
+      - "./db:/var/lib/postgresql/data"
+
+  api:
+    image: node:16
+    working_dir: /opt/mcrates/api
+    depends_on:
+      - 'pg'
+    entrypoint: npm start
+    environment:
+      DATABASE_URL: 'postgresql://mcrates:digdeep@pg:5432/mcrates?schema=public'
+    volumes:
+      - "./api:/opt/mcrates/api"
+
+  client:
+    image: node:16
+    working_dir: /opt/mcrates/client
+    entrypoint: npm start
+    ports:
+      - '8080:8080' # fwd the hmr websocket
+    volumes:
+      - "./client:/opt/mcrates/client"
+      - "./api:/opt/mcrates/api"
+
+  nginx:
+    image: nginx:latest
+    depends_on:
+      - 'api'
+    volumes:
+      - './nginx/localhost.nginx.conf:/etc/nginx/conf.d/default.conf'
+    ports:
+      - '80:80'

nginx/localhost.nginx.conf

@@ -0,0 +1,34 @@
+upstream mcrates_api {
+    server api:41337;
+}
+
+upstream mcrates_client {
+    server client:8080;
+}
+
+map $http_upgrade $connection_upgrade {
+    default upgrade;
+    '' close;
+}
+
+server {
+    location / {
+        proxy_pass http://mcrates_client;
+        proxy_read_timeout 600s;
+    }
+
+    location /api/ws {
+        proxy_pass http://mcrates_api;
+        proxy_http_version 1.1;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection $connection_upgrade;
+        proxy_set_header Host $host;
+        proxy_read_timeout 600s;
+    }
+
+    location /api/ {
+        # trailing slash means api will receive url WITHOUT /api
+        proxy_pass http://mcrates_api/;
+        proxy_read_timeout 600s;
+    }
+}

nginx/matescrates.au.nginx.conf

@@ -0,0 +1,54 @@
+upstream mcrates_api {
+    server api:41337;
+}
+
+map $http_upgrade $connection_upgrade {
+    default upgrade;
+    '' close;
+}
+
+server {
+    server_name matescrates.au;
+
+    gzip on;
+    gzip_vary on;
+    gzip_proxied any;
+    gzip_comp_level 6;
+    gzip_types text/plain text/css text/xml application/json application/javascript application/xml+rss application/atom+xml image/svg+xml;
+
+    location / {
+        root /srv/matescrates;
+        index index.html;
+        try_files $uri $uri/ index.html;
+    }
+
+    location /api/ws {
+        proxy_pass http://mcrates_api;
+        proxy_http_version 1.1;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection $connection_upgrade;
+        proxy_set_header Host $host;
+        proxy_read_timeout 600s;
+    }
+
+    location /api/ {
+        # trailing slash means api will receive url WITHOUT /api
+        proxy_pass http://mcrates_api/;
+        proxy_read_timeout 600s;
+    }
+
+    error_page 404 /;
+
+    listen [::]:443 ssl ipv6only=on; # managed by Certbot
+    listen 443 ssl; # managed by Certbot
+    ssl_certificate /etc/letsencrypt/live/matescrates.au/fullchain.pem; # managed by Certbot
+    ssl_certificate_key /etc/letsencrypt/live/matescrates.au/privkey.pem; # managed by Certbot
+    include /etc/letsencrypt/options-ssl-nginx.conf; # managed by Certbot
+    ssl_dhparam /etc/letsencrypt/ssl-dhparams.pem; # managed by Certbot
+}
+
+# http -> https
+server {
+    server_name matescrates.au;
+    return 301 https://$host$request_uri;
+}

server/docker-compose.yaml

@@ -1,13 +0,0 @@
-version: "3.3"
-
-services:
-  pg:
-    image: postgres:latest
-    environment:
-      POSTGRES_USER: 'mcrates'
-      POSTGRES_DB: 'mcrates'
-      POSTGRES_PASSWORD: 'digdeep'
-    ports:
-      - '45432:5432'
-    volumes:
-      - "./db:/var/lib/postgresql/data"

server/index.ts

@@ -1,74 +0,0 @@
-import fs from 'fs/promises';
-import _ from 'lodash';
-import Bunyan from 'bunyan';
-import { PrismaClient } from '@prisma/client'
-import Promise from "bluebird";
-
-import discogsService from './src/discogs';
-import pgService from './src/pg';
-import { logAxiosError } from './src/utils';
-import createLog from './src/log';
-import createApi from './src/api';
-
-async function start(log) {
-    const prisma = new PrismaClient();
-    const pg = pgService(log, prisma);
-    const discogs = discogsService(log, pg);
-    const api = createApi(log, pg);
-
-    const usernames = [
-        'vanderbabe',
-        'margh',
-        'jmcdermid1',
-    ];
-
-    async function populateUserListings(user) {
-        log.info(user);
-        const wants = await discogs.wantlist(user);
-
-        // const latest = await discogs.wantlistLatest(user);
-        // if (wants.length !== latest.length)
-        log.info({ username: user.discogs, wantCount: wants.length });
-
-        return Promise.mapSeries(wants, async want => {
-            const listings = await discogs.listings(want);
-            const populated = listings.filter(l => l);
-            log.info({ id: want.id, release: want.release, populated: populated.length, total: listings.length });
-            return populated;
-        });
-    }
-
-    // await Promise.mapSeries(usernames, async u => {
-    //     const user = await discogs.user(u)
-    //     return populateUserListings(user);
-    // });
-
-    await api.listen();
-
-    // return getBundles();
-}
-
-async function run() {
-    const log = createLog();
-
-    process.on('SIGTERM', () => {
-      log.debug('SIGTERM received, exiting');
-      process.exit(0);
-    });
-
-    try {
-        const r = await start(log)
-        // log.info('done syncing', { totalListings: r.flat().length });
-        log.info(r);
-        setTimeout(run, 60 * 1000);
-    } catch (e) {
-        if (e.message === 'rate limited') {
-            log.info('rate limited, trying again in 60s');
-            return setTimeout(run, 60 * 1000);
-        }
-        log.error(e);
-        process.exit(1);
-    }
-}
-
-run();

server/package.json

@@ -1,31 +0,0 @@
-{
-  "name": "mates-crates",
-  "version": "1.0.0",
-  "description": "",
-  "main": "index.js",
-  "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1",
-    "migrate": "knex migrate:latest",
-    "migrate:make": "prisma migrate dev --name",
-    "start": "ts-node-dev --respawn --transpile-only index.ts | bunyan -o short"
-  },
-  "author": "",
-  "license": "ISC",
-  "devDependencies": {
-    "@types/bluebird": "^3.5.36",
-    "@types/lodash": "^4.14.182",
-    "node-dev": "^7.4.3",
-    "prisma": "^4.1.0",
-    "ts-node-dev": "^2.0.0",
-    "typescript": "^4.7.4"
-  },
-  "dependencies": {
-    "@prisma/client": "^4.1.0",
-    "axios": "^0.27.2",
-    "bluebird": "^3.7.2",
-    "bunyan": "^1.8.15",
-    "cors": "^2.8.5",
-    "express": "^4.18.1",
-    "lodash": "^4.17.21"
-  }
-}

server/prisma/schema.prisma

@@ -1,51 +0,0 @@
-generator client {
-    provider = "prisma-client-js"
-    previewFeatures = ["interactiveTransactions"]
-}
-
-datasource db {
-    provider = "postgresql"
-    url      = env("DATABASE_URL")
-}
-
-model Listing {
-    id         Int      @id
-    seller     Int
-    data       Json
-
-    wantId     String   @db.Uuid
-    want       Want     @relation(fields: [wantId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-
-    createdAt  DateTime @default(now())
-    updatedAt  DateTime @updatedAt
-
-    @@index([seller])
-}
-
-model User {
-    id         String     @id       @default(dbgenerated("gen_random_uuid()")) @db.Uuid
-    discogs    String?    @unique
-    data       Json
-
-    createdAt  DateTime   @default(now())
-    updatedAt  DateTime   @updatedAt
-
-    wants      Want[]
-}
-
-model Want {
-    id         String     @id       @default(dbgenerated("gen_random_uuid()")) @db.Uuid
-    release    Int?
-    data       Json
-
-    userId     String     @db.Uuid
-    user       User       @relation(fields: [userId], references: [id], onDelete: Cascade, onUpdate: Cascade)
-
-    createdAt  DateTime   @default(now())
-    updatedAt  DateTime   @updatedAt
-
-    listings   Listing[]
-
-    @@unique([userId, release])
-    @@index([release])
-}

server/src/api.ts

@@ -1,84 +0,0 @@
-import express from 'express';
-import http from 'http';
-import cors from 'cors';
-import { groupBy } from 'lodash';
-
-import type Log from 'bunyan';
-
-import { Pg } from './pg';
-import type { Listing, User, Prisma } from '@prisma/client';
-
-export default function createApi(log: Log, pg: Pg) {
-    const PORT = 41337;
-
-    const app = express();
-    const server = http.createServer(app);
-
-    interface ListingData extends Listing {
-        data: any,
-        want: { user: User },
-    };
-
-    async function getBundles() {
-        const bundles = await pg.bundleCandidates();
-
-        return bundles.map((b: ListingData[]) => {
-            const total = b.reduce((acc, l) => acc + l.data.original_price.value, 0);
-
-            const items = b.map(l => ({
-                id: l.data.id,
-                description: l.data.release.description,
-                price: l.data.original_price.value,
-                currency: l.data.original_price.curr_abbr,
-                condition: l.data.condition,
-                uri: l.data.uri,
-                user: l.want.user.discogs,
-            }));
-
-            const shipping = b[0]?.data.seller.shipping;
-
-            console.log(b.map(l => l.data));
-
-            const bundle = {
-                username: b[0]?.data.seller.username,
-                seller: b[0]?.data.seller.id,
-                shipsFrom: b[0]?.data.ships_from,
-                total,
-                currency: b[0]?.data.original_price.curr_abbr,
-                shipping: '...',
-                items,
-                mentionsAustralia: shipping.toLowerCase().includes('australia'),
-                mentionsWorldwide: shipping.toLowerCase().includes('world'),
-            }
-
-            log.info(bundle);
-            return bundle;
-        });
-    }
-
-
-    function listen() {
-        return new Promise((resolve, reject) => {
-            server.on('error', err => {
-                reject(err);
-            })
-
-            server.listen(PORT, () => {
-                log.info('listening', { PORT });
-            });
-        });
-    }
-
-    app.use(cors());
-
-    app.get('/bundles', async (req, res, next) => {
-        const bundles = await getBundles();
-        // log.info(bundles);
-        res.json(bundles);
-    })
-
-    return {
-        app,
-        listen,
-    };
-}

server/src/pg.ts

@@ -1,148 +0,0 @@
-import type Log from 'bunyan';
-import type { PrismaClient, Want, User, Listing, Prisma } from '@prisma/client';
-import * as Bluebird from 'bluebird';
-
-export interface Pg {
-    userFindId:         (id: UUID) => Promise<User>,
-    userFindName:       (name: DiscogsName) => Promise<User>,
-    userUpsert:         (user: User) => Promise<User>,
-    userWants:          (user: User) => Promise<Want[]>,
-
-    wantUpsert:         (want: Want, user: User) => Promise<Want>,
-    listingUpsert:      (listing: Listing, want: Want) => Promise<Listing>,
-    listingFind:        (id: DiscogsListing) => Promise<Listing>,
-    listingRmUnlisted:  (want: Want, ids: DiscogsListing[]) => Promise<number>,
-
-    bundleCandidates:   () => Promise<Listing[][]>,
-}
-
-export default function createPg(log: Log, prisma: PrismaClient): Pg {
-    async function userFindId(id) {
-        return prisma.user.findUnique({ where: { id }});
-    }
-
-    async function userFindName(name: DiscogsName) {
-        return prisma.user.findUnique({ where: { discogs: name }});
-    }
-
-    async function userWants(user: User) {
-        return prisma.want.findMany({ where: { userId: user.id }});
-    }
-
-    async function userUpsert(user) {
-        const data = {
-            discogs: user.username,
-            data: user as Prisma.JsonObject,
-        };
-
-        return prisma.user.upsert({
-          where: {
-            discogs: user.username,
-          },
-          update: data,
-          create: data,
-        });
-    }
-
-    async function wantUpsert(dcWant, user) {
-        const values: { userId: UUID, release: DiscogsListing, data: any } = {
-            data: dcWant,
-            release: dcWant.id,
-            userId: user.id,
-        };
-
-        return prisma.want.upsert({
-            // get these from the generated types
-            // ./node_modules/.prisma/client/index.d.ts
-            where: { userId_release: {
-                userId: values.userId,
-                release: values.release || null,
-            }},
-            update: values,
-            create: values,
-        });
-    }
-
-    async function listingRmUnlisted(want: Want, ids: DiscogsListing[]) {
-        const { count } = await prisma.listing.deleteMany({
-            where: {
-                wantId: want.id,
-                id: {
-                    notIn: ids,
-                }
-            }
-        });
-
-        return count;
-    }
-
-    async function listingUpsert(listing, want) {
-        const values = {
-            id: listing.id,
-            wantId: want.id,
-            seller: listing.seller.id,
-            data: listing,
-        };
-
-        return prisma.listing.upsert({
-            where: {
-                id: listing.id
-            },
-            update: values,
-            create: values,
-        });
-    }
-
-    async function listingFind(id: DiscogsListing) {
-        return prisma.listing.findUnique({
-            where: {
-                id,
-            },
-            include: {
-                want: {
-                    include: { user: true },
-                }
-            }
-        });
-    }
-
-    async function bundleCandidates(): Promise<Listing[][]> {
-        const candidates = await prisma.$queryRaw`
-            select
-                seller, count(distinct("wantId")), array_agg(id) as listings
-            from
-                "Listing"
-            group by
-                seller
-            order by
-                count desc
-            limit 5;
-        ` as BundleCandidate[];
-
-        return Promise.all(candidates.map(async c => prisma.listing.findMany({
-            where: {
-                id: { in: c.listings }
-            },
-            include: {
-                want: {
-                    include: { user: true },
-                }
-            },
-            distinct: ['wantId'],
-        })));
-    }
-
-    return {
-        userFindId,
-        userFindName,
-        userUpsert,
-        userWants,
-
-        wantUpsert,
-        listingUpsert,
-        listingFind,
-        listingRmUnlisted,
-
-        bundleCandidates,
-    };
-}