//
//  OSSInputStreamHelper.m
//  AliyunOSSSDK
//
//  Created by 怀叙 on 2017/12/7.
//  Copyright © 2017年 阿里云. All rights reserved.
//

#import "OSSInputStreamHelper.h"
#import "OSSLog.h"
#import "aos_crc64.h"

@interface OSSInputStreamHelper ()
{
    NSInputStream *_inputStream;
    CFAbsoluteTime _startTime;
    dispatch_semaphore_t _semaphore;
}

@end

@implementation OSSInputStreamHelper

- (instancetype)initWithFileAtPath:(nonnull NSString *)path
{
    self = [super init];
    if (self) {
        _crc64 = 0;
        _inputStream = [NSInputStream inputStreamWithFileAtPath:path];
        _semaphore = dispatch_semaphore_create(1);
    }
    return self;
}

- (instancetype)initWithURL:(nonnull NSURL *)URL
{
    self = [super init];
    if (self) {
        _crc64 = 0;
        _inputStream = [NSInputStream inputStreamWithURL:URL];
        _semaphore = dispatch_semaphore_create(1);
    }
    return self;
}

- (void)syncReadBuffers
{
    dispatch_semaphore_wait(_semaphore, DISPATCH_TIME_FOREVER);

    _startTime = CFAbsoluteTimeGetCurrent();
    [_inputStream open];
    NSInteger length = 1;
    while (length > 0)
    {
        @autoreleasepool{
            uint8_t streamData[1024 * 4];
            length = [_inputStream read:streamData maxLength:1024 * 4];
            if (length > 0) {
                _crc64 = aos_crc64(_crc64, streamData, length);
            }
        }
    }
    
    if (length < 0) {
        OSSLogError(@"there is an error when reading buffer from file!");
    }
    [_inputStream close];
    
    CFAbsoluteTime duration =  CFAbsoluteTimeGetCurrent() - _startTime;
    OSSLogDebug(@"read file cost time is :%f",duration);
    
    dispatch_semaphore_signal(_semaphore);
}

- (uint64_t)crc64
{
    return _crc64;
}

@end