#include "inspector.h"
#include "environment.h"
#include "runnable.h"
#include "util.h"
#include "lib/timer.h"
#include <string>

using namespace ivm;
using namespace v8;
using namespace v8_inspector;
using std::shared_ptr;
using std::unique_ptr;

namespace ivm {

/**
 * This constructor will be called from a non-locked thread.
 */
InspectorAgent::InspectorAgent(IsolateEnvironment& isolate) : isolate(isolate), inspector(V8Inspector::create(isolate, this)) {
	struct AddDefaultContext : public Runnable {
		InspectorAgent& that;
		explicit AddDefaultContext(InspectorAgent& agent) : that(agent) {}
		void Run() final {
			// We can assume that agent is still alive because otherwise this won't get called
			that.ContextCreated(that.isolate.DefaultContext(), "default");
		}
	};
	SendInterrupt(std::make_unique<AddDefaultContext>(*this));
}

/**
 * Called right before the isolate is disposed.
 */
InspectorAgent::~InspectorAgent() {
	auto sessions_lock = active_sessions.write();
	for (auto ii = sessions_lock->begin(); ii != sessions_lock->end(); ) {
		InspectorSession* session = *ii;
		++ii;
		session->Disconnect();
	}
	assert(sessions_lock->empty());
}

/**
 * When debugging running JS code this function is called and is expected to block and process
 * inspector messages until the inspector is done. This happens in the isolate's currently running
 * thread so we know that an Executor::Lock is up.
 */
void InspectorAgent::runMessageLoopOnPause(int /*context_group_id*/) {
	if (terminated) {
		return;
	}
	Executor::PauseScope pause_cpu_timer{isolate.executor.cpu_timer};
	std::unique_lock<std::mutex> lock{mutex};
	running = true;
	do {
		cv.wait(lock);
		lock.unlock();
		{
			Executor::UnpauseScope unpause_cpu_timer{pause_cpu_timer};
			isolate.InterruptEntryAsync();
		}
		lock.lock();
	} while (running && !terminated);
}

/**
 * This is the notificaiton to exit from the currently running `runMessageLoopOnPause` from another
 * thread.
 */
void InspectorAgent::quitMessageLoopOnPause() {
	// This is called from within runMessageLoopOnPause, therefore lock is already acquired
	running = false;
	cv.notify_all();
}

/**
 * Connects a V8Inspector::Channel to a V8Inspector which returns an instance of V8InspectorSession.
 */
auto InspectorAgent::ConnectSession(InspectorSession& session) -> unique_ptr<V8InspectorSession> {
	active_sessions.write()->insert(&session);
#if V8_AT_LEAST(10, 3, 118)
	return inspector->connect(1, &session, StringView(), v8_inspector::V8Inspector::ClientTrustLevel::kFullyTrusted);
#else
	return inspector->connect(1, &session, StringView());
#endif
}

/**
 * Called from the session when it disconnects.
 */
void InspectorAgent::SessionDisconnected(InspectorSession& session) {
	assert(active_sessions.write()->erase(&session) == 1);
}

/**
 * Request to send an interrupt to the inspected isolate
 */
void InspectorAgent::SendInterrupt(unique_ptr<Runnable> task) {
	// If this isolate is already locked just run the task. This happens at least when the isolate is disposing
	// and `holder` no longer has a valid shared_ptr
	if (Executor::GetCurrentEnvironment() == &isolate) {
		task->Run();
		return;
	}
	// Grab pointer because it's needed for WakeIsolate
	auto holder = isolate.holder.lock();
	assert(holder);
	auto ptr = holder->GetIsolate();
	assert(ptr);
	// Push interrupt onto queue
	auto scheduler_lock = isolate.scheduler->Lock();
	scheduler_lock->interrupts.push(std::move(task));
	// Wake up the isolate
	if (!scheduler_lock->WakeIsolate(ptr)) { // `true` if isolate is inactive
		// Isolate is currently running
		std::lock_guard<std::mutex> lock{mutex};
		if (running) {
			// Isolate is being debugged and is in `runMessageLoopOnPause`
			cv.notify_all();
		} else {
			// Isolate is busy running JS code
			scheduler_lock->InterruptIsolate();
		}
	}
}

/**
 * Hook to add context to agent.
 */
void InspectorAgent::ContextCreated(Local<Context> context, const std::string& name) {
	inspector->contextCreated(V8ContextInfo(context, 1, StringView(reinterpret_cast<const uint8_t*>(name.c_str()), name.length())));
}

/**
 * Hook to remove context from agent.
 */
void InspectorAgent::ContextDestroyed(Local<Context> context) {
	inspector->contextDestroyed(context);
}

/**
 * Called when this isolate needs to dispose, disables all inspector activity
 */
void InspectorAgent::Terminate() {
	std::lock_guard<std::mutex> lock(mutex);
	terminated = true;
	cv.notify_all();
}

/**
 * Creates a new session and connects it to a given agent.
 */
InspectorSession::InspectorSession(IsolateEnvironment& isolate) : agent(*isolate.GetInspectorAgent()), session(agent.ConnectSession(*this)) {}

InspectorSession::~InspectorSession() {
	Disconnect();
}

/**
 * Disconnects this session from the v8 inspector. Allows inspector to deallocate gracefully.
 */
void InspectorSession::Disconnect() {
	std::lock_guard<std::mutex> lock(mutex);
	if (session) {
		agent.SessionDisconnected(*this);
		struct DeleteSession : public Runnable {
			shared_ptr<V8InspectorSession> session;
			explicit DeleteSession(shared_ptr<V8InspectorSession> session) : session(std::move(session)) {}
			// Nothing is needed since the dtor will (should) delete the session in the right context
			void Run() final {}
		};
		agent.SendInterrupt(std::make_unique<DeleteSession>(std::move(session)));
	}
}

/**
 * Send a message from this session to the backend.
 */
void InspectorSession::DispatchBackendProtocolMessage(std::vector<uint16_t> message) {
	std::lock_guard<std::mutex> lock(mutex);
	if (session) {
		struct DispatchMessage : public Runnable {
			std::vector<uint16_t> message;
			std::weak_ptr<V8InspectorSession> weak_session;
			explicit DispatchMessage(std::vector<uint16_t> message, shared_ptr<V8InspectorSession>& session) : message(std::move(message)), weak_session(session) {}
			void Run() final {
				auto session = weak_session.lock();
				if (session) {
					session->dispatchProtocolMessage(StringView(&message[0], message.size()));
				}
			}
		};
		agent.SendInterrupt(std::make_unique<DispatchMessage>(std::move(message), session));
	} else {
		throw RuntimeGenericError("Session is dead");
	}
}

} // namespace ivm