diff --git a/backend/tasks.js b/backend/tasks.js index a86a9d6..6f487cc 100644 --- a/backend/tasks.js +++ b/backend/tasks.js @@ -285,8 +285,10 @@ async function rebuildDB() { const usersFileFolder = config_api.getConfigItem('ytdl_users_base_path'); const user_exists = await db_api.getRecord('users', {uid: user_to_add}); - if (!user_exists) await auth_api.registerUser(user_to_add, user_to_add, ''); - else logger.info(`Regenerated user ${user_to_add}`); + if (!user_exists) { + await auth_api.registerUser(user_to_add, user_to_add, ''); + logger.info(`Regenerated user ${user_to_add}`); + } const user_channel_subs = await guessSubscriptions(false, path.join(usersFileFolder, user_to_add), user_to_add); const user_playlist_subs = await guessSubscriptions(true, path.join(usersFileFolder, user_to_add), user_to_add); @@ -294,7 +296,7 @@ async function rebuildDB() { } for (const sub_to_add of subs_to_add) { - const sub_exists = await db_api.getRecord('subscriptions', {name: sub_to_add['name']}); + const sub_exists = !!(await subscriptions_api.getSubscriptionByName(sub_to_add['name'], sub_to_add['user_uid'])); // TODO: we shouldn't be creating this here const new_sub = { name: sub_to_add['name'], @@ -305,9 +307,14 @@ async function rebuildDB() { type: sub_to_add['type'], paused: true }; - if (!sub_exists) await subscriptions_api.subscribe(new_sub, sub_to_add['user_uid']); - else logger.info(`Regenerated subscription ${sub_to_add['name']}`); + if (!sub_exists) { + await subscriptions_api.subscribe(new_sub, sub_to_add['user_uid']); + logger.info(`Regenerated subscription ${sub_to_add['name']}`); + } } + + logger.info(`Importing unregistered files`); + await files_api.importUnregisteredFiles(); } const guessUsers = async () => {