Release v1.56.4 (#1356)

kevinkim-ogp · web-flow · commit 2d40ccc32209 · 2025-12-03T18:43:21.000+08:00
- fix(formsg-frontend): table field preview
- fix(pipe-transfer): filter excel steps to nullify
- chore(slack): reduce Slack scopes
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/backend/package.json b/packages/backend/package.json
@@ -111,5 +111,5 @@
     "tsconfig-paths": "^4.2.0",
     "type-fest": "4.10.3"
   },
-  "version": "1.56.3"
+  "version": "1.56.4"
 }
diff --git a/packages/backend/src/apps/formsg/triggers/new-submission/get-data-out-metadata.ts b/packages/backend/src/apps/formsg/triggers/new-submission/get-data-out-metadata.ts
@@ -204,7 +204,9 @@ function buildTableMetadatum(fieldData: IJSONObject): IDataOutMetadata {
 
   const tableObject = JSON.parse(fieldData.answer as string)
   return {
-    label: `Response ${fieldData.order}`,
+    label: fieldData.question
+      ? `${fieldData.order}. ${fieldData.question}`
+      : `Response ${fieldData.order}`,
     order: fieldData.order ? (fieldData.order as number) + 0.1 : null,
     type: 'table',
     displayedValue: `Preview ${tableObject.rows.length} row(s)`,
diff --git a/packages/backend/src/apps/formsg/triggers/new-submission/get-mock-data.ts b/packages/backend/src/apps/formsg/triggers/new-submission/get-mock-data.ts
@@ -13,6 +13,7 @@ type FormField = {
   _id: string
   columns?: Array<{
     _id: string
+    title?: string
   }>
   fieldType: string
   fieldOptions?: string[]
@@ -130,8 +131,9 @@ async function getMockData($: IGlobalVariable) {
           data.responses[formFields[i]._id].answer = 'Signature captured' // mock this to always be present regardless of whether the user has signed or not
         }
 
-        // formsg payload doesnt contain this anyways, so we dont return in mock data
-        if (fieldType === 'statement') {
+        // formsg payload doesnt contain these fields anyways, so we dont return in mock data
+        // this ensures that the question numbering remains consistent with the actual submission
+        if (fieldType === 'statement' || fieldType === 'image') {
           delete data.responses[formFields[i]._id]
           continue
         }
@@ -160,11 +162,21 @@ async function getMockData($: IGlobalVariable) {
         if (fieldType === 'table') {
           const answerArray = data.responses[formFields[i]._id]
             .answerArray as string[][]
-          const question = data.responses[formFields[i]._id].question
+          const question = `${
+            data.responses[formFields[i]._id].question
+          } (${formFields[i].columns
+            ?.map((column, index) => column?.title ?? `Col ${index + 1}`)
+            .join(', ')})`
+
+          data.responses[formFields[i]._id].question = question
           data.responses[formFields[i]._id].answer =
             convertTableAnswerArrayToTableObject(question, answerArray)
         }
 
+        if (fieldType === 'section' || fieldType === 'image') {
+          data.responses[formFields[i]._id].answer = ''
+        }
+
         data.responses[formFields[i]._id].order = i + 1
         data.responses[formFields[i]._id].id = undefined
       }
diff --git a/packages/backend/src/apps/slack/auth/generate-auth-url.ts b/packages/backend/src/apps/slack/auth/generate-auth-url.ts
@@ -6,46 +6,8 @@ import type {
 
 import qs from 'qs'
 
-const scopes = [
-  'channels:manage',
-  'channels:read',
-  'channels:join',
-  'chat:write',
-  'chat:write.customize',
-  'chat:write.public',
-  'files:write',
-  'im:write',
-  'mpim:write',
-  'team:read',
-  'users.profile:read',
-  'users:read',
-  'workflow.steps:execute',
-  'users:read.email',
-  'commands',
-]
-const userScopes = [
-  'channels:history',
-  'channels:read',
-  'channels:write',
-  'chat:write',
-  'emoji:read',
-  'files:read',
-  'files:write',
-  'groups:history',
-  'groups:read',
-  'groups:write',
-  'im:write',
-  'mpim:write',
-  'reactions:read',
-  'reminders:write',
-  'search:read',
-  'stars:read',
-  'team:read',
-  'users.profile:read',
-  'users.profile:write',
-  'users:read',
-  'users:read.email',
-]
+const scopes = ['chat:write', 'chat:write.customize', 'chat:write.public']
+const userScopes = ['channels:read', 'chat:write', 'search:read', 'users:read']
 
 export default async function generateAuthUrl($: IGlobalVariable) {
   // Our own auth, so safe to cast $.app.auth
diff --git a/packages/backend/src/apps/slack/auth/index.ts b/packages/backend/src/apps/slack/auth/index.ts
@@ -22,7 +22,7 @@ const auth: IUserAddedConnectionAuth = {
     },
     {
       key: 'consumerKey',
-      label: 'API Key',
+      label: 'Client ID',
       type: 'string' as const,
       required: true,
       readOnly: false,
@@ -33,7 +33,7 @@ const auth: IUserAddedConnectionAuth = {
     },
     {
       key: 'consumerSecret',
-      label: 'API Secret',
+      label: 'Client Secret',
       type: 'string' as const,
       required: true,
       readOnly: false,
diff --git a/packages/backend/src/graphql/mutations/update-flow-transfer-status.ts b/packages/backend/src/graphql/mutations/update-flow-transfer-status.ts
@@ -103,7 +103,9 @@ const updateFlowTransferStatus: MutationResolvers['updateFlowTransferStatus'] =
       // nullify connections for M365-excel
       // excel connections cannot be shared; the new owner should use their own connection
       const excelStepIds = flow.steps
-        .filter((step) => step.appKey === 'm365-excel')
+        .filter(
+          (step) => step.appKey === 'm365-excel' && step.connectionId != null,
+        )
         .map((step) => step.id)
       const numExcelNullified = await Step.query(trx)
         .patch({ connection: null, connectionId: null, status: 'incomplete' })
diff --git a/packages/frontend/package.json b/packages/frontend/package.json
@@ -1,6 +1,6 @@
 {
   "name": "frontend",
-  "version": "1.56.3",
+  "version": "1.56.4",
   "type": "module",
   "scripts": {
     "dev": "wait-on tcp:3000 && vite --host --force",
diff --git a/packages/frontend/src/components/VariablesList/TableVariableItem.tsx b/packages/frontend/src/components/VariablesList/TableVariableItem.tsx
@@ -33,6 +33,7 @@ export default function TableVariableItem(props: TableVariableItemProps) {
       />
       {!onClick && (
         <TableVariableModal
+          variableId={variable.name}
           isOpen={isOpen}
           onClose={onClose}
           currentExecutionStep={currentTestExecutionStep}
diff --git a/packages/frontend/src/components/VariablesList/TableVariableModal.tsx b/packages/frontend/src/components/VariablesList/TableVariableModal.tsx
@@ -28,6 +28,8 @@ interface TableVariableModalProps {
   isOpen: boolean
   onClose: () => void
   currentExecutionStep?: IExecutionStep | null
+  // variableName is the step variable: `step.<uuid>.xxxxx`
+  variableId: string
 }
 
 const TableHeader = ({ columns }: { columns: ProcessedColumn[] }) => (
@@ -107,12 +109,15 @@ const TableRow = ({
 )
 
 export default function TableVariableModal(props: TableVariableModalProps) {
-  const { isOpen, onClose, currentExecutionStep } = props
+  const { isOpen, onClose, currentExecutionStep, variableId } = props
 
   if (!currentExecutionStep) {
     return null
   }
-  const { rowsFound, dataRows, columns } = processData(currentExecutionStep)
+  const { rowsFound, dataRows, columns } = processData(
+    currentExecutionStep,
+    variableId,
+  )
 
   return (
     <Modal
diff --git a/packages/frontend/src/components/VariablesList/schema.ts b/packages/frontend/src/components/VariablesList/schema.ts
@@ -1,5 +1,6 @@
 import { IJSONObject } from '@plumber/types'
 
+import get from 'lodash.get'
 import { z } from 'zod'
 
 const RowDataSchema = z.object({
@@ -32,26 +33,31 @@ const FormSgTableFieldSchema = z.object({
 
 const FormSgFieldSchema = z.object({
   fieldType: z.string(),
-  answer: z.union([z.string(), z.record(z.any())]).optional(),
+  answer: z.union([z.string(), z.record(z.any())]).nullish(),
 })
 
-const FormSgFieldsSchema = z.record(FormSgFieldSchema).transform((fields) => {
-  const tableField = Object.values(fields).find(
-    (field) => field?.fieldType === 'table',
-  ) as z.infer<typeof FormSgFieldSchema> | undefined
+const createFormSgFieldsSchema = (variableId: string) => {
+  const regex = new RegExp(
+    /step\.[\da-f]{8}(?:-[\da-f]{4}){3}-[\da-f]{12}\.fields\.([^.]+)\.answer/,
+  )
+  const match = variableId.match(regex)
+  const tableFieldId = match?.[1]
 
-  if (!tableField) {
-    return {
-      fieldType: 'table',
-      answer: {
-        rows: [],
-        columns: [],
-      },
+  return z.record(FormSgFieldSchema).transform((fields) => {
+    if (!tableFieldId) {
+      return {
+        fieldType: 'table',
+        answer: {
+          rows: [],
+          columns: [],
+        },
+      }
     }
-  }
 
-  return FormSgTableFieldSchema.parse(tableField)
-})
+    const tableField = get(fields, tableFieldId)
+    return FormSgTableFieldSchema.parse(tableField)
+  })
+}
 
 /**
  * FormSG has a different dataOut structure from our own apps.
@@ -60,26 +66,29 @@ const FormSgFieldsSchema = z.record(FormSgFieldSchema).transform((fields) => {
  * Note: FormSG implements check to have at least 1 row in the table field.
  * the cells may be empty, but there will always be at least 1 row.
  */
-export const FormSgTableDataOutSchema = z
-  .object({
-    fields: FormSgFieldsSchema,
-  })
-  .transform((dataOut) => {
-    const parsedData = dataOut.fields.answer as z.infer<typeof RowDataSchema>
-    return {
-      rowsFound:
-        (parsedData.rows as z.infer<typeof RowDataSchema>['rows'])?.length ?? 0,
-      data: parsedData,
-    }
-  })
+export const createFormSgTableDataOutSchema = (variableName: string) =>
+  z
+    .object({
+      fields: createFormSgFieldsSchema(variableName),
+    })
+    .transform((dataOut) => {
+      const parsedData = dataOut.fields.answer as z.infer<typeof RowDataSchema>
+      return {
+        rowsFound:
+          (parsedData.rows as z.infer<typeof RowDataSchema>['rows'])?.length ??
+          0,
+        data: parsedData,
+      }
+    })
 
 export const MultipleRowDataOutSchema = z.object({
   rowsFound: z.union([z.string(), z.number()]).default(0),
   data: RowDataSchema,
 })
 
 // Enhanced schema that can handle both regular and FormSG data
-export const ExecutionStepDataOutSchema = z.union([
-  MultipleRowDataOutSchema,
-  FormSgTableDataOutSchema,
-])
+export const createExecutionStepDataOutSchema = (variableName: string) =>
+  z.union([
+    MultipleRowDataOutSchema,
+    createFormSgTableDataOutSchema(variableName),
+  ])
diff --git a/packages/frontend/src/components/VariablesList/utils.tsx b/packages/frontend/src/components/VariablesList/utils.tsx
@@ -1,6 +1,6 @@
 import { IExecutionStep } from '@plumber/types'
 
-import { ExecutionStepDataOutSchema } from './schema'
+import { createExecutionStepDataOutSchema } from './schema'
 
 export interface RawColumn {
   id: string
@@ -42,9 +42,14 @@ const processColumns = (rawColumns: RawColumn[]): ProcessedColumn[] => {
     .sort((a, b) => (a.order ?? 0) - (b.order ?? 0))
 }
 
-export const processData = (executionStep: IExecutionStep): ProcessedData => {
+export const processData = (
+  executionStep: IExecutionStep,
+  variableId: string,
+): ProcessedData => {
   try {
-    const dataOut = ExecutionStepDataOutSchema.parse(executionStep.dataOut)
+    const dataOut = createExecutionStepDataOutSchema(variableId).parse(
+      executionStep.dataOut,
+    )
     const rowsFound = String(dataOut.rowsFound)
 
     return {
diff --git a/packages/types/package.json b/packages/types/package.json
@@ -2,5 +2,5 @@
   "name": "@plumber/types",
   "description": "Shared types for plumber",
   "types": "./index.d.ts",
-  "version": "1.56.3"
+  "version": "1.56.4"
 }

Original file line number	Diff line number	Diff line change
`@@ -111,5 +111,5 @@`
`111`	`111`	`"tsconfig-paths": "^4.2.0",`
`112`	`112`	`"type-fest": "4.10.3"`
`113`	`113`	`},`
`114`		`- "version": "1.56.3"`
	`114`	`+ "version": "1.56.4"`
`115`	`115`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "frontend",`
`3`		`- "version": "1.56.3",`
	`3`	`+ "version": "1.56.4",`
`4`	`4`	`"type": "module",`
`5`	`5`	`"scripts": {`
`6`	`6`	`"dev": "wait-on tcp:3000 && vite --host --force",`