boxesController.js

'use strict';

/**
 * @apiDefine ExposureFilterParam
 * @apiParam {String="indoor","outdoor","mobile","unknown"} [exposure] only include boxes with this exposure. Allows to specify multiple exposures separated by comma (Example: `indoor,mobile`)
 */

/**
 * MQTT broker integration data
 * @apiDefine MqttOption Settings for a senseBox connected through MQTT
 */

/**
 * @apiDefine MqttBody
 *
 * @apiParam (MqttOption) {Boolean} enabled="false" enable or disable mqtt
 * @apiParam (MqttOption) {String} url the url to the mqtt server.
 * @apiParam (MqttOption) {String} topic the topic to subscribe to.
 * @apiParam (MqttOption) {String="json","csv"} messageFormat the format the mqtt messages are in.
 * @apiParam (MqttOption) {String} decodeOptions a json encoded string with options for decoding the message. 'jsonPath' for 'json' messageFormat.
 * @apiParam (MqttOption) {String} connectionOptions a json encoded string with options to supply to the mqtt client (https://github.com/mqttjs/MQTT.js#client)
 */

/**
 * thethingsnetwork.org integration data
 * @apiDefine TTNOption Settings for a senseBox connected through thethingsnetwork.org (TTN)
 */

/**
 * @apiDefine TTNBody
 *
 * @apiParam (TTNOption) {String} dev_id The device ID recieved from TTN
 * @apiParam (TTNOption) {String} app_id The application ID recieved from TTN
 * @apiParam (TTNOption) {String="lora-serialization","sensebox/home","json","debug", "cayenne-lpp"} profile A decoding profile matching the payload format. For details and configuration see https://github.com/sensebox/ttn-osem-integration#decoding-profiles
 * @apiParam (TTNOption) {Array}  [decodeOptions] A JSON Array containing decoder configuration, needed for some profiles.
 * @apiParam (TTNOption) {Number} [port] The TTN port to listen for messages. Optional, if not provided, all ports are used.
 */

const
  { Box, User, Claim } = require('@sensebox/opensensemap-api-models'),
  { addCache, clearCache, checkContentType, redactEmail, postToSlack } = require('../helpers/apiUtils'),
  { point } = require('@turf/helpers'),
  classifyTransformer = require('../transformers/classifyTransformer'),
  {
    retrieveParameters,
    parseAndValidateTimeParamsForFindAllBoxes,
    validateFromToTimeParams,
    checkPrivilege,
    validateDateNotPast
  } = require('../helpers/userParamHelpers'),
  handleError = require('../helpers/errorHandler'),
  jsonstringify = require('stringify-stream');

/**
 * @apiDefine Addons
 * @apiParam {String="feinstaub"} addon specify a sensor addon for a box.
 */

