Compare commits
30 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9c0c83143f | ||
|
|
ac074c4c00 | ||
|
|
9a3ce1e184 | ||
|
|
e17053141d | ||
|
|
320e5aec2a | ||
|
|
2d8c1c655a | ||
|
|
7e268fec0b | ||
|
|
1de8af197e | ||
|
|
d01c0744e5 | ||
|
|
175511ba45 | ||
|
|
4edcc4c88d | ||
|
|
915716880c | ||
|
|
77a7678565 | ||
|
|
49fd516d45 | ||
|
|
7e4b548583 | ||
|
|
981d862fa7 | ||
|
|
fc35a5aa97 | ||
|
|
d52d9d7f20 | ||
|
|
a3b83f93c3 | ||
|
|
2efdc6b0aa | ||
|
|
1e7d81b181 | ||
|
|
bbf7b43aa3 | ||
|
|
5aefa9e558 | ||
|
|
605aba7a05 | ||
|
|
5a43cd0e46 | ||
|
|
307b9adfa3 | ||
|
|
85a23578e7 | ||
|
|
db0b3c8c62 | ||
|
|
e820c82c56 | ||
|
|
ac29dbebba |
12
CHANGELOG.md
12
CHANGELOG.md
@@ -1,3 +1,15 @@
|
||||
1.5.7 / 2024-04-04
|
||||
|
||||
- В параметр bookReadLink конфига добавлен вариант замены DOWNLOAD_URI на uri из ссылки для скачивания книги (#29)
|
||||
- В параметры командной строки добавлена возможность задавать путь к файлу конфигурации, а все остальные настройки приложения можно указать в нем самом (#30)
|
||||
|
||||
1.5.6 / 2024-03-25
|
||||
|
||||
- Добавлен вывод version.info в статистику по коллекции (#27)
|
||||
- Убрано (по умолчанию) ежеминутное журналирование статистики сервера. В конфиг добавлен параметр logServerStats (#26)
|
||||
- В конфиг добавлен параметр logQueries для журналирования запросов и времени их выполнения
|
||||
- Добавлена расшифровка имен жанров в информации о книге (#24)
|
||||
|
||||
1.5.5 / 2023-04-25
|
||||
|
||||
- Улучшение работы с inpx: теперь понимает zip-архивы, вложенные в каталоги (библиотека Траума)
|
||||
|
||||
71
README.md
71
README.md
@@ -66,29 +66,63 @@ OPDS-сервер доступен по адресу [http://127.0.0.1:12380/opd
|
||||
Usage: inpx-web [options]
|
||||
|
||||
Options:
|
||||
--help Показать опции командной строки
|
||||
--host=<ip> Задать имя хоста для веб сервера, по умолчанию: 0.0.0.0
|
||||
--port=<port> Задать порт для веб сервера, по умолчанию: 12380
|
||||
--app-dir=<dirpath> Задать рабочую директорию, по умолчанию: <execDir>/.inpx-web
|
||||
--lib-dir=<dirpath> Задать директорию библиотеки (с zip-архивами), по умолчанию: там же, где лежит файл приложения
|
||||
--inpx=<filepath> Задать путь к файлу .inpx, по умолчанию: тот, что найдется в директории библиотеки
|
||||
--recreate Принудительно пересоздать поисковую БД при запуске приложения
|
||||
--help Показать опции командной строки
|
||||
--host=<ip> Задать имя хоста для веб сервера, по умолчанию: 0.0.0.0
|
||||
--port=<port> Задать порт для веб сервера, по умолчанию: 12380
|
||||
--config=<filepath> Задать файл конфигурации, по умолчанию: <dataDir>/config.json
|
||||
--data-dir=<dirpath> (или --app-dir) Задать рабочую директорию, по умолчанию: <execDir>/.inpx-web
|
||||
--lib-dir=<dirpath> Задать директорию библиотеки (с zip-архивами), по умолчанию: там же, где лежит файл приложения
|
||||
--inpx=<filepath> Задать путь к файлу .inpx, по умолчанию: тот, что найдется в директории библиотеки
|
||||
--recreate Принудительно пересоздать поисковую БД при запуске приложения
|
||||
--unsafe-filter Использовать небезопасный фильтр на свой страх и риск
|
||||
```
|
||||
|
||||
<a id="config" />
|
||||
|
||||
### Конфигурация
|
||||
При первом запуске в рабочей директории будет создан конфигурационный файл `config.json`:
|
||||
|
||||
По умолчанию, при первом запуске в рабочей директории будет создан конфигурационный файл `config.json`.
|
||||
При необходимости, можно настроить нужный параметр в этом файле вручную. Параметры командной
|
||||
строки имеют больший приоритет, чем настройки из `config.json`.
|
||||
|
||||
```js
|
||||
{
|
||||
// рабочая директория приложения, аналог параметра командной строки --data-dir (или --app-dir)
|
||||
// пустая строка: использовать значение по умолчанию - <execDir>/.inpx-web
|
||||
// где execDir - директория файла приложения
|
||||
"dataDir": "",
|
||||
|
||||
// директория для хранения временных файлов
|
||||
// пустая строка: использовать значение по умолчанию - <dataDir>/tmp
|
||||
// специальное значение "${OS}" указывается для использования системного каталога:
|
||||
// "${OS}" => "<os_temporary_dir>/inpx-web"
|
||||
"tempDir": "",
|
||||
|
||||
// директория для хранения логов
|
||||
// пустая строка: использовать значение по умолчанию - <dataDir>/logs
|
||||
"logDir": "",
|
||||
|
||||
// директория библиотеки (с zip-архивами), аналог параметра командной строки --lib-dir
|
||||
// пустая строка: использовать значение по умолчанию - директорию файла приложения
|
||||
// пустая строка: использовать значение по умолчанию - директорию файла приложения (execDir)
|
||||
"libDir": "",
|
||||
|
||||
// путь к файлу .inpx, аналог параметра командной строки --inpx
|
||||
// пустая строка: использовать значение по умолчанию - inpx-файл, что найдется в директории библиотеки
|
||||
"inpx": "",
|
||||
|
||||
// конфигурационный файл для фильтра по авторам и книгам (см. ниже)
|
||||
// пустая строка: использовать значение по умолчанию - файл filter.json в директории файла конфигурации
|
||||
"inpxFilterFile": "",
|
||||
|
||||
// разрешить(true)/запретить(false) перезаписывать файл конфигурации, если появились новые параметры для настройки
|
||||
// файл перезаписывается с сохранением всех предыдущих настроек и с новыми по умолчанию
|
||||
// бывает полезно при выходе новых версий приложения
|
||||
"allowConfigRewrite": false,
|
||||
|
||||
// разрешить(true)/запретить(false) использовать небезопасный фильтр (см. ниже)
|
||||
// аналог параметра командной строки --unsafe-filter
|
||||
"allowUnsafeFilter": false,
|
||||
|
||||
// пароль для ограничения доступа к веб-интерфейсу сервера
|
||||
// пустое значение - доступ без ограничений
|
||||
"accessPassword": "",
|
||||
@@ -106,11 +140,19 @@ Options:
|
||||
// содержимое кнопки-ссылки "(читать)", если не задано - кнопка "(читать)" не показывается
|
||||
// пример: "https://omnireader.ru/#/reader?url=${DOWNLOAD_LINK}"
|
||||
// на место ${DOWNLOAD_LINK} будет подставлена ссылка на скачивание файла книги
|
||||
// пример: "https://mydomain.ru/#/reader?url=http://127.0.0.1:8086${DOWNLOAD_URI}"
|
||||
// на место ${DOWNLOAD_URI} будут подставлены параметры (без имени хоста) из ссылки на скачивание файла книги
|
||||
"bookReadLink": "",
|
||||
|
||||
// включить(true)/выключить(false) журналирование
|
||||
"loggingEnabled": true,
|
||||
|
||||
// включить/выключить ежеминутный вывод в лог memUsage и loadAvg
|
||||
"logServerStats": false,
|
||||
|
||||
// включить/выключить вывод в лог запросов и времени их выполнения
|
||||
"logQueries": false,
|
||||
|
||||
// максимальный размер кеша каждой таблицы в БД, в блоках (требуется примерно 1-10Мб памяти на один блок)
|
||||
// если надо кешировать всю БД, можно поставить значение от 1000 и больше
|
||||
"dbCacheSize": 5,
|
||||
@@ -202,9 +244,6 @@ Options:
|
||||
}
|
||||
```
|
||||
|
||||
При необходимости, можно настроить нужный параметр в этом файле вручную. Параметры командной
|
||||
строки имеют больший приоритет, чем настройки из `config.json`.
|
||||
|
||||
<a id="remotelib" />
|
||||
|
||||
### Удаленная библиотека
|
||||
@@ -239,8 +278,8 @@ Options:
|
||||
### Фильтр по авторам и книгам
|
||||
|
||||
При создании поисковой БД, во время загрузки и парсинга .inpx-файла, имеется возможность
|
||||
отфильтровать авторов и книги, задав определенные критерии. Для этого небходимо создать
|
||||
в рабочей директории (там же, где `config.json`) файл `filter.json` следующего вида:
|
||||
отфильтровать авторов и книги, задав определенные критерии. По умолчанию, для этого небходимо создать
|
||||
в директории конфигурационного файла (там же, где `config.json`) файл `filter.json` следующего вида:
|
||||
```json
|
||||
{
|
||||
"info": {
|
||||
@@ -285,8 +324,10 @@ Options:
|
||||
}
|
||||
```
|
||||
Использование `filter` небезопасно, т.к. позволяет выполнить произвольный js-код внутри программы,
|
||||
поэтому запуск приложения в этом случае должен сопровождаться дополнительным параметром командной строки `--unsafe-filter`.
|
||||
поэтому запуск приложения в этом случае должен сопровождаться дополнительным параметром командной строки `--unsafe-filter`
|
||||
или разрешением в конфиге `allowUnsafeFilter`.
|
||||
Названия атрибутов inpxRec соответствуют названиям в нижнем регистре из структуры structure.info в .inpx-файле.
|
||||
Файл `filter.json` можно расположить где угодно, что задается параметром `inpxFilterFile` в конфиге.
|
||||
<a id="https" />
|
||||
|
||||
### Настройка https с помощью nginx
|
||||
|
||||
@@ -3,6 +3,7 @@ const path = require('path');
|
||||
const { execSync } = require('child_process');
|
||||
|
||||
const pckg = require('../package.json');
|
||||
const platform = process.argv[2];
|
||||
|
||||
const distDir = path.resolve(__dirname, '../dist');
|
||||
const outDir = `${distDir}/release`;
|
||||
@@ -20,10 +21,14 @@ async function makeRelease(target) {
|
||||
async function main() {
|
||||
try {
|
||||
await fs.emptyDir(outDir);
|
||||
await makeRelease('win');
|
||||
await makeRelease('linux');
|
||||
await makeRelease('linux-arm64');
|
||||
await makeRelease('macos');
|
||||
if (platform) {
|
||||
await makeRelease(platform);
|
||||
} else {
|
||||
await makeRelease('win');
|
||||
await makeRelease('linux');
|
||||
await makeRelease('linux-arm64');
|
||||
await makeRelease('macos');
|
||||
}
|
||||
} catch(e) {
|
||||
console.error(e);
|
||||
process.exit(1);
|
||||
|
||||
@@ -178,7 +178,18 @@ export default class BaseList {
|
||||
if (this.list.liberamaReady) {
|
||||
this.$emit('listEvent', {action: 'submitUrl', data: href});
|
||||
} else {
|
||||
const url = this.config.bookReadLink.replace('${DOWNLOAD_LINK}', href);
|
||||
const bookReadLink = this.config.bookReadLink;
|
||||
let url = bookReadLink;
|
||||
|
||||
if (bookReadLink.indexOf('${DOWNLOAD_LINK}') >= 0) {
|
||||
url = bookReadLink.replace('${DOWNLOAD_LINK}', href);
|
||||
|
||||
} else if (bookReadLink.indexOf('${DOWNLOAD_URI}') >= 0) {
|
||||
const hrefUrl = new URL(href);
|
||||
const urlWithoutHost = hrefUrl.pathname + hrefUrl.search + hrefUrl.hash;
|
||||
url = bookReadLink.replace('${DOWNLOAD_URI}', urlWithoutHost);
|
||||
}
|
||||
|
||||
window.open(url, '_blank');
|
||||
}
|
||||
} else if (action == 'bookInfo') {
|
||||
|
||||
@@ -118,6 +118,7 @@ class BookInfoDialog {
|
||||
_props = {
|
||||
modelValue: Boolean,
|
||||
bookInfo: Object,
|
||||
genreMap: Object,
|
||||
};
|
||||
|
||||
dialogVisible = false;
|
||||
@@ -169,6 +170,19 @@ class BookInfoDialog {
|
||||
return `${size.toFixed(1)} ${unit}`;
|
||||
}
|
||||
|
||||
convertGenres(genreArr) {
|
||||
let result = [];
|
||||
if (genreArr) {
|
||||
for (const genre of genreArr) {
|
||||
const g = genre.trim();
|
||||
const name = this.genreMap.get(g);
|
||||
result.push(name ? name : g);
|
||||
}
|
||||
}
|
||||
|
||||
return result.join(', ');
|
||||
}
|
||||
|
||||
get inpx() {
|
||||
const mapping = [
|
||||
{name: 'fileInfo', label: 'Информация о файле', value: [
|
||||
@@ -211,6 +225,9 @@ class BookInfoDialog {
|
||||
if (nodePath == 'titleInfo/author')
|
||||
return value.split(',').join(', ');
|
||||
|
||||
if (nodePath == 'titleInfo/genre')
|
||||
return this.convertGenres(value.split(','));
|
||||
|
||||
if (nodePath == 'titleInfo/librate' && !value)
|
||||
return null;
|
||||
|
||||
@@ -279,11 +296,16 @@ class BookInfoDialog {
|
||||
}
|
||||
}
|
||||
|
||||
const self = this;
|
||||
this.fb2 = parser.bookInfoList(infoObj, {
|
||||
valueToString(value, nodePath, origVTS) {//eslint-disable-line no-unused-vars
|
||||
if (nodePath == 'documentInfo/historyHtml' && value)
|
||||
return value.replace(/<p>/g, `<p class="p-history">`);
|
||||
|
||||
if ((nodePath == 'titleInfo/genre' || nodePath == 'srcTitleInfo/genre') && value) {
|
||||
return self.convertGenres(value);
|
||||
}
|
||||
|
||||
return origVTS(value, nodePath);
|
||||
},
|
||||
});
|
||||
|
||||
@@ -347,7 +347,7 @@
|
||||
<SelectLibRateDialog v-model="selectLibRateDialogVisible" v-model:librate="search.librate" />
|
||||
<SelectDateDialog v-model="selectDateDialogVisible" v-model:date="search.date" />
|
||||
<SelectExtDialog v-model="selectExtDialogVisible" v-model:ext="search.ext" :ext-list="extList" />
|
||||
<BookInfoDialog v-model="bookInfoDialogVisible" :book-info="bookInfo" />
|
||||
<BookInfoDialog v-model="bookInfoDialogVisible" :book-info="bookInfo" :genre-map="genreMap" />
|
||||
<SelectExtSearchDialog v-model="selectExtSearchDialogVisible" v-model:ext-search="extSearch" />
|
||||
</div>
|
||||
</template>
|
||||
@@ -931,6 +931,10 @@ class Search {
|
||||
<b>collection.info:</b>
|
||||
<pre>${inpxInfo.collection}</pre>
|
||||
</div>
|
||||
<div><hr/>
|
||||
<b>version.info:</b>
|
||||
<pre>${inpxInfo.version}</pre>
|
||||
</div>
|
||||
`;
|
||||
|
||||
this.$root.stdDialog.alert(info, 'Статистика по коллекции', {iconName: 'la la-info-circle'});
|
||||
|
||||
7543
package-lock.json
generated
7543
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
62
package.json
62
package.json
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "inpx-web",
|
||||
"version": "1.5.5",
|
||||
"version": "1.5.8",
|
||||
"author": "Book Pauk <bookpauk@gmail.com>",
|
||||
"license": "CC0-1.0",
|
||||
"repository": "bookpauk/inpx-web",
|
||||
@@ -17,6 +17,10 @@
|
||||
"build:client-dev": "webpack --config build/webpack.dev.config.js",
|
||||
"build:all": "npm run build:linux && npm run build:win && npm run build:macos && npm run build:linux-arm64",
|
||||
"release": "npm run build:all && node build/release.js",
|
||||
"release:linux": "npm run build:linux && node build/release.js linux",
|
||||
"release:win": "npm run build:win && node build/release.js win",
|
||||
"release:macos": "npm run build:macos && node build/release.js macos",
|
||||
"release:arm64": "npm run build:linux-arm64 && node build/release.js arm64",
|
||||
"postinstall": "npm run build:client-dev"
|
||||
},
|
||||
"bin": "server/index.js",
|
||||
@@ -25,38 +29,38 @@
|
||||
"assets": "dist/public.json"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@babel/core": "^7.20.5",
|
||||
"@babel/eslint-parser": "^7.19.1",
|
||||
"@babel/eslint-plugin": "^7.19.1",
|
||||
"@babel/plugin-proposal-decorators": "^7.20.5",
|
||||
"@babel/preset-env": "^7.20.2",
|
||||
"@babel/core": "^7.24.3",
|
||||
"@babel/eslint-parser": "^7.24.1",
|
||||
"@babel/eslint-plugin": "^7.23.5",
|
||||
"@babel/plugin-proposal-decorators": "^7.24.1",
|
||||
"@babel/preset-env": "^7.24.3",
|
||||
"@vue/compiler-sfc": "^3.2.22",
|
||||
"babel-loader": "^9.1.0",
|
||||
"babel-loader": "^9.1.3",
|
||||
"copy-webpack-plugin": "^11.0.0",
|
||||
"css-loader": "^6.7.2",
|
||||
"css-loader": "^6.10.0",
|
||||
"css-minimizer-webpack-plugin": "^4.2.2",
|
||||
"eslint": "^8.28.0",
|
||||
"eslint-plugin-vue": "^9.8.0",
|
||||
"html-webpack-plugin": "^5.5.0",
|
||||
"mini-css-extract-plugin": "^2.7.1",
|
||||
"pkg": "^5.8.0",
|
||||
"eslint": "^8.57.0",
|
||||
"eslint-plugin-vue": "^9.23.0",
|
||||
"html-webpack-plugin": "^5.6.0",
|
||||
"mini-css-extract-plugin": "^2.8.1",
|
||||
"pkg": "^5.8.1",
|
||||
"showdown": "^2.1.0",
|
||||
"terser-webpack-plugin": "^5.3.6",
|
||||
"vue-eslint-parser": "^9.1.0",
|
||||
"vue-loader": "^17.0.1",
|
||||
"terser-webpack-plugin": "^5.3.10",
|
||||
"vue-eslint-parser": "^9.4.2",
|
||||
"vue-loader": "^17.4.2",
|
||||
"vue-style-loader": "^4.1.3",
|
||||
"webpack": "^5.75.0",
|
||||
"webpack-cli": "^5.0.0",
|
||||
"webpack-dev-middleware": "^6.0.1",
|
||||
"webpack-hot-middleware": "^2.25.3",
|
||||
"webpack-merge": "^5.8.0"
|
||||
"webpack": "^5.91.0",
|
||||
"webpack-cli": "^5.1.4",
|
||||
"webpack-dev-middleware": "^6.1.2",
|
||||
"webpack-hot-middleware": "^2.26.1",
|
||||
"webpack-merge": "^5.10.0"
|
||||
},
|
||||
"dependencies": {
|
||||
"@quasar/extras": "^1.15.6",
|
||||
"@quasar/extras": "^1.16.9",
|
||||
"axios": "^0.27.2",
|
||||
"chardet": "^1.5.0",
|
||||
"dayjs": "^1.11.6",
|
||||
"express": "^4.18.2",
|
||||
"chardet": "^1.6.0",
|
||||
"dayjs": "^1.11.10",
|
||||
"express": "^4.19.1",
|
||||
"express-basic-auth": "^1.2.1",
|
||||
"fs-extra": "^10.1.0",
|
||||
"he": "^1.2.0",
|
||||
@@ -64,15 +68,15 @@
|
||||
"jembadb": "^5.1.7",
|
||||
"localforage": "^1.10.0",
|
||||
"lodash": "^4.17.21",
|
||||
"minimist": "^1.2.7",
|
||||
"minimist": "^1.2.8",
|
||||
"node-stream-zip": "^1.15.0",
|
||||
"quasar": "^2.10.2",
|
||||
"quasar": "^2.15.1",
|
||||
"safe-buffer": "^5.2.1",
|
||||
"vue": "^3.2.37",
|
||||
"vue-router": "^4.1.6",
|
||||
"vue-router": "^4.3.0",
|
||||
"vuex": "^4.1.0",
|
||||
"vuex-persist": "^3.1.3",
|
||||
"ws": "^8.11.0",
|
||||
"ws": "^8.16.0",
|
||||
"yazl": "^2.5.1"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -10,14 +10,22 @@ module.exports = {
|
||||
name: pckg.name,
|
||||
|
||||
execDir,
|
||||
dataDir: '',
|
||||
tempDir: '',
|
||||
logDir: '',
|
||||
libDir: '',
|
||||
inpx: '',
|
||||
inpxFilterFile: '',
|
||||
|
||||
allowConfigRewrite: false,
|
||||
allowUnsafeFilter: false,
|
||||
accessPassword: '',
|
||||
accessTimeout: 0,
|
||||
extendedSearch: true,
|
||||
bookReadLink: '',
|
||||
loggingEnabled: true,
|
||||
logServerStats: false,
|
||||
logQueries: false,
|
||||
|
||||
//поправить в случае, если были критические изменения в DbCreator или InpxParser
|
||||
//иначе будет рассинхронизация по кешу между сервером и клиентом на уровне БД
|
||||
|
||||
@@ -5,13 +5,21 @@ const fs = require('fs-extra');
|
||||
const branchFilename = __dirname + '/application_env';
|
||||
|
||||
const propsToSave = [
|
||||
'dataDir',
|
||||
'tempDir',
|
||||
'logDir',
|
||||
'libDir',
|
||||
'inpx',
|
||||
'inpxFilterFile',
|
||||
'allowConfigRewrite',
|
||||
'allowUnsafeFilter',
|
||||
'accessPassword',
|
||||
'accessTimeout',
|
||||
'extendedSearch',
|
||||
'bookReadLink',
|
||||
'loggingEnabled',
|
||||
'logServerStats',
|
||||
'logQueries',
|
||||
'dbCacheSize',
|
||||
'maxFilesDirSize',
|
||||
'queryCacheEnabled',
|
||||
@@ -44,7 +52,7 @@ class ConfigManager {
|
||||
return instance;
|
||||
}
|
||||
|
||||
async init(dataDir) {
|
||||
async init(defaultDataDir, configFile) {
|
||||
if (this.inited)
|
||||
throw new Error('already inited');
|
||||
|
||||
@@ -61,14 +69,17 @@ class ConfigManager {
|
||||
this.branchConfigFile = __dirname + `/${this.branch}.js`;
|
||||
const config = require(this.branchConfigFile);
|
||||
|
||||
if (dataDir) {
|
||||
config.dataDir = path.resolve(dataDir);
|
||||
} else {
|
||||
config.dataDir = `${config.execDir}/.${config.name}`;
|
||||
if (!defaultDataDir) {
|
||||
defaultDataDir = `${config.execDir}/.${config.name}`;
|
||||
}
|
||||
|
||||
if (configFile) {
|
||||
config.configFile = path.resolve(configFile);
|
||||
} else {
|
||||
await fs.ensureDir(defaultDataDir);
|
||||
config.configFile = `${defaultDataDir}/config.json`;
|
||||
}
|
||||
|
||||
await fs.ensureDir(config.dataDir);
|
||||
this._userConfigFile = `${config.dataDir}/config.json`;
|
||||
this._config = config;
|
||||
|
||||
this.inited = true;
|
||||
@@ -84,37 +95,31 @@ class ConfigManager {
|
||||
Object.assign(this._config, value);
|
||||
}
|
||||
|
||||
get userConfigFile() {
|
||||
return this._userConfigFile;
|
||||
}
|
||||
|
||||
set userConfigFile(value) {
|
||||
if (value)
|
||||
this._userConfigFile = value;
|
||||
}
|
||||
|
||||
async load() {
|
||||
try {
|
||||
if (!this.inited)
|
||||
throw new Error('not inited');
|
||||
|
||||
if (await fs.pathExists(this.userConfigFile)) {
|
||||
const data = JSON.parse(await fs.readFile(this.userConfigFile, 'utf8'));
|
||||
if (await fs.pathExists(this._config.configFile)) {
|
||||
const data = JSON.parse(await fs.readFile(this._config.configFile, 'utf8'));
|
||||
const config = _.pick(data, propsToSave);
|
||||
|
||||
this.config = config;
|
||||
|
||||
//сохраним конфиг, если не все атрибуты присутствуют в файле конфига
|
||||
for (const prop of propsToSave)
|
||||
if (!Object.prototype.hasOwnProperty.call(config, prop)) {
|
||||
await this.save();
|
||||
break;
|
||||
if (config.allowConfigRewrite) {
|
||||
for (const prop of propsToSave) {
|
||||
if (!Object.prototype.hasOwnProperty.call(config, prop)) {
|
||||
await this.save();
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
} else {
|
||||
await this.save();
|
||||
}
|
||||
} catch(e) {
|
||||
throw new Error(`Error while loading "${this.userConfigFile}": ${e.message}`);
|
||||
throw new Error(`Error while loading "${this._config.configFile}": ${e.message}`);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -123,7 +128,7 @@ class ConfigManager {
|
||||
throw new Error('not inited');
|
||||
|
||||
const dataToSave = _.pick(this._config, propsToSave);
|
||||
await fs.writeFile(this.userConfigFile, JSON.stringify(dataToSave, null, 4));
|
||||
await fs.writeFile(this._config.configFile, JSON.stringify(dataToSave, null, 4));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -56,11 +56,12 @@ class WebSocketController {
|
||||
async onMessage(ws, message) {
|
||||
let req = {};
|
||||
try {
|
||||
if (this.isDevelopment) {
|
||||
log(`WebSocket-IN: ${message.substr(0, 4000)}`);
|
||||
if (this.isDevelopment || this.config.logQueries) {
|
||||
log(`WebSocket-IN: ${utils.cutString(message)}`);
|
||||
}
|
||||
|
||||
req = JSON.parse(message);
|
||||
req.__startTime = Date.now();
|
||||
|
||||
ws.lastActivity = Date.now();
|
||||
|
||||
@@ -123,8 +124,9 @@ class WebSocketController {
|
||||
const message = JSON.stringify(r);
|
||||
ws.send(message);
|
||||
|
||||
if (this.isDevelopment) {
|
||||
log(`WebSocket-OUT: ${message.substr(0, 200)}`);
|
||||
if (this.isDevelopment || this.config.logQueries) {
|
||||
log(`WebSocket-OUT: ${utils.cutString(message)}`);
|
||||
log(`${Date.now() - req.__startTime}ms`);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -314,7 +314,7 @@ class WebWorker {
|
||||
|
||||
let result;
|
||||
const db = this.db;
|
||||
if (!db.wwCache.genres) {
|
||||
if (!db.wwCache.genreTree) {
|
||||
const genres = _.cloneDeep(genreTree);
|
||||
const last = genres[genres.length - 1];
|
||||
|
||||
@@ -362,9 +362,31 @@ class WebWorker {
|
||||
inpxHash: (config.inpxHash ? config.inpxHash : ''),
|
||||
};
|
||||
|
||||
db.wwCache.genres = result;
|
||||
db.wwCache.genreTree = result;
|
||||
} else {
|
||||
result = db.wwCache.genres;
|
||||
result = db.wwCache.genreTree;
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
async getGenreMap() {
|
||||
this.checkMyState();
|
||||
|
||||
let result;
|
||||
const db = this.db;
|
||||
if (!db.wwCache.genreMap) {
|
||||
const genreTree = await this.getGenreTree();
|
||||
|
||||
result = new Map();
|
||||
for (const section of genreTree.genreTree) {
|
||||
for (const g of section.value)
|
||||
result.set(g.value, g.name);
|
||||
}
|
||||
|
||||
db.wwCache.genreMap = result;
|
||||
} else {
|
||||
result = db.wwCache.genreMap;
|
||||
}
|
||||
|
||||
return result;
|
||||
@@ -604,16 +626,16 @@ class WebWorker {
|
||||
let loadAvg = os.loadavg();
|
||||
loadAvg = loadAvg.map(v => v.toFixed(2));
|
||||
|
||||
log(`Server info [ memUsage: ${memUsage.toFixed(2)}MB, loadAvg: (${loadAvg.join(', ')}) ]`);
|
||||
|
||||
if (this.config.server.ready)
|
||||
log(`Server accessible at http://127.0.0.1:${this.config.server.port} (listening on ${this.config.server.host}:${this.config.server.port})`);
|
||||
log(`Server stats [ memUsage: ${memUsage.toFixed(2)}MB, loadAvg: (${loadAvg.join(', ')}) ]`);
|
||||
} catch (e) {
|
||||
log(LM_ERR, e.message);
|
||||
}
|
||||
}
|
||||
|
||||
async periodicLogServerStats() {
|
||||
if (!this.config.logServerStats)
|
||||
return;
|
||||
|
||||
while (1) {// eslint-disable-line
|
||||
this.logServerStats();
|
||||
await utils.sleep(60*1000);
|
||||
@@ -637,8 +659,6 @@ class WebWorker {
|
||||
}
|
||||
}
|
||||
|
||||
log(LM_WARN, `clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files, total size=${size}`);
|
||||
|
||||
files.sort((a, b) => a.stat.mtimeMs - b.stat.mtimeMs);
|
||||
|
||||
let i = 0;
|
||||
@@ -651,7 +671,10 @@ class WebWorker {
|
||||
i++;
|
||||
}
|
||||
|
||||
log(LM_WARN, `removed ${i} files`);
|
||||
if (i) {
|
||||
log(LM_WARN, `clean dir ${dir}, maxSize=${maxSize}, found ${files.length} files, total size=${size}`);
|
||||
log(LM_WARN, `removed ${i} files`);
|
||||
}
|
||||
}
|
||||
|
||||
async periodicCleanDir(dirConfig) {
|
||||
@@ -705,7 +728,7 @@ class WebWorker {
|
||||
log('inpx file: changes found, recreating DB');
|
||||
await this.recreateDb();
|
||||
} else {
|
||||
log('inpx file: no changes');
|
||||
//log('inpx file: no changes');
|
||||
}
|
||||
} catch(e) {
|
||||
log(LM_ERR, `periodicCheckInpx: ${e.message}`);
|
||||
|
||||
@@ -24,6 +24,19 @@ class BookPage extends BasePage {
|
||||
return `${size.toFixed(1)} ${unit}`;
|
||||
}
|
||||
|
||||
convertGenres(genreArr) {
|
||||
let result = [];
|
||||
if (genreArr) {
|
||||
for (const genre of genreArr) {
|
||||
const g = genre.trim();
|
||||
const name = this.genreMap.get(g);
|
||||
result.push(name ? name : g);
|
||||
}
|
||||
}
|
||||
|
||||
return result.join(', ');
|
||||
}
|
||||
|
||||
inpxInfo(bookRec) {
|
||||
const mapping = [
|
||||
{name: 'fileInfo', label: 'Информация о файле', value: [
|
||||
@@ -66,6 +79,9 @@ class BookPage extends BasePage {
|
||||
if (nodePath == 'titleInfo/author')
|
||||
return value.split(',').join(', ');
|
||||
|
||||
if (nodePath == 'titleInfo/genre')
|
||||
return this.convertGenres(value.split(','));
|
||||
|
||||
if (nodePath == 'titleInfo/librate' && !value)
|
||||
return null;
|
||||
|
||||
@@ -118,6 +134,7 @@ class BookPage extends BasePage {
|
||||
async body(req) {
|
||||
const result = {};
|
||||
|
||||
this.genreMap = await this.webWorker.getGenreMap();
|
||||
result.link = this.baseLinks(req, true);
|
||||
|
||||
const bookUid = req.query.uid;
|
||||
@@ -183,7 +200,17 @@ class BookPage extends BasePage {
|
||||
}
|
||||
|
||||
ann = infoObj.titleInfo.annotationHtml || '';
|
||||
const infoList = parser.bookInfoList(infoObj);
|
||||
const self = this;
|
||||
const infoList = parser.bookInfoList(infoObj, {
|
||||
valueToString(value, nodePath, origVTS) {//eslint-disable-line no-unused-vars
|
||||
if ((nodePath == 'titleInfo/genre' || nodePath == 'srcTitleInfo/genre') && value) {
|
||||
return self.convertGenres(value);
|
||||
}
|
||||
|
||||
return origVTS(value, nodePath);
|
||||
},
|
||||
});
|
||||
|
||||
info += this.htmlInfo('Fb2 инфо', infoList);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -74,7 +74,12 @@ module.exports = function(app, config) {
|
||||
if (config.opds.password) {
|
||||
if (!config.opds.user)
|
||||
throw new Error('User must not be empty if password set');
|
||||
|
||||
/*
|
||||
app.use((req, res, next) => {
|
||||
console.log(req.headers);
|
||||
next();
|
||||
});
|
||||
*/
|
||||
app.use(opdsPaths, basicAuth({
|
||||
users: {[config.opds.user]: config.opds.password},
|
||||
challenge: true,
|
||||
|
||||
@@ -196,6 +196,20 @@ function wordEnding(num, type = 0) {
|
||||
}
|
||||
}
|
||||
|
||||
function cutString(data, len = 500) {
|
||||
try {
|
||||
if (!data)
|
||||
return '';
|
||||
|
||||
if (typeof(data) !== 'string')
|
||||
data = JSON.stringify(data);
|
||||
|
||||
return `${data.substring(0, len)}${data.length > len ? ' ...' : ''}`;
|
||||
} catch (e) {
|
||||
return '';
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
sleep,
|
||||
processLoop,
|
||||
@@ -216,4 +230,5 @@ module.exports = {
|
||||
makeValidFileName,
|
||||
makeValidFileNameOrEmpty,
|
||||
wordEnding,
|
||||
cutString,
|
||||
};
|
||||
@@ -1,5 +1,6 @@
|
||||
const fs = require('fs-extra');
|
||||
const path = require('path');
|
||||
const os = require('os');
|
||||
|
||||
const express = require('express');
|
||||
const http = require('http');
|
||||
@@ -13,7 +14,7 @@ let log;
|
||||
let config;
|
||||
let argv;
|
||||
let branch = '';
|
||||
const argvStrings = ['host', 'port', 'app-dir', 'lib-dir', 'inpx'];
|
||||
const argvStrings = ['host', 'port', 'config', 'data-dir', 'app-dir', 'lib-dir', 'inpx'];
|
||||
|
||||
function showHelp(defaultConfig) {
|
||||
console.log(utils.versionText(defaultConfig));
|
||||
@@ -21,24 +22,27 @@ function showHelp(defaultConfig) {
|
||||
`Usage: ${defaultConfig.name} [options]
|
||||
|
||||
Options:
|
||||
--help Print ${defaultConfig.name} command line options
|
||||
--host=<ip> Set web server host, default: ${defaultConfig.server.host}
|
||||
--port=<port> Set web server port, default: ${defaultConfig.server.port}
|
||||
--app-dir=<dirpath> Set application working directory, default: <execDir>/.${defaultConfig.name}
|
||||
--lib-dir=<dirpath> Set library directory, default: the same as ${defaultConfig.name} executable's
|
||||
--inpx=<filepath> Set INPX collection file, default: the one that found in library dir
|
||||
--recreate Force recreation of the search database on start
|
||||
--help Print ${defaultConfig.name} command line options
|
||||
--host=<ip> Set web server host, default: ${defaultConfig.server.host}
|
||||
--port=<port> Set web server port, default: ${defaultConfig.server.port}
|
||||
--config=<filepath> Set config filename, default: <dataDir>/config.json
|
||||
--data-dir=<dirpath> (or --app-dir) Set application working directory, default: <execDir>/.${defaultConfig.name}
|
||||
--lib-dir=<dirpath> Set library directory, default: the same as ${defaultConfig.name} executable's
|
||||
--inpx=<filepath> Set INPX collection file, default: the one that found in library dir
|
||||
--recreate Force recreation of the search database on start
|
||||
--unsafe-filter Use filter config at your own risk
|
||||
`
|
||||
);
|
||||
}
|
||||
|
||||
async function init() {
|
||||
argv = require('minimist')(process.argv.slice(2), {string: argvStrings});
|
||||
const dataDir = argv['app-dir'];
|
||||
const argvDataDir = argv['data-dir'] || argv['app-dir'];
|
||||
const configFile = argv['config'];
|
||||
|
||||
//config
|
||||
const configManager = new (require('./config'))();//singleton
|
||||
await configManager.init(dataDir);
|
||||
await configManager.init(argvDataDir, configFile);
|
||||
const defaultConfig = configManager.config;
|
||||
|
||||
await configManager.load();
|
||||
@@ -46,8 +50,12 @@ async function init() {
|
||||
branch = config.branch;
|
||||
|
||||
//dirs
|
||||
config.tempDir = `${config.dataDir}/tmp`;
|
||||
config.logDir = `${config.dataDir}/log`;
|
||||
config.dataDir = config.dataDir || argvDataDir || `${config.execDir}/.${config.name}`;
|
||||
config.tempDir = config.tempDir || `${config.dataDir}/tmp`;
|
||||
if (config.tempDir === '${OS}')
|
||||
config.tempDir = `${os.tmpdir()}/${config.name}`
|
||||
|
||||
config.logDir = config.logDir || `${config.dataDir}/log`;
|
||||
config.publicDir = `${config.dataDir}/public`;
|
||||
config.publicFilesDir = `${config.dataDir}/public-files`;
|
||||
config.rootPathStatic = config.server.root || '';
|
||||
@@ -127,14 +135,34 @@ async function init() {
|
||||
}
|
||||
|
||||
config.recreateDb = argv.recreate || false;
|
||||
config.inpxFilterFile = `${config.dataDir}/filter.json`;
|
||||
config.allowUnsafeFilter = argv['unsafe-filter'] || false;
|
||||
config.inpxFilterFile = config.inpxFilterFile || `${path.dirname(config.configFile)}/filter.json`;
|
||||
config.allowUnsafeFilter = argv['unsafe-filter'] || config.allowUnsafeFilter || false;
|
||||
|
||||
//web app
|
||||
if (branch !== 'development') {
|
||||
const createWebApp = require('./createWebApp');
|
||||
await createWebApp(config);
|
||||
}
|
||||
|
||||
//log dirs
|
||||
for (const prop of ['configFile', 'dataDir', 'tempDir', 'logDir']) {
|
||||
log(`${prop}: ${config[prop]}`);
|
||||
}
|
||||
|
||||
if (await fs.pathExists(config.inpxFilterFile))
|
||||
log(`inpxFilterFile: ${config.inpxFilterFile}`)
|
||||
}
|
||||
|
||||
function logQueries(app) {
|
||||
app.use(function(req, res, next) {
|
||||
const start = Date.now();
|
||||
log(`${req.method} ${req.originalUrl} ${utils.cutString(req.body)}`);
|
||||
//log(`${JSON.stringify(req.headers, null, 2)}`)
|
||||
res.once('finish', () => {
|
||||
log(`${Date.now() - start}ms`);
|
||||
});
|
||||
next();
|
||||
});
|
||||
}
|
||||
|
||||
async function main() {
|
||||
@@ -168,6 +196,10 @@ async function main() {
|
||||
const { WebSocketController } = require('./controllers');
|
||||
new WebSocketController(wss, webAccess, config);
|
||||
|
||||
if (config.logQueries) {
|
||||
logQueries(app);
|
||||
}
|
||||
|
||||
if (devModule) {
|
||||
devModule.logErrors(app);
|
||||
} else {
|
||||
@@ -179,7 +211,7 @@ async function main() {
|
||||
|
||||
server.listen(config.server.port, config.server.host, () => {
|
||||
config.server.ready = true;
|
||||
log(`Server ready`);
|
||||
log(`Server accessible at http://127.0.0.1:${config.server.port} (listening on ${config.server.host}:${config.server.port})`);
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user