add DB layer to Data Layer
Project: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/commit/4d553b77 Tree: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/tree/4d553b77 Diff: http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/diff/4d553b77 Branch: refs/heads/master Commit: 4d553b77ffca08dc70d85fea0d2bd3ad604b823c Parents: 80108f1 Author: Sagar <[email protected]> Authored: Mon Jul 4 14:59:43 2016 +0530 Committer: Sagar <[email protected]> Committed: Mon Jul 4 14:59:43 2016 +0530 ---------------------------------------------------------------------- .../apache/taverna/mobile/data/DataManager.java | 20 ++++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-taverna-mobile/blob/4d553b77/app/src/main/java/org/apache/taverna/mobile/data/DataManager.java ---------------------------------------------------------------------- diff --git a/app/src/main/java/org/apache/taverna/mobile/data/DataManager.java b/app/src/main/java/org/apache/taverna/mobile/data/DataManager.java index e35cbb5..78c2e89 100644 --- a/app/src/main/java/org/apache/taverna/mobile/data/DataManager.java +++ b/app/src/main/java/org/apache/taverna/mobile/data/DataManager.java @@ -18,6 +18,7 @@ */ package org.apache.taverna.mobile.data; +import org.apache.taverna.mobile.data.local.DBHelper; import org.apache.taverna.mobile.data.model.Announcements; import org.apache.taverna.mobile.data.model.DetailAnnouncement; import org.apache.taverna.mobile.data.model.Workflow; @@ -29,12 +30,15 @@ import org.apache.taverna.mobile.data.remote.BaseApiManager; import java.util.Map; import rx.Observable; +import rx.functions.Func1; public class DataManager { public BaseApiManager mBaseApiManager = new BaseApiManager(); + public DBHelper mDBHelper = new DBHelper(); + public DataManager() { } @@ -56,7 +60,13 @@ public class DataManager { * @return List of all Workflow */ public Observable<Workflows> getAllWorkflow(Map<String, String> options) { - return mBaseApiManager.getTavernaApi().getAllWorkflows(options); + return mBaseApiManager.getTavernaApi().getAllWorkflows(options) + .concatMap(new Func1<Workflows, Observable<? extends Workflows>>() { + @Override + public Observable<? extends Workflows> call(Workflows workflows) { + return mDBHelper.syncWorkflows(workflows); + } + }); } /** @@ -64,7 +74,13 @@ public class DataManager { */ public Observable<Workflow> getDetailWorkflow(String id, Map<String, String> options) { - return mBaseApiManager.getTavernaApi().getDetailWorkflow(id, options); + return mBaseApiManager.getTavernaApi().getDetailWorkflow(id, options) + .concatMap(new Func1<Workflow, Observable<? extends Workflow>>() { + @Override + public Observable<? extends Workflow> call(Workflow workflow) { + return mDBHelper.syncWorkflow(workflow); + } + }); } /**
