Release 3.12.1

.github/workflows/chromatic.yml

@@ -8,22 +8,25 @@ on:
 jobs:
   chromatic-deployment:
     runs-on: ubuntu-latest
-    container: node:22.21
     defaults:
       run:
         working-directory: packages/webapp
     steps:
       - name: Checkout repo
-        uses: actions/checkout@v4
+        uses: actions/checkout@v6
         with:
           fetch-depth: 0
+      - uses: actions/setup-node@v6
+        with:
+          node-version: 22.21
       - name: Setup pnpm
-        uses: pnpm/action-setup@v4
+        uses: pnpm/action-setup@v6
         with:
-          package_json_file: "packages/webapp/package.json"
+          package_json_file: packages/webapp/package.json
       - name: Install dependencies
-        run: pnpm install
-      - name: Publish to Chromatic
-        env:
-          NODE_OPTIONS: "--max-old-space-size=8192"
-        run: ./node_modules/.bin/chromatic --project-token ${{ secrets.CHROMATIC_PROJECT_TOKEN }}
+        run: pnpm install --frozen-lockfile
+      - name: Run Chromatic
+        uses: chromaui/action@98132da0fca2211fb41b3af7b49ce85176007851 # v17.8.0
+        with:
+          projectToken: ${{ secrets.CHROMATIC_PROJECT_TOKEN }}
+          workingDir: packages/webapp

packages/api/db/migration/20260625000000_generalize_survey_tables.js

@@ -0,0 +1,76 @@
+/*
+ *  Copyright 2026 LiteFarm.org
+ *  This file is part of LiteFarm.
+ *
+ *  LiteFarm is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  LiteFarm is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ *  GNU General Public License for more details, see <https://www.gnu.org/licenses/>.
+ */
+
+/**
+ * Generalizes the bespoke TAPE survey storage into a reusable, multi-survey model:
+ * - Renames `tape_survey` to `survey_response` and adds a `survey_key` column identifying which survey each row answers
+ * - Makes `survey_step` nullable, as it is TAPE-specific and not used by every survey
+ * - Repurposes the TAPE permissions to generic survey_response permissions (add/get/edit).
+ *
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+export const up = async function (knex) {
+  await knex.schema.renameTable('tape_survey', 'survey_response');
+
+  await knex.schema.alterTable('survey_response', function (table) {
+    table.string('survey_key').nullable();
+  });
+
+  // Every existing row is a TAPE response.
+  await knex('survey_response').update({ survey_key: 'tape' });
+  await knex.schema.alterTable('survey_response', function (table) {
+    table.string('survey_key').notNullable().alter();
+  });
+
+  await knex.schema.alterTable('survey_response', function (table) {
+    table.string('survey_step').nullable().alter();
+  });
+
+  // Repurpose the TAPE permissions (names only)
+  await knex('permissions')
+    .where({ permission_id: 185 })
+    .update({ name: 'add:survey_response', description: 'add survey_response' });
+  await knex('permissions')
+    .where({ permission_id: 186 })
+    .update({ name: 'get:survey_response', description: 'get survey_response' });
+  await knex('permissions')
+    .where({ permission_id: 187 })
+    .update({ name: 'edit:survey_response', description: 'edit survey_response' });
+};
+
+/**
+ * @param { import("knex").Knex } knex
+ * @returns { Promise<void> }
+ */
+export const down = async function (knex) {
+  await knex('permissions')
+    .where({ permission_id: 185 })
+    .update({ name: 'add:tape_survey', description: 'add tape_survey' });
+  await knex('permissions')
+    .where({ permission_id: 186 })
+    .update({ name: 'get:tape_survey', description: 'get tape_survey' });
+  await knex('permissions')
+    .where({ permission_id: 187 })
+    .update({ name: 'edit:tape_survey', description: 'edit tape_survey' });
+
+  await knex.schema.alterTable('survey_response', function (table) {
+    table.string('survey_step').notNullable().alter();
+  });
+  await knex.schema.alterTable('survey_response', function (table) {
+    table.dropColumn('survey_key');
+  });
+  await knex.schema.renameTable('survey_response', 'tape_survey');
+};

packages/api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "litefarm-api",
-  "version": "3.12.0",
+  "version": "3.12.1",
   "description": "LiteFarm API server",
   "main": "./api/src/server.js",
   "type": "module",

packages/api/src/controllers/surveyResponseController.ts

