orama-js-pool 0.4.1

Create a pool of JavaScript engines to invoke JavaScript code concurrently.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147


import "ext:deno_url/01_urlpattern.js"
import "ext:deno_web/05_base64.js"
import "ext:deno_web/16_image_data.js"
import "ext:deno_web/08_text_encoding.js"
import "ext:deno_web/04_global_interfaces.js"
import "ext:deno_fetch/27_eventsource.js"
import "ext:deno_web/10_filereader.js"
import "ext:deno_web/13_message_port.js"
import "ext:deno_web/15_performance.js"
import "ext:deno_web/14_compression.js"

import "ext:orama_extension/runtime.js"

// The following lines are copied from deno_core repository
// See: https://github.com/denoland/deno/blob/5c8d894aa3858e8aa8130b7d2058033a0c7de539/runtime/js/98_global_scope_shared.js
// That code is licensed under MIT license
import { core } from "ext:core/mod.js";

import * as event from "ext:deno_web/02_event.js";
import * as timers from "ext:deno_web/02_timers.js";
import * as base64 from "ext:deno_web/05_base64.js";
import * as encoding from "ext:deno_web/08_text_encoding.js";
import * as console from "ext:deno_console/01_console.js";
import * as compression from "ext:deno_web/14_compression.js";
import * as performance from "ext:deno_web/15_performance.js";
import * as url from "ext:deno_url/00_url.js";
import * as urlPattern from "ext:deno_url/01_urlpattern.js";
import * as headers from "ext:deno_fetch/20_headers.js";
import * as streams from "ext:deno_web/06_streams.js";
import * as fileReader from "ext:deno_web/10_filereader.js";
import * as file from "ext:deno_web/09_file.js";
import * as formData from "ext:deno_fetch/21_formdata.js";
import * as request from "ext:deno_fetch/23_request.js";
import * as response from "ext:deno_fetch/23_response.js";
import * as fetch from "ext:deno_fetch/26_fetch.js";
import * as eventSource from "ext:deno_fetch/27_eventsource.js";
import * as messagePort from "ext:deno_web/13_message_port.js";
import * as webidl from "ext:deno_webidl/00_webidl.js";
import { DOMException } from "ext:deno_web/01_dom_exception.js";
import * as abortSignal from "ext:deno_web/03_abort_signal.js";
import * as imageData from "ext:deno_web/16_image_data.js";
import * as crypto from "ext:deno_crypto/00_crypto.js";
// This is changed !!!
// We don't want to color the STDOUT/STDERR because we could send it to HTTP...
console.setNoColorFns(
    () => true,
    () => true,
)

