it-multipart
Advanced tools
Comparing version
(function (root, factory) {(typeof module === 'object' && module.exports) ? module.exports = factory() : root.ItMultipart = factory()}(typeof self !== 'undefined' ? self : this, function () { | ||
"use strict";var ItMultipart=(()=>{var S=Object.create;var f=Object.defineProperty;var M=Object.getOwnPropertyDescriptor;var _=Object.getOwnPropertyNames;var j=Object.getPrototypeOf,A=Object.prototype.hasOwnProperty;var I=(r,t)=>()=>(t||r((t={exports:{}}).exports,t),t.exports),P=(r,t)=>{for(var e in t)f(r,e,{get:t[e],enumerable:!0})},m=(r,t,e,n)=>{if(t&&typeof t=="object"||typeof t=="function")for(let u of _(t))!A.call(r,u)&&u!==e&&f(r,u,{get:()=>t[u],enumerable:!(n=M(t,u))||n.enumerable});return r};var U=(r,t,e)=>(e=r!=null?S(j(r)):{},m(t||!r||!r.__esModule?f(e,"default",{value:r,enumerable:!0}):e,r)),V=r=>m(f({},"__esModule",{value:!0}),r);var w=I(()=>{});var B={};P(B,{default:()=>y});var x=U(w(),1);var a=class{constructor(t){if(!(t>0)||t-1&t)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(t),this.mask=t-1,this.top=0,this.btm=0,this.next=null}push(t){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=t,this.top=this.top+1&this.mask,!0)}shift(){let t=this.buffer[this.btm];if(t!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,t}isEmpty(){return this.buffer[this.btm]===void 0}},o=class{constructor(t={}){this.hwm=t.splitLimit??16,this.head=new a(this.hwm),this.tail=this.head,this.size=0}calculateSize(t){return t?.byteLength!=null?t.byteLength:1}push(t){if(t?.value!=null&&(this.size+=this.calculateSize(t.value)),!this.head.push(t)){let e=this.head;this.head=e.next=new a(2*this.head.buffer.length),this.head.push(t)}}shift(){let t=this.tail.shift();if(t===void 0&&this.tail.next!=null){let e=this.tail.next;this.tail.next=null,this.tail=e,t=this.tail.shift()}return t?.value!=null&&(this.size-=this.calculateSize(t.value)),t}isEmpty(){return this.head.isEmpty()}};function c(r={}){return q(e=>{let n=e.shift();if(n==null)return{done:!0};if(n.error!=null)throw n.error;return{done:n.done===!0,value:n.value}},r)}function q(r,t){t=t??{};let e=t.onEnd,n=new o,u,s,l,g=async()=>n.isEmpty()?l?{done:!0}:await new Promise((i,L)=>{s=N=>{s=null,n.push(N);try{i(r(n))}catch(k){L(k)}return u}}):r(n),b=i=>s!=null?s(i):(n.push(i),u),E=i=>(n=new o,s!=null?s({error:i}):(n.push({error:i}),u)),p=i=>{if(l)return u;if(t?.objectMode!==!0&&i?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return b({done:!1,value:i})},d=i=>l?u:(l=!0,i!=null?E(i):b({done:!0})),v=()=>(n=new o,d(),{done:!0}),z=i=>(d(i),{done:!0});if(u={[Symbol.asyncIterator](){return this},next:g,return:v,throw:z,push:p,end:d,get readableLength(){return n.size}},e==null)return u;let h=u;return u={[Symbol.asyncIterator](){return this},next(){return h.next()},throw(i){return h.throw(i),e!=null&&(e(i),e=void 0),{done:!0}},return(){return h.return(),e!=null&&(e(),e=void 0),{done:!0}},push:p,end(i){return h.end(i),e!=null&&(e(i),e=void 0),u},get readableLength(){return h.readableLength}},u}async function*y(r){let t=c({objectMode:!0});if(r==null){t.end(new Error("request missing")),yield*t;return}let e=(0,x.default)({keepExtensions:!0});e.parse(r,n=>{t.end(n)}),e.onPart=n=>{let u=c();n.on("data",s=>{u.push(s)}),n.on("end",()=>{u.end()}),n.on("error",s=>{u.end(s)}),t.push({headers:n.headers,body:u})},yield*t}return V(B);})(); | ||
"use strict";var ItMultipart=(()=>{var j=Object.create;var c=Object.defineProperty;var A=Object.getOwnPropertyDescriptor;var I=Object.getOwnPropertyNames;var R=Object.getPrototypeOf,T=Object.prototype.hasOwnProperty;var q=(t,e)=>()=>(e||t((e={exports:{}}).exports,e),e.exports),B=(t,e)=>{for(var r in e)c(t,r,{get:e[r],enumerable:!0})},v=(t,e,r,n)=>{if(e&&typeof e=="object"||typeof e=="function")for(let u of I(e))!T.call(t,u)&&u!==r&&c(t,u,{get:()=>e[u],enumerable:!(n=A(e,u))||n.enumerable});return t};var D=(t,e,r)=>(r=t!=null?j(R(t)):{},v(e||!t||!t.__esModule?c(r,"default",{value:t,enumerable:!0}):r,t)),O=t=>v(c({},"__esModule",{value:!0}),t);var z=q(()=>{});var V={};B(V,{default:()=>k});var L=D(z(),1);function p(){let t={};return t.promise=new Promise((e,r)=>{t.resolve=e,t.reject=r}),t}var b=class{buffer;mask;top;btm;next;constructor(e){if(!(e>0)||e-1&e)throw new Error("Max size for a FixedFIFO should be a power of two");this.buffer=new Array(e),this.mask=e-1,this.top=0,this.btm=0,this.next=null}push(e){return this.buffer[this.top]!==void 0?!1:(this.buffer[this.top]=e,this.top=this.top+1&this.mask,!0)}shift(){let e=this.buffer[this.btm];if(e!==void 0)return this.buffer[this.btm]=void 0,this.btm=this.btm+1&this.mask,e}isEmpty(){return this.buffer[this.btm]===void 0}},h=class{size;hwm;head;tail;constructor(e={}){this.hwm=e.splitLimit??16,this.head=new b(this.hwm),this.tail=this.head,this.size=0}calculateSize(e){return e?.byteLength!=null?e.byteLength:1}push(e){if(e?.value!=null&&(this.size+=this.calculateSize(e.value)),!this.head.push(e)){let r=this.head;this.head=r.next=new b(2*this.head.buffer.length),this.head.push(e)}}shift(){let e=this.tail.shift();if(e===void 0&&this.tail.next!=null){let r=this.tail.next;this.tail.next=null,this.tail=r,e=this.tail.shift()}return e?.value!=null&&(this.size-=this.calculateSize(e.value)),e}isEmpty(){return this.head.isEmpty()}};var w=class extends Error{type;code;constructor(e,r){super(e??"The operation was aborted"),this.type="aborted",this.code=r??"ABORT_ERR"}};function x(t={}){return U(r=>{let n=r.shift();if(n==null)return{done:!0};if(n.error!=null)throw n.error;return{done:n.done===!0,value:n.value}},t)}function U(t,e){e=e??{};let r=e.onEnd,n=new h,u,s,f,m=p(),N=async()=>{try{return n.isEmpty()?f?{done:!0}:await new Promise((i,o)=>{s=d=>{s=null,n.push(d);try{i(t(n))}catch(l){o(l)}return u}}):t(n)}finally{n.isEmpty()&&queueMicrotask(()=>{m.resolve(),m=p()})}},E=i=>s!=null?s(i):(n.push(i),u),M=i=>(n=new h,s!=null?s({error:i}):(n.push({error:i}),u)),g=i=>{if(f)return u;if(e?.objectMode!==!0&&i?.byteLength==null)throw new Error("objectMode was not true but tried to push non-Uint8Array value");return E({done:!1,value:i})},y=i=>f?u:(f=!0,i!=null?M(i):E({done:!0})),P=()=>(n=new h,y(),{done:!0}),S=i=>(y(i),{done:!0});if(u={[Symbol.asyncIterator](){return this},next:N,return:P,throw:S,push:g,end:y,get readableLength(){return n.size},onEmpty:async i=>{let o=i?.signal;if(o?.throwIfAborted(),n.isEmpty())return;let d,l;o!=null&&(d=new Promise((C,_)=>{l=()=>{_(new w)},o.addEventListener("abort",l)}));try{await Promise.race([m.promise,d])}finally{l!=null&&o!=null&&o?.removeEventListener("abort",l)}}},r==null)return u;let a=u;return u={[Symbol.asyncIterator](){return this},next(){return a.next()},throw(i){return a.throw(i),r!=null&&(r(i),r=void 0),{done:!0}},return(){return a.return(),r!=null&&(r(),r=void 0),{done:!0}},push:g,end(i){return a.end(i),r!=null&&(r(i),r=void 0),u},get readableLength(){return a.readableLength}},u}async function*k(t){let e=x({objectMode:!0});if(t==null){e.end(new Error("request missing")),yield*e;return}let r=(0,L.default)({keepExtensions:!0});r.parse(t,n=>{e.end(n)}),r.onPart=n=>{let u=x();n.on("data",s=>{u.push(s)}),n.on("end",()=>{u.end()}),n.on("error",s=>{u.end(s)}),e.push({headers:n.headers,body:u})},yield*e}return O(V);})(); | ||
return ItMultipart})); |
{ | ||
"name": "it-multipart", | ||
"version": "3.0.3", | ||
"version": "3.0.4", | ||
"description": "Async iterable http multipart message parser", | ||
@@ -15,6 +15,2 @@ "author": "Alex Potsides <alex@achingbrain.net>", | ||
}, | ||
"engines": { | ||
"node": ">=16.0.0", | ||
"npm": ">=7.0.0" | ||
}, | ||
"type": "module", | ||
@@ -136,7 +132,7 @@ "types": "./dist/src/index.d.ts", | ||
"formidable": "^2.0.1", | ||
"it-pushable": "^3.1.0" | ||
"it-pushable": "^3.2.0" | ||
}, | ||
"devDependencies": { | ||
"@types/formidable": "^2.0.5", | ||
"aegir": "^39.0.2", | ||
"aegir": "^40.0.11", | ||
"form-data": "^4.0.0", | ||
@@ -143,0 +139,0 @@ "it-drain": "^3.0.0", |
Unidentified License
License(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.
Found 1 instance in 1 package
Unidentified License
License(Experimental) Something that seems like a license was found, but its contents could not be matched with a known license.
Found 1 instance in 1 package
13386
4.29%106
1.92%Updated