[Wasm] Wasm target implementation

Author: skuzmich

build.gradle

@@ -160,6 +160,7 @@ configure(subprojects.findAll { !sourceless.contains(it.name) && it.name != core
         }
 
         apply from: rootProject.file("gradle/compile-js-multiplatform.gradle")
+        apply from: rootProject.file("gradle/compile-wasm-multiplatform.gradle")
         kotlin.sourceSets.commonMain.dependencies {
             api project(":$coreModule")
         }
@@ -370,3 +371,7 @@ if (CacheRedirector.enabled) {
         nodeJsExtension.nodeDownloadBaseUrl = CacheRedirector.maybeRedirect(nodeJsExtension.nodeDownloadBaseUrl)
     }
 }
+
+extensions.findByType(org.jetbrains.kotlin.gradle.targets.js.nodejs.NodeJsRootExtension.class).with {
+    it.nodeVersion = "20.2.0"
+}

gradle/compile-js-multiplatform.gradle

@@ -12,6 +12,16 @@ kotlin {
     }
 
     sourceSets {
+        jsMain {
+            kotlin {
+                srcDir 'jsWasm/src'
+            }
+        }
+        jsTest {
+            kotlin {
+                srcDir 'jsWasm/test'
+            }
+        }
         jsTest.dependencies {
             api "org.jetbrains.kotlin:kotlin-test-js:$kotlin_version"
         }

gradle/compile-wasm-multiplatform.gradle

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+kotlin {
+    wasm {
+        moduleName = project.name
+        nodejs()
+        compilations['main']?.dependencies {
+            api "org.jetbrains.kotlinx:atomicfu-wasm:$atomicfu_version"
+        }
+    }
+
+    sourceSets {
+        wasmMain {
+            kotlin {
+                srcDir 'jsWasm/src'
+            }
+        }
+        wasmTest {
+            kotlin {
+                srcDir 'jsWasm/test'
+            }
+        }
+        wasmTest.dependencies {
+            api "org.jetbrains.kotlin:kotlin-test-wasm:$kotlin_version"
+        }
+    }
+}
+

kotlinx-coroutines-core/build.gradle

@@ -1,3 +1,5 @@
+import org.jetbrains.kotlin.gradle.targets.js.nodejs.NodeJsRootPlugin
+
 /*
  * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
@@ -16,6 +18,7 @@ if (rootProject.ext.native_targets_enabled) {
 }
 
 apply from: rootProject.file("gradle/compile-js-multiplatform.gradle")
+apply from: rootProject.file("gradle/compile-wasm-multiplatform.gradle")
 
 apply from: rootProject.file('gradle/dokka.gradle.kts')
 apply from: rootProject.file('gradle/publish.gradle')
@@ -265,6 +268,15 @@ jvmTest {
 // Setup manifest for kotlinx-coroutines-core-jvm.jar
 jvmJar { setupManifest(it) }
 
+wasmNodeTest {
+    filter.with {
+        excludeTest("ChannelsTest", "testIterableAsReceiveChannel")
+        excludeTest("ChannelsTest", "testEmptyList")
+        excludeTest("ChannelsTest", "testToList")
+        excludeTest("ChannelBuildersFlowTest", "testConsumeAsFlowProduceBuffered")
+    }
+}
+
 /*
  * Setup manifest for kotlinx-coroutines-core.jar
  * This is convenient for users that pass -javaagent arg manually and also is a workaround #2619 and KTIJ-5659.
@@ -376,4 +388,4 @@ task testsJar(type: Jar, dependsOn: jvmTestClasses) {
 
 artifacts {
     archives testsJar
-}
+}

kotlinx-coroutines-core/js/src/CloseableCoroutineDispatcher.kt renamed to kotlinx-coroutines-core/jsWasm/src/CloseableCoroutineDispatcher.kt

@@ -29,4 +29,4 @@ internal actual class SafeCollector<T> actual constructor(
 
     public actual fun releaseIntercepted() {
     }
-}
+}

kotlinx-coroutines-core/js/src/Dispatchers.kt renamed to kotlinx-coroutines-core/jsWasm/src/Dispatchers.kt

@@ -18,7 +18,7 @@ internal actual fun ensurePlatformExceptionHandlerLoaded(callback: CoroutineExce
 
 internal actual fun propagateExceptionFinalResort(exception: Throwable) {
     // log exception
-    console.error(exception)
+    console.error(exception.toString())
 }
 
 internal actual class DiagnosticCoroutineContextException actual constructor(context: CoroutineContext) :

kotlinx-coroutines-core/js/src/EventLoop.kt renamed to kotlinx-coroutines-core/jsWasm/src/EventLoop.kt

@@ -11,4 +11,4 @@ internal actual class CommonThreadLocal<T> {
     actual fun set(value: T) { this.value = value }
 }
 
-internal actual fun<T> commonThreadLocal(name: Symbol): CommonThreadLocal<T> = CommonThreadLocal()
+internal actual fun<T> commonThreadLocal(name: Symbol): CommonThreadLocal<T> = CommonThreadLocal()

kotlinx-coroutines-core/js/src/Exceptions.kt renamed to kotlinx-coroutines-core/jsWasm/src/Exceptions.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2020 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2016-2023 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
  */
 
 package kotlinx.coroutines

kotlinx-coroutines-core/js/src/Runnable.kt renamed to kotlinx-coroutines-core/jsWasm/src/Runnable.kt

@@ -0,0 +1,22 @@
+/*
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines
+
+import kotlinx.coroutines.internal.*
+
+internal actual abstract class CompletionHandlerBase actual constructor() : LockFreeLinkedListNode(), CompletionHandler {
+    actual abstract override fun invoke(cause: Throwable?)
+}
+
+internal actual inline val CompletionHandlerBase.asHandler: CompletionHandler get() = this
+
+internal actual abstract class CancelHandlerBase actual constructor() : CompletionHandler {
+    actual abstract override fun invoke(cause: Throwable?)
+}
+
+internal actual inline val CancelHandlerBase.asHandler: CompletionHandler get() = this
+
+@Suppress("NOTHING_TO_INLINE")
+internal actual inline fun CompletionHandler.invokeIt(cause: Throwable?) = invoke(cause)

kotlinx-coroutines-core/js/src/SchedulerTask.kt renamed to kotlinx-coroutines-core/jsWasm/src/SchedulerTask.kt

@@ -0,0 +1,51 @@
+/*
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines
+
+import kotlinx.coroutines.internal.*
+import org.w3c.dom.*
+import kotlin.coroutines.*
+
+internal external interface JsProcess : JsAny {
+    fun nextTick(handler: () -> Unit)
+}
+
+internal fun tryGetProcess(): JsProcess? =
+    js("(typeof(process) !== 'undefined' && typeof(process.nextTick) === 'function') ? process : null")
+
+internal fun tryGetWindow(): Window? =
+    js("(typeof(window) !== 'undefined' && window != null && typeof(window.addEventListener) === 'function') ? window : null")
+
+internal fun createDefaultDispatcher(): CoroutineDispatcher =
+    tryGetProcess()?.let(::NodeDispatcher)
+        ?: tryGetWindow()?.let(::WindowDispatcher)
+        ?: SetTimeoutDispatcher
+
+@PublishedApi // Used from kotlinx-coroutines-test via suppress, not part of ABI
+internal actual val DefaultDelay: Delay
+    get() = Dispatchers.Default as Delay
+
+public actual fun CoroutineScope.newCoroutineContext(context: CoroutineContext): CoroutineContext {
+    val combined = coroutineContext + context
+    return if (combined !== Dispatchers.Default && combined[ContinuationInterceptor] == null)
+        combined + Dispatchers.Default else combined
+}
+
+public actual fun CoroutineContext.newCoroutineContext(addedContext: CoroutineContext): CoroutineContext {
+    return this + addedContext
+}
+
+// No debugging facilities on JS
+internal actual inline fun <T> withCoroutineContext(context: CoroutineContext, countOrElement: Any?, block: () -> T): T = block()
+internal actual inline fun <T> withContinuationContext(continuation: Continuation<*>, countOrElement: Any?, block: () -> T): T = block()
+internal actual fun Continuation<*>.toDebugString(): String = toString()
+internal actual val CoroutineContext.coroutineName: String? get() = null // not supported on JS
+
+internal actual class UndispatchedCoroutine<in T> actual constructor(
+    context: CoroutineContext,
+    uCont: Continuation<T>
+) : ScopeCoroutine<T>(context, uCont) {
+    override fun afterResume(state: Any?) = uCont.resumeWith(recoverResult(state, uCont))
+}

kotlinx-coroutines-core/js/src/flow/internal/FlowExceptions.kt renamed to kotlinx-coroutines-core/jsWasm/src/flow/internal/FlowExceptions.kt

@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package kotlinx.coroutines
+
+internal actual val DEBUG: Boolean = false
+
+internal actual val Any.hexAddress: String
+    get() = this.hashCode().toString()
+
+internal actual val Any.classSimpleName: String get() = this::class.simpleName ?: "Unknown"
+
+internal actual inline fun assert(value: () -> Boolean) {}
+
+internal external interface Console {
+    fun error(s: String)
+}
+
+internal external val console: Console