initial multi user feature
This commit is contained in:
@@ -0,0 +1,20 @@
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:flutter/services.dart';
|
||||
import 'package:riverpod/riverpod.dart';
|
||||
import 'package:weblibre/core/logger.dart';
|
||||
|
||||
Future<void> exitApp(ProviderContainer container) async {
|
||||
logger.i('Preparing exit');
|
||||
|
||||
await SystemNavigator.pop();
|
||||
logger.i('SystemNavigator popped');
|
||||
|
||||
container.dispose();
|
||||
logger.i('Provider container disposed');
|
||||
|
||||
await Future.delayed(const Duration(seconds: 1)).whenComplete(() {
|
||||
logger.i('Bye !!1');
|
||||
exit(0);
|
||||
});
|
||||
}
|
||||
@@ -0,0 +1,130 @@
|
||||
import 'dart:async';
|
||||
import 'dart:convert';
|
||||
import 'dart:io';
|
||||
|
||||
import 'package:path/path.dart' as p;
|
||||
import 'package:uuid/uuid_value.dart';
|
||||
import 'package:weblibre/core/logger.dart';
|
||||
import 'package:weblibre/domain/entities/profile.dart';
|
||||
|
||||
const profilesDirName = 'weblibre_profiles';
|
||||
const profileDirPrefix = 'profile-';
|
||||
|
||||
const _startupProfileFileName = 'current_profile';
|
||||
const _metadataFile = 'metadata.json';
|
||||
|
||||
final profileTransformer =
|
||||
StreamTransformer<FileSystemEntity, Directory>.fromHandlers(
|
||||
handleData: (entity, sink) {
|
||||
if (entity is Directory &&
|
||||
p.basename(entity.path).startsWith(profileDirPrefix)) {
|
||||
sink.add(entity);
|
||||
}
|
||||
},
|
||||
);
|
||||
|
||||
Future<List<Directory>> getAvailableProfileDirectories(Directory profilesDir) {
|
||||
return profilesDir.list().transform(profileTransformer).toList();
|
||||
}
|
||||
|
||||
Future<UuidValue?> readStartupProfile(Directory dir) async {
|
||||
final file = File(p.join(dir.path, _startupProfileFileName));
|
||||
|
||||
if (await file.exists()) {
|
||||
final contents = await file.readAsString();
|
||||
try {
|
||||
return UuidValue.withValidation(contents);
|
||||
} catch (e, s) {
|
||||
logger.e('Could not parse profile', error: e, stackTrace: s);
|
||||
}
|
||||
}
|
||||
|
||||
return null;
|
||||
}
|
||||
|
||||
Future<void> writeStartupProfile(
|
||||
Directory dir,
|
||||
UuidValue profile, {
|
||||
bool flush = false,
|
||||
}) async {
|
||||
final file = File(p.join(dir.path, _startupProfileFileName));
|
||||
await file.writeAsString(profile.uuid, flush: flush);
|
||||
}
|
||||
|
||||
Future<UuidValue?> selectStartupProfile(Directory profilesDir) async {
|
||||
var startupProfile = await readStartupProfile(profilesDir);
|
||||
final availableProfiles = await getAvailableProfileDirectories(profilesDir);
|
||||
|
||||
if (startupProfile == null) {
|
||||
final sortedDirs = await sortByAccessTime(availableProfiles);
|
||||
|
||||
for (final dir in sortedDirs) {
|
||||
try {
|
||||
startupProfile = extractDirectoryUuid(dir);
|
||||
await writeStartupProfile(profilesDir, startupProfile);
|
||||
|
||||
break;
|
||||
} catch (e, s) {
|
||||
logger.w('Could not parse profile folder', error: e, stackTrace: s);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return startupProfile;
|
||||
}
|
||||
|
||||
UuidValue extractDirectoryUuid(Directory dir) => UuidValue.withValidation(
|
||||
p.basename(dir.path).substring(profileDirPrefix.length),
|
||||
);
|
||||
|
||||
Directory getProfileDir(Directory profilesDir, UuidValue profileUuid) {
|
||||
return Directory(
|
||||
p.join(profilesDir.path, '$profileDirPrefix${profileUuid.uuid}'),
|
||||
);
|
||||
}
|
||||
|
||||
Future<Profile?> readProfileMetadata(Directory profileDir) async {
|
||||
final file = File(p.join(profileDir.path, _metadataFile));
|
||||
if (!await file.exists()) {
|
||||
return null;
|
||||
}
|
||||
|
||||
final content = await file.readAsString();
|
||||
return Profile.fromJson(jsonDecode(content) as Map<String, dynamic>);
|
||||
}
|
||||
|
||||
Future<void> writeProfileMetadata(Directory profileDir, Profile profile) async {
|
||||
final file = File(p.join(profileDir.path, _metadataFile));
|
||||
await file.writeAsString(jsonEncode(profile.toJson()), flush: true);
|
||||
}
|
||||
|
||||
Future<bool> createNewProfile(Directory profilesDir, Profile profile) async {
|
||||
final profileDir = getProfileDir(profilesDir, profile.uuidValue);
|
||||
|
||||
if (await profileDir.exists()) {
|
||||
return false;
|
||||
}
|
||||
await profileDir.create();
|
||||
await writeProfileMetadata(profileDir, profile);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
Future<List<Directory>> sortByAccessTime(
|
||||
List<Directory> dirs, {
|
||||
bool descending = true,
|
||||
}) async {
|
||||
final dirsWithStats = await Future.wait(
|
||||
dirs.map((dir) async {
|
||||
final stat = await dir.stat();
|
||||
return (dir: dir, accessed: stat.accessed);
|
||||
}),
|
||||
);
|
||||
|
||||
dirsWithStats.sort((a, b) {
|
||||
final comparison = a.accessed.compareTo(b.accessed);
|
||||
return descending ? -comparison : comparison;
|
||||
});
|
||||
|
||||
return dirsWithStats.map((record) => record.dir).toList();
|
||||
}
|
||||
Reference in New Issue
Block a user