test/hosted/fail_gracefully_on_bad_version_listing_response_test.dart

// Copyright (c) 2020, the Dart project authors.  Please see the AUTHORS file
// for details. 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 'package:pub/src/exit_codes.dart' as exit_codes;
import 'package:shelf/shelf.dart';
import 'package:test/test.dart';

import '../descriptor.dart' as d;
import '../golden_file.dart';
import '../test_pub.dart';

void main() {
  forBothPubGetAndUpgrade((command) {
    test(
        'fails gracefully if the package server responds with broken package listings',
        () async {
      await servePackages((b) => b..serve('foo', '1.2.3'));
      globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
          expectAsync1((request) {
        expect(request.method, 'GET');
        return Response(200,
            body: jsonEncode({
              'notTheRight': {'response': 'type'}
            }));
      });
      await d.appDir({'foo': '1.2.3'}).create();

      await pubCommand(command,
          error: allOf([
            contains(
                'Got badly formatted response trying to find package foo at http://localhost:'),
            contains('), version solving failed.')
          ]),
          exitCode: exit_codes.DATA);
    });
  });

  testWithGolden('bad_json', (ctx) async {
    await servePackages((b) => b..serve('foo', '1.2.3'));
    globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
        expectAsync1((request) {
      expect(request.method, 'GET');
      return Response(200,
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

    await ctx.run(['get']);
  });

  testWithGolden('403', (ctx) async {
    await servePackages((b) => b..serve('foo', '1.2.3'));
    globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
        expectAsync1((request) {
      expect(request.method, 'GET');
      return Response(403,
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

    await ctx.run(['get']);
  });

  testWithGolden('401', (ctx) async {
    await servePackages((b) => b..serve('foo', '1.2.3'));
    globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
        expectAsync1((request) {
      expect(request.method, 'GET');
      return Response(401,
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

    await ctx.run(['get']);
  });

  testWithGolden('403-with-message', (ctx) async {
    await servePackages((b) => b..serve('foo', '1.2.3'));
    globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
        expectAsync1((request) {
      expect(request.method, 'GET');
      return Response(403,
          headers: {
            'www-authenticate': 'Bearer realm="pub", message="<message>"',
          },
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

    await ctx.run(['get']);
  });

  testWithGolden('401-with-message', (ctx) async {
    await servePackages((b) => b..serve('foo', '1.2.3'));
    globalPackageServer.extraHandlers[RegExp('/api/packages/.*')] =
        expectAsync1((request) {
      expect(request.method, 'GET');
      return Response(401,
          headers: {
            'www-authenticate': 'Bearer realm="pub", message="<message>"',
          },
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

    await ctx.run(['get']);
  });
}