Skip to content

Commit

Permalink
Merge branch 'main' into bugfix/Weaviate-PDF
Browse files Browse the repository at this point in the history
# Conflicts:
#	packages/components/package.json
  • Loading branch information
HenryHengZJ committed Jun 16, 2023
2 parents 93c2464 + 07fb71d commit 9224fbe
Show file tree
Hide file tree
Showing 3 changed files with 127 additions and 0 deletions.
117 changes: 117 additions & 0 deletions packages/components/nodes/documentloaders/Playwright/Playwright.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,117 @@
import { INode, INodeData, INodeParams } from '../../../src/Interface'
import { TextSplitter } from 'langchain/text_splitter'
import { PlaywrightWebBaseLoader } from 'langchain/document_loaders/web/playwright'
import { test } from 'linkifyjs'
import { getAvailableURLs } from '../../../src'

class Playwright_DocumentLoaders implements INode {
label: string
name: string
description: string
type: string
icon: string
category: string
baseClasses: string[]
inputs: INodeParams[]

constructor() {
this.label = 'Playwright Web Scraper'
this.name = 'playwrightWebScraper'
this.type = 'Document'
this.icon = 'playwright.svg'
this.category = 'Document Loaders'
this.description = `Load data from webpages`
this.baseClasses = [this.type]
this.inputs = [
{
label: 'URL',
name: 'url',
type: 'string'
},
{
label: 'Text Splitter',
name: 'textSplitter',
type: 'TextSplitter',
optional: true
},
{
label: 'Web Scrap for Relative Links',
name: 'webScrap',
type: 'boolean',
optional: true,
additionalParams: true
},
{
label: 'Web Scrap Links Limit',
name: 'limit',
type: 'number',
default: 10,
optional: true,
additionalParams: true
},
{
label: 'Metadata',
name: 'metadata',
type: 'json',
optional: true,
additionalParams: true
}
]
}

async init(nodeData: INodeData): Promise<any> {
const textSplitter = nodeData.inputs?.textSplitter as TextSplitter
const metadata = nodeData.inputs?.metadata
const webScrap = nodeData.inputs?.webScrap as boolean
let limit = nodeData.inputs?.limit as string

let url = nodeData.inputs?.url as string
url = url.trim()
if (!test(url)) {
throw new Error('Invalid URL')
}

const playwrightLoader = async (url: string): Promise<any> => {
let docs = []
const loader = new PlaywrightWebBaseLoader(url)
if (textSplitter) {
docs = await loader.loadAndSplit(textSplitter)
} else {
docs = await loader.load()
}
return docs
}

let availableUrls: string[]
let docs = []
if (webScrap) {
if (!limit) limit = '10'
availableUrls = await getAvailableURLs(url, parseInt(limit))
for (let i = 0; i < availableUrls.length; i++) {
docs.push(...(await playwrightLoader(availableUrls[i])))
}
} else {
docs = await playwrightLoader(url)
}

if (metadata) {
const parsedMetadata = typeof metadata === 'object' ? metadata : JSON.parse(metadata)
let finaldocs = []
for (const doc of docs) {
const newdoc = {
...doc,
metadata: {
...doc.metadata,
...parsedMetadata
}
}
finaldocs.push(newdoc)
}
return finaldocs
}

return docs
}
}

module.exports = { nodeClass: Playwright_DocumentLoaders }
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
1 change: 1 addition & 0 deletions packages/components/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@
"node-fetch": "^2.6.11",
"pdf-parse": "^1.1.1",
"pdfjs-dist": "^3.7.107",
"playwright": "^1.35.0",
"puppeteer": "^20.7.1",
"srt-parser-2": "^1.2.3",
"weaviate-ts-client": "^1.1.0",
Expand Down

0 comments on commit 9224fbe

Please sign in to comment.