Как правильно структуризовать обработчик API на NodeJS?

Question

[BEKa T]

Переписал я значит service.php на NodeJS, но не уверен что правильно сделал. Вызывает ошибку

SyntaxError: "[object Object]" is not valid JSON
    at JSON.parse (<anonymous>)
    at Object.process (file:///D:/code/SimSim/routes/user.js:190:54)
    at file:///D:/code/SimSim/routes/user.js:270:17
    at Layer.handle [as handle_request] (D:\code\SimSim\node_modules\express\lib\router\layer.js:95:5)
    at next (D:\code\SimSim\node_modules\express\lib\router\route.js:144:13)
    at Route.dispatch (D:\code\SimSim\node_modules\express\lib\router\route.js:114:3)
    at Layer.handle [as handle_request] (D:\code\SimSim\node_modules\express\lib\router\layer.js:95:5)
    at D:\code\SimSim\node_modules\express\lib\router\index.js:284:15
    at Function.process_params (D:\code\SimSim\node_modules\express\lib\router\index.js:346:12)
    at next (D:\code\SimSim\node_modules\express\lib\router\index.js:280:10)

service.JS

class CdekService {
    constructor(login, secret, baseUrl = 'https://api.cdek.ru/v2') {
        this.login = login;
        this.secret = secret;
        this.baseUrl = baseUrl;
        this.authToken = null;
        this.requestData = null;
    }
  
    process(requestData, body) {
        this.requestData = { ...requestData, ...(JSON.parse(body) || {}) };
  
        if (!this.requestData.action) {
            this.sendValidationError('Action is required');
        }
  
        this.getAuthToken();
  
        switch (this.requestData.action) {
            case 'offices':
                this.sendResponse(this.getOffices());
                break;
            case 'calculate':
                this.sendResponse(this.calculate());
                break;
            default:
                this.sendValidationError('Unknown action');
        }
    }
  
    sendValidationError(message) {
        console.error(message);
        process.exit(1);
    }
  
    async getAuthToken() {
        try {
            const response = await axios.post(`${this.baseUrl}/oauth/token`, {
                grant_type: 'client_credentials',
                client_id: this.login,
                client_secret: this.secret,
            });
  
            if (response.data.access_token) {
                this.authToken = response.data.access_token;
            } else {
                throw new Error('Server not authorized to CDEK API');
            }
        } catch (error) {
            console.error('Error acquiring token:', error.message);
            this.sendError(error.message);
        }
    }
  
    async httpRequest(method, data, useFormData = false, useJson = false) {
        const headers = {
            'Accept': 'application/json',
        };
  
        if (this.authToken) {
            headers['Authorization'] = `Bearer ${this.authToken}`;
        }
  
        try {
            const response = await axios({
                method: 'post',
                url: `${this.baseUrl}/${method}`,
                headers,
                data: useJson ? JSON.stringify(data) : data,
            });
  
            return response.data;
        } catch (error) {
            throw new Error(error.message);
        }
    }
  
    sendResponse(data) {
        console.log(data);
        process.exit(0);
    }
  
    async getOffices() {
        return this.httpRequest('deliverypoints', this.requestData);
    }
  
    async calculate() {
        return this.httpRequest('calculator/tarifflist', this.requestData, false, true);
    }
  }
  
  const cdekService = new CdekService('LOGIN', 'PASS');
  
  // Assume req.query and requestBody contain the necessary data
  router.get('/service', async (req, res) =>{
    cdekService.process(req.query, req.body);
  })

Помогите, пожалуйста, переписать корректно

Comments

[Сергей delphinpro]

Навскидку:

- process(requestData, body) {
+ async process(requestData, body) {
        this.requestData = { ...requestData, ...(JSON.parse(body) || {}) };
  
        if (!this.requestData.action) {
            this.sendValidationError('Action is required');
        }
  
-       this.getAuthToken();
+       await this.getAuthToken();
  
        switch (this.requestData.action) {

И здесь тоже

async getOffices() {
-        return this.httpRequest('deliverypoints', this.requestData);
+        return await this.httpRequest('deliverypoints', this.requestData);
    }
  
    async calculate() {
-        return this.httpRequest('calculator/tarifflist', this.requestData, false, true);
+        return await this.httpRequest('calculator/tarifflist', this.requestData, false, true);
    }

[BEKa T]

Сергей delphinpro, отметил у себя. Что дальше?))

Answer 1

[Алексей Ярков]

cdekService.process(req.query, req.body); // в req.body у вас строка уже испорченная приходит, а не в json

Показывайте код до router.get. Подозреваю что у вас какой-нибудь express и не включён middleware обработки тела запроса.

Comments

[BEKa T]

дело в том, что для начального отображения body вообще не нужен. Ну то есть хотя бы сам виджет должен показываться. С фронта приходит action=offices и по нему делаю запрос в СДЭК api.
Получаю json со всеми точками 10к наверное и это все отрисовывается в Яндекс карте.

spoiler

// CDEK
import axios from 'axios'

router.get("/service", async (req, res) => {
console.log("REQUEST прилетел", req.body)
console.log("REQUEST прилетел", req.query)

const baseURL = 'https://api.cdek.ru/v2';
const client_credentials = 'client_credentials';
const clientId = 'LOGIN';
const clientSecret = 'PASS';

// Get authToken
async function getAuthToken() {
  try {
    await axios({
      method: "post",
      baseURL: baseURL,
      url: "oauth/token",
      params: {
        client_id: clientId,
        client_secret: clientSecret,
        grant_type: client_credentials,
      },
    }).then(function (response) {
        console.log("API TOKEN:", response.data.access_token);
        getOffices(response.data.access_token)
        return response.data.access_token
      }).catch(function (error) {
        console.log("error", error);
        return null;
    });
  } catch (error) {
    console.error(error);
  }
}

// Получить все отделения ПВЗ
async function getOffices(authToken) {
  try {
    await axios({
      method: "get",
      baseURL: baseURL,
      url: "deliverypoints",
      params: {
        client_id: clientId,
        client_secret: clientSecret,
        grant_type: client_credentials,
        is_handout: true,
        weight: 1000,
      },
      headers: {
        Authorization: "Bearer " + authToken,
      },
    })
      .then(function (response) {
        // console.log("Отделения ПВЗ:", response.data);
        return res.json(response.data);
      })
      .catch(function (error) {
        console.log("error", error);
        return null;
      });
  } catch (error) {
    console.error(error);
  }
}


if(req.query){
  getAuthToken();

  if(req.query.action == "offices"){
    await getOffices()

    console.log("FUNCTION offices")
    console.log("req.query.action", req.query.action)
  } else {
    res.json("Action require")
  }
} else{
  console.error('NO actions', req.query);
}
})

router.post("/service", async (req, res) => {
  console.log("REQUEST body прилетел", req.body)
  console.log("REQUEST query прилетел", req.query)
  
  const baseURL = 'https://api.cdek.ru/v2';
  const client_credentials = 'client_credentials';
  const clientId = 'LOGIN';
  const clientSecret = 'PASS';
  
  // Get authToken
  async function getAuthToken() {
    try {
      await axios({
        method: "post",
        baseURL: baseURL,
        url: "oauth/token",
        params: {
          client_id: clientId,
          client_secret: clientSecret,
          grant_type: client_credentials,
        },
      }).then(function (response) {
          console.log("API TOKEN:", response.data.access_token);
          calculate(response.data.access_token)
          return response.data.access_token
        }).catch(function (error) {
          console.log("error", error);
          return null;
      });
    } catch (error) {
      console.error(error);
    }
  }
  
  
  // Получить все отделения ПВЗ
  async function calculate(authToken) {
    try {
      await axios({
        method: "post",
        baseURL: baseURL,
        url: "calculator/tarifflist",
        params: {
          client_id: clientId,
          client_secret: clientSecret,
          grant_type: client_credentials,
          is_handout: true,
          weight: 1000,
        },
        headers: {
          Authorization: "Bearer " + authToken,
        },
      })
        .then(function (response) {
          console.log("Отделения ПВЗ:", response);
          return res.json(response.data);
        })
        .catch(function (error) {
          console.log("error", error);
          return null;
        });
    } catch (error) {
      console.error(error);
    }
  }
  
  if(req.query){
    getAuthToken();
  
    if(req.query.action == "calculate"){
      console.log("FUNCTION calculate")
      await calculate()
    } else {
      res.json("Action require")
    }
  } else{
    console.error('NO actions', req.query);
  }
  })

Этот костыль отрабатывает начальные этапы. Но при выборе конкретного пункта выдачи. Прилетает пост запрос с данными ПВЗ и все ломается.

Я в принципе понимаю, что сделать, но уверен, что есть более масштабируемый способ. "Швейцарский нож", но пока для этого не хватает знаний ;)