Feature/ebp api integration

.env.sample

@@ -1,2 +1,3 @@
 BACKUP_ZIP_PASSWORD=<zip-password>
 SB_DOMAIN=sb.localhost
+EBP_API_TOKEN=<ebp-api-token>

compose.yml

@@ -41,6 +41,11 @@ services:
     build: .
     entrypoint: ./entrypoint.sh
     command: start
+    logging:
+        driver: "json-file"
+        options:
+            max-size: "10m"
+            max-file: "3"
 #    env_file:
 #      - sb-server.env
     environment:
@@ -51,6 +56,7 @@ services:
       REDIS_HOST: redis
       REDIS_PORT: 6379
       REDIS_DB: 0
+      EBP_API_TOKEN: ${EBP_API_TOKEN}
     depends_on:
       redis:
         condition: service_healthy

server/actions/ebp.js

@@ -0,0 +1,331 @@
+const paging = require('../helpers/paging')
+const incremental = require('../helpers/incremental')
+const { upgradeAction } = require('../utils/upgrade')
+const Promise = require('bluebird')
+
+exports.ebbSpeciesList = upgradeAction('ah17', {
+  name: 'ebp:speciesList',
+  description: 'ebp:speciesList',
+  middleware: ['admin'],
+  inputs: paging.declareInputs(incremental.declareInputs({
+    filter: {}
+  })),
+
+  run: function (api, data, next) {
+    try {
+      let q = {
+        order: [['sbNameLa', 'ASC']]
+      }
+      q = paging.prepareQuery(q, data.params)
+      return api.models.ebp_birds.findAndCountAll(q).then(function (result) {
+        data.response.count = result.count
+        data.response.meta = incremental.generateMeta(data, paging.generateMeta(result.count, data))
+        data.response.data = result.rows.map(function (ebpSpecies) {
+          return ebpSpecies.apiData(api)
+        })
+        return next()
+      }).catch(function (e) {
+        console.error('Failure for list EBP species', e)
+        return next(e)
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebbSpeciesUpdate = upgradeAction('ah17', {
+  name: 'ebp:speciesUpdate',
+  description: 'ebp:speciesUpdate',
+  middleware: ['admin'],
+  inputs: {
+    items: { required: true }
+  },
+
+  run: function (api, data, next) {
+    Promise.resolve()
+      .then(function () {
+        if (!(data.params.items instanceof Array)) {
+          data.connection.rawConnection.responseHttpCode = 400
+          throw new Error('items is not array')
+        }
+        if (data.params.items.length <= 0) {
+          data.connection.rawConnection.responseHttpCode = 400
+          throw new Error('cannot update with empty items')
+        }
+        return data.params.items.map(function (item) {
+          const record = api.models.ebp_birds.build({})
+          record.apiUpdate(item)
+          return record
+        })
+      })
+      .then(function (models) {
+        return api.sequelize.sequelize.transaction(function (t) {
+          return api.models.ebp_birds
+            .destroy({
+              where: {},
+              transaction: t
+            })
+            .then(function (deleted) {
+              api.log('replacing ebp_birds %d with %d', 'info', deleted, models.length)
+            })
+            .then(function () {
+              return Promise.map(models, function (item) {
+                return item.save({ transaction: t }).then((m) => m.apiData())
+              })
+            })
+        })
+      })
+      .then(function (result) {
+        data.response.count = result.length
+        data.response.data = result
+      })
+      .then(function () {
+        return next()
+      }, function (e) {
+        api.log('Failure to update ebp_birds', 'error', e)
+        return next(e)
+      })
+  }
+})
+
+exports.ebpSpeciesStatusList = upgradeAction('ah17', {
+  name: 'ebp:speciesStatusList',
+  description: 'ebp:speciesStatusList',
+  middleware: ['admin'],
+
+  run: function (api, data, next) {
+    try {
+      const q = {
+        order: [['ebpId', 'ASC']]
+      }
+      return api.models.ebp_birds_status.findAndCountAll(q).then(function (result) {
+        data.response.count = result.count
+        data.response.data = result.rows.map(function (ebpSpeciesStatus) {
+          return ebpSpeciesStatus.apiData(api)
+        })
+        return next()
+      }).catch(function (e) {
+        console.error('Failure for list EBP species statuses', e)
+        return next(e)
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebbSpeciesStatusUpdate = upgradeAction('ah17', {
+  name: 'ebp:speciesStatusUpdate',
+  description: 'ebp:speciesStatusUpdate',
+  middleware: ['admin'],
+  inputs: {
+    items: { required: true }
+  },
+
+  run: function (api, data, next) {
+    Promise.resolve()
+      .then(function () {
+        if (!(data.params.items instanceof Array)) {
+          data.connection.rawConnection.responseHttpCode = 400
+          throw new Error('items is not array')
+        }
+        if (data.params.items.length <= 0) {
+          data.connection.rawConnection.responseHttpCode = 400
+          throw new Error('cannot update with empty items')
+        }
+        return data.params.items.map(function (item) {
+          const record = api.models.ebp_birds_status.build({})
+          record.apiUpdate(item)
+          return record
+        })
+      })
+      .then(function (models) {
+        return api.sequelize.sequelize.transaction(function (t) {
+          return api.models.ebp_birds_status
+            .destroy({
+              where: {},
+              transaction: t
+            })
+            .then(function (deleted) {
+              api.log('replacing ebp_birds_status %d with %d', 'info', deleted, models.length)
+            })
+            .then(function () {
+              return Promise.map(models, function (item) {
+                return item.save({ transaction: t }).then((m) => m.apiData())
+              })
+            })
+        })
+      })
+      .then(function (result) {
+        data.response.count = result.length
+        data.response.data = result
+      })
+      .then(function () {
+        return next()
+      }, function (e) {
+        api.log('Failure to update ebp_birds_status', 'error', e)
+        return next(e)
+      })
+  }
+})
+
+exports.ebpOrganizationsList = upgradeAction('ah17', {
+  name: 'ebp:organizationsList',
+  description: 'ebp:organizationsList',
+  middleware: ['admin'],
+
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_organizations'
+        }
+      }).then(function (ebpOrganizations) {
+        data.response.data = JSON.parse(ebpOrganizations?.value || '[]')
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebpOrganizationsUpdate = upgradeAction('ah17', {
+  name: 'ebp:organizationsUpdate',
+  description: 'ebp:organizationsUpdate',
+  middleware: ['admin'],
+  inputs: {
+    items: { required: true }
+  },
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_organizations'
+        }
+      }).then(function (ebpOrganizations) {
+        if (!ebpOrganizations) {
+          ebpOrganizations = api.models.settings.build({
+            name: 'ebp_organizations'
+          })
+        }
+        ebpOrganizations.value = JSON.stringify(data.params.items)
+        ebpOrganizations.save()
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebpSourcesList = upgradeAction('ah17', {
+  name: 'ebp:sourcesList',
+  description: 'ebp:sourcesList',
+  middleware: ['admin'],
+
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_sources'
+        }
+      }).then(function (ebpSources) {
+        data.response.data = JSON.parse(ebpSources?.value || '[]')
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebpSourcesUpdate = upgradeAction('ah17', {
+  name: 'ebp:sourcesUpdate',
+  description: 'ebp:sourcesUpdate',
+  middleware: ['admin'],
+  inputs: {
+    items: { required: true }
+  },
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_sources'
+        }
+      }).then(function (ebpSources) {
+        if (!ebpSources) {
+          ebpSources = api.models.settings.build({
+            name: 'ebp_sources'
+          })
+        }
+        ebpSources.value = JSON.stringify(data.params.items)
+        ebpSources.save()
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebpProtocolGet = upgradeAction('ah17', {
+  name: 'ebp:protocolGet',
+  description: 'ebp:protocolGet',
+  middleware: ['admin'],
+
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_protocol'
+        }
+      }).then(function (setting) {
+        data.response.data = {
+          protocol: setting?.value || ''
+        }
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})
+
+exports.ebpProtocolUpdate = upgradeAction('ah17', {
+  name: 'ebp:protocolUpdate',
+  description: 'ebp:protocolUpdate',
+  middleware: ['admin'],
+  inputs: {
+    protocol: {}
+  },
+  run: function (api, data, next) {
+    try {
+      return api.models.settings.findOne({
+        where: {
+          name: 'ebp_protocol'
+        }
+      }).then(function (setting) {
+        if (!setting) {
+          setting = api.models.settings.build({
+            name: 'ebp_protocol'
+          })
+        }
+        setting.value = data.params.protocol
+        setting.save()
+        return next()
+      })
+    } catch (e) {
+      console.error(e)
+      return next(e)
+    }
+  }
+})