WIP

Podfile

@@ -73,6 +73,7 @@ target 'Signal' do
 
   # Loki
   pod 'GCDWebServer', '~> 3.0'
+  pod 'FeedKit', '~> 8.1'
 
   target 'SignalTests' do
     inherit! :search_paths

Pods

@@ -1 +1 @@
-Subproject commit 98077061d67643bda2dc906dd37d571eccbcd164
+Subproject commit 95f519e4b407713a98f98d0aec572b7487c941b3

Signal/src/AppDelegate.m

@@ -1509,7 +1509,7 @@ static NSTimeInterval launchStartedAt;
     for (LKGroupChat *chat in allGroupChats) {
         NSString *userDefaultsKey = [@"isSetUp." stringByAppendingString:chat.id];
         BOOL isChatSetUp = [NSUserDefaults.standardUserDefaults boolForKey:userDefaultsKey];
-        if (chat.isDeletable && isChatSetUp) { continue; }
+        if (!isChatSetUp || !chat.isDeletable) {
             TSGroupModel *group = [[TSGroupModel alloc] initWithTitle:chat.displayName memberIds:@[ userHexEncodedPublicKey, chat.server ] image:nil groupId:[chat.id dataUsingEncoding:NSUTF8StringEncoding]];
             __block TSGroupThread *thread;
             [OWSPrimaryStorage.dbReadWriteConnection readWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) {
@@ -1526,6 +1526,7 @@ static NSTimeInterval launchStartedAt;
             [NSUserDefaults.standardUserDefaults setBool:YES forKey:userDefaultsKey];
         }
     }
+}
 
 - (void)createGroupChatPollersIfNeeded
 {
@@ -1538,6 +1539,8 @@ static NSTimeInterval launchStartedAt;
 {
     [self createGroupChatPollersIfNeeded];
     [self.lokiPublicChatPoller startIfNeeded];
+    [self.lokiNewsPoller startIfNeeded];
+    [self.lokiMessengerUpdatesPoller startIfNeeded];
 }
 
 @end

Signal/src/Loki/LokiGroupChatPoller.swift

@@ -9,7 +9,7 @@ public final class LokiGroupChatPoller : NSObject {
     private lazy var pollForNewMessagesInterval: TimeInterval = {
         switch group.kind {
         case .publicChat(_): return 4
-        case .rss(_): return 8 * 60
+        case .rss(_): return 4//8 * 60
         }
     }()
     
@@ -29,6 +29,7 @@ public final class LokiGroupChatPoller : NSObject {
     @objc public func startIfNeeded() {
         if hasStarted { return }
         pollForNewMessagesTimer = Timer.scheduledTimer(withTimeInterval: pollForNewMessagesInterval, repeats: true) { [weak self] _ in self?.pollForNewMessages() }
+        pollForNewMessages() // Perform initial update
         if group.isPublicChat {
             pollForDeletedMessagesTimer = Timer.scheduledTimer(withTimeInterval: pollForDeletedMessagesInterval, repeats: true) { [weak self] _ in self?.pollForDeletedMessages() }
         }
@@ -69,7 +70,14 @@ public final class LokiGroupChatPoller : NSObject {
                     }
                 }
             }
-        case .rss(let customID): break // TODO: Implement
+        case .rss(_):
+            let url = URL(string: group.server)!
+            let parser = LokiRSSFeedParser(url: url)
+            parser.parse { items in
+                items.reversed().forEach { item in
+                    print("Loki", "\(item.title ?? "nil"), \(item.description ?? "nil"), \(item.dateAsString ?? "nil")")
+                }
+            }
         }
     }