Added filter & simplify schema plugins, get reports route w/ pagination

Author: heythisischris

package.json

@@ -15,13 +15,15 @@
   "dependencies": {},
   "devDependencies": {
     "@fastify/aws-lambda": "^4.0.0",
+    "@graphile-contrib/pg-simplify-inflector": "^6.1.0",
     "@types/node": "^20.12.7",
     "aws-jwt-verify": "^4.0.1",
     "esbuild": "^0.20.1",
     "fastify": "^4.26.2",
     "graphql": "^16.8.1",
     "pg": "^8.11.5",
     "postgraphile": "^4.13.0",
+    "postgraphile-plugin-connection-filter": "^2.3.0",
     "serverless-postgres": "^2.1.0"
   },
   "resolutions": {

src/app.ts

@@ -1,5 +1,5 @@
 import Fastify from 'fastify';
-import { getResults, graphql } from './routes/index.js';
+import { getReports, getResults, graphql } from './routes/index.js';
 import { CognitoJwtVerifier } from 'aws-jwt-verify';
 export const fastify = Fastify({ logger: true });
 const cognitoJwtVerifier = CognitoJwtVerifier.create({
@@ -21,6 +21,7 @@ fastify.addHook('preHandler', async (request, reply) => {
 
 fastify.post('/graphql', {}, async (request, reply) => graphql({ request, reply }));
 fastify.get('/get/results', {}, async (request, reply) => getResults({ request, reply }));
+fastify.get('/get/reports', {}, async (request, reply) => getReports({ request, reply }));
 
 fastify.listen({ port: 3000 }, (err) => {
     console.log(`Server listening on ${fastify.server.address().port}`)

src/routes/getReports.ts

@@ -0,0 +1,29 @@
+import { graphqlQuery } from '../utils/index.js';
+
+export const getReports = async ({ request, reply }) => {
+    const response = (await graphqlQuery({
+        query: `query($first: Int, $offset: Int){
+            reports(first: $first, offset: $offset) { 
+                nodes {
+                    id
+                    title
+                    filters
+                }
+                totalCount
+            }
+        }`,
+        variables: {
+            first: parseInt(request.query.first),
+            offset: parseInt(request.query.offset),
+        },
+    }))?.data;
+
+    return {
+        status: 'success',
+        result: response?.reports?.nodes?.map(obj => ({
+            ...obj,
+            filters: obj?.filters ? JSON.parse(obj?.filters) : null,
+        })),
+        total: response?.reports?.totalCount,
+    };
+}

src/routes/index.ts

@@ -1,2 +1,3 @@
 export * from './getResults.js'
-export * from './graphql.js'
+export * from './graphql.js'
+export * from './getReports.js'

src/utils/graphqlQuery.ts

@@ -1,9 +1,11 @@
 import { graphql as gql } from 'graphql';
 import { withPostGraphileContext, createPostGraphileSchema } from 'postgraphile';
+import PgSimplifyInflectorPlugin from '@graphile-contrib/pg-simplify-inflector';
+import ConnectionFilterPlugin from 'postgraphile-plugin-connection-filter';
 import pg from 'pg';
 import { jwtClaims } from '../app.js';
 const pool = new pg.Pool({ connectionString: process.env.DB_CONNECTION_URL });
-const cache = createPostGraphileSchema(pool, 'public');
+const cache = createPostGraphileSchema(pool, 'public', { appendPlugins: [PgSimplifyInflectorPlugin, ConnectionFilterPlugin] });
 
 export const graphqlQuery = async ({ query, variables = null }) => {
     try {

yarn.lock

@@ -150,6 +150,11 @@
   dependencies:
     fast-deep-equal "^3.1.3"
 
+"@graphile-contrib/pg-simplify-inflector@^6.1.0":
+  version "6.1.0"
+  resolved "https://registry.yarnpkg.com/@graphile-contrib/pg-simplify-inflector/-/pg-simplify-inflector-6.1.0.tgz#5ecb842bd43af4d3ffdfcd25b1e7c452374f7440"
+  integrity sha512-3eI2FP4ulu/fxwkJBNXhR6XEzqVz4wJWFr4LfeyUNNArUtLFx0DpP6YdcARCYgwLExFcIQNE8fnul3JKiciYIw==
+
 "@graphile/lru@4.11.0":
   version "4.11.0"
   resolved "https://registry.yarnpkg.com/@graphile/lru/-/lru-4.11.0.tgz#dd805ee083063488796ec0eac5a8b50b21c076f9"
@@ -1033,6 +1038,13 @@ postgraphile-core@4.13.0:
     graphile-build-pg "4.13.0"
     tslib "^2.0.1"
 
+postgraphile-plugin-connection-filter@^2.3.0:
+  version "2.3.0"
+  resolved "https://registry.yarnpkg.com/postgraphile-plugin-connection-filter/-/postgraphile-plugin-connection-filter-2.3.0.tgz#0ef9316f73b3cac6452187debe2053c379cf2ade"
+  integrity sha512-TR5bq/NOqqtm4xV3D2Qw+CJo0Hanrx1lqh0KZiU78z8YijcLC0NuT3z0nJyCB842nWbx5Wi6p0S+xmrgzRFNgQ==
+  dependencies:
+    tslib "^2.3.0"
+
 postgraphile@^4.13.0:
   version "4.13.0"
   resolved "https://registry.yarnpkg.com/postgraphile/-/postgraphile-4.13.0.tgz#ed8cb05e6919e09d4a90bd8d9db6941eb3ce7690"
@@ -1348,7 +1360,7 @@ toidentifier@1.0.1:
   resolved "https://registry.yarnpkg.com/toidentifier/-/toidentifier-1.0.1.tgz#3be34321a88a820ed1bd80dfaa33e479fbb8dd35"
   integrity sha512-o5sSPKEkg/DIQNmH43V0/uerLrpzVedkUh8tGNvaeXpfpuwjKenlSox/2O/BTlZUtEe+JG7s5YhEz608PlAHRA==
 
-tslib@^2.0.1, tslib@^2.1.0:
+tslib@^2.0.1, tslib@^2.1.0, tslib@^2.3.0:
   version "2.6.2"
   resolved "https://registry.yarnpkg.com/tslib/-/tslib-2.6.2.tgz#703ac29425e7b37cd6fd456e92404d46d1f3e4ae"
   integrity sha512-AEYxH93jGFPn/a2iVAwW87VuUIkR1FVUKB77NwMF7nBTDkDrrT/Hpt/IrCJ0QXhW27jTBDcf5ZY7w6RiqTMw2Q==