add collectionView dataSource

FisherMan/Models/LanguageModel.swift

@@ -12,7 +12,7 @@ import RealmSwift
 final class LanguageModel: Object {
 
     @objc dynamic public var id = 0
-    @objc dynamic public var locale = "en"
+    @objc dynamic public var  locale = "en"
 
     override static func primaryKey() -> String? {
         return "id"

FisherMan/Models/NewsModel.swift

@@ -8,6 +8,7 @@
 
 import UIKit
 import RealmSwift
+import RxDataSources
 
 final class NewsModel: Object, BaseNewsModelType {
 
@@ -28,3 +29,27 @@ final class NewsModel: Object, BaseNewsModelType {
         return "id"
     }
 }
+
+extension NewsModel: IdentifiableType {
+    typealias Identity = String
+    var identity: Identity { return id }
+}
+
+func == (lhs: NewsModel, rhs: NewsModel) -> Bool {
+    return lhs.id == rhs.id
+}
+
+struct SectionOfArticles {
+    var items: [NewsModel]
+}
+
+extension SectionOfArticles: AnimatableSectionModelType {
+    typealias Item = NewsModel
+
+    var identity: String { return "SectionOfArticles" }
+
+    init(original: SectionOfArticles, items: [NewsModel]) {
+        self = original
+        self.items = items
+    }
+}

FisherMan/VeiwModels/NewsSceneViewModel.swift

@@ -24,8 +24,11 @@ final class NewsSceneViewModel: BaseViewModel<NewsModel> {
 
     override func performAction() {
         dependencies.newsService.getAllNews()
-        elements = dependencies.newsService.observeEntries()?
-            .map({ $0.0 }).asDriver(onErrorJustReturn: [NewsModel()])
+        elements = dependencies.newsService.observeEntries()?.do(onNext: {
+            print (">>deleted - \($0.1?.deleted)<<")
+            print (">>inserted - \($0.1?.inserted)<<")
+            print (">>updated - \($0.1?.updated)<<")
+        }).map({ $0.0 }).asDriver(onErrorJustReturn: [NewsModel()])
         newsListObserver =
             Observable.combineLatest(elements?.asObservable() ?? .empty(),
                                      LanguageManager.shared.notifyObservable,

FisherMan/Views/NewsSceneViewController.swift

@@ -10,6 +10,10 @@ import UIKit
 import RxSwift
 import RxCocoa
 import SDWebImage
+import RxDataSources
+
+typealias Section = AnimatableSectionModel<String, NewsModel>
+typealias DataSource = RxCollectionViewSectionedAnimatedDataSource<SectionOfArticles>
 
 class NewsSceneViewController: BaseViewController<NewsSceneViewModel> {
 
@@ -40,6 +44,20 @@ class NewsSceneViewController: BaseViewController<NewsSceneViewModel> {
         return collectionView
     }()
 
+    private lazy var dataSource: DataSource = {
+        let animationConfiguration = AnimationConfiguration(insertAnimation: .automatic,
+                                                            reloadAnimation: .automatic,
+                                                            deleteAnimation: .automatic)
+        return DataSource(animationConfiguration: animationConfiguration,
+                          configureCell: { _, collectionView, indexPath, data in
+                            let cell = collectionView
+                                .dequeueReusableCell(withReuseIdentifier: Constants.newsCollectionViewCell,
+                                                     for: indexPath) as? NewsCollectionViewCell
+                            cell?.setupEntry(data)
+                            return cell ?? UICollectionViewCell()
+        })
+    }()
+
     override func setupUI() {
         view.backgroundColor = .white
     }
@@ -48,11 +66,10 @@ class NewsSceneViewController: BaseViewController<NewsSceneViewModel> {
         viewModel?.indicatorViewAnimating.drive(spinner.rx.isAnimating).disposed(by: disposeBag)
         viewModel?.loadError.map({ _ in false }).drive(errorImageView.rx.isHidden).disposed(by: disposeBag)
         viewModel?.reachBottomObserver = newsCollectionView.rx.reachedBottom().asObservable()
-        viewModel?.newsListObserver?.bind(to: self.newsCollectionView.rx
-            .items(cellIdentifier: Constants.newsCollectionViewCell,
-                   cellType: NewsCollectionViewCell.self)) { _, data, cell in
-                    cell.setupEntry(data)
-        }.disposed(by: self.disposeBag)
+        viewModel?.newsListObserver?
+            .map({ [SectionOfArticles(items: $0)] })
+            .bind(to: newsCollectionView.rx.items(dataSource: dataSource))
+            .disposed(by: disposeBag)
     }
 }
 

Podfile

@@ -5,10 +5,11 @@ target 'FisherMan' do
 
   pod 'RxAlamofire'
   pod 'RxGesture'
+  pod 'RxRealm'
+  pod 'RxDataSources'
   pod 'Action'
   pod 'SwiftLint'
   pod 'lottie-ios'
-  pod 'RxRealm'
   pod 'SwiftyJSON'
   pod 'SDWebImage'