Implement connectivity stream

gogrocy/lib/core/enums/connectivity_status.dart

@@ -0,0 +1 @@
+enum ConnectivityStatus { WiFi, Cellular, Offline }

gogrocy/lib/core/services/connectivity_service.dart

@@ -0,0 +1,37 @@
+import 'dart:async';
+
+import 'package:connectivity/connectivity.dart';
+import 'package:gogrocy/core/enums/connectivity_status.dart';
+
+class ConnectivityService {
+  StreamController<ConnectivityStatus> _connectionStatusController;
+
+  ConnectivityService() {
+    _connectionStatusController = StreamController<ConnectivityStatus>();
+    _initNetworkStatusListener();
+  }
+
+  StreamController<ConnectivityStatus> get connectionStatusController =>
+      _connectionStatusController;
+
+  void _initNetworkStatusListener() {
+    Connectivity().onConnectivityChanged.listen((ConnectivityResult result) {
+      _connectionStatusController.add(_getStatusFromResult(result));
+    });
+  }
+
+  ConnectivityStatus _getStatusFromResult(ConnectivityResult result) {
+    switch (result) {
+      case ConnectivityResult.wifi:
+        return ConnectivityStatus.WiFi;
+      case ConnectivityResult.mobile:
+        return ConnectivityStatus.Cellular;
+      case ConnectivityResult.none:
+        return ConnectivityStatus.Offline;
+    }
+  }
+
+  void disposeStream(){
+    _connectionStatusController.close();
+  }
+}

gogrocy/lib/core/viewModels/base_model.dart

@@ -1,29 +1,50 @@
-import 'dart:io';
+import 'dart:async';
 
 import 'package:flutter/widgets.dart';
+import 'package:gogrocy/core/enums/connectivity_status.dart';
 import 'package:gogrocy/core/enums/viewstate.dart';
+import 'package:gogrocy/core/services/connectivity_service.dart';
 
 class BaseModel extends ChangeNotifier {
   ViewState _state = ViewState.Idle;
 
   ViewState get state => _state;
 
+  StreamController<ConnectivityStatus> _connectivityStatusController =
+      ConnectivityService().connectionStatusController;
+  Stream<ConnectivityStatus> connectivityStatus =
+      ConnectivityService().connectionStatusController.stream;
+  bool hasConnection = true;
+
+  BaseModel() {
+    connectivityStatus.listen((ConnectivityStatus status) {
+      switch (status) {
+        case ConnectivityStatus.WiFi:
+          this.hasConnection = true;
+          print(hasConnection);
+          notifyListeners();
+          break;
+        case ConnectivityStatus.Cellular:
+          this.hasConnection = true;
+          notifyListeners();
+          break;
+        case ConnectivityStatus.Offline:
+          this.hasConnection = false;
+          notifyListeners();
+          break;
+      }
+    });
+  }
+
   void setState(ViewState viewState) {
     _state = viewState;
     notifyListeners();
   }
 
-  Future<bool> checkInternetStatus() async {
-    try {
-      final result = await InternetAddress.lookup('google.com');
-      if (result.isNotEmpty && result[0].rawAddress.isNotEmpty) {
-        print('connected');
-        return true;
-      }
-    } on SocketException catch (_) {
-      print('not connected');
-      return false;
-    }
-    return false;
+  @override
+  void dispose() {
+    // TODO: implement dispose
+    _connectivityStatusController.close();
+    super.dispose();
   }
 }

gogrocy/lib/core/viewModels/login_model.dart

@@ -114,4 +114,8 @@ class LoginModel extends BaseModel {
     }
     return user;
   }
+
+  checkInternetStatus() {
+    return true;
+  }
 }

gogrocy/lib/main.dart

@@ -1,11 +1,13 @@
 import 'package:flutter/material.dart';
 import 'package:flutter/services.dart';
+import 'package:gogrocy/core/services/connectivity_service.dart';
 import 'package:gogrocy/core/services/navigation_service.dart';
 import 'package:gogrocy/core/services/shared_prefs.dart';
 import 'package:gogrocy/service_locator.dart';
 import 'package:gogrocy/ui/router.dart';
 import 'package:gogrocy/ui/views/startup_view.dart';
 import 'package:gogrocy/ui/widgets/navbar/bottom_navbar.dart';
+import 'package:provider/provider.dart';
 
 void main() {
   setupLocator();

gogrocy/lib/ui/views/base_view.dart

@@ -1,8 +1,14 @@
+import 'dart:async';
+
+import 'package:flushbar/flushbar.dart';
 import 'package:flutter/material.dart';
+import 'package:gogrocy/core/enums/connectivity_status.dart';
+import 'package:gogrocy/core/services/connectivity_service.dart';
 import 'package:gogrocy/core/viewModels/base_model.dart';
+import 'package:gogrocy/ui/widgets/snackbars/no_internet_snackbar.dart';
 import 'package:provider/provider.dart';
 
-import '../../service_locator.dart';
+import 'package:gogrocy/service_locator.dart';
 
 class BaseView<T extends BaseModel> extends StatefulWidget {
   final Widget Function(BuildContext context, T model, Widget child) builder;
@@ -19,18 +25,42 @@ class _BaseViewState<T extends BaseModel> extends State<BaseView<T>> {
 
   bool isDisposed = false;
 
+  StreamController<ConnectivityStatus> _connectivityStatusController =
+      ConnectivityService().connectionStatusController;
+
+  Flushbar _onlineFlush = onlineSnackBar();
+  Flushbar _offlineFlush = offlineSnackBar();
+
   @override
   void initState() {
     super.initState();
-    if(!isDisposed)
-    if (widget.onModelReady != null) {
+    _connectivityStatusController.stream.listen((ConnectivityStatus status) {
+      switch (status) {
+        case ConnectivityStatus.WiFi:
+          if (_offlineFlush.isShowing()) {
+            _offlineFlush.dismiss();
+            _onlineFlush.show(context);
+          }
+          break;
+        case ConnectivityStatus.Cellular:
+          if (_offlineFlush.isShowing()) {
+            _offlineFlush.dismiss();
+            _onlineFlush.show(context);
+          }
+          break;
+        case ConnectivityStatus.Offline:
+          _offlineFlush.show(context);
+          break;
+      }
+    });
+    if (!isDisposed) if (widget.onModelReady != null) {
       widget.onModelReady(model);
     }
   }
 
-
   @override
   void dispose() {
+    _connectivityStatusController.close();
     model.dispose();
     isDisposed = true;
     super.dispose();
@@ -39,7 +69,10 @@ class _BaseViewState<T extends BaseModel> extends State<BaseView<T>> {
   @override
   Widget build(BuildContext context) {
     return ChangeNotifierProvider<T>(
-        create: (context) => model,
-        child: Consumer<T>(builder: widget.builder));
+      create: (context) => model,
+      child: Consumer<T>(
+        builder: widget.builder,
+      ),
+    );
   }
 }