WIP: Add isStarred column to database

guardian · Sep 15, 2023 · 6e125dc · 6e125dc
1 parent 46861fd
commit 6e125dc
Show file tree

Hide file tree

Showing 12 changed files with 75 additions and 25 deletions.
diff --git a/cdk/lib/__snapshots__/stack.test.ts.snap b/cdk/lib/__snapshots__/stack.test.ts.snap
@@ -2268,6 +2268,7 @@ type Mutation {
   editItem(itemId: String!, input: EditItemInput!): Item
   deleteItem(itemId: String!): Item
   claimItem(itemId: String!): Claimed
+  setIsStarred(itemId: String!, isStarred: Boolean!): Item
   seenItem(input: LastItemSeenByUserInput!): LastItemSeenByUser
   setWebPushSubscriptionForUser(webPushSubscription: AWSJSON): MyUser
   addManuallyOpenedPinboardIds(pinboardId: String!, maybeEmailOverride: String): MyUser
@@ -2278,7 +2279,7 @@ type Mutation {
 type Subscription {
   onMutateItem(
     pinboardId: String
-  ): Item @aws_subscribe(mutations: [\\"createItem\\", \\"editItem\\", \\"deleteItem\\"])
+  ): Item @aws_subscribe(mutations: [\\"createItem\\", \\"editItem\\", \\"deleteItem\\", \\"setIsStarred\\"])
 
   onClaimItem(
     pinboardId: String
@@ -2313,6 +2314,7 @@ type Item {
   relatedItemId: String
   editHistory: [AWSDateTime!]
   deletedAt: AWSDateTime
+  isStarred: Boolean!
 }
 
 type LastItemSeenByUser {
@@ -2467,7 +2469,7 @@ type PinboardIdWithItemCounts {
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "addManuallyOpenedPinboardIds",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2488,7 +2490,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "claimItem",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2509,7 +2511,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "createItem",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2530,7 +2532,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "deleteItem",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2551,7 +2553,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "editItem",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2572,7 +2574,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "removeManuallyOpenedPinboardIds",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2593,7 +2595,28 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "seenItem",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
+$util.toJson($ctx.result)",
+        "TypeName": "Mutation",
+      },
+      "Type": "AWS::AppSync::Resolver",
+    },
+    "pinboardappsyncapidatabasebridgelambdadsMutationsetIsStarredResolver7A053545": Object {
+      "DependsOn": Array [
+        "pinboardappsyncapidatabasebridgelambdads970CB9A7",
+        "pinboardappsyncapiSchema868D9F5B",
+      ],
+      "Properties": Object {
+        "ApiId": Object {
+          "Fn::GetAtt": Array [
+            "pinboardappsyncapi9D519400",
+            "ApiId",
+          ],
+        },
+        "DataSourceName": "database_bridge_lambda_ds",
+        "FieldName": "setIsStarred",
+        "Kind": "UNIT",
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2614,7 +2637,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "setWebPushSubscriptionForUser",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2635,7 +2658,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "visitTourStep",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Mutation",
       },
@@ -2656,7 +2679,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "getGroupPinboardIds",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2677,7 +2700,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "getItemCounts",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2698,7 +2721,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "getMyUser",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2719,7 +2742,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "getUsers",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2740,7 +2763,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "listItems",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2761,7 +2784,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "listLastItemSeenByUsers",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2782,7 +2805,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "database_bridge_lambda_ds",
         "FieldName": "searchMentionableUsers",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2907,7 +2930,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "grid_bridge_lambda_ds",
         "FieldName": "asGridPayload",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -2928,7 +2951,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "grid_bridge_lambda_ds",
         "FieldName": "getGridSearchSummary",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -3053,7 +3076,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "workflow_bridge_lambda_ds",
         "FieldName": "getPinboardByComposerId",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -3074,7 +3097,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "workflow_bridge_lambda_ds",
         "FieldName": "getPinboardsByIds",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },
@@ -3095,7 +3118,7 @@ $util.toJson($ctx.result)",
         "DataSourceName": "workflow_bridge_lambda_ds",
         "FieldName": "listPinboards",
         "Kind": "UNIT",
-        "ResponseMappingTemplate": "## schema checksum : aa02bae16942e48366fa36a1cd643d16
+        "ResponseMappingTemplate": "## schema checksum : b72f387aabaad7462e0e00a8ab981ffc
 $util.toJson($ctx.result)",
         "TypeName": "Query",
       },

diff --git a/client/gql.ts b/client/gql.ts
@@ -68,6 +68,7 @@ const itemReturnFields = `
   relatedItemId
   editHistory
   deletedAt
+  isStarred
 `;
 
 // TODO: consider updating the resolver (cdk/stack.ts) to use a Query with a secondary index (if performance degrades when we have lots of items)

diff --git a/client/src/starred/starredMessages.tsx b/client/src/starred/starredMessages.tsx
@@ -3,9 +3,9 @@ import ReactDOM from "react-dom";
 
 export const STARRED_MESSAGES_HTML_TAG = "pinboard-starred-messages";
 
-interface StarredMessagesProps {}
+// interface StarredMessagesProps {}
 
-const StarredMessages = (props: StarredMessagesProps) => (
+const StarredMessages = (/* props: StarredMessagesProps */) => (
   <div>
     <p>Starred Messages</p>
   </div>

diff --git a/client/src/tour/tourMessageReplies.ts b/client/src/tour/tourMessageReplies.ts
@@ -29,6 +29,7 @@ const buildMessageItem = (
   claimedByEmail: null,
   claimable: false,
   pinboardId: demoPinboardData.id,
+  isStarred: false,
 });
 
 export const replyTo = (

diff --git a/client/src/tour/tourState.tsx b/client/src/tour/tourState.tsx
@@ -302,6 +302,7 @@ export const TourStateProvider: React.FC = ({ children }) => {
         })),
         groupMentions: [], //TODO - map variables.input.groupMentions to mention handle,
         claimable: variables.input.claimable || false,
+        isStarred: false,
       };
       setSuccessfulSends((prevSuccessfulSends) => [
         ...prevSuccessfulSends,

diff --git a/database-bridge-lambda/src/index.ts b/database-bridge-lambda/src/index.ts
@@ -10,6 +10,7 @@ import {
   getGroupPinboardIds,
   getItemCounts,
   listItems,
+  setIsStarred,
 } from "./sql/Item";
 import { Sql } from "../../shared/database/types";
 import { listLastItemSeenByUsers, seenItem } from "./sql/LastItemSeenByUser";
@@ -42,6 +43,8 @@ const run = (
       return deleteItem(sql, args, userEmail);
     case "claimItem":
       return claimItem(sql, args, userEmail);
+    case "setIsStarred":
+      return setIsStarred(sql, args, userEmail);
     case "listItems":
       return listItems(sql, args, userEmail);
     case "seenItem":

diff --git a/database-bridge-lambda/src/sql/Item.ts b/database-bridge-lambda/src/sql/Item.ts
@@ -143,6 +143,19 @@ export const claimItem = (
     };
   });
 
+export const setIsStarred = async (
+  sql: Sql,
+  args: { itemId: string; isStarred: boolean },
+  userEmail: string
+) =>
+  sql`
+        UPDATE "Item"
+        SET 
+            "isStarred" = ${args.isStarred}
+        WHERE "id" = ${args.itemId}
+        RETURNING ${fragmentItemFields(sql, userEmail)}
+    `.then((rows) => rows[0]);
+
 export const getGroupPinboardIds = async (
   sql: Sql,
   userEmail: string

diff --git a/notifications-lambda/run.ts b/notifications-lambda/run.ts
@@ -40,6 +40,7 @@ import { Item } from "shared/graphql/graphql";
       relatedItemId: null,
       editHistory: null,
       deletedAt: null,
+      isStarred: false,
     } satisfies Item,
     users: [yourUser as UserWithWebPushSubscription],
   });

