init

filcnaplo/lib/api/client.dart

@@ -0,0 +1,85 @@
+import 'dart:convert';
+
+import 'package:filcnaplo/models/config.dart';
+import 'package:filcnaplo/models/news.dart';
+import 'package:filcnaplo/models/release.dart';
+import 'package:filcnaplo_kreta_api/models/school.dart';
+import 'package:http/http.dart' as http;
+
+class FilcAPI {
+  static const SCHOOL_LIST = "https://filcnaplo.hu/v2/school_list.json";
+  static const CONFIG = "https://filcnaplo.hu/v2/config.json";
+  static const NEWS = "https://filcnaplo.hu/v2/news.json";
+  static const REPO = "filc/naplo";
+  static const RELEASES = "https://api.github.com/repos/$REPO/releases";
+
+  static Future<List<School>?> getSchools() async {
+    try {
+      http.Response res = await http.get(Uri.parse(SCHOOL_LIST));
+
+      if (res.statusCode == 200) {
+        return (jsonDecode(res.body) as List).cast<Map>().map((json) => School.fromJson(json)).toList();
+      } else {
+        throw "HTTP ${res.statusCode}: ${res.body}";
+      }
+    } catch (error) {
+      print("ERROR: FilcAPI.getSchools: $error");
+    }
+  }
+
+  static Future<Config?> getConfig() async {
+    try {
+      http.Response res = await http.get(Uri.parse(CONFIG));
+
+      if (res.statusCode == 200) {
+        return Config.fromJson(jsonDecode(res.body));
+      } else {
+        throw "HTTP ${res.statusCode}: ${res.body}";
+      }
+    } catch (error) {
+      print("ERROR: FilcAPI.getConfig: $error");
+    }
+  }
+
+  static Future<List<News>?> getNews() async {
+    try {
+      http.Response res = await http.get(Uri.parse(NEWS));
+
+      if (res.statusCode == 200) {
+        return (jsonDecode(res.body) as List).cast<Map>().map((e) => News.fromJson(e)).toList();
+      } else {
+        throw "HTTP ${res.statusCode}: ${res.body}";
+      }
+    } catch (error) {
+      print("ERROR: FilcAPI.getNews: $error");
+    }
+  }
+
+  static Future<List<Release>?> getReleases() async {
+    try {
+      http.Response res = await http.get(Uri.parse(RELEASES));
+
+      if (res.statusCode == 200) {
+        return (jsonDecode(res.body) as List).cast<Map>().map((e) => Release.fromJson(e)).toList();
+      } else {
+        throw "HTTP ${res.statusCode}: ${res.body}";
+      }
+    } catch (error) {
+      print("ERROR: FilcAPI.getReleases: $error");
+    }
+  }
+
+  static Future<http.StreamedResponse?> downloadRelease(Release release) {
+    if (release.downloads.length > 0) {
+      try {
+        var client = http.Client();
+        var request = http.Request('GET', Uri.parse(release.downloads.first));
+        return client.send(request);
+      } catch (error) {
+        print("ERROR: FilcAPI.downloadRelease: $error");
+      }
+    }
+
+    return Future.value(null);
+  }
+}

filcnaplo/lib/api/login.dart

