pkg/compiler/lib/src/kernel/front_end_adapter.dart

// Copyright (c) 2017, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

/// Helper classes and methods to adapt between `package:compiler` and
/// `package:front_end` APIs.
library;

import 'dart:async';
import 'dart:typed_data';

// ignore: implementation_imports
import 'package:front_end/src/api_unstable/dart2js.dart' as fe;

import '../../compiler_api.dart' as api;

import '../common.dart';
import '../io/source_file.dart';

/// A front-ends's [FileSystem] that uses dart2js's [api.CompilerInput].
class CompilerFileSystem implements fe.FileSystem {
  final api.CompilerInput inputProvider;

  CompilerFileSystem(this.inputProvider);

  @override
  fe.FileSystemEntity entityForUri(Uri uri) {
    if (uri.isScheme('data')) {
      return fe.DataFileSystemEntity(Uri.base.resolveUri(uri));
    } else {
      return _CompilerFileSystemEntity(uri, this);
    }
  }
}

class _CompilerFileSystemEntity implements fe.FileSystemEntity {
  @override
  final Uri uri;
  final CompilerFileSystem fs;

  _CompilerFileSystemEntity(this.uri, this.fs);

  @override
  Future<String> readAsString() async {
    api.Input<Uint8List> input;
    try {
      input = await fs.inputProvider.readFromUri(
        uri,
        inputKind: api.InputKind.utf8,
      );
    } catch (e) {
      throw fe.FileSystemException(uri, '$e');
    }
    // TODO(sigmund): technically someone could provide dart2js with an input
    // that is not a SourceFile. Note that this assumption is also done in the
    // (non-kernel) ScriptLoader.
    SourceFile file = input as SourceFile;
    return file.slowText();
  }

  @override
  Future<Uint8List> readAsBytes() async {
    api.Input<Uint8List> input;
    try {
      input = await fs.inputProvider.readFromUri(
        uri,
        inputKind: api.InputKind.binary,
      );
    } catch (e) {
      throw fe.FileSystemException(uri, '$e');
    }
    return input.data;
  }

  @override
  Future<Uint8List> readAsBytesAsyncIfPossible() => readAsBytes();

  @override
  Future<bool> exists() async {
    try {
      await fs.inputProvider.readFromUri(uri, inputKind: api.InputKind.binary);
      return true;
    } catch (e) {
      return false;
    }
  }

  @override
  Future<bool> existsAsyncIfPossible() => exists();
}

/// Report a [message] received from the front-end, using dart2js's
/// [DiagnosticReporter].
void reportFrontEndMessage(
  DiagnosticReporter reporter,
  fe.CfeDiagnosticMessage message,
) {
  Spannable getSpannable(fe.CfeDiagnosticMessage message) {
    Uri? uri = fe.getMessageUri(message);
    int offset = fe.getMessageCharOffset(message)!;
    int length = fe.getMessageLength(message)!;
    if (uri != null && offset != -1) {
      return SourceSpan(uri, offset, offset + length);
    } else {
      return noLocationSpannable;
    }
  }

  DiagnosticMessage convertMessage(fe.CfeDiagnosticMessage message) {
    Spannable span = getSpannable(message);
    String? text = fe.getMessageHeaderText(message);
    return reporter.createMessage(span, MessageKind.generic, {
      'text': text ?? '',
    });
  }

  Iterable<fe.CfeDiagnosticMessage>? relatedInformation = fe
      .getMessageRelatedInformation(message);
  DiagnosticMessage mainMessage = convertMessage(message);
  List<DiagnosticMessage> infos = relatedInformation != null
      ? relatedInformation.map(convertMessage).toList()
      : const [];
  switch (message.severity) {
    case fe.CfeSeverity.internalProblem:
      throw mainMessage.message.message;
    case fe.CfeSeverity.error:
      reporter.reportError(mainMessage, infos);
      break;
    case fe.CfeSeverity.warning:
      reporter.reportWarning(mainMessage, infos);
      break;
    case fe.CfeSeverity.info:
      reporter.reportInfo(mainMessage, infos);
      break;
    case fe.CfeSeverity.context:
    case fe.CfeSeverity.ignored:
      throw UnimplementedError('unhandled severity ${message.severity}');
  }
}