mirror of
https://github.com/orangecoding/fredy.git
synced 2026-06-16 12:31:07 +00:00
Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
2896d531e4 | ||
|
|
0cbfa25062 | ||
|
|
bcd3042026 | ||
|
|
0ce93acaf6 | ||
|
|
cabef973a2 |
@@ -227,7 +227,7 @@ class FredyPipelineExecutioner {
|
|||||||
const extractor = new Extractor({ ...this._providerConfig.puppeteerOptions, browser: this._browser });
|
const extractor = new Extractor({ ...this._providerConfig.puppeteerOptions, browser: this._browser });
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
extractor
|
extractor
|
||||||
.execute(url, this._providerConfig.waitForSelector)
|
.execute(url, this._providerConfig.waitForSelector, this._providerId)
|
||||||
.then(() => {
|
.then(() => {
|
||||||
const listings = extractor.parseResponseText(
|
const listings = extractor.parseResponseText(
|
||||||
this._providerConfig.crawlContainer,
|
this._providerConfig.crawlContainer,
|
||||||
|
|||||||
@@ -76,13 +76,13 @@ fastify.register(async (app) => {
|
|||||||
app.register(dashboardPlugin, { prefix: '/api/dashboard' });
|
app.register(dashboardPlugin, { prefix: '/api/dashboard' });
|
||||||
app.register(userSettingsPlugin, { prefix: '/api/user/settings' });
|
app.register(userSettingsPlugin, { prefix: '/api/user/settings' });
|
||||||
app.register(trackingPlugin, { prefix: '/api/tracking' });
|
app.register(trackingPlugin, { prefix: '/api/tracking' });
|
||||||
|
app.register(generalSettingsPlugin, { prefix: '/api/admin/generalSettings' });
|
||||||
});
|
});
|
||||||
|
|
||||||
// Admin-only routes
|
// Admin-only routes
|
||||||
fastify.register(async (app) => {
|
fastify.register(async (app) => {
|
||||||
app.addHook('preHandler', authHook);
|
app.addHook('preHandler', authHook);
|
||||||
app.addHook('preHandler', adminHook);
|
app.addHook('preHandler', adminHook);
|
||||||
app.register(generalSettingsPlugin, { prefix: '/api/admin/generalSettings' });
|
|
||||||
app.register(backupPlugin, { prefix: '/api/admin/backup' });
|
app.register(backupPlugin, { prefix: '/api/admin/backup' });
|
||||||
app.register(userPlugin, { prefix: '/api/admin/users' });
|
app.register(userPlugin, { prefix: '/api/admin/users' });
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -9,6 +9,10 @@ import {
|
|||||||
precheckRestore,
|
precheckRestore,
|
||||||
restoreFromZip,
|
restoreFromZip,
|
||||||
} from '../../services/storage/backupRestoreService.js';
|
} from '../../services/storage/backupRestoreService.js';
|
||||||
|
import { getSettings } from '../../services/storage/settingsStorage.js';
|
||||||
|
import { isAdmin } from '../security.js';
|
||||||
|
|
||||||
|
const DEMO_MODE_ERROR = 'Backup and restore are not available in demo mode.';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param {import('fastify').FastifyInstance} fastify
|
* @param {import('fastify').FastifyInstance} fastify
|
||||||
@@ -21,7 +25,11 @@ export default async function backupPlugin(fastify) {
|
|||||||
(req, body, done) => done(null, body),
|
(req, body, done) => done(null, body),
|
||||||
);
|
);
|
||||||
|
|
||||||
fastify.get('/', async (_request, reply) => {
|
fastify.get('/', async (request, reply) => {
|
||||||
|
const settings = await getSettings();
|
||||||
|
if (settings.demoMode && !isAdmin(request)) {
|
||||||
|
return reply.code(403).send({ error: DEMO_MODE_ERROR });
|
||||||
|
}
|
||||||
const zipBuffer = await createBackupZip();
|
const zipBuffer = await createBackupZip();
|
||||||
const fileName = await buildBackupFileName();
|
const fileName = await buildBackupFileName();
|
||||||
reply.header('Content-Type', 'application/zip');
|
reply.header('Content-Type', 'application/zip');
|
||||||
@@ -30,6 +38,10 @@ export default async function backupPlugin(fastify) {
|
|||||||
});
|
});
|
||||||
|
|
||||||
fastify.post('/restore', async (request, reply) => {
|
fastify.post('/restore', async (request, reply) => {
|
||||||
|
const settings = await getSettings();
|
||||||
|
if (settings.demoMode && !isAdmin(request)) {
|
||||||
|
return reply.code(403).send({ error: DEMO_MODE_ERROR });
|
||||||
|
}
|
||||||
const { dryRun = 'false', force = 'false' } = request.query || {};
|
const { dryRun = 'false', force = 'false' } = request.query || {};
|
||||||
const doDryRun = String(dryRun) === 'true';
|
const doDryRun = String(dryRun) === 'true';
|
||||||
const doForce = String(force) === 'true';
|
const doForce = String(force) === 'true';
|
||||||
|
|||||||
@@ -27,8 +27,11 @@ export default async function generalSettingsPlugin(fastify) {
|
|||||||
}
|
}
|
||||||
const localSettings = await getSettings();
|
const localSettings = await getSettings();
|
||||||
|
|
||||||
if (localSettings.demoMode && !isAdmin(request)) {
|
if (!isAdmin(request)) {
|
||||||
return reply.code(403).send({ error: 'In demo mode, it is not allowed to change these settings.' });
|
const reason = localSettings.demoMode
|
||||||
|
? 'In demo mode, it is not allowed to change these settings.'
|
||||||
|
: 'Only admins can change these settings.';
|
||||||
|
return reply.code(403).send({ error: reason });
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|||||||
@@ -26,7 +26,7 @@ function parseId(shortenedLink) {
|
|||||||
|
|
||||||
async function fetchDetails(listing, browser) {
|
async function fetchDetails(listing, browser) {
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(listing.link, null, { browser });
|
const html = await puppeteerExtractor(listing.link, null, { browser, name: 'immobilienDe_details' });
|
||||||
if (!html) return listing;
|
if (!html) return listing;
|
||||||
|
|
||||||
const $ = cheerio.load(html);
|
const $ = cheerio.load(html);
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ let appliedBlackList = [];
|
|||||||
|
|
||||||
async function fetchDetails(listing, browser) {
|
async function fetchDetails(listing, browser) {
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(listing.link, null, { browser });
|
const html = await puppeteerExtractor(listing.link, null, { browser, name: 'immowelt_details' });
|
||||||
if (!html) return listing;
|
if (!html) return listing;
|
||||||
|
|
||||||
const $ = cheerio.load(html);
|
const $ = cheerio.load(html);
|
||||||
|
|||||||
@@ -128,7 +128,7 @@ async function enrichListingFromDetails(listing, browser) {
|
|||||||
if (!absoluteLink) return listing;
|
if (!absoluteLink) return listing;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(absoluteLink, null, { browser });
|
const html = await puppeteerExtractor(absoluteLink, null, { browser, name: 'kleinanzeigen_details' });
|
||||||
if (!html) return { ...listing, link: absoluteLink };
|
if (!html) return { ...listing, link: absoluteLink };
|
||||||
|
|
||||||
const { detailAddress, detailDescription } = extractDetailFromHtml(html);
|
const { detailAddress, detailDescription } = extractDetailFromHtml(html);
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ let appliedBlackList = [];
|
|||||||
|
|
||||||
async function fetchDetails(listing, browser) {
|
async function fetchDetails(listing, browser) {
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(listing.link, 'body', { browser });
|
const html = await puppeteerExtractor(listing.link, 'body', { browser, name: 'sparkasse_details' });
|
||||||
|
|
||||||
const $ = cheerio.load(html);
|
const $ = cheerio.load(html);
|
||||||
const nextDataRaw = $('#__NEXT_DATA__').text;
|
const nextDataRaw = $('#__NEXT_DATA__').text;
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ let appliedBlackList = [];
|
|||||||
|
|
||||||
async function fetchDetails(listing, browser) {
|
async function fetchDetails(listing, browser) {
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(listing.link, null, { browser });
|
const html = await puppeteerExtractor(listing.link, null, { browser, name: 'wgGesucht_details' });
|
||||||
if (!html) return listing;
|
if (!html) return listing;
|
||||||
|
|
||||||
const $ = cheerio.load(html);
|
const $ = cheerio.load(html);
|
||||||
|
|||||||
@@ -29,11 +29,12 @@ export default class Extractor {
|
|||||||
* your response will never contain what you are really looking for
|
* your response will never contain what you are really looking for
|
||||||
* @param url
|
* @param url
|
||||||
* @param waitForSelector
|
* @param waitForSelector
|
||||||
|
* @param jobKey
|
||||||
*/
|
*/
|
||||||
execute = async (url, waitForSelector = null) => {
|
execute = async (url, waitForSelector = null, jobKey = null) => {
|
||||||
this.responseText = null;
|
this.responseText = null;
|
||||||
try {
|
try {
|
||||||
this.responseText = await puppeteerExtractor(url, waitForSelector, this.options);
|
this.responseText = await puppeteerExtractor(url, waitForSelector, { ...this.options, name: jobKey });
|
||||||
if (this.responseText != null) {
|
if (this.responseText != null) {
|
||||||
loadParser(this.responseText);
|
loadParser(this.responseText);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -148,7 +148,11 @@ export default async function execute(url, waitForSelector, options) {
|
|||||||
if (botDetected(pageSource, statusCode)) {
|
if (botDetected(pageSource, statusCode)) {
|
||||||
logger.warn('We have been detected as a bot :-/ Tried url: => ', url);
|
logger.warn('We have been detected as a bot :-/ Tried url: => ', url);
|
||||||
|
|
||||||
await trackPoi(TRACKING_POIS.DETECTED_AS_BOT);
|
if (options != null && options.name != null) {
|
||||||
|
await trackPoi(TRACKING_POIS.DETECTED_AS_BOT + '_' + options.name);
|
||||||
|
} else {
|
||||||
|
await trackPoi(TRACKING_POIS.DETECTED_AS_BOT);
|
||||||
|
}
|
||||||
|
|
||||||
result = null;
|
result = null;
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "fredy",
|
"name": "fredy",
|
||||||
"version": "22.0.3",
|
"version": "22.0.7",
|
||||||
"description": "[F]ind [R]eal [E]states [d]amn eas[y].",
|
"description": "[F]ind [R]eal [E]states [d]amn eas[y].",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"prepare": "husky",
|
"prepare": "husky",
|
||||||
@@ -75,7 +75,7 @@
|
|||||||
"@turf/boolean-point-in-polygon": "^7.3.5",
|
"@turf/boolean-point-in-polygon": "^7.3.5",
|
||||||
"@vitejs/plugin-react": "6.0.1",
|
"@vitejs/plugin-react": "6.0.1",
|
||||||
"adm-zip": "^0.5.17",
|
"adm-zip": "^0.5.17",
|
||||||
"better-sqlite3": "^12.9.0",
|
"better-sqlite3": "^12.10.0",
|
||||||
"chart.js": "^4.5.1",
|
"chart.js": "^4.5.1",
|
||||||
"cheerio": "^1.2.0",
|
"cheerio": "^1.2.0",
|
||||||
"cloakbrowser": "^0.3.28",
|
"cloakbrowser": "^0.3.28",
|
||||||
|
|||||||
@@ -95,7 +95,10 @@ async function downloadHtmlProvider(name, providerConfig, launchBrowser, closeBr
|
|||||||
|
|
||||||
const browser = await launchBrowser(providerConfig.url, {});
|
const browser = await launchBrowser(providerConfig.url, {});
|
||||||
try {
|
try {
|
||||||
const html = await puppeteerExtractor(providerConfig.url, providerConfig.waitForSelector, { browser });
|
const html = await puppeteerExtractor(providerConfig.url, providerConfig.waitForSelector, {
|
||||||
|
browser,
|
||||||
|
name: 'dowload_fixtures',
|
||||||
|
});
|
||||||
|
|
||||||
if (!html) {
|
if (!html) {
|
||||||
console.warn(` Failed to download ${name}`);
|
console.warn(` Failed to download ${name}`);
|
||||||
|
|||||||
@@ -174,7 +174,7 @@ const JobGrid = () => {
|
|||||||
Toast.success('Job status successfully changed');
|
Toast.success('Job status successfully changed');
|
||||||
loadData();
|
loadData();
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
Toast.error(error);
|
Toast.error(error.error);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|||||||
@@ -54,6 +54,7 @@ const GeneralSettings = function GeneralSettings() {
|
|||||||
const [loading, setLoading] = React.useState(true);
|
const [loading, setLoading] = React.useState(true);
|
||||||
|
|
||||||
const settings = useSelector((state) => state.generalSettings.settings);
|
const settings = useSelector((state) => state.generalSettings.settings);
|
||||||
|
const currentUser = useSelector((state) => state.user.currentUser);
|
||||||
|
|
||||||
const [interval, setInterval] = React.useState('');
|
const [interval, setInterval] = React.useState('');
|
||||||
const [port, setPort] = React.useState('');
|
const [port, setPort] = React.useState('');
|
||||||
@@ -467,12 +468,26 @@ const GeneralSettings = function GeneralSettings() {
|
|||||||
itemKey="backup"
|
itemKey="backup"
|
||||||
>
|
>
|
||||||
<div className="generalSettings__tab-content">
|
<div className="generalSettings__tab-content">
|
||||||
|
{demoMode && !currentUser?.isAdmin && (
|
||||||
|
<Banner
|
||||||
|
fullMode={false}
|
||||||
|
type="warning"
|
||||||
|
closeIcon={null}
|
||||||
|
style={{ marginBottom: '12px' }}
|
||||||
|
description="Backup and restore are not available in demo mode."
|
||||||
|
/>
|
||||||
|
)}
|
||||||
<SegmentPart
|
<SegmentPart
|
||||||
name="Backup & Restore"
|
name="Backup & Restore"
|
||||||
helpText="Download a zipped backup of your database or restore from a backup zip."
|
helpText="Download a zipped backup of your database or restore from a backup zip."
|
||||||
>
|
>
|
||||||
<div style={{ display: 'flex', gap: '0.5rem', alignItems: 'center', flexWrap: 'wrap' }}>
|
<div style={{ display: 'flex', gap: '0.5rem', alignItems: 'center', flexWrap: 'wrap' }}>
|
||||||
<Button theme="solid" icon={<IconSave />} onClick={handleDownloadBackup}>
|
<Button
|
||||||
|
theme="solid"
|
||||||
|
icon={<IconSave />}
|
||||||
|
onClick={handleDownloadBackup}
|
||||||
|
disabled={demoMode && !currentUser?.isAdmin}
|
||||||
|
>
|
||||||
Download Backup
|
Download Backup
|
||||||
</Button>
|
</Button>
|
||||||
<input
|
<input
|
||||||
@@ -482,7 +497,12 @@ const GeneralSettings = function GeneralSettings() {
|
|||||||
style={{ display: 'none' }}
|
style={{ display: 'none' }}
|
||||||
onChange={handleSelectRestoreFile}
|
onChange={handleSelectRestoreFile}
|
||||||
/>
|
/>
|
||||||
<Button onClick={handleOpenFilePicker} theme="light" icon={<IconFolder />}>
|
<Button
|
||||||
|
onClick={handleOpenFilePicker}
|
||||||
|
theme="light"
|
||||||
|
icon={<IconFolder />}
|
||||||
|
disabled={demoMode && !currentUser?.isAdmin}
|
||||||
|
>
|
||||||
Restore from Zip
|
Restore from Zip
|
||||||
</Button>
|
</Button>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -37,7 +37,7 @@ const Users = function Users() {
|
|||||||
await actions.jobsData.getJobs();
|
await actions.jobsData.getJobs();
|
||||||
await actions.user.getUsers();
|
await actions.user.getUsers();
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
Toast.error(error);
|
Toast.error(error.error);
|
||||||
setUserIdToBeRemoved(null);
|
setUserIdToBeRemoved(null);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|||||||
@@ -2675,10 +2675,10 @@ basic-ftp@^5.0.2:
|
|||||||
resolved "https://registry.yarnpkg.com/basic-ftp/-/basic-ftp-5.3.1.tgz#3148ee9af43c0522514a4f973fecb1d3cbb6d71e"
|
resolved "https://registry.yarnpkg.com/basic-ftp/-/basic-ftp-5.3.1.tgz#3148ee9af43c0522514a4f973fecb1d3cbb6d71e"
|
||||||
integrity sha512-bopVNp6ugyA150DDuZfPFdt1KZ5a94ZDiwX4hMgZDzF+GttD80lEy8kj98kbyhLXnPvhtIo93mdnLIjpCAeeOw==
|
integrity sha512-bopVNp6ugyA150DDuZfPFdt1KZ5a94ZDiwX4hMgZDzF+GttD80lEy8kj98kbyhLXnPvhtIo93mdnLIjpCAeeOw==
|
||||||
|
|
||||||
better-sqlite3@^12.9.0:
|
better-sqlite3@^12.10.0:
|
||||||
version "12.9.0"
|
version "12.10.0"
|
||||||
resolved "https://registry.yarnpkg.com/better-sqlite3/-/better-sqlite3-12.9.0.tgz#32498c99ba3fb36f604fbb5c70667c5f68c00414"
|
resolved "https://registry.yarnpkg.com/better-sqlite3/-/better-sqlite3-12.10.0.tgz#bde622d14a18008583a53bc53501ae98f1a12221"
|
||||||
integrity sha512-wqUv4Gm3toFpHDQmaKD4QhZm3g1DjUBI0yzS4UBl6lElUmXFYdTQmmEDpAFa5o8FiFiymURypEnfVHzILKaxqQ==
|
integrity sha512-CyzaZRQKyHkB2ZInfTTl2nvT33EbDpjkLEbE8/Zck3Ll6O0qqvuGdrJ45HgtH+HykRg88ITY3AdreBGN70aBSQ==
|
||||||
dependencies:
|
dependencies:
|
||||||
bindings "^1.5.0"
|
bindings "^1.5.0"
|
||||||
prebuild-install "^7.1.1"
|
prebuild-install "^7.1.1"
|
||||||
|
|||||||
Reference in New Issue
Block a user