@@ -0,0 +1,110 @@
+import 'package:filcnaplo_kreta_api/providers/absence_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/event_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/exam_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/grade_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/homework_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/message_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/note_provider.dart';
+import 'package:filcnaplo_kreta_api/providers/timetable_provider.dart';
+import 'package:filcnaplo/api/providers/user_provider.dart';
+import 'package:filcnaplo/api/providers/database_provider.dart';
+import 'package:filcnaplo/models/settings.dart';
+import 'package:filcnaplo/models/user.dart';
+import 'package:filcnaplo/utils/jwt.dart';
+import 'package:filcnaplo_kreta_api/client/api.dart';
+import 'package:filcnaplo_kreta_api/client/client.dart';
+import 'package:filcnaplo_kreta_api/models/message.dart';
+import 'package:filcnaplo_kreta_api/models/student.dart';
+import 'package:filcnaplo_kreta_api/models/week.dart';
+import 'package:flutter/material.dart';
+import 'package:provider/provider.dart';
+import 'package:filcnaplo/api/nonce.dart';
+
+enum LoginState { normal, inProgress, missingFields, invalidGrant, success, failed }
+
+Nonce getNonce(BuildContext context, String nonce, String username, String instituteCode) {
+  Nonce nonceEncoder = Nonce(key: [53, 75, 109, 112, 109, 103, 100, 53, 102, 74], nonce: nonce);
+  nonceEncoder.encode(username.toLowerCase() + instituteCode.toLowerCase() + nonce);
+
+  return nonceEncoder;
+}
+
+Future loginApi({
+  required String username,
+  required String password,
+  required String instituteCode,
+  required BuildContext context,
+  void Function(User)? onLogin,
+  void Function()? onSuccess,
+}) async {
+  Provider.of<KretaClient>(context, listen: false).userAgent = Provider.of<SettingsProvider>(context, listen: false).config.userAgent;
+
+  Map<String, String> headers = {
+    "content-type": "application/x-www-form-urlencoded",
+  };
+
+  String nonceStr = await Provider.of<KretaClient>(context, listen: false).getAPI(KretaAPI.nonce, json: false);
+
+  Nonce nonce = getNonce(context, nonceStr, username, instituteCode);
+  headers.addAll(nonce.header());
+
+  Map? res = await Provider.of<KretaClient>(context, listen: false).postAPI(KretaAPI.login,
+      headers: headers,
+      body: User.loginBody(
+        username: username,
+        password: password,
+        instituteCode: instituteCode,
+      ));
+  if (res != null) {
+    if (res.containsKey("error")) {
+      if (res["error"] == "invalid_grant") {
+        return LoginState.invalidGrant;
+      }
+    } else {
+      if (res.containsKey("access_token")) {
+        try {
+          Provider.of<KretaClient>(context, listen: false).accessToken = res["access_token"];
+          Map? studentJson = await Provider.of<KretaClient>(context, listen: false).getAPI(KretaAPI.student(instituteCode));
+          var user = User(
+            username: username,
+            password: password,
+            instituteCode: instituteCode,
+            name: JwtUtils.getNameFromJWT(res["access_token"]) ?? "?",
+            student: Student.fromJson(studentJson!),
+          );
+
+          if (onLogin != null) onLogin(user);
+
+          // Store User in the database
+          await Provider.of<DatabaseProvider>(context, listen: false).store.storeUser(user);
+          Provider.of<UserProvider>(context, listen: false).addUser(user);
+          Provider.of<UserProvider>(context, listen: false).setUser(user.id);
+
+          // Get user data
+          try {
+            await Provider.of<GradeProvider>(context, listen: false).fetch();
+            await Provider.of<TimetableProvider>(context, listen: false).fetch(week: Week.current());
+            await Provider.of<ExamProvider>(context, listen: false).fetch();
+            await Provider.of<HomeworkProvider>(context, listen: false).fetch();
+            await Provider.of<MessageProvider>(context, listen: false).fetch(type: MessageType.inbox);
+            await Provider.of<NoteProvider>(context, listen: false).fetch();
+            await Provider.of<EventProvider>(context, listen: false).fetch();
+            await Provider.of<AbsenceProvider>(context, listen: false).fetch();
+          } catch (error) {
+            print("WARNING: failed to fetch user data: $error");
+          }
+
+          if (onSuccess != null) onSuccess();
+
+          return LoginState.success;
+        } catch (error) {
+          print("ERROR: loginApi: $error");
+          // maybe check debug mode
+          // ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text("ERROR: $error")));
+          return LoginState.failed;
+        }
+      }
+    }
+  }
+  return LoginState.failed;
+}

filcnaplo/lib/api/nonce.dart

@@ -0,0 +1,25 @@
+import 'dart:convert';
+import 'package:crypto/crypto.dart';
+
+class Nonce {
+  String nonce;
+  List<int> key;
+  String? encoded;
+
+  Nonce({required this.nonce, required this.key});
+
+  Future encode(String message) async {
+    List<int> messageBytes = utf8.encode(message);
+    Hmac hmac = Hmac(sha512, key);
+    Digest digest = hmac.convert(messageBytes);
+    encoded = base64.encode(digest.bytes);
+  }
+
+  Map<String, String> header() {
+    return {
+      "X-Authorizationpolicy-Nonce": nonce,
+      "X-Authorizationpolicy-Key": encoded ?? "",
+      "X-Authorizationpolicy-Version": "v1",
+    };
+  }
+}

filcnaplo/lib/api/providers/database_provider.dart

@@ -0,0 +1,20 @@
+import 'package:filcnaplo/database/query.dart';
+import 'package:filcnaplo/database/store.dart';
+import 'package:sqflite/sqflite.dart';
+
+class DatabaseProvider {
+  // late Database _database;
+  late DatabaseQuery query;
+  late UserDatabaseQuery userQuery;
+  late DatabaseStore store;
+  late UserDatabaseStore userStore;
+
+  Future<void> init() async {
+    var db = await openDatabase("app.db");
+    // _database = db;
+    query = DatabaseQuery(db: db);
+    store = DatabaseStore(db: db);
+    userQuery = UserDatabaseQuery(db: db);
+    userStore = UserDatabaseStore(db: db);
+  }
+}

filcnaplo/lib/api/providers/news_provider.dart