/**
 * @api {put} /boxes/:senseBoxId Update a senseBox
 * @apiDescription
 * Modify the properties of a senseBox. Almost every aspect of a senseBox can be modified through this endpoint.
 *
 * ### Creating, updating or deleting sensors:
 *
 * Your request should contain a `sensors` array with at least one `sensor` object. You'll need to specify at least one of these properties:
 *
 * - `sensor` object has `"edited"` key present: Tell the API to replace all keys of the sensor with the specified `_id` with the supllied keys. (Specify all properties! `{ _id, title, unit, sensorType, icon }`)
 * - `sensor` object has `"edited"` and `"new"` keys: Tell the API this sensor is new and should be added to the senseBox. (Specify all properties! `{ title, unit, sensorType }`)
 * - `sensor` object has `"deleted"` key: Tell the API to delete this sensor from the senseBox. **Also deletes all measurements of this sensor!!** Needs the `_id` property.
 *
 * `sensor` objects without `edited`, `new`, or `deleted` keys will be ignored!
 *
 * @apiUse SensorBody
 * @apiUse LocationBody
 * @apiUse MqttBody
 * @apiUse TTNBody
 *
 * @apiParam (RequestBody) {String} [name] the name of this senseBox.
 * @apiParam (RequestBody) {String[]} [grouptag] the grouptag(s) of this senseBox. Send [] (empty array) to delete this property.
 * @apiParam (RequestBody) {Location} [location] the new coordinates of this senseBox. Measurements will keep the reference to their correct location
 * @apiParam (RequestBody) {Sensor[]} [sensors] an array containing the sensors of this senseBox. Only use if model is unspecified
 * @apiParam (RequestBody) {MqttOption} [mqtt] settings for the MQTT integration of this senseBox
 * @apiParam (RequestBody) {TTNOption} [ttn] settings for the TTN integration of this senseBox
 * @apiParam (RequestBody) {String} [description] the updated description of this senseBox. Send '' (empty string) to delete this property.
 * @apiParam (RequestBody) {String} [image] the updated image of this senseBox encoded as base64 data uri. To delete the current image, send 'deleteImage: true'.
 * @apiParam (RequestBody) {Object} [addons] allows to add addons to the box. Submit as Object with key `add` and the desired addon as value like `{"add":"feinstaub"}`
 * @apiParam (Sensor) {String} edited *Value is ignored. Presence alone is enough* Tell the API to consider this sensor for changing or deleting. Specify all properties, even if not changed!
 * @apiParam (Sensor) {String} new *Value is ignored. Presence alone is enough* Tell the API to add this new sensor to the senseBox.
 * @apiParam (Sensor) {String} deleted *Value is ignored. Presence alone is enough* Tell the API to delete this sensor from the senseBox. *Warning: This will also delete all measurements of this sensor*
 * @apiParamExample {json} Request-Example:
 * {
 *  "_id": "56e741ff933e450c0fe2f705",
 *  "name": "my senseBox",
 *  "description": "this is just a description",
 *  "weblink": "https://opensensemap.org/explore/561ce8acb3de1fe005d3d7bf",
 *  "grouptag": "senseBoxes99",
 *  "exposure": "indoor",
 *  "sensors": [
 *    {
 *      "_id": "56e741ff933e450c0fe2f707",
 *      "title": "UV-Intensität",
 *      "unit": "μW/cm²",
 *      "sensorType": "VEML6070",
 *      "icon": "osem-sprinkles",
 *      "edited": "true"
 *    }
 *  ],
 *  "location": {
 *    "lng": 8.6956,
 *    "lat": 50.0430
 *  },
 *  "image": "data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAMAAAAoLQ9TAAAAIVBMVEUAAABKrkMGteh0wW5Ixu931vKy3bO46fj/7hr/+J36/vyFw5EiAAAAAXRSTlMAQObYZgAAAF5JREFUeAFdjdECgzAIA1kIUvP/HzyhdrPe210L2GLYzhjj7VvRefmpn1MKFbdHUOzA9qRQEhIw3xMzEVeJDqkOrC9IJqWE7hFDLZ0Q6+zh7odsoU/j9qeDPXDf/cEX1xsDKIqAkK8AAAAASUVORK5CYII=",
 *  "mqtt": {
 *    "url": "some url",
 *    "topic": "some topic",
 *    "messageFormat": "json",
 *    "decodeOptions": "{\"jsonPath\":\"$.bla\"}"
 *  }
 *  "ttn": {
 *    "app_id": "my-app-id-from-ttn",
 *    "dev_id": "my-dev-id-from-ttn",
 *    "profile": "sensebox/home",
 *    "decodeOptions": "{\"jsonPath\":\"$.bla\"}"
 *  },
 *  "addons": { "add": "feinstaub" }
 * }
 * @apiGroup Boxes
 * @apiName updateBox
 * @apiUse JWTokenAuth
 * @apiUse BoxIdParam
 * @apiUse ContentTypeJSON
 *
 */
