504 lines
13 KiB
JavaScript
504 lines
13 KiB
JavaScript
let db = require('@config/database')
|
|
|
|
let SiteScrape = require('@helpers/SiteScrape')
|
|
|
|
let Attachment = module.exports = {}
|
|
|
|
const cheerio = require('cheerio')
|
|
const rp = require('request-promise')
|
|
const request = require('request')
|
|
const fs = require('fs')
|
|
|
|
const gm = require('gm')
|
|
|
|
const tesseract = require("node-tesseract-ocr")
|
|
const filePath = '../staticFiles/'
|
|
|
|
// Attachment.migrateOld
|
|
|
|
Attachment.textSearch = (userId, searchTerm) => {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
const front = 5
|
|
const tail = 150
|
|
|
|
const query = `
|
|
SELECT
|
|
*,
|
|
substring(
|
|
text,
|
|
IF(LOCATE(?, text) > ${tail}, LOCATE(?, text) - ${front}, 1),
|
|
${tail} + LENGTH(?) + ${front}
|
|
) as snippet
|
|
FROM attachment
|
|
WHERE user_id = ?
|
|
AND MATCH(text)
|
|
AGAINST(? IN NATURAL LANGUAGE MODE)
|
|
LIMIT 1000`
|
|
|
|
db.promise()
|
|
.query(query, [searchTerm, searchTerm, searchTerm, userId, searchTerm])
|
|
.then((rows, fields) => {
|
|
resolve(rows[0]) //Return all attachments found by query
|
|
})
|
|
.catch(console.log)
|
|
})
|
|
}
|
|
|
|
Attachment.search = (userId, noteId, attachmentType, offset, setSize) => {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
let params = [userId]
|
|
let query = 'SELECT * FROM attachment WHERE user_id = ? AND visible = 1 '
|
|
|
|
if(noteId && noteId > 0){
|
|
query += 'AND note_id = ? '
|
|
params.push(noteId)
|
|
}
|
|
|
|
if(attachmentType == 'links'){
|
|
query += 'AND attachment_type = 1 '
|
|
}
|
|
if(attachmentType == 'files'){
|
|
query += 'AND attachment_type > 1 '
|
|
}
|
|
|
|
|
|
query += 'ORDER BY last_indexed DESC '
|
|
|
|
const limitOffset = parseInt(offset, 10) || 0 //Either parse int, or use zero
|
|
const parsedSetSize = parseInt(setSize, 10) || 20 //Either parse int, or use zero
|
|
query += ` LIMIT ${limitOffset}, ${parsedSetSize}`
|
|
|
|
db.promise()
|
|
.query(query, params)
|
|
.then((rows, fields) => {
|
|
resolve(rows[0]) //Return all attachments found by query
|
|
})
|
|
.catch(console.log)
|
|
})
|
|
}
|
|
|
|
//Returns all attachments
|
|
Attachment.forNote = (userId, noteId) => {
|
|
return new Promise((resolve, reject) => {
|
|
db.promise()
|
|
.query(`SELECT * FROM attachment WHERE user_id = ? AND note_id = ? AND visible = 1 ORDER BY last_indexed DESC;`, [userId, noteId])
|
|
.then((rows, fields) => {
|
|
resolve(rows[0]) //Return all attachments found by query
|
|
})
|
|
.catch(console.log)
|
|
})
|
|
}
|
|
|
|
Attachment.urlForNote = (userId, noteId) => {
|
|
return new Promise((resolve, reject) => {
|
|
db.promise()
|
|
.query(`SELECT * FROM attachment WHERE user_id = ? AND note_id = ? AND attachment_type = 1 ORDER BY last_indexed DESC;`, [userId, noteId])
|
|
.then((rows, fields) => {
|
|
resolve(rows[0]) //Return all attachments found by query
|
|
})
|
|
.catch(console.log)
|
|
})
|
|
}
|
|
|
|
//Update attachment in database
|
|
Attachment.update = (userId, attachmentId, updatedText, noteId) => {
|
|
return new Promise((resolve, reject) => {
|
|
db.promise()
|
|
.query(`UPDATE attachment SET text = ? WHERE id = ? AND user_id = ?`,
|
|
[updatedText, attachmentId, userId])
|
|
.then((rows, fields) => {
|
|
resolve(true)
|
|
})
|
|
.catch(console.log)
|
|
})
|
|
}
|
|
|
|
Attachment.delete = (userId, attachmentId, urlDelete = false) => {
|
|
|
|
return new Promise((resolve, reject) => {
|
|
db.promise()
|
|
.query('SELECT * FROM attachment WHERE id = ? AND user_id = ? LIMIT 1', [attachmentId, userId])
|
|
.then((rows, fields) => {
|
|
|
|
//Attachment doesn't exist, return done
|
|
if(rows[0].length == 0){
|
|
return resolve(true)
|
|
}
|
|
|
|
//Pull data we want out of
|
|
let row = rows[0][0]
|
|
let url = row.url
|
|
const noteId = row.note_id
|
|
|
|
//Try to delete file and thumbnail
|
|
try {
|
|
fs.unlinkSync(filePath+row.file_location)
|
|
} catch(err) { console.error('File Does not exist') }
|
|
try {
|
|
fs.unlinkSync(filePath+'thumb_'+row.file_location)
|
|
} catch(err) { console.error('Thumbnail Does not exist') }
|
|
|
|
//Do not delete link attachments, just hide them. They will be deleted if removed from note
|
|
if(row.attachment_type == 1 && !urlDelete){
|
|
db.promise()
|
|
.query(`UPDATE attachment SET visible = 0 WHERE id = ?`, [attachmentId])
|
|
.then((rows, fields) => { })
|
|
.catch(console.log)
|
|
|
|
return resolve(true)
|
|
}
|
|
|
|
db.promise()
|
|
.query(`DELETE FROM attachment WHERE id = ?`, [attachmentId])
|
|
.then((rows, fields) => { })
|
|
.catch(console.log)
|
|
|
|
return resolve(true)
|
|
})
|
|
})
|
|
}
|
|
|
|
Attachment.processUploadedFile = (userId, noteId, fileObject) => {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
const rawFilename = fileObject.filename
|
|
const extension = '.'+fileObject.originalname.split('.').pop()
|
|
const goodFileName = rawFilename+extension
|
|
const fileName = fileObject.originalname //Actual name of the file, dog.jpg
|
|
|
|
//Rename random file name to one with an extension
|
|
fs.rename(filePath+rawFilename, filePath+goodFileName, (err) => {
|
|
|
|
const created = Math.round((+new Date)/1000)
|
|
|
|
db.promise()
|
|
.query(`
|
|
INSERT INTO attachment
|
|
(note_id, user_id, attachment_type, \`text\`, last_indexed, file_location)
|
|
VALUES
|
|
(?, ?, ?, ?, ?, ?)
|
|
`, [noteId, userId, 2, 'Add a description to -> '+fileName, created, goodFileName])
|
|
.then((rows, fields) => {
|
|
|
|
Attachment.generateThumbnail(goodFileName)
|
|
|
|
//If its an image, scrape text
|
|
if(true){
|
|
|
|
// https://github.com/tesseract-ocr/tesseract/wiki/ImproveQuality
|
|
//psm 3 - default, 11 - as much text as possible
|
|
const config = { lang: "eng", oem: 1, psm: 3 }
|
|
|
|
tesseract.recognize(filePath+goodFileName, config)
|
|
.then(text => {
|
|
|
|
text = text.slice(0, -1).trim()
|
|
|
|
if(text.length > 5){
|
|
console.log('Inserting text')
|
|
db.promise().query(
|
|
`UPDATE attachment SET text = ? WHERE id = ? AND user_id = ? LIMIT 1`,
|
|
[text, rows[0].insertId, userId]
|
|
).then(results => {
|
|
resolve({ fileName, goodFileName })
|
|
})
|
|
} else {
|
|
return resolve({ fileName, goodFileName })
|
|
}
|
|
|
|
})
|
|
.catch(error => {
|
|
console.log(error.message)
|
|
})
|
|
|
|
} else {
|
|
resolve({ fileName, goodFileName })
|
|
}
|
|
})
|
|
.catch(console.log)
|
|
|
|
})
|
|
})
|
|
}
|
|
|
|
Attachment.generateThumbnail = (fileName) => {
|
|
return new Promise((resolve, reject) => {
|
|
gm(filePath+fileName)
|
|
.resize(550) //Resize to width of 550 px
|
|
.quality(75) //compression level 0 - 100 (best)
|
|
.write(filePath + 'thumb_'+fileName, function (err) {
|
|
resolve(fileName)
|
|
})
|
|
})
|
|
}
|
|
|
|
//Scans text for websites, returns all attachments
|
|
Attachment.scanTextForWebsites = (io, userId, noteId, noteText) => {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
let solrAttachmentText = '' //Final searchable scrape text for note
|
|
|
|
if(noteText.length == 0){ resolve(solrAttachmentText) }
|
|
|
|
Attachment.urlForNote(userId, noteId).then(attachments => {
|
|
|
|
//Pull all the URLs out of the text
|
|
let foundUrls = SiteScrape.getCleanUrls(noteText)
|
|
|
|
//Go through each saved URL, remove new URLs from saved URLs
|
|
//If a URL is not found, delete it
|
|
attachments.forEach(attachment => {
|
|
//URL already scraped, push text and continue
|
|
let urlIndex = foundUrls.indexOf( attachment.url )
|
|
|
|
if(urlIndex != -1){
|
|
solrAttachmentText += attachment.text
|
|
foundUrls.splice(urlIndex, 1) //Remove existing from set of found
|
|
} else {
|
|
//If existing attachment is not found in note, remove it
|
|
Attachment.delete(userId, attachment.id, true)
|
|
}
|
|
})
|
|
|
|
//No newly scraped URLs, resolve with looked up attachment text
|
|
if(foundUrls == null || foundUrls.length == 0){
|
|
return resolve(solrAttachmentText)
|
|
}
|
|
|
|
//Process the remaining URLs into attachments
|
|
Attachment.scrapeUrlsCreateAttachments(userId, noteId, foundUrls).then( freshlyScrapedText => {
|
|
|
|
//Once everything is done being scraped, emit new attachment events
|
|
if(io){
|
|
io.to(userId).emit('update_counts')
|
|
}
|
|
|
|
solrAttachmentText += freshlyScrapedText
|
|
resolve(solrAttachmentText)
|
|
})
|
|
})
|
|
})
|
|
}
|
|
|
|
//Return scraped text from each URL
|
|
Attachment.scrapeUrlsCreateAttachments = (userId, noteId, foundUrls) => {
|
|
return new Promise((resolve, reject) => {
|
|
|
|
if(foundUrls == null || foundUrls.length == 0){
|
|
return resolve('')
|
|
}
|
|
|
|
console.log('About to scrape')
|
|
console.log(foundUrls)
|
|
|
|
let processedCount = 0
|
|
let scrapedText = ''
|
|
|
|
//Process each URL passd to function, a DB entry will be created for each scrape
|
|
foundUrls.forEach(url => {
|
|
Attachment.processUrl(userId, noteId, url).then( freshlyScrapedText => {
|
|
|
|
scrapedText += freshlyScrapedText
|
|
processedCount ++
|
|
|
|
//All URLs have been scraped, return data
|
|
if(processedCount == foundUrls.length){
|
|
resolve(scrapedText)
|
|
}
|
|
})
|
|
})
|
|
})
|
|
}
|
|
|
|
Attachment.downloadFileFromUrl = (url) => {
|
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
if(url == null){
|
|
resolve(null)
|
|
}
|
|
|
|
const random = Math.random().toString(36).substring(2, 15) + Math.random().toString(36).substring(2, 15)
|
|
const extension = '.'+url.split('.').pop() //This is throwing an error
|
|
let fileName = random+'_scrape'+extension
|
|
const thumbPath = 'thumb_'+fileName
|
|
|
|
console.log('Scraping image url')
|
|
console.log(url)
|
|
|
|
console.log('Getting ready to scrape ', url)
|
|
|
|
request(url)
|
|
.on('error', error => {
|
|
console.log(error)
|
|
resolve(null)
|
|
})
|
|
.on('response', res => {
|
|
console.log(res.statusCode)
|
|
console.log(res.headers['content-type'])
|
|
})
|
|
.pipe(fs.createWriteStream(filePath+thumbPath))
|
|
.on('close', () => {
|
|
|
|
//resize image if its real big
|
|
gm(filePath+thumbPath)
|
|
.resize(550) //Resize to width of 550 px
|
|
.quality(75) //compression level 0 - 100 (best)
|
|
.write(filePath+thumbPath, function (err) {
|
|
if(err){ console.log(err) }
|
|
})
|
|
|
|
|
|
console.log('Saved Image')
|
|
resolve(fileName)
|
|
})
|
|
})
|
|
}
|
|
|
|
Attachment.processUrl = (userId, noteId, url) => {
|
|
|
|
const scrapeTime = 20*1000;
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
|
const options = {
|
|
uri: url,
|
|
simple: true,
|
|
timeout: scrapeTime,
|
|
headers: {
|
|
'User-Agent':'Mozilla/5.0 (compatible; Googlebot/2.1; +http://www.google.com/bot.html)' //Simulate google headers
|
|
},
|
|
transform: function (body) {
|
|
return cheerio.load(body);
|
|
}
|
|
}
|
|
|
|
let requestTimeout = null
|
|
let thumbnail = null
|
|
let request = null
|
|
let created = Math.round((+new Date)/1000)
|
|
let insertedId = null
|
|
|
|
//Create a shell attachment for each URL, put in processing state
|
|
db.promise()
|
|
.query(`INSERT INTO attachment
|
|
(note_id, user_id, attachment_type, text, url, last_indexed, file_location)
|
|
VALUES (?, ?, ?, ?, ?, ?, ?)`,
|
|
[noteId, userId, 1, 'Processing...', url, created, null])
|
|
.then((rows, fields) => {
|
|
//Set two bigger variables then return request for processing
|
|
request = rp(options)
|
|
insertedId = rows[0].insertId
|
|
|
|
return request
|
|
})
|
|
.then($ => {
|
|
|
|
//Clear timeout that would end this function
|
|
clearTimeout(requestTimeout)
|
|
|
|
// let header = $('h1').text().replace(removeWhitespace, " ")
|
|
// desiredSearchText += header + "\n"
|
|
|
|
const pageTitle = SiteScrape.getTitle($)
|
|
|
|
const hostname = SiteScrape.getHostName(url)
|
|
|
|
const thumbnail = SiteScrape.getDisplayImage($, url)
|
|
|
|
const keywords = SiteScrape.getKeywords($)
|
|
|
|
var desiredSearchText = ''
|
|
desiredSearchText += pageTitle + "\n"
|
|
desiredSearchText += keywords
|
|
|
|
console.log({
|
|
pageTitle,
|
|
hostname,
|
|
thumbnail,
|
|
keywords
|
|
})
|
|
|
|
|
|
// throw new Error('Ending this function early.')
|
|
|
|
|
|
// console.log('TexT Scraped')
|
|
// console.log(desiredSearchText)
|
|
|
|
created = Math.round((+new Date)/1000)
|
|
|
|
//Scrape URL for thumbnail - take filename and save in attachment
|
|
Attachment.downloadFileFromUrl(thumbnail)
|
|
.then(thumbnailFilename => {
|
|
|
|
//Update text and thumbnail filename
|
|
created = Math.round((+new Date)/1000)
|
|
db.promise()
|
|
.query(`UPDATE attachment SET
|
|
text = ?,
|
|
last_indexed = ?,
|
|
file_location = ?
|
|
WHERE id = ?
|
|
`, [desiredSearchText, created, thumbnailFilename, insertedId])
|
|
.then((rows, fields) => {
|
|
resolve(desiredSearchText) //Return found text
|
|
})
|
|
.catch(console.log)
|
|
|
|
|
|
//Create attachment in DB with scrape text and provided data
|
|
// db.promise()
|
|
// .query(`INSERT INTO attachment
|
|
// (note_id, user_id, attachment_type, text, url, last_indexed, file_location)
|
|
// VALUES (?, ?, ?, ?, ?, ?, ?)`, [noteId, userId, 1, desiredSearchText, url, created, thumbnailFilename])
|
|
// .then((rows, fields) => {
|
|
|
|
// resolve(desiredSearchText) //Return found text
|
|
// })
|
|
// .catch(console.log)
|
|
})
|
|
|
|
})
|
|
.catch(error => {
|
|
// console.log('Scrape pooped out')
|
|
// console.log('Issue with scrape')
|
|
console.log(error)
|
|
// resolve('')
|
|
})
|
|
|
|
requestTimeout = setTimeout( () => {
|
|
console.log('Cancel the request, its taking to long.')
|
|
request.cancel()
|
|
|
|
desiredSearchText = 'No Description for -> '+url
|
|
|
|
created = Math.round((+new Date)/1000)
|
|
db.promise()
|
|
.query(`UPDATE attachment SET
|
|
text = ?,
|
|
last_indexed = ?,
|
|
WHERE id = ?
|
|
`, [desiredSearchText, created, insertedId])
|
|
.then((rows, fields) => {
|
|
resolve(desiredSearchText) //Return found text
|
|
})
|
|
.catch(console.log)
|
|
|
|
//Create attachment in DB with scrape text and provided data
|
|
// db.promise()
|
|
// .query(`INSERT INTO attachment
|
|
// (note_id, user_id, attachment_type, text, url, last_indexed)
|
|
// VALUES (?, ?, ?, ?, ?, ?)`, [noteId, userId, 1, desiredSearchText, url, created])
|
|
// .then((rows, fields) => {
|
|
// resolve(desiredSearchText) //Return found text
|
|
// })
|
|
// .catch(console.log)
|
|
|
|
}, scrapeTime )
|
|
})
|
|
} |