Zakaria
130 lines
3.6 KiB
Dart
130 lines
3.6 KiB
Dart
import 'dart:async';
|
|
import 'dart:collection';
|
|
|
|
import 'package:chopper/chopper.dart' as chopper;
|
|
import 'package:chopper/src/chopper_log_record.dart';
|
|
import 'package:logging/logging.dart';
|
|
|
|
/// A logger that aggregates the request and response logs from Chopper.
|
|
/// Once a request (or response) is completed,
|
|
/// the whole request log is flushed to the delegated chopperLogger.
|
|
///
|
|
/// All other operations are delegated by default.
|
|
class ChopperAggregateLogger implements Logger {
|
|
final Logger _delegate = chopper.chopperLogger;
|
|
|
|
final Map<chopper.Request, StringBuffer> _requests = HashMap();
|
|
|
|
final Map<chopper.Response, StringBuffer> _responses = HashMap();
|
|
|
|
@override
|
|
String get name => _delegate.name;
|
|
|
|
@override
|
|
String get fullName => _delegate.fullName;
|
|
|
|
@override
|
|
Logger? get parent => _delegate.parent;
|
|
|
|
@override
|
|
Level get level => _delegate.level;
|
|
|
|
@override
|
|
set level(Level? value) {
|
|
_delegate.level = value;
|
|
}
|
|
|
|
@override
|
|
Map<String, Logger> get children => _delegate.children;
|
|
|
|
@override
|
|
void log(Level logLevel, Object? message,
|
|
[Object? error, StackTrace? stackTrace, Zone? zone]) {
|
|
if (message is ChopperLogRecord) {
|
|
if (message.request != null) {
|
|
_requests[message.request]?.writeln(message.message);
|
|
return;
|
|
} else if (message.response != null) {
|
|
_responses[message.response]?.writeln(message.message);
|
|
return;
|
|
}
|
|
}
|
|
_delegate.log(logLevel, message, error, stackTrace, zone);
|
|
}
|
|
|
|
void onStartRequest(chopper.Request request) {
|
|
_requests[request] = StringBuffer();
|
|
}
|
|
|
|
void onEndRequest(chopper.Request request) {
|
|
info(_censorSensitiveLog(_requests.remove(request)?.toString().trim()));
|
|
}
|
|
|
|
void onStartResponse(chopper.Response response) {
|
|
_responses[response] = StringBuffer();
|
|
}
|
|
|
|
void onEndResponse(chopper.Response response) {
|
|
info(_censorSensitiveLog(_responses.remove(response)?.toString().trim()));
|
|
}
|
|
|
|
String? _censorSensitiveLog(String? message) {
|
|
if (message == null) {
|
|
return null;
|
|
}
|
|
|
|
return message
|
|
.replaceAll(RegExp(r'Token="[^"]*"'), 'Token="TOKEN"')
|
|
.replaceAll(RegExp(r'"Username":"[^"]*"'), '"Username":"USER"')
|
|
.replaceAll(RegExp(r'"Pw":"[^"]*"'), '"Pw":"PASSWORD"');
|
|
}
|
|
|
|
@override
|
|
Stream<Level?> get onLevelChanged => _delegate.onLevelChanged;
|
|
|
|
@override
|
|
Stream<LogRecord> get onRecord => _delegate.onRecord;
|
|
|
|
@override
|
|
void clearListeners() {
|
|
_delegate.clearListeners();
|
|
}
|
|
|
|
@override
|
|
bool isLoggable(Level value) {
|
|
return _delegate.isLoggable(value);
|
|
}
|
|
|
|
@override
|
|
void finest(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.FINEST, message, error, stackTrace);
|
|
|
|
@override
|
|
void finer(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.FINER, message, error, stackTrace);
|
|
|
|
@override
|
|
void fine(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.FINE, message, error, stackTrace);
|
|
|
|
@override
|
|
void config(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.CONFIG, message, error, stackTrace);
|
|
|
|
@override
|
|
void info(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.INFO, message, error, stackTrace);
|
|
|
|
@override
|
|
void warning(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.WARNING, message, error, stackTrace);
|
|
|
|
@override
|
|
void severe(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.SEVERE, message, error, stackTrace);
|
|
|
|
@override
|
|
void shout(Object? message, [Object? error, StackTrace? stackTrace]) =>
|
|
log(Level.SHOUT, message, error, stackTrace);
|
|
}
|