Update caiyun-1.0.0-alpha.7.mjs

139cloud/caiyun-1.0.0-alpha.7.mjs

@@ -281,9 +281,9 @@ ${o}`},agent:r})}async function DM(s,{key:e,level:t="passive",...i},r,a){return
 `+t).digest("base64");n=`&timestamp=${u}&sign=${encodeURIComponent(c)}`}return Os(s,"钉钉推送",{url:`https://oapi.dingtalk.com/robot/send?access_token=${e}${n}`,data:{msgtype:"text",text:{content:` ${r}
 
 ${a}`},...i},headers:{"content-type":"application/json"}})}function uC(){return{pushplus:gM,serverChan:yM,workWeixin:xM,workWeixinBot:bM,tgBot:wM,bark:DM,twoIm:kM,customPost:mM,dingTalk:vM}}async function M9({logger:s},e,t,i){try{if(!e||!e.pass||!e.from||!e.host)return;let{createTransport:r}=await Promise.resolve().then(()=>Dt(WT(),1)),a=Number(e.port)||465,o=await r({host:e.host,port:a,secure:a===465,auth:{user:e.from,pass:e.pass}}).sendMail({from:`${t} <${e.from}>`,to:e.to,subject:t,headers:{"Content-Type":"text/plain; charset=utf-8"},text:i.replace(/\n/g,`\r
-`)});s.info(`邮件消息已发送: ${o.messageId}`)}catch(r){s.error("邮件消息发送失败",r)}}async function ru(s,e,t,i){let r={email:M9,...uC()};for(let[a,n]of Object.entries(e)){let o=r[a];!o||!e||(await q9(s,n),await o(s,n,t,i))}}async function R9(s){let{HttpsProxyAgent:e}=await Promise.resolve().then(()=>(YT(),XT));return{https:new e({maxSockets:256,scheduling:"lifo",proxy:s})}}async function q9(s,e){if(typeof e.proxy=="string")try{e.agent=await R9(e.proxy)}catch(t){s.logger.error(t)}}lt();Yu();h();Pe();Ui();import{randomBytes as U9}from"node:crypto";function H9(s){let e=U9(16);return{randomBuffer:e,fileMd5:s.node.myMD5(e.toString("hex")),fileSize:209715216}}async function $9(s){let e=H9(s),t={digest:e.fileMd5,contentSize:e.fileSize,manualRename:2,ext:".mp4",createTime:mr()};s.logger.debug(new Date().toLocaleString(),JSON.stringify(t)),await V9(s,s.config.catalog,t,e.randomBuffer)&&s.logger.debug("上传成功")}async function QT(s,e){if(li()){s.logger.debug("当前环境为WPS，不支持上传文件");return}s.logger.debug("已经上传",e,"字节");let t=1025-Math.floor(e/1024/1024);s.logger.debug("需要上传",t,"MB");for(let i=0;i<t;i+=200)await $9(s),t-200>0&&await s.sleep(3e3)}async function V9(s,e,{ext:t=".png",digest:i=Ke(32).toUpperCase(),contentSize:r=ut(1,1e3),manualRename:a=2,contentName:n="asign-"+Ke(4)+t,createTime:o=mr()}={},u){try{s.logger.warn("未实现功能")}catch(c){s.logger.error("上传文件异常",c)}return!1}h();import{Buffer as au}from"node:buffer";import{createCipheriv as W9,randomBytes as G9}from"node:crypto";function K9(s,e){let t=W9("aes-128-cbc",au.from("xuL97!x7GGxG%8V4","utf-8"),e);return au.concat([t.update(s,"utf-8"),t.final()])}function ZT(s){let e=G9(16);return au.from(au.concat([e,K9(s,e)]).toString("base64"),"utf-8").toString("base64")}h();import{Buffer as J9}from"node:buffer";function zs(s,e){var t=(s&65535)+(e&65535),i=(s>>16)+(e>>16)+(t>>16);return i<<16|t&65535}function X9(s,e){return s<<e|s>>>32-e}function nu(s,e,t,i,r,a){return zs(X9(zs(zs(e,s),zs(i,a)),r),t)}function $e(s,e,t,i,r,a,n){return nu(e&t|~e&i,s,e,r,a,n)}function Ve(s,e,t,i,r,a,n){return nu(e&i|t&~i,s,e,r,a,n)}function We(s,e,t,i,r,a,n){return nu(e^t^i,s,e,r,a,n)}function Ge(s,e,t,i,r,a,n){return nu(t^(e|~i),s,e,r,a,n)}function Y9(s,e,t,i,r){let a,n,o,u,c;for(c=0;c<s.length;c+=16)a=e,n=t,o=i,u=r,e=$e(e,t,i,r,s[c],7,-680876936),r=$e(r,e,t,i,s[c+1],12,-389564586),i=$e(i,r,e,t,s[c+2],17,606105819),t=$e(t,i,r,e,s[c+3],22,-1044525330),e=$e(e,t,i,r,s[c+4],7,-176418897),r=$e(r,e,t,i,s[c+5],12,1200080426),i=$e(i,r,e,t,s[c+6],17,-1473231341),t=$e(t,i,r,e,s[c+7],22,-45705983),e=$e(e,t,i,r,s[c+8],7,1770035416),r=$e(r,e,t,i,s[c+9],12,-1958414417),i=$e(i,r,e,t,s[c+10],17,-42063),t=$e(t,i,r,e,s[c+11],22,-1990404162),e=$e(e,t,i,r,s[c+12],7,1804603682),r=$e(r,e,t,i,s[c+13],12,-40341101),i=$e(i,r,e,t,s[c+14],17,-1502002290),t=$e(t,i,r,e,s[c+15],22,1236535329),e=Ve(e,t,i,r,s[c+1],5,-165796510),r=Ve(r,e,t,i,s[c+6],9,-1069501632),i=Ve(i,r,e,t,s[c+11],14,643717713),t=Ve(t,i,r,e,s[c],20,-373897302),e=Ve(e,t,i,r,s[c+5],5,-701558691),r=Ve(r,e,t,i,s[c+10],9,38016083),i=Ve(i,r,e,t,s[c+15],14,-660478335),t=Ve(t,i,r,e,s[c+4],20,-405537848),e=Ve(e,t,i,r,s[c+9],5,568446438),r=Ve(r,e,t,i,s[c+14],9,-1019803690),i=Ve(i,r,e,t,s[c+3],14,-187363961),t=Ve(t,i,r,e,s[c+8],20,1163531501),e=Ve(e,t,i,r,s[c+13],5,-1444681467),r=Ve(r,e,t,i,s[c+2],9,-51403784),i=Ve(i,r,e,t,s[c+7],14,1735328473),t=Ve(t,i,r,e,s[c+12],20,-1926607734),e=We(e,t,i,r,s[c+5],4,-378558),r=We(r,e,t,i,s[c+8],11,-2022574463),i=We(i,r,e,t,s[c+11],16,1839030562),t=We(t,i,r,e,s[c+14],23,-35309556),e=We(e,t,i,r,s[c+1],4,-1530992060),r=We(r,e,t,i,s[c+4],11,1272893353),i=We(i,r,e,t,s[c+7],16,-155497632),t=We(t,i,r,e,s[c+10],23,-1094730640),e=We(e,t,i,r,s[c+13],4,681279174),r=We(r,e,t,i,s[c],11,-358537222),i=We(i,r,e,t,s[c+3],16,-722521979),t=We(t,i,r,e,s[c+6],23,76029189),e=We(e,t,i,r,s[c+9],4,-640364487),r=We(r,e,t,i,s[c+12],11,-421815835),i=We(i,r,e,t,s[c+15],16,530742520),t=We(t,i,r,e,s[c+2],23,-995338651),e=Ge(e,t,i,r,s[c],6,-198630844),r=Ge(r,e,t,i,s[c+7],10,1126891415),i=Ge(i,r,e,t,s[c+14],15,-1416354905),t=Ge(t,i,r,e,s[c+5],21,-57434055),e=Ge(e,t,i,r,s[c+12],6,1700485571),r=Ge(r,e,t,i,s[c+3],10,-1894986606),i=Ge(i,r,e,t,s[c+10],15,-1051523),t=Ge(t,i,r,e,s[c+1],21,-2054922799),e=Ge(e,t,i,r,s[c+8],6,1873313359),r=Ge(r,e,t,i,s[c+15],10,-30611744),i=Ge(i,r,e,t,s[c+6],15,-1560198380),t=Ge(t,i,r,e,s[c+13],21,1309151649),e=Ge(e,t,i,r,s[c+4],6,-145523070),r=Ge(r,e,t,i,s[c+11],10,-1120210379),i=Ge(i,r,e,t,s[c+2],15,718787259),t=Ge(t,i,r,e,s[c+9],21,-343485551),e=zs(e,a),t=zs(t,n),i=zs(i,o),r=zs(r,u);return[e,t,i,r]}function Q9(s,e,t=!0,i={a:1732584193,b:-271733879,c:-1732584194,d:271733878},r=0){return t&&(s[e>>5]|=128<<e%32,s[(e+64>>>9<<4)+14]=e+r),Y9(s,i.a,i.b,i.c,i.d)}function Z9(s,e=0,t={a:1732584193,b:-271733879,c:-1732584194,d:271733878}){return t7(e7(Q9(s7(decodeURIComponent(s)),s.length*8,!0,t,e)))}function e7(s){let e="",t=s.length*32;for(let i=0;i<t;i+=8)e+
Line truncated
+`)});s.info(`邮件消息已发送: ${o.messageId}`)}catch(r){s.error("邮件消息发送失败",r)}}async function ru(s,e,t,i){let r={email:M9,...uC()};for(let[a,n]of Object.entries(e)){let o=r[a];!o||!e||(await q9(s,n),await o(s,n,t,i))}}async function R9(s){let{HttpsProxyAgent:e}=await Promise.resolve().then(()=>(YT(),XT));return{https:new e({maxSockets:256,scheduling:"lifo",proxy:s})}}async function q9(s,e){if(typeof e.proxy=="string")try{e.agent=await R9(e.proxy)}catch(t){s.logger.error(t)}}lt();Yu();h();Pe();Ui();import{randomBytes as U9}from"node:crypto";function H9(s){let e=U9(16);return{randomBuffer:e,fileMd5:s.node.myMD5(e.toString("hex")),fileSize:209715216}}async function $9(s){let e=H9(s),t={digest:e.fileMd5,contentSize:e.fileSize,manualRename:2,ext:".mp4",createTime:mr()};s.logger.debug(new Date().toLocaleString(),JSON.stringify(t)),await V9(s,s.config.catalog,t,e.randomBuffer)&&s.logger.debug("上传成功")}async function QT(s,e){if(li()){s.logger.debug("当前环境为WPS，不支持上传文件");return}s.logger.debug("已经上传",e,"字节");let t=1025-Math.floor(e/1024/1024);s.logger.debug("需要上传",t,"MB");for(let i=0;i<t;i+=200)await $9(s),t-200>0&&await s.sleep(3e3)}async function V9(s,e,{ext:t=".png",digest:i=Ke(32).toUpperCase(),contentSize:r=ut(1,1e3),manualRename:a=2,contentName:n="asign-"+Ke(4)+t,createTime:o=mr()}={},u){try{s.logger.warn("未实现功能")}catch(c){s.logger.error("上传文件异常",c)}return!1}h();import{Buffer as au}from"node:buffer";import{createCipheriv as W9,randomBytes as G9}from"node:crypto";function K9(s,e){let t=W9("aes-128-cbc",au.from("xuL97!x7GGxG%8V4","utf-8"),e);return au.concat([t.update(s,"utf-8"),t.final()])}function ZT(s){let e=G9(16);return au.from(au.concat([e,K9(s,e)]).toString("base64"),"utf-8").toString("base64")}h();import{Buffer as J9}from"node:buffer";function zs(s,e){var t=(s&65535)+(e&65535),i=(s>>16)+(e>>16)+(t>>16);return i<<16|t&65535}function X9(s,e){return s<<e|s>>>32-e}function nu(s,e,t,i,r,a){return zs(X9(zs(zs(e,s),zs(i,a)),r),t)}function $e(s,e,t,i,r,a,n){return nu(e&t|~e&i,s,e,r,a,n)}function Ve(s,e,t,i,r,a,n){return nu(e&i|t&~i,s,e,r,a,n)}function We(s,e,t,i,r,a,n){return nu(e^t^i,s,e,r,a,n)}function Ge(s,e,t,i,r,a,n){return nu(t^(e|~i),s,e,r,a,n)}function Y9(s,e,t,i,r){let a,n,o,u,c;for(c=0;c<s.length;c+=16)a=e,n=t,o=i,u=r,e=$e(e,t,i,r,s[c],7,-680876936),r=$e(r,e,t,i,s[c+1],12,-389564586),i=$e(i,r,e,t,s[c+2],17,606105819),t=$e(t,i,r,e,s[c+3],22,-1044525330),e=$e(e,t,i,r,s[c+4],7,-176418897),r=$e(r,e,t,i,s[c+5],12,1200080426),i=$e(i,r,e,t,s[c+6],17,-1473231341),t=$e(t,i,r,e,s[c+7],22,-45705983),e=$e(e,t,i,r,s[c+8],7,1770035416),r=$e(r,e,t,i,s[c+9],12,-1958414417),i=$e(i,r,e,t,s[c+10],17,-42063),t=$e(t,i,r,e,s[c+11],22,-1990404162),e=$e(e,t,i,r,s[c+12],7,1804603682),r=$e(r,e,t,i,s[c+13],12,-40341101),i=$e(i,r,e,t,s[c+14],17,-1502002290),t=$e(t,i,r,e,s[c+15],22,1236535329),e=Ve(e,t,i,r,s[c+1],5,-165796510),r=Ve(r,e,t,i,s[c+6],9,-1069501632),i=Ve(i,r,e,t,s[c+11],14,643717713),t=Ve(t,i,r,e,s[c],20,-373897302),e=Ve(e,t,i,r,s[c+5],5,-701558691),r=Ve(r,e,t,i,s[c+10],9,38016083),i=Ve(i,r,e,t,s[c+15],14,-660478335),t=Ve(t,i,r,e,s[c+4],20,-405537848),e=Ve(e,t,i,r,s[c+9],5,568446438),r=Ve(r,e,t,i,s[c+14],9,-1019803690),i=Ve(i,r,e,t,s[c+3],14,-187363961),t=Ve(t,i,r,e,s[c+8],20,1163531501),e=Ve(e,t,i,r,s[c+13],5,-1444681467),r=Ve(r,e,t,i,s[c+2],9,-51403784),i=Ve(i,r,e,t,s[c+7],14,1735328473),t=Ve(t,i,r,e,s[c+12],20,-1926607734),e=We(e,t,i,r,s[c+5],4,-378558),r=We(r,e,t,i,s[c+8],11,-2022574463),i=We(i,r,e,t,s[c+11],16,1839030562),t=We(t,i,r,e,s[c+14],23,-35309556),e=We(e,t,i,r,s[c+1],4,-1530992060),r=We(r,e,t,i,s[c+4],11,1272893353),i=We(i,r,e,t,s[c+7],16,-155497632),t=We(t,i,r,e,s[c+10],23,-1094730640),e=We(e,t,i,r,s[c+13],4,681279174),r=We(r,e,t,i,s[c],11,-358537222),i=We(i,r,e,t,s[c+3],16,-722521979),t=We(t,i,r,e,s[c+6],23,76029189),e=We(e,t,i,r,s[c+9],4,-640364487),r=We(r,e,t,i,s[c+12],11,-421815835),i=We(i,r,e,t,s[c+15],16,530742520),t=We(t,i,r,e,s[c+2],23,-995338651),e=Ge(e,t,i,r,s[c],6,-198630844),r=Ge(r,e,t,i,s[c+7],10,1126891415),i=Ge(i,r,e,t,s[c+14],15,-1416354905),t=Ge(t,i,r,e,s[c+5],21,-57434055),e=Ge(e,t,i,r,s[c+12],6,1700485571),r=Ge(r,e,t,i,s[c+3],10,-1894986606),i=Ge(i,r,e,t,s[c+10],15,-1051523),t=Ge(t,i,r,e,s[c+1],21,-2054922799),e=Ge(e,t,i,r,s[c+8],6,1873313359),r=Ge(r,e,t,i,s[c+15],10,-30611744),i=Ge(i,r,e,t,s[c+6],15,-1560198380),t=Ge(t,i,r,e,s[c+13],21,1309151649),e=Ge(e,t,i,r,s[c+4],6,-145523070),r=Ge(r,e,t,i,s[c+11],10,-1120210379),i=Ge(i,r,e,t,s[c+2],15,718787259),t=Ge(t,i,r,e,s[c+9],21,-343485551),e=zs(e,a),t=zs(t,n),i=zs(i,o),r=zs(r,u);return[e,t,i,r]}function Q9(s,e,t=!0,i={a:1732584193,b:-271733879,c:-1732584194,d:271733878},r=0){return t&&(s[e>>5]|=128<<e%32,s[(e+64>>>9<<4)+14]=e+r),Y9(s,i.a,i.b,i.c,i.d)}function Z9(s,e=0,t={a:1732584193,b:-271733879,c:-1732584194,d:271733878}){return t7(e7(Q9(s7(decodeURIComponent(s)),s.length*8,!0,t,e)))}function e7(s){let e="",t=s.length*32;for(let i=0;i<t;i+=8)e+
Line truncated
 
-`),{newAuth:a,$:t}}async function w7(s){return bf(s)||xf(s)?await ef(s):s}async function Gae(s){let{config:e,path:t,message:i}=await w7(s),r=[{level:3,type:"info",date:new Date,msg:"文档地址：https://as.js.cool"}],a=await qs({pushData:r});if(r.push({level:3,type:"info",date:new Date,msg:"当前版本 0.5.11-rc.2"}),!e||!e.length)return a.error("未找到配置文件/变量");let{expiredAuth:n}=await k7(e,a,t);await D7(n,i),await ou({pushData:r,message:i})}async function D7(s,e){s.length&&await ou({pushData:[{level:0,type:"error",date:new Date,msg:"存在账号过期，请重新登录"},...s.map(t=>({level:3,type:"info",date:new Date,msg:t}))],message:{...e,title:"账号过期推送"}})}async function k7(s,e,t){let i=[];for(let r=0;r<s.length;r++){let a=s[r];if(!a.auth){e.error("该配置中不存在 auth");continue}try{let{newAuth:n,$:o,isNoLogin:u}=await b7(a,{logger:e});if(u){i.push(o?.config?.phone);continue}n&&ME(t,["caiyun",r,"auth"],n)}catch(n){e.error(n)}}return{expiredAuth:i}}export{k7 as _run,qs as createLogger,w7 as getConfig,oi as init,ef as loadConfig,b7 as main,D7 as pushExpiredAuth,ou as pushMessage,Gae as run,f7 as runHc1t,wr as sleep,s2 as useExchange,o7 as useMultiExchange};
+`),{newAuth:a,$:t}}async function w7(s){return bf(s)||xf(s)?await ef(s):s}async function Gae(s){let{config:e,path:t,message:i}=await w7(s),r=[{level:3,type:"info",date:new Date,msg:"☁️☁️☁️☁️☁️☁️☁️"}],a=await qs({pushData:r});if(r.push({level:3,type:"info",date:new Date,msg:"当前版本 0.5.11-rc.2"}),!e||!e.length)return a.error("未找到配置文件/变量");let{expiredAuth:n}=await k7(e,a,t);await D7(n,i),await ou({pushData:r,message:i})}async function D7(s,e){s.length&&await ou({pushData:[{level:0,type:"error",date:new Date,msg:"存在账号过期，请重新登录"},...s.map(t=>({level:3,type:"info",date:new Date,msg:t}))],message:{...e,title:"账号过期推送"}})}async function k7(s,e,t){let i=[];for(let r=0;r<s.length;r++){let a=s[r];if(!a.auth){e.error("该配置中不存在 auth");continue}try{let{newAuth:n,$:o,isNoLogin:u}=await b7(a,{logger:e});if(u){i.push(o?.config?.phone);continue}n&&ME(t,["caiyun",r,"auth"],n)}catch(n){e.error(n)}}return{expiredAuth:i}}export{k7 as _run,qs as createLogger,w7 as getConfig,oi as init,ef as loadConfig,b7 as main,D7 as pushExpiredAuth,ou as pushMessage,Gae as run,f7 as runHc1t,wr as sleep,s2 as useExchange,o7 as useMultiExchange};
 /*! Bundled license information:
 
 lodash-es/lodash.js: