setup boards: fix boards not shown immediately when adding site

Clover/app/src/main/java/org/floens/chan/core/database/DatabaseBoardManager.java

@@ -89,7 +89,7 @@ public class DatabaseBoardManager {
         };
     }
 
-    public Callable<Void> createAll(final Site site, final List<Board> boards) {
+    public Callable<Boolean> createAll(final Site site, final List<Board> boards) {
         return () -> {
             long start = Time.startTiming();
 
@@ -146,7 +146,7 @@ public class DatabaseBoardManager {
             Time.endTiming("createAll boards " +
                     toCreate.size() + ", " + toUpdate.size(), start);
 
-            return null;
+            return !toCreate.isEmpty() || !toUpdate.isEmpty();
         };
     }
 

Clover/app/src/main/java/org/floens/chan/core/presenter/BoardSetupPresenter.java

@@ -20,6 +20,7 @@ package org.floens.chan.core.presenter;
 
 import org.floens.chan.core.manager.BoardManager;
 import org.floens.chan.core.model.orm.Board;
+import org.floens.chan.core.repository.BoardRepository;
 import org.floens.chan.core.site.Site;
 import org.floens.chan.ui.helper.BoardHelper;
 import org.floens.chan.utils.BackgroundUtils;
@@ -29,12 +30,14 @@ import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
+import java.util.Observable;
+import java.util.Observer;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
 
 import javax.inject.Inject;
 
-public class BoardSetupPresenter {
+public class BoardSetupPresenter implements Observer {
     private BoardManager boardManager;
 
     private Callback callback;
@@ -44,12 +47,16 @@ public class BoardSetupPresenter {
 
     private List<Board> savedBoards;
 
+    private BoardRepository.SitesBoards allBoardsObservable;
+
     private Executor executor = Executors.newSingleThreadExecutor();
     private BackgroundUtils.Cancelable suggestionCall;
 
     private List<BoardSuggestion> suggestions = new ArrayList<>();
     private List<String> selectedSuggestions = new LinkedList<>();
 
+    private String suggestionsQuery = null;
+
     @Inject
     public BoardSetupPresenter(BoardManager boardManager) {
         this.boardManager = boardManager;
@@ -61,10 +68,25 @@ public class BoardSetupPresenter {
 
         savedBoards = boardManager.getSiteSavedBoards(site);
         callback.setSavedBoards(savedBoards);
+
+        allBoardsObservable = boardManager.getAllBoardsObservable();
+        allBoardsObservable.addObserver(this);
     }
 
     public void destroy() {
         boardManager.updateBoardOrders(savedBoards);
+
+        allBoardsObservable.deleteObserver(this);
+    }
+
+    @Override
+    public void update(Observable o, Object arg) {
+        if (o == allBoardsObservable) {
+            if (addCallback != null) {
+                // Update the boards shown in the query.
+                queryBoardsWithQueryAndShowInAddDialog();
+            }
+        }
     }
 
     public void addClicked() {
@@ -74,13 +96,14 @@ public class BoardSetupPresenter {
     public void bindAddDialog(AddCallback addCallback) {
         this.addCallback = addCallback;
 
-        searchEntered(null);
+        queryBoardsWithQueryAndShowInAddDialog();
     }
 
     public void unbindAddDialog() {
         this.addCallback = null;
         suggestions.clear();
         selectedSuggestions.clear();
+        suggestionsQuery = null;
     }
 
     public void onSelectAllClicked() {
@@ -88,7 +111,7 @@ public class BoardSetupPresenter {
             suggestion.checked = true;
             selectedSuggestions.add(suggestion.getCode());
         }
-        addCallback.updateSuggestions();
+        addCallback.suggestionsWereChanged();
     }
 
     public void onSuggestionClicked(BoardSuggestion suggestion) {
@@ -165,12 +188,17 @@ public class BoardSetupPresenter {
     }
 
     public void searchEntered(String userQuery) {
+        suggestionsQuery = userQuery;
+        queryBoardsWithQueryAndShowInAddDialog();
+    }
+
+    private void queryBoardsWithQueryAndShowInAddDialog() {
         if (suggestionCall != null) {
             suggestionCall.cancel();
         }
 
-        final String query = userQuery == null ? null :
+        final String query = suggestionsQuery == null ? null :
-                userQuery.replace("/", "").replace("\\", "");
+                suggestionsQuery.replace("/", "").replace("\\", "");
         suggestionCall = BackgroundUtils.runWithExecutor(executor, () -> {
             List<BoardSuggestion> suggestions = new ArrayList<>();
             if (site.boardsType().canList) {
@@ -210,7 +238,7 @@ public class BoardSetupPresenter {
             updateSuggestions(result);
 
             if (addCallback != null) {
-                addCallback.updateSuggestions();
+                addCallback.suggestionsWereChanged();
             }
         });
     }
@@ -240,7 +268,7 @@ public class BoardSetupPresenter {
     }
 
     public interface AddCallback {
-        void updateSuggestions();
+        void suggestionsWereChanged();
     }
 
     public static class BoardSuggestion {

Clover/app/src/main/java/org/floens/chan/core/repository/BoardRepository.java

@@ -23,6 +23,7 @@ import org.floens.chan.core.database.DatabaseBoardManager;
 import org.floens.chan.core.database.DatabaseManager;
 import org.floens.chan.core.model.orm.Board;
 import org.floens.chan.core.site.Site;
+import org.floens.chan.utils.Logger;
 import org.floens.chan.utils.Time;
 
 import java.util.ArrayList;
@@ -35,6 +36,8 @@ import javax.inject.Singleton;
 
 @Singleton
 public class BoardRepository implements Observer {
+    private static final String TAG = "BoardRepository";
+
     private final DatabaseManager databaseManager;
     private final DatabaseBoardManager databaseBoardManager;
 
@@ -68,7 +71,11 @@ public class BoardRepository implements Observer {
     }
 
     public void updateAvailableBoardsForSite(Site site, List<Board> availableBoards) {
-        databaseManager.runTask(databaseBoardManager.createAll(site, availableBoards));
+        boolean changed = databaseManager.runTask(databaseBoardManager.createAll(site, availableBoards));
+        Logger.d(TAG, "updateAvailableBoardsForSite changed = " + changed);
+        if (changed) {
+            updateObservablesAsync();
+        }
     }
 
     public Board getFromCode(Site site, String code) {

Clover/app/src/main/java/org/floens/chan/ui/layout/BoardAddLayout.java

@@ -110,7 +110,7 @@ public class BoardAddLayout extends LinearLayout implements SearchLayout.SearchL
     }
 
     @Override
-    public void updateSuggestions() {
+    public void suggestionsWereChanged() {
         suggestionsAdapter.notifyDataSetChanged();
     }