Update last value when triggering nested flows with array values

api/src/flows.ts

@@ -292,7 +292,7 @@ class FlowManager {
 		const database = (context.database as Knex) ?? getDatabase();
 		const schema = (context.schema as SchemaOverview) ?? (await getSchema({ database }));
 
-		const keyedData: Record<string, unknown> = {
+		const keyedData: Record<string, unknown> = (context.data as Record<string, unknown>) ?? {
 			[TRIGGER_KEY]: data,
 			[LAST_KEY]: data,
 			[ACCOUNTABILITY_KEY]: context?.accountability ?? null,

api/src/operations/exec/index.test.ts

@@ -111,6 +111,7 @@ test('Allows modules that are whitelisted', () => {
 
 	expect(
 		config.handler({ code: testCode }, {
+			data: {},
 			env: {
 				FLOWS_EXEC_ALLOWED_MODULES: 'bytes',
 			},

api/src/operations/exec/index.ts

@@ -13,6 +13,11 @@ export default defineOperationApi<Options>({
 		const opts: NodeVMOptions = {
 			eval: false,
 			wasm: false,
+			sandbox: {
+				$trigger: data['$trigger'],
+				$accountability: data['$accountability'],
+				$last: data['$last'],
+			},
 		};
 
 		if (allowedModules.length > 0) {

api/src/operations/trigger/index.ts

@@ -17,7 +17,12 @@ export default defineOperationApi<Options>({
 		let result: unknown | unknown[];
 
 		if (Array.isArray(payloadObject)) {
-			result = await Promise.all(payloadObject.map((payload) => flowManager.runOperationFlow(flow, payload, context)));
+			result = await Promise.all(
+				payloadObject.map((payload) => {
+					const updatedData = { ...context.data, $last: payload };
+					return flowManager.runOperationFlow(flow, payload, { ...context, data: updatedData });
+				})
+			);
 		} else {
 			result = await flowManager.runOperationFlow(flow, payloadObject, context);
 		}