feat: add i18next for internationalization and implement translation functionality

Author: nicomontanari

package.json

@@ -15,6 +15,7 @@
     "axios": "^1.10.0",
     "dotenv": "^17.2.0",
     "fastify": "^5.4.0",
+    "i18next": "^25.3.2",
     "lodash": "^4.17.21",
     "moment": "^2.30.1",
     "pg": "^8.16.3",

src/controllers/telegram.ts

@@ -5,7 +5,7 @@ import { getAddressFromCoordinates, getGoogleMapsRoute } from '../services/googl
 import { getTelegramUsers } from '../models/telegram-user'
 import { MolinellaCoordinates } from '../utilites/constants'
 import { InlineKeyboardButton } from 'telegraf/typings/core/types/typegram'
-import { getActualWorkShift } from '../utilites/common'
+import { getActualWorkShift, translateKey } from '../utilites/common'
 import { ParsedMeteoAlert } from '../utilites/meteo-alerts'
 
 const molinellaWord = 'MOLINELLA'
@@ -154,7 +154,7 @@ export const sendNewTomorrowAlertMessage = async (alert: ParsedMeteoAlert) => {
     const telegramUsers = await getTelegramUsers()
 
     const criticDataMessage = Object.keys(alert.criticZoneData)
-        .map((key) => `${key}: ${alert.criticZoneData[key]}`)
+        .map((key) => `${key.toUpperCase()}: ${translateKey(`alert.colors.${alert.criticZoneData[key]}`, 'it')}`)
         .join('\n')
 
     const textMessage = `⚠️ Nuova allerta meteo per domani!

src/models/last-alert-report.ts

@@ -0,0 +1,26 @@
+import { database } from '..'
+
+const tableName = 'django_models_latestreport'
+
+export interface LastAlertReport {
+    id: number
+    report_id: string
+}
+
+export const getLastAlertReport = async (): Promise<LastAlertReport> => {
+    const query = `SELECT * FROM ${tableName} `
+
+    const reports = await database.query<LastAlertReport>(query)
+
+    if (reports.length === 0) {
+        throw new Error('No last alert report found')
+    }
+
+    return reports[0]
+}
+
+export const updateLastAlertReport = async (reportId: string): Promise<void> => {
+    const query = `UPDATE ${tableName} SET report_id = $1 WHERE id = 1`
+
+    await database.query(query, [reportId])
+}

src/models/telegram-user.ts

@@ -22,7 +22,5 @@ export const getTelegramUsers = async (allowTest: boolean = true): Promise<Teleg
 
     const query = `SELECT * FROM ${tableName} ${filterStatements.length > 0 ? 'WHERE ' + filterStatements.join(' AND ') : ''}`
 
-    const result = await database.query<TelegramUser>(query)
-
-    return result
+    return database.query<TelegramUser>(query)
 }

src/resources/locales/it.json

@@ -0,0 +1,10 @@
+{
+    "alert": {
+        "colors": {
+            "red": "Rossa",
+            "orange": "Arancione",
+            "yellow": "Gialla",
+            "green": "Verde"
+        }
+    }
+}

src/routes/meteo-alerts.ts

@@ -1,22 +1,29 @@
 import { sendNewTomorrowAlertMessage } from '../controllers/telegram'
-import { getMeteoAlert } from '../services/meteo-alerts'
+import { getLastAlertReport, updateLastAlertReport } from '../models/last-alert-report'
+import { getTomorrowMeteoAlert } from '../services/meteo-alerts'
 import { parseMeteoAlert } from '../utilites/meteo-alerts'
 
 export const registerMeteoAlertsRoutes = (fastify) => {
     fastify.route({
         method: 'POST',
         url: '/meteo-alerts',
         handler: async (_, reply) => {
-            const tomorrowAlert = await getMeteoAlert('2025-07-07 13:00')
+            const tomorrowAlert = await getTomorrowMeteoAlert()
 
             if (!tomorrowAlert) {
                 return reply.status(204).send(undefined)
             }
 
             const parsedAlert = parseMeteoAlert(tomorrowAlert, 'D1')
 
-            if(parsedAlert.isCritic){
-                sendNewTomorrowAlertMessage(parsedAlert)
+            const lastAlertReport = await getLastAlertReport()
+
+            if (lastAlertReport.report_id !== parsedAlert.id) {
+                if (parsedAlert.isCritic) {
+                    sendNewTomorrowAlertMessage(parsedAlert)
+                }
+
+                await updateLastAlertReport(parsedAlert.id)
             }
 
             reply.status(200).send(parsedAlert)

src/server.ts

@@ -1,13 +1,29 @@
 import Fastify from 'fastify'
 import { registerNotifireRoutes } from './routes/notifire'
 import { registerMeteoAlertsRoutes } from './routes/meteo-alerts'
+import i18next from 'i18next'
+import italian from './resources/locales/it.json'
+
+const translations = {
+    it: {
+        translation: italian,
+    },
+}
 
 export const startServer = async () => {
     const fastify = Fastify({
         logger: true,
         disableRequestLogging: true,
     })
 
+    void i18next.init({
+        resources: translations,
+        fallbackLng: 'it',
+        interpolation: {
+            escapeValue: false,
+        },
+    })
+
     fastify.get('/health', async () => {
         return { status: 'ok' }
     })

src/utilites/common.ts

@@ -1,5 +1,6 @@
 import customMoment from '../custom-components/custom-moment'
 import { WORK_SHIFTS } from './constants'
+import i18next, { TOptions } from 'i18next'
 
 export interface Workshift {
     shift: string
@@ -54,3 +55,7 @@ export const getActualWorkShift = (isVolunteer: boolean): Workshift => {
         night: nightShift,
     }
 }
+
+export const translateKey = (key: string, language: string, options: TOptions = {}) => {
+    return i18next.t(key, { lng: language, ...options })
+}

src/utilites/meteo-alerts.ts

@@ -10,6 +10,7 @@ export interface ParsedMeteoAlert extends BaseMeteoAlert {
 }
 
 const correctColors = ['green', null]
+const wordToRemove = /allerta|bollettino/i
 
 export const parseMeteoAlert = (alert: MeteoAlert, zone: (typeof alertZones)[number]): ParsedMeteoAlert => {
     const zoneData = alert[zone]
@@ -24,13 +25,11 @@ export const parseMeteoAlert = (alert: MeteoAlert, zone: (typeof alertZones)[num
         throw new Error(`Invalid link format: ${alert.link}`)
     }
 
-    const id = fileName.replace('.pdf', '').replace('bollettino', '').replace('_', '/')
+    const id = fileName.replace('.pdf', '').replace('_', '/').replace(wordToRemove, '').trim()
 
     alert.link = `https://allertameteo.regione.emilia-romagna.it${alert.link}`
 
-    const criticData = Object.keys(zoneData).filter(
-        (key) => !correctColors.includes(zoneData[key])
-    )
+    const criticData = Object.keys(zoneData).filter((key) => !correctColors.includes(zoneData[key]))
 
     return {
         ...omit(alert, alertZones),

yarn.lock

@@ -2,6 +2,11 @@
 # yarn lockfile v1
 
 
+"@babel/runtime@^7.27.6":
+  version "7.28.2"
+  resolved "https://registry.yarnpkg.com/@babel/runtime/-/runtime-7.28.2.tgz#2ae5a9d51cc583bd1f5673b3bb70d6d819682473"
+  integrity sha512-KHp2IflsnGywDjBWDkR9iEqiWSpc8GIi0lgTT3mOElT0PP1tG26P4tmFI2YvAdzgq9RGyoHZQEIEdZy6Ec5xCA==
+
 "@cspotcode/source-map-support@^0.8.0":
   version "0.8.1"
   resolved "https://registry.yarnpkg.com/@cspotcode/source-map-support/-/source-map-support-0.8.1.tgz#00629c35a688e05a88b1cda684fb9d5e73f000a1"
@@ -1094,6 +1099,13 @@ humanize-ms@^1.2.1:
   dependencies:
     ms "^2.0.0"
 
+i18next@^25.3.2:
+  version "25.3.2"
+  resolved "https://registry.yarnpkg.com/i18next/-/i18next-25.3.2.tgz#3d6a7d1dc058caa1b9bdca47fd585483e2e7a637"
+  integrity sha512-JSnbZDxRVbphc5jiptxr3o2zocy5dEqpVm9qCGdJwRNO+9saUJS0/u4LnM/13C23fUEWxAylPqKU/NpMV/IjqA==
+  dependencies:
+    "@babel/runtime" "^7.27.6"
+
 ignore-by-default@^1.0.1:
   version "1.0.1"
   resolved "https://registry.yarnpkg.com/ignore-by-default/-/ignore-by-default-1.0.1.tgz#48ca6d72f6c6a3af00a9ad4ae6876be3889e2b09"