create api routes

pages/api/datamart/v0/land/[...slug].js

@@ -0,0 +1,118 @@
+// eslint-disable-next-line no-unused-vars
+import { NextApiRequest, NextApiResponse } from 'next';
+import {
+  createRequestByGeostoryId,
+  getDataByGeostoreId,
+  getDataFromLink,
+} from 'services/datamart';
+import { GFW_DATA_API, GFW_STAGING_DATA_API } from 'utils/apis';
+
+// types
+/**
+ * @typedef {object} DataLinkObject
+ * @property {string} link - The URL to POST the content.
+ */
+
+/**
+ * @typedef {object} GetResponseObject
+ * @property {string} status - status.
+ * @property {DataLinkObject} data - data link object.
+ */
+
+/**
+ * @typedef {object} NotFoundObject
+ * @property {string} status - status.
+ * @property {string} message - message.
+ */
+// END types
+
+const ENVIRONMENT = process.env.NEXT_PUBLIC_FEATURE_ENV;
+
+// We never use the staging api
+export const DATA_API_URL =
+  ENVIRONMENT === 'staging' ? GFW_STAGING_DATA_API : GFW_DATA_API;
+
+/**
+ * @param {NextApiRequest} req
+ * @param {NextApiResponse} res
+ */
+const fetchDataByDatasetAndGeostore = async (req, res) => {
+  const { query } = req;
+  // TODO: add more parameters to the query like, global, adm9, adm1, etc etc etc
+  const { slug: slugs, geostore_id, canopy_cover } = query;
+
+  if (slugs.length === 0) {
+    res.status(400).send();
+    return;
+  }
+
+  if (slugs.length === 1) {
+    const dataByGeostore = await getDataByGeostoreId({
+      dataset: slugs[0],
+      geostoreId: geostore_id,
+      canopy: canopy_cover,
+    });
+
+    res.status(200).send(dataByGeostore);
+    return;
+  }
+
+  const url = `${DATA_API_URL}/${slugs.join('/')}`;
+  try {
+    const dataByUrl = await getDataFromLink({ url });
+
+    res.send(dataByUrl);
+  } catch (error) {
+    res.status(error.response?.status).send({
+      status: error.response?.status,
+      message: error?.message,
+    });
+  }
+};
+
+/**
+ * @param {NextApiRequest} req
+ * @param {NextApiResponse} res
+ */
+const postData = async (req, res) => {
+  const { query } = req;
+  // TODO: add more parameters to the query like, global, adm9, adm1, etc etc etc
+  const { slug: slugs, geostore_id, canopy_cover } = query;
+
+  if (slugs.length === 0) {
+    res.status(400).send();
+    return;
+  }
+
+  try {
+    const submitted = await createRequestByGeostoryId({
+      dataset: slugs[0],
+      geostoreId: geostore_id,
+      canopy: canopy_cover,
+    });
+
+    res.status(201).send(submitted);
+  } catch (error) {
+    res.status(error.response?.status).send({
+      status: error.response?.status,
+      message: error?.message,
+    });
+  }
+};
+
+/**
+ * @param {NextApiRequest} req
+ * @param {NextApiResponse} res
+ */
+export default async (req, res) => {
+  switch (req.method) {
+    case 'POST':
+      postData(req, res);
+      break;
+    case 'GET':
+      fetchDataByDatasetAndGeostore(req, res);
+      break;
+    default:
+      res.send(405);
+  }
+};

services/datamart.js

@@ -1,4 +1,3 @@
-import axios from 'axios';
 import qs from 'qs';
 import { dataRequest } from 'utils/request';
 
@@ -22,13 +21,13 @@ import { dataRequest } from 'utils/request';
 /**
  * 1
  * @param {Object} request - request
+ * @param {string} request.dataset - dataset.
  * @param {string} request.geostoreId - a geostore id.
  * @param {number} request.canopy - canopy filter.
  * @returns {Promise<GetResponseObject | NotFoundObject>} response.
  */
-export const getDataByGeostoreId = async ({ geostoreId, canopy }) => {
-  // TODO: receive url as a param (or at least the dataset)
-  const url = '/v0/land/tree-cover-loss-by-driver';
+export const getDataByGeostoreId = async ({ dataset, geostoreId, canopy }) => {
+  const url = `/v0/land/${dataset}`;
   const params = {
     geostore_id: geostoreId,
     canopy_cover: canopy,
@@ -58,46 +57,33 @@ export const getDataByGeostoreId = async ({ geostoreId, canopy }) => {
 /**
  * 2
  * @param {Object} request - request
+ * @param {string} request.dataset - dataset.
  * @param {string} request.geostoreId - a geostore id.
  * @param {number} request.canopy - canopy filter.
  * @returns {Promise<GetResponseObject>} response.
  */
-export const createRequestByGeostoryId = async ({ geostoreId, canopy }) => {
-  // TODO: receive url as a param (or at least the dataset)
-  const url = '/v0/land/tree-cover-loss-by-driver';
+export const createRequestByGeostoryId = async ({
+  dataset,
+  geostoreId,
+  canopy,
+}) => {
+  const url = `/v0/land/${dataset}`;
   const params = {
     geostore_id: geostoreId,
     canopy_cover: canopy,
   };
 
-  console.log('POSTing...');
   const response = await dataRequest.post(url, params);
 
   return response;
 };
 
-const DATA_API_KEY = process.env.NEXT_PUBLIC_GFW_API_KEY;
 /**
  * 3
  * @param {Object} request - request
  * @param {string} request.url - url
  * @returns {Promise<GetResponseObject>} response.
  */
-export const getDataFromLink = async ({ url }) => {
-
-  console.log('> getDataFromLink: ', url)
-  try {
-  const response = await axios.create({
-    timeout: 30 * 1000,
-    headers: {
-      'x-api-key': DATA_API_KEY,
-    },
-    transformResponse: [(data) => JSON.parse(data)?.data],
-  }).get(url);
-  console.log('>> getDataFromLink response: ', response);
-  return response;
-  } catch (error) {
-    console.log('> err: ', error);
-    throw error;
-  }
+export const getDataFromLink = ({ url }) => {
+  return dataRequest.get(url);
 };