user_service.dart 2.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. import 'dart:async';
  2. import 'package:dartz/dartz.dart';
  3. import 'package:flowy_sdk/dispatch/dispatch.dart';
  4. import 'package:flowy_sdk/protobuf/flowy-error/errors.pb.dart';
  5. import 'package:flowy_sdk/protobuf/flowy-folder/workspace.pb.dart';
  6. import 'package:flowy_sdk/protobuf/flowy-user/user_profile.pb.dart';
  7. class UserService {
  8. final String userId;
  9. UserService({
  10. required this.userId,
  11. });
  12. Future<Either<UserProfilePB, FlowyError>> getUserProfile(
  13. {required String userId}) {
  14. return UserEventGetUserProfile().send();
  15. }
  16. Future<Either<Unit, FlowyError>> updateUserProfile({
  17. String? name,
  18. String? password,
  19. String? email,
  20. String? iconUrl,
  21. }) {
  22. var payload = UpdateUserProfilePayloadPB.create()..id = userId;
  23. if (name != null) {
  24. payload.name = name;
  25. }
  26. if (password != null) {
  27. payload.password = password;
  28. }
  29. if (email != null) {
  30. payload.email = email;
  31. }
  32. if (iconUrl != null) {
  33. payload.iconUrl = iconUrl;
  34. }
  35. return UserEventUpdateUserProfile(payload).send();
  36. }
  37. Future<Either<Unit, FlowyError>> deleteWorkspace(
  38. {required String workspaceId}) {
  39. throw UnimplementedError();
  40. }
  41. Future<Either<Unit, FlowyError>> signOut() {
  42. return UserEventSignOut().send();
  43. }
  44. Future<Either<Unit, FlowyError>> initUser() async {
  45. return UserEventInitUser().send();
  46. }
  47. Future<Either<List<WorkspacePB>, FlowyError>> getWorkspaces() {
  48. final request = WorkspaceIdPB.create();
  49. return FolderEventReadWorkspaces(request).send().then((result) {
  50. return result.fold(
  51. (workspaces) => left(workspaces.items),
  52. (error) => right(error),
  53. );
  54. });
  55. }
  56. Future<Either<WorkspacePB, FlowyError>> openWorkspace(String workspaceId) {
  57. final request = WorkspaceIdPB.create()..value = workspaceId;
  58. return FolderEventOpenWorkspace(request).send().then((result) {
  59. return result.fold(
  60. (workspace) => left(workspace),
  61. (error) => right(error),
  62. );
  63. });
  64. }
  65. Future<Either<WorkspacePB, FlowyError>> createWorkspace(
  66. String name, String desc) {
  67. final request = CreateWorkspacePayloadPB.create()
  68. ..name = name
  69. ..desc = desc;
  70. return FolderEventCreateWorkspace(request).send().then((result) {
  71. return result.fold(
  72. (workspace) => left(workspace),
  73. (error) => right(error),
  74. );
  75. });
  76. }
  77. }