@@ -0,0 +1,82 @@
+import 'dart:math';
+
+import 'package:filcnaplo/api/client.dart';
+import 'package:filcnaplo/models/news.dart';
+import 'package:filcnaplo/models/settings.dart';
+import 'package:flutter/material.dart';
+import 'package:provider/provider.dart';
+
+class NewsProvider extends ChangeNotifier {
+  // Private
+  late List<News> _news;
+  late int _state;
+  late int _fresh;
+  bool show = false;
+  late BuildContext _context;
+
+  // Public
+  List<News> get news => _news;
+  int get state => _fresh - 1;
+
+  NewsProvider({
+    List<News> initialNews = const [],
+    required BuildContext context,
+  }) {
+    _news = List.castFrom(initialNews);
+    _context = context;
+  }
+
+  Future<void> restore() async {
+    // Load news state from the database
+    var state_ = Provider.of<SettingsProvider>(_context, listen: false).newsState;
+
+    if (state_ == -1) {
+      var news_ = await FilcAPI.getNews();
+      if (news_ != null) {
+        state_ = news_.length;
+        _news = news_;
+      }
+    }
+
+    _state = state_;
+    Provider.of<SettingsProvider>(_context, listen: false).update(_context, newsState: _state);
+  }
+
+  Future<void> fetch() async {
+    var news_ = await FilcAPI.getNews();
+    if (news_ == null) return;
+
+    _news = news_;
+    _fresh = news_.length - _state;
+
+    if (_fresh < 0) {
+      _state = news_.length;
+      Provider.of<SettingsProvider>(_context, listen: false).update(_context, newsState: _state);
+    }
+
+    _fresh = max(_fresh, 0);
+
+    if (_fresh > 0) {
+      show = true;
+      notifyListeners();
+    }
+  }
+
+  void lock() => show = false;
+
+  void release() {
+    if (_fresh == 0) return;
+
+    _fresh--;
+    _state++;
+
+    Provider.of<SettingsProvider>(_context, listen: false).update(_context, newsState: _state);
+
+    if (_fresh > 0)
+      show = true;
+    else
+      show = false;
+
+    notifyListeners();
+  }
+}

filcnaplo/lib/api/providers/update_provider.dart

@@ -0,0 +1,41 @@
+import 'dart:io';
+
+import 'package:filcnaplo/api/client.dart';
+import 'package:filcnaplo/models/release.dart';
+import 'package:flutter/material.dart';
+import 'package:package_info_plus/package_info_plus.dart';
+
+class UpdateProvider extends ChangeNotifier {
+  // Private
+  late List<Release> _releases;
+  late BuildContext _context;
+  bool _available = false;
+  bool get available => _available && _releases.length > 0;
+  PackageInfo? _packageInfo;
+
+  // Public
+  List<Release> get releases => _releases;
+
+  UpdateProvider({
+    List<Release> initialReleases = const [],
+    required BuildContext context,
+  }) {
+    _releases = List.castFrom(initialReleases);
+    _context = context;
+    PackageInfo.fromPlatform().then((value) => _packageInfo = value);
+  }
+
+  Future<void> fetch() async {
+    if (!Platform.isAndroid) return;
+
+    _releases = await FilcAPI.getReleases() ?? [];
+    _releases.sort((a, b) => -a.version.compareTo(b.version));
+
+    // Check for new releases
+    if (_releases.length > 0) {
+      print("INFO: New update: ${releases.first.version}");
+      _available = _packageInfo != null && _releases.first.version.compareTo(Version.fromString(_packageInfo?.version ?? "")) == 1;
+      notifyListeners();
+    }
+  }
+}

filcnaplo/lib/api/providers/user_provider.dart

@@ -0,0 +1,41 @@
+import 'package:filcnaplo/models/user.dart';
+import 'package:filcnaplo_kreta_api/models/student.dart';
+import 'package:flutter/foundation.dart';
+
+class UserProvider with ChangeNotifier {
+  Map<String, User> _users = {};
+  String? _selectedUserId;
+  User? get user => _users[_selectedUserId];
+
+  // _user properties
+  String? get instituteCode => user?.instituteCode;
+  String? get id => user?.id;
+  String? get name => user?.name;
+  String? get username => user?.username;
+  String? get password => user?.password;
+  Student? get student => user?.student;
+
+  void setUser(String userId) {
+    _selectedUserId = userId;
+    notifyListeners();
+  }
+
+  void addUser(User user) {
+    _users[user.id] = user;
+    print("DEBUG: Added User: ${user.id} ${user.name}");
+  }
+
+  void removeUser(String userId) {
+    _users.removeWhere((key, value) => key == userId);
+    if (_users.isNotEmpty) _selectedUserId = _users.keys.first;
+    notifyListeners();
+  }
+
+  User getUser(String userId) {
+    return _users[userId]!;
+  }
+
+  List<User> getUsers() {
+    return _users.values.toList();
+  }
+}