73 lines
1.7 KiB
Dart
73 lines
1.7 KiB
Dart
import 'dart:async';
|
|
import 'dart:convert';
|
|
|
|
import 'package:fl_clash/enum/enum.dart';
|
|
import 'package:fl_clash/models/models.dart';
|
|
import 'package:flutter/foundation.dart';
|
|
|
|
import 'core.dart';
|
|
|
|
abstract mixin class ClashMessageListener {
|
|
void onLog(Log log) {}
|
|
|
|
void onTun(String fd) {}
|
|
|
|
void onDelay(Delay delay) {}
|
|
|
|
void onProcess(Metadata metadata) {}
|
|
|
|
void onNow(Now now) {}
|
|
}
|
|
|
|
class ClashMessage {
|
|
StreamSubscription? subscription;
|
|
|
|
ClashMessage._() {
|
|
if (subscription != null) {
|
|
subscription!.cancel();
|
|
subscription = null;
|
|
}
|
|
subscription = ClashCore.receiver.listen((message) {
|
|
final m = Message.fromJson(json.decode(message));
|
|
for (final ClashMessageListener listener in _listeners) {
|
|
switch (m.type) {
|
|
case MessageType.log:
|
|
listener.onLog(Log.fromJson(m.data));
|
|
break;
|
|
case MessageType.tun:
|
|
listener.onTun(m.data);
|
|
break;
|
|
case MessageType.delay:
|
|
listener.onDelay(Delay.fromJson(m.data));
|
|
break;
|
|
case MessageType.process:
|
|
listener.onProcess(Metadata.fromJson(m.data));
|
|
break;
|
|
case MessageType.now:
|
|
listener.onNow(Now.fromJson(m.data));
|
|
break;
|
|
}
|
|
}
|
|
});
|
|
}
|
|
|
|
static final ClashMessage instance = ClashMessage._();
|
|
|
|
final ObserverList<ClashMessageListener> _listeners =
|
|
ObserverList<ClashMessageListener>();
|
|
|
|
bool get hasListeners {
|
|
return _listeners.isNotEmpty;
|
|
}
|
|
|
|
void addListener(ClashMessageListener listener) {
|
|
_listeners.add(listener);
|
|
}
|
|
|
|
void removeListener(ClashMessageListener listener) {
|
|
_listeners.remove(listener);
|
|
}
|
|
}
|
|
|
|
final clashMessage = ClashMessage.instance;
|