self-deployed-api.ts

import express from 'express'
import {Filter} from 'mongodb'
import cors from 'cors'
import {mongoClient, MONGODB_COLLECTION} from './util'
import {User} from './util'

const app = express()

app.use(cors({credentials: true, origin: 'http://localhost:4000'}))

app.get('/search', async (req, res) => {
  const searchQuery = req.query.query as string
  const country = req.query.country as string

  if (!searchQuery || searchQuery.length < 2) {
    res.json([])
    return
  }

  const db = mongoClient.db('tutorial')
  const collection = db.collection<User>(MONGODB_COLLECTION)

  const filter: Filter<User> = {
    $text: {$search: searchQuery, $caseSensitive: false, $diacriticSensitive: false},
  }
  if (country) filter.country = country

  const result = await collection
    .find(filter)
    .project({score: {$meta: 'textScore'}, _id: 0})
    .sort({score: {$meta: 'textScore'}})
    .limit(10)

  const array = await result.toArray()

  res.json(array)
})

async function main() {
  try {
    await mongoClient.connect()

    const db = mongoClient.db('tutorial')
    const collection = db.collection<User>(MONGODB_COLLECTION)

    // Text index for searching fullName and email
    await collection.createIndexes([{name: 'fullName_email_text', key: {fullName: 'text', email: 'text'}}])

    app.listen(3000, () => console.log('http://localhost:3000/search?query=gilbert'))
  } catch (err) {
    console.log(err)
  }

  process.on('SIGTERM', async () => {
    await mongoClient.close()
    process.exit(0)
  })
}

main()