diff --git a/lib.js b/lib.js index 948d197..e03385e 100644 --- a/lib.js +++ b/lib.js @@ -468,7 +468,7 @@ export const populateSource = (source, postReducerCallback, lock) => { let sourceLock = lock.sources[source.name] ??= {} source.posts = [] - source = processRss(source, sourceLock.timestamp ?? 0, postReducerCallback) + source = processRss(source, sourceLock.timestamp ?? 0, postReducerCallback, lock) if(sourceLock.items) { for(let itemText of sourceLock.items) { @@ -479,6 +479,7 @@ export const populateSource = (source, postReducerCallback, lock) => { } lock.sources[source.name] = sourceLock + lockSource(source, lock) return source }