import 'package:flutter_bloc/flutter_bloc.dart'; import 'package:selfprivacy/config/get_it_config.dart'; import 'package:selfprivacy/logic/api_maps/server.dart'; import 'package:selfprivacy/logic/cubit/services/services_cubit.dart'; import 'package:selfprivacy/logic/cubit/users/users_cubit.dart'; import 'package:selfprivacy/logic/get_it/ssh.dart'; import 'package:selfprivacy/logic/models/job.dart'; import 'package:equatable/equatable.dart'; import 'package:selfprivacy/logic/models/user.dart'; export 'package:provider/provider.dart'; import 'package:easy_localization/easy_localization.dart'; part 'jobs_state.dart'; class JobsCubit extends Cubit { JobsCubit({ required this.usersCubit, required this.servicesCubit, }) : super(JobsStateEmpty()); final api = ServerApi(); final UsersCubit usersCubit; final ServicesCubit servicesCubit; void addJob(Job job) { var newJobsList = []; if (state is JobsStateWithJobs) { newJobsList.addAll((state as JobsStateWithJobs).jobList); } newJobsList.add(job); getIt().showSnackBar('jobs.jobAdded'.tr()); emit(JobsStateWithJobs(newJobsList)); } void removeJob(String id) { final newState = (state as JobsStateWithJobs).removeById(id); emit(newState); } void createOrRemoveServiceToggleJob(ServiceToggleJob job) { var newJobsList = []; if (state is JobsStateWithJobs) { newJobsList.addAll((state as JobsStateWithJobs).jobList); } var needToRemoveJob = newJobsList.any((el) => el is ServiceToggleJob && el.type == job.type); if (needToRemoveJob) { var removingJob = newJobsList .firstWhere(((el) => el is ServiceToggleJob && el.type == job.type)); removeJob(removingJob.id); } else { newJobsList.add(job); getIt().showSnackBar('jobs.jobAdded'.tr()); emit(JobsStateWithJobs(newJobsList)); } } void createShhJobIfNotExist(CreateSSHKeyJob job) { var newJobsList = []; if (state is JobsStateWithJobs) { newJobsList.addAll((state as JobsStateWithJobs).jobList); } var isExistInJobList = newJobsList.any((el) => el is CreateSSHKeyJob); if (!isExistInJobList) { newJobsList.add(job); getIt().showSnackBar('jobs.jobAdded'.tr()); emit(JobsStateWithJobs(newJobsList)); } } Future rebootServer() async { emit(JobsStateLoading()); final isSuccessful = await api.reboot(); if (isSuccessful) { getIt().showSnackBar('jobs.rebootSuccess'.tr()); } else { getIt().showSnackBar('jobs.rebootFailed'.tr()); } emit(JobsStateEmpty()); } Future upgradeServer() async { emit(JobsStateLoading()); final isPullSuccessful = await api.pullConfigurationUpdate(); final isSuccessful = await api.upgrade(); if (isSuccessful) { if (!isPullSuccessful) { getIt().showSnackBar('jobs.configPullFailed'.tr()); } else { getIt().showSnackBar('jobs.upgradeSuccess'.tr()); } } else { getIt().showSnackBar('jobs.upgradeFailed'.tr()); } emit(JobsStateEmpty()); } Future applyAll() async { if (state is JobsStateWithJobs) { var jobs = (state as JobsStateWithJobs).jobList; emit(JobsStateLoading()); var newUsers = []; var hasServiceJobs = false; for (var job in jobs) { if (job is CreateUserJob) { newUsers.add(job.user); await api.createUser(job.user); } if (job is DeleteUserJob) { final deleted = await api.deleteUser(job.user); if (deleted) usersCubit.remove(job.user); } if (job is ServiceToggleJob) { hasServiceJobs = true; await api.switchService(job.type, job.needToTurnOn); } if (job is CreateSSHKeyJob) { await getIt().generateKeys(); api.sendSsh(getIt().savedPubKey!); } } usersCubit.addUsers(newUsers); await api.pullConfigurationUpdate(); await api.apply(); if (hasServiceJobs) { await servicesCubit.load(); } emit(JobsStateEmpty()); getIt().navigator!.pop(); } } }