Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

@datastream/charset

Package Overview
Dependencies
Maintainers
1
Versions
48
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@datastream/charset - npm Package Compare versions

Comparing version
0.0.38
to
0.0.39
+2
-4
decode.node.mjs

@@ -21,6 +21,4 @@ import { createTransformStream } from "@datastream/core";

const getSupportedEncoding = (charset) => {
if (charset === "ISO-8859-8-I")
charset = "ISO-8859-8";
if (!iconv.encodingExists(charset))
charset = "UTF-8";
if (charset === "ISO-8859-8-I") charset = "ISO-8859-8";
if (!iconv.encodingExists(charset)) charset = "UTF-8";
return charset;

@@ -27,0 +25,0 @@ };

@@ -5,4 +5,4 @@ {

"sourcesContent": ["import { createTransformStream } from '@datastream/core'\nimport iconv from 'iconv-lite'\n\nexport const charsetDecodeStream = ({ charset } = {}, streamOptions) => {\n charset = getSupportedEncoding(charset)\n\n const conv = iconv.getDecoder(charset)\n\n const transform = (chunk, enqueue) => {\n const res = conv.write(chunk)\n if (res?.length) {\n enqueue(res, 'utf8')\n }\n }\n const flush = (enqueue) => {\n const res = conv.end()\n if (res?.length) {\n enqueue(res, 'utf8')\n }\n }\n return createTransformStream(transform, flush, streamOptions)\n}\n\n// TODO to peek ahead and determin charset from that\n/*\nexport const charsetDetectDecodeStream = (\n { charset, peekAhead } = { peekAhead: 0 },\n streamOptions\n) => {\n charset = getSupportedEncoding(charset)\n\n let conv,\n peekAheadChunk = ''\n\n const transform = (chunk, enqueue) => {\n if (!conv && peekahead && peekahead < peekAheadChunk.length) {\n peekAheadChunk += chunk\n return\n }\n if (!conv) {\n conv = iconv.getDecoder(charset)\n chunk = peekAheadChunk + chunk\n }\n\n const res = conv.write(chunk)\n if (res?.length) {\n enqueue(res, 'utf8')\n }\n }\n const flush = (enqueue) => {\n const res = conv.end()\n if (res?.length) {\n enqueue(res, 'utf8')\n }\n }\n return createTransformStream(transform, flush, streamOptions)\n} */\n\nconst getSupportedEncoding = (charset) => {\n if (charset === 'ISO-8859-8-I') charset = 'ISO-8859-8'\n if (!iconv.encodingExists(charset)) charset = 'UTF-8'\n return charset\n}\nexport default charsetDecodeStream\n"],
"mappings": "AAAA,SAAS,6BAA6B;AACtC,OAAO,WAAW;AAEX,MAAM,sBAAsB,CAAC,EAAE,QAAQ,IAAI,CAAC,GAAG,kBAAkB;AACtE,YAAU,qBAAqB,OAAO;AAEtC,QAAM,OAAO,MAAM,WAAW,OAAO;AAErC,QAAM,YAAY,CAAC,OAAO,YAAY;AACpC,UAAM,MAAM,KAAK,MAAM,KAAK;AAC5B,QAAI,KAAK,QAAQ;AACf,cAAQ,KAAK,MAAM;AAAA,IACrB;AAAA,EACF;AACA,QAAM,QAAQ,CAAC,YAAY;AACzB,UAAM,MAAM,KAAK,IAAI;AACrB,QAAI,KAAK,QAAQ;AACf,cAAQ,KAAK,MAAM;AAAA,IACrB;AAAA,EACF;AACA,SAAO,sBAAsB,WAAW,OAAO,aAAa;AAC9D;AAqCA,MAAM,uBAAuB,CAAC,YAAY;AACxC,MAAI,YAAY;AAAgB,cAAU;AAC1C,MAAI,CAAC,MAAM,eAAe,OAAO;AAAG,cAAU;AAC9C,SAAO;AACT;AACA,IAAO,sBAAQ;",
"mappings": "AAAA,SAAS,6BAA6B;AACtC,OAAO,WAAW;AAEX,MAAM,sBAAsB,CAAC,EAAE,QAAQ,IAAI,CAAC,GAAG,kBAAkB;AACtE,YAAU,qBAAqB,OAAO;AAEtC,QAAM,OAAO,MAAM,WAAW,OAAO;AAErC,QAAM,YAAY,CAAC,OAAO,YAAY;AACpC,UAAM,MAAM,KAAK,MAAM,KAAK;AAC5B,QAAI,KAAK,QAAQ;AACf,cAAQ,KAAK,MAAM;AAAA,IACrB;AAAA,EACF;AACA,QAAM,QAAQ,CAAC,YAAY;AACzB,UAAM,MAAM,KAAK,IAAI;AACrB,QAAI,KAAK,QAAQ;AACf,cAAQ,KAAK,MAAM;AAAA,IACrB;AAAA,EACF;AACA,SAAO,sBAAsB,WAAW,OAAO,aAAa;AAC9D;AAqCA,MAAM,uBAAuB,CAAC,YAAY;AACxC,MAAI,YAAY,eAAgB,WAAU;AAC1C,MAAI,CAAC,MAAM,eAAe,OAAO,EAAG,WAAU;AAC9C,SAAO;AACT;AACA,IAAO,sBAAQ;",
"names": []
}

