db.js

const path = require('path')
const ogs = require('open-graph-scraper')
const prompts = require('prompts')
const low = require('lowdb')
const FileSync = require('lowdb/adapters/FileSync')

const selectDB = [
  {
    type: 'select',
    name: 'db',
    message: 'Select a database:',
    choices: [
      { title: 'Reading', value: 'reading' },
      { title: 'Design', value: 'design' },
      { title: 'Music', value: 'music' },
      { title: 'Keyboards', value: 'keyboards' }
    ]
  }
]

const main = async () => {
  // Get database name
  const { db: dbName } = await prompts(selectDB)
  const dbFileName = path.join(__dirname, `../data/${dbName}.json`)

  // Open up a database connection
  const adapter = new FileSync(dbFileName)
  const db = low(adapter)

  // Set some defaults in case the file is empty
  db.defaults({ schema: [], data: [] })

  // Get the keys
  const dbKeys = db.get('schema').value()

  if (!dbKeys) {
    console.error(`Cannot find schema for ${dbName} database in ${dbFileName}`)
    process.exit(1)
    return
  }

  // Get the desired key and retrieve the URL
  const { key, url, pinned } = await prompts([
    {
      type: 'select',
      name: 'key',
      message: 'Pick a key:',
      choices: dbKeys.map(k => {
        return {
          name: k.name,
          value: k.name
        }
      })
    },
    {
      type: 'text',
      name: 'url',
      message: 'Enter a URL:'
    },
    {
      type: 'confirm',
      name: 'pinned',
      message: 'Pin this entry?',
      initial: false
    }
  ])

  ogs({ url }, (error, results) => {
    if (error) {
      console.log(`Error while fetching OG data.`)
      process.exit(1)
      return
    }

    const { data } = results

    const image = data.ogImage ? data.ogImage.url : null
    const title = data.ogTitle
    const description = data.ogDescription

    const alreadyExists = db
      .get('data')
      .find({ url: url })
      .value()

    const obj = {
      title,
      description,
      image,
      url,
      key,
      pinned
    }

    if (alreadyExists) {
      // If item already exists, replace it
      db.get('data')
        .find({ url: url })
        .assign(obj)
        .write()
    } else {
      // Add new entry
      db.get('data')
        .unshift(obj)
        .write()
    }

    console.log('✨ Added database entry.')
  })
}

main()