//
//  VideoDepacketizer.m
//  Limelight-iOS
//
//  Created by Diego Waxemberg on 1/18/14.
//  Copyright (c) 2014 Diego Waxemberg. All rights reserved.
//

#import "VideoDepacketizer.h"

@implementation VideoDepacketizer
static int BUFFER_LENGTH = 131072;

- (id)initWithFile:(NSString *)file renderTarget:(UIView*)renderTarget
{
    self = [super init];
    self.file = file;
    self.target = renderTarget;
    return self;
}

- (void)main
{
    NSInputStream* inStream = [[NSInputStream alloc] initWithFileAtPath:self.file];
    self.byteBuffer = malloc(BUFFER_LENGTH);
    self.decoder = [[VideoDecoder alloc]init];
    
    
    [inStream open];
    while ([inStream streamStatus] != NSStreamStatusOpen) {
        NSLog(@"stream status: %d", [inStream streamStatus]);
        sleep(1);
    }
    while (true)
    {
        unsigned int len = 0;

        len = [inStream read:self.byteBuffer maxLength:BUFFER_LENGTH];
        if (len)
        {
            BOOL firstStart = false;
            for (int i = 0; i < len - 4; i++) {
                self.offset++;
                if (self.byteBuffer[i] == 0 && self.byteBuffer[i+1] == 0
                    && self.byteBuffer[i+2] == 0 && self.byteBuffer[i+3] == 1)
                {
                    if (firstStart)
                    {
                        // decode the first i-1 bytes and render a frame
                        //[self.decoder decode:self.byteBuffer length:i];
                        [self.target performSelectorOnMainThread:@selector(setNeedsDisplay) withObject:NULL waitUntilDone:FALSE];
                        
                        // move offset back to beginning of start sequence
                        [inStream setProperty:[[NSNumber alloc] initWithInt:self.offset-4] forKey:NSStreamFileCurrentOffsetKey];
                        self.offset -= 1;
                        
                        break;
                    } else
                    {
                        firstStart = true;
                    }
                }
            }
        }
        else
        {
            NSLog(@"No Buffer! restarting file!");
            // move offset back to beginning of start sequence
            self.offset = 0;
            [inStream close];
            inStream = [[NSInputStream alloc] initWithFileAtPath:self.file];
            [inStream open];
        }
    }

}

@end