aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Android_Studio/Tango.Synchronization/src
diff options
context:
space:
mode:
authorRoy <roy.mail.net@gmail.com>2017-12-24 02:26:55 +0200
committerRoy <roy.mail.net@gmail.com>2017-12-24 02:26:55 +0200
commitceac40d058a8554638aa3fa39d4697f3fbfe62f8 (patch)
treef865540d3c3c56ccbcc9ef0d57999e8c9456f8f3 /Software/Android_Studio/Tango.Synchronization/src
parent6091da506db1083f6ca707c24e509ca3470f6a73 (diff)
downloadTango-ceac40d058a8554638aa3fa39d4697f3fbfe62f8.tar.gz
Tango-ceac40d058a8554638aa3fa39d4697f3fbfe62f8.zip
Implemented android external bridge service.
Implemented external bridge authentication. Implemented machine connection view in machine studio. Modified Transport layer on android to Tango result.
Diffstat (limited to 'Software/Android_Studio/Tango.Synchronization/src')
-rw-r--r--Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/ITangoSynchronizer.java17
-rw-r--r--Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/TangoSynchronizer.java71
2 files changed, 0 insertions, 88 deletions
diff --git a/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/ITangoSynchronizer.java b/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/ITangoSynchronizer.java
deleted file mode 100644
index ef17439fd..000000000
--- a/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/ITangoSynchronizer.java
+++ /dev/null
@@ -1,17 +0,0 @@
-package com.twine.tango.synchronization;
-
-import io.reactivex.Completable;
-
-
-/**
- * Represents the Tango application local to remote synchronization engine.
- */
-public interface ITangoSynchronizer
-{
- /**
- * Synchronizes the local database with the remote database through the remote machine service.
- *
- * @return the completable.
- */
- Completable synchronizeDB();
-}
diff --git a/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/TangoSynchronizer.java b/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/TangoSynchronizer.java
deleted file mode 100644
index e0cb01ef1..000000000
--- a/Software/Android_Studio/Tango.Synchronization/src/main/java/com/twine/tango/synchronization/TangoSynchronizer.java
+++ /dev/null
@@ -1,71 +0,0 @@
-package com.twine.tango.synchronization;
-
-import com.elvishew.xlog.XLog;
-import com.google.protobuf.ByteString;
-import com.snatik.storage.Storage;
-import com.twine.tango.core.ContextHelper;
-import com.twine.tango.dal.TangoDB;
-import com.twine.tango.integration.IMachineIdentityProvider;
-import com.twine.tango.pmr.synchronization.SynchronizeDBRequestOuterClass.SynchronizeDBRequest;
-import com.twine.tango.web.WebApiFactory;
-import com.twine.tango.web.ISynchronizationAPI;
-
-import io.reactivex.Completable;
-
-
-/**
- * Represents the Tango application local to remote synchronization engine.
- */
-public class TangoSynchronizer implements ITangoSynchronizer
-{
- private IMachineIdentityProvider machineIdentityProvider;
-
-
- /**
- * Instantiates a new Tango synchronizer.
- *
- * @param machineIdentityProvider the machine identity provider
- */
- public TangoSynchronizer(IMachineIdentityProvider machineIdentityProvider)
- {
- this.machineIdentityProvider = machineIdentityProvider;
- }
-
- @Override
- public Completable synchronizeDB()
- {
- return Completable.create((emitter) ->
- {
-
- //Backup DataBase.
- TangoDB.backup();
-
- Storage storage = new Storage(ContextHelper.getApplicationContext());
-
- //Read current DB file bytes.
- byte[] data = storage.readFile(TangoDB.getDataBasePath());
-
- //Create synchronization web api.
- ISynchronizationAPI synchAPI = WebApiFactory.getSynchronizationAPI();
-
- //Create synchronization response.
- SynchronizeDBRequest request = SynchronizeDBRequest.newBuilder()
- .setSerialNumber(machineIdentityProvider.getSerialNumber())
- .setLocalDB(ByteString.copyFrom(data))
- .build();
-
- synchAPI.synchronize(request).singleOrError().subscribe((response) ->
- {
-
- TangoDB.replace(response.getRemoteDB().toByteArray());
- emitter.onComplete();
-
- },(ex) ->
- {
- XLog.e(ex);
- emitter.onError(ex);
- });
-
- });
- }
-}