updated

Author: hoc081098

lib/data/remote/search_remote_source_impl.dart

@@ -1,9 +1,9 @@
 import 'dart:io';
 
 import 'package:flutter_github_search_rx_redux/data/remote/search_result.dart';
+import 'package:http/http.dart' as http;
 
 import 'search_remote_source.dart';
-import 'package:http/http.dart' as http;
 
 class SearchRemoteSourceImpl implements SearchRemoteSource {
   final http.Client _client;
@@ -18,6 +18,7 @@ class SearchRemoteSourceImpl implements SearchRemoteSource {
       'search/repositories',
       {'q': term, 'page': page.toString()},
     );
+    print('SearchRemoteSourceImpl: ${url.queryParameters}');
     final response = await _client.get(url);
 
     if (response.statusCode != HttpStatus.ok) {

lib/ui/home/home_action.dart

@@ -44,13 +44,26 @@ class RetryAction implements HomeAction {
 // Side effect actions
 //
 
+abstract class TextChangedAction
+    implements Built<TextChangedAction, TextChangedActionBuilder>, HomeAction {
+  String get term;
+
+  TextChangedAction._();
+
+  factory TextChangedAction([void Function(TextChangedActionBuilder) updates]) =
+      _$TextChangedAction;
+
+  @override
+  HomeState reduce(HomeState state) => state;
+}
+
 abstract class SearchLoadingAction
     implements
         Built<SearchLoadingAction, SearchLoadingActionBuilder>,
         HomeAction {
   String get term;
 
-  int get page;
+  int get nextPage;
 
   SearchLoadingAction._();
 
@@ -60,7 +73,7 @@ abstract class SearchLoadingAction
 
   @override
   HomeState reduce(HomeState state) {
-    if (page == 1) {
+    if (nextPage == 1) {
       return state.rebuild((b) => b
         ..term = term
         ..page = 0
@@ -97,8 +110,16 @@ abstract class SearchSuccessAction
         ..page = state.page + (items.isEmpty ? 0 : 1)
         ..term = term
         ..items = (b.items
-          ..update(
-              (ib) => state.isFirstPage ? ib.replace(items) : ib.addAll(items)))
+          ..update((ib) {
+            if (state.isFirstPage) {
+              ib.replace(items);
+            } else {
+              final urls = Set.of(state.items.map((item) => item.htmlUrl));
+              final distinctItems =
+                  items.where((item) => urls.add(item.htmlUrl));
+              ib.addAll(distinctItems);
+            }
+          }))
         ..error = null
         ..isLoading = false,
     );
@@ -124,7 +145,6 @@ abstract class SearchFailureAction
   HomeState reduce(HomeState state) {
     return state.rebuild(
       (b) => b
-        ..items = ListBuilder<RepoItem>()
         ..term = term
         ..error = error
         ..isLoading = false,

lib/ui/home/home_action.g.dart

@@ -33,9 +33,13 @@ class _MyHomePageState extends State<MyHomePage> with DisposeBagMixin {
   }
 
   void subscribe(RxReduxStore<HomeAction, HomeState> store) {
+    store.stateStream
+        .listen((state) => print('Page: ${state.page}'))
+        .disposedBy(bag);
+
     store.actionStream.listen((action) {
       if (action is SearchFailureAction) {
-        key.snackBar('Error: ${action.error}');
+        key.snackBar('Error occurred');
       }
     }).disposedBy(bag);
   }
@@ -104,7 +108,8 @@ class _MyHomePageState extends State<MyHomePage> with DisposeBagMixin {
                             width: 128,
                             height: 48,
                             child: RaisedButton(
-                              onPressed: () => store.dispatch(RetryAction()),
+                              onPressed: () =>
+                                  store.dispatch(const RetryAction()),
                               child: Text('Retry'),
                               elevation: 12,
                               shape: RoundedRectangleBorder(
@@ -162,9 +167,29 @@ class RepoItemsListWidget extends StatelessWidget {
         }
 
         if (state.error != null) {
-          return ListTile(
-            title: Text(
-                "Search for '${state.term}', page: ${state.page + 1} error: ${state.error}"),
+          return Padding(
+            padding: const EdgeInsets.all(8.0),
+            child: Column(
+              children: [
+                Text(
+                  "Search for '${state.term}', page: ${state.page + 1} error: ${state.error}",
+                  style: Theme.of(context).textTheme.subtitle2,
+                  textAlign: TextAlign.center,
+                ),
+                const SizedBox(height: 16),
+                SizedBox(
+                  width: 128,
+                  height: 48,
+                  child: RaisedButton(
+                    onPressed: () => dispatch(const RetryAction()),
+                    child: Text('Retry'),
+                    elevation: 12,
+                    shape: RoundedRectangleBorder(
+                        borderRadius: BorderRadius.circular(24)),
+                  ),
+                ),
+              ],
+            ),
           );
         }
 
@@ -184,10 +209,16 @@ class RepoItemsListWidget extends StatelessWidget {
         return Padding(
           padding: const EdgeInsets.only(bottom: 12),
           child: Center(
-            child: RaisedButton(
-              onPressed: () => dispatch(const LoadNextPageAction()),
-              padding: const EdgeInsets.all(12),
-              child: Text('Load next page'),
+            child: SizedBox(
+              width: 128,
+              height: 48,
+              child: RaisedButton(
+                onPressed: () => dispatch(const LoadNextPageAction()),
+                child: Text('Load next page'),
+                elevation: 12,
+                shape: RoundedRectangleBorder(
+                    borderRadius: BorderRadius.circular(24)),
+              ),
             ),
           ),
         );

lib/ui/home/home_page.dart

@@ -28,4 +28,13 @@ abstract class HomeState implements Built<HomeState, HomeStateBuilder> {
       );
 
   bool get isFirstPage => page == 0;
+
+  bool get canLoadNextPage =>
+      !isLoading &&
+      error == null &&
+      items.isNotEmpty &&
+      term.isNotEmpty &&
+      page > 0;
+
+  bool get canRetry => !isLoading && error != null;
 }