sos-nextjs/db/models/item.js

const pg = require('../pg')
const joinjs = require('join-js').default;
const debug = require('debug')('sos:db:item')
const mappings = require('../mappings')
const dbUtil = require('../util')

const sharp = require('sharp')

const item = module.exports = {}

item.findAll = async (showUnpublished = false) => {
  let queryPublished = 'select * from sos.v_item where item_published = true'
  let queryAll = 'select * from sos.v_item'

  const query = (
    showUnpublished === "true"
      ? queryAll
      : queryPublished
  )

  debug(query);

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_');
}

item.findById = async (item_uuid) => {
  const query = {
    text: 'select * from sos.v_item where item_uuid = $1',
    values: [
      item_uuid
    ]
  }

  debug(query);

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0];
}

item.findBySlug = async (item_slug) => {
  const query = {
    text: 'select * from sos.v_item where item_urlslug = $1',
    values: [
      item_slug
    ]
  }

  debug(query);

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0];
}

item.create = async (name, urlslug, description, price_cents, published, hs_tariff_number, customs_description, origin_country, weight) => 
  dbUtil.executeFunction({
    name: 'create_item',
    params: [
      name,
      urlslug,
      description,
      price_cents,
      published,
      hs_tariff_number,
      customs_description,
      origin_country,
      weight
    ],
    returnType: 'item',
    single: true
  })

item.update = async (uuid, name, urlslug, description, price_cents, published) => {
  const query = {
    text: 'select * from sos.update_item($1::uuid, $2::text, $3::citext, $4::text, $5::integer, $6::boolean)',
    values: [
      uuid,
      name,
      urlslug,
      description,
      price_cents,
      published
    ]
  }

  debug(query)

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}

item.addImage = async (item_uuid, image_buffer, uploader_uuid) => {
  // Default param chain: output as png
  const source = sharp(image_buffer).png()

  // All output images clone the source param chain, and then
  // resize before creating a buffer
  const [image, thumb] = await Promise.all([
    source.clone().toBuffer(),
    source.clone().resize({width: 300}).toBuffer()
  ])

  const query = {
    text: 'select * from sos.add_image_to_item($1, $2, $3, $4, $5)',
    values: [
      item_uuid,
      image,
      thumb,
      'image/png',
      uploader_uuid
    ]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}

item.setFeatured = (image_uuid) =>
  dbUtil.executeFunction({
    name: 'set_featured_image',
    params: [image_uuid],
    returnType: 'item',
    single: true
  })

const imageSizeQueries = {
  'large': 'select * from sos.get_image_large($1)',
  'thumb': 'select * from sos.get_image_thumb($1)'
}

item.getImage = async (image_uuid, size) => {
  if(!imageSizeQueries[size])
    throw new Error(`Cannot get unknown image size: "${size}"`)

  const query = {
    text: imageSizeQueries[size],
    values: [image_uuid]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'bareImageMap', 'image_')[0];
}

item.removeImage = async (image_uuid) => {
  const query = {
    text: 'select * from sos.remove_image($1)',
    values: [
      image_uuid
    ]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}

item.removeItem = async (item_uuid) => {
  const query = {
    text: 'select * from sos.delete_item($1)',
    values: [
      item_uuid
    ]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}

item.publish = async (item_uuid) => {
  const query = {
    text: 'select * from sos.publish_item($1)',
    values: [
      item_uuid
    ]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}

item.unpublish = async (item_uuid) => {
  const query = {
    text: 'select * from sos.unpublish_item($1)',
    values: [
      item_uuid
    ]
  }

  const {rows} = await pg.query(query)
  return joinjs.map(rows, mappings, 'itemMap', 'item_')[0]
}