Function createNativeGodotModule

common/NativeGodotModule.cpp:614–891

}

jsi::Value createNativeGodotModule(jsi::Runtime &rt, const std::shared_ptr<facebook::react::CallInvoker> &callInvoker) {
	// Perform initialization

	std::shared_ptr<facebook::react::CallInvoker> jsCallInvoker = callInvoker;

	auto runOnJS = [jsCallInvoker](std::function<void()> &&f) {
		// Run on React JS Runtime
		jsCallInvoker->invokeAsync(std::move(f));
	};

	auto runOnWorklet = [](std::function<void()> &&f) {
		GodotModule::get_singleton()->runOnGodotThread(std::move(f));
	};

	std::shared_ptr<RNWorklet::JsiWorkletContext> workletContext = std::make_shared<RNWorklet::JsiWorkletContext>(
			"ReactNativeGodot",
			&rt,
			runOnJS,
			runOnWorklet);

	LOGI("NativeGodotModule::createNativeModule");

	auto runOnGodotThreadFunc = [workletContext](jsi::Runtime &runtime, const jsi::Value &thisValue, const jsi::Value *arguments, size_t count) -> jsi::Value {
		if (!arguments[0].isObject()) {
			throw jsi::JSError(runtime, "runOnGodotThread: First argument has to be a function!");
		}

		auto worklet = std::make_shared<RNWorklet::JsiWorklet>(runtime, arguments[0]);
		auto workletInvoker = std::make_shared<RNWorklet::WorkletInvoker>(worklet);

		auto runOnGodotCallback = jsi::Function::createFromHostFunction(runtime,
				jsi::PropNameID::forAscii(runtime, "runOnGodotCallback"),
				2,
				[workletInvoker, workletContext](jsi::Runtime &runtime, const jsi::Value &thisValue, const jsi::Value *arguments, size_t count) -> jsi::Value {
					auto resolverValue = std::make_shared<jsi::Value>((arguments[0].asObject(runtime)));
					auto rejecterValue = std::make_shared<jsi::Value>((arguments[1].asObject(runtime)));

					auto resolver = [resolverValue, workletContext](std::shared_ptr<RNWorklet::JsiWrapper> wrappedValue) {
						workletContext->invokeOnJsThread([resolverValue, wrappedValue](jsi::Runtime &runtime) {
							auto resolverFunc = resolverValue->asObject(runtime).asFunction(runtime);
							auto resultValue = wrappedValue->unwrap(runtime);
							resolverFunc.call(runtime, resultValue);
						});
					};
					auto rejecter = [rejecterValue, workletContext](const std::string &message) {
						workletContext->invokeOnJsThread([rejecterValue, message](jsi::Runtime &runtime) {
							auto rejecterFunc = rejecterValue->asObject(runtime).asFunction(runtime);
							auto messageValue = jsi::String::createFromUtf8(runtime, message);
							rejecterFunc.call(runtime, messageValue);
						});
					};

					workletContext->invokeOnWorkletThread([resolver, rejecter, workletInvoker](RNWorklet::JsiWorkletContext *ctx, jsi::Runtime &workletRT) {
						try {
							auto resultValue = workletInvoker->call(workletRT, jsi::Value::undefined(), nullptr, 0);
							auto result = RNWorklet::JsiWrapper::wrap(workletRT, resultValue);
							resolver(result);
						} catch (std::exception &exc) {