model-improve.js

const connection = require('./connection');

const insert = async (travel) => {
  const { passengerId, startingAddress, endingAddress } = travel;

  const [{ insertId }] = await connection.execute(
    'INSERT INTO travels'
     + '(passenger_id, starting_address, ending_address)' 
     + 'VALUE (?, ?, ?)',
    [passengerId, startingAddress, endingAddress],
  );

  return insertId;
};

const findById = async (travelId) => {
  const [[travel]] = await connection.execute(
    'SELECT * FROM travels WHERE id = ?',
    [travelId],
  );

  if (!travel) {
    return null;
  }

  return {
    passengerId: travel.passenger_id,
    startingAddress: travel.starting_address,
    endingAddress: travel.ending_address,
  };
};

const findByTravelStatusId = async (travelStatusId) => {
  const [travels] = await connection.execute(
    'SELECT * FROM travels WHERE travel_status_id = ?',
    [travelStatusId],
  );

  return travels.map((travel) => ({
    passengerId: travel.passenger_id,
    startingAddress: travel.starting_address,
    endingAddress: travel.ending_address,
  }));
};

module.exports = {
  insert,
  findById,
  findByTravelStatusId,
};