#import "RoomBoomEventQueue.h"
#import "RoomBoomEvent.h"

@implementation RoomBoomEventQueue

- (instancetype)init {
    self = [super init];
    if (self) {
        _events = [[NSMutableArray alloc] init];
        _isProcessing = NO;
    }
    return self;
}

- (void)enqueueEvent:(id)event {
    @synchronized (self.events) {
        [self.events addObject:event];
        
        // 如果当前没有在处理事件，则开始处理
        if (!self.isProcessing) {
            [self processNextEvent];
        }
    }
}

- (void)processNextEvent {
    @synchronized (self.events) {
        if (self.events.count == 0) {
            self.isProcessing = NO;
            return;
        }
        
        self.isProcessing = YES;
        id event = self.events.firstObject;
        [self.events removeObjectAtIndex:0];
        
        if (self.processBlock) {
            dispatch_async(dispatch_get_main_queue(), ^{
                self.processBlock(event);
            });
        }
    }
}

- (void)clear {
    @synchronized (self.events) {
        [self.events removeAllObjects];
        self.isProcessing = NO;
    }
}

- (NSString *)description {
    return [NSString stringWithFormat:@"<%@: %p> events count: %lu, isProcessing: %@",
            NSStringFromClass([self class]),
            self,
            (unsigned long)self.events.count,
            self.isProcessing ? @"YES" : @"NO"];
}

@end