-
Notifications
You must be signed in to change notification settings - Fork 10
Expand file tree
/
Copy pathWacsStore.cs
More file actions
114 lines (95 loc) · 3.53 KB
/
WacsStore.cs
File metadata and controls
114 lines (95 loc) · 3.53 KB
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
using System;
using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using HakoJS.Backend.Configuration;
using HakoJS.Backend.Core;
using Wacs.Core.Runtime;
using Wacs.Core.Runtime.Types;
using Wacs.Core.Types;
using Wacs.WASIp1;
namespace HakoJS.Backend.Wacs;
public sealed class WacsStore : WasmStore
{
private readonly WasmStoreOptions _options;
internal readonly WasmRuntime Runtime;
internal readonly Wasi? Wasi;
private bool _disposed;
internal WacsStore(WacsEngineOptions engineOptions, WasmStoreOptions? storeOptions)
{
_options = storeOptions ?? new WasmStoreOptions
{
WasiConfiguration = storeOptions?.WasiConfiguration,
MaxMemoryBytes = storeOptions?.MaxMemoryBytes
};
Runtime = new WasmRuntime
{
TranspileModules = engineOptions.TranspileModules
};
if (_options.WasiConfiguration != null)
{
var wasiConfig = ConvertWasiConfiguration(_options.WasiConfiguration);
Wasi = new Wasi(wasiConfig);
}
}
public override WasmLinker CreateLinker()
{
ObjectDisposedException.ThrowIf(_disposed, this);
return new WacsLinker(this, _options);
}
public override WasmMemory CreateMemory(MemoryConfiguration config)
{
ObjectDisposedException.ThrowIf(_disposed, this);
ArgumentNullException.ThrowIfNull(config);
var memoryType = new MemoryType(config.InitialPages, config.MaximumPages);
var memoryInstance = new MemoryInstance(memoryType);
return new WacsMemory(memoryInstance);
}
internal WasmMemory CreateMemory(uint initialPages, uint? maximumPages)
{
ObjectDisposedException.ThrowIf(_disposed, this);
var memType = new MemoryType(initialPages, maximumPages);
var memoryInstance = Runtime.BindHostMemory(("env", "memory"), memType);
return new WacsMemory(memoryInstance);
}
private static WasiConfiguration ConvertWasiConfiguration(HakoWasiConfiguration config)
{
List<string> args;
if (config.Arguments != null)
args = config.Arguments.ToList();
else if (config.InheritEnvironment)
args = Environment.GetCommandLineArgs().Skip(1).ToList();
else
args = [];
Dictionary<string, string> envVars;
if (config.EnvironmentVariables != null)
envVars = config.EnvironmentVariables;
else if (config.InheritEnvironment)
envVars = GetHostEnvironmentVariables();
else
envVars = [];
return new WasiConfiguration
{
StandardInput = config.InheritStdio ? Console.OpenStandardInput() : Stream.Null,
StandardOutput = config.InheritStdio ? Console.OpenStandardOutput() : Stream.Null,
StandardError = config.InheritStdio ? Console.OpenStandardError() : Stream.Null,
Arguments = args,
EnvironmentVariables = envVars,
HostRootDirectory = config.PreopenDirectory ?? Directory.GetCurrentDirectory()
};
}
private static Dictionary<string, string> GetHostEnvironmentVariables()
{
return Environment.GetEnvironmentVariables()
.Cast<DictionaryEntry>()
.ToDictionary(e => e.Key.ToString()!, e => e.Value?.ToString() ?? "");
}
protected override void Dispose(bool disposing)
{
if (_disposed) return;
if (disposing) Wasi?.Dispose();
_disposed = true;
base.Dispose(disposing);
}
}