feat: calculations

frontend/appflowy_flutter/integration_test/database/database_field_test.dart

@@ -39,12 +39,7 @@ void main() {
  await tester.createNewPageWithNameUnderParent(layout: ViewLayoutPB.Grid);
 
  // Invoke the field editor
- await tester.tapGridFieldWithName('Type');
- await tester.tapEditFieldButton();
-
- await tester.tapSwitchFieldTypeButton();
- await tester.selectFieldType(FieldType.Checkbox);
- await tester.dismissFieldEditor();
+ await tester.changeFieldTypeOfFieldWithName('Type', FieldType.Checkbox);
 
  await tester.assertFieldTypeWithFieldName(
  'Type',

frontend/appflowy_flutter/integration_test/grid/grid_calculations_test.dart

@@ -0,0 +1,107 @@
+import 'package:appflowy_backend/protobuf/flowy-database2/protobuf.dart';
+import 'package:appflowy_backend/protobuf/flowy-folder/view.pbenum.dart';
+import 'package:flutter/services.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:integration_test/integration_test.dart';
+
+import '../util/database_test_op.dart';
+import '../util/util.dart';
+
+void main() {
+ IntegrationTestWidgetsFlutterBinding.ensureInitialized();
+
+ group('Grid Calculations', () {
+ testWidgets('add calculation and update cell', (tester) async {
+ await tester.initializeAppFlowy();
+ await tester.tapGoButton();
+
+ await tester.createNewPageWithNameUnderParent(layout: ViewLayoutPB.Grid);
+
+ // Change one Field to Number
+ await tester.changeFieldTypeOfFieldWithName('Type', FieldType.Number);
+
+ expect(find.text('Calculate'), findsOneWidget);
+
+ await tester.changeCalculateAtIndex(1, CalculationType.Sum);
+
+ // Enter values in cells
+ await tester.editCell(
+ rowIndex: 0,
+ fieldType: FieldType.Number,
+ input: '100',
+ );
+
+ await tester.editCell(
+ rowIndex: 1,
+ fieldType: FieldType.Number,
+ input: '100',
+ );
+
+ // Dismiss edit cell
+ await tester.sendKeyDownEvent(LogicalKeyboardKey.enter);
+
+ await tester.pumpAndSettle(const Duration(seconds: 1));
+
+ expect(find.text('200'), findsOneWidget);
+ });
+
+ testWidgets('add calculations and remove row', (tester) async {
+ await tester.initializeAppFlowy();
+ await tester.tapGoButton();
+
+ await tester.createNewPageWithNameUnderParent(layout: ViewLayoutPB.Grid);
+
+ // Change two Fields to Number
+ await tester.changeFieldTypeOfFieldWithName('Type', FieldType.Number);
+ await tester.changeFieldTypeOfFieldWithName('Done', FieldType.Number);
+
+ expect(find.text('Calculate'), findsNWidgets(2));
+
+ await tester.changeCalculateAtIndex(1, CalculationType.Sum);
+ await tester.changeCalculateAtIndex(2, CalculationType.Min);
+
+ // Enter values in cells
+ await tester.editCell(
+ rowIndex: 0,
+ fieldType: FieldType.Number,
+ input: '100',
+ );
+ await tester.editCell(
+ rowIndex: 1,
+ fieldType: FieldType.Number,
+ input: '150',
+ );
+ await tester.editCell(
+ rowIndex: 0,
+ fieldType: FieldType.Number,
+ input: '50',
+ cellIndex: 1,
+ );
+ await tester.editCell(
+ rowIndex: 1,
+ fieldType: FieldType.Number,
+ input: '100',
+ cellIndex: 1,
+ );
+
+ await tester.pumpAndSettle();
+
+ // Dismiss edit cell
+ await tester.sendKeyDownEvent(LogicalKeyboardKey.enter);
+ await tester.pumpAndSettle();
+
+ expect(find.text('250'), findsOneWidget);
+ expect(find.text('50'), findsNWidgets(2));
+
+ // Delete 1st row
+ await tester.hoverOnFirstRowOfGrid();
+ await tester.tapRowMenuButtonInGrid();
+ await tester.tapDeleteOnRowMenu();
+
+ await tester.pumpAndSettle(const Duration(seconds: 1));
+
+ expect(find.text('150'), findsNWidgets(2));
+ expect(find.text('100'), findsNWidgets(2));
+ });
+ });
+}

frontend/appflowy_flutter/integration_test/util/database_test_op.dart

@@ -1,5 +1,8 @@
 import 'dart:io';
 
+import 'package:appflowy/plugins/database/application/calculations/calculation_type_ext.dart';
+import 'package:appflowy/plugins/database/grid/presentation/widgets/calculations/calculate_cell.dart';
+import 'package:appflowy/plugins/database/grid/presentation/widgets/calculations/calculation_type_item.dart';
 import 'package:appflowy/plugins/database/grid/presentation/widgets/common/type_option_separator.dart';
 import 'package:appflowy/plugins/database/grid/presentation/widgets/header/type_option/number.dart';
 import 'package:appflowy/plugins/database/widgets/cell/editable_cell_skeleton/checkbox.dart';
@@ -717,6 +720,31 @@ extension AppFlowyDatabaseTest on WidgetTester {
  await pumpAndSettle();
  }
 
+ Future<void> changeFieldTypeOfFieldWithName(
+ String name,
+ FieldType type,
+ ) async {
+ await tapGridFieldWithName(name);
+ await tapEditFieldButton();
+
+ await tapSwitchFieldTypeButton();
+ await selectFieldType(type);
+ await dismissFieldEditor();
+ }
+
+ Future<void> changeCalculateAtIndex(int index, CalculationType type) async {
+ await tap(find.byType(CalculateCell).at(index));
+ await pumpAndSettle();
+
+ await tap(
+ find.descendant(
+ of: find.byType(CalculationTypeItem),
+ matching: find.text(type.label),
+ ),
+ );
+ await pumpAndSettle();
+ }
+
  /// Should call [tapGridFieldWithName] first.
  Future<void> tapEditFieldButton() async {
  await tapButtonWithName(LocaleKeys.grid_field_editProperty.tr());

frontend/appflowy_flutter/lib/plugins/database/application/calculations/calculation_type_ext.dart

@@ -0,0 +1,18 @@
+import 'package:appflowy/generated/locale_keys.g.dart';
+import 'package:appflowy_backend/protobuf/flowy-database2/protobuf.dart';
+import 'package:easy_localization/easy_localization.dart';
+
+extension CalcTypeLabel on CalculationType {
+ String get label => switch (this) {
+ CalculationType.Average =>
+ LocaleKeys.grid_calculationTypeLabel_average.tr(),
+ CalculationType.Max => LocaleKeys.grid_calculationTypeLabel_max.tr(),
+ CalculationType.Median =>
+ LocaleKeys.grid_calculationTypeLabel_median.tr(),
+ CalculationType.Min => LocaleKeys.grid_calculationTypeLabel_min.tr(),
+ CalculationType.Sum => LocaleKeys.grid_calculationTypeLabel_sum.tr(),
+ _ => throw UnimplementedError(
+ 'Label for $this has not been implemented',
+ ),
+ };
+}

frontend/appflowy_flutter/lib/plugins/database/application/calculations/calculations_listener.dart

@@ -0,0 +1,54 @@
+import 'dart:async';
+import 'dart:typed_data';
+
+import 'package:appflowy/core/notification/grid_notification.dart';
+import 'package:appflowy_backend/protobuf/flowy-database2/protobuf.dart';
+import 'package:appflowy_backend/protobuf/flowy-error/errors.pb.dart';
+import 'package:dartz/dartz.dart';
+import 'package:flowy_infra/notifier.dart';
+
+typedef UpdateCalculationValue
+ = Either<CalculationChangesetNotificationPB, FlowyError>;
+
+class CalculationsListener {
+ CalculationsListener({required this.viewId});
+
+ final String viewId;
+
+ PublishNotifier<UpdateCalculationValue>? _calculationNotifier =
+ PublishNotifier();
+ DatabaseNotificationListener? _listener;
+
+ void start({
+ required void Function(UpdateCalculationValue) onCalculationChanged,
+ }) {
+ _calculationNotifier?.addPublishListener(onCalculationChanged);
+ _listener = DatabaseNotificationListener(
+ objectId: viewId,
+ handler: _handler,
+ );
+ }
+
+ void _handler(
+ DatabaseNotification ty,
+ Either<Uint8List, FlowyError> result,
+ ) {
+ switch (ty) {
+ case DatabaseNotification.DidUpdateCalculation:
+ _calculationNotifier?.value = result.fold(
+ (payload) => left(
+ CalculationChangesetNotificationPB.fromBuffer(payload),
+ ),
+ (err) => right(err),
+ );
+ default:
+ break;
+ }
+ }
+
+ Future<void> stop() async {
+ await _listener?.stop();
+ _calculationNotifier?.dispose();
+ _calculationNotifier = null;
+ }
+}

frontend/appflowy_flutter/lib/plugins/database/application/calculations/calculations_service.dart

@@ -0,0 +1,46 @@
+import 'package:appflowy_backend/dispatch/dispatch.dart';
+import 'package:appflowy_backend/protobuf/flowy-database2/protobuf.dart';
+import 'package:appflowy_backend/protobuf/flowy-error/errors.pb.dart';
+import 'package:dartz/dartz.dart';
+
+class CalculationsBackendService {
+ const CalculationsBackendService({required this.viewId});
+
+ final String viewId;
+
+ // Get Calculations (initial fetch)
+ Future<Either<RepeatedCalculationsPB, FlowyError>> getCalculations() async {
+ final payload = DatabaseViewIdPB()..value = viewId;
+
+ return DatabaseEventGetAllCalculations(payload).send();
+ }
+
+ Future<void> updateCalculation(
+ String fieldId,
+ CalculationType type, {
+ String? calculationId,
+ }) async {
+ final payload = UpdateCalculationChangesetPB()
+ ..viewId = viewId
+ ..fieldId = fieldId
+ ..calculationType = type;
+
+ if (calculationId != null) {
+ payload.calculationId = calculationId;
+ }
+
+ await DatabaseEventUpdateCalculation(payload).send();
+ }
+
+ Future<void> removeCalculation(
+ String fieldId,
+ String calculationId,
+ ) async {
+ final payload = RemoveCalculationChangesetPB()
+ ..viewId = viewId
+ ..fieldId = fieldId
+ ..calculationId = calculationId;
+
+ await DatabaseEventRemoveCalculation(payload).send();
+ }
+}