Add API route to save postal areas in postgres database

lib/api/postal-code/models.js

@@ -0,0 +1,9 @@
+import {PostalArea} from '../../util/sequelize.js'
+
+export const getAllPostalAreas = () => PostalArea.findAll({attributes: ['postalCode']})
+
+export const putPostalAreas = postalAreas => PostalArea.bulkCreate(postalAreas, {updateOnDuplicate: ['geometry'], subQuery: false})
+
+export const deletePostalAreas = postalCodes => {
+  postalCodes.map(postalCode => PostalArea.destroy({where: {postalCode}}))
+}

lib/api/postal-code/routes.js

@@ -0,0 +1,50 @@
+import 'dotenv/config.js' // eslint-disable-line import/no-unassigned-import
+import {customAlphabet} from 'nanoid'
+import express, {response} from 'express'
+import queue from '../../util/queue.cjs'
+import auth from '../../middleware/auth.js'
+import analyticsMiddleware from '../../middleware/analytics.js'
+import {getAllPostalAreas, putPostalAreas, deletePostalAreas} from './models.js'
+
+const apiQueue = queue('api')
+
+const BAN_API_URL
+  = process.env.BAN_API_URL || 'https://plateforme.adresse.data.gouv.fr/api'
+
+const nanoid = customAlphabet('123456789ABCDEFGHJKMNPQRSTVWXYZ', 9)
+
+const app = new express.Router()
+
+app.route('/')
+  .put(async (req, res) => {
+    const postalCodeDBResponse = await getAllPostalAreas() || []
+    const postalCodesFromDB = new Set(postalCodeDBResponse.map(({postalCode}) => postalCode))
+
+    const {features, crs} = req.body || {}
+
+    const bulkOperations = features.map(({properties, geometry}) => {
+      const postalCode = properties.cp
+      postalCodesFromDB.delete(postalCode)
+      if (geometry.crs === undefined) {
+        geometry.crs = crs
+      }
+
+      return {postalCode, geometry}
+    })
+
+    const bulkPostalCode = putPostalAreas(bulkOperations)
+
+    const deletePostalCode = postalCodesFromDB.size > 0 ? deletePostalAreas([...postalCodesFromDB]) : true
+
+    const operations = await Promise.all([bulkPostalCode, deletePostalCode])
+
+    res.send(
+      {
+        date: new Date(),
+        status: 'success',
+        response: operations,
+      }
+    )
+  })
+
+export default app

lib/api/routes.js

@@ -6,6 +6,7 @@ import commonToponymRoutes from './common-toponym/routes.js'
 import districtRoutes from './district/routes.js'
 import statusRoutes from './job-status/routes.js'
 import banIdRoutes from './ban-id/routes.js'
+import postalCodeRoutes from './postal-code/routes.js'
 
 const app = new express.Router()
 
@@ -14,5 +15,6 @@ app.use('/common-toponym', commonToponymRoutes)
 app.use('/district', districtRoutes)
 app.use('/job-status', statusRoutes)
 app.use('/ban-id', banIdRoutes)
+app.use('/postal-code', postalCodeRoutes)
 
 export default app