init project

.flutter-plugins

@@ -0,0 +1,7 @@
+# This is a generated file; do not edit or check into version control.
+path_provider=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider-2.0.11\\
+path_provider_android=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider_android-2.0.14\\
+path_provider_ios=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider_ios-2.0.9\\
+path_provider_linux=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider_linux-2.1.7\\
+path_provider_macos=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider_macos-2.0.6\\
+path_provider_windows=C:\\src\\flutter\\.pub-cache\\hosted\\pub.flutter-io.cn\\path_provider_windows-2.0.7\\

.flutter-plugins-dependencies

@@ -0,0 +1 @@
+{"info":"This is a generated file; do not edit or check into version control.","plugins":{"ios":[{"name":"path_provider_ios","path":"C:\\\\src\\\\flutter\\\\.pub-cache\\\\hosted\\\\pub.flutter-io.cn\\\\path_provider_ios-2.0.9\\\\","dependencies":[]}],"android":[{"name":"path_provider_android","path":"C:\\\\src\\\\flutter\\\\.pub-cache\\\\hosted\\\\pub.flutter-io.cn\\\\path_provider_android-2.0.14\\\\","dependencies":[]}],"macos":[{"name":"path_provider_macos","path":"C:\\\\src\\\\flutter\\\\.pub-cache\\\\hosted\\\\pub.flutter-io.cn\\\\path_provider_macos-2.0.6\\\\","dependencies":[]}],"linux":[{"name":"path_provider_linux","path":"C:\\\\src\\\\flutter\\\\.pub-cache\\\\hosted\\\\pub.flutter-io.cn\\\\path_provider_linux-2.1.7\\\\","dependencies":[]}],"windows":[{"name":"path_provider_windows","path":"C:\\\\src\\\\flutter\\\\.pub-cache\\\\hosted\\\\pub.flutter-io.cn\\\\path_provider_windows-2.0.7\\\\","dependencies":[]}],"web":[]},"dependencyGraph":[{"name":"path_provider","dependencies":["path_provider_android","path_provider_ios","path_provider_linux","path_provider_macos","path_provider_windows"]},{"name":"path_provider_android","dependencies":[]},{"name":"path_provider_ios","dependencies":[]},{"name":"path_provider_linux","dependencies":[]},{"name":"path_provider_macos","dependencies":[]},{"name":"path_provider_windows","dependencies":[]}],"date_created":"2022-06-20 16:26:50.607726","version":"2.10.4"}

.gitignore

@@ -0,0 +1,29 @@
+# Miscellaneous
+*.class
+*.log
+*.pyc
+*.swp
+.DS_Store
+.atom/
+.buildlog/
+.history
+.svn/
+
+# IntelliJ related
+*.iml
+*.ipr
+*.iws
+.idea/
+
+# The .vscode folder contains launch configuration and tasks you configure in
+# VS Code which you may wish to be included in version control, so this line
+# is commented out by default.
+#.vscode/
+
+# Flutter/Dart/Pub related
+# Libraries should not include pubspec.lock, per https://dart.dev/guides/libraries/private-files#pubspeclock.
+/pubspec.lock
+**/doc/api/
+.dart_tool/
+.packages
+build/

.metadata

@@ -0,0 +1,10 @@
+# This file tracks properties of this Flutter project.
+# Used by Flutter tool to assess capabilities and perform upgrades etc.
+#
+# This file should be version controlled and should not be manually edited.
+
+version:
+  revision: c860cba910319332564e1e9d470a17074c1f2dfd
+  channel: stable
+
+project_type: package

CHANGELOG.md

@@ -0,0 +1,3 @@
+## 0.0.1
+
+* TODO: Describe initial release.

LICENSE

@@ -0,0 +1 @@
+TODO: Add your license here.

README.md

