| // Copyright 2019 The Flutter Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| import 'dart:convert'; |
| import 'dart:typed_data'; |
| |
| import 'package:cocoon_service/src/request_handling/body.dart'; |
| import 'package:cocoon_service/src/request_handling/cache_request_handler.dart'; |
| import 'package:cocoon_service/src/service/cache_service.dart'; |
| import 'package:test/test.dart'; |
| |
| import '../src/datastore/fake_config.dart'; |
| import '../src/request_handling/fake_http.dart'; |
| import '../src/request_handling/fake_request_handler.dart'; |
| import '../src/request_handling/request_handler_tester.dart'; |
| |
| void main() { |
| group('CacheRequestHandler', () { |
| late FakeConfig config; |
| late RequestHandlerTester tester; |
| |
| late CacheService cache; |
| |
| const String testHttpPath = '/cache_request_handler_test'; |
| |
| setUp(() async { |
| config = FakeConfig(); |
| tester = RequestHandlerTester( |
| request: FakeHttpRequest( |
| path: testHttpPath, |
| ), |
| ); |
| |
| cache = CacheService(inMemory: true); |
| }); |
| |
| test('returns response from cache', () async { |
| const String responseKey = '$testHttpPath:'; |
| const String expectedResponse = 'Hello, World!'; |
| final Body expectedBody = Body.forString(expectedResponse); |
| final FakeRequestHandler fallbackHandler = FakeRequestHandler(body: expectedBody, config: FakeConfig()); |
| |
| final Uint8List? serializedBody = await expectedBody.serialize().first; |
| |
| await cache.set(CacheRequestHandler.responseSubcacheName, responseKey, serializedBody); |
| |
| final CacheRequestHandler<Body> cacheRequestHandler = |
| CacheRequestHandler<Body>(delegate: fallbackHandler, cache: cache, config: config); |
| |
| final Body body = await tester.get(cacheRequestHandler); |
| final Uint8List response = (await body.serialize().first)!; |
| final String strResponse = utf8.decode(response); |
| expect(strResponse, expectedResponse); |
| }); |
| |
| test('fallback handler called when cache is empty', () async { |
| final FakeRequestHandler fallbackHandler = FakeRequestHandler( |
| body: Body.forString('hello!'), |
| config: FakeConfig(), |
| ); |
| |
| final CacheRequestHandler<Body> cacheRequestHandler = |
| CacheRequestHandler<Body>(delegate: fallbackHandler, cache: cache, config: config); |
| |
| expect(fallbackHandler.callCount, 0); |
| await tester.get(cacheRequestHandler); |
| expect(fallbackHandler.callCount, 1); |
| }); |
| |
| test('flush cache param calls purge', () async { |
| tester = RequestHandlerTester( |
| request: FakeHttpRequest( |
| path: testHttpPath, |
| queryParametersValue: <String, String>{ |
| CacheRequestHandler.flushCacheQueryParam: 'true', |
| }, |
| ), |
| ); |
| final FakeRequestHandler fallbackHandler = FakeRequestHandler( |
| body: Body.empty, |
| config: FakeConfig(), |
| ); |
| |
| const String responseKey = '$testHttpPath:'; |
| const String expectedResponse = 'Hello, World!'; |
| final Body expectedBody = Body.forString(expectedResponse); |
| |
| final Uint8List? serializedBody = await expectedBody.serialize().first; |
| |
| // set an existing response for the request |
| await cache.set(CacheRequestHandler.responseSubcacheName, responseKey, serializedBody); |
| |
| final CacheRequestHandler<Body> cacheRequestHandler = |
| CacheRequestHandler<Body>(delegate: fallbackHandler, cache: cache, config: config); |
| |
| expect(fallbackHandler.callCount, 0); |
| |
| final Body body = await tester.get(cacheRequestHandler); |
| final Uint8List response = (await body.serialize().first)!; |
| final String strResponse = utf8.decode(response); |
| |
| // the mock should update the cache to have null -> empty string |
| expect(strResponse, ''); |
| expect(fallbackHandler.callCount, 1); |
| }); |
| }); |
| } |
