-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: syncing books from otzaria-library GitHub
refactor: the main function
- Loading branch information
Showing
7 changed files
with
346 additions
and
68 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -30,7 +30,7 @@ migrate_working_dir/ | |
| .pub-cache/ | ||
| .pub/ | ||
| /build/ | ||
|
|
||
| /windows/ | ||
| # Symbolication related | ||
| app.*.symbols | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,123 @@ | ||
| import 'dart:convert'; | ||
| import 'dart:io'; | ||
| import 'package:flutter_settings_screens/flutter_settings_screens.dart'; | ||
| import 'package:http/http.dart' as http; | ||
|
|
||
| class FileSyncService { | ||
| final String githubOwner; | ||
| final String repositoryName; | ||
| final String branch; | ||
| bool isSyncing = false; | ||
|
|
||
| FileSyncService({ | ||
| required this.githubOwner, | ||
| required this.repositoryName, | ||
| this.branch = 'main', | ||
| }); | ||
|
|
||
| Future<String> get _localManifestPath async { | ||
| final directory = _localDirectory; | ||
| return '${await directory}${Platform.pathSeparator}files_manifest.json'; | ||
| } | ||
|
|
||
| Future<String> get _localDirectory async { | ||
| return Settings.getValue('key-library-path') ?? 'C:/אוצריא'; | ||
| } | ||
|
|
||
| Future<Map<String, dynamic>> _getLocalManifest() async { | ||
| try { | ||
| final file = File(await _localManifestPath); | ||
| if (!await file.exists()) { | ||
| return {}; | ||
| } | ||
| final content = await file.readAsString(); | ||
| return json.decode(content); | ||
| } catch (e) { | ||
| print('Error reading local manifest: $e'); | ||
| return {}; | ||
| } | ||
| } | ||
|
|
||
| Future<Map<String, dynamic>> _getRemoteManifest() async { | ||
| final url = | ||
| 'https://raw.githubusercontent.com/$githubOwner/$repositoryName/$branch/files_manifest.json'; | ||
| try { | ||
| final response = await http.get(Uri.parse(url)); | ||
| if (response.statusCode == 200) { | ||
| return json.decode(response.body); | ||
| } | ||
| throw Exception('Failed to fetch remote manifest'); | ||
| } catch (e) { | ||
| print('Error fetching remote manifest: $e'); | ||
| rethrow; | ||
| } | ||
| } | ||
|
|
||
| Future<void> downloadFile(String filePath) async { | ||
| final url = | ||
| 'https://raw.githubusercontent.com/$githubOwner/$repositoryName/$branch/$filePath'; | ||
| try { | ||
| final response = await http.get(Uri.parse(url)); | ||
| if (response.statusCode == 200) { | ||
| final directory = await _localDirectory; | ||
| final file = File('$directory/$filePath'); | ||
|
|
||
| // Create directories if they don't exist | ||
| await file.parent.create(recursive: true); | ||
| await file.writeAsBytes(response.bodyBytes); | ||
| } | ||
| } catch (e) { | ||
| print('Error downloading file $filePath: $e'); | ||
| } | ||
| } | ||
|
|
||
| Future<List<String>> checkForUpdates() async { | ||
| final localManifest = await _getLocalManifest(); | ||
| final remoteManifest = await _getRemoteManifest(); | ||
|
|
||
| final filesToUpdate = <String>[]; | ||
|
|
||
| remoteManifest.forEach((filePath, remoteInfo) { | ||
| if (!localManifest.containsKey(filePath) || | ||
| localManifest[filePath]['modified'] != remoteInfo['modified']) { | ||
| filesToUpdate.add(filePath); | ||
| } | ||
| }); | ||
|
|
||
| return filesToUpdate; | ||
| } | ||
|
|
||
| Future<int> syncFiles() async { | ||
| if (isSyncing) { | ||
| return 0; | ||
| } | ||
| isSyncing = true; | ||
| int count = 0; | ||
| try { | ||
| final filesToUpdate = await checkForUpdates(); | ||
|
|
||
| for (final filePath in filesToUpdate) { | ||
| if (isSyncing == false) { | ||
| return count; | ||
| } | ||
| await downloadFile(filePath); | ||
| count++; | ||
| } | ||
|
|
||
| // Update local manifest | ||
| final remoteManifest = await _getRemoteManifest(); | ||
| final manifestFile = File(await _localManifestPath); | ||
| await manifestFile.writeAsString(json.encode(remoteManifest)); | ||
| } catch (e) { | ||
| print('Error during sync: $e'); | ||
| isSyncing = false; | ||
| rethrow; | ||
| } | ||
| isSyncing = false; | ||
| return count; | ||
| } | ||
|
|
||
| Future<void> stopSyncing() async { | ||
| isSyncing = false; | ||
| } | ||
| } |
Oops, something went wrong.