sdk/pkg/dds_service_extensions/lib/dap.dart

import 'package:dap/dap.dart' as dap;
// ignore: implementation_imports
import 'package:vm_service/src/vm_service.dart' as vm;

extension DapExtension on vm.VmService {
  static bool _factoriesRegistered = false;
  Future<DapResponse> sendDapRequest(String message) async {
    return _callHelper<DapResponse>(
      'sendDapRequest',
      args: {'message': message},
    );
  }

  Future<T> _callHelper<T>(String method,
      {String? isolateId, Map args = const {}}) {
    if (!_factoriesRegistered) {
      _registerFactories();
    }
    return callMethod(
      method,
      args: {
        if (isolateId != null) 'isolateId': isolateId,
        ...args,
      },
    ).then((e) => e as T);
  }

  static void _registerFactories() {
    vm.addTypeFactory('DapResponse', DapResponse.parse);
    _factoriesRegistered = true;
  }

  Stream<vm.Event> get onDAPEvent => onEvent(DapEventStreams.kDAP);
}

class DapResponse extends vm.Response {
  static DapResponse? parse(Map<String, dynamic>? json) =>
      json == null ? null : DapResponse._fromJson(json);

  DapResponse({
    required this.dapResponse,
  });

  DapResponse._fromJson(Map<String, dynamic> json)
      : dapResponse = dap.Response.fromJson(json['dapResponse']);

  @override
  String get type => 'DapResponse';

  @override
  String toString() => '[DapResponse]';

  final dap.Response dapResponse;
}

extension DapEvents on vm.Event {
  dap.Event get dapData {
    assert(json != null);
    return dap.Event.fromJson(json!['dapData']);
  }
}

abstract class DapEventStreams extends vm.EventStreams {
  static const String kDAP = 'DAP';
}

abstract class DapEventKind extends vm.EventKind {
  /// Notification that a DAP event occurred.
  static const String kDAPEvent = 'DAPEvent';
}