AppFlowy/app_flowy/lib/workspace/infrastructure/i_app_impl.dart

import 'package:app_flowy/workspace/infrastructure/repos/app_repo.dart';
import 'package:app_flowy/workspace/infrastructure/repos/doc_repo.dart';
import 'package:dartz/dartz.dart';
import 'package:flowy_sdk/protobuf/flowy-workspace/errors.pb.dart';
import 'package:app_flowy/workspace/domain/i_app.dart';
import 'package:flowy_sdk/protobuf/flowy-workspace/view_create.pb.dart';
export 'package:app_flowy/workspace/domain/i_app.dart';

class IAppImpl extends IApp {
  AppRepository repo;
  IAppImpl({
    required this.repo,
  });

  @override
  Future<Either<List<View>, WorkspaceError>> getViews() {
    return repo.getViews();
  }

  @override
  Future<Either<View, WorkspaceError>> createView(
      {required String name, String? desc, required ViewType viewType}) {
    return repo.createView(name, desc ?? "", viewType).then((result) {
      return result.fold(
        (view) => _createDoc(view),
        (r) => right(r),
      );
    });
  }

  Future<Either<View, WorkspaceError>> _createDoc(View view) async {
    switch (view.viewType) {
      case ViewType.Doc:
        final docRepo = DocRepository(docId: view.id);
        final result = await docRepo.createDoc(name: view.name, desc: "");
        return result.fold((l) => left(view), (r) => left(view));
      default:
        return left(view);
    }
  }
}

class IAppWatchImpl extends IAppWatch {
  AppWatchRepository repo;
  IAppWatchImpl({
    required this.repo,
  });

  @override
  void startWatching(
      {AppAddViewCallback? addViewCallback,
      AppUpdatedCallback? updatedCallback}) {
    repo.startWatching(
        addViewCallback: addViewCallback, updatedCallback: updatedCallback);
  }

  @override
  Future<void> stopWatching() async {
    await repo.close();
  }
}