Minor touches to improve inbox list subscription

richardguerre · Oct 18, 2024 · 2faf93c · 2faf93c
1 parent 9216fb1
commit 2faf93c
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 1 deletion.
diff --git a/apps/server/package.json b/apps/server/package.json
@@ -8,6 +8,7 @@
     "start": "echo \"⚠️ This is still a development server. In production, the server is bundled and served by Bun.\" && echo \"⚠️ This simulates running in production.\" && NODE_ENV=production bun run src/index.ts",
     "type-check": "bun run db:gen && tsc --noEmit && echo '✅ Type checking passed!'",
     "build": "bun build ./src/index.ts --outdir dist --target bun && bun run copy-web && bun run copy-mobile-pwa",
+    "build-push": "bun run build && cd ../.. && bun run cp-build && bun run push-build",
     "preview": "cd dist && NODE_ENV=production PORT=4040 DATABASE_URL=postgres://postgres:postgres@localhost:5432/flow ORIGIN=https://lamporchestra.isflow.in PATH_TO_PLUGINS=../plugins BUN_JSC_forceRAMSize=180000000 bun run index.js",
     "copy-web": "rm -rf ./dist/web && cp -r ../web/dist ./dist/web && echo '✅ apps/web/dist copied to apps/server/dist/web'",
     "copy-mobile-pwa": "rm -rf ./dist/mobile-pwa && cp -r ../mobile-pwa/dist ./dist/mobile-pwa && echo '✅ apps/mobile-pwa/dist copied to apps/server/dist/mobile-pwa'",

diff --git a/apps/server/src/graphql/Item.ts b/apps/server/src/graphql/Item.ts
@@ -91,7 +91,6 @@ Pass the \`where\` argument to override these defaults.`,
     resolve: (query, _, args) => {
       return prisma.item.findMany({
         ...query,
-        take: undefined, // prevents `query` from overriding `take` and return all items
         where: args.where ?? undefined,
         orderBy: args.orderBy ?? undefined,
       });

diff --git a/apps/server/src/graphql/builder.ts b/apps/server/src/graphql/builder.ts
@@ -100,13 +100,15 @@ export const builder = new SchemaBuilder<{
   smartSubscriptions: {
     subscribe: async ($name, context, callback) => {
       const name = $name as PubSubKeys;
+      console.log("subscribing", name);
       if (!context.subscriptions[name]) context.subscriptions[name] = pubsub.subscribe(name);
       for await (const data of context.subscriptions[name]) {
         callback(undefined, data);
       }
     },
     unsubscribe: ($name, context) => {
       const name = $name as PubSubKeys;
+      console.log("unsubscribing", name);
       context.subscriptions[name]?.return?.();
       delete context.subscriptions[name];
     },

diff --git a/apps/web/src/components/InboxList.tsx b/apps/web/src/components/InboxList.tsx
@@ -58,6 +58,7 @@ const InboxListItems = (props: {
           tasks: { none: { status: { equals: TODO } } }
         }
         orderBy: { inboxPoints: Desc }
+        first: 30
       ) {
         ...InboxListItems_itemsConnection
       }