126 lines
2.7 KiB
JavaScript
126 lines
2.7 KiB
JavaScript
const { gql } = require('graphql-tag')
|
|
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
|
|
}
|
|
root {
|
|
subName
|
|
}
|
|
status
|
|
maxBid
|
|
company
|
|
location
|
|
remote
|
|
upvotes
|
|
wvotes
|
|
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' : ''}`
|
|
}
|
|
if (!item.sub?.name && item.root?.subName) {
|
|
itemcp.sub = { name: item.root.subName }
|
|
}
|
|
|
|
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: { items: { items, cursor } } } = await apollo.query({
|
|
query: gql`
|
|
${ITEM_SEARCH_FIELDS}
|
|
query AllItems($cursor: String) {
|
|
items(cursor: $cursor, sort: "recent", limit: 100, type: "all") {
|
|
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 }
|