index.js

const Joi = require('joi')
const Sequelize = require('sequelize')
const Hapi = require('hapi');
const Inert = require("inert");
const Vision = require("vision");
const HapiSwagger = require("hapi-swagger");
const port = process.env.PORT || 3000;
const server = new Hapi.Server(
  {
    port
  }
);

const failAction = async (request, h, err) => {
  console.error('err', err)
  throw err;
}

(async () => {
  if (!process.env.POSTGRES_HOST) {
    throw Error(
      "process.env.POSTGRES_HOST must be a: user:pass@ipService:port ",
    );
  }
  const sequelize = new Sequelize(
    `postgres://${process.env.POSTGRES_HOST}/${process.env.POSTGRES_DB || "heroes"}`,
    {
      ssl: process.env.POSTGRES_SSL,
      dialectOptions: {
        ssl: process.env.POSTGRES_SSL,
      },
    }
  );
  await sequelize.authenticate();
  console.log("postgres is running");

  const Hero = sequelize.define("hero", {
    name: Sequelize.STRING,
    power: Sequelize.STRING,
  });

  await Hero.sync({ force: true });

  await server.register([
    Inert,
    Vision,
    {
      plugin: HapiSwagger,
      options: {
        info: {
          title: "Node.js with Postgres Example - Erick Wendel",
          version: "1.0",
        },
      }
    },
  ]);

  server.route([
    {
      method: "GET",
      path: "/heroes",
      handler: () => {
        return Hero.findAll();
      },
      config: {
        description: "List All heroes",
        notes: "heroes from database",
        tags: ["api"],
      },
    },
    {
      method: "GET",
      path: "/heroes/{id}",
      handler: (req) => {
        return Hero.findAll({ where: { id: req.params.id } });
      },
      config: {
        description: "Get a hero",
        notes: "heroes from database",
        tags: ["api"],
      },
    },
    {
      method: "POST",
      path: "/heroes",
      config: {
        handler: (req) => {
          const { payload } = req;
          return Hero.create(payload);
        },
        description: "Create a hero",
        notes: "create a hero",
        tags: ["api"],
        validate: {
          failAction,

          payload: {
            name: Joi.string().required(),
            power: Joi.string().required(),
          },
        },
      },
    },
    {
      method: "PUT",
      path: "/heroes/{id}",
      config: {
        handler: (req) => {
          const { payload } = req;
          return Hero.update(payload, { where: { id: req.params.id } });
        },
        description: "Create a hero",
        notes: "create a hero",
        tags: ["api"],
        validate: {
          failAction,
          params: {
            id: Joi.string().required(),
          },
          payload: {
            name: Joi.string(),
            power: Joi.string(),
          },
        },
      },
    },

    {
      method: "DELETE",
      path: "/heroes/{id}",
      config: {
        handler: (req) => {
          return Hero.destroy({ where: { id: req.params.id } });
        },
        description: "Delete a hero",
        notes: "Delete a hero",
        tags: ["api"],
        validate: {
          failAction,
          params: {
            id: Joi.string().required(),
          },
        },
      },
    },
  ]);

  await server.start();
  console.log("server running at", server.info.port);
})();