albert/refilc-plus
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

init refilc-plus

Browse source
This commit is contained in:
skidoodle 2024-10-03 18:47:25 +02:00
commit 6edc2029bd
Signed by: albert
GPG key ID: A06E3070D7D55BF2
37 changed files with 6988 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

201
lib/api/auth.dart Normal file
View file

@ -0,0 +1,201 @@
import 'dart:async';
import 'dart:convert';
import 'dart:developer';
import 'dart:io';
import 'package:refilc/api/client.dart';
import 'package:refilc/models/settings.dart';
import 'package:flutter/foundation.dart';
import 'package:refilc_plus/models/premium_result.dart';
// import 'package:flutter/foundation.dart';
// import 'package:flutter/services.dart';
import 'package:url_launcher/url_launcher.dart';
import 'package:uni_links/uni_links.dart';
import 'package:http/http.dart' as http;
// import 'package:home_widget/home_widget.dart';
class PremiumAuth {
final SettingsProvider _settings;
StreamSubscription? _sub;
PremiumAuth({required SettingsProvider settings}) : _settings = settings;
// initAuth() {
// try {
// _sub ??= uriLinkStream.listen(
// (Uri? uri) {
// if (uri != null) {
// final accessToken = uri.queryParameters['access_token'];
// if (accessToken != null) {
// finishAuth(accessToken);
// }
// }
// },
// onError: (err) {
// log("ERROR: initAuth: $err");
// },
// );
// launchUrl(
// Uri.parse(FilcAPI.plusAuthLogin),
// mode: LaunchMode.externalApplication,
// );
// } catch (err, sta) {
// log("ERROR: initAuth: $err\n$sta");
// }
// }
initAuth({required String product}) {
try {
_sub ??= uriLinkStream.listen(
(Uri? uri) {
if (uri != null) {
final sessionId = uri.queryParameters['session_id'];
if (sessionId != null) {
finishAuth(sessionId);
}
}
},
onError: (err) {
log("ERROR: initAuth: $err");
},
);
launchUrl(
Uri.parse(
"${FilcAPI.payment}/stripe-create-checkout?product=$product&rf_uinid=${_settings.xFilcId}"),
mode: LaunchMode.externalApplication,
);
} catch (err, sta) {
log("ERROR: initAuth: $err\n$sta");
}
}
// Future<bool> finishAuth(String accessToken) async {
// try {
// // final res = await http.get(Uri.parse(
// // "${FilcAPI.plusScopes}?access_token=${Uri.encodeComponent(accessToken)}"));
// // final scopes =
// // ((jsonDecode(res.body) as Map)["scopes"] as List).cast<String>();
// // log("[INFO] Premium auth finish: ${scopes.join(',')}");
// await _settings.update(premiumAccessToken: accessToken);
// final result = await refreshAuth();
// // if (Platform.isAndroid) updateWidget();
// return result;
// } catch (err, sta) {
// log("[ERROR] reFilc+ auth failed: $err\n$sta");
// }
// await _settings.update(premiumAccessToken: "", premiumScopes: []);
// // if (Platform.isAndroid) updateWidget();
// return false;
// }
Future<bool> finishAuth(String sessionId) async {
try {
// final res = await http.get(Uri.parse(
// "${FilcAPI.plusScopes}?access_token=${Uri.encodeComponent(accessToken)}"));
// final scopes =
// ((jsonDecode(res.body) as Map)["scopes"] as List).cast<String>();
// log("[INFO] Premium auth finish: ${scopes.join(',')}");
await _settings.update(plusSessionId: sessionId);
final result = await refreshAuth();
// if (Platform.isAndroid) updateWidget();
return result;
} catch (err, sta) {
log("[ERROR] reFilc+ auth failed: $err\n$sta");
}
await _settings.update(plusSessionId: "", premiumScopes: []);
// if (Platform.isAndroid) updateWidget();
return false;
}
// Future<bool?> updateWidget() async {
// try {
// return HomeWidget.updateWidget(name: 'widget_timetable.WidgetTimetable');
// } on PlatformException catch (exception) {
// if (kDebugMode) {
// print('Error Updating Widget After Auth. $exception');
// }
// }
// return false;
// }
Future<bool> refreshAuth(
{bool removePremium = false, bool reactivate = false}) async {
if (!removePremium) {
if (_settings.plusSessionId == "" && !reactivate) {
await _settings.update(premiumScopes: [], premiumLogin: "");
return false;
}
// skip reFilc+ check when disconnected
try {
final status = await InternetAddress.lookup('api.refilc.hu');
if (status.isEmpty) return false;
} on SocketException catch (_) {
return false;
}
for (int tries = 0; tries < 3; tries++) {
try {
if (kDebugMode) {
print(FilcAPI.plusActivation);
print(_settings.plusSessionId);
print(_settings.xFilcId);
}
final res = await http.post(Uri.parse(FilcAPI.plusActivation), body: {
"session_id": _settings.plusSessionId,
"rf_uinid": _settings.xFilcId,
});
if (kDebugMode) print(res.body);
if (res.body == "") throw "empty body";
// if (res.body == "Unauthorized") {
// throw "User is not autchenticated to Github!";
// }
// if (res.body == "empty_sponsors") {
// throw "This user isn't sponsoring anyone currently!";
// }
if (res.body == "expired_subscription") {
throw "This user isn't a subscriber anymore!";
}
if (res.body == "no_subscription") {
throw "This user isn't a subscriber!";
}
if (res.body == "unknown_device") {
throw "This device is not recognized, please contact support!";
}
final premium = PremiumResult.fromJson(jsonDecode(res.body) as Map);
// successful activation of reFilc+
log("[INFO] reFilc+ activated: ${premium.scopes.join(',')}");
await _settings.update(
plusSessionId: premium.sessionId,
premiumScopes: premium.scopes,
premiumLogin: premium.login,
);
return true;
} catch (err, sta) {
// error while activating reFilc+
log("[ERROR] reFilc+ activation failed: $err\n$sta");
}
await Future.delayed(const Duration(seconds: 1));
}
}
// activation of reFilc+ failed
await _settings.update(
premiumAccessToken: "",
premiumScopes: [],
premiumLogin: "",
plusSessionId: "",
);
return false;
}
}