/*
 * Copyright (c) Facebook, Inc. and its affiliates.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 */

#import <XCTest/XCTest.h>

#import <React/RCTMultipartStreamReader.h>

@interface RCTMultipartStreamReaderTests : XCTestCase

@end

@implementation RCTMultipartStreamReaderTests

- (void)testSimpleCase
{
  NSString *response =
      @"preamble, should be ignored\r\n"
      @"--sample_boundary\r\n"
      @"Content-Type: application/json; charset=utf-8\r\n"
      @"Content-Length: 2\r\n\r\n"
      @"{}\r\n"
      @"--sample_boundary--\r\n"
      @"epilogue, should be ignored";

  NSInputStream *inputStream = [NSInputStream inputStreamWithData:[response dataUsingEncoding:NSUTF8StringEncoding]];
  RCTMultipartStreamReader *reader = [[RCTMultipartStreamReader alloc] initWithInputStream:inputStream
                                                                                  boundary:@"sample_boundary"];
  __block NSInteger count = 0;
  BOOL success = [reader
      readAllPartsWithCompletionCallback:^(NSDictionary *headers, NSData *content, BOOL done) {
        XCTAssertTrue(done);
        XCTAssertEqualObjects(headers[@"Content-Type"], @"application/json; charset=utf-8");
        XCTAssertEqualObjects([[NSString alloc] initWithData:content encoding:NSUTF8StringEncoding], @"{}");
        count++;
      }
                        progressCallback:nil];
  XCTAssertTrue(success);
  XCTAssertEqual(count, 1);
}

- (void)testMultipleParts
{
  NSString *response =
      @"preamble, should be ignored\r\n"
      @"--sample_boundary\r\n"
      @"1\r\n"
      @"--sample_boundary\r\n"
      @"2\r\n"
      @"--sample_boundary\r\n"
      @"3\r\n"
      @"--sample_boundary--\r\n"
      @"epilogue, should be ignored";

  NSInputStream *inputStream = [NSInputStream inputStreamWithData:[response dataUsingEncoding:NSUTF8StringEncoding]];
  RCTMultipartStreamReader *reader = [[RCTMultipartStreamReader alloc] initWithInputStream:inputStream
                                                                                  boundary:@"sample_boundary"];
  __block NSInteger count = 0;
  BOOL success = [reader
      readAllPartsWithCompletionCallback:^(__unused NSDictionary *headers, NSData *content, BOOL done) {
        count++;
        XCTAssertEqual(done, count == 3);
        NSString *expectedBody = [NSString stringWithFormat:@"%ld", (long)count];
        NSString *actualBody = [[NSString alloc] initWithData:content encoding:NSUTF8StringEncoding];
        XCTAssertEqualObjects(actualBody, expectedBody);
      }
                        progressCallback:nil];
  XCTAssertTrue(success);
  XCTAssertEqual(count, 3);
}

- (void)testNoDelimiter
{
  NSString *response = @"Yolo";

  NSInputStream *inputStream = [NSInputStream inputStreamWithData:[response dataUsingEncoding:NSUTF8StringEncoding]];
  RCTMultipartStreamReader *reader = [[RCTMultipartStreamReader alloc] initWithInputStream:inputStream
                                                                                  boundary:@"sample_boundary"];
  __block NSInteger count = 0;
  BOOL success = [reader
      readAllPartsWithCompletionCallback:^(
          __unused NSDictionary *headers, __unused NSData *content, __unused BOOL done) {
        count++;
      }
                        progressCallback:nil];
  XCTAssertFalse(success);
  XCTAssertEqual(count, 0);
}

- (void)testNoCloseDelimiter
{
  NSString *response =
      @"preamble, should be ignored\r\n"
      @"--sample_boundary\r\n"
      @"Content-Type: application/json; charset=utf-8\r\n"
      @"Content-Length: 2\r\n\r\n"
      @"{}\r\n"
      @"--sample_boundary\r\n"
      @"incomplete message...";

  NSInputStream *inputStream = [NSInputStream inputStreamWithData:[response dataUsingEncoding:NSUTF8StringEncoding]];
  RCTMultipartStreamReader *reader = [[RCTMultipartStreamReader alloc] initWithInputStream:inputStream
                                                                                  boundary:@"sample_boundary"];
  __block NSInteger count = 0;
  BOOL success = [reader
      readAllPartsWithCompletionCallback:^(
          __unused NSDictionary *headers, __unused NSData *content, __unused BOOL done) {
        count++;
      }
                        progressCallback:nil];
  XCTAssertFalse(success);
  XCTAssertEqual(count, 1);
}

@end