DisposeCapability.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134
  1. using Jint.Runtime;
  2. namespace Jint.Native.Disposable;
  3. internal sealed class DisposeCapability
  4. {
  5. private readonly Engine _engine;
  6. private readonly List<DisposableResource> _disposableResourceStack = [];
  7. public DisposeCapability(Engine engine)
  8. {
  9. _engine = engine;
  10. }
  11. public void AddDisposableResource(JsValue v, DisposeHint hint, ICallable? method = null)
  12. {
  13. DisposableResource resource;
  14. if (method is null)
  15. {
  16. if (v.IsNullOrUndefined() && hint == DisposeHint.Sync)
  17. {
  18. return;
  19. }
  20. resource = CreateDisposableResource(v, hint);
  21. }
  22. else
  23. {
  24. resource = CreateDisposableResource(JsValue.Undefined, hint, method);
  25. }
  26. _disposableResourceStack.Add(resource);
  27. }
  28. private DisposableResource CreateDisposableResource(JsValue v, DisposeHint hint, ICallable? method = null)
  29. {
  30. if (method is null)
  31. {
  32. if (v.IsNullOrUndefined())
  33. {
  34. v = JsValue.Undefined;
  35. method = null;
  36. }
  37. else
  38. {
  39. if (!v.IsObject())
  40. {
  41. Throw.TypeError(_engine.Realm, "Expected an object for disposable resource.");
  42. return default;
  43. }
  44. method = v.AsObject().GetDisposeMethod(hint);
  45. if (method is null)
  46. {
  47. Throw.TypeError(_engine.Realm, "No dispose method found for the resource.");
  48. return default;
  49. }
  50. }
  51. }
  52. return new DisposableResource(v, hint, method);
  53. }
  54. public Completion DisposeResources(Completion c)
  55. {
  56. var needsAwait = false;
  57. var hasAwaited = false;
  58. for (var i = _disposableResourceStack.Count - 1; i >= 0; i--)
  59. {
  60. var (value, hint, method) = _disposableResourceStack[i];
  61. if (hint == DisposeHint.Sync && needsAwait && !hasAwaited)
  62. {
  63. _engine.RunAvailableContinuations();
  64. needsAwait = false;
  65. }
  66. if (method is not null)
  67. {
  68. var result = JsValue.Undefined;
  69. JavaScriptException? exception = null;
  70. try
  71. {
  72. result = method.Call(value);
  73. if (hint == DisposeHint.Async)
  74. {
  75. hasAwaited = true;
  76. try
  77. {
  78. result = result.UnwrapIfPromise(_engine.Options.Constraints.PromiseTimeout);
  79. }
  80. catch (JavaScriptException e)
  81. {
  82. exception = e;
  83. }
  84. }
  85. }
  86. catch (JavaScriptException e)
  87. {
  88. exception = e;
  89. }
  90. if (exception is not null)
  91. {
  92. if (c.Type == CompletionType.Throw)
  93. {
  94. var error = _engine.Intrinsics.SuppressedError.Construct(_engine.Intrinsics.SuppressedError, "", exception.Error, c.Value);
  95. c = new Completion(CompletionType.Throw, error, c._source);
  96. }
  97. else
  98. {
  99. c = new Completion(CompletionType.Throw, exception.Error, c._source);
  100. }
  101. }
  102. }
  103. else
  104. {
  105. // Assert: hint is "async-dispose"
  106. needsAwait = true;
  107. }
  108. }
  109. if (needsAwait && !hasAwaited)
  110. {
  111. _engine.RunAvailableContinuations();
  112. }
  113. _disposableResourceStack.Clear();
  114. return c;
  115. }
  116. private readonly record struct DisposableResource(JsValue ResourceValue, DisposeHint Hint, ICallable? DisposeMethod);
  117. }