api: Add route setTypingStatus.

The two legacy cases will need to be dropped separately at different
server versions. The tests will fail accordingly as we do that.

Signed-off-by: Zixuan James Li <[email protected]>

Author: PIG208

lib/api/model/events.dart

@@ -1002,7 +1002,9 @@ class TypingEvent extends Event {
 @JsonEnum(fieldRename: FieldRename.snake)
 enum TypingOp {
   start,
-  stop
+  stop;
+
+  String toJson() => _$TypingOpEnumMap[this]!;
 }
 
 /// A Zulip event of type `reaction`, with op `add` or `remove`.

lib/api/model/events.g.dart

@@ -0,0 +1,28 @@
+import '../core.dart';
+import '../model/events.dart';
+import 'messages.dart';
+
+
+/// https://zulip.com/api/set-typing-status
+Future<void> setTypingStatus(ApiConnection connection, {
+  required TypingOp op,
+  required MessageDestination destination,
+}) {
+  switch (destination) {
+    case StreamDestination():
+      final supportsTypeChannel = connection.zulipFeatureLevel! >= 248; // TODO(server-9)
+      final supportsStreamId = connection.zulipFeatureLevel! >= 215; // TODO(server-8)
+      return connection.post('setTypingStatus', (_) {}, 'typing', {
+        'type':  RawParameter((supportsTypeChannel) ? 'channel' : 'stream'),
+        'op':    RawParameter(op.toJson()),
+        'topic': RawParameter(destination.topic),
+        ...(supportsStreamId) ? {'stream_id': destination.streamId}
+                              : {'to': [destination.streamId]}
+      });
+    case DmDestination():
+      return connection.post('setTypingStatus', (_) {}, 'typing', {
+        'op': RawParameter(op.toJson()),
+        'to': destination.userIds,
+      });
+  }
+}

lib/api/route/typing.dart

@@ -0,0 +1,89 @@
+import 'dart:convert';
+
+import 'package:http/http.dart' as http;
+import 'package:checks/checks.dart';
+import 'package:flutter_test/flutter_test.dart';
+import 'package:zulip/api/model/events.dart';
+import 'package:zulip/api/route/messages.dart';
+import 'package:zulip/api/route/typing.dart';
+
+import '../../stdlib_checks.dart';
+import '../fake_api.dart';
+
+void main() {
+  const streamId = 123;
+  const topic = 'topic';
+  const userIds = [101, 102, 103];
+
+  Future<void> checkSetTypingStatus(FakeApiConnection connection, TypingOp op, {
+    required MessageDestination destination,
+    required Map<String, String> expectedBodyFields,
+  }) async {
+    connection.prepare(json: {});
+    await setTypingStatus(connection, op: op, destination: destination);
+    check(connection.lastRequest).isA<http.Request>()
+      ..method.equals('POST')
+      ..url.path.equals('/api/v1/typing')
+      ..bodyFields.deepEquals(expectedBodyFields);
+  }
+
+  Future<void> checkTopicExpectedOp(TypingOp op, String expectedOp) =>
+    FakeApiConnection.with_((connection) =>
+      checkSetTypingStatus(connection, op,
+        destination: const StreamDestination(streamId, topic),
+        expectedBodyFields: {
+          'type': 'channel',
+          'op': expectedOp,
+          'stream_id': streamId.toString(),
+          'topic': topic,
+        }));
+
+  test('send typing status start to topic', () {
+    return checkTopicExpectedOp(TypingOp.start, 'start');
+  });
+
+  test('send typing status stop to topic', () {
+    return checkTopicExpectedOp(TypingOp.stop, 'stop');
+  });
+
+  Future<void> checkDmExpectedOp(TypingOp op, String expectedOp) =>
+    FakeApiConnection.with_((connection) =>
+      checkSetTypingStatus(connection, op,
+        destination: const DmDestination(userIds: userIds),
+        expectedBodyFields: {
+          'op': expectedOp,
+          'to': jsonEncode(userIds),
+        }));
+
+  test('send typing status start to dm', () {
+    return checkDmExpectedOp(TypingOp.start, 'start');
+  });
+
+  test('send typing status stop to dm', () {
+    return checkDmExpectedOp(TypingOp.stop, 'stop');
+  });
+
+  test('use stream on legacy server', () {
+    return FakeApiConnection.with_(zulipFeatureLevel: 247, (connection) =>
+      checkSetTypingStatus(connection, TypingOp.start,
+        destination: const StreamDestination(streamId, topic),
+        expectedBodyFields: {
+          'type': 'stream',
+          'op': 'start',
+          'stream_id': streamId.toString(),
+          'topic': topic,
+        }));
+  });
+
+  test('use to=[streamId] on legacy server', () {
+    return FakeApiConnection.with_(zulipFeatureLevel: 214, (connection) =>
+      checkSetTypingStatus(connection, TypingOp.start,
+        destination: const StreamDestination(streamId, topic),
+        expectedBodyFields: {
+          'type': 'stream',
+          'op': 'start',
+          'to': jsonEncode([streamId]),
+          'topic': topic,
+        }));
+  });
+}