feat(flux): taggue l'utilisation des flux geojson sur Matomo (#11)

* feat(flux): taggue l'utilisation des flux geojson sur Matomo

* refactor: refactorise

Co-authored-by: Francois Romain <francoisromain@gmail.com>

.env.example

@@ -7,3 +7,7 @@ URL=
 
 # certificat ssh (docker-compose)
 LETSENCRYPT_EMAIL=
+
+# stats
+MATOMO_SITE_ID=
+MATOMO_HOST=

lib/stats/index.js

@@ -0,0 +1,6 @@
+const MatomoTracker = require('matomo-tracker')
+
+module.exports =
+  process.env.MATOMO_SITE_ID && process.env.MATOMO_HOST
+    ? new MatomoTracker(process.env.MATOMO_SITE_ID, process.env.MATOMO_HOST)
+    : null

lib/titres/index.js

@@ -4,28 +4,30 @@ const basicAuth = require('basic-auth')
 const apiGet = require('../api/index')
 const geojsonFormat = require('../utils/geojson-format')
 
+const matomo = require('../stats/index')
+
 // importe les requêtes graphQL
 const {
   titresQuery,
   domainesQuery,
   typesQuery,
   statutsQuery,
-  tokenQuery
+  tokenQuery,
 } = require('../api/queries')
 
 const params = {
   arrays: ['typesIds', 'domainesIds', 'statutsIds'],
-  strings: ['entreprises', 'noms', 'references', 'substances', 'territoires']
+  strings: ['entreprises', 'noms', 'references', 'substances', 'territoires'],
 }
 
 // pour chaque definition (domainesIds, typesIds, statutsIds)
 // retourne un tableau avec les noms correspondant aux ids
 // - domaines: []
 // - types: []
 // - statuts: []
-const metasFormat = metas =>
+const metasFormat = (metas) =>
   Object.keys(metas).reduce((metasObj, metaName) => {
-    metasObj[metaName] = metas[metaName].map(m => m.nom || m.type.nom)
+    metasObj[metaName] = metas[metaName].map((m) => m.nom || m.type.nom)
 
     return metasObj
   }, {})
@@ -35,7 +37,7 @@ const tokenGet = async (email, motDePasse) => {
 
   const data = await apiGet('utilisateurTokenCreer', {
     query: tokenQuery,
-    variables
+    variables,
   })
 
   return (data && data.token) || null
@@ -60,7 +62,7 @@ const auth = async (req, res, next) => {
   next()
 }
 
-const queryParse = query =>
+const queryParse = (query) =>
   Object.keys(query).reduce((variables, key) => {
     if (params.arrays.includes(key)) {
       variables[key] = query[key].split(',')
@@ -104,9 +106,19 @@ const titresGet = async (req, res) => {
 
     // construit le flux geojson
     const geojson = geojsonFormat(titres, {
-      ...metasFormat(metas)
+      ...metasFormat(metas),
     })
 
+    if (matomo) {
+      const url = req.protocol + '://' + req.get('host') + req.originalUrl
+
+      // track Matomo
+      matomo.track({
+        url,
+        action_name: 'flux / titres',
+      })
+    }
+
     res.send(geojson)
   } catch (e) {
     console.error(e)

package.json

@@ -26,6 +26,7 @@
     "cron": "^1.8.2",
     "dotenv": "^8.2.0",
     "express": "^4.17.1",
+    "matomo-tracker": "^2.2.1",
     "node-fetch": "^2.6.0",
     "npm-check-updates": "^4.1.0",
     "rimraf": "^3.0.2",
@@ -38,7 +39,7 @@
     "@types/node": "^13.9.5",
     "@types/node-fetch": "^2.5.5",
     "@types/serve-index": "^1.7.30",
-    "commitizen": "^4.0.3",
+    "commitizen": "^4.0.4",
     "conventional-github-releaser": "^3.1.3",
     "cz-conventional-changelog": "^3.1.0",
     "eslint": "^6.8.0",