msw: Implement GET /api/v1/me/updates request handler

Author: Turbo87

packages/crates-io-msw/handlers/versions.js

@@ -1,10 +1,21 @@
 import dependencies from './versions/dependencies.js';
 import downloads from './versions/downloads.js';
+import followUpdates from './versions/follow-updates.js';
 import getVersion from './versions/get.js';
 import listVersions from './versions/list.js';
 import patchVersion from './versions/patch.js';
 import readme from './versions/readme.js';
 import unyankVersion from './versions/unyank.js';
 import yankVersion from './versions/yank.js';
 
-export default [listVersions, getVersion, patchVersion, yankVersion, unyankVersion, dependencies, downloads, readme];
+export default [
+  listVersions,
+  getVersion,
+  patchVersion,
+  yankVersion,
+  unyankVersion,
+  dependencies,
+  downloads,
+  readme,
+  followUpdates,
+];

packages/crates-io-msw/handlers/versions/follow-updates.js

@@ -0,0 +1,28 @@
+import { http, HttpResponse } from 'msw';
+
+import { db } from '../../index.js';
+import { serializeVersion } from '../../serializers/version.js';
+import { pageParams } from '../../utils/handlers.js';
+import { getSession } from '../../utils/session.js';
+
+export default http.get('/api/v1/me/updates', ({ request }) => {
+  let { user } = getSession();
+  if (!user) {
+    return HttpResponse.json({ errors: [{ detail: 'must be logged in to perform that action' }] }, { status: 403 });
+  }
+
+  let allVersions = user.followedCrates
+    .flatMap(crate => db.version.findMany({ where: { crate: { id: { equals: crate.id } } } }))
+    .sort((a, b) => b.id - a.id);
+
+  let { start, end, page, perPage } = pageParams(request);
+
+  let versions = allVersions.slice(start, end);
+  let totalCount = allVersions.length;
+  let totalPages = Math.ceil(totalCount / perPage);
+
+  return HttpResponse.json({
+    versions: versions.map(v => serializeVersion(v)),
+    meta: { more: page < totalPages },
+  });
+});

packages/crates-io-msw/handlers/versions/follow-updates.test.js

@@ -0,0 +1,84 @@
+import { assert, test } from 'vitest';
+
+import { db } from '../../index.js';
+
+test('returns 403 for unauthenticated user', async function () {
+  let response = await fetch('/api/v1/me/updates');
+  assert.strictEqual(response.status, 403);
+  assert.deepEqual(await response.json(), {
+    errors: [{ detail: 'must be logged in to perform that action' }],
+  });
+});
+
+test('returns latest versions of followed crates', async function () {
+  let foo = db.crate.create({ name: 'foo' });
+  db.version.create({ crate: foo, num: '1.2.3' });
+
+  let bar = db.crate.create({ name: 'bar' });
+  db.version.create({ crate: bar, num: '0.8.6' });
+
+  let user = db.user.create({ followedCrates: [foo] });
+  db.mswSession.create({ user });
+
+  let response = await fetch('/api/v1/me/updates');
+  assert.strictEqual(response.status, 200);
+  assert.deepEqual(await response.json(), {
+    versions: [
+      {
+        id: 1,
+        crate: 'foo',
+        crate_size: 162_963,
+        created_at: '2010-06-16T21:30:45Z',
+        dl_path: '/api/v1/crates/foo/1.2.3/download',
+        downloads: 3702,
+        features: {},
+        license: 'MIT',
+        links: {
+          dependencies: '/api/v1/crates/foo/1.2.3/dependencies',
+          version_downloads: '/api/v1/crates/foo/1.2.3/downloads',
+        },
+        num: '1.2.3',
+        published_by: null,
+        readme_path: '/api/v1/crates/foo/1.2.3/readme',
+        rust_version: null,
+        updated_at: '2017-02-24T12:34:56Z',
+        yanked: false,
+        yank_message: null,
+      },
+    ],
+    meta: {
+      more: false,
+    },
+  });
+});
+
+test('empty case', async function () {
+  let user = db.user.create();
+  db.mswSession.create({ user });
+
+  let response = await fetch('/api/v1/me/updates');
+  assert.strictEqual(response.status, 200);
+  assert.deepEqual(await response.json(), {
+    versions: [],
+    meta: { more: false },
+  });
+});
+
+test('supports pagination', async function () {
+  let crate = db.crate.create({ name: 'foo' });
+  Array.from({ length: 25 }, () => db.version.create({ crate }));
+
+  let user = db.user.create({ followedCrates: [crate] });
+  db.mswSession.create({ user });
+
+  let response = await fetch('/api/v1/me/updates?page=2');
+  assert.strictEqual(response.status, 200);
+
+  let responsePayload = await response.json();
+  assert.strictEqual(responsePayload.versions.length, 10);
+  assert.deepEqual(
+    responsePayload.versions.map(it => it.id),
+    [15, 14, 13, 12, 11, 10, 9, 8, 7, 6],
+  );
+  assert.deepEqual(responsePayload.meta, { more: true });
+});