56 lines
1.5 KiB
Dart
56 lines
1.5 KiB
Dart
import 'dart:convert';
|
|
import 'dart:io';
|
|
|
|
import 'package:bloc/bloc.dart';
|
|
import 'package:bloc_concurrency/bloc_concurrency.dart';
|
|
import 'package:equatable/equatable.dart';
|
|
import 'package:meta/meta.dart';
|
|
|
|
import '../models/scoop_app_model.dart';
|
|
import '../utils/scoop_utils.dart';
|
|
|
|
part 'scoop_list_event.dart';
|
|
part 'scoop_list_state.dart';
|
|
|
|
class ScoopListBloc extends Bloc<ScoopListEvent, ScoopListState> {
|
|
ScoopListBloc() : super(ScoopListInitial()) {
|
|
on<ScoopLocate>(
|
|
(event, emit) {
|
|
if (scoopInstalled()) {
|
|
add(ScoopListRequested());
|
|
} else {
|
|
emit(ScoopNotFound());
|
|
}
|
|
},
|
|
transformer: droppable(),
|
|
);
|
|
on<ScoopUpdateRequested>(
|
|
(event, emit) async {
|
|
try {
|
|
final process =
|
|
await Process.start('scoop', ["update"], runInShell: true);
|
|
await process.stdout.transform(utf8.decoder).forEach((e) {
|
|
emit(ScoopUpdateInProgress(e));
|
|
});
|
|
int exitCode = await process.exitCode;
|
|
if (exitCode != 0) {
|
|
throw Exception(
|
|
"Command `scoop update` failed with code $exitCode");
|
|
}
|
|
add(ScoopListRequested());
|
|
} catch (e) {
|
|
emit(ScoopUpdateError(e.toString()));
|
|
}
|
|
},
|
|
transformer: droppable(),
|
|
);
|
|
on<ScoopListRequested>(
|
|
(event, emit) async {
|
|
emit(ScoopListLoading());
|
|
final apps = await getInstalledScoopApps();
|
|
emit(ScoopLocalAppList(apps));
|
|
},
|
|
transformer: droppable(),
|
|
);
|
|
}
|
|
}
|