// Copyright (c) 2017, 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:async';
import 'dart:convert';

import 'package:typed_data/typed_buffers.dart';

import 'body.dart';
import 'multipart_file.dart';
import 'utils.dart';

/// A `multipart/form-data` request [Body].
///
/// Such a request has both string fields, which function as normal form
/// fields, and (potentially streamed) binary files.
class MultipartBody implements Body {
  /// The contents of the message body.
  ///
  /// This will be `null` after [read] is called.
  Stream<List<int>> _stream;

  final int contentLength;

  /// Multipart forms do not have an encoding.
  Encoding get encoding => null;

  /// Creates a [MultipartBody] from the given [fields] and [files].
  ///
  /// The [boundary] is used to separate key value pairs within the body.
  factory MultipartBody(Map<String, String> fields,
      Iterable<MultipartFile> files, String boundary) {
    var controller = new StreamController<List<int>>(sync: true);
    var buffer = new Uint8Buffer();

    void writeAscii(String string) {
      buffer.addAll(string.codeUnits);
    }

    void writeUtf8(String string) {
      buffer.addAll(UTF8.encode(string));
    }

    void writeLine() {
      buffer..add(13)..add(10); // \r\n
    }

    // Write the fields to the buffer.
    fields.forEach((name, value) {
      writeAscii('--$boundary\r\n');
      writeUtf8(_headerForField(name, value));
      writeUtf8(value);
      writeLine();
    });

    controller.add(buffer);

    // Iterate over the files to get the length and compute the headers ahead of
    // time so the length can be synchronously accessed.
    var fileList = files.toList();
    var fileHeaders = <List<int>>[];
    var fileContentsLength = 0;

    for (var file in fileList) {
      var header = <int>[]
        ..addAll('--$boundary\r\n'.codeUnits)
        ..addAll(UTF8.encode(_headerForFile(file)));

      fileContentsLength += header.length + file.length + 2;
      fileHeaders.add(header);
    }

    // Ending characters.
    var ending = '--$boundary--\r\n'.codeUnits;
    fileContentsLength += ending.length;

    // Write the files to the stream asynchronously.
    _writeFilesToStream(controller, fileList, fileHeaders, ending);

    return new MultipartBody._(
        controller.stream, buffer.length + fileContentsLength);
  }

  MultipartBody._(this._stream, this.contentLength);

  Stream<List<int>> read() {
    if (_stream == null) {
      throw new StateError("The 'read' method can only be called once on a "
          'http.Request/http.Response object.');
    }
    var stream = _stream;
    _stream = null;
    return stream;
  }

  /// Writes the [files] to the [controller].
  static Future _writeFilesToStream(
      StreamController<List<int>> controller,
      List<MultipartFile> files,
      List<List<int>> fileHeaders,
      List<int> ending) async {
    for (var i = 0; i < files.length; ++i) {
      controller.add(fileHeaders[i]);

      // file.read() can throw synchronously
      try {
        await writeStreamToSink(files[i].read(), controller);
      } catch (exception, stackTrace) {
        controller.addError(exception, stackTrace);
      }

      controller.add([13, 10]);
    }

    controller
      ..add(ending)
      ..close();
  }

  /// Returns the header string for a field.
  static String _headerForField(String name, String value) {
    var header =
        'content-disposition: form-data; name="${_browserEncode(name)}"';
    if (!isPlainAscii(value)) {
      header = '$header\r\n'
          'content-type: text/plain; charset=utf-8\r\n'
          'content-transfer-encoding: binary';
    }
    return '$header\r\n\r\n';
  }

  /// Returns the header string for a file.
  ///
  /// The return value is guaranteed to contain only ASCII characters.
  static String _headerForFile(MultipartFile file) {
    var header = 'content-type: ${file.contentType}\r\n'
        'content-disposition: form-data; name="${_browserEncode(file.field)}"';

    if (file.filename != null) {
      header = '$header; filename="${_browserEncode(file.filename)}"';
    }
    return '$header\r\n\r\n';
  }

  static final _newlineRegExp = new RegExp(r'\r\n|\r|\n');

  /// Encode [value] in the same way browsers do.
  static String _browserEncode(String value) =>
      // http://tools.ietf.org/html/rfc2388 mandates some complex encodings for
      // field names and file names, but in practice user agents seem not to
      // follow this at all. Instead, they URL-encode `\r`, `\n`, and `\r\n` as
      // `\r\n`; URL-encode `"`; and do nothing else (even for `%` or non-ASCII
      // characters). We follow their behavior.
      value.replaceAll(_newlineRegExp, '%0D%0A').replaceAll('"', '%22');
}