@@ -0,0 +1,149 @@
+/*
+ *  Copyright 2026 LiteFarm.org
+ *  This file is part of LiteFarm.
+ *
+ *  LiteFarm is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation, either version 3 of the License, or
+ *  (at your option) any later version.
+ *
+ *  LiteFarm is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ *  GNU General Public License for more details, see <https://www.gnu.org/licenses/>.
+ */
+
+import { Response } from 'express';
+import { LiteFarmRequest } from '../types.js';
+import SurveyResponseModel from '../models/surveyResponseModel.js';
+
+interface SurveyResponseData {
+  survey_version: string;
+  project_id: string;
+  survey_step?: string;
+  [key: string]: unknown;
+}
+
+interface CreateSurveyResponseReqBody {
+  survey_key: string;
+  survey_response: SurveyResponseData;
+}
+
+interface LatestSurveyResponseQuery {
+  survey_key?: string;
+}
+
+interface UpdateSurveyResponseParams {
+  submission_id: string;
+}
+
+interface UpdateSurveyResponseReqBody {
+  survey_response: SurveyResponseData;
+}
+
+type InsertableQuery = { insert: (data: Record<string, unknown>) => Promise<unknown> };
+
+const surveyResponseController = {
+  createSurveyResponse() {
+    return async (
+      req: LiteFarmRequest<unknown, unknown, unknown, CreateSurveyResponseReqBody>,
+      res: Response,
+    ) => {
+      try {
+        const { farm_id } = req.headers;
+        const user_id = req.auth?.user_id;
+        const { survey_key, survey_response } = req.body;
+        if (!survey_key) {
+          return res.status(400).json({ error: 'survey_key is required' });
+        }
+        const { survey_version, project_id, survey_step } = survey_response;
+
+        const insertQuery = SurveyResponseModel.query().context({
+          user_id,
+        }) as unknown as InsertableQuery;
+        await insertQuery.insert({
+          farm_id,
+          survey_key,
+          survey_response,
+          survey_version,
+          project_id,
+          survey_step,
+        });
+
+        return res.status(201).send();
+      } catch (error) {
+        console.error(error);
+        return res.status(500).json({ error });
+      }
+    };
+  },
+
+  getLatestSurveyResponse() {
+    return async (req: LiteFarmRequest<LatestSurveyResponseQuery>, res: Response) => {
+      try {
+        const { farm_id } = req.headers;
+        const { survey_key } = req.query;
+        if (!survey_key) {
+          return res.status(400).json({ error: 'survey_key is required' });
+        }
+        // Find the latest survey response of this kind for the farm
+        const result = await SurveyResponseModel.query()
+          .where({ farm_id, survey_key })
+          .orderBy('created_at', 'desc')
+          .first();
+        return res.status(200).send(result ?? null);
+      } catch (error) {
+        console.error(error);
+        return res.status(500).json({ error });
+      }
+    };
+  },
+
+  // Note: Not currently called from frontend
+  updateSurveyResponse() {
+    return async (
+      req: LiteFarmRequest<
+        unknown,
+        UpdateSurveyResponseParams,
+        unknown,
+        UpdateSurveyResponseReqBody
+      >,
+      res: Response,
+    ) => {
+      try {
+        const { farm_id } = req.headers;
+        const user_id = req.auth?.user_id;
+        const { submission_id } = req.params;
+        const { survey_response } = req.body;
+        const { survey_version, project_id, survey_step } = survey_response;
+
+        const existing = (await SurveyResponseModel.query().findOne({ submission_id })) as
+          | { survey_key: string }
+          | undefined;
+        if (!existing) {
+          return res.status(404).json({ error: 'Survey response not found' });
+        }
+
+        const insertQuery = SurveyResponseModel.query().context({
+          user_id,
+        }) as unknown as InsertableQuery;
+        await insertQuery.insert({
+          submission_id,
+          farm_id,
+          survey_key: existing.survey_key,
+          survey_response,
+          survey_version,
+          project_id,
+          survey_step,
+        });
+
+        return res.status(204).send();
+      } catch (error) {
+        console.error(error);
+        return res.status(500).json({ error });
+      }
+    };
+  },
+};
+
+export default surveyResponseController;

packages/api/src/controllers/timeNotificationController.js

@@ -135,7 +135,10 @@ const timeNotificationController = {
       );
 
       for (const locationId in prescriptionsByLocation) {
-        const latestPrescription = prescriptionsByLocation[locationId].at(-1);
+        // Select the latest prescription explicitly rather than relying on the order Ensemble returns.
+        const latestPrescription = prescriptionsByLocation[locationId].reduce((latest, current) =>
+          current.id > latest.id ? current : latest,
+        );
         const { id: irrigation_prescription_id, recommended_start_date } = latestPrescription;
 
         const previousNotification = await NotificationModel.query()