import 'dart:async';

import 'package:flutter/services.dart';

import 'amap_marker.dart';

class AmapViewController {
  MethodChannel _methodChannel;

  StreamController _guideStreamController;
  Stream<Map> get guideStream => _guideStreamController.stream;

  void init(int id) {
    _methodChannel = MethodChannel("com.i2edu.mapView/map_view_$id");
    _methodChannel.setMethodCallHandler(platformCallHandler);
    _guideStreamController = StreamController<Map>.broadcast();
  }

  Future<void> platformCallHandler(MethodCall call) async {
    try {
      if (call.method == "guide") {
        _guideStreamController.add(call.arguments);
      }
    } catch (ex) {
      print('Unexpected error: $ex');
    }
    return null;
  }

  Future<void> setMapMarkers(List<AmapMarker> markers) async {
    assert(_methodChannel != null);
    return await _methodChannel.invokeMethod(
        "setMarkers", {"markers": markers.map((f) => f.toMap()).toList()});
  }

  Future<void> onCreateMapView() async {
    assert(_methodChannel != null);
    return await _methodChannel.invokeMethod('onCreate');
  }

  Future<void> onPauseMapView() async {
    assert(_methodChannel != null);
    return await _methodChannel.invokeMethod('onPause');
  }

  Future<void> onResumeMapView() async {
    assert(_methodChannel != null);
    return await _methodChannel.invokeMethod('onResume');
  }

  void dispose() {
    if (!_guideStreamController.isClosed) {
      _guideStreamController.close();
    }
  }
}