@@ -0,0 +1,39 @@
+<!-- 
+This README describes the package. If you publish this package to pub.dev,
+this README's contents appear on the landing page for your package.
+
+For information about how to write a good package README, see the guide for
+[writing package pages](https://dart.dev/guides/libraries/writing-package-pages). 
+
+For general information about developing packages, see the Dart guide for
+[creating packages](https://dart.dev/guides/libraries/create-library-packages)
+and the Flutter guide for
+[developing packages and plugins](https://flutter.dev/developing-packages). 
+-->
+
+TODO: Put a short description of the package here that helps potential users
+know whether this package might be useful for them.
+
+## Features
+
+TODO: List what your package can do. Maybe include images, gifs, or videos.
+
+## Getting started
+
+TODO: List prerequisites and provide or point to information on how to
+start using the package.
+
+## Usage
+
+TODO: Include short and useful examples for package users. Add longer examples
+to `/example` folder. 
+
+```dart
+const like = 'sample';
+```
+
+## Additional information
+
+TODO: Tell users more about the package: where to find more information, how to 
+contribute to the package, how to file issues, what response they can expect 
+from the package authors, and more.

analysis_options.yaml

@@ -0,0 +1,4 @@
+include: package:flutter_lints/flutter.yaml
+
+# Additional information about this file can be found at
+# https://dart.dev/guides/language/analysis-options

lib/data_host/data_host.dart

@@ -0,0 +1,3 @@
+export 'stub/data_host.dart'
+    if (dart.library.html) 'web/data_host.dart'
+    if (dart.library.io) 'native/data_host.dart';

lib/data_host/env.dart

@@ -0,0 +1,17 @@
+import 'package:fis_common/env/env.dart';
+import 'package:fis_jsonrpc/services/platform.dart';
+
+typedef VDHSPlatformServiceGetter = PlatformService Function();
+
+class VidDataHostEnv {
+  static VDHSPlatformServiceGetter? _platformGetter;
+
+  static bool get isShell => FPlatform.isWindows || FPlatform.isMacOS;
+  // static bool get isShell => false;
+
+  static VDHSPlatformServiceGetter? get platformGetter => _platformGetter;
+
+  static void setPlatformGetter(VDHSPlatformServiceGetter getter) {
+    _platformGetter = getter;
+  }
+}

lib/data_host/interface/data_host.dart

@@ -0,0 +1,41 @@
+import 'package:fis_vid/processors/base.dart';
+import 'package:vid/us/vid_us_image.dart';
+import 'package:vid/us/vid_us_image_data.dart';
+import 'package:vid/us/vid_us_probe.dart';
+
+abstract class VidDataHostInterface {
+  VidDataHostInterface(this.url);
+
+  /// Vid文件链接
+  final String url;
+
+  /// 图像帧数
+  int get frameCount;
+
+  /// Vid Probe
+  VidUsProbe get probe;
+
+  /// 获取Vid信息
+  Future<VidUsImageData?> getData();
+
+  /// 加载文件信息
+  Future<VidDataHostLoadInfo?> load();
+
+  /// 获取帧
+  ///
+  /// [index] 帧索引
+  ///
+  /// [processors] 帧处理器集合
+  Future<VidUsImage?> getFrame<TProcessor extends VidFrameProcessor>(
+    int index, {
+    List<TProcessor>? processors,
+  });
+
+  /// 释放Host
+  Future<void> release();
+}
+
+class VidDataHostLoadInfo {
+  VidDataHostLoadInfo(this.probe);
+  final VidUsProbe probe;
+}

lib/data_host/native/data_host.dart

@@ -0,0 +1,92 @@
+import 'dart:io';
+import 'dart:isolate';
+import 'dart:typed_data';
+
+import 'package:fis_vid/data_host/interface/data_host.dart';
+import 'package:fis_vid/data_host/vid_download.dart';
+import 'package:flutter/painting.dart';
+import 'package:flutter/rendering.dart';
+import 'package:image/image.dart' as img;
+import 'package:path_provider/path_provider.dart';
+import 'package:vid/us/vid_us_image.dart';
+import 'package:fis_vid/processors/base.dart';
+import 'package:vid/us/vid_us_image_data.dart';
+import 'package:vid/us/vid_us_probe.dart';
+
+class VidDataHost implements VidDataHostInterface {
+  VidDataHost(this.url);
+  static const _kStorageDir = 'ExamRecords';
+
+  VidUsImageData? _data;
+
+  @override
+  final String url;
+
+  @override
+  VidUsProbe get probe => _data!.probe;
+
+  @override
+  int get frameCount => _data!.imageCount;
+
+  @override
+  Future<VidUsImageData?> getData() async => _data;
+
+  @override
+  Future<VidDataHostLoadInfo?> load() async {
+    final vidFileBuffer = await _loadVidFile(url);
+    if (vidFileBuffer == null) return null;
+
+    _data = VidUsImageData(vidFileBuffer);
+    return VidDataHostLoadInfo(probe);
+  }
+
+  @override
+  Future<VidUsImage> getFrame<TProcessor extends VidFrameProcessor>(
+    int index, {
+    List<TProcessor>? processors,
+  }) async {
+    if (_data == null) {
+      throw Exception(
+          "[VidDataHost] getFrame: must call load first and data is not null.");
+    }
+
+    final frame = _data!.getImage(index);
+    return VidFrameProcessor.processFrame(frame, processors);
+  }
+
+  @override
+  Future<void> release() async {
+    _data = null;
+  }
+
+  Future<Uint8List?> _loadVidFile(String url) async {
+    try {
+      final name = url.split('/').last.split('.').first;
+      final fileName = '$name.dat';
+      final cachePath = await _getStoragePath(fileName);
+      var file = File(cachePath);
+      if (await file.exists()) {
+        final buffer = await file.readAsBytes();
+        return buffer;
+      } else {
+        final buffer = await VidFileDownloader.download(url);
+        if (buffer != null) {
+          file = await file.create(recursive: true);
+          file.writeAsBytes(buffer);
+        }
+        return buffer;
+      }
+    } catch (e) {
+      return null;
+    }
+  }
+
+  Future<String> _getStoragePath(String fileName) async {
+    Directory? dir;
+    if (Platform.isAndroid) {
+      dir = await getExternalStorageDirectory();
+    }
+    dir ??= await getApplicationDocumentsDirectory();
+    return "${dir.path}/$_kStorageDir/$fileName";
+  }
+}

lib/data_host/stub/data_host.dart

@@ -0,0 +1,45 @@
+import 'package:fis_vid/data_host/interface/data_host.dart';
+import 'package:vid/us/vid_us_image.dart';
+import 'package:fis_vid/processors/base.dart';
+import 'package:vid/us/vid_us_image_data.dart';
+import 'package:vid/us/vid_us_probe.dart';
+
+class VidDataHost implements VidDataHostInterface {
+  VidDataHost(this.url);
+
+  @override
+  final String url;
+
+  @override
+  Future<VidUsImage> getFrame<TProcessor extends VidFrameProcessor>(int index,
+      {List<TProcessor>? processors}) {
+    // TODO: implement getFrame
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<VidDataHostLoadInfo?> load() {
+    // TODO: implement load
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<void> release() {
+    // TODO: implement release
+    throw UnimplementedError();
+  }
+
+  @override
+  Future<VidUsImageData?> getData() {
+    // TODO: implement getData
+    throw UnimplementedError();
+  }
+
+  @override
+  // TODO: implement probe
+  VidUsProbe get probe => throw UnimplementedError();
+
+  @override
+  // TODO: implement frameCount
+  int get frameCount => throw UnimplementedError();
+}

lib/data_host/vid_download.dart

@@ -0,0 +1,39 @@
+import 'dart:typed_data';
+
+import 'package:dio/dio.dart' as dio;
+import 'package:fis_common/logger/logger.dart';
+
+class VidFileDownloadCancel extends dio.CancelToken {}
+
+typedef VidFileDownloadProgressCallback = void Function(int count, int total);
+
+class VidFileDownloader {
+  static dio.Dio? _httpClient;
+
+  static Future<Uint8List?> download(
+    String url, {
+    VidFileDownloadCancel? cancelToken,
+    VidFileDownloadProgressCallback? onReceiveProgress,
+  }) async {
+    try {
+      _httpClient ??= dio.Dio(
+        dio.BaseOptions(
+          responseType: dio.ResponseType.bytes,
+          sendTimeout: 1 * 1000,
+          receiveTimeout: 10 * 1000,
+        ),
+      );
+
+      final response = await _httpClient!.get(
+        url,
+        cancelToken: cancelToken,
+        onReceiveProgress: onReceiveProgress,
+      );
+      final bytes = response.data as Uint8List;
+      return bytes;
+    } catch (e) {
+      logger.e("VidFileDownloader call download error", e);
+      return null;
+    }
+  }
+}

lib/data_host/web/broswer.dart

@@ -0,0 +1,47 @@
+part of 'data_host.dart';
+
+class _VidDataHostBroswer implements VidDataHostInterface {
+  _VidDataHostBroswer(this.url);
+
+  @override
+  final String url;
+
+  VidUsImageData? _data;
+
+  @override
+  int get frameCount => _data!.imageCount;
+
+  @override
+  VidUsProbe get probe => _data!.probe;
+
+  @override
+  Future<VidUsImageData?> getData() async => _data;
+
+  @override
+  Future<VidUsImage> getFrame<TProcessor extends VidFrameProcessor>(
+    int index, {
+    List<TProcessor>? processors,
+  }) async {
+    if (_data == null) {
+      throw Exception(
+          "[VidDataHost] getFrame: must call load first and data is not null.");
+    }
+    return _data!.getImage(index);
+  }
+
+  @override
+  Future<VidDataHostLoadInfo?> load() async {
+    final bytes = await VidFileDownloader.download(url);
+    if (bytes != null && bytes.isNotEmpty) {
+      _data = VidUsImageData(bytes);
+      final info = VidDataHostLoadInfo(_data!.probe);
+      return info;
+    }
+    return null;
+  }
+
+  @override
+  Future<void> release() async {
+    _data = null;
+  }
+}

lib/data_host/web/data_host.dart

@@ -0,0 +1,66 @@
+import 'dart:convert';
+import 'dart:typed_data';
+
+import 'package:fis_common/env/env.dart';
+import 'package:fis_vid/data_host/interface/data_host.dart';
+import 'package:fis_vid/data_host/vid_download.dart';
+import 'package:fis_vid/data_host/env.dart';
+import 'package:fis_vid/processors/base.dart';
+import 'package:fis_jsonrpc/rpc.dart';
+import 'package:fis_vid/processors/brightness.dart';
+import 'package:fis_vid/processors/contrast.dart';
+import 'package:flutter/painting.dart';
+import 'package:vid/us/vid_us_image.dart';
+import 'package:vid/us/vid_us_image_data.dart';
+import 'package:vid/us/vid_us_probe.dart';
+
+part 'broswer.dart';
+part 'shell.dart';
+
+class VidDataHost implements VidDataHostInterface {
+  VidDataHost(this.url);
+
+  VidDataHostInterface? _hostInstance;
+
+  @override
+  final String url;
+
+  @override
+  int get frameCount => _hostInstance!.frameCount;
+
+  @override
+  VidUsProbe get probe => _hostInstance!.probe;
+
+  @override
+  Future<VidUsImageData?> getData() async => await _hostInstance?.getData();
+
+  @override
+  Future<VidUsImage?> getFrame<TProcessor extends VidFrameProcessor>(
+    int index, {
+    List<TProcessor>? processors,
+  }) {
+    if (_hostInstance == null) {
+      throw Exception(
+          "[VidDataHost] getFrame: must call load first and data is not null.");
+    }
+    return _hostInstance!.getFrame(index, processors: processors);
+  }
+
+  @override
+  Future<VidDataHostLoadInfo?> load() async {
+    if (_hostInstance != null) {
+      await _hostInstance!.release();
+      _hostInstance = null;
+    }
+    _hostInstance = VidDataHostEnv.isShell
+        ? _VidDataHostShell(url)
+        : _VidDataHostBroswer(url);
+    return await _hostInstance!.load();
+  }
+
+  @override
+  Future<void> release() async {
+    await _hostInstance?.release();
+    _hostInstance = null;
+  }
+}

lib/data_host/web/shell.dart

@@ -0,0 +1,83 @@
+part of 'data_host.dart';
+
+class _VidDataHostShell implements VidDataHostInterface {
+  _VidDataHostShell(this.url);
+
+  static PlatformService get _platform => VidDataHostEnv.platformGetter!.call();
+
+  VidUsProbe? _probe;
+  int? _frameCount;
+
+  @override
+  final String url;
+
+  @override
+  int get frameCount => _frameCount!;
+
+  @override
+  VidUsProbe get probe => _probe!;
+
+  @override
+  Future<VidUsImageData?> getData() async => null;
+
+  @override
+  Future<VidDataHostLoadInfo?> load() async {
+    final rst = await _platform.loadVid(url);
+    if (!rst.isSuccess) return null;
+
+    final buffer = const Base64Decoder().convert(rst.probeBase64!);
+    final probe = VidUsProbe.fromBytes(buffer);
+    _probe = probe;
+    _frameCount = rst.frameCount;
+
+    final info = VidDataHostLoadInfo(probe);
+    return info;
+  }
+
+  @override
+  Future<VidUsImage?> getFrame<TProcessor extends VidFrameProcessor>(
+    int index, {
+    List<TProcessor>? processors,
+  }) async {
+    final rpcProcessors = _convert2RpcProcessors(processors);
+    final rst = await _platform.getVidFrame(GetVidFrameRequest(
+      index: index,
+      processors: rpcProcessors,
+    ));
+    if (!rst.isSuccess) return null;
+
+    final buffer = const Base64Decoder().convert(rst.frameBase64!);
+    final frame = VidUsImage.fromBytes(buffer);
+    return frame;
+  }
+
+  @override
+  Future<void> release() async {
+    _platform.releaseVid();
+  }
+
+  List<TOut>? _convert2RpcProcessors<TIn extends VidFrameProcessor,
+      TOut extends VidFrameProcessorBase>(List<TIn>? processors) {
+    if (processors == null || processors.isEmpty) return null;
+
+    final result = <TOut>[];
+    for (final processor in processors) {
+      final converted = _convert2RpcProcessor<TIn, TOut>(processor);
+      if (converted != null) {
+        result.add(converted);
+      }
+    }
+    return result;
+  }
+
+  TOut? _convert2RpcProcessor<TIn extends VidFrameProcessor,
+      TOut extends VidFrameProcessorBase>(TIn processor) {
+    if (processor is VidBrightnessProcessor) {
+      return VidFrameBrightnessProcessor(processor.brightness) as TOut;
+    }
+    if (processor is VidContrastProcessor) {
+      return VidFrameContrastProcessor(processor.contrast) as TOut;
+    }
+    return null;
+  }
+}

lib/index.dart

@@ -0,0 +1,5 @@
+library fis_vid;
+
+export 'data_host/data_host.dart';
+export 'data_host/env.dart';
+export 'processors/index.dart';

lib/processors/base.dart

@@ -0,0 +1,54 @@
+import 'dart:typed_data';
+import 'dart:ui' as ui;
+
+import 'package:flutter/painting.dart';
+import 'package:image/image.dart' as img;
+import 'package:vid/us/vid_us_image.dart';
+
+abstract class VidFrameProcessor {
+  Uint8List process(Uint8List bytes, int position);
+
+  static Future<VidUsImage> processFrame(
+    VidUsImage frame,
+    List<VidFrameProcessor>? processors,
+  ) async {
+    if (processors == null || processors.isEmpty) return frame;
+
+    try {
+      final start = DateTime.now();
+      final bitmap = await decodeImageFromList(frame.imageData);
+      final buffer = (await bitmap.toByteData())!.buffer.asUint8List();
+      final width = bitmap.width, height = bitmap.height;
+      if (processors.length == 1) {
+        final processor = processors.first;
+        for (int x = 0; x < width; x++) {
+          for (int y = 0; y < height; y++) {
+            int position = ((y * width) + x) * 4;
+            processor.process(buffer, position);
+          }
+        }
+      } else {
+        for (final processor in processors) {
+          for (int x = 0; x < width; x++) {
+            for (int y = 0; y < height; y++) {
+              int position = ((y * width) + x) * 4;
+              processor.process(buffer, position);
+            }
+          }
+        }
+      }
+      final dstImg = img.Image.fromBytes(width, height, buffer);
+      final jpgData = img.encodeJpg(dstImg);
+      final dstBuffer = Uint8List.fromList(jpgData);
+
+      final end = DateTime.now();
+      final snap = end.difference(start).inMilliseconds;
+      // print(snap);
+
+      return VidUsImage(frame.index, width, height, dstBuffer);
+    } catch (e) {
+      // ignore
+    }
+    return frame;
+  }
+}

lib/processors/brightness.dart

@@ -0,0 +1,55 @@
+import 'dart:typed_data';
+
+import 'base.dart';
+
+/// Vid亮度处理器
+class VidBrightnessProcessor extends VidFrameProcessor {
+  VidBrightnessProcessor(this.brightness) {
+    _setActualBrightness();
+  }
+
+  /// 亮度 [-255~255]
+  final int brightness;
+
+  late final int _actualBrightness;
+
+  void _setActualBrightness() {
+    if (brightness < -255) {
+      _actualBrightness = -255;
+    } else if (brightness > 255) {
+      _actualBrightness = 255;
+    } else {
+      _actualBrightness = brightness;
+    }
+  }
+
+  @override
+  Uint8List process(Uint8List bytes, int position) {
+    final i = position;
+    final _brightness = _actualBrightness;
+
+    int b = bytes[i];
+    int g = bytes[i + 1];
+    int r = bytes[i + 2];
+
+    b += _brightness;
+    g += _brightness;
+    r += _brightness;
+
+    if (b < 0) b = 0;
+    if (b > 255) b = 255;
+    if (g < 0) g = 0;
+    if (g > 255) g = 255;
+    if (r < 0) r = 0;
+    if (r > 255) r = 255;
+
+    bytes[i] = b;
+    bytes[i + 1] = g;
+    bytes[i + 2] = r;
+
+    return bytes;
+  }
+
+  @override
+  String toString() => 'VidBrightnessProcessor: $brightness';
+}

lib/processors/contrast.dart

@@ -0,0 +1,71 @@
+import 'dart:typed_data';
+
+import 'base.dart';
+
+/// Vid对比度处理器
+class VidContrastProcessor extends VidFrameProcessor {
+  VidContrastProcessor(this.contrast) {
+    _setActualContrast();
+  }
+
+  /// 对比度 [-99~99]
+  final int contrast;
+
+  late final double _actualContrast;
+
+  void _setActualContrast() {
+    double value = contrast.toDouble();
+    if (value < -100) value = -100;
+    if (value > 100) value = 100;
+    value = (100.0 + value) / 100.0;
+    value *= value;
+
+    _actualContrast = value;
+  }
+
+  @override
+  Uint8List process(Uint8List bytes, int position) {
+    final i = position;
+    final _contrast = _actualContrast;
+
+    double b = bytes[i].toDouble();
+    double g = bytes[i + 1].toDouble();
+    double r = bytes[i + 2].toDouble();
+
+    //process b
+    b = b / 255.0;
+    b -= 0.5;
+    b *= _contrast;
+    b += 0.5;
+    b *= 255;
+    if (b < 0) b = 0;
+    if (b > 255) b = 255;
+
+    //process g
+    g = g / 255.0;
+    g -= 0.5;
+    g *= _contrast;
+    g += 0.5;
+    g *= 255;
+    if (g < 0) g = 0;
+    if (g > 255) g = 255;
+
+    //process r
+    r = r / 255.0;
+    r -= 0.5;
+    r *= _contrast;
+    r += 0.5;
+    r *= 255;
+    if (r < 0) r = 0;
+    if (r > 255) r = 255;
+
+    bytes[i] = b.toInt();
+    bytes[i + 1] = g.toInt();
+    bytes[i + 2] = r.toInt();
+
+    return bytes;
+  }
+
+  @override
+  String toString() => 'VidContrastProcessor: $contrast';
+}

lib/processors/index.dart

@@ -0,0 +1,3 @@
+export 'base.dart';
+export 'brightness.dart';
+export 'contrast.dart';

lib/processors/processor.dart

@@ -0,0 +1,159 @@
+import 'dart:typed_data';
+
+class Test {
+  void run() {
+    final processor = BrightnessProcessor();
+    processor.propertyChanged.add(onPropertyChanged);
+    processor.brightness++;
+    processor.propertyChanged.remove(onPropertyChanged);
+    processor.brightness++;
+  }
+
+  onPropertyChanged(Object sender, void e) {
+    //
+    print('onPropertyChanged');
+  }
+}
+
+abstract class IImageProcessor {
+  // final propertyChanged = FEventHandler<int>();
+  late final FEventHandler<void> propertyChanged;
+
+  bool get changed;
+
+  Uint8List process(Uint8List pixelDatas);
+
+  void reset();
+}
+
+class BrightnessProcessor implements IImageProcessor {
+  int _brightness = 0;
+
+  int get brightness => _brightness;
+
+  set brightness(int value) {
+    if (_brightness != value) {
+      _brightness = value;
+
+      // OnBrightnessChanged();
+      onPropertyChanged();
+    }
+  }
+
+  @override
+  bool get changed => _brightness != 0;
+
+  @override
+  Uint8List process(Uint8List pixelDatas) {
+    if (brightness == 0) {
+      return pixelDatas;
+    }
+    int bVal = brightness;
+    if (bVal < -255) bVal = -255;
+    if (bVal > 255) bVal = 255;
+    for (int i = 0; i < pixelDatas.length - 1; i += 4) {
+      int b = pixelDatas[i];
+      int g = pixelDatas[i + 1];
+      int r = pixelDatas[i + 2];
+      b += bVal;
+      g += bVal;
+      r += bVal;
+
+      if (b < 0) b = 0;
+      if (b > 255) b = 255;
+      if (g < 0) g = 0;
+      if (g > 255) g = 255;
+      if (r < 0) r = 0;
+      if (r > 255) r = 255;
+      pixelDatas[i] = b;
+      pixelDatas[i + 1] = g;
+      pixelDatas[i + 2] = r;
+    }
+    // for (int i = 0; i < pixelDatas.length - 1; i++) {
+    //   int pixel = pixelDatas[i];
+
+    //   List<int> pixelBytes = intToBytes(pixel);
+    //   int b = pixelBytes[0];
+    //   int g = pixelBytes[1];
+    //   int r = pixelBytes[2];
+    //   b += bVal;
+    //   g += bVal;
+    //   r += bVal;
+
+    //   if (b < 0) b = 0;
+    //   if (b > 255) b = 255;
+    //   if (g < 0) g = 0;
+    //   if (g > 255) g = 255;
+    //   if (r < 0) r = 0;
+    //   if (r > 255) r = 255;
+    //   pixelBytes[0] = b;
+    //   pixelBytes[1] = g;
+    //   pixelBytes[2] = r;
+    //   ByteData data = ByteData.view(Uint8List.fromList(pixelBytes).buffer);
+    //   final rst = data.getInt32(0, Endian.host);
+    //   // final rst = bytesToInt(pixelBytes);
+    //   pixelDatas[i] = rst;
+    // }
+    return pixelDatas;
+  }
+
+  static List<int> intToBytes(int i) {
+    final bytes = List<int>.filled(4, 0, growable: false);
+    bytes[0] = i & 0xff;
+    bytes[1] = (i >> 8) & 0xff;
+    bytes[2] = (i >> 16) & 0xff;
+    bytes[3] = (i >> 24) & 0xff;
+    return bytes;
+  }
+
+  static int bytesToInt(List<int> bytes, [int offset = 0]) {
+    int value;
+    value = (bytes[offset] & 0xff) |
+        ((bytes[offset + 1] & 0xff) << 8) |
+        ((bytes[offset + 2] & 0xff) << 16) |
+        ((bytes[offset + 3] & 0xff) << 24);
+    return value;
+  }
+
+  @override
+  void reset() {
+    print('reset');
+  }
+
+  @override
+  FEventHandler<void> propertyChanged = FEventHandler<void>();
+
+  void onPropertyChanged() {
+    propertyChanged.emit(this, null);
+  }
+}
+
+typedef FEventCallback<T> = void Function(
+  Object sender,
+  T e,
+);
+
+class FEventHandler<T> {
+  List<FEventCallback<T>>? _callbacks;
+
+  void emit(Object sender, T e) {
+    if (_callbacks != null && _callbacks!.isNotEmpty) {
+      for (final callback in _callbacks!) {
+        callback.call(sender, e);
+      }
+    }
+  }
+
+  void add(FEventCallback<T> callback) {
+    _callbacks ??= [];
+    _callbacks!.add(callback);
+  }
+
+  void remove(FEventCallback<T> callback) {
+    if (_callbacks == null) return;
+
+    if (_callbacks!.contains(callback)) {
+      _callbacks!.remove(callback);
+    }
+  }
+}

pubspec.yaml

@@ -0,0 +1,73 @@
+name: fis_vid
+description: A new Flutter package project.
+version: 0.0.1
+homepage:
+publish_to: none
+
+environment:
+  sdk: ">=2.16.2 <3.0.0"
+  flutter: ">=1.17.0"
+
+dependencies:
+  flutter:
+    sdk: flutter
+  vid:
+    git:
+      url: http://git.ius.plus:88/Project-Wing/flutter_vid
+  fis_common:
+    git:
+      url: http://git.ius.plus/Project-Wing/fis_lib_common.git
+      ref: ^1.0.7+1
+  fis_jsonrpc:
+    git:
+      url: http://git.ius.plus:88/Project-Wing/fis_lib_jsonrpc.git
+      ref: ^1.1.0     
+  image: 3.1.3     
+
+dependency_overrides:
+  fis_common:
+    git:
+      url: http://git.ius.plus:88/Project-Wing/fis_lib_common.git
+      ref: 1.0.7+1        
+
+dev_dependencies:
+  flutter_test:
+    sdk: flutter
+  flutter_lints: ^1.0.0
+
+# For information on the generic Dart part of this file, see the
+# following page: https://dart.dev/tools/pub/pubspec
+
+# The following section is specific to Flutter.
+flutter:
+
+  # To add assets to your package, add an assets section, like this:
+  # assets:
+  #   - images/a_dot_burr.jpeg
+  #   - images/a_dot_ham.jpeg
+  #
+  # For details regarding assets in packages, see
+  # https://flutter.dev/assets-and-images/#from-packages
+  #
+  # An image asset can refer to one or more resolution-specific "variants", see
+  # https://flutter.dev/assets-and-images/#resolution-aware.
+
+  # To add custom fonts to your package, add a fonts section here,
+  # in this "flutter" section. Each entry in this list should have a
+  # "family" key with the font family name, and a "fonts" key with a
+  # list giving the asset and other descriptors for the font. For
+  # example:
+  # fonts:
+  #   - family: Schyler
+  #     fonts:
+  #       - asset: fonts/Schyler-Regular.ttf
+  #       - asset: fonts/Schyler-Italic.ttf
+  #         style: italic
+  #   - family: Trajan Pro
+  #     fonts:
+  #       - asset: fonts/TrajanPro.ttf
+  #       - asset: fonts/TrajanPro_Bold.ttf
+  #         weight: 700
+  #
+  # For details regarding fonts in packages, see
+  # https://flutter.dev/custom-fonts/#from-packages

test/fis_lib_vid_test.dart

@@ -0,0 +1,5 @@
+import 'package:flutter_test/flutter_test.dart';
+
+void main() {
+  test('adds one to input values', () {});
+}