Add watch project (#1522)

kickstarter · Jan 24, 2022 · f0569f5 · f0569f5
1 parent c162e71
commit f0569f5
Show file tree

Hide file tree

Showing 7 changed files with 51 additions and 2 deletions.
diff --git a/app/src/main/graphql/project.graphql b/app/src/main/graphql/project.graphql
@@ -85,6 +85,15 @@ mutation CreateComment($body: String!, $commentableId: ID!, $parentId: ID, $clie
   }
 }
 
+mutation watchProject($id: ID!) {
+  watchProject(input: {id: $id}) {
+    clientMutationId
+    project {
+      ...fullProject
+    }
+  }
+}
+
 query GetProjectComments($slug: String!, $limit: Int!, $cursor: String) {
   project(slug: $slug) {
     id

diff --git a/app/src/main/java/com/kickstarter/mock/services/MockApolloClient.kt b/app/src/main/java/com/kickstarter/mock/services/MockApolloClient.kt
@@ -76,6 +76,10 @@ open class MockApolloClient : ApolloClientType {
         return Observable.just(listOf(reward, reward))
     }
 
+    override fun watchProject(project: Project): Observable<Project> {
+        return Observable.just(project.toBuilder().isStarred(true).build())
+    }
+
     override fun cancelBacking(backing: Backing, note: String): Observable<Any> {
         return Observable.just(true)
     }

diff --git a/app/src/main/java/com/kickstarter/services/ApolloClientType.kt b/app/src/main/java/com/kickstarter/services/ApolloClientType.kt
@@ -68,6 +68,8 @@ interface ApolloClientType {
 
     fun getProjectAddOns(slug: String, locationId: Location): Observable<List<Reward>>
 
+    fun watchProject(project: Project): Observable<Project>
+
     fun getStoredCards(): Observable<List<StoredCard>>
 
     fun savePaymentMethod(savePaymentMethodData: SavePaymentMethodData): Observable<StoredCard>

diff --git a/app/src/main/java/com/kickstarter/services/KSApolloClient.kt b/app/src/main/java/com/kickstarter/services/KSApolloClient.kt
@@ -18,6 +18,7 @@ import UpdateUserEmailMutation
 import UpdateUserPasswordMutation
 import UserPaymentsQuery
 import UserPrivacyQuery
+import WatchProjectMutation
 import com.apollographql.apollo.ApolloCall
 import com.apollographql.apollo.ApolloClient
 import com.apollographql.apollo.api.Response
@@ -670,6 +671,35 @@ class KSApolloClient(val service: ApolloClient) : ApolloClientType {
         }
     }
 
+    override fun watchProject(project: Project): Observable<Project> {
+        return Observable.defer {
+            val ps = PublishSubject.create<Project>()
+            this.service.mutate(
+                WatchProjectMutation.builder().id(encodeRelayId(project)).build()
+            )
+                .enqueue(object : ApolloCall.Callback<WatchProjectMutation.Data>() {
+                    override fun onFailure(exception: ApolloException) {
+                        ps.onError(exception)
+                    }
+
+                    override fun onResponse(response: Response<WatchProjectMutation.Data>) {
+                        if (response.hasErrors()) {
+                            ps.onError(java.lang.Exception(response.errors?.first()?.message))
+                        }
+                        /* make a copy of what you posted. just in case
+                         * we want to update the list without doing
+                         * a full refresh.
+                         */
+                        ps.onNext(
+                            projectTransformer(response.data?.watchProject()?.project()?.fragments()?.fullProject())
+                        )
+                        ps.onCompleted()
+                    }
+                })
+            return@defer ps
+        }
+    }
+
     private fun getAddOnsFromProject(addOnsGr: GetProjectAddOnsQuery.AddOns): List<Reward> {
         return addOnsGr.nodes()?.map { node ->
             val shippingRulesGr = node.shippingRulesExpanded()?.nodes()?.map { it.fragments().shippingRule() } ?: emptyList()

diff --git a/app/src/main/java/com/kickstarter/viewmodels/ProjectViewModel.kt b/app/src/main/java/com/kickstarter/viewmodels/ProjectViewModel.kt
@@ -1210,7 +1210,7 @@ interface ProjectViewModel {
         }
 
         private fun saveProject(project: Project): Observable<Project> {
-            return this.client.saveProject(project)
+            return this.apolloClient.watchProject(project)
                 .compose(neverError())
         }
 

diff --git a/app/src/main/java/com/kickstarter/viewmodels/projectpage/ProjectPageViewModel.kt b/app/src/main/java/com/kickstarter/viewmodels/projectpage/ProjectPageViewModel.kt
@@ -1145,7 +1145,7 @@ interface ProjectPageViewModel {
         }
 
         private fun saveProject(project: Project): Observable<Project> {
-            return this.client.saveProject(project)
+            return this.apolloClient.watchProject(project)
                 .compose(neverError())
         }
 

diff --git a/app/src/test/java/com/kickstarter/viewmodels/ProjectPageViewModelTest.kt b/app/src/test/java/com/kickstarter/viewmodels/ProjectPageViewModelTest.kt
@@ -524,6 +524,10 @@ class ProjectPageViewModelTest : KSRobolectricTestCase() {
         this.savedTest.assertValues(false, true)
         this.heartDrawableId.assertValues(R.drawable.icon__heart_outline, R.drawable.icon__heart)
         this.showSavedPromptTest.assertValueCount(0)
+        this.projectData.assertValues(
+            ProjectDataFactory.project(project),
+            ProjectDataFactory.project(project.toBuilder().isStarred(true).build())
+        )
     }
 
     @Test