prove isRead flag for article

.idea/gradle.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="GradleMigrationSettings" migrationVersion="1" />
   <component name="GradleSettings">
     <option name="linkedExternalProjectsSettings">
       <GradleProjectSettings>
+        <option name="delegatedBuild" value="false" />
         <option name="testRunner" value="PLATFORM" />
         <option name="distributionType" value="DEFAULT_WRAPPED" />
         <option name="externalProjectPath" value="$PROJECT_DIR$" />

app/src/main/java/com/biganto/visual/roompark/data/data_provider/FeedsRepository.kt

@@ -10,6 +10,7 @@ import com.biganto.visual.roompark.domain.model.ArticleModel
 import com.biganto.visual.roompark.domain.model.ArticlesPreviewModel
 import com.biganto.visual.roompark.domain.model.FeedModel
 import com.biganto.visual.roompark.domain.model.fromEntity
+import io.reactivex.Completable
 import io.reactivex.Observable
 import io.reactivex.schedulers.Schedulers
 import timber.log.Timber
@@ -33,6 +34,7 @@ class FeedsContractModule @Inject constructor(
     override fun fetchFeedObservable(feedAlias: String): Observable<ArticlesPreviewModel> =
         fetchArticles(feedAlias)
 
+
     override fun fetchFeedObservable(feedAlias: String,pageSize:Int,  startIndex:Int)
             : Observable<ArticlesPreviewModel> = fetchArticles(feedAlias,pageSize,startIndex)
 
@@ -123,5 +125,9 @@ class FeedsContractModule @Inject constructor(
             arrayListOf(fetchArticleDb(articleId),fetchArticleApi(articleId))
         ).map { fromEntity(it,true) }
 
+    override fun articleRead(articleId: Int): Completable =
+        db.setArticleReadState(articleId,true)
+
+
 }
 

app/src/main/java/com/biganto/visual/roompark/data/repository/db/IDb.kt

 package com.biganto.visual.roompark.data.repository.db
 
 import com.biganto.visual.roompark.data.repository.db.requrey.model.*
+import io.reactivex.Completable
 import io.reactivex.Observable
 import io.reactivex.Single
 import io.requery.Persistable
@@ -31,4 +32,5 @@ interface IDb {
     fun getEstate(estateId: Int): Observable<EstateEntity>
     fun upsertEstate(entity: EstateEntity)
     fun fetchEstateByNumber(building: Int, number: String): ReactiveResult<EstateEntity>
+    fun setArticleReadState(id: Int, state: Boolean): Completable
 }
\ No newline at end of file

app/src/main/java/com/biganto/visual/roompark/data/repository/db/requrey/RequeryRepository.kt

@@ -157,4 +157,12 @@ class RequeryRepository @Inject constructor(
                         .where(EstateEntity.USER_ID.eq(uuid))
                         .and(EstateEntity.FAVORITE.eq(true))
                         .get().observable()
+
+        override fun setArticleReadState(id:Int,state:Boolean) =
+                store.update(ArticleEntity::class)
+                        .set(ArticleEntity.ANNOUNCE,"")
+                        .where(ArticleEntity.ID.eq(id))
+                        .get()
+                        .single()
+                        .ignoreElement()
 }

app/src/main/java/com/biganto/visual/roompark/data/repository/db/requrey/model/Article.kt

@@ -27,4 +27,7 @@ interface Article : Persistable {
     val feed : Feed?
     @get:Convert(TitledPhotoListConverter::class)
     var photo : List<TitledPhoto>?
+
+    val read : Boolean
+
 }
\ No newline at end of file

app/src/main/java/com/biganto/visual/roompark/data/repository/db/requrey/model/Deal.kt

@@ -25,4 +25,6 @@ interface Deal : Persistable {
     @get:ForeignKey(references = User::class )
     @get:ManyToOne(cascade = [CascadeAction.NONE])
     var user:User?
+    
+    val read : Boolean
 }
\ No newline at end of file

app/src/main/java/com/biganto/visual/roompark/domain/contract/FeedsContract.kt

@@ -3,6 +3,7 @@ package com.biganto.visual.roompark.domain.contract
 import com.biganto.visual.roompark.domain.model.ArticleModel
 import com.biganto.visual.roompark.domain.model.ArticlesPreviewModel
 import com.biganto.visual.roompark.domain.model.FeedModel
+import io.reactivex.Completable
 import io.reactivex.Observable
 
 /**
@@ -20,4 +21,5 @@ interface FeedsContract{
     ): Observable<ArticlesPreviewModel>
 
     fun fetchFeedObservable(feedAlias: String): Observable<ArticlesPreviewModel>
+    fun articleRead(articleId:Int):Completable
 }
\ No newline at end of file

app/src/main/java/com/biganto/visual/roompark/domain/use_case/feedUseCase.kt

@@ -21,4 +21,6 @@ class FeedUseCase @Inject constructor(
 
     fun getArticle(articleId:Int) =
         contract.getArticle(articleId)
+
+    fun setRead(articleId: Int) = contract.articleRead(articleId)
 }
\ No newline at end of file