add mark notifications as read mutation resolver (#4169)

backend/native/backpack-api/src/routes/graphql/clients/hasura.ts

@@ -82,8 +82,9 @@ export class Hasura {
       throw new GraphQLError("Failed to create new notification");
     }
 
-    return NodeBuilder.notification(resp.insert_auth_notifications_one.id, {
+    return NodeBuilder.notification({
       body: b,
+      dbId: resp.insert_auth_notifications_one.id,
       source,
       title,
       timestamp: timestamp.toISOString(),
@@ -268,8 +269,9 @@ export class Hasura {
 
     // Create the list of notification type nodes for the connection
     const nodes = resp.auth_notifications.map((n) =>
-      NodeBuilder.notification(n.id, {
+      NodeBuilder.notification({
         body: n.body,
+        dbId: n.id,
         source: n.xnft_id,
         timestamp: new Date(n.timestamp as string).toISOString(),
         title: n.title,

backend/native/backpack-api/src/routes/graphql/index.ts

@@ -10,6 +10,7 @@ import {
   friendshipTypeResolvers,
   importPublicKeyMutationResolver,
   jsonObjectScalar,
+  markNotificationsAsReadMutationResolver,
   notificationTypeResolvers,
   sendFriendRequestMutationResolver,
   tokenListQueryResolver,
@@ -28,6 +29,7 @@ const mutationResolvers: MutationResolvers = {
   authenticate: authenticateMutationResolver,
   deauthenticate: deauthenticateMutationResolver,
   importPublicKey: importPublicKeyMutationResolver,
+  markNotificationsAsRead: markNotificationsAsReadMutationResolver,
   sendFriendRequest: sendFriendRequestMutationResolver,
 };
 

backend/native/backpack-api/src/routes/graphql/nodes.ts

@@ -63,11 +63,8 @@ export abstract class NodeBuilder {
     );
   }
 
-  static notification(
-    dbId: unknown,
-    data: Omit<Notification, "id">
-  ): Notification {
-    return this._createNode(`notification:${dbId}`, data);
+  static notification(data: Omit<Notification, "id">): Notification {
+    return this._createNode(`notification:${data.dbId}`, data);
   }
 
   static notificationAppData(

backend/native/backpack-api/src/routes/graphql/resolvers/mutation/index.ts

@@ -1,3 +1,4 @@
 export * from "./authentication";
 export * from "./friendship";
+export * from "./notifications";
 export * from "./wallets";

backend/native/backpack-api/src/routes/graphql/resolvers/mutation/notifications.ts

@@ -0,0 +1,31 @@
+import type { GraphQLResolveInfo } from "graphql";
+
+import { updateNotificationSeen } from "../../../../db/notifications";
+import type { ApiContext } from "../../context";
+import type {
+  MutationMarkNotificationsAsReadArgs,
+  MutationResolvers,
+} from "../../types";
+
+/**
+ * Handler for the mutation to mark a set of notifications as viewed.
+ * @param {{}} _parent
+ * @param {MutationMarkNotificationsAsReadArgs} args
+ * @param {ApiContext} ctx
+ * @param {GraphQLResolveInfo} _info
+ * @returns
+ */
+export const markNotificationsAsReadMutationResolver: MutationResolvers["markNotificationsAsRead"] =
+  async (
+    _parent: {},
+    args: MutationMarkNotificationsAsReadArgs,
+    ctx: ApiContext,
+    _info: GraphQLResolveInfo
+  ): Promise<number> => {
+    // TODO: move implementation into contextual Hasura client
+    const res = await updateNotificationSeen({
+      notificationIds: args.ids,
+      uuid: ctx.authorization.userId ?? "",
+    });
+    return res.update_auth_notifications?.affected_rows ?? 0;
+  };

backend/native/backpack-api/src/routes/graphql/types.ts

@@ -162,6 +162,8 @@ export type Mutation = {
   deauthenticate: Scalars["String"];
   /** Attempt to add a new wallet public key to the user account. */
   importPublicKey?: Maybe<Scalars["Boolean"]>;
+  /** Set the `viewed` status of the argued notification IDs are `true`. */
+  markNotificationsAsRead: Scalars["Int"];
   /** Allows users to send friend requests to another remote user. */
   sendFriendRequest?: Maybe<Scalars["Boolean"]>;
 };
@@ -181,6 +183,11 @@ export type MutationImportPublicKeyArgs = {
   signature: Scalars["String"];
 };
 
+/** Root level mutation type. */
+export type MutationMarkNotificationsAsReadArgs = {
+  ids: Array<Scalars["Int"]>;
+};
+
 /** Root level mutation type. */
 export type MutationSendFriendRequestArgs = {
   accept: Scalars["Boolean"];
@@ -258,6 +265,8 @@ export type Notification = Node & {
   app?: Maybe<NotificationApplicationData>;
   /** Arbitrary body data of the notification parsed as an object. */
   body: Scalars["JSONObject"];
+  /** The database unique integer identifier. */
+  dbId: Scalars["Int"];
   /** Globally unique identifier for a specific notification. */
   id: Scalars["ID"];
   /** The emitting source of the notification. */
@@ -985,6 +994,12 @@ export type MutationResolvers<
       "address" | "providerId" | "signature"
     >
   >;
+  markNotificationsAsRead?: Resolver<
+    ResolversTypes["Int"],
+    ParentType,
+    ContextType,
+    RequireFields<MutationMarkNotificationsAsReadArgs, "ids">
+  >;
   sendFriendRequest?: Resolver<
     Maybe<ResolversTypes["Boolean"]>,
     ParentType,
@@ -1092,6 +1107,7 @@ export type NotificationResolvers<
     ContextType
   >;
   body?: Resolver<ResolversTypes["JSONObject"], ParentType, ContextType>;
+  dbId?: Resolver<ResolversTypes["Int"], ParentType, ContextType>;
   id?: Resolver<ResolversTypes["ID"], ParentType, ContextType>;
   source?: Resolver<ResolversTypes["String"], ParentType, ContextType>;
   timestamp?: Resolver<ResolversTypes["String"], ParentType, ContextType>;

backend/native/backpack-api/src/schema.graphql

@@ -45,6 +45,11 @@ type Mutation {
     signature: String!
   ): Boolean
 
+  """
+  Set the `viewed` status of the argued notification IDs are `true`.
+  """
+  markNotificationsAsRead(ids: [Int!]!): Int!
+
   """
   Allows users to send friend requests to another remote user.
   """
@@ -562,6 +567,11 @@ type Notification implements Node {
   """
   body: JSONObject!
 
+  """
+  The database unique integer identifier.
+  """
+  dbId: Int!
+
   """
   The emitting source of the notification.
   """

packages/data-components/src/apollo/graphql.ts

@@ -156,6 +156,8 @@ export type Mutation = {
   deauthenticate: Scalars["String"];
   /** Attempt to add a new wallet public key to the user account. */
   importPublicKey?: Maybe<Scalars["Boolean"]>;
+  /** Set the `viewed` status of the argued notification IDs are `true`. */
+  markNotificationsAsRead: Scalars["Int"];
   /** Allows users to send friend requests to another remote user. */
   sendFriendRequest?: Maybe<Scalars["Boolean"]>;
 };
@@ -175,6 +177,11 @@ export type MutationImportPublicKeyArgs = {
   signature: Scalars["String"];
 };
 
+/** Root level mutation type. */
+export type MutationMarkNotificationsAsReadArgs = {
+  ids: Array<Scalars["Int"]>;
+};
+
 /** Root level mutation type. */
 export type MutationSendFriendRequestArgs = {
   accept: Scalars["Boolean"];
@@ -252,6 +259,8 @@ export type Notification = Node & {
   app?: Maybe<NotificationApplicationData>;
   /** Arbitrary body data of the notification parsed as an object. */
   body: Scalars["JSONObject"];
+  /** The database unique integer identifier. */
+  dbId: Scalars["Int"];
   /** Globally unique identifier for a specific notification. */
   id: Scalars["ID"];
   /** The emitting source of the notification. */