@mrtujiawei/bin - npm Package Compare versions

Comparing version 1.3.11 to 1.3.12

dist/index.cjs.js

 #!/bin/env node
-(()=>{"use strict";var e={415:e=>{e.exports={i8:"1.3.10"}}},t={};function r(o){var n=t[o];if(void 0!==n)return n.exports;var i=t[o]={exports:{}};return e[o](i,i.exports,r),i.exports}r.n=e=>{var t=e&&e.__esModule?()=>e.default:()=>e;return r.d(t,{a:t}),t},r.d=(e,t)=>{for(var o in t)r.o(t,o)&&!r.o(e,o)&&Object.defineProperty(e,o,{enumerable:!0,get:t[o]})},r.o=(e,t)=>Object.prototype.hasOwnProperty.call(e,t),r.r=e=>{"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})};var o={};(()=>{r.r(o);const e=require("commander"),t=require("path");var n=r.n(t);const i=require("https");var a=r.n(i);const s=require("fs");var c=r.n(s);const p=require("koa");var d=r.n(p);const u=require("koa-static");var l=r.n(u);const m=require("koa-router");var f=r.n(m);const h=require("@koa/cors");var w=r.n(h);const g=require("koa-bodyparser");var y=r.n(g);const v=require("@mrtujiawei/node-utils"),b=require("http");var x=r.n(b);const S=require("@mrtujiawei/utils"),$=S.Logger.getLogger("@mrtujiawei/bin");$.setLevel(S.Logger.LOG_LEVEL.ALL),$.subscribe((e=>{console.log(e.getFormattedMessage())}));class q extends Error{constructor(e="Invalid Arguments"){super(e)}}const _=e=>!!e&&e.startsWith("#"),k=e=>!!e&&e.startsWith("http"),j=e=>{if(!k(e))throw new q};function L(e){const t=new(d()),r=new(f());if(e.dir.forEach((e=>{$.info(`static dir: ${e}`),t.use(l()(e))})),t.use(w()()).use(y()()).use(r.routes()).use(((e,t)=>{const r=e.req,o=e.path,n=r.method,i=e.querystring;return $.trace(`${n} ${o}${i?`?${i}`:""}`),t()})).use(r.allowedMethods()),e.target&&t.use((async(t,r)=>{const{request:o}=t,i=new RegExp(`^${e.prefix}`);if(i.test(o.url)){e.rewrite&&(o.url=o.url.replace(i,""));const r=new URL(e.target);let s={method:o.method,path:n().resolve(r.pathname,o.url),hostname:r.hostname,headers:{"Content-Type":"application/json"}};const c=new Set(["host","referer","accept-encoding","Content-Length"]);for(const e in o.headers)c.has(e)||(s.headers[e]=o.headers[e]);try{const r=await async function(e,t,r){let o=r?a():x();return new Promise(((r,n)=>{const i=o.request(e,(e=>{let t=[];e.on("data",(e=>{t.push(e.toString())})),e.on("end",(()=>{r(t.join(""))}))})).end(JSON.stringify(t)).on("timeout",(()=>{$.info("请求超时"),n(new Error("请求超时")),i.destroy()})).on("error",(e=>{console.log({err:e}),n(e)}))}))}(s,o.body,e.target?.startsWith("https"));t.body=r}catch(e){t.body=e}}else await r()})),e.https){const r={key:c().readFileSync(n().resolve(__dirname,"../pem/private_key.pem")),cert:c().readFileSync(n().resolve(__dirname,"../pem/ca-cert.pem"))};a().createServer(r,t.callback()).listen(e.port,(()=>{const t=(0,v.getIps)();$.info("Server is running at:"),t.forEach((t=>{$.info(`https://${t}:${e.port}`)}))}))}else t.listen(e.port,(()=>{const t=(0,v.getIps)();$.info("Server is running at:"),t.forEach((t=>{$.info(`http://${t}:${e.port}`)}))}))}const E=async(e,t)=>{const r=(j(o=e),(o.match(/^http[s]?\:\/\/[^/]+/)||[])[0]||"");var o;const n=e.replace(/[^/]*$/,""),i=(await(0,v.request)(e)).join("").split(/\r?\n/),a=(0,v.pathResolve)((0,v.getCwd)(),t.dir||e.split(/[/.]/).slice(-2,-1)[0]);await(0,v.rmdir)(a),$.trace("删除目录 "+a+" 成功"),await(0,v.mkdir)(a),$.trace("创建目录 "+a+" 成功");const s=i.map((e=>{const t=e;return!t||_(t)?e:`/${(0,v.getFileName)(t)}`}));await(0,v.writeFile)((0,v.pathResolve)(a,"index.m3u8"),s.join("\n")),$.trace("写入index.m3u8成功");const c=((e,t,r)=>{const o=new S.Lock(4);return async n=>{if(!n||_(n))return;k(n)||(n=n.startsWith("/")?e+n:t+n);const i=(0,v.getFileName)(n);try{await o.lock();let e=await(0,v.request)(n),t=(0,v.pathResolve)(r,i);await(0,v.writeFile)(t,e),$.trace(`下载成功 ${i}`)}catch(e){$.error(`下载失败: ${i}`),$.error(`失败地址: ${n}`),$.error(""+e)}finally{o.unlock()}}})(r,n,a);i.forEach((e=>{c(e)}))},F=async e=>{const t={cwd:e,encoding:"utf8"};$.info(`${e} 开始提交`);try{$.info("git add ."),await(0,v.exec)("git add .",t),$.info("git commit -m 'feat(all):自动提交'"),await(0,v.exec)("git commit -m 'feat(all):自动提交'",t),$.info("git push"),await(0,v.exec)("git push",t),$.info(`${e} 提交成功`)}catch(e){$.error("提交终止"+e)}},O=async()=>{const e=(0,v.getCwd)(),t=await(0,v.getDirs)(e);for(let r=0;r<t.length;r++){const o=(0,v.pathResolve)(e,t[r]);await F(o)}},M=e=>{(0,s.readdirSync)(".").forEach((r=>{const o=(0,t.parse)(r);".m3u8"!=o.ext&&".ts"!=o.ext&&((e,t,r=".png")=>{const o=1048576,n=new DataView(new ArrayBuffer(o)),i=(0,s.openSync)(`${e}${r}`,"r"),a=(0,s.openSync)(`${e}.ts`,"w");let c=(0,s.readSync)(i,n,0,o,t);for((0,s.writeFileSync)(a,new DataView(n.buffer,0,c));c==o;)t+=c,c=(0,s.readSync)(i,n,0,o,t),(0,s.writeFileSync)(a,new DataView(n.buffer,0,c))})(o.name,e,o.ext)}))},P=new e.Command;P.name("t").description("").version(r(415).i8),P.command("download-m3u8").description("下载m3u8文件").argument("<url>","index.m3u8").option("--dir <dir>","指定下载目录").action(((e,t)=>E(e,t))),P.command("pushAll").description("提交指定目录下的所有git仓库").action((()=>{O()})),P.command("server").description("静态文件服务，支持https，请求代理").option("-s, --https","开启https",!1).option("-p, --port <port>","监听端口号","3000").option("-d, --dir <directory...>","项目根目录",[process.cwd()]).option("-t, --target <url>","代理目录地址").option("--prefix <prefix>","需要代理的路径前缀","/api").option("--rewrite","是否移除前缀",!1).action((e=>{e.port=Number(e.port);for(let t=0;t<e.dir.length;t++)n().isAbsolute(e.dir[t])||(e.dir[t]=n().resolve(process.cwd(),e.dir[t]));L(e)})),P.command("skip-bytes").description("转换非.ts文件到.ts").requiredOption("-p --position <position>","起始位置").action((e=>{M(e.position)})),P.parse(process.argv)})();var n=exports;for(var i in o)n[i]=o[i];o.__esModule&&Object.defineProperty(n,"__esModule",{value:!0})})();
+(()=>{"use strict";var e={415:e=>{e.exports={i8:"1.3.12"}}},t={};function r(o){var n=t[o];if(void 0!==n)return n.exports;var i=t[o]={exports:{}};return e[o](i,i.exports,r),i.exports}r.n=e=>{var t=e&&e.__esModule?()=>e.default:()=>e;return r.d(t,{a:t}),t},r.d=(e,t)=>{for(var o in t)r.o(t,o)&&!r.o(e,o)&&Object.defineProperty(e,o,{enumerable:!0,get:t[o]})},r.o=(e,t)=>Object.prototype.hasOwnProperty.call(e,t),r.r=e=>{"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})};var o={};(()=>{r.r(o);const e=require("commander"),t=require("path");var n=r.n(t);const i=require("https");var a=r.n(i);const s=require("fs");var c=r.n(s);const p=require("koa");var u=r.n(p);const d=require("koa-static");var l=r.n(d);const m=require("koa-router");var f=r.n(m);const h=require("@koa/cors");var w=r.n(h);const g=require("koa-bodyparser");var y=r.n(g);const v=require("@mrtujiawei/node-utils"),b=require("http");var x=r.n(b);const S=require("@mrtujiawei/utils"),$=S.Logger.getLogger("@mrtujiawei/bin");$.setLevel(S.Logger.LOG_LEVEL.ALL),$.subscribe((e=>{console.log(e.getFormattedMessage())}));class q extends Error{constructor(e="Invalid Arguments"){super(e)}}const _=e=>!!e&&e.startsWith("#"),k=e=>!!e&&e.startsWith("http"),j=e=>{if(!k(e))throw new q};function L(e){const t=new(u()),r=new(f());if(e.dir.forEach((e=>{$.info(`static dir: ${e}`),t.use(l()(e))})),t.use(w()()).use(y()()).use(r.routes()).use(((e,t)=>{const r=e.req,o=e.path,n=r.method,i=e.querystring;return $.trace(`${n} ${o}${i?`?${i}`:""}`),t()})).use(r.allowedMethods()),e.target&&t.use((async(t,r)=>{const{request:o}=t,i=new RegExp(`^${e.prefix}`);if(i.test(o.url)){e.rewrite&&(o.url=o.url.replace(i,""));const r=new URL(e.target);let s={method:o.method,path:n().resolve(r.pathname,o.url),hostname:r.hostname,headers:{"Content-Type":"application/json"}};const c=new Set(["host","referer","accept-encoding","Content-Length"]);for(const e in o.headers)c.has(e)||(s.headers[e]=o.headers[e]);try{const r=await async function(e,t,r){let o=r?a():x();return new Promise(((r,n)=>{const i=o.request(e,(e=>{let t=[];e.on("data",(e=>{t.push(e.toString())})),e.on("end",(()=>{r(t.join(""))}))})).end(JSON.stringify(t)).on("timeout",(()=>{$.info("请求超时"),n(new Error("请求超时")),i.destroy()})).on("error",(e=>{console.log({err:e}),n(e)}))}))}(s,o.body,e.target?.startsWith("https"));t.body=r}catch(e){t.body=e}}else await r()})),e.https){const r={key:c().readFileSync(n().resolve(__dirname,"../pem/private_key.pem")),cert:c().readFileSync(n().resolve(__dirname,"../pem/ca-cert.pem"))};a().createServer(r,t.callback()).listen(e.port,(()=>{const t=(0,v.getIps)();$.info("Server is running at:"),t.forEach((t=>{$.info(`https://${t}:${e.port}`)}))}))}else t.listen(e.port,(()=>{const t=(0,v.getIps)();$.info("Server is running at:"),t.forEach((t=>{$.info(`http://${t}:${e.port}`)}))}))}const E=async(e,t)=>{const r=(j(o=e),(o.match(/^http[s]?\:\/\/[^/]+/)||[])[0]||"");var o;const n=e.replace(/[^/]*$/,""),i=(await(0,v.request)(e)).join("").split(/\r?\n/),a=(0,v.pathResolve)((0,v.getCwd)(),t.dir||e.split(/[/.]/).slice(-2,-1)[0]);await(0,v.rmdir)(a),$.trace("删除目录 "+a+" 成功"),await(0,v.mkdir)(a),$.trace("创建目录 "+a+" 成功");const s=i.map((e=>{const t=e;return!t||_(t)?e:`/${(0,v.getFileName)(t)}`}));await(0,v.writeFile)((0,v.pathResolve)(a,"index.m3u8"),s.join("\n")),$.trace("写入index.m3u8成功");const c=((e,t,r)=>{const o=new S.Lock(4);return async n=>{if(!n||_(n))return;k(n)||(n=n.startsWith("/")?e+n:t+n);const i=(0,v.getFileName)(n);try{await o.lock();let e=await(0,v.request)(n),t=(0,v.pathResolve)(r,i);await(0,v.writeFile)(t,e),$.trace(`下载成功 ${i}`)}catch(e){$.error(`下载失败: ${i}`),$.error(`失败地址: ${n}`),$.error(""+e)}finally{o.unlock()}}})(r,n,a);i.forEach((e=>{c(e)}))},F=async e=>{const t={cwd:e,encoding:"utf8"};$.info(`${e} 开始提交`);try{$.info("git add ."),await(0,v.exec)("git add .",t),$.info("git commit -m 'feat(all):自动提交'"),await(0,v.exec)("git commit -m 'feat(all):自动提交'",t),$.info("git push"),await(0,v.exec)("git push",t),$.info(`${e} 提交成功`)}catch(e){$.error("提交终止"+e)}},O=async()=>{const e=(0,v.getCwd)(),t=await(0,v.getDirs)(e);for(let r=0;r<t.length;r++){const o=(0,v.pathResolve)(e,t[r]);await F(o)}},M=e=>{(0,s.readdirSync)(".").forEach((r=>{const o=(0,t.parse)(r);".m3u8"!=o.ext&&".ts"!=o.ext&&((e,t,r=".png")=>{const o=1048576,n=new DataView(new ArrayBuffer(o)),i=(0,s.openSync)(`${e}${r}`,"r"),a=(0,s.openSync)(`${e}.ts`,"w");let c=(0,s.readSync)(i,n,0,o,t);for((0,s.writeFileSync)(a,new DataView(n.buffer,0,c));c==o;)t+=c,c=(0,s.readSync)(i,n,0,o,t),(0,s.writeFileSync)(a,new DataView(n.buffer,0,c))})(o.name,e,o.ext)}))},P=new e.Command;P.name("t").description("").version(r(415).i8),P.command("download-m3u8").description("下载m3u8文件").argument("<url>","index.m3u8").option("--dir <dir>","指定下载目录").action(((e,t)=>E(e,t))),P.command("pushAll").description("提交指定目录下的所有git仓库").action((()=>{O()})),P.command("server").description("静态文件服务，支持https，请求代理").option("-s, --https","开启https",!1).option("-p, --port <port>","监听端口号","3000").option("-d, --dir <directory...>","项目根目录",[process.cwd()]).option("-t, --target <url>","代理目录地址").option("--prefix <prefix>","需要代理的路径前缀","/api").option("--rewrite","是否移除前缀",!1).action((e=>{e.port=Number(e.port);for(let t=0;t<e.dir.length;t++)n().isAbsolute(e.dir[t])||(e.dir[t]=n().resolve(process.cwd(),e.dir[t]));L(e)})),P.command("skip-bytes").description("转换非.ts文件到.ts").requiredOption("-p --position <position>","起始位置").action((e=>{M(Number(e.position))})),P.parse(process.argv)})();var n=exports;for(var i in o)n[i]=o[i];o.__esModule&&Object.defineProperty(n,"__esModule",{value:!0})})();

package.json

 {
   "name": "@mrtujiawei/bin",
-  "version": "1.3.11",
+  "version": "1.3.12",
   "description": "我的命令行工具",
@@ -5,0 +5,0 @@ "files": [

No alert changes

Improved metrics

Total package byte prevSize

17609

increased by0.05%

No dependency changes