const { gql } = require('apollo-server-micro') const search = require('../api/search') const ITEM_SEARCH_FIELDS = gql` fragment ItemSearchFields on Item { id parentId createdAt updatedAt title text url userId user { name } sub { name } status maxBid company location remote upvotes sats boost lastCommentAt commentSats path ncomments }` async function _indexItem (item) { console.log('indexing item', item.id) // HACK: modify the title for jobs so that company/location are searchable // and highlighted without further modification const itemcp = { ...item } if (item.company) { itemcp.title += ` \\ ${item.company}` } if (item.location || item.remote) { itemcp.title += ` \\ ${item.location || ''}${item.location && item.remote ? ' or ' : ''}${item.remote ? 'Remote' : ''}` } try { await search.index({ id: item.id, index: 'item', version: new Date(item.updatedAt).getTime(), versionType: 'external_gte', body: itemcp }) } catch (e) { // ignore version conflict ... if (e?.meta?.statusCode === 409) { console.log('version conflict ignoring', item.id) return } console.log(e) throw e } console.log('done indexing item', item.id) } function indexItem ({ apollo }) { return async function ({ data: { id } }) { // 1. grab item from database // could use apollo to avoid duping logic // when grabbing sats and user name, etc const { data: { item } } = await apollo.query({ query: gql` ${ITEM_SEARCH_FIELDS} query Item { item(id: ${id}) { ...ItemSearchFields } }` }) // 2. index it with external version based on updatedAt await _indexItem(item) } } function indexAllItems ({ apollo }) { return async function () { // cursor over all items in the Item table let items = []; let cursor = null do { // query for items ({ data: { allItems: { items, cursor } } } = await apollo.query({ query: gql` ${ITEM_SEARCH_FIELDS} query AllItems($cursor: String) { allItems(cursor: $cursor) { items { ...ItemSearchFields } cursor } }`, variables: { cursor } })) // for all items, index them try { items.forEach(_indexItem) } catch (e) { // ignore errors console.log(e) } } while (cursor) } } module.exports = { indexItem, indexAllItems }