feat: read index

src/app/listener.middleware/handler.channels.js

@@ -11,7 +11,7 @@ export default async function handler({ operation, data, payload }) {
         const chs = payload;
         await Promise.all(
           chs.map(({ gid, ...rest }) => {
-            return table.setItem(gid, { gid, ...rest });
+            return table.setItem(gid + "", { gid, ...rest });
           })
         );
       }

src/app/listener.middleware/handler.contacts.js

@@ -11,7 +11,7 @@ export default async function handler({ operation, data, payload }) {
         const contacts = payload;
         await Promise.all(
           contacts.map(({ uid, ...rest }) => {
-            return table.setItem(uid, { uid, ...rest });
+            return table.setItem(uid + "", { uid, ...rest });
           })
         );
       }

src/app/services/channel.js

@@ -75,9 +75,10 @@ export const channelApi = createApi({
       },
     }),
     sendChannelMsg: builder.mutation({
-      query: ({ id, content, type = "text" }) => ({
+      query: ({ id, content, type = "text", properties = "" }) => ({
         headers: {
           "content-type": ContentTypes[type],
+          "X-Properties": properties,
         },
         url: `group/${id}/send`,
         method: "POST",

src/app/services/contact.js

@@ -73,9 +73,10 @@ export const contactApi = createApi({
       }),
     }),
     sendMsg: builder.mutation({
-      query: ({ id, content, type = "text" }) => ({
+      query: ({ id, content, type = "text", properties = "" }) => ({
         headers: {
           "content-type": ContentTypes[type],
+          "X-Properties": properties,
         },
         url: `user/${id}/send`,
         method: "POST",

src/app/services/message.js

@@ -1,5 +1,5 @@
 import { createApi } from "@reduxjs/toolkit/query/react";
-import { batch } from "react-redux";
+// import { batch } from "react-redux";
 
 import { ContentTypes } from "../config";
 import { updateReadChannels, updateReadUsers } from "../slices/footprint";
@@ -57,27 +57,31 @@ export const messageApi = createApi({
         method: "POST",
         body: data,
       }),
-      async onQueryStarted(data, { dispatch, getState, queryFulfilled }) {
-        const { users = [], groups = [] } = data;
-        const { readUsers, readChannels } = getState().footprint.readUsers;
-        const prevUsers = users.map(({ uid }) => {
-          return { uid, mid: readUsers[uid] };
-        });
-        const prevChannels = users.map(({ gid }) => {
-          return { gid, mid: readChannels[gid] };
-        });
-        batch(() => {
-          dispatch(updateReadChannels(groups));
+      async onQueryStarted(data, { dispatch, queryFulfilled }) {
+        const { users = null, groups = null } = data;
+        // const { readUsers, readChannels } = getState().footprint;
+        // const prevUsers = users.map(({ uid }) => {
+        //   return { uid, mid: readUsers[uid] };
+        // });
+        // const prevChannels = users.map(({ gid }) => {
+        //   return { gid, mid: readChannels[gid] };
+        // });
+        // batch(() => {
+        if (users) {
           dispatch(updateReadUsers(users));
-        });
+        }
+        if (groups) {
+          dispatch(updateReadChannels(groups));
+        }
+        // });
         try {
           await queryFulfilled;
         } catch {
           // todo
-          batch(() => {
-            dispatch(updateReadChannels(prevChannels));
-            dispatch(updateReadUsers(prevUsers));
-          });
+          // batch(() => {
+          //   dispatch(updateReadChannels(prevChannels));
+          //   dispatch(updateReadUsers(prevUsers));
+          // });
         }
       },
     }),

src/app/slices/contacts.js

@@ -50,7 +50,10 @@ const contactsSlice = createSlice({
           case "create":
             {
               state.byId[uid] = { uid, ...rest };
-              state.ids.push(uid);
+              const idx = state.ids.findIndex((i) => i == uid);
+              if (idx == -1) {
+                state.ids.push(uid);
+              }
             }
             break;
           case "delete":