diff assets

Author: robb-j

api-server/CHANGELOG.md

@@ -2,6 +2,10 @@
 
 This file documents changes to the Deconf API Server.
 
-## 0.1.0
+## 0.1.2
+
+- **new** Stage and diff assets during upsert-schedule
+
+## 0.1.1
 
 🎉 Everything is new!

api-server/source/admin/admin-lib.ts

@@ -1,6 +1,7 @@
 import { HTTPError, SqlDependency, Structure } from "gruber";
 import {
   assertRequestParam,
+  AssetTable,
   ConferenceTable,
   ContentTable,
   LabelTable,
@@ -125,11 +126,17 @@ export async function _assertConferenceData(
     sql`session_id IN ${sql(getRecordIds(sessions))}`,
   );
 
+  const assets = await AssetTable.select(
+    sql,
+    sql`conference_id = ${conference.id}`,
+  );
+
   return {
     conference,
     sessions,
     people,
     content,
+    assets,
 
     taxonomies,
     labels,
@@ -153,7 +160,7 @@ interface Unwraped<T> {
   records: T[];
 }
 
-export interface UnwrapOptions {
+export interface PerformDiffOptions {
   insert?: boolean;
   update?: boolean;
   delete?: boolean;
@@ -174,7 +181,7 @@ export async function _performDiff<
   diff: Differential<T>,
   table: TableDefinition<U>,
   map: (value: T) => Partial<U>,
-  options: UnwrapOptions = {},
+  options: PerformDiffOptions = {},
 ): Promise<Unwraped<U>> {
   const lookup = new Map<string, number>();
   let records: U[] = [];

api-server/source/admin/upsert-schedule.ts

@@ -1,6 +1,8 @@
 import { assertRequestBody, defineRoute, Structure } from "gruber";
 
 import {
+  AssetRecord,
+  AssetTable,
   LabelRecord,
   LabelTable,
   PersonRecord,
@@ -21,12 +23,12 @@ import {
   useStore,
 } from "../lib/mod.ts";
 import {
+  _assertConferenceData,
   _diffRelationship,
   _diffResource,
   _getRelated,
   _performDiff,
   _totalDiffs,
-  _assertConferenceData,
 } from "./admin-lib.ts";
 
 // The shape of the accepted HTTP request body
@@ -47,13 +49,8 @@ const _Request = Structure.object({
   people: Structure.array(
     Structure.object({
       id: Structure.string(),
-      ...PersonTable.fields([
-        "avatar_id",
-        "bio",
-        "name",
-        "subtitle",
-        "metadata",
-      ]),
+      avatar_id: Structure.union([Structure.null(), Structure.string()]),
+      ...PersonTable.fields(["bio", "name", "subtitle", "metadata"]),
     }),
   ),
   sessions: Structure.array(
@@ -94,6 +91,12 @@ const _Request = Structure.object({
       ...SessionLinkTable.fields(["title", "url", "metadata"]),
     }),
   ),
+  assets: Structure.array(
+    Structure.object({
+      id: Structure.string(),
+      ...AssetTable.fields(["title", "url", "metadata"]),
+    }),
+  ),
 });
 
 export const upsertScheduleRoute = defineRoute({
@@ -133,6 +136,8 @@ export const upsertScheduleRoute = defineRoute({
         ["label_id", "session_id"],
         [data.labels, data.sessions],
       ),
+
+      assets: _diffResource(body.assets, "id", data.assets),
     };
 
     // Exit early & output information if the dry run flag was passed in the URL
@@ -188,19 +193,27 @@ export const upsertScheduleRoute = defineRoute({
         }),
       );
 
+      const assets = await _performDiff(
+        trx,
+        diff.assets,
+        AssetTable,
+        (value): Partial<AssetRecord> => ({
+          ...pickProperties(value, ["title", "url", "metadata"]),
+          conference_id: data.conference.id,
+        }),
+        { delete: false },
+      );
+
       const people = await _performDiff(
         trx,
         diff.people,
         PersonTable,
         (value): Partial<PersonRecord> => ({
-          ...pickProperties(value, [
-            "avatar_id",
-            "bio",
-            "name",
-            "subtitle",
-            "metadata",
-          ]),
+          ...pickProperties(value, ["bio", "name", "subtitle", "metadata"]),
           conference_id: data.conference.id,
+          avatar_id: value.avatar_id
+            ? _getRelated(assets.lookup, value.avatar_id)
+            : null,
         }),
       );