const windowOrWorkerGlobalScope = {
    AbortController: core.propNonEnumerable(abortSignal.AbortController),
    AbortSignal: core.propNonEnumerable(abortSignal.AbortSignal),
    Blob: core.propNonEnumerable(file.Blob),
    ByteLengthQueuingStrategy: core.propNonEnumerable(
        streams.ByteLengthQueuingStrategy,
    ),
    CloseEvent: core.propNonEnumerable(event.CloseEvent),
    CompressionStream: core.propNonEnumerable(compression.CompressionStream),
    CountQueuingStrategy: core.propNonEnumerable(
        streams.CountQueuingStrategy,
    ),
    CustomEvent: core.propNonEnumerable(event.CustomEvent),
    DecompressionStream: core.propNonEnumerable(compression.DecompressionStream),
    DOMException: core.propNonEnumerable(DOMException),
    ErrorEvent: core.propNonEnumerable(event.ErrorEvent),
    Event: core.propNonEnumerable(event.Event),
    EventTarget: core.propNonEnumerable(event.EventTarget),
    File: core.propNonEnumerable(file.File),
    FileReader: core.propNonEnumerable(fileReader.FileReader),
    FormData: core.propNonEnumerable(formData.FormData),
    Headers: core.propNonEnumerable(headers.Headers),
    ImageData: core.propNonEnumerable(imageData.ImageData),
    MessageEvent: core.propNonEnumerable(event.MessageEvent),
    Performance: core.propNonEnumerable(performance.Performance),
    PerformanceEntry: core.propNonEnumerable(performance.PerformanceEntry),
    PerformanceMark: core.propNonEnumerable(performance.PerformanceMark),
    PerformanceMeasure: core.propNonEnumerable(performance.PerformanceMeasure),
    PromiseRejectionEvent: core.propNonEnumerable(event.PromiseRejectionEvent),
    ProgressEvent: core.propNonEnumerable(event.ProgressEvent),
    ReadableStream: core.propNonEnumerable(streams.ReadableStream),
    ReadableStreamDefaultReader: core.propNonEnumerable(
        streams.ReadableStreamDefaultReader,
    ),
    Request: core.propNonEnumerable(request.Request),
    Response: core.propNonEnumerable(response.Response),
    TextDecoder: core.propNonEnumerable(encoding.TextDecoder),
    TextEncoder: core.propNonEnumerable(encoding.TextEncoder),
    TextDecoderStream: core.propNonEnumerable(encoding.TextDecoderStream),
    TextEncoderStream: core.propNonEnumerable(encoding.TextEncoderStream),
    TransformStream: core.propNonEnumerable(streams.TransformStream),
    URL: core.propNonEnumerable(url.URL),
    URLPattern: core.propNonEnumerable(urlPattern.URLPattern),
    URLSearchParams: core.propNonEnumerable(url.URLSearchParams),
    MessageChannel: core.propNonEnumerable(messagePort.MessageChannel),
    MessagePort: core.propNonEnumerable(messagePort.MessagePort),
    WritableStream: core.propNonEnumerable(streams.WritableStream),
    WritableStreamDefaultWriter: core.propNonEnumerable(
        streams.WritableStreamDefaultWriter,
    ),
    WritableStreamDefaultController: core.propNonEnumerable(
        streams.WritableStreamDefaultController,
    ),
    ReadableByteStreamController: core.propNonEnumerable(
        streams.ReadableByteStreamController,
    ),
    ReadableStreamBYOBReader: core.propNonEnumerable(
        streams.ReadableStreamBYOBReader,
    ),
    ReadableStreamBYOBRequest: core.propNonEnumerable(
        streams.ReadableStreamBYOBRequest,
    ),
    ReadableStreamDefaultController: core.propNonEnumerable(
        streams.ReadableStreamDefaultController,
    ),
    TransformStreamDefaultController: core.propNonEnumerable(
        streams.TransformStreamDefaultController,
    ),
    atob: core.propWritable(base64.atob),
    btoa: core.propWritable(base64.btoa),
    clearInterval: core.propWritable(timers.clearInterval),
    clearTimeout: core.propWritable(timers.clearTimeout),
    console: core.propNonEnumerable(
        // This is changed!!!!!
        new console.Console((msg, level) => {
            return Deno.core.ops.op_stream_to_oramacore_print(msg, level > 1)
        }),
    ),
    // Coped from:
    // https://github.com/denoland/deno/blob/a02d2201797d5e3436a251ff39e4cde6b2d4a13b/ext/crypto/README.md?plain=1#L13
    Crypto: core.propWritable(crypto.Crypto),
    CryptoKey: core.propWritable(crypto.CryptoKey),
    crypto: core.propWritable(crypto.crypto),
    SubtleCrypto: core.propWritable(crypto.SubtleCrypto),
    fetch: core.propWritable(fetch.fetch),
    EventSource: core.propWritable(eventSource.EventSource),
    performance: core.propWritable(performance.performance),
    reportError: core.propWritable(event.reportError),
    setInterval: core.propWritable(timers.setInterval),
    setTimeout: core.propWritable(timers.setTimeout),
    structuredClone: core.propWritable(messagePort.structuredClone),
    [webidl.brand]: core.propNonEnumerable(webidl.brand),
};

for (const [name, desc] of Object.entries(windowOrWorkerGlobalScope)) {
    Object.defineProperty(globalThis, name, desc);
}