@@ -21,6 +21,4 @@ import { createTransformStream } from "@datastream/core";

const getSupportedEncoding = (charset) => {
if (charset === "ISO-8859-8-I")
charset = "ISO-8859-8";
if (!iconv.encodingExists(charset))
charset = "UTF-8";
if (charset === "ISO-8859-8-I") charset = "ISO-8859-8";
if (!iconv.encodingExists(charset)) charset = "UTF-8";
return charset;

@@ -27,0 +25,0 @@ };

@@ -5,4 +5,4 @@ {

"sourcesContent": ["import { createTransformStream } from '@datastream/core'\nimport iconv from 'iconv-lite'\n\nexport const charsetEncodeStream = ({ charset } = {}, streamOptions) => {\n charset = getSupportedEncoding(charset)\n\n const conv = iconv.getEncoder(charset)\n const transform = (chunk, enqueue) => {\n const res = conv.write(chunk)\n if (res?.length) {\n enqueue(res)\n }\n }\n const flush = (enqueue) => {\n const res = conv.end()\n if (res?.length) {\n enqueue(res)\n }\n }\n return createTransformStream(transform, flush, streamOptions)\n}\n\nconst getSupportedEncoding = (charset) => {\n if (charset === 'ISO-8859-8-I') charset = 'ISO-8859-8'\n if (!iconv.encodingExists(charset)) charset = 'UTF-8'\n return charset\n}\nexport default charsetEncodeStream\n"],
"mappings": "AAAA,SAAS,6BAA6B;AACtC,OAAO,WAAW;AAEX,MAAM,sBAAsB,CAAC,EAAE,QAAQ,IAAI,CAAC,GAAG,kBAAkB;AACtE,YAAU,qBAAqB,OAAO;AAEtC,QAAM,OAAO,MAAM,WAAW,OAAO;AACrC,QAAM,YAAY,CAAC,OAAO,YAAY;AACpC,UAAM,MAAM,KAAK,MAAM,KAAK;AAC5B,QAAI,KAAK,QAAQ;AACf,cAAQ,GAAG;AAAA,IACb;AAAA,EACF;AACA,QAAM,QAAQ,CAAC,YAAY;AACzB,UAAM,MAAM,KAAK,IAAI;AACrB,QAAI,KAAK,QAAQ;AACf,cAAQ,GAAG;AAAA,IACb;AAAA,EACF;AACA,SAAO,sBAAsB,WAAW,OAAO,aAAa;AAC9D;AAEA,MAAM,uBAAuB,CAAC,YAAY;AACxC,MAAI,YAAY;AAAgB,cAAU;AAC1C,MAAI,CAAC,MAAM,eAAe,OAAO;AAAG,cAAU;AAC9C,SAAO;AACT;AACA,IAAO,sBAAQ;",
"mappings": "AAAA,SAAS,6BAA6B;AACtC,OAAO,WAAW;AAEX,MAAM,sBAAsB,CAAC,EAAE,QAAQ,IAAI,CAAC,GAAG,kBAAkB;AACtE,YAAU,qBAAqB,OAAO;AAEtC,QAAM,OAAO,MAAM,WAAW,OAAO;AACrC,QAAM,YAAY,CAAC,OAAO,YAAY;AACpC,UAAM,MAAM,KAAK,MAAM,KAAK;AAC5B,QAAI,KAAK,QAAQ;AACf,cAAQ,GAAG;AAAA,IACb;AAAA,EACF;AACA,QAAM,QAAQ,CAAC,YAAY;AACzB,UAAM,MAAM,KAAK,IAAI;AACrB,QAAI,KAAK,QAAQ;AACf,cAAQ,GAAG;AAAA,IACb;AAAA,EACF;AACA,SAAO,sBAAsB,WAAW,OAAO,aAAa;AAC9D;AAEA,MAAM,uBAAuB,CAAC,YAAY;AACxC,MAAI,YAAY,eAAgB,WAAU;AAC1C,MAAI,CAAC,MAAM,eAAe,OAAO,EAAG,WAAU;AAC9C,SAAO;AACT;AACA,IAAO,sBAAQ;",
"names": []
}
{
"name": "@datastream/charset",
"version": "0.0.38",
"version": "0.0.39",
"description": "",

@@ -128,8 +128,8 @@ "type": "module",

"dependencies": {
"@datastream/charset": "0.0.38",
"@datastream/core": "0.0.38",
"@datastream/charset": "0.0.39",
"@datastream/core": "0.0.39",
"charset-detector": "0.0.2",
"iconv-lite": "0.6.3"
},
"gitHead": "e473d15a15b64399d0855477b478cef04b39b56a"
"gitHead": "cf149bf625928b550a2976f2d8b355ca275bbd58"
}