diff --git a/core/src/main/groovy/com/muwire/core/filefeeds/FeedManager.groovy b/core/src/main/groovy/com/muwire/core/filefeeds/FeedManager.groovy index 52b3baaf..ebc47272 100644 --- a/core/src/main/groovy/com/muwire/core/filefeeds/FeedManager.groovy +++ b/core/src/main/groovy/com/muwire/core/filefeeds/FeedManager.groovy @@ -91,21 +91,19 @@ class FeedManager { private void loadItems() { def slurper = new JsonSlurper() - feeds.keySet().each { - File itemsFile = getItemsFile(feeds[it]) + feeds.keySet().each { persona -> + File itemsFile = getItemsFile(feeds[persona]) if (!itemsFile.exists()) return // no items yet? itemsFile.eachLine { line -> - def parsed = slurper.parse(line) - FeedItem item = FeedItems.objToFeedItem(parsed, it) - - Set items = feedItems.get(it) + def parsed = slurper.parseText(line) + FeedItem item = FeedItems.objToFeedItem(parsed, persona) + Set items = feedItems.get(persona) if (items == null) { items = new ConcurrentHashSet<>() - feedItems.put(it, items) + feedItems.put(persona, items) } items.add(item) - eventBus.publish(new FeedItemLoadedEvent(item : item)) } }