Created Session Management.

lib/locator.dart

@@ -12,6 +12,7 @@ import 'package:talawa/services/image_service.dart';
 import 'package:talawa/services/navigation_service.dart';
 import 'package:talawa/services/org_service.dart';
 import 'package:talawa/services/post_service.dart';
+import 'package:talawa/services/session_manager.dart';
 import 'package:talawa/services/size_config.dart';
 import 'package:talawa/services/task_service.dart';
 import 'package:talawa/services/third_party_service/multi_media_pick_service.dart';
@@ -75,6 +76,9 @@ final organizationService = locator<OrganizationService>();
 ///creating GetIt for ImageService.
 final imageService = locator<ImageService>();
 
+///creating GetIt for SessionManager.
+final sessionManager = locator<SessionManager>();
+
 /// This function registers the widgets/objects in "GetIt".
 ///
 /// **params**:
@@ -94,6 +98,9 @@ void setupLocator() {
   //userConfig
   locator.registerSingleton(UserConfig());
 
+  //sessionManager
+  locator.registerSingleton(SessionManager());
+
   //Services
   locator.registerLazySingleton(() => PostService());
   locator.registerLazySingleton(() => EventService());

lib/plugins/fetch_plugin_list.dart

@@ -27,6 +27,6 @@ class FetchPluginList {
       ),
     );
     box = Hive.box('pluginBox');
-    box.put('plugins', result.data!["getPlugins"]);
+    box.put('plugins', result.data?["getPlugins"]);
   }
 }

lib/services/database_mutation_functions.dart

@@ -39,6 +39,19 @@ class DataBaseMutationFunctions {
     _query = Queries();
   }
 
+  /// initializes [clientNonAuth] function.
+  ///
+  /// **params**:
+  ///   None
+  ///
+  /// **returns**:
+  ///   None
+  void initClientNonAuth() {
+    graphqlConfig.getOrgUrl();
+    clientNonAuth = graphqlConfig.clientToQuery();
+    _query = Queries();
+  }
+
   /// Graphql error for handling.
   GraphQLError userNotFound = const GraphQLError(message: 'User not found');
 

lib/services/event_service.dart

