adds head request method, test methods

urusai88 · Dec 30, 2023 · ee64743 · ee64743
1 parent d0b1c49
commit ee64743
Show file tree

Hide file tree

Showing 4 changed files with 87 additions and 0 deletions.
diff --git a/lib/src/client_x.dart b/lib/src/client_x.dart
@@ -66,6 +66,23 @@ extension TioClientX<E> on Tio<E> {
         onSendProgress: onSendProgress,
       );
 
+  TioRequestProxy<T, E> head<T>(
+    String path, {
+    Object? data,
+    JSON? queryParameters,
+    Options? options,
+    CancelToken? cancelToken,
+  }) =>
+      TioRequestProxy(
+        this,
+        path,
+        method: 'HEAD',
+        data: data,
+        queryParameters: queryParameters,
+        options: options,
+        cancelToken: cancelToken,
+      );
+
   TioRequestProxy<T, E> patch<T>(
     String path, {
     Object? data,

diff --git a/test/_server.dart b/test/_server.dart
@@ -49,6 +49,20 @@ Future<void> _serverListener(HttpRequest req) async {
   final segments = req.uri.pathSegments.map((e) => e.toLowerCase()).toList();
 
   switch (segments) {
+    case ['method']:
+      final method = switch (req.method.toUpperCase().trim()) {
+        'GET' => 'GET',
+        'POST' => 'POST',
+        'PUT' => 'PUT',
+        'HEAD' => 'HEAD',
+        'PATCH' => 'PATCH',
+        'DELETE' => 'DELETE',
+        _ => 'UNKNOWN METHOD ${req.method}',
+      };
+      if (req.method.toUpperCase().trim() == 'GET') {
+        resp.headers.set('X-GET', 'TRUE');
+      }
+      resp.write(method);
     case ['long_job']:
       await Future<void>.delayed(const Duration(seconds: 10));
     case ['posts']:
@@ -99,6 +113,8 @@ Future<void> _serverListener(HttpRequest req) async {
     case ['404_json']:
       resp.statusCode = errorCode;
       _writeJson(resp, errorJson, sendStatusCode: false);
+    case _:
+      resp.write('UNKNOWN SEGMENTS $segments');
   }
 
   await resp.close();

diff --git a/test/_test_service.dart b/test/_test_service.dart
@@ -8,6 +8,24 @@ import '_typedefs.dart';
 class TestTioService extends TioService<MyResponseError> {
   const TestTioService({required super.client});
 
+  Future<MyResponse<String>> methodGet() =>
+      client.get<String>('/method').string();
+
+  Future<MyResponse<String>> methodPost() =>
+      client.post<String>('/method').string();
+
+  Future<MyResponse<String>> methodPut() =>
+      client.put<String>('/method').string();
+
+  Future<MyResponse<String>> methodHead() =>
+      client.head<String>('/method').string();
+
+  Future<MyResponse<String>> methodPatch() =>
+      client.patch<String>('/method').string();
+
+  Future<MyResponse<String>> methodDelete() =>
+      client.delete<String>('/method').string();
+
   Future<MyResponse<void>> long(CancelToken cancelToken) =>
       client.get<void>('/long_job', cancelToken: cancelToken).empty();
 

diff --git a/test/methods_test.dart b/test/methods_test.dart
@@ -0,0 +1,36 @@
+import 'package:test/test.dart';
+
+import '_internal.dart';
+
+void main() {
+  upAndDownTest();
+
+  void testMethod(String method, Future<MyResponse<String>> Function() fn) {
+    test(
+      'method $method',
+      () async => expect(
+        fn(),
+        completion(
+          isA<MySuccess<String>>().having((s) => s.result, 'result',
+              predicate((result) {
+            if (method == 'HEAD') {
+              return result == '';
+            }
+            return result == method;
+          })).having(
+            (s) => s.response?.requestOptions.method,
+            'response.requestOptions.method',
+            method,
+          ),
+        ),
+      ),
+    );
+  }
+
+  testMethod('GET', testService.methodGet);
+  testMethod('POST', testService.methodPost);
+  testMethod('PUT', testService.methodPut);
+  testMethod('HEAD', testService.methodHead);
+  testMethod('PATCH', testService.methodPatch);
+  testMethod('DELETE', testService.methodDelete);
+}