wip: unit test BatchLogRecordProcessor

Author: yuzurihaaa

test/unit/mocks.dart

@@ -21,6 +21,8 @@ class MockSpanProcessor extends Mock implements SpanProcessor {}
 
 class MockLogRecordProcessor extends Mock implements LogRecordProcessor {}
 
+class MockLogRecordExporter extends Mock implements LogRecordExporter {}
+
 class FakeTimeProvider extends Mock implements TimeProvider {
   FakeTimeProvider({required Int64 now}) : _now = now;
   final Int64 _now;

test/unit/sdk/logs/processors/batch_log_record_processor_test.dart

@@ -0,0 +1,114 @@
+// Copyright 2021-2022 Workiva.
+// Licensed under the Apache License, Version 2.0. Please see https://github.com/Workiva/opentelemetry-dart/blob/master/LICENSE for more information
+
+@TestOn('vm')
+import 'package:fixnum/fixnum.dart';
+import 'package:mocktail/mocktail.dart';
+import 'package:opentelemetry/api.dart' as api;
+import 'package:opentelemetry/sdk.dart' as sdk;
+import 'package:opentelemetry/src/experimental_api.dart' as api;
+import 'package:opentelemetry/src/experimental_sdk.dart' as sdk;
+import 'package:opentelemetry/src/sdk/logs/log_record_limit.dart';
+import 'package:test/test.dart';
+
+import '../../../mocks.dart';
+
+void main() {
+  test('test processor', () async {
+    final exporter = MockLogRecordExporter();
+    when(() => exporter.export(any())).thenAnswer((_) async => sdk.ExportResult(code: sdk.ExportResultCode.success));
+    final processor = sdk.BatchLogRecordProcessor(
+      exporter: exporter,
+      scheduledDelayMillis: Duration.zero.inMilliseconds,
+    );
+
+    final tracer = sdk.TracerProviderBase().getTracer('test');
+    final parent = tracer.startSpan('parent');
+    final context = api.contextWithSpan(api.Context.current, parent);
+    final logRecord = sdk.LogRecord(
+        instrumentationScope: sdk.InstrumentationScope('library_name', 'library_version', 'url://schema', []),
+        logRecordLimits: LogRecordLimitsImpl(),
+        context: context,
+        timeProvider: FakeTimeProvider(now: Int64(123)));
+    final logRecordA = logRecord
+      ..body = 'test log'
+      ..severityNumber = api.Severity.fatal3;
+    processor.onEmit(logRecordA);
+
+    await Future.delayed(const Duration(milliseconds: 100));
+    verify(() => exporter.export(any<List<sdk.ReadableLogRecord>>(
+          that: predicate<List<sdk.ReadableLogRecord>>((a) {
+            final first = a.first;
+            return first.body == 'test log' &&
+                first.spanContext?.spanId == parent.spanContext.spanId &&
+                first.severityNumber == api.Severity.fatal3;
+          }),
+        ))).called(1);
+  });
+
+  test('processor shut down', () async {
+    final exporter = MockLogRecordExporter();
+    when(exporter.shutdown).thenAnswer((_) async => sdk.ExportResult(code: sdk.ExportResultCode.success));
+
+    final processor = sdk.BatchLogRecordProcessor(
+      exporter: exporter,
+      scheduledDelayMillis: Duration.zero.inMilliseconds,
+    );
+
+    await processor.shutdown();
+
+    verify(exporter.shutdown).called(1);
+  });
+
+  test('processor shut down will not emit log', () async {
+    final exporter = MockLogRecordExporter();
+    when(exporter.shutdown).thenAnswer((_) async => sdk.ExportResult(code: sdk.ExportResultCode.success));
+
+    final processor = sdk.BatchLogRecordProcessor(
+      exporter: exporter,
+      scheduledDelayMillis: Duration.zero.inMilliseconds,
+    );
+
+    await processor.shutdown();
+    final logRecord = sdk.LogRecord(
+      instrumentationScope: sdk.InstrumentationScope('library_name', 'library_version', 'url://schema', []),
+      logRecordLimits: LogRecordLimitsImpl(),
+    );
+    final logRecordA = logRecord
+      ..body = 'test log'
+      ..severityNumber = api.Severity.fatal3;
+    processor.onEmit(logRecordA);
+
+    await Future.delayed(const Duration(milliseconds: 100));
+
+    verifyNever(() => exporter.export(any()));
+  });
+
+  test('processor force flush', () async {
+    final exporter = MockLogRecordExporter();
+    when(() => exporter.export(any())).thenAnswer((_) async => sdk.ExportResult(code: sdk.ExportResultCode.success));
+
+    final processor = sdk.BatchLogRecordProcessor(
+      exporter: exporter,
+      scheduledDelayMillis: Duration(seconds: 5).inMilliseconds,
+    );
+
+    final logRecord = sdk.LogRecord(
+      instrumentationScope: sdk.InstrumentationScope('library_name', 'library_version', 'url://schema', []),
+      logRecordLimits: LogRecordLimitsImpl(),
+    );
+    final logRecordA = logRecord
+      ..body = 'test log'
+      ..severityNumber = api.Severity.fatal3;
+    processor.onEmit(logRecordA);
+
+    await processor.forceFlush();
+
+    verify(() => exporter.export(any<List<sdk.ReadableLogRecord>>(
+          that: predicate<List<sdk.ReadableLogRecord>>((a) {
+            final first = a.first;
+            return first.body == 'test log' && first.severityNumber == api.Severity.fatal3;
+          }),
+        ))).called(1);
+  });
+}