diff --git a/shared/database/local/runDatabaseSetup.ts b/shared/database/local/runDatabaseSetup.ts
@@ -85,6 +85,8 @@ const runSetupTriggerSqlFile = (
           getEmailLambdaFunctionName(stage),
           EMAIL_DATABASE_TRIGGER_NAME
         ),
+    "add isStarred column to Item table": () =>
+      runSetupSqlFile(sql, "020-AddIsStarredColumnToItemTable.sql"),
   };
 
   const allSteps = async () => {

diff --git a/shared/database/local/setup/020-AddIsStarredColumnToItemTable.sql b/shared/database/local/setup/020-AddIsStarredColumnToItemTable.sql
@@ -0,0 +1,2 @@
+ALTER TABLE "Item"
+    ADD COLUMN "isStarred" BOOLEAN NOT NULL DEFAULT FALSE;
diff --git a/shared/graphql/operations.ts b/shared/graphql/operations.ts
@@ -33,6 +33,7 @@ export const MUTATIONS = {
     "editItem",
     "deleteItem",
     "claimItem",
+    "setIsStarred",
     "seenItem",
     "setWebPushSubscriptionForUser",
     "addManuallyOpenedPinboardIds",

diff --git a/shared/graphql/schema.graphql b/shared/graphql/schema.graphql
@@ -27,6 +27,7 @@ type Mutation {
   editItem(itemId: String!, input: EditItemInput!): Item
   deleteItem(itemId: String!): Item
   claimItem(itemId: String!): Claimed
+  setIsStarred(itemId: String!, isStarred: Boolean!): Item
   seenItem(input: LastItemSeenByUserInput!): LastItemSeenByUser
   setWebPushSubscriptionForUser(webPushSubscription: AWSJSON): MyUser
   addManuallyOpenedPinboardIds(pinboardId: String!, maybeEmailOverride: String): MyUser
@@ -37,7 +38,7 @@ type Mutation {
 type Subscription {
   onMutateItem(
     pinboardId: String
-  ): Item @aws_subscribe(mutations: ["createItem", "editItem", "deleteItem"])
+  ): Item @aws_subscribe(mutations: ["createItem", "editItem", "deleteItem", "setIsStarred"])
 
   onClaimItem(
     pinboardId: String
@@ -72,6 +73,7 @@ type Item {
   relatedItemId: String
   editHistory: [AWSDateTime!]
   deletedAt: AWSDateTime
+  isStarred: Boolean!
 }
 
 type LastItemSeenByUser {
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		ALTER TABLE "Item"
		ADD COLUMN "isStarred" BOOLEAN NOT NULL DEFAULT FALSE;