blob: 2de0f5129d095aece5164ea83f8d89398a6b5924 [file] [log] [blame]
// Copyright 2018 The Fuchsia Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
import 'dart:async';
import 'package:flutter/material.dart';
import 'package:xi_client/client.dart';
import 'editor.dart';
import 'line_cache.dart';
/// A notification called when the document has changed.
typedef DocumentChangeNotification = void Function(Document event);
/// Stores and manages updates to the state for a Xi document, and provides
/// access to the editing API to the [Editor], via the [XiViewProxy].
class Document extends Stream<Document> implements XiViewHandler {
final LineCache lines = new LineCache(TextStyle(color:;
final TextStyle _defaultStyle = const TextStyle(color: Colors.white);
/// A connection to xi-core.
XiViewProxy _viewProxy;
final StreamController<Document> _controller;
Document() : _controller = new StreamController.broadcast();
List<Completer<XiViewProxy>> _pending = [];
/// Provides access to the [XiViewProxy] via a [Future].
/// Because view creation is asynchronous, we cannot get a handle to the
/// [XiViewProxy] until after the document has been created. By returning
/// a [Future], we allow the [Editor] to call edit API methods before the
/// view has been resolved.
Future<XiViewProxy> get viewProxy {
if (_viewProxy != null) {
return Future.value(_viewProxy);
final completer = new Completer();
return completer.future;
// Assigns the XiViewProxy. This should only be called once,
// by the root [XiHandler] when the 'new_view' request first resolves.
void finalizeViewProxy(XiViewProxy newViewProxy) {
assert(_viewProxy == null);
_viewProxy = newViewProxy;
for (var completer in _pending) {
_pending = null;
LineCol _scrollPos = new LineCol(line: 0, col: 0);
LineCol get scrollPos => _scrollPos;
double _measureWidth(String s) {
TextSpan span = new TextSpan(text: s, style: _defaultStyle);
TextPainter painter =
new TextPainter(text: span, textDirection: TextDirection.ltr)..layout();
return painter.width;
List<List<double>> measureWidths(List<Map<String, dynamic>> params) {
List<List<double>> result = <List<double>>[];
for (Map<String, dynamic> req in params) {
List<double> inner = <double>[];
List<String> strings = req['strings'];
for (String s in strings) {
return result;
void _notifyListeners() {
void close() {
void scrollTo(int line, int col) {
_scrollPos = new LineCol(line: line, col: col);
void update(List<Map<String, dynamic>> params) {
StreamSubscription<Document> listen(void Function(Document event) onData,
{Function onError, void Function() onDone, bool cancelOnError}) {
return, onError: onError, onDone: onDone);