#pragma once

#include "kj/async.h"
#include "Python.h"
#include "capabilityHelper.h"

class PyEventPort: public kj::EventPort {
public:
  PyEventPort(PyObject * _py_event_port): py_event_port(_py_event_port) {
    // We don't need to incref/decref, since this C++ class will be owned by the Python wrapper class, and we'll make sure the python class doesn't refcount to 0 elsewhere.
    // Py_INCREF(py_event_port);
  }
  virtual void wait() {
    GILAcquire gil;
    PyObject_CallMethod(py_event_port, const_cast<char *>("wait"), NULL);
  }

  virtual void poll() {
    GILAcquire gil;
    PyObject_CallMethod(py_event_port, const_cast<char *>("poll"), NULL);
  }

  virtual void setRunnable(bool runnable) {
    GILAcquire gil;
    PyObject * arg = Py_False;
    if (runnable)
      arg = Py_True;
    PyObject_CallMethod(py_event_port, const_cast<char *>("set_runnable"), const_cast<char *>("o"), arg);
  }

private:
  PyObject * py_event_port;
};

void waitNeverDone(kj::WaitScope & scope) {
  GILRelease gil;
  kj::NEVER_DONE.wait(scope);
}

kj::Timer * getTimer(kj::AsyncIoContext * context) {
  return &context->lowLevelProvider->getTimer();
}

void waitVoidPromise(kj::Promise<void> * promise, kj::WaitScope & scope) {
  GILRelease gil;
  promise->wait(scope);
}

PyObject * waitPyPromise(kj::Promise<PyObject *> * promise, kj::WaitScope & scope) {
  GILRelease gil;
  return promise->wait(scope);
}

capnp::Response< ::capnp::DynamicStruct> * waitRemote(capnp::RemotePromise< ::capnp::DynamicStruct> * promise, kj::WaitScope & scope) {
  GILRelease gil;
  return new capnp::Response< ::capnp::DynamicStruct>(promise->wait(scope));
}