Skip to content

[wip] feat: implement web streams #1214

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
sgammon wants to merge 1 commit into from
Closed

[wip] feat: implement web streams #1214

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion packages/engine/src/main/kotlin/elide/runtime/plugins/AbstractLanguagePlugin.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,7 @@ import elide.runtime.plugins.bindings.Bindings
context.evaluate(
this,
script.bufferedReader().use { it.readText() },
name = source.path.split("/").last(),
name = source.path.substringAfterLast('/'),
internals = true,
cached = true,
)
Expand Down
119 changes: 115 additions & 4 deletions packages/graalvm/api/graalvm.api
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1113,7 +1113,7 @@ public final class elide/runtime/gvm/internals/intrinsics/js/url/URLSearchParams
public static final fun urlParams (Ljava/lang/String;)Lelide/runtime/intrinsics/js/URLSearchParams;
}

public synthetic class elide/runtime/gvm/internals/intrinsics/js/webstreams/$ReadableStreamIntrinsic$Definition : io/micronaut/context/AbstractInitializableBeanDefinitionAndReference {
public synthetic class elide/runtime/gvm/internals/intrinsics/js/webstreams/$WebStreamsIntrinsic$Definition : io/micronaut/context/AbstractInitializableBeanDefinitionAndReference {
public static final field $ANNOTATION_METADATA Lio/micronaut/core/annotation/AnnotationMetadata;
public fun <init> ()V
protected fun <init> (Ljava/lang/Class;Lio/micronaut/context/AbstractInitializableBeanDefinition$MethodOrFieldReference;)V
Expand Down Expand Up @@ -2036,19 +2036,23 @@ public abstract interface class elide/runtime/intrinsics/js/RandomSource {
public abstract fun randomUUID ()Lelide/runtime/intrinsics/js/typed/UUID;
}

public abstract interface class elide/runtime/intrinsics/js/ReadableStream {
public abstract interface class elide/runtime/intrinsics/js/ReadableStream : elide/runtime/intrinsics/js/Stream {
public static final field DefaultFactory Lelide/runtime/intrinsics/js/ReadableStream$DefaultFactory;
}

public final class elide/runtime/intrinsics/js/ReadableStream$DefaultFactory : elide/runtime/intrinsics/js/ReadableStream$Factory {
public final class elide/runtime/intrinsics/js/ReadableStream$DefaultFactory : elide/runtime/intrinsics/js/ReadableStream$Factory, org/graalvm/polyglot/proxy/ProxyInstantiable {
public fun create (Lelide/runtime/intrinsics/js/stream/ReadableStreamSource;Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/ReadableStream;
public fun empty ()Lelide/runtime/intrinsics/js/ReadableStream;
public fun newInstance ([Lorg/graalvm/polyglot/Value;)Ljava/lang/Object;
public fun wrap (Ljava/io/InputStream;)Lelide/runtime/intrinsics/js/ReadableStream;
public fun wrap (Ljava/io/Reader;)Lelide/runtime/intrinsics/js/ReadableStream;
public fun wrap (Ljava/nio/ByteBuffer;)Lelide/runtime/intrinsics/js/ReadableStream;
public fun wrap ([B)Lelide/runtime/intrinsics/js/ReadableStream;
}

public abstract interface class elide/runtime/intrinsics/js/ReadableStream$Factory {
public abstract interface class elide/runtime/intrinsics/js/ReadableStream$Factory : org/graalvm/polyglot/proxy/ProxyInstantiable {
public fun create (Lelide/runtime/intrinsics/js/stream/ReadableStreamSource;)Lelide/runtime/intrinsics/js/ReadableStream;
public abstract fun create (Lelide/runtime/intrinsics/js/stream/ReadableStreamSource;Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/ReadableStream;
public abstract fun empty ()Lelide/runtime/intrinsics/js/ReadableStream;
public abstract fun wrap (Ljava/io/InputStream;)Lelide/runtime/intrinsics/js/ReadableStream;
public abstract fun wrap (Ljava/io/Reader;)Lelide/runtime/intrinsics/js/ReadableStream;
Expand All @@ -2060,6 +2064,9 @@ public abstract interface class elide/runtime/intrinsics/js/ServerAgent {
public abstract fun initialize (Lorg/graalvm/polyglot/Context;Ljava/util/concurrent/Phaser;)V
}

public abstract interface class elide/runtime/intrinsics/js/Stream {
}

public abstract interface class elide/runtime/intrinsics/js/StringLike : java/lang/CharSequence {
}

Expand All @@ -2079,6 +2086,12 @@ public abstract interface class elide/runtime/intrinsics/js/Timers {
public static synthetic fun setTimeout$default (Lelide/runtime/intrinsics/js/Timers;Ljava/lang/Long;[Ljava/lang/Object;Lorg/graalvm/polyglot/Value;ILjava/lang/Object;)J
}

public abstract interface class elide/runtime/intrinsics/js/TransformStream : elide/runtime/intrinsics/js/Stream {
}

public abstract interface class elide/runtime/intrinsics/js/TransformStream$Factory {
}

public abstract interface class elide/runtime/intrinsics/js/URL : java/io/Serializable, org/graalvm/polyglot/proxy/ProxyObject {
public abstract fun getHash ()Ljava/lang/String;
public abstract fun getHost ()Ljava/lang/String;
Expand Down Expand Up @@ -2118,6 +2131,12 @@ public abstract interface class elide/runtime/intrinsics/js/URLSearchParams : el
public abstract fun sort ()V
}

public abstract interface class elide/runtime/intrinsics/js/WritableStream : elide/runtime/intrinsics/js/Stream {
}

public abstract interface class elide/runtime/intrinsics/js/WritableStream$Factory {
}

public abstract interface class elide/runtime/intrinsics/js/encoding/EncodingUtility : org/graalvm/polyglot/proxy/ProxyObject {
public abstract fun getEncoding ()Ljava/lang/String;
}
Expand Down Expand Up @@ -5130,6 +5149,95 @@ public abstract interface class elide/runtime/intrinsics/js/node/zlib/ZlibOption
public abstract fun getWindowBits ()I
}

public abstract interface class elide/runtime/intrinsics/js/stream/ByteLengthQueuingStrategy : elide/runtime/intrinsics/js/stream/QueuingStrategy, org/graalvm/polyglot/proxy/ProxyObject {
public abstract fun getHighWaterMark ()I
public abstract fun size ()I
}

public abstract interface class elide/runtime/intrinsics/js/stream/CountQueuingStrategy : elide/runtime/intrinsics/js/stream/QueuingStrategy, org/graalvm/polyglot/proxy/ProxyObject {
public abstract fun getHighWaterMark ()I
public fun size ()I
}

public abstract interface class elide/runtime/intrinsics/js/stream/QueuingStrategy {
public abstract fun size ()I
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableByteStreamController : elide/runtime/intrinsics/js/stream/ReadableStreamController {
public static final field Companion Lelide/runtime/intrinsics/js/stream/ReadableByteStreamController$Companion;
public static fun create (Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/stream/ReadableByteStreamController;
}

public final class elide/runtime/intrinsics/js/stream/ReadableByteStreamController$Companion {
public final fun create (Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/stream/ReadableByteStreamController;
public static synthetic fun create$default (Lelide/runtime/intrinsics/js/stream/ReadableByteStreamController$Companion;Lelide/runtime/intrinsics/js/stream/QueuingStrategy;ILjava/lang/Object;)Lelide/runtime/intrinsics/js/stream/ReadableByteStreamController;
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamBYOBReader {
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamBYOBRequest {
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamController {
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamDefaultController : elide/runtime/intrinsics/js/stream/ReadableStreamController {
public static final field Companion Lelide/runtime/intrinsics/js/stream/ReadableStreamDefaultController$Companion;
public static fun create (Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/stream/ReadableStreamDefaultController;
}

public final class elide/runtime/intrinsics/js/stream/ReadableStreamDefaultController$Companion {
public final fun create (Lelide/runtime/intrinsics/js/stream/QueuingStrategy;)Lelide/runtime/intrinsics/js/stream/ReadableStreamDefaultController;
public static synthetic fun create$default (Lelide/runtime/intrinsics/js/stream/ReadableStreamDefaultController$Companion;Lelide/runtime/intrinsics/js/stream/QueuingStrategy;ILjava/lang/Object;)Lelide/runtime/intrinsics/js/stream/ReadableStreamDefaultController;
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamDefaultReader {
}

public abstract interface class elide/runtime/intrinsics/js/stream/ReadableStreamSource {
public static final field Companion Lelide/runtime/intrinsics/js/stream/ReadableStreamSource$Companion;
public abstract fun cancel (Ljava/lang/String;)Ljava/util/concurrent/Future;
public static fun from (Lorg/graalvm/polyglot/Value;)Lelide/runtime/intrinsics/js/stream/ReadableStreamSource;
public abstract fun getType ()Lelide/runtime/intrinsics/js/stream/StreamSourceType;
public abstract fun pull (Lelide/runtime/intrinsics/js/stream/ReadableStreamController;)Ljava/util/concurrent/Future;
public abstract fun start (Lelide/runtime/intrinsics/js/stream/ReadableStreamController;)Ljava/util/concurrent/Future;
}

public final class elide/runtime/intrinsics/js/stream/ReadableStreamSource$Companion {
public final fun from (Lorg/graalvm/polyglot/Value;)Lelide/runtime/intrinsics/js/stream/ReadableStreamSource;
}

public final class elide/runtime/intrinsics/js/stream/StreamSourceType : java/lang/Enum, elide/core/api/Symbolic {
public static final field BYTES Lelide/runtime/intrinsics/js/stream/StreamSourceType;
public static final field Companion Lelide/runtime/intrinsics/js/stream/StreamSourceType$Companion;
public static final field DEFAULT Lelide/runtime/intrinsics/js/stream/StreamSourceType;
public static fun getEntries ()Lkotlin/enums/EnumEntries;
public synthetic fun getSymbol ()Ljava/lang/Object;
public fun getSymbol ()Ljava/lang/String;
public static fun valueOf (Ljava/lang/String;)Lelide/runtime/intrinsics/js/stream/StreamSourceType;
public static fun values ()[Lelide/runtime/intrinsics/js/stream/StreamSourceType;
}

public final class elide/runtime/intrinsics/js/stream/StreamSourceType$Companion : elide/core/api/Symbolic$SealedResolver {
public synthetic fun resolve (Ljava/lang/Object;)Lelide/core/api/Symbolic;
public fun resolve (Ljava/lang/String;)Lelide/runtime/intrinsics/js/stream/StreamSourceType;
}

public final class elide/runtime/intrinsics/js/stream/StreamSourceTypeKt {
public static final field STREAM_SOURCE_TYPE_BYTES Ljava/lang/String;
public static final field STREAM_SOURCE_TYPE_DEFAULT Ljava/lang/String;
}

public abstract interface class elide/runtime/intrinsics/js/stream/TransformStreamDefaultController {
}

public abstract interface class elide/runtime/intrinsics/js/stream/WritableStreamDefaultController {
}

public abstract interface class elide/runtime/intrinsics/js/stream/WritableStreamDefaultWriter {
}

public abstract interface class elide/runtime/intrinsics/js/typed/UUID : elide/runtime/intrinsics/js/StringLike {
public abstract fun getAsString ()Ljava/lang/String;
}
Expand Down Expand Up @@ -7485,6 +7593,7 @@ public final class elide/runtime/plugins/js/JavaScriptConfig : elide/runtime/plu
public final fun getCharset ()Ljava/nio/charset/Charset;
public final fun getDefaultLocale ()Ljava/util/Locale;
public final fun getEsm ()Z
public final fun getHighResTimers ()Z
public final fun getInteractive ()Z
public final fun getLanguage ()Lelide/runtime/plugins/js/JavaScriptVersion;
public final fun getLocale ()Ljava/util/Locale;
Expand All @@ -7497,6 +7606,7 @@ public final class elide/runtime/plugins/js/JavaScriptConfig : elide/runtime/plu
public final fun setCharset (Ljava/nio/charset/Charset;)V
public final fun setDefaultLocale (Ljava/util/Locale;)V
public final fun setEsm (Z)V
public final fun setHighResTimers (Z)V
public final fun setInteractive (Z)V
public final fun setLanguage (Lelide/runtime/plugins/js/JavaScriptVersion;)V
public final fun setLocale (Ljava/util/Locale;)V
Expand Down Expand Up @@ -7528,6 +7638,7 @@ public final class elide/runtime/plugins/js/JavaScriptVersion : java/lang/Enum {
public static final field ES2021 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field ES2022 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field ES2023 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field ES2024 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field ES5 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field ES6 Lelide/runtime/plugins/js/JavaScriptVersion;
public static final field LATEST Lelide/runtime/plugins/js/JavaScriptVersion;
Expand Down
4 changes: 2 additions & 2 deletions packages/graalvm/detekt-baseline.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@
<CurrentIssues>
<ID>ComplexCondition:AbstractStaticNativeLibraryFeature.kt$AbstractStaticNativeLibraryFeature$!it.builtin &amp;&amp; !it.registerPrefix &amp;&amp; !it.registerJni &amp;&amp; !it.eager</ID>
<ID>ComplexCondition:NodeAssertTest.kt$NodeAssertTest$(left is Value &amp;&amp; left.isNull) || (right is Value &amp;&amp; right.isNull)</ID>
<ID>ExplicitGarbageCollectionCall:EmbeddedGuestVFSImpl.kt$EmbeddedGuestVFSImpl$gc()</ID>
<ID>ForbiddenComment:HostVFS.kt$HostVFS$// @TODO: OS-specific? configurable?</ID>
<ID>ForbiddenComment:IntrinsicsResolver.kt$IntrinsicsResolver$// @TODO: disablement</ID>
<ID>ForbiddenComment:JsEncoding.kt$TextDecoder$// @TODO: honor `DecodeOptions` from host?</ID>
Expand Down Expand Up @@ -41,7 +40,6 @@
<ID>MatchingDeclarationName:EnvPlugin.kt$Environment</ID>
<ID>MatchingDeclarationName:Types.kt$GuestHandlerFunction</ID>
<ID>MatchingDeclarationName:VfsPlugin.kt$Vfs</ID>
<ID>MaxLineLength:EmbeddedGuestVFSImpl.kt$EmbeddedGuestVFSImpl$assert(bundleStream.canReadEntryData(entry)) { "Bundle '${bundle.location}' cannot read entry '${info.path}'" }</ID>
<ID>MaxLineLength:JsConcurrentMap.kt$JsConcurrentMap.Factory$*</ID>
<ID>MaxLineLength:JsMutableMultiMap.kt$JsMutableMultiMap.Factory$@JvmStatic override</ID>
<ID>MaxLineLength:URLIntrinsicTest.kt$URLIntrinsicTest$"equal,https://dl.elide.dev/test?abc=123&amp;def=456,https://dl.elide.dev/test?abc=123&amp;def=456,true,URLs should be equal"</ID>
Expand Down Expand Up @@ -113,5 +111,7 @@
<ID>UnusedPrivateMember:HttpServerAgent.kt$HttpServerAgent.Companion$private fun resolveLanguage(source: Source): GuestLanguage</ID>
<ID>UnusedPrivateMember:NativeCryptoFeature.kt$NativeCryptoFeature$private fun renameNativeCryptoLib(lib: String): String</ID>
<ID>UnusedPrivateProperty:AbstractJsIntrinsicTest.kt$AbstractJsIntrinsicTest$private val testInject: Boolean = true</ID>
<ID>UnusedPrivateProperty:JavaScript.kt$JavaScript$private val resources: LanguagePluginManifest</ID>
<ID>UnusedPrivateProperty:JavaScriptLang.kt$JavaScriptLang$/** * TBD. */ @JvmStatic private val SYMBOL_ELIDE: Symbol = Symbol.createPrivate(ELIDE)</ID>
</CurrentIssues>
</SmellBaseline>
75 changes: 0 additions & 75 deletions ...in/kotlin/elide/runtime/gvm/internals/intrinsics/js/webstreams/ReadableStreamIntrinsic.kt
View file
Open in desktop

This file was deleted.

Loading
Loading