mirror of
https://github.com/Tzahi12345/YoutubeDL-Material.git
synced 2026-04-17 19:11:29 +03:00
Fixes bug (hopefully) that causes stale data to be saved to the db due to multiple adapters instances being used. Now the db adapter gets passed as a parameter
This commit is contained in:
@@ -61,7 +61,7 @@ const logger = winston.createLogger({
|
|||||||
});
|
});
|
||||||
|
|
||||||
config_api.setLogger(logger);
|
config_api.setLogger(logger);
|
||||||
subscriptions_api.setLogger(logger);
|
subscriptions_api.initialize(db, logger);
|
||||||
|
|
||||||
// var GithubContent = require('github-content');
|
// var GithubContent = require('github-content');
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,3 @@
|
|||||||
const low = require('lowdb')
|
|
||||||
const FileSync = require('lowdb/adapters/FileSync')
|
const FileSync = require('lowdb/adapters/FileSync')
|
||||||
|
|
||||||
var fs = require('fs-extra');
|
var fs = require('fs-extra');
|
||||||
@@ -8,14 +7,18 @@ var path = require('path');
|
|||||||
var youtubedl = require('youtube-dl');
|
var youtubedl = require('youtube-dl');
|
||||||
const config_api = require('./config');
|
const config_api = require('./config');
|
||||||
|
|
||||||
const adapter = new FileSync('./appdata/db.json');
|
|
||||||
const db = low(adapter)
|
|
||||||
|
|
||||||
const debugMode = process.env.YTDL_MODE === 'debug';
|
const debugMode = process.env.YTDL_MODE === 'debug';
|
||||||
|
|
||||||
var logger = null;
|
var logger = null;
|
||||||
|
var db = null;
|
||||||
|
function setDB(input_db) { db = input_db; }
|
||||||
function setLogger(input_logger) { logger = input_logger; }
|
function setLogger(input_logger) { logger = input_logger; }
|
||||||
|
|
||||||
|
function initialize(input_db, input_logger) {
|
||||||
|
setDB(input_db);
|
||||||
|
setLogger(input_logger);
|
||||||
|
}
|
||||||
|
|
||||||
async function subscribe(sub) {
|
async function subscribe(sub) {
|
||||||
const result_obj = {
|
const result_obj = {
|
||||||
success: false,
|
success: false,
|
||||||
@@ -328,5 +331,6 @@ module.exports = {
|
|||||||
deleteSubscriptionFile : deleteSubscriptionFile,
|
deleteSubscriptionFile : deleteSubscriptionFile,
|
||||||
getVideosForSub : getVideosForSub,
|
getVideosForSub : getVideosForSub,
|
||||||
removeIDFromArchive : removeIDFromArchive,
|
removeIDFromArchive : removeIDFromArchive,
|
||||||
setLogger : setLogger
|
setLogger : setLogger,
|
||||||
|
initialize : initialize
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user