Reset store returns a promise

AUTHORS

@@ -67,3 +67,4 @@ Andrew E. Rhyne <rhyneandrew@gmail.com>
 Miroslav Simulcik <simulcik.miro@gmail.com>
 Stephen Potter <me@stevepotter.me>
 Michaël De Boey <info@michaeldeboey.be>
+Andreas Bergenwall <abergenw@gmail.com>

CHANGELOG.md

@@ -1,6 +1,7 @@
 # Change log
 
 ### vNEXT
+- Make ApolloClient.resetStore() and QueryManager.resetStore() return a promise instead of void [PR #1674](https://github.com/apollographql/apollo-client/pull/1674)
 
 ### 1.2.2
 - Fix: Remove race condition in queryListenerFromObserver [PR #1670](https://github.com/apollographql/apollo-client/pull/1670)

src/ApolloClient.ts

@@ -495,10 +495,8 @@ export default class ApolloClient implements DataProxy {
    * re-execute any queries then you should make sure to stop watching any
    * active queries.
    */
-  public resetStore() {
-    if (this.queryManager) {
-      this.queryManager.resetStore();
-    }
+  public resetStore(): Promise<ApolloQueryResult<any>[]>|null {
+    return this.queryManager ? this.queryManager.resetStore() : null;
   }
 
   public getInitialState(): { data: Object } {

src/core/QueryManager.ts

@@ -796,7 +796,7 @@ export class QueryManager {
     }
   }
 
-  public resetStore(): void {
+  public resetStore(): Promise<ApolloQueryResult<any>[]> {
     // Before we have sent the reset action to the store,
     // we can no longer rely on the results returned by in-flight
     // requests since these may depend on values that previously existed
@@ -819,15 +819,18 @@ export class QueryManager {
     // watched. If there is an existing query in flight when the store is reset,
     // the promise for it will be rejected and its results will not be written to the
     // store.
+    const observableQueryPromises: Promise<ApolloQueryResult<any>>[] = [];
     Object.keys(this.observableQueries).forEach((queryId) => {
       const storeQuery = this.reduxRootSelector(this.store.getState()).queries[queryId];
 
       const fetchPolicy = this.observableQueries[queryId].observableQuery.options.fetchPolicy;
 
       if (fetchPolicy !== 'cache-only' && fetchPolicy !== 'standby') {
-        this.observableQueries[queryId].observableQuery.refetch();
+        observableQueryPromises.push(this.observableQueries[queryId].observableQuery.refetch());
       }
     });
+
+    return Promise.all(observableQueryPromises);
   }
 
   public startQuery<T>(queryId: string, options: WatchQueryOptions, listener: QueryListener) {

test/QueryManager.ts

@@ -2343,6 +2343,11 @@ describe('QueryManager', () => {
   });
 
   describe('store resets', () => {
+    it('returns a promise', done => {
+      const queryManager = createQueryManager({});
+      queryManager.resetStore().then(() => done());
+    });
+
     it('should change the store state to an empty state', () => {
       const queryManager = createQueryManager({});