{"version":3,"sources":["/Users/kevin/Dev/OpenSource/iterators/fast-extract/src/streams/pipelines/file.mjs"],"sourcesContent":["import path from 'path';\n\nimport statsBasename from '../../sourceStats/basename.mjs';\nimport DataProgressTransform from '../transforms/DataProgress.mjs';\nimport PathToData from '../transforms/PathToData.mjs';\nimport createWriteStream from '../write/file.mjs';\n\nexport default function createFilePipeline(dest, streams, options) {\n  const isPath = typeof options.source === 'string';\n  const basename = statsBasename(options.source, options);\n  const fullPath = basename === undefined ? dest : path.join(dest, basename);\n\n  streams = streams.slice();\n  !isPath || streams.unshift(new PathToData());\n  !options.progress || streams.push(new DataProgressTransform({ basename: basename, fullPath: fullPath, ...options }));\n  streams.push(createWriteStream(fullPath, options));\n  return streams;\n}\n"],"names":["createFilePipeline","dest","streams","options","isPath","source","basename","statsBasename","fullPath","undefined","path","join","slice","unshift","PathToData","progress","push","DataProgressTransform","createWriteStream"],"mappings":";;;;+BAOA;;;eAAwBA;;;2DAPP;+DAES;mEACQ;iEACX;2DACO;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAEf,SAASA,mBAAmBC,IAAI,EAAEC,OAAO,EAAEC,OAAO;IAC/D,IAAMC,SAAS,OAAOD,QAAQE,MAAM,KAAK;IACzC,IAAMC,WAAWC,IAAAA,iBAAa,EAACJ,QAAQE,MAAM,EAAEF;IAC/C,IAAMK,WAAWF,aAAaG,YAAYR,OAAOS,aAAI,CAACC,IAAI,CAACV,MAAMK;IAEjEJ,UAAUA,QAAQU,KAAK;IACvB,CAACR,UAAUF,QAAQW,OAAO,CAAC,IAAIC,mBAAU;IACzC,CAACX,QAAQY,QAAQ,IAAIb,QAAQc,IAAI,CAAC,IAAIC,qBAAqB,CAAC;QAAEX,UAAUA;QAAUE,UAAUA;OAAaL;IACzGD,QAAQc,IAAI,CAACE,IAAAA,aAAiB,EAACV,UAAUL;IACzC,OAAOD;AACT"}