Auto reconnects fastly to DDP server if you device reconnects to network

README.md

@@ -12,7 +12,7 @@
 
 # react-native-meteor
 
-Meteor-like methods for React Native. **Currently in v1.0.0-beta6** ! For old docs, see [v0.6.2 documentation](https://github.com/inProgress-team/react-native-meteor/tree/0.6.2) (classic ddp interface).
+Meteor-like methods for React Native. **Currently in v1.0.0-beta7** ! For old docs, see [v0.6.2 documentation](https://github.com/inProgress-team/react-native-meteor/tree/0.6.2) (classic ddp interface).
 
 ## What is it for ?
 

docs/Install.md

@@ -1,3 +1,13 @@
+# Android
+
+Add this to your AndroidManifest.xml file to autoreconnect fastly to DDP server if your device reconnects to network
+
+```xml
+<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
+```
+
+
+
 # Installing decorators
 
 ## With RN >= 0.20.0 (Babel 6)

example/mobile/android/app/src/main/AndroidManifest.xml

@@ -2,6 +2,7 @@
     package="com.mobile">
 
     <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
 
     <application
       android:allowBackup="true"

package.json

@@ -1,6 +1,6 @@
 {
   "name": "react-native-meteor",
-  "version": "1.0.0-beta6",
+  "version": "1.0.0-beta7",
   "description": "DDP React-native Client",
   "main": "src/Meteor.js",
   "scripts": {

src/Data.js

@@ -2,6 +2,8 @@ import minimongo from 'minimongo-cache';
 process.nextTick = setImmediate;
 
 export default {
+  endpoint: null,
+  options: null,
   ddp: null,
   subscriptions: {},
   db: new minimongo(),

src/Meteor.js

@@ -1,3 +1,5 @@
+import { NetInfo } from 'react-native';
+
 import reactMixin from 'react-mixin';
 import Trackr from 'trackr';
 import DDP from '../lib/ddp.js';
@@ -54,7 +56,17 @@ module.exports = {
       Data.ddp.disconnect();
     }
   },
+  _reconnect() {
+    if(Data._endpoint) {
+      this.connect(Data._endpoint, Data._options);
+    }
+  },
   connect(endpoint, options) {
+    Data._endpoint = endpoint;
+    Data._options = options;
+
+
+
     this.ddp = Data.ddp = new DDP({
       endpoint: endpoint,
       SocketConstructor: WebSocket,
@@ -64,6 +76,16 @@ module.exports = {
     Data.ddp.on("connected", ()=>{
       console.info("Connected to DDP server.");
       this._loadInitialUser();
+
+
+      if(!this._netInfoListener) {
+        this._netInfoListener = isConnected=>{
+          if(isConnected) {
+            this._reconnect();
+          }
+        };
+        NetInfo.isConnected.addEventListener('change', this._netInfoListener);
+      }
     });
 
     Data.ddp.on("disconnected", ()=>{
@@ -103,6 +125,7 @@ module.exports = {
         }
       }
     });
+
   },
   subscribe(name) {
     var params = Array.prototype.slice.call(arguments, 1);