feat: implement split mode. (#5)

* allow running ccx on a bunch of files at once using split mode

todo: progress indicator

* feat: implement split mode

Author: techno-disaster

lib/bloc/process_bloc/process_bloc.dart

@@ -100,9 +100,31 @@ class ProcessBloc extends Bloc<ProcessEvent, ProcessState> {
     );
   }
 
+  Stream<ProcessState> _extractFilesInSplitMode() async* {
+    unawaited(
+      _extractor
+          .extractFilesInSplitMode(
+        state.orignalList,
+        listenProgress: (progress) =>
+            add(ProcessFileExtractorProgress(progress)),
+        listenOutput: (line) => add(ProcessFileExtractorOutput(line)),
+        listenVideoDetails: (videoDetails) =>
+            add(ProcessFileVideoDetails(videoDetails)),
+      )
+          .then(
+        (value) {
+          if (value != 0) {
+            add(ProcessError(value));
+          }
+          add(SplitModeProcessComplete());
+        },
+      ),
+    );
+  }
+
   @override
   Stream<ProcessState> mapEventToState(ProcessEvent event) async* {
-    if (event is ProcessStarted) {
+    if (event is StartAllProcess) {
       yield state.copyWith(
         current: state.current,
         // This equality checks if the queue and originalList are same which
@@ -117,11 +139,14 @@ class ProcessBloc extends Bloc<ProcessEvent, ProcessState> {
         started: true,
       );
       yield* _extractNext();
-    } else if (event is ProcessStopped) {
+    } else if (event is StartProcessInSplitMode) {
+      yield state.copyWith(current: state.current, started: true);
+      yield* _extractFilesInSplitMode();
+    } else if (event is StopAllProcess) {
       // stops everything
       try {
         _extractor.cancelRun();
-      } on Exception catch (_) {}
+      } catch (_) {}
       yield state.copyWith(
         current: null,
         queue: state.orignalList,
@@ -132,7 +157,7 @@ class ProcessBloc extends Bloc<ProcessEvent, ProcessState> {
     } else if (event is ProcessKill) {
       try {
         _extractor.cancelRun();
-      } on Exception catch (_) {}
+      } catch (_) {}
       yield state.copyWith(
         current: state.current,
         orignalList: state.orignalList
@@ -143,7 +168,7 @@ class ProcessBloc extends Bloc<ProcessEvent, ProcessState> {
     } else if (event is ProcessRemoveAll) {
       try {
         _extractor.cancelRun();
-      } on Exception catch (_) {}
+      } catch (_) {}
       yield state.copyWith(
         current: null,
         progress: '0',
@@ -175,6 +200,13 @@ class ProcessBloc extends Bloc<ProcessEvent, ProcessState> {
         );
         yield* _extractNext();
       }
+    } else if (event is SplitModeProcessComplete) {
+      yield state.copyWith(
+          current: null,
+          log: state.log,
+          exitCode: null,
+          started: false,
+          progress: '100');
     } else if (event is ProcessFilesSubmitted) {
       yield state.copyWith(
         current: state.current,

lib/bloc/process_bloc/process_event.dart

@@ -11,10 +11,15 @@ class ProcessFilesSubmitted extends ProcessEvent {
   const ProcessFilesSubmitted(this.files);
 }
 
-class ProcessStarted extends ProcessEvent {}
+class StartAllProcess extends ProcessEvent {}
 
 /// ProcessStopped stops all the files from processing.
-class ProcessStopped extends ProcessEvent {}
+class StopAllProcess extends ProcessEvent {}
+
+/// ccx runs on all the files at once
+class StartProcessInSplitMode extends ProcessEvent {}
+
+class SplitModeProcessComplete extends ProcessEvent {}
 
 /// Removes pending file from state queue
 class ProcessFileRemoved extends ProcessEvent {

lib/bloc/settings_bloc/settings_state.dart

@@ -1,5 +1,7 @@
 part of 'settings_bloc.dart';
 
+//TODO: CurrentSettingsState sometimes makes the code messy,
+//try to change it a single class state like other bloc states
 abstract class SettingsState extends Equatable {
   const SettingsState();
 

lib/models/settings_model.dart

@@ -120,7 +120,7 @@ class SettingsModel {
   bool detectItalics;
   String confThresh;
   String whiteThresh;
-
+  bool splitMode;
   SettingsModel({
     this.out = 'auto/default',
     this.inp = 'auto/default',
@@ -216,6 +216,7 @@ class SettingsModel {
     this.detectItalics = false,
     this.confThresh = '',
     this.whiteThresh = '',
+    this.splitMode = false,
   });
 
   static Map<String, String> get paramsLookUpMap {
@@ -312,6 +313,7 @@ class SettingsModel {
       'detectItalics': '-detect_italics',
       'confThresh': '-conf_thresh',
       'whiteThresh': '-whiteness_thresh',
+      'splitMode': '', // splitMode is not a ccx setting
     };
   }
 
@@ -341,102 +343,102 @@ class SettingsModel {
     return enabledtextfields;
   }
 
-  SettingsModel copyWith({
-    String? out,
-    String? inp,
-    String? outputfilename,
-    bool? fixptsjumps,
-    bool? append,
-    String? outInterval,
-    bool? segmentonkeyonly,
-    bool? goptime,
-    bool? nogoptime,
-    bool? fixpadding,
-    bool? freqEs15,
-    String? stream,
-    bool? videoedited,
-    bool? usepicorder,
-    bool? myth,
-    bool? nomyth,
-    bool? wtvconvertfix,
-    bool? wtvmpeg2,
-    String? program_number,
-    bool? autoprogram,
-    bool? multiprogram,
-    String? streamtype,
-    bool? hauppauge,
-    bool? mp4vidtrack,
-    bool? noautotimeref,
-    bool? noscte20,
-    bool? webvttcss,
-    bool? analyzevideo,
-    bool? notimestamp,
-    bool? nolevdist,
-    String? minlevdist,
-    String? maxlevdist,
-    bool? chapters,
-    bool? bom,
-    bool? nobom,
-    String? encoder,
-    bool? nofontcolor,
-    bool? nohtmlescape,
-    bool? notypesetting,
-    bool? trim,
-    String? defaultcolor,
-    bool? sentencecap,
-    String? capFile,
-    bool? kf,
-    String? profanityFile,
-    bool? splitbysentence,
-    bool? datets,
-    bool? sects,
-    bool? latrusmap,
-    bool? xds,
-    bool? lf,
-    bool? df,
-    bool? autodash,
-    String? xmltv,
-    String? xmltvliveinterval,
-    String? xmltvoutputinterval,
-    bool? xmltvonlycurrent,
-    bool? sem,
-    String? dvblang,
-    String? mkvlang,
-    String? ocrlang,
-    String? quant,
-    String? oem,
-    bool? bufferinput,
-    bool? nobufferinput,
-    String? buffersize,
-    bool? koc,
-    bool? dru,
-    bool? norollup,
-    String? rollUp,
-    String? delay,
-    String? startat,
-    String? endat,
-    String? codec,
-    String? nocodec,
-    String? startcreditstext,
-    String? startcreditsnotbefore,
-    String? startcreditsnotafter,
-    String? startcreditsforatleast,
-    String? startcreditsforatmost,
-    String? endcreditstext,
-    String? endcreditsforatleast,
-    String? endcreditsforatmost,
-    String? tpage,
-    bool? teletext,
-    bool? noteletext,
-    bool? hardsubx,
-    bool? tickertext,
-    String? ocrMode,
-    String? subcolor,
-    String? minSubDuration,
-    bool? detectItalics,
-    String? confThresh,
-    String? whiteThresh,
-  }) {
+  SettingsModel copyWith(
+      {String? out,
+      String? inp,
+      String? outputfilename,
+      bool? fixptsjumps,
+      bool? append,
+      String? outInterval,
+      bool? segmentonkeyonly,
+      bool? goptime,
+      bool? nogoptime,
+      bool? fixpadding,
+      bool? freqEs15,
+      String? stream,
+      bool? videoedited,
+      bool? usepicorder,
+      bool? myth,
+      bool? nomyth,
+      bool? wtvconvertfix,
+      bool? wtvmpeg2,
+      String? program_number,
+      bool? autoprogram,
+      bool? multiprogram,
+      String? streamtype,
+      bool? hauppauge,
+      bool? mp4vidtrack,
+      bool? noautotimeref,
+      bool? noscte20,
+      bool? webvttcss,
+      bool? analyzevideo,
+      bool? notimestamp,
+      bool? nolevdist,
+      String? minlevdist,
+      String? maxlevdist,
+      bool? chapters,
+      bool? bom,
+      bool? nobom,
+      String? encoder,
+      bool? nofontcolor,
+      bool? nohtmlescape,
+      bool? notypesetting,
+      bool? trim,
+      String? defaultcolor,
+      bool? sentencecap,
+      String? capFile,
+      bool? kf,
+      String? profanityFile,
+      bool? splitbysentence,
+      bool? datets,
+      bool? sects,
+      bool? latrusmap,
+      bool? xds,
+      bool? lf,
+      bool? df,
+      bool? autodash,
+      String? xmltv,
+      String? xmltvliveinterval,
+      String? xmltvoutputinterval,
+      bool? xmltvonlycurrent,
+      bool? sem,
+      String? dvblang,
+      String? mkvlang,
+      String? ocrlang,
+      String? quant,
+      String? oem,
+      bool? bufferinput,
+      bool? nobufferinput,
+      String? buffersize,
+      bool? koc,
+      bool? dru,
+      bool? norollup,
+      String? rollUp,
+      String? delay,
+      String? startat,
+      String? endat,
+      String? codec,
+      String? nocodec,
+      String? startcreditstext,
+      String? startcreditsnotbefore,
+      String? startcreditsnotafter,
+      String? startcreditsforatleast,
+      String? startcreditsforatmost,
+      String? endcreditstext,
+      String? endcreditsforatleast,
+      String? endcreditsforatmost,
+      String? tpage,
+      bool? teletext,
+      bool? noteletext,
+      bool? hardsubx,
+      bool? tickertext,
+      String? ocrMode,
+      String? subcolor,
+      String? minSubDuration,
+      bool? detectItalics,
+      String? confThresh,
+      String? whiteThresh,
+      bool? splitMode}) {
     return SettingsModel(
       out: out ?? this.out,
       inp: inp ?? this.inp,
@@ -535,6 +537,7 @@ class SettingsModel {
       detectItalics: detectItalics ?? this.detectItalics,
       confThresh: confThresh ?? this.confThresh,
       whiteThresh: whiteThresh ?? this.whiteThresh,
+      splitMode: splitMode ?? this.splitMode,
     );
   }
 
@@ -634,6 +637,7 @@ class SettingsModel {
       'detectItalics': detectItalics,
       'confThresh': confThresh,
       'whiteThresh': whiteThresh,
+      'splitMode': splitMode,
     };
   }
 
@@ -733,12 +737,13 @@ class SettingsModel {
       detectItalics: map['detectItalics'],
       confThresh: map['confThresh'],
       whiteThresh: map['whiteThresh'],
+      splitMode: map['splitMode'],
     );
   }
 
   @override
   String toString() {
-    return 'SettingsModel(out: $out, inp: $inp, outputfilename: $outputfilename, fixptsjumps: $fixptsjumps, append: $append, outInterval: $outInterval, segmentonkeyonly: $segmentonkeyonly, goptime: $goptime, nogoptime: $nogoptime, fixpadding: $fixpadding, freqEs15: $freqEs15, stream: $stream, videoedited: $videoedited, usepicorder: $usepicorder, myth: $myth, nomyth: $nomyth, wtvconvertfix: $wtvconvertfix, wtvmpeg2: $wtvmpeg2, program_number: $program_number, autoprogram: $autoprogram, multiprogram: $multiprogram, streamtype: $streamtype, hauppauge: $hauppauge, mp4vidtrack: $mp4vidtrack, noautotimeref: $noautotimeref, noscte20: $noscte20, webvttcss: $webvttcss, analyzevideo: $analyzevideo, notimestamp: $notimestamp, nolevdist: $nolevdist, minlevdist: $minlevdist, maxlevdist: $maxlevdist, chapters: $chapters, bom: $bom, nobom: $nobom, encoder: $encoder, nofontcolor: $nofontcolor, nohtmlescape: $nohtmlescape, notypesetting: $notypesetting, trim: $trim, defaultcolor: $defaultcolor, sentencecap: $sentencecap, capFile: $capFile, kf: $kf, profanityFile: $profanityFile, splitbysentence: $splitbysentence, datets: $datets, sects: $sects, latrusmap: $latrusmap, xds: $xds, lf: $lf, df: $df, autodash: $autodash, xmltv: $xmltv, xmltvliveinterval: $xmltvliveinterval, xmltvoutputinterval: $xmltvoutputinterval, xmltvonlycurrent: $xmltvonlycurrent, sem: $sem, dvblang: $dvblang, mkvlang: $mkvlang, ocrlang: $ocrlang, quant: $quant, oem: $oem, bufferinput: $bufferinput, nobufferinput: $nobufferinput, buffersize: $buffersize, koc: $koc, dru: $dru, norollup: $norollup, rollUp: $rollUp, delay: $delay, startat: $startat, endat: $endat, codec: $codec, nocodec: $nocodec, startcreditstext: $startcreditstext, startcreditsnotbefore: $startcreditsnotbefore, startcreditsnotafter: $startcreditsnotafter, startcreditsforatleast: $startcreditsforatleast, startcreditsforatmost: $startcreditsforatmost, endcreditstext: $endcreditstext, endcreditsforatleast: $endcreditsforatleast, endcreditsforatmost: $endcreditsforatmost, tpage: $tpage, teletext: $teletext, noteletext: $noteletext, hardsubx: $hardsubx, tickertext: $tickertext, ocrMode: $ocrMode, subcolor: $subcolor, minSubDuration: $minSubDuration, detectItalics: $detectItalics, confThresh: $confThresh, whiteThresh: $whiteThresh)';
+    return 'SettingsModel(out: $out, inp: $inp, outputfilename: $outputfilename, fixptsjumps: $fixptsjumps, append: $append, outInterval: $outInterval, segmentonkeyonly: $segmentonkeyonly, goptime: $goptime, nogoptime: $nogoptime, fixpadding: $fixpadding, freqEs15: $freqEs15, stream: $stream, videoedited: $videoedited, usepicorder: $usepicorder, myth: $myth, nomyth: $nomyth, wtvconvertfix: $wtvconvertfix, wtvmpeg2: $wtvmpeg2, program_number: $program_number, autoprogram: $autoprogram, multiprogram: $multiprogram, streamtype: $streamtype, hauppauge: $hauppauge, mp4vidtrack: $mp4vidtrack, noautotimeref: $noautotimeref, noscte20: $noscte20, webvttcss: $webvttcss, analyzevideo: $analyzevideo, notimestamp: $notimestamp, nolevdist: $nolevdist, minlevdist: $minlevdist, maxlevdist: $maxlevdist, chapters: $chapters, bom: $bom, nobom: $nobom, encoder: $encoder, nofontcolor: $nofontcolor, nohtmlescape: $nohtmlescape, notypesetting: $notypesetting, trim: $trim, defaultcolor: $defaultcolor, sentencecap: $sentencecap, capFile: $capFile, kf: $kf, profanityFile: $profanityFile, splitbysentence: $splitbysentence, datets: $datets, sects: $sects, latrusmap: $latrusmap, xds: $xds, lf: $lf, df: $df, autodash: $autodash, xmltv: $xmltv, xmltvliveinterval: $xmltvliveinterval, xmltvoutputinterval: $xmltvoutputinterval, xmltvonlycurrent: $xmltvonlycurrent, sem: $sem, dvblang: $dvblang, mkvlang: $mkvlang, ocrlang: $ocrlang, quant: $quant, oem: $oem, bufferinput: $bufferinput, nobufferinput: $nobufferinput, buffersize: $buffersize, koc: $koc, dru: $dru, norollup: $norollup, rollUp: $rollUp, delay: $delay, startat: $startat, endat: $endat, codec: $codec, nocodec: $nocodec, startcreditstext: $startcreditstext, startcreditsnotbefore: $startcreditsnotbefore, startcreditsnotafter: $startcreditsnotafter, startcreditsforatleast: $startcreditsforatleast, startcreditsforatmost: $startcreditsforatmost, endcreditstext: $endcreditstext, endcreditsforatleast: $endcreditsforatleast, endcreditsforatmost: $endcreditsforatmost, tpage: $tpage, teletext: $teletext, noteletext: $noteletext, hardsubx: $hardsubx, tickertext: $tickertext, ocrMode: $ocrMode, subcolor: $subcolor, minSubDuration: $minSubDuration, detectItalics: $detectItalics, confThresh: $confThresh, whiteThresh: $whiteThresh, splitMode: $splitMode,)';
   }
 
   @override
@@ -839,7 +844,8 @@ class SettingsModel {
         other.minSubDuration == minSubDuration &&
         other.detectItalics == detectItalics &&
         other.confThresh == confThresh &&
-        other.whiteThresh == whiteThresh;
+        other.whiteThresh == whiteThresh &&
+        other.splitMode == splitMode;
   }
 
   @override
@@ -937,6 +943,7 @@ class SettingsModel {
         minSubDuration.hashCode ^
         detectItalics.hashCode ^
         confThresh.hashCode ^
-        whiteThresh.hashCode;
+        whiteThresh.hashCode ^
+        splitMode.hashCode;
   }
 }