#include "Utility/NMessageQueue.h"
#include "Utility/NSyncObject.h"

// OFFSET: 0x00736340
NMessageQueue::NMessageQueue() : m_semaphore(nullptr), m_enabled(false) {
  InitializeCriticalSection(&this->m_criticalSection);
  // The original passes the address of an empty string, not a null name.
  this->m_semaphore = CreateSemaphoreA(nullptr, 0, 0x7FFFFFFF, "");
  if (this->m_semaphore) {
    this->m_enabled = true;
  }
}

// OFFSET: 0x00736460
// FUNCTION: fn_07620
// OFFSET: 0x007364F0
// FUNCTION: fn_07621
NMessageQueue::~NMessageQueue() {
  if (this->m_semaphore) {
    CloseHandle(this->m_semaphore);
    this->m_semaphore = nullptr;
  }
  DeleteCriticalSection(&this->m_criticalSection);
}

// OFFSET: 0x00736590
// FUNCTION: fn_07622
NMessage* NMessageQueue::Pop(NMessage* message) {
  NSyncObject held(&this->m_criticalSection);
  if (!this->m_messages.empty()) {
    Record record = this->m_messages.front();
    this->m_messages.pop_front();
    message->id = record.id;
    message->argumentHigh = record.argumentHigh;
    message->argumentLow = record.argumentLow;
    message->valid = true;
  } else {
    message->id = 0;
    message->argumentHigh = 0;
    message->argumentLow = 0;
    message->valid = false;
  }
  return message;
}

// OFFSET: 0x00736660
// FUNCTION: fn_07624
void NMessageQueue::Push(std::uint64_t argument, std::uint32_t id) {
  NSyncObject held(&this->m_criticalSection);
  this->m_messages.push_back({static_cast<std::uint32_t>(argument), static_cast<std::uint32_t>(argument >> 32), id});
  ReleaseSemaphore(this->m_semaphore, 1, nullptr);
}

// OFFSET: 0x00736650
// FUNCTION: fn_07623
void NMessageQueue::Clear() {
  // Original clear tears down deque storage without acquiring the lock or
  // draining semaphore count; preserve that caller synchronization contract.
  std::deque<Record>().swap(this->m_messages);
}