@ -33,7 +33,7 @@ exports.subscribe = async (sub, user_uid = null, skip_get_info = false) => {
}
}
sub [ 'user_uid' ] = user _uid ? user _uid : undefined ;
sub [ 'user_uid' ] = user _uid ? user _uid : undefined ;
await db _api . insertRecordIntoTable ( 'subscriptions' , sub) ;
await db _api . insertRecordIntoTable ( 'subscriptions' , JSON. parse ( JSON . stringify ( sub) ) ) ;
let success = skip _get _info ? true : await getSubscriptionInfo ( sub ) ;
let success = skip _get _info ? true : await getSubscriptionInfo ( sub ) ;
exports . writeSubscriptionMetadata ( sub ) ;
exports . writeSubscriptionMetadata ( sub ) ;
@ -491,6 +491,8 @@ exports.writeSubscriptionMetadata = (sub) => {
: config _api . getConfigItem ( 'ytdl_subscriptions_base_path' ) ;
: config _api . getConfigItem ( 'ytdl_subscriptions_base_path' ) ;
const appendedBasePath = getAppendedBasePath ( sub , basePath ) ;
const appendedBasePath = getAppendedBasePath ( sub , basePath ) ;
const metadata _path = path . join ( appendedBasePath , CONSTS . SUBSCRIPTION _BACKUP _PATH ) ;
const metadata _path = path . join ( appendedBasePath , CONSTS . SUBSCRIPTION _BACKUP _PATH ) ;
fs . ensureDirSync ( appendedBasePath ) ;
fs . writeJSONSync ( metadata _path , sub ) ;
fs . writeJSONSync ( metadata _path , sub ) ;
}
}