// @ts-nocheck /* * Copyright (C) 2020 Apple Inc. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF * THE POSSIBILITY OF SUCH DAMAGE. */ // @internal export function isTransformStream(stream) { return $isObject(stream) && !!$getByIdDirectPrivate(stream, "readable"); } export function isTransformStreamDefaultController(controller) { return $isObject(controller) && !!$getByIdDirectPrivate(controller, "transformAlgorithm"); } export function createTransformStream( startAlgorithm, transformAlgorithm, flushAlgorithm, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm, ) { if (writableHighWaterMark === undefined) writableHighWaterMark = 1; if (writableSizeAlgorithm === undefined) writableSizeAlgorithm = () => 1; if (readableHighWaterMark === undefined) readableHighWaterMark = 0; if (readableSizeAlgorithm === undefined) readableSizeAlgorithm = () => 1; $assert(writableHighWaterMark >= 0); $assert(readableHighWaterMark >= 0); const transform = {}; $putByIdDirectPrivate(transform, "TransformStream", true); const stream = new TransformStream(transform); const startPromiseCapability = $newPromiseCapability(Promise); $initializeTransformStream( stream, startPromiseCapability.promise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm, ); const controller = new TransformStreamDefaultController(); $setUpTransformStreamDefaultController(stream, controller, transformAlgorithm, flushAlgorithm); startAlgorithm().$then( () => { startPromiseCapability.resolve.$call(); }, error => { startPromiseCapability.reject.$call(undefined, error); }, ); return stream; } export function initializeTransformStream( stream, startPromise, writableHighWaterMark, writableSizeAlgorithm, readableHighWaterMark, readableSizeAlgorithm, ) { const startAlgorithm = () => { return startPromise; }; const writeAlgorithm = chunk => { return $transformStreamDefaultSinkWriteAlgorithm(stream, chunk); }; const abortAlgorithm = reason => { return $transformStreamDefaultSinkAbortAlgorithm(stream, reason); }; const closeAlgorithm = () => { return $transformStreamDefaultSinkCloseAlgorithm(stream); }; const writable = $createWritableStream( startAlgorithm, writeAlgorithm, closeAlgorithm, abortAlgorithm, writableHighWaterMark, writableSizeAlgorithm, ); const pullAlgorithm = () => { return $transformStreamDefaultSourcePullAlgorithm(stream); }; const cancelAlgorithm = reason => { $transformStreamErrorWritableAndUnblockWrite(stream, reason); return Promise.$resolve(); }; const underlyingSource = {}; $putByIdDirectPrivate(underlyingSource, "start", startAlgorithm); $putByIdDirectPrivate(underlyingSource, "pull", pullAlgorithm); $putByIdDirectPrivate(underlyingSource, "cancel", cancelAlgorithm); const options = {}; $putByIdDirectPrivate(options, "size", readableSizeAlgorithm); $putByIdDirectPrivate(options, "highWaterMark", readableHighWaterMark); const readable = new ReadableStream(underlyingSource, options); // The writable to expose to JS through writable getter. $putByIdDirectPrivate(stream, "writable", writable); // The writable to use for the actual transform algorithms. $putByIdDirectPrivate(stream, "internalWritable", $getInternalWritableStream(writable)); $putByIdDirectPrivate(stream, "readable", readable); $putByIdDirectPrivate(stream, "backpressure", undefined); $putByIdDirectPrivate(stream, "backpressureChangePromise", undefined); $transformStreamSetBackpressure(stream, true); $putByIdDirectPrivate(stream, "controller", undefined); } export function transformStreamError(stream, e) { const readable = $getByIdDirectPrivate(stream, "readable"); const readableController = $getByIdDirectPrivate(readable, "readableStreamController"); $readableStreamDefaultControllerError(readableController, e); $transformStreamErrorWritableAndUnblockWrite(stream, e); } export function transformStreamErrorWritableAndUnblockWrite(stream, e) { $transformStreamDefaultControllerClearAlgorithms($getByIdDirectPrivate(stream, "controller")); const writable = $getByIdDirectPrivate(stream, "internalWritable"); $writableStreamDefaultControllerErrorIfNeeded($getByIdDirectPrivate(writable, "controller"), e); if ($getByIdDirectPrivate(stream, "backpressure")) $transformStreamSetBackpressure(stream, false); } export function transformStreamSetBackpressure(stream, backpressure) { $assert($getByIdDirectPrivate(stream, "backpressure") !== backpressure); const backpressureChangePromise = $getByIdDirectPrivate(stream, "backpressureChangePromise"); if (backpressureChangePromise !== undefined) backpressureChangePromise.resolve.$call(); $putByIdDirectPrivate(stream, "backpressureChangePromise", $newPromiseCapability(Promise)); $putByIdDirectPrivate(stream, "backpressure", backpressure); } export function setUpTransformStreamDefaultController(stream, controller, transformAlgorithm, flushAlgorithm) { $assert($isTransformStream(stream)); $assert($getByIdDirectPrivate(stream, "controller") === undefined); $putByIdDirectPrivate(controller, "stream", stream); $putByIdDirectPrivate(stream, "controller", controller); $putByIdDirectPrivate(controller, "transformAlgorithm", transformAlgorithm); $putByIdDirectPrivate(controller, "flushAlgorithm", flushAlgorithm); } export function setUpTransformStreamDefaultControllerFromTransformer(stream, transformer, transformerDict) { const controller = new TransformStreamDefaultController(); let transformAlgorithm = chunk => { try { $transformStreamDefaultControllerEnqueue(controller, chunk); } catch (e) { return Promise.$reject(e); } return Promise.$resolve(); }; let flushAlgorithm = () => { return Promise.$resolve(); }; if ("transform" in transformerDict) transformAlgorithm = chunk => { return $promiseInvokeOrNoopMethod(transformer, transformerDict["transform"], [chunk, controller]); }; if ("flush" in transformerDict) { flushAlgorithm = () => { return $promiseInvokeOrNoopMethod(transformer, transformerDict["flush"], [controller]); }; } $setUpTransformStreamDefaultController(stream, controller, transformAlgorithm, flushAlgorithm); } export function transformStreamDefaultControllerClearAlgorithms(controller) { // We set transformAlgorithm to true to allow GC but keep the isTransformStreamDefaultController check. $putByIdDirectPrivate(controller, "transformAlgorithm", true); $putByIdDirectPrivate(controller, "flushAlgorithm", undefined); } export function transformStreamDefaultControllerEnqueue(controller, chunk) { const stream = $getByIdDirectPrivate(controller, "stream"); const readable = $getByIdDirectPrivate(stream, "readable"); const readableController = $getByIdDirectPrivate(readable, "readableStreamController"); $assert(readableController !== undefined); if (!$readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) $throwTypeError("TransformStream.readable cannot close or enqueue"); try { $readableStreamDefaultControllerEnqueue(readableController, chunk); } catch (e) { $transformStreamErrorWritableAndUnblockWrite(stream, e); throw $getByIdDirectPrivate(readable, "storedError"); } const backpressure = !$readableStreamDefaultControllerShouldCallPull(readableController); if (backpressure !== $getByIdDirectPrivate(stream, "backpressure")) { $assert(backpressure); $transformStreamSetBackpressure(stream, true); } } export function transformStreamDefaultControllerError(controller, e) { $transformStreamError($getByIdDirectPrivate(controller, "stream"), e); } export function transformStreamDefaultControllerPerformTransform(controller, chunk) { const promiseCapability = $newPromiseCapability(Promise); const transformPromise = $getByIdDirectPrivate(controller, "transformAlgorithm").$call(undefined, chunk); transformPromise.$then( () => { promiseCapability.resolve(); }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); promiseCapability.reject.$call(undefined, r); }, ); return promiseCapability.promise; } export function transformStreamDefaultControllerTerminate(controller) { const stream = $getByIdDirectPrivate(controller, "stream"); const readable = $getByIdDirectPrivate(stream, "readable"); const readableController = $getByIdDirectPrivate(readable, "readableStreamController"); // FIXME: Update readableStreamDefaultControllerClose to make this check. if ($readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) $readableStreamDefaultControllerClose(readableController); const error = $makeTypeError("the stream has been terminated"); $transformStreamErrorWritableAndUnblockWrite(stream, error); } export function transformStreamDefaultSinkWriteAlgorithm(stream, chunk) { const writable = $getByIdDirectPrivate(stream, "internalWritable"); $assert($getByIdDirectPrivate(writable, "state") === "writable"); const controller = $getByIdDirectPrivate(stream, "controller"); if ($getByIdDirectPrivate(stream, "backpressure")) { const promiseCapability = $newPromiseCapability(Promise); const backpressureChangePromise = $getByIdDirectPrivate(stream, "backpressureChangePromise"); $assert(backpressureChangePromise !== undefined); backpressureChangePromise.promise.$then( () => { const state = $getByIdDirectPrivate(writable, "state"); if (state === "erroring") { promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(writable, "storedError")); return; } $assert(state === "writable"); $transformStreamDefaultControllerPerformTransform(controller, chunk).$then( () => { promiseCapability.resolve(); }, e => { promiseCapability.reject.$call(undefined, e); }, ); }, e => { promiseCapability.reject.$call(undefined, e); }, ); return promiseCapability.promise; } return $transformStreamDefaultControllerPerformTransform(controller, chunk); } export function transformStreamDefaultSinkAbortAlgorithm(stream, reason) { $transformStreamError(stream, reason); return Promise.$resolve(); } export function transformStreamDefaultSinkCloseAlgorithm(stream) { const readable = $getByIdDirectPrivate(stream, "readable"); const controller = $getByIdDirectPrivate(stream, "controller"); const readableController = $getByIdDirectPrivate(readable, "readableStreamController"); const flushAlgorithm = $getByIdDirectPrivate(controller, "flushAlgorithm"); $assert(flushAlgorithm !== undefined); const flushPromise = $getByIdDirectPrivate(controller, "flushAlgorithm").$call(); $transformStreamDefaultControllerClearAlgorithms(controller); const promiseCapability = $newPromiseCapability(Promise); flushPromise.$then( () => { if ($getByIdDirectPrivate(readable, "state") === $streamErrored) { promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); return; } // FIXME: Update readableStreamDefaultControllerClose to make this check. if ($readableStreamDefaultControllerCanCloseOrEnqueue(readableController)) $readableStreamDefaultControllerClose(readableController); promiseCapability.resolve(); }, r => { $transformStreamError($getByIdDirectPrivate(controller, "stream"), r); promiseCapability.reject.$call(undefined, $getByIdDirectPrivate(readable, "storedError")); }, ); return promiseCapability.promise; } export function transformStreamDefaultSourcePullAlgorithm(stream) { $assert($getByIdDirectPrivate(stream, "backpressure")); $assert($getByIdDirectPrivate(stream, "backpressureChangePromise") !== undefined); $transformStreamSetBackpressure(stream, false); return $getByIdDirectPrivate(stream, "backpressureChangePromise").promise; } n> Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/packages/integrations/netlify/test/functions/fixtures/.gitignore (unfollow)
AgeCommit message (Collapse)AuthorFilesLines
2022-09-29[ci] update lockfile (#4899)Gravatar Fred K. Bot 1-735/+718
Co-authored-by: FredKSchott <FredKSchott@users.noreply.github.com> Co-authored-by: Matthew Phillips <matthew@skypack.dev>
2022-09-29[ci] formatGravatar matthewp 1-1/+3
2022-09-29fix trailing slash mismatch in dev vs build in docs example (#4912)Gravatar Rishi Raj Jain 1-1/+1
2022-09-29[ci] formatGravatar bluwy 1-1/+1
2022-09-29Support Vue JSX (#4897)Gravatar Bjorn Lu 12-5/+329
Co-authored-by: Dan Jutan <danjutan@gmail.com>
2022-09-28[ci] formatGravatar matthewp 1-8/+4
2022-09-28Fix CSS ordering between imported and Astro styles (#4907)Gravatar Matthew Phillips 12-7/+218
* Fix CSS ordering between imported and Astro styles * Fix linting errors * Add changeset and upgrade compiler version * Update test to reflect shared styles placed before page styles
2022-09-28[ci] formatGravatar matthewp 23-137/+127
2022-09-28Astro.cookies implementation (#4876)Gravatar Matthew Phillips 32-29/+943
* Astro.cookies implementation * Remove unused var * Fix build * Add a changesetp * Remove spoken-word expires
2022-09-28Fix: let Squoosh default image quality internally (#4906)Gravatar Tony Sullivan 5-11/+20
* removes our quality defaults, allowing Squoosh format-specific defaults to be used * chore: add changeset
2022-09-28Update README.md (#4898)Gravatar stijlmassi 1-2/+3
* Update README.md In the astro.config.mjs: defineConfig() was missing. * Update packages/integrations/tailwind/README.md Co-authored-by: Yan Thomas <61414485+Yan-Thomas@users.noreply.github.com> Co-authored-by: Fred K. Schott <fkschott@gmail.com> Co-authored-by: Yan Thomas <61414485+Yan-Thomas@users.noreply.github.com>
2022-09-28Fix test (#4904)Gravatar Bjorn Lu 2-1/+7
2022-09-28[ci] formatGravatar FredKSchott 2-4/+4
2022-09-28redesign basics template (#4879)Gravatar Fred K. Schott 3-88/+34
2022-09-28[ci] formatGravatar bluwy 1-2/+2
2022-09-28Remove shamefully-hoist (#4842)Gravatar Bjorn Lu 104-527/+768
2022-09-28[ci] formatGravatar matthewp 4-14/+16
2022-09-28Hoist hydration script out of slot templates (#4891)Gravatar Matthew Phillips 13-43/+165
* Hoist hydration script out of slot templates * Add changeset * Fix HTML components * Mark as html string
2022-09-28Ensure head content rendered once with lazy layouts (#4892)Gravatar Matthew Phillips 9-3/+59
* Ensure head content rendered once with lazy layouts * Add changeset
2022-09-27fixed typing (#4893)Gravatar tweenietomatoes 1-1/+1
2022-09-27[ci] release (#4846)create-astro@1.1.0astro@1.3.1@astrojs/webapi@1.1.0@astrojs/vercel@2.0.1@astrojs/mdx@0.11.2@astrojs/image@0.8.0Gravatar Fred K. Bot 60-185/+169
Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>
2022-09-27fix: post API routes in SSG should warn or error during dev mode (#4878)Gravatar Rishi Raj Jain 3-2/+17
* Update endpoint.ts * add warning for post routes called when output is not server * Update famous-camels-study.md * Update endpoint.ts * If not get * Resolve changes
2022-09-27docs: Fix links to Tailwind examples (#4883)Gravatar Deanmv 1-1/+1
Co-authored-by: Sarah Rainsberger <sarah@rainsberger.ca>
2022-09-27Set SSR target webworker for Vercel edge (#4884)Gravatar Bjorn Lu 2-0/+6
2022-09-27[ci] update lockfile (#4885)Gravatar Fred K. Bot 1-86/+79
Co-authored-by: FredKSchott <FredKSchott@users.noreply.github.com>
2022-09-26[ci] formatGravatar bholmesdev 3-23/+19
2022-09-26Fix: correctly transform `import.meta.env.*` in MDX (#4858)Gravatar Ben Holmes 12-233/+454
* fix: serialize route pattern for Netlify edge Co-authored-by: Jackie Macharia <jackiewmacharia> * fix: escape import.meta.env in MDX compiler output * test: env vars in mdx * chore: changeset * deps: estree-util-visit, @types/estree * feat: inject import.meta.env w/ recma * feat: pull importMetaEnv from vite + astro configs * test: `import.meta.env` in JSX * fix: lockfile * chore: update changeset * fix: remove stray stashed commit
2022-09-26Change negative lookbehind to lookahead (#4866)Gravatar Rishi Raj Jain 1-1/+1
2022-09-26add double check on astro file return type to display more human readable ↵Gravatar Steven Yung 6-2/+61
error (#4857)
2022-09-26[ci] update lockfile (#4862)Gravatar Fred K. Bot 1-81/+81
Co-authored-by: FredKSchott <FredKSchott@users.noreply.github.com>
2022-09-26fix: Script with innerHTML not working on Safari (#4861)Gravatar Rishi Raj Jain 3-3/+10
* fix: Script with innerHTML not working on Safari * Update cool-camels-tease.md
2022-09-26Prevent /undefined catch-all routes in dev (#4873)Gravatar Bjorn Lu 6-9/+66
2022-09-26fix: 🐛 BUG: class:list directive adding class attribute when undefined ↵Gravatar Rishi Raj Jain 2-2/+9
(#4867) * Update hydration.ts * Create lucky-comics-bow.md
2022-09-26docs: Standardize common integration READMEs (#4874)Gravatar Jake Strawn 7-6/+66
2022-09-26docs: Update references to support channel in Discord. (#4872)Gravatar Jake Strawn 12-12/+12
2022-09-26[ci] formatGravatar bluwy 1-1/+1
2022-09-26fix: "chunks" directory appears in build output, if custom modules are ↵Gravatar Rishi Raj Jain 2-6/+34
imported in Astro files (#4868)
2022-09-23[ci] formatGravatar matthewp 1-1/+1
2022-09-23Define toStringTag another way (#4855)Gravatar Matthew Phillips 2-4/+12
* Define toStringTag another way * Adding a changeset
2022-09-23update SSR example to match recent change on Astro API Context (#4854)Gravatar Steven Yung 2-4/+6
2022-09-23[ci] update lockfile (#4852)Gravatar Fred K. Bot 1-373/+402
Co-authored-by: FredKSchott <FredKSchott@users.noreply.github.com>