/**
 ******************************************************************************
 * Xenia : Xbox 360 Emulator Research Project                                 *
 ******************************************************************************
 * Copyright 2013 Ben Vanik. All rights reserved.                             *
 * Released under the BSD license - see LICENSE in the root for more details. *
 ******************************************************************************
 */

#include "xenia/base/logging.h"
#include "xenia/kernel/kernel_state.h"
#include "xenia/kernel/objects/xnotify_listener.h"
#include "xenia/kernel/util/shim_utils.h"
#include "xenia/kernel/xam_private.h"
#include "xenia/xbox.h"

namespace xe {
namespace kernel {

SHIM_CALL XamNotifyCreateListener_shim(PPCContext* ppc_state,
                                       KernelState* state) {
  uint64_t mask = SHIM_GET_ARG_64(0);
  uint32_t one = SHIM_GET_ARG_32(1);

  XELOGD("XamNotifyCreateListener(%.8llX, %d)", mask, one);

  // r4=1 may indicate user process?

  auto listener = object_ref<XNotifyListener>(new XNotifyListener(state));
  listener->Initialize(mask);

  // Handle ref is incremented, so return that.
  uint32_t handle = listener->handle();

  SHIM_SET_RETURN_64(handle);
}

// http://ffplay360.googlecode.com/svn/Test/Common/AtgSignIn.cpp
SHIM_CALL XNotifyGetNext_shim(PPCContext* ppc_state, KernelState* state) {
  uint32_t handle = SHIM_GET_ARG_32(0);
  uint32_t match_id = SHIM_GET_ARG_32(1);
  uint32_t id_ptr = SHIM_GET_ARG_32(2);
  uint32_t param_ptr = SHIM_GET_ARG_32(3);

  XELOGD("XNotifyGetNext(%.8X, %.8X, %.8X, %.8X)", handle, match_id, id_ptr,
         param_ptr);

  if (!handle) {
    SHIM_SET_RETURN_64(0);
    return;
  }

  // Grab listener.
  auto listener = state->object_table()->LookupObject<XNotifyListener>(handle);
  if (!listener) {
    SHIM_SET_RETURN_64(0);
    return;
  }

  bool dequeued = false;
  uint32_t id = 0;
  uint32_t param = 0;
  if (match_id) {
    // Asking for a specific notification
    id = match_id;
    dequeued = listener->DequeueNotification(match_id, &param);
  } else {
    // Just get next.
    dequeued = listener->DequeueNotification(&id, &param);
  }

  if (dequeued) {
    SHIM_SET_MEM_32(id_ptr, id);
    SHIM_SET_MEM_32(param_ptr, param);
  }

  SHIM_SET_RETURN_64(dequeued ? 1 : 0);
}

SHIM_CALL XNotifyDelayUI_shim(PPCContext* ppc_state, KernelState* state) {
  uint32_t delay_ms = SHIM_GET_ARG_32(0);

  XELOGD("XNotifyDelayUI(%d)", delay_ms);

  // Ignored.
  SHIM_SET_RETURN_32(0);
}

SHIM_CALL XNotifyPositionUI_shim(PPCContext* ppc_state, KernelState* state) {
  uint32_t position = SHIM_GET_ARG_32(0);

  XELOGD("XNotifyPositionUI(%.8X)", position);

  // Ignored.
}

}  // namespace kernel
}  // namespace xe

void xe::kernel::xam::RegisterNotifyExports(
    xe::cpu::ExportResolver* export_resolver, KernelState* state) {
  SHIM_SET_MAPPING("xam.xex", XamNotifyCreateListener, state);
  SHIM_SET_MAPPING("xam.xex", XNotifyGetNext, state);
  SHIM_SET_MAPPING("xam.xex", XNotifyDelayUI, state);
  SHIM_SET_MAPPING("xam.xex", XNotifyPositionUI, state);
}