Introduce `FileSink.ref()` and `FileSink.unref()`

1 files changed, 181 insertions, 9 deletions

diff --git a/src/bun.js/bindings/JSSink.cpp b/src/bun.js/bindings/JSSink.cpp
index ed3b6a5ac..a93e4e298 100644
--- a/src/bun.js/bindings/JSSink.cpp
+++ b/src/bun.js/bindings/JSSink.cpp
@@ -1,6 +1,6 @@
 
 // AUTO-GENERATED FILE. DO NOT EDIT.
-// Generated by 'make generate-sink' at 2022-11-20T12:51:04.404Z
+// Generated by 'make generate-sink' at 2022-11-25T07:36:18.561Z
 // To regenerate this file, run:
 //
 //   make generate-sink
@@ -127,6 +127,48 @@ JSC_DEFINE_HOST_FUNCTION(functionStartDirectStream, (JSC::JSGlobalObject * lexic
     RELEASE_AND_RETURN(scope, JSC::JSValue::encode(JSC::jsUndefined()));
 }
 
+void JSArrayBufferSink::ref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount++;
+    if (m_refCount == 1) {
+        ArrayBufferSink__updateRef(m_sinkPtr, true);
+    }
+}
+
+void JSArrayBufferSink::unref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount = std::max(0, m_refCount - 1);
+    if (!m_refCount) {
+        ArrayBufferSink__updateRef(m_sinkPtr, false);
+    }
+}
+
+JSC_DEFINE_HOST_FUNCTION(ArrayBufferSink__ref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSArrayBufferSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->ref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
+JSC_DEFINE_HOST_FUNCTION(ArrayBufferSink__unref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSArrayBufferSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->unref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
 JSC_DEFINE_CUSTOM_GETTER(functionArrayBufferSink__getter, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::EncodedJSValue thisValue, JSC::PropertyName))
 {
     auto& vm = lexicalGlobalObject->vm();
@@ -203,6 +245,48 @@ JSC_DEFINE_HOST_FUNCTION(ArrayBufferSink__doClose, (JSC::JSGlobalObject * lexica
     return JSC::JSValue::encode(JSC::jsUndefined());
 }
 
+void JSFileSink::ref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount++;
+    if (m_refCount == 1) {
+        FileSink__updateRef(m_sinkPtr, true);
+    }
+}
+
+void JSFileSink::unref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount = std::max(0, m_refCount - 1);
+    if (!m_refCount) {
+        FileSink__updateRef(m_sinkPtr, false);
+    }
+}
+
+JSC_DEFINE_HOST_FUNCTION(FileSink__ref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSFileSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->ref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
+JSC_DEFINE_HOST_FUNCTION(FileSink__unref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSFileSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->unref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
 JSC_DEFINE_CUSTOM_GETTER(functionFileSink__getter, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::EncodedJSValue thisValue, JSC::PropertyName))
 {
     auto& vm = lexicalGlobalObject->vm();
@@ -279,6 +363,48 @@ JSC_DEFINE_HOST_FUNCTION(FileSink__doClose, (JSC::JSGlobalObject * lexicalGlobal
     return JSC::JSValue::encode(JSC::jsUndefined());
 }
 
+void JSHTTPResponseSink::ref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount++;
+    if (m_refCount == 1) {
+        HTTPResponseSink__updateRef(m_sinkPtr, true);
+    }
+}
+
+void JSHTTPResponseSink::unref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount = std::max(0, m_refCount - 1);
+    if (!m_refCount) {
+        HTTPResponseSink__updateRef(m_sinkPtr, false);
+    }
+}
+
+JSC_DEFINE_HOST_FUNCTION(HTTPResponseSink__ref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSHTTPResponseSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->ref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
+JSC_DEFINE_HOST_FUNCTION(HTTPResponseSink__unref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSHTTPResponseSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->unref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
 JSC_DEFINE_CUSTOM_GETTER(functionHTTPResponseSink__getter, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::EncodedJSValue thisValue, JSC::PropertyName))
 {
     auto& vm = lexicalGlobalObject->vm();
@@ -355,6 +481,48 @@ JSC_DEFINE_HOST_FUNCTION(HTTPResponseSink__doClose, (JSC::JSGlobalObject * lexic
     return JSC::JSValue::encode(JSC::jsUndefined());
 }
 
+void JSHTTPSResponseSink::ref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount++;
+    if (m_refCount == 1) {
+        HTTPSResponseSink__updateRef(m_sinkPtr, true);
+    }
+}
+
+void JSHTTPSResponseSink::unref()
+{
+    if (!m_sinkPtr)
+        return;
+
+    m_refCount = std::max(0, m_refCount - 1);
+    if (!m_refCount) {
+        HTTPSResponseSink__updateRef(m_sinkPtr, false);
+    }
+}
+
+JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__ref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSHTTPSResponseSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->ref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
+JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__unref, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::CallFrame* callFrame))
+{
+    auto& vm = lexicalGlobalObject->vm();
+    auto* sink = jsDynamicCast<WebCore::JSHTTPSResponseSink*>(callFrame->thisValue());
+    if (LIKELY(sink)) {
+        sink->unref();
+    }
+    return JSC::JSValue::encode(JSC::jsUndefined());
+}
+
 JSC_DEFINE_CUSTOM_GETTER(functionHTTPSResponseSink__getter, (JSC::JSGlobalObject * lexicalGlobalObject, JSC::EncodedJSValue thisValue, JSC::PropertyName))
 {
     auto& vm = lexicalGlobalObject->vm();
@@ -440,6 +608,8 @@ JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__doClose, (JSC::JSGlobalObject * lexi
   end        ArrayBufferSink__end             ReadOnly|DontDelete|Function 0
   start      ArrayBufferSink__start           ReadOnly|DontDelete|Function 1
   write      ArrayBufferSink__write           ReadOnly|DontDelete|Function 1
+  ref        ArrayBufferSink__ref             ReadOnly|DontDelete|Function 0
+  unref      ArrayBufferSink__unref           ReadOnly|DontDelete|Function 0
 @end
 */
 
@@ -460,6 +630,8 @@ JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__doClose, (JSC::JSGlobalObject * lexi
   end        FileSink__end             ReadOnly|DontDelete|Function 0
   start      FileSink__start           ReadOnly|DontDelete|Function 1
   write      FileSink__write           ReadOnly|DontDelete|Function 1
+  ref        FileSink__ref             ReadOnly|DontDelete|Function 0
+  unref      FileSink__unref           ReadOnly|DontDelete|Function 0
 @end
 */
 
@@ -480,6 +652,8 @@ JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__doClose, (JSC::JSGlobalObject * lexi
   end        HTTPResponseSink__end             ReadOnly|DontDelete|Function 0
   start      HTTPResponseSink__start           ReadOnly|DontDelete|Function 1
   write      HTTPResponseSink__write           ReadOnly|DontDelete|Function 1
+  ref        HTTPResponseSink__ref             ReadOnly|DontDelete|Function 0
+  unref      HTTPResponseSink__unref           ReadOnly|DontDelete|Function 0
 @end
 */
 
@@ -500,6 +674,8 @@ JSC_DEFINE_HOST_FUNCTION(HTTPSResponseSink__doClose, (JSC::JSGlobalObject * lexi
   end        HTTPSResponseSink__end             ReadOnly|DontDelete|Function 0
   start      HTTPSResponseSink__start           ReadOnly|DontDelete|Function 1
   write      HTTPSResponseSink__write           ReadOnly|DontDelete|Function 1
+  ref        HTTPSResponseSink__ref             ReadOnly|DontDelete|Function 0
+  unref      HTTPSResponseSink__unref           ReadOnly|DontDelete|Function 0
 @end
 */
 
@@ -1603,8 +1779,7 @@ extern "C" JSC__JSValue ArrayBufferSink__createObject(JSC__JSGlobalObject* arg0,
 {
     auto& vm = arg0->vm();
     Zig::GlobalObject* globalObject = reinterpret_cast<Zig::GlobalObject*>(arg0);
-    JSC::JSValue prototype = globalObject->ArrayBufferSinkPrototype();
-    JSC::Structure* structure = WebCore::JSArrayBufferSink::createStructure(vm, globalObject, prototype);
+    JSC::Structure* structure = globalObject->ArrayBufferSinkStructure();
     return JSC::JSValue::encode(WebCore::JSArrayBufferSink::create(vm, globalObject, structure, sinkPtr));
 }
 
@@ -1690,8 +1865,7 @@ extern "C" JSC__JSValue FileSink__createObject(JSC__JSGlobalObject* arg0, void*
 {
     auto& vm = arg0->vm();
     Zig::GlobalObject* globalObject = reinterpret_cast<Zig::GlobalObject*>(arg0);
-    JSC::JSValue prototype = globalObject->FileSinkPrototype();
-    JSC::Structure* structure = WebCore::JSFileSink::createStructure(vm, globalObject, prototype);
+    JSC::Structure* structure = globalObject->FileSinkStructure();
     return JSC::JSValue::encode(WebCore::JSFileSink::create(vm, globalObject, structure, sinkPtr));
 }
 
@@ -1777,8 +1951,7 @@ extern "C" JSC__JSValue HTTPResponseSink__createObject(JSC__JSGlobalObject* arg0
 {
     auto& vm = arg0->vm();
     Zig::GlobalObject* globalObject = reinterpret_cast<Zig::GlobalObject*>(arg0);
-    JSC::JSValue prototype = globalObject->HTTPResponseSinkPrototype();
-    JSC::Structure* structure = WebCore::JSHTTPResponseSink::createStructure(vm, globalObject, prototype);
+    JSC::Structure* structure = globalObject->HTTPResponseSinkStructure();
     return JSC::JSValue::encode(WebCore::JSHTTPResponseSink::create(vm, globalObject, structure, sinkPtr));
 }
 
@@ -1864,8 +2037,7 @@ extern "C" JSC__JSValue HTTPSResponseSink__createObject(JSC__JSGlobalObject* arg
 {
     auto& vm = arg0->vm();
     Zig::GlobalObject* globalObject = reinterpret_cast<Zig::GlobalObject*>(arg0);
-    JSC::JSValue prototype = globalObject->HTTPSResponseSinkPrototype();
-    JSC::Structure* structure = WebCore::JSHTTPSResponseSink::createStructure(vm, globalObject, prototype);
+    JSC::Structure* structure = globalObject->HTTPSResponseSinkStructure();
     return JSC::JSValue::encode(WebCore::JSHTTPSResponseSink::create(vm, globalObject, structure, sinkPtr));
 }