@@ -71,10 +71,6 @@ class EventService {
   /// **returns**:
   ///   None
   Future<void> getEvents() async {
-    // refresh user's access token
-    await _dbFunctions.refreshAccessToken(userConfig.currentUser.refreshToken!);
-    _dbFunctions.init();
-
     // get current organization id
     final String currentOrgID = _currentOrg.id!;
     // mutation to fetch the events
@@ -102,7 +98,6 @@ class EventService {
   /// **returns**:
   /// * `Future<dynamic>`: Information about event registrants.
   Future<dynamic> fetchRegistrantsByEvent(String eventId) async {
-    await _dbFunctions.refreshAccessToken(userConfig.currentUser.refreshToken!);
     final result = await _dbFunctions.gqlAuthQuery(
       EventQueries().registrantsByEvent(eventId),
     );
@@ -117,9 +112,6 @@ class EventService {
   /// **returns**:
   /// * `Future<dynamic>`: Information about the event registration.
   Future<dynamic> registerForAnEvent(String eventId) async {
-    final tokenResult = await _dbFunctions
-        .refreshAccessToken(userConfig.currentUser.refreshToken!);
-    debugPrint(tokenResult.toString());
     final Map<String, dynamic> variables = {'eventId': eventId};
     final result = await _dbFunctions.gqlAuthMutation(
       EventQueries().registerForEvent(),
@@ -139,9 +131,6 @@ class EventService {
     navigationService.pushDialog(
       const CustomProgressDialog(key: Key('DeleteEventProgress')),
     );
-    final tokenResult = await _dbFunctions
-        .refreshAccessToken(userConfig.currentUser.refreshToken!);
-    debugPrint(tokenResult.toString());
     final result = await _dbFunctions.gqlAuthMutation(
       EventQueries().deleteEvent(eventId),
     );
@@ -166,9 +155,6 @@ class EventService {
         key: Key('EditEventProgress'),
       ),
     );
-    final tokenResult = await _dbFunctions
-        .refreshAccessToken(userConfig.currentUser.refreshToken!);
-    debugPrint(tokenResult.toString());
     final result = await _dbFunctions.gqlAuthMutation(
       EventQueries().updateEvent(eventId: eventId),
       variables: variables,

lib/services/graphql_config.dart

@@ -1,6 +1,3 @@
-// ignore_for_file: talawa_api_doc
-// ignore_for_file: talawa_good_doc_comments
-
 import 'package:graphql_flutter/graphql_flutter.dart';
 import 'package:hive/hive.dart';
 import 'package:http/http.dart' as http;
@@ -39,8 +36,6 @@ class GraphqlConfig {
     orgURI = url ?? ' ';
     displayImgRoute = imgUrl ?? ' ';
     httpLink = HttpLink(orgURI!);
-    clientToQuery();
-    authClient();
   }
 
   GraphQLClient clientToQuery() {

lib/services/post_service.dart

@@ -73,8 +73,6 @@ class PostService {
   /// **returns**:
   /// * `Future<void>`: returns future void
   Future<void> getPosts() async {
-    await _dbFunctions.refreshAccessToken(userConfig.currentUser.refreshToken!);
-    _dbFunctions.init();
     // variables
     final String currentOrgID = _currentOrg.id!;
     final String query = PostQueries().getPostsById(currentOrgID);

lib/services/session_manager.dart

@@ -0,0 +1,52 @@
+import 'dart:async';
+
+import 'package:talawa/locator.dart';
+
+/// Manages user sessions and periodically refreshes access tokens.
+class SessionManager {
+  SessionManager() {
+    initializeSessionRefresher();
+  }
+
+  /// returns refresh interval of Session Manager.
+  int get refreshInterval => _refreshInterval;
+
+  /// refresh interval in seconds.
+  static const int _refreshInterval = 600;
+
+  /// Initializes as session refresher.
+  ///
+  /// Invokes [refreshSession] periodically at regular
+  /// refresh intervals.
+  ///
+  /// **params**:
+  ///   None
+  ///
+  /// **returns**:
+  /// * `Timer`: refresh timer.
+  Timer initializeSessionRefresher() {
+    return Timer.periodic(
+      const Duration(seconds: _refreshInterval),
+      (Timer timer) async {
+        refreshSession();
+      },
+    );
+  }
+
+  /// Asynchronously refreshes the user session.
+  ///
+  /// **params**:
+  ///   None
+  ///
+  /// **returns**:
+  /// * `Future<bool>`: indicates if session refresh was
+  /// successful.
+  Future<bool> refreshSession() async {
+    if (userConfig.loggedIn && userConfig.currentUser.refreshToken != null) {
+      final refreshed = await databaseFunctions
+          .refreshAccessToken(userConfig.currentUser.refreshToken!);
+      return refreshed;
+    }
+    return false;
+  }
+}

lib/services/task_service.dart

@@ -35,8 +35,6 @@ class TaskService {
   /// **returns**:
   ///   None
   Future<void> getTasksForEvent(String eventId) async {
-    await _databaseMutationFunctions
-        .refreshAccessToken(_userConfig.currentUser.refreshToken!);
     final res = await _databaseMutationFunctions
         .gqlNonAuthQuery(TaskQueries.eventTasks(eventId));
 
@@ -57,8 +55,6 @@ class TaskService {
   /// **returns**:
   ///   None
   Future<void> getTasksByUser() async {
-    await _databaseMutationFunctions
-        .refreshAccessToken(_userConfig.currentUser.refreshToken!);
     final res = await _databaseMutationFunctions
         .gqlNonAuthQuery(TaskQueries.userTasks(_userConfig.currentUser.id!));
 
@@ -89,8 +85,6 @@ class TaskService {
     required String deadline,
     required String taskId,
   }) async {
-    _databaseMutationFunctions
-        .refreshAccessToken(_userConfig.currentUser.refreshToken!);
     final res = await _databaseMutationFunctions.gqlAuthMutation(
       TaskQueries.editTask(
         title: title,
@@ -135,8 +129,6 @@ class TaskService {
     required String deadline,
     required String eventId,
   }) async {
-    _databaseMutationFunctions
-        .refreshAccessToken(_userConfig.currentUser.refreshToken!);
     final res = await _databaseMutationFunctions.gqlAuthMutation(
       TaskQueries.addTask(
         title: title,
@@ -166,8 +158,6 @@ class TaskService {
   ///   None
   Future<void> deleteTask(String taskId, String creatorId) async {
     if (creatorId == _userConfig.currentUser.id) {
-      await _databaseMutationFunctions
-          .refreshAccessToken(_userConfig.currentUser.refreshToken!);
       final res = await _databaseMutationFunctions
           .gqlAuthMutation(TaskQueries.deleteTask(taskId));
       if (res != null) _tasks.removeWhere((task) => task.id == taskId);

lib/services/user_config.dart

@@ -89,9 +89,11 @@ class UserConfig {
       _currentUser = User(id: 'null', authToken: 'null');
       return false;
     }
+
+    databaseFunctions.initClientNonAuth();
+    await sessionManager.refreshSession();
     // generate access token
     graphqlConfig.getToken().then((value) async {
-      databaseFunctions.init();
       try {
         final QueryResult result = await databaseFunctions.gqlAuthQuery(
           queries.fetchUserInfo,

lib/splash_screen.dart

@@ -73,7 +73,7 @@
       setState(() => _initialUri = null);
     }
 
-    final bool userLoggedIn = await userConfig.userLoggedIn();
+    final bool userLoggedIn = userConfig.loggedIn;
     _initialUri = null;
     _latestUri = null;
     if (_latestUri == null && _initialUri == null) {

lib/view_model/after_auth_view_models/event_view_models/create_event_view_model.dart

@@ -188,9 +188,6 @@ class CreateEventViewModel extends BaseModel {
       navigationService.pushDialog(
         const CustomProgressDialog(key: Key('EventCreationProgress')),
       );
-      final tokenResult = await databaseFunctions
-          .refreshAccessToken(userConfig.currentUser.refreshToken!);
-      print(tokenResult);
       // invoke the `gqlAuthMutation` function of `databaseFunctions`
       // service along with the mutation query and variable map.
       final result = await databaseFunctions.gqlAuthMutation(

pubspec.lock

@@ -346,7 +346,7 @@ packages:
     source: hosted
     version: "7.0.0"
   fake_async:
-    dependency: transitive
+    dependency: "direct dev"
     description:
       name: fake_async
       sha256: "511392330127add0b769b75a987850d136345d9227c6b94c96a04cf4a391bf78"

pubspec.yaml

@@ -82,6 +82,7 @@ dependencies:
 dev_dependencies:
   build_runner: ^2.4.7
   custom_lint: 0.5.8
+  fake_async: ^1.3.1
   flutter_test:
     sdk: flutter
   hive_generator: ^2.0.1

test/helpers/test_helpers.dart

@@ -29,6 +29,7 @@ import 'package:talawa/services/image_service.dart';
 import 'package:talawa/services/navigation_service.dart';
 import 'package:talawa/services/org_service.dart';
 import 'package:talawa/services/post_service.dart';
+import 'package:talawa/services/session_manager.dart';
 import 'package:talawa/services/size_config.dart';
 import 'package:talawa/services/task_service.dart';
 import 'package:talawa/services/third_party_service/multi_media_pick_service.dart';
@@ -55,6 +56,7 @@ import 'package:talawa/view_model/widgets_view_models/custom_drawer_view_model.d
 import 'package:talawa/view_model/widgets_view_models/like_button_view_model.dart';
 import 'package:talawa/view_model/widgets_view_models/progress_dialog_view_model.dart';
 import '../service_tests/image_service_test.dart';
+import '../service_tests/user_config_test.dart';
 import '../views/main_screen_test.dart';
 import 'test_helpers.mocks.dart';
 
@@ -175,6 +177,13 @@ CommentService getAndRegisterCommentService() {
   return service;
 }
 
+SessionManager getAndRegisterSessionManager() {
+  _removeRegistrationIfExists<SessionManager>();
+  final service = MockSessionManger();
+  locator.registerSingleton<SessionManager>(service);
+  return service;
+}
+
 ChatService getAndRegisterChatService() {
   _removeRegistrationIfExists<ChatService>();
   final service = MockChatService();

test/model_tests/user/user_info_test.dart

@@ -61,6 +61,7 @@ final testDataFromOrg = <String, dynamic>{
 /// Test Data Not From Organization.
 final testDataNotFromOrg = {
   "user": {
+    "id": "1234567890",
     "firstName": "ravidi",
     "lastName": "sheikh",
     "email": "[email protected]",

test/service_tests/database_mutations_function_test.dart

@@ -66,6 +66,7 @@ void main() async {
     registerServices();
     functionsClass = DataBaseMutationFunctions();
     functionsClass.init();
+    functionsClass.initClientNonAuth();
   });
 
   group('Database Mutation Functions Tests', () {

test/service_tests/event_service_test.dart

@@ -12,6 +12,7 @@ import 'package:talawa/utils/task_queries.dart';
 
 import '../helpers/test_helpers.dart';
 import '../helpers/test_locator.dart';
+import '../model_tests/user/user_info_test.dart';
 
 void main() {
   testSetupLocator();
@@ -162,6 +163,9 @@ void main() {
                   "name": "Organization Name",
                   "description": "Sample organization description.",
                 },
+                "registrants": [
+                  testDataNotFromOrg,
+                ],
               }
             ],
           },

test/service_tests/post_service_test.dart

@@ -76,12 +76,10 @@ void main() {
 
   group('Test PostService', () {
     test('Test refreshFeed method', () async {
-      final dataBaseMutationFunctions = locator<DataBaseMutationFunctions>();
       final service = PostService();
       // Populating refreshing feed
       await service.refreshFeed();
-      verify(dataBaseMutationFunctions.refreshAccessToken('testtoken'))
-          .called(2);
+      verify(service.getPosts()).called(2);
     });
 
     test('Test addNewPost method', () async {
@@ -306,8 +304,7 @@ void main() {
       ); // Adjust the delay as needed
 
       // Verify that refresh token was called to check getPost method was called correctly.
-      verify(dataBaseMutationFunctions.refreshAccessToken('testtoken'))
-          .called(3);
+      verify(service.getPosts()).called(1);
 
       // Close the stream controller to avoid memory leaks
       await orgInfoStreamController.close();