const updateBox = async function updateBox (req, res, next) {
  try {
    let box = await Box.findBoxById(req._userParams.boxId, { lean: false, populate: false });
    box = await box.updateBox(req._userParams);
    if (box._sensorsChanged === true) {
      req.user.mail('newSketch', box);
    }

    res.send({ code: 'Ok', data: box.toJSON({ includeSecrets: true }) });
    clearCache(['getBoxes']);
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {get} /boxes/:senseBoxId/locations Get locations of a senseBox
 * @apiGroup Boxes
 * @apiName getBoxLocations
 * @apiDescription Get all locations of the specified senseBox ordered by date as an array of GeoJSON Points.
 * If `format=geojson`, a GeoJSON linestring will be returned, with `properties.timestamps`
 * being an array with the timestamp for each coordinate.
 *
 * @apiParam {String=json,geojson} format=json
 * @apiParam {RFC3339Date} [from-date] Beginning date of location timestamps (default: 48 hours ago from now)
 * @apiParam {RFC3339Date} [to-date] End date of location timstamps (default: now)
 * @apiUse BoxIdParam
 *
 * @apiSuccessExample {application/json} Example response for :format=json
 * [
 *   { "coordinates": [7.68123, 51.9123], "type": "Point", "timestamp": "2017-07-27T12:00:00Z"},
 *   { "coordinates": [7.68223, 51.9433, 66.6], "type": "Point", "timestamp": "2017-07-27T12:01:00Z"},
 *   { "coordinates": [7.68323, 51.9423], "type": "Point", "timestamp": "2017-07-27T12:02:00Z"}
 * ]
 */
const getBoxLocations = async function getBoxLocations (req, res, next) {
  // TODO: do we really need this ?!?! -> just used in frontend to display the line / path
  try {
    const box = await Box.findBoxById(req._userParams.boxId, { onlyLocations: true, lean: false });
    res.send(await box.getLocations(req._userParams));
  } catch (err) {
    handleError(err, next);
  }
};

const geoJsonStringifyReplacer = function geoJsonStringifyReplacer (key, box) {
  if (key === '') {
    const coordinates = box.currentLocation.coordinates;
    box.currentLocation = undefined;
    box.loc = undefined;

    return point(coordinates, box);
  }

  return box;
};

/**
 * @api {get} /boxes?date=:date&phenomenon=:phenomenon&format=:format Get all senseBoxes
 * @apiDescription With the optional `date` and `phenomenon` parameters you can find senseBoxes that have submitted data around that time, +/- 4 hours, or specify two dates separated by a comma.
 * @apiName getBoxes
 * @apiGroup Boxes
 * @apiParam {String} [name] Search string to find boxes by name, if specified all other parameters are ignored.
 * @apiParam {Number} [limit=5] Limit the search results.
 * @apiParam {RFC3339Date} [date] One or two RFC 3339 timestamps at which boxes should provide measurements. Use in combination with `phenomenon`.
 * @apiParam {String} [phenomenon] A sensor phenomenon (determined by sensor name) such as temperature, humidity or UV intensity. Use in combination with `date`.
 * @apiParam {String=json,geojson} [format=json] the format the sensor data is returned in.
 * @apiParam {String} [grouptag] only return boxes with this grouptag, allows to specify multiple separated with a comma
 * @apiParam {String="homeEthernet","homeWifi","homeEthernetFeinstaub","homeWifiFeinstaub","luftdaten_sds011","luftdaten_sds011_dht11","luftdaten_sds011_dht22","luftdaten_sds011_bmp180","luftdaten_sds011_bme280"} [model] only return boxes with this model, allows to specify multiple separated with a comma
 * @apiParam {Boolean="true","false"} [classify=false] if specified, the api will classify the boxes accordingly to their last measurements.
 * @apiParam {Boolean="true","false"} [minimal=false] if specified, the api will only return a minimal set of box metadata consisting of [_id, updatedAt, currentLocation, exposure, name] for a fast response.
 * @apiParam {Boolean="true","false"} [full=false] if true the API will return populated lastMeasurements (use this with caution for now, expensive on the database)
 * @apiParam {String} [near] A comma separated coordinate, if specified, the api will only return senseBoxes within maxDistance (in m) of this location
 * @apiParam {Number} [maxDistance=1000] the amount of meters around the near Parameter that the api will search for senseBoxes
 * @apiUse ExposureFilterParam
 * @apiUse BBoxParam
 * @apiSampleRequest https://api.opensensemap.org/boxes
 * @apiSampleRequest https://api.opensensemap.org/boxes?date=2015-03-07T02:50Z&phenomenon=Temperatur
 * @apiSampleRequest https://api.opensensemap.org/boxes?date=2015-03-07T02:50Z,2015-04-07T02:50Z&phenomenon=Temperatur
 */
const getBoxes = async function getBoxes (req, res, next) {
  // content-type is always application/json for this route
  res.header('Content-Type', 'application/json; charset=utf-8');

  // default format
  let stringifier = jsonstringify({ open: '[', close: ']' });
  // format
  if (req._userParams.format === 'geojson') {
    stringifier = jsonstringify({ open: '{"type":"FeatureCollection","features":[', close: ']}' }, geoJsonStringifyReplacer);
  }

  try {
    let stream;

    // Search boxes by name
    // Directly return results and do nothing else
    if (req._userParams.name) {
      stream = await Box.findBoxes(req._userParams);
    } else {
      if (req._userParams.minimal === 'true') {
        stream = await Box.findBoxesMinimal(req._userParams);
      } else {
        stream = await Box.findBoxesLastMeasurements(req._userParams);
      }

      if (req._userParams.classify === 'true') {
        stream = stream
          .pipe(new classifyTransformer())
          .on('error', function (err) {
            res.end(`Error: ${err.message}`);
          });
      }
    }

    stream
      .pipe(stringifier)
      .on('error', function (err) {
        res.end(`Error: ${err.message}`);
      })
      .pipe(res);
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {get} /boxes/:senseBoxId?format=:format Get one senseBox
 * @apiName getBox
 * @apiGroup Boxes
 *
 * @apiUse BoxIdParam
 * @apiParam {String=json,geojson} [format=json] The format the sensor data is returned in. If `geojson`, a GeoJSON Point Feature is returned.
 *
 * @apiSuccessExample Example data on success:
 * {
  "_id": "57000b8745fd40c8196ad04c",
  "createdAt": "2016-06-02T11:22:51.817Z",
  "exposure": "outdoor",
  "grouptag": "",
  "image": "57000b8745fd40c8196ad04c.png?1466435154159",
  "currentLocation": {
    "coordinates": [
      7.64568,
      51.962372
    ],
    "timestamp": "2016-06-02T11:22:51.817Z",
    "type": "Point"
  },
  "name": "Oststr/Mauritzsteinpfad",
  "sensors": [
    {
      "_id": "57000b8745fd40c8196ad04e",
      "lastMeasurement": {
        "value": "0",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "sensorType": "VEML6070",
      "title": "UV-Intensität",
      "unit": "μW/cm²"
    },
    {
      "_id": "57000b8745fd40c8196ad04f",
      "lastMeasurement": {
        "value": "0",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "sensorType": "TSL45315",
      "title": "Beleuchtungsstärke",
      "unit": "lx"
    },
    {
      "_id": "57000b8745fd40c8196ad050",
      "lastMeasurement": {
        "value": "1019.21",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "sensorType": "BMP280",
      "title": "Luftdruck",
      "unit": "hPa"
    },
    {
      "_id": "57000b8745fd40c8196ad051",
      "lastMeasurement": {
        "value": "99.38",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "sensorType": "HDC1008",
      "title": "rel. Luftfeuchte",
      "unit": "%"
    },
    {
      "_id": "57000b8745fd40c8196ad052",
      "lastMeasurement": {
        "value": "0.21",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "sensorType": "HDC1008",
      "title": "Temperatur",
      "unit": "°C"
    },
    {
      "_id": "576996be6c521810002479dd",
      "sensorType": "WiFi",
      "unit": "dBm",
      "title": "Wifi-Stärke",
      "lastMeasurement": {
        "value": "-66",
        "createdAt": "2016-11-11T21:22:01.675Z"
      }
    },
    {
      "_id": "579f9eae68b4a2120069edc8",
      "sensorType": "VCC",
      "unit": "V",
      "title": "Eingangsspannung",
      "lastMeasurement": {
        "value": "2.73",
        "createdAt": "2016-11-11T21:22:01.675Z"
      },
      "icon": "osem-shock"
    }
  ],
  "updatedAt": "2016-11-11T21:22:01.686Z"
}
 */

const getBox = async function getBox (req, res, next) {
  const { format, boxId } = req._userParams;

  try {
    const box = await Box.findBoxById(boxId);

    if (format === 'geojson') {
      const coordinates = box.currentLocation.coordinates;
      box.currentLocation = undefined;
      box.loc = undefined;

      return res.send(point(coordinates, box));
    }
    res.send(box);
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {post} /boxes Post new senseBox
 * @apiGroup Boxes
 * @apiName postNewBox
 * @apiDescription Create a new senseBox. This method allows you to submit a new senseBox.
 *
 * ### MQTT Message formats
 * If you specify `mqtt` parameters, the openSenseMap API will try to connect to the MQTT broker
 * specified by you. The parameter `messageFormat` tells the API in which format you are sending
 * measurements in. The accepted formats are listed under `Measurements/Post mutliple new Measurements`
 *
 * @apiParam (RequestBody) {String} name the name of this senseBox.
 * @apiParam (RequestBody) {String} [grouptag] the grouptag of this senseBox.
 * @apiParam (RequestBody) {String="indoor","outdoor","mobile","unknown"} exposure the exposure of this senseBox.
 * @apiParam (RequestBody) {Location} location the coordinates of this senseBox.
 * @apiParam (RequestBody) {String="homeV2Lora","homeV2Ethernet","homeV2Wifi","homeEthernet","homeWifi","homeEthernetFeinstaub","homeWifiFeinstaub","luftdaten_sds011","luftdaten_sds011_dht11","luftdaten_sds011_dht22","luftdaten_sds011_bmp180","luftdaten_sds011_bme280","hackair_home_v2"} [model] specify the model if you want to use a predefined senseBox model, autocreating sensor definitions.
 * @apiParam (RequestBody) {Sensor[]} [sensors] an array containing the sensors of this senseBox. Only use if `model` is unspecified.
 * @apiParam (RequestBody) {String[]="hdc1080","bmp280","tsl45315","veml6070","sds011","bme680","smt50","soundlevelmeter","windspeed","scd30","dps310"} [sensorTemplates] Specify which sensors should be included.
 * @apiParam (RequestBody) {Object} [mqtt] specify parameters of the MQTT integration for external measurement upload. Please see below for the accepted parameters
 * @apiParam (RequestBody) {Object} [ttn] specify parameters for the TTN integration for measurement from TheThingsNetwork.org upload. Please see below for the accepted parameters
 * @apiParam (RequestBody) {Boolean="true","false"} [useAuth] whether to use access_token or not for authentication
 *
 * @apiUse LocationBody
 * @apiUse SensorBody
 * @apiUse MqttBody
 * @apiUse TTNBody
 * @apiUse ContentTypeJSON
 * @apiUse JWTokenAuth
 */
const postNewBox = async function postNewBox (req, res, next) {
  try {
    let newBox = await req.user.addBox(req._userParams);
    newBox = await Box.populate(newBox, Box.BOX_SUB_PROPS_FOR_POPULATION);
    res.send(201, { message: 'Box successfully created', data: newBox });
    clearCache(['getBoxes', 'getStats']);
    postToSlack(`New Box: ${req.user.name} (${redactEmail(req.user.email)}) just registered "${newBox.name}" (${newBox.model}): <https://opensensemap.org/explore/${newBox._id}|link>`);
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {get} /boxes/:senseBoxId/script Download the Arduino script for your senseBox
 * @apiName getSketch
 * @apiGroup Boxes
 * @apiParam {String="Serial1","Serial2"} [serialPort] the serial port the SDS011 sensor is connected to
 * @apiParam {String="A","B","C"} [soilDigitalPort] the digital port the SMT50 sensor is connected to
 * @apiParam {String="A","B","C"} [soundMeterPort] the digital port the soundlevelmeter sensor is connected to
 * @apiParam {String="A","B","C"} [windSpeedPort] the digital port the windspeed sensor is connected to
 * @apiParam {String} [ssid] the ssid of your wifi network
 * @apiParam {String} [password] the password of your wifi network
 * @apiParam {String} [devEUI] the devEUI of TTN device
 * @apiParam {String} [appEUI] the appEUI of TTN application
 * @apiParam {String} [appKey] the appKey of TTN application
 * @apiParam {Boolean="true","false"} [display_enabled] include code for an attached oled display
 * @apiUse JWTokenAuth
 * @apiUse BoxIdParam
 */
const getSketch = async function getSketch (req, res, next) {
  res.header('Content-Type', 'text/plain; charset=utf-8');
  try {
    const box = await Box.findBoxById(req._userParams.boxId, { populate: false, lean: false });

    const params = {
      serialPort: req._userParams.serialPort,
      soilDigitalPort: req._userParams.soilDigitalPort,
      soundMeterPort: req._userParams.soundMeterPort,
      windSpeedPort: req._userParams.windSpeedPort,
      ssid: req._userParams.ssid,
      password: req._userParams.password,
      devEUI: req._userParams.devEUI,
      appEUI: req._userParams.appEUI,
      appKey: req._userParams.appKey,
      display_enabled: req._userParams.display_enabled
    };

    // pass access token only if useAuth is true and access_token is available
    if (box.access_token) {
      params.access_token = box.access_token;
    }

    res.send(box.getSketch(params));
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {delete} /boxes/:senseBoxId Mark a senseBox and its measurements for deletion
 * @apiDescription This will delete all the measurements of the senseBox. Please note that the deletion isn't happening immediately.
 * @apiName deleteBox
 * @apiGroup Boxes
 * @apiUse ContentTypeJSON
 * @apiParam {String} password the current password for this user.
 * @apiUse JWTokenAuth
 * @apiUse BoxIdParam
 */
const deleteBox = async function deleteBox (req, res, next) {
  const { password, boxId } = req._userParams;

  try {
    await req.user.checkPassword(password);
    const box = await req.user.removeBox(boxId);
    res.send({ code: 'Ok', message: 'box and all associated measurements marked for deletion' });
    clearCache(['getBoxes', 'getStats']);
    postToSlack(`Box deleted: ${req.user.name} (${redactEmail(req.user.email)}) just deleted "${box.name}" (${boxId})`);

  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {get} /boxes/transfer/:senseBoxId Get transfer information for a senseBox
 * @apiDescription Get transfer information for a senseBox
 * @apiName getTransfer
 * @apiGroup Boxes
 * @apiUse JWTokenAuth
 * @apiUse BoxIdParam
 */
const getTransfer = async function getTransfer (req, res, next) {
  const { boxId } = req._userParams;
  try {
    const transfer = await Claim.findClaimByDeviceID(boxId);
    res.send(200, {
      data: transfer,
    });
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {post} /boxes/transfer Mark a senseBox for transferring to a different user
 * @apiDescription This will mark a senseBox for transfering it to a different user account
 * @apiName createTransfer
 * @apiGroup Boxes
 * @apiParam (RequestBody) {String} boxId ID of the senseBox you want to transfer.
 * @apiParam (RequestBody) {RFC3339Date} expiresAt Expiration date for transfer token (default: 24 hours from now).
 * @apiUse JWTokenAuth
 */
const createTransfer = async function createTransfer (req, res, next) {
  const { boxId, date } = req._userParams;
  try {
    const transferCode = await req.user.transferBox(boxId, date);
    res.send(201, {
      message: 'Box successfully prepared for transfer',
      data: transferCode,
    });
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {put} /boxes/transfer/:senseBoxId Update a transfer token
 * @apiDescription Update the expiration date of a transfer token
 * @apiName updateTransfer
 * @apiGroup Boxes
 * @apiParam (RequestBody) {String} Transfer token you want to update.
 * @apiParam (RequestBody) {RFC3339Date} expiresAt Expiration date for transfer token (default: 24 hours from now).
 * @apiUse JWTokenAuth
 * @apiUse BoxIdParam
 */
const updateTransfer = async function updateTransfer (req, res, next) {
  const { boxId, token, date } = req._userParams;
  try {
    const transfer = await req.user.updateTransfer(boxId, token, date);
    res.send(200, {
      message: 'Transfer successfully updated',
      data: transfer,
    });
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {delete} /boxes/transfer Revoke transfer token and remove senseBox from transfer
 * @apiDescription This will revoke the transfer token and remove the senseBox from transfer
 * @apiName removeTransfer
 * @apiGroup Boxes
 * @apiParam (RequestBody) {String} boxId ID of the senseBox you want to remove from transfer.
 * @apiParam (RequestBody) {String} token Transfer token you want to revoke.
 * @apiUse JWTokenAuth
 */
const removeTransfer = async function removeTransfer (req, res, next) {
  const { boxId, token } = req._userParams;
  try {
    await req.user.removeTransfer(boxId, token);
    res.send(204);
  } catch (err) {
    handleError(err, next);
  }
};

/**
 * @api {post} /boxes/claim Claim a senseBox marked for transfer
 * @apiDescription This will claim a senseBox marked for transfer
 * @apiName claimBox
 * @apiGroup Boxes
 * @apiUse ContentTypeJSON
 * @apiParam (RequestBody) {String} token the token to claim a senseBox
 * @apiUse JWTokenAuth
 */
const claimBox = async function claimBox (req, res, next) {
  const { token } = req._userParams;

  try {
    const { owner, claim } = await req.user.claimBox(token);
    await User.transferOwnershipOfBox(owner, claim.boxId);

    await claim.expireToken();

    res.send(200, { message: 'Device successfully claimed!' });
  } catch (err) {
    handleError(err, next);
  }
};

module.exports = {
  // auth required
  deleteBox: [
    checkContentType,
    retrieveParameters([
      { predef: 'boxId', required: true },
      { predef: 'password' },
    ]),
    checkPrivilege,
    deleteBox,
  ],
  getTransfer: [
    retrieveParameters([{ predef: 'boxId', required: true }]),
    checkPrivilege,
    getTransfer,
  ],
  createTransfer: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      { predef: 'dateNoDefault' },
    ]),
    validateDateNotPast,
    checkPrivilege,
    createTransfer,
  ],
  updateTransfer: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      { name: 'token', dataType: 'String' },
      { predef: 'dateNoDefault', required: true },
    ]),
    validateDateNotPast,
    checkPrivilege,
    updateTransfer,
  ],
  removeTransfer: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      { name: 'token', dataType: 'String' },
    ]),
    checkPrivilege,
    removeTransfer,
  ],
  claimBox: [
    checkContentType,
    retrieveParameters([{ name: 'token', dataType: 'String' }]),
    claimBox,
  ],
  getSketch: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      {
        name: 'serialPort',
        dataType: 'String',
        allowedValues: ['Serial1', 'Serial2'],
      },
      {
        name: 'soilDigitalPort',
        dataType: 'String',
        allowedValues: ['A', 'B', 'C'],
      },
      {
        name: 'soundMeterPort',
        dataType: 'String',
        allowedValues: ['A', 'B', 'C'],
      },
      {
        name: 'windSpeedPort',
        dataType: 'String',
        allowedValues: ['A', 'B', 'C'],
      },
      { name: 'ssid', dataType: 'StringWithEmpty' },
      { name: 'password', dataType: 'StringWithEmpty' },
      { name: 'devEUI', dataType: 'StringWithEmpty' },
      { name: 'appEUI', dataType: 'StringWithEmpty' },
      { name: 'appKey', dataType: 'StringWithEmpty' },
      { name: 'display_enabled', allowedValues: ['true', 'false'] },
    ]),
    checkPrivilege,
    getSketch,
  ],
  updateBox: [
    checkContentType,
    retrieveParameters([
      { predef: 'boxId', required: true },
      { name: 'name' },
      { name: 'grouptag', dataType: ['String'] },
      { name: 'description', dataType: 'StringWithEmpty' },
      { name: 'weblink', dataType: 'StringWithEmpty' },
      { name: 'image', dataType: 'base64Image' },
      { name: 'exposure', allowedValues: Box.BOX_VALID_EXPOSURES },
      { name: 'mqtt', dataType: 'object' },
      { name: 'ttn', dataType: 'object' },
      { name: 'sensors', dataType: ['object'] },
      { name: 'addons', dataType: 'object' },
      { predef: 'location' },
      { name: 'useAuth', allowedValues: ['true', 'false'] },
      { name: 'generate_access_token', allowedValues: ['true', 'false'] },
    ]),
    checkPrivilege,
    updateBox,
  ],
  // no auth required
  getBoxLocations: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      {
        name: 'format',
        defaultValue: 'json',
        allowedValues: ['json', 'geojson'],
      },
      { predef: 'toDate' },
      { predef: 'fromDate' },
      validateFromToTimeParams,
    ]),
    getBoxLocations,
  ],
  postNewBox: [
    checkContentType,
    retrieveParameters([
      { name: 'name', required: true },
      { name: 'grouptag', dataType: ['String'], aliases: ['tag'] },
      { name: 'exposure', allowedValues: Box.BOX_VALID_EXPOSURES },
      { name: 'model', allowedValues: Box.BOX_VALID_MODELS },
      { name: 'sensors', dataType: ['object'] },
      {
        name: 'sensorTemplates',
        dataType: ['String'],
        allowedValues: [
          'hdc1080',
          'bmp280',
          'sds 011',
          'tsl45315',
          'veml6070',
          'bme680',
          'smt50',
          'soundlevelmeter',
          'windspeed',
          'scd30',
          'dps310',
        ],
      },
      {
        name: 'serialPort',
        dataType: 'String',
        defaultValue: 'Serial1',
        allowedValues: ['Serial1', 'Serial2'],
      },
      {
        name: 'soilDigitalPort',
        dataType: 'String',
        defaultValue: 'A',
        allowedValues: ['A', 'B', 'C'],
      },
      {
        name: 'soundMeterPort',
        dataType: 'String',
        defaultValue: 'B',
        allowedValues: ['A', 'B', 'C'],
      },
      {
        name: 'windSpeedPort',
        dataType: 'String',
        defaultValue: 'C',
        allowedValues: ['A', 'B', 'C'],
      },
      { name: 'mqtt', dataType: 'object' },
      { name: 'ttn', dataType: 'object' },
      { name: 'useAuth', allowedValues: ['true', 'false'] },
      { predef: 'location', required: true },
    ]),
    postNewBox,
  ],
  getBox: [
    retrieveParameters([
      { predef: 'boxId', required: true },
      {
        name: 'format',
        defaultValue: 'json',
        allowedValues: ['json', 'geojson'],
      },
    ]),
    getBox,
  ],
  getBoxes: [
    retrieveParameters([
      { name: 'name', dataType: 'String' },
      { name: 'limit', dataType: 'Number', defaultValue: 5, min: 1, max: 20 },
      {
        name: 'exposure',
        allowedValues: Box.BOX_VALID_EXPOSURES,
        dataType: ['String'],
      },
      { name: 'model', dataType: ['StringWithEmpty'] },
      { name: 'grouptag', dataType: ['StringWithEmpty'] },
      { name: 'phenomenon', dataType: 'StringWithEmpty' },
      { name: 'date', dataType: ['RFC 3339'] },
      {
        name: 'format',
        defaultValue: 'json',
        allowedValues: ['json', 'geojson'],
      },
      {
        name: 'classify',
        defaultValue: 'false',
        allowedValues: ['true', 'false'],
      },
      {
        name: 'minimal',
        defaultValue: 'false',
        allowedValues: ['true', 'false'],
      },
      { name: 'full', defaultValue: 'false', allowedValues: ['true', 'false'] },
      { name: 'near' },
      { name: 'maxDistance' },
      { predef: 'bbox' },
    ]),
    parseAndValidateTimeParamsForFindAllBoxes,
    addCache('5 minutes', 'getBoxes'),
    getBoxes,
  ],
};