// 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 {
      final server = await servePackages();
      server.serve('foo', '1.2.3');
      server.expect(
        'GET',
        RegExp('/api/packages/.*'),
        expectAsync1((request) {
          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 {
    final server = await servePackages();
    server.serve('foo', '1.2.3');
    server.expect('GET', RegExp('/api/packages/.*'), (request) {
      return Response(200,
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

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

  testWithGolden('403', (ctx) async {
    final server = await servePackages();
    server.serve('foo', '1.2.3');
    server.expect('GET', RegExp('/api/packages/.*'), (request) {
      return Response(403,
          body: jsonEncode({
            'notTheRight': {'response': 'type'}
          }));
    });
    await d.appDir({'foo': '1.2.3'}).create();

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

  testWithGolden('401', (ctx) async {
    final server = await servePackages();
    server.serve('foo', '1.2.3');
    server.expect('GET', RegExp('/api/packages/.*'), (request) {
      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 {
    final server = await servePackages();
    server.serve('foo', '1.2.3');
    server.expect('GET', RegExp('/api/packages/.*'), (request) {
      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 {
    final server = await servePackages();
    server.serve('foo', '1.2.3');
    server.expect('GET', RegExp('/api/packages/.*'), (request) {
      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']);
  });
}