imock-snapshot/library/index.js

!function(e){var t={}
function n(r){if(t[r])return t[r].exports
var o=t[r]={i:r,l:!1,exports:{}}
e[r].call(o.exports,o,o.exports,n)
o.l=!0
return o.exports}n.m=e
n.c=t
n.d=function(e,t,r){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:r})}
n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"})
Object.defineProperty(e,"__esModule",{value:!0})}
n.t=function(e,t){1&t&&(e=n(e))
if(8&t)return e
if(4&t&&"object"==typeof e&&e&&e.__esModule)return e
var r=Object.create(null)
n.r(r)
Object.defineProperty(r,"default",{enumerable:!0,value:e})
if(2&t&&"string"!=typeof e)for(var o in e)n.d(r,o,function(t){return e[t]}.bind(null,o))
return r}
n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e}
n.d(t,"a",t)
return t}
n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)}
n.p=""
n(n.s=12)}([function(e,t){e.exports=require("fs")},function(e,t){e.exports=require("path")},function(e,t){e.exports=require("util")},function(e,t){e.exports=require("crypto")},function(e,t){e.exports=require("url")},function(e,t){e.exports=require("zlib")},function(e,t){e.exports=require("http")},function(e,t){e.exports=require("https")},function(module,__webpack_exports__,__webpack_require__){__webpack_require__.d(__webpack_exports__,"a",function(){return tryRequire})
const tryRequire=(name="")=>{try{return eval("require")(name)}catch(e){}}},function(e){e.exports={a:"imock-snapshot",b:"0.7.0"}},function(e,t){e.exports=require("readline")},function(e,t){e.exports=require("stream")},function(e,t,n){n.r(t)
var r=n(1)
var o=n(0)
var s=n(2)
n(10)
Object(s.promisify)(o.stat)
const a=Object(s.promisify)(o.lstat)
Object(s.promisify)(o.rename)
Object(s.promisify)(o.unlink)
Object(s.promisify)(o.access)
const i=Object(s.promisify)(o.mkdir)
Object(s.promisify)(o.rmdir)
const c=Object(s.promisify)(o.readdir)
const u=Object(s.promisify)(o.readFile)
const p=Object(s.promisify)(o.writeFile)
o.copyFile?Object(s.promisify)(o.copyFile):(()=>{const e=Object(s.promisify)(o.open)
const t=Object(s.promisify)(o.fstat)})()
r.sep
const l=new o.Stats(-1,-1,0,-1,-1,-1,0,0,0,0,0,0,0,0)
const d="File",g="Directory",h="SymbolicLink",m="Other",f="Error"
const S=e=>l
const w=e=>a(e).catch(S)
const y=e=>e.isDirectory()?g:e.isFile()?d:e.isSymbolicLink()?h:e!==l?m:f
const b=async(e,t)=>{void 0===t&&(t=await w(e))
if(t.isDirectory())return
if(t!==l)throw new Error("[createDirectory] path already taken by non-directory")
const n=Object(r.dirname)(e)
const o=await w(n)
!o.isDirectory()&&await b(n,o)
await i(e)}
const v=e=>{console.warn(e)
throw e}
const k=(e,...t)=>{let n,r
try{n=e(...t)}catch(e){r=e}return{result:n,error:r}}
const x=async(e,...t)=>{let n,r
try{n=await e(...t)}catch(e){r=e}return{result:n,error:r}}
const T=({queueLengthThreshold:e,...t})=>(({outputStream:e,queueLengthThreshold:t=1024})=>{const n=[]
const r=()=>{n.push("")
const e=n.join("\n")
n.length=0
return e}
const o=()=>{0!==n.length&&e.write(r())}
return{add:e=>{n.push(e)
n.length>t&&o()},save:o,end:()=>{0!==n.length&&e.write(r())
e.end()}}})({outputStream:(({pathOutputFile:e,flag:t="w",mode:n=438,onError:r=v})=>{let s=Object(o.openSync)(e,t,n)
let a=[]
let i=[]
const c=e=>e?r(e):a.length=0
const u=e=>s&&Object(o.write)(s,e,c)
return{write:e=>{if(e){i.push(e)
if(0===a.length){[a,i]=[i,[]]
process.nextTick(u,a.join(""))}}},end:()=>{const e=[...a,...i]
0!==e.length&&Object(o.writeSync)(s,e.join(""))
Object(o.closeSync)(s)
s=null
i.length=a.length=0}}})(t),queueLengthThreshold:e})
const O=[{event:"exit",listener:e=>E({eventType:"exit",code:e})},{event:"uncaughtException",listener:e=>N({eventType:"uncaughtException",error:e})},{event:"unhandledRejection",listener:(e,t)=>N({eventType:"unhandledRejection",error:e,promise:t})},...["SIGINT","SIGHUP","SIGQUIT","SIGTERM"].map(e=>({event:e,listener:()=>N({eventType:"signal",signalEventType:e})}))]
const $=new Set
const L=new Set
const E=e=>{for(const t of Array.from($))k(t,e)}
const N=async e=>{R()
for(const t of Array.from(L))await x(t,e)
E(e)
process.exit(e.code||(e.error?-1:0))}
let A=!1
const P=()=>{A=!0
O.forEach(({event:e,listener:t})=>process.on(e,t))}
const R=()=>{A=!1
O.forEach(({event:e,listener:t})=>process.removeListener(e,t))}
const j=(...e)=>{e.forEach(e=>$.add(e))
!A&&P()}
const C=(...e)=>{e.forEach(e=>L.add(e))
!A&&P()}
const D=()=>{}
const I=async({pathLogDirectory:e,logFilePrefix:t})=>{const n=(({add:e,...t})=>({...t,add:(...t)=>e((new Date).toISOString(),...t)}))(e?await(async({pathLogDirectory:e,prefixLogFile:t="",getLogFileName:n=(()=>`${t}${(new Date).toISOString().replace(/\W/g,"-")}.log`),saveInterval:o=3e4,splitInterval:s=864e5,...a})=>{let i
let c
let u
const p=()=>{g()
const t=Object(r.resolve)(e,n())
i=T({...a,pathOutputFile:t})
c=o&&setInterval(l,o)
u=s&&setTimeout(d,s)}
const l=()=>{i&&i.save()}
const d=()=>{i&&p()}
const g=()=>{i&&i.end()
c&&clearInterval(c)
u&&clearTimeout(u)
i=null
c=null
u=null}
await b(e)
p()
return{add:(...e)=>{i&&i.add(e.join(" "))},save:l,split:d,end:g}})({flags:"a",pathLogDirectory:e,getLogFileName:()=>`${t}${(new Date).toISOString().replace(/\W/g,"-")}.log`}):{add:console.log,save:D,split:D,end:D})
C(e=>{n.add(`[EXITING] ${JSON.stringify(e)}`)})
j(e=>{n.add(`[EXIT] ${JSON.stringify(e)}`)
e.error&&n.add(`[EXIT][ERROR] ${e.error.stack||e.error}`)
n.end()})
return n}
var M=n(3)
var F=n(6)
var _=n(7)
const z=()=>"undefined"!=typeof window?window:"undefined"!=typeof global?global:void 0
const U=z()
const q=(()=>{try{const{performance:e}=U
const t=e.now.bind(e)
if(t()<=t())return t}catch(e){}try{const{process:e}=U
const t=()=>{const[t,n]=e.hrtime()
return 1e3*t+1e-6*n}
if(t()<=t())return t}catch(e){}return Date.now})()
const J=()=>Math.floor(.001*Date.now())
const G=(e=0)=>new Promise(t=>setTimeout(t,e))
const[H,B]=U.requestAnimationFrame?[U.requestAnimationFrame,U.cancelAnimationFrame]:[e=>setTimeout(e,1e3/60),clearTimeout]
const V=(e,t=null,n=null)=>({value:e,prev:t,next:n})
const Q=(e,t,n,r)=>({...V(t),key:e,size:n,expireAt:r})
const W=({valueSizeSumMax:e,valueSizeSingleMax:t=Math.max(.05*e,1)})=>{const{clear:n,subscribe:r,unsubscribe:o,send:s}=(()=>{let e=new Set
return{clear:()=>e.clear(),subscribe:t=>{e.add(t)},unsubscribe:t=>{e.delete(t)},send:t=>e.forEach(e=>e(t))}})()
const a=new Map
const i=(()=>{let e,t,n
const r=()=>{e=new Set
t=V(null)
n=V(null)
t.next=n
n.prev=t}
r()
const o=(t,n)=>{const{next:r}=n
n.next=r.prev=t
t.prev=n
t.next=r
e.add(t)}
const s=(t,n)=>{const{prev:r}=n
n.prev=r.next=t
t.prev=r
t.next=n
e.add(t)}
const a=t=>{const{prev:n,next:r}=t
n.next=r
r.prev=n
t.prev=t.next=null
e.delete(t)}
return{clear:r,getHead:()=>t,getTail:()=>n,getLength:()=>e.size,insertAfter:o,insertBefore:s,remove:a,removeBetween:(t,n)=>{const{prev:r}=t
const{next:o}=n
r.next=o
o.prev=r
t.prev=n.next=null
let s=t
for(;s;){e.delete(s)
s=s.next}},forEach:e=>{let r=t.next
let o=0
for(;r!==n;){e(r,o)
r=r.next
o++}},forEachReverse:r=>{let o=n.prev
let s=e.size-1
for(;o!==t;){r(o,s)
o=o.prev
s--}},reverse:()=>{let e=t.next
for(;e!==n;){const{prev:t,next:n}=e
e.prev=n
e.next=t
e=n}const{next:r}=t
const{prev:o}=n
t.next=o
n.prev=r
o.prev=t
r.next=n},setFirst:e=>{if(e===t.next)return
const{prev:n,next:r}=e
n.next=r
r.prev=n
e.prev=t
e.next=t.next
t.next=e},setLast:e=>{if(e===n.prev)return
const{prev:t,next:r}=e
t.next=r
r.prev=t
e.prev=n.prev
e.next=n
n.prev=e},push:e=>s(e,n),pop:()=>a(n.prev),unshift:e=>o(e,t),shift:()=>a(t.next)}})()
let c=0
const u=e=>{a.set(e.key,e)
i.unshift(e)
c+=e.size
s({type:"add",key:e.key,payload:e.value})}
const p=e=>{a.delete(e.key)
i.remove(e)
c-=e.size
s({type:"delete",key:e.key,payload:e.value})}
return{clearHub:n,subscribe:r,unsubscribe:o,getSize:()=>a.size,clear:()=>a.forEach(p),set:(n,r,o=1,s=Date.now()+6e4)=>{const l=a.get(n)
l&&p(l)
if(!(o>t)){for(;o+c>e;)p(i.getTail().prev)
u(Q(n,r,o,s))}},get:(e,t=Date.now())=>{const n=a.get(e)
if(n){if(n.expireAt<=t)return p(n)
i.setFirst(n)
return n.value}},touch:(e,t=Date.now()+6e4)=>{const n=a.get(e)
if(n){n.expireAt=t
i.setFirst(n)
return n.value}},delete:e=>{const t=a.get(e)
t&&p(t)
return t&&t.value},packList:()=>{const e=[]
i.forEachReverse(({key:t,value:n,size:r,expireAt:o})=>e.push({key:t,value:n,size:r,expireAt:o}))
return e},parseList:(e,t=Date.now())=>e.forEach(({key:e,value:n,size:r,expireAt:o})=>{const s=Q(e,n,r,o)
s.expireAt<=t?p(s):u(s)})}}
const Z=Number.isInteger
const K=e=>"object"==typeof e&&null!==e&&!Array.isArray(e)
const Y=Array.isArray
const X=e=>{const t=typeof e
let n
if("function"===t)n="()=>{...}"
else try{n=JSON.stringify(e)}catch(e){n="{...}"}return`<${t}> ${n}`}
const ee=(e,t,n)=>{throw new Error(`[verify|${e}]${t?` ${t};`:""} ${n}`)}
const te=(e,t)=>(n,r)=>t(n)||ee(e,r,`get: ${X(n)}`)
const ne=te("String",e=>"string"==typeof e)
const re=te("Number",e=>"number"==typeof e)
const oe=te("Integer",Z)
te("BasicObject",K)
te("Array",Y)
const se=(e,t,n)=>((e,t)=>Y(e)&&e.length===t)(e,t)||ee("ArrayLength",n,`expect length: ${t}, get: ${e.length}`)
const ae=te("Function",e=>"function"==typeof e)
var ie=n(4)
const ce=e=>{if(e.response.finished)return e
const{error:t}=e.getState()
!e.response.headersSent&&e.response.writeHead(t?500:400)
e.response.end()}
const ue=({url:e,method:t,headers:{host:n=""},socket:{remoteAddress:r,remotePort:o}})=>`[${t}] ${n}${e} (${r}:${o})`
const pe=e=>t=>{const{time:n,error:r}=t.getState()
e(ue(t.request),"|",r?"[ERROR]":"[END]",(e=>{const t=.75*Math.abs(e)
return t<1e3?`${Math.floor(e)}ms`:t<6e4?`${(e/1e3).toFixed(2)}s`:t<36e5?`${(e/6e4).toFixed(2)}m`:t<864e5?`${(e/36e5).toFixed(2)}h`:`${(e/864e5).toFixed(2)}d`})(q()-n),t.response.statusCode,r?r.stack||r:"")}
const le={protocol:"https:",hostname:"localhost",port:443,isSecure:!0,secureOptions:M.constants.SSL_OP_NO_SSLv3|M.constants.SSL_OP_NO_SSLv2}
const de={protocol:"http:",hostname:"localhost",port:80,isSecure:!1}
const ge=new Set([le.protocol,de.protocol])
const he=ce
const me=async({protocol:e="http:",hostname:t="localhost",port:n,fileSSLKey:r,fileSSLCert:o,fileSSLChain:s,fileSSLDHParam:a})=>{const i="https:"===e
return(({protocol:e,...t})=>{if(!ge.has(e))throw new Error(`[createServer] invalid protocol: ${e}`);(t={..."https:"===e?le:de,...t}).baseUrl=`${e}//${t.hostname}:${t.port}`
const n=t.isSecure?Object(_.createServer)(t):Object(F.createServer)()
t.isSecure&&(e=>{const t=W({valueSizeSumMax:4096})
e.on("newSession",(e,n,r)=>{t.set(e.toString("hex"),n,1,Date.now()+6e5)
r()})
e.on("resumeSession",(e,n)=>{n(null,t.get(e.toString("hex"))||null)})})(n)
return{server:n,option:t,start:()=>{!n.listening&&n.listen(t.port,t.hostname)},stop:()=>{n.listening&&n.close()}}})({protocol:e,hostname:t,port:n,key:i&&r?await u(r):null,cert:i&&o?await u(o):null,ca:i&&s?await u(s):null,dhparam:i&&a?await u(a):null})}
var fe=n(5)
const Se="application/octet-stream"
const we=["application/javascript;js;mjs","application/json","application/pdf","application/xml","audio/midi;mid","audio/mpeg;mp3","audio/ogg","audio/wav","audio/webm;weba","audio/x-flac;flac","font/ttf","font/otf","font/woff","font/woff2","image/bmp","image/gif","image/jpeg;jpg","image/png","image/svg+xml;svg","image/webp","image/x-icon;ico","text/css","text/csv","text/html;htm","text/plain;txt;text;conf;log;ini","text/rtf","text/xml","video/mp4;mp4v;mpg4","video/mpeg;mpg","video/webm","video/x-flv;flv","video/x-ms-wmv;wmv","video/x-msvideo;avi"].reduce((e,t)=>{const[n]=t.split(";")
t.split("/")[1].split(";").forEach(t=>e[t]=n)
return e},{})
const ye=e=>new Promise((t,n)=>{const r=[]
e.on("error",n)
e.on("data",e=>r.push(e))
e.on("end",()=>{e.removeListener("error",n)
t(Buffer.concat(r))})})
const be=(e,t)=>new Promise((n,r)=>{e.on("error",r)
e.write(t,()=>{e.removeListener("error",r)
n()})})
n(11)
const ve=Object(s.promisify)(fe.gzip)
const ke=(e,t,n,r)=>{t&&e.response.setHeader("etag",t)
const o=!t||!e.request.headers["if-none-match"]||!e.request.headers["if-none-match"].includes(t)
o?e.response.writeHead(200,{"content-type":n,"content-length":r}):e.response.writeHead(304,{"content-type":n})
return o}
const xe=async(e,{buffer:t,bufferGzip:n,entityTag:r,type:o=Se,length:s=t.length})=>{r&&e.response.setHeader("etag",r)
const a=!r||!e.request.headers["if-none-match"]||!e.request.headers["if-none-match"].includes(r)
const i=a&&s&&e.request.headers["accept-encoding"]&&e.request.headers["accept-encoding"].includes("gzip")
const c=i?n||await ve(t):t
a?e.response.writeHead(200,i?{"content-type":o,"content-length":c.length,"content-encoding":"gzip"}:{"content-type":o,"content-length":s}):e.response.writeHead(304,{"content-type":o})
return a&&s&&be(e.response,c)}
const Te=(e,{object:t,entityTag:n})=>xe(e,{buffer:Buffer.from(JSON.stringify(t)),type:we.json,entityTag:n})
const Oe=(e,t)=>({type:t,buffer:e,bufferGzip:Object(fe.gzipSync)(e),entityTag:(e=>`"${e.length.toString(16)}-${Object(M.createHash)("sha1").update(e).digest("base64")}"`)(e),length:e.length})
const $e=(e,t,n)=>K(t)&&e.unshift(...Object.entries(t).map(([e,t],r)=>[e,t,r,n]))
const Le=(e,t)=>void 0===e[t]?e[t]={}:e[t]
const Ee=(e,t)=>{const n=[]
return{routeNode:e=t.split("/").reduce((e,r)=>{if("*"===r){n.push("/*")
return Le(e,"/*")}if(":"===r[0]){const o=r.slice(1)
if(!o||n.includes(o))throw new Error(`[parseRouteToMap] invalid frag [${r}] for route: ${t}`)
n.push(o)
return Le(e,"/:PARAM")}return Le(e,r)},e),paramNameList:n}}
const Ne=(e,t)=>{const n=[]
const r=t.split("/")
for(let o=0,s=r.length;o<s;o++){const s=r[o]
if(e[s])e=e[s]
else{if(!e["/:PARAM"]){if(e["/*"]){n.push(r.slice(o).join("/"))
e=e["/*"]
break}throw new Error(`[findRouteFromMap] stuck at [${s}] for route: ${t}`)}n.push(s)
e=e["/:PARAM"]}}return{routeNode:e,paramValueList:n}}
const Ae=(e=[],t=[])=>["<!DOCTYPE html>","<html>","<head>",'<meta charset="utf-8">','<meta name="viewport" content="minimum-scale=1, width=device-width">',...e,"</head>","<body>",...t,"</body>","</html>"].join("\n")
const Pe=(e,t)=>{const n=document.querySelector(e)
n&&"string"==typeof t&&(n.innerHTML=t)
return n}
const Re=e=>[...document.querySelectorAll(e)]
const je=(e,t={},n=[])=>{const r=Object.assign(document.createElement(e),t)
n.forEach(e=>e&&r.appendChild(e))
return r}
const Ce=(e,t=[])=>t.forEach(t=>t&&e.appendChild(t))
const De=(e,t,...n)=>e.classList[t?"add":"remove"](...n)
const Ie=(e,t,n,r="")=>e[t?"setAttribute":"removeAttribute"](n,r)
const Me=()=>"complete"===document.readyState
const Fe=e=>{if(window.iDR())return e()
const t=()=>{if(window.iDR()){document.removeEventListener("readystatechange",t)
e()}}
document.addEventListener("readystatechange",t)}
const _e={GET:"/GET",POST:"/POST",PUT:"/PUT",PATCH:"/PATCH",DELETE:"/DELETE",HEAD:"/HEAD",OPTIONS:"/OPTIONS",CONNECT:"/CONNECT",TRACE:"/TRACE"}
const ze=(e,t="/",n="GET",r)=>{if(Array.isArray(t))return t.reduce((t,o)=>ze(e,o,n,r),e)
if(Array.isArray(n))return n.reduce((n,o)=>ze(e,t,o,r),e)
const{routeNode:o,paramNameList:s}=Ee(e,t)
if(!_e[n])throw new Error(`[appendRouteMap] invalid method [${n}] for route: ${t}`)
if(o[_e[n]])throw new Error(`[appendRouteMap] duplicate method [${n}] for route: ${t}`)
if("function"!=typeof r)throw new Error(`[appendRouteMap] invalid routeResponder for route: ${t}`)
o[_e[n]]={route:t,paramNameList:s,routeResponder:r}
return e}
const Ue=(e,t)=>(({paramMap:e},t)=>e[t])(e.getState(),t)
const qe=e=>{const t=[]
const n=new Set(Object.values(_e));((e,t)=>{const n=[]
$e(n,e,0)
for(;n.length;){const[e,r,o,s]=n.shift()
if(t(r,e,o,s))return{value:r,key:e,index:o,level:s}
$e(n,r,s+1)}})(e,(e,r)=>{n.has(r)&&t.push({method:r,route:e.route})})
return t}
const Je=(e,t=[])=>Ae(["<style>\n*, *::before, *::after { margin: 0; padding: 0; box-sizing: border-box; outline-color: #f00; }\n::-webkit-scrollbar-thumb { background: #0004; }\n::-webkit-scrollbar-thumb:hover { background: #0006; }\nbody { overflow: hidden; display: flex; flex-flow: column; width: 100vw; height: 100vh; font-family: monospace; font-size: 16px; }\nbutton, .button { text-decoration: none; cursor: pointer; margin: 4px; padding: 4px; min-width: 32px; border: 0; border-radius: 4px; background: hsla(0, 0%, 70%, 0.4); box-shadow: inset 0 0 0 1px #888; }\nbutton:hover, .button:hover { background: hsla(0, 0%, 80%, 0.4); box-shadow: inset 0 0 0 1px #aaa; }\nbutton.select, button:hover.select, .button.select, .button:hover.select { color: #e00; box-shadow: inset 0 0 0 1px #e00; }\nbutton:disabled, button:disabled:hover, .button:disabled, .button:disabled:hover { cursor: default; background: hsla(0, 0%, 100%, 0.4); box-shadow: unset; }\n@media (pointer: fine) {\n  ::-webkit-scrollbar { width: 14px; height: 14px; }\n  button, .button, .auto-height { min-height: 20px; font-size: 14px; } \n}\n@media (pointer: coarse) {\n  ::-webkit-scrollbar { width: 6px; height: 6px; }\n  button, .button, .auto-height { min-height: 32px; font-size: 18px; } \n}\n</style>","<style>body { overflow: auto; align-items: start; }</style>"],["<h2>Route List</h2>","<table>",...qe(e).map(({method:e,route:t})=>`<tr><td><b>${e}</b></td><td>${"/GET"===e?`<a href="${t}">${t}</a>`:t}</td></tr>`),"</table>",...t])
const Ge=(e,t)=>{const n=[]
for(let r=0;r<t;r++)n.push(e(r))
return n}
const He=(e=0,t=!0)=>({A:()=>e,B:()=>++e,C:()=>--e,D:()=>t,E:()=>t=!1})
const Be=(e=(e=>{}))=>{let t=He()
let n=Promise.resolve("QUEUE_HEAD")
return{reset:()=>{t.E()
t=He()
n=Promise.resolve("QUEUE_HEAD")},getLength:()=>t.A(),pushTask:r=>{const{promise:o,resolve:s}=(()=>{let e,t
return{promise:new Promise((n,r)=>{e=n
t=r}),resolve:n=>{const r=e
e=t=void 0
r&&r(n)},reject:n=>{const r=t
e=t=void 0
r&&r(n)}}})()
const a=n.then(r)
a.catch(e).then(()=>{t.C()
t.D()&&s()})
t.B()
n=o
return a}}}
const Ve=({clearRunner:e=(()=>{}),resetRunner:t=((e,t)=>{}),getTaskId:n,getTaskInitialState:r=(e=>e),runTask:o})=>{const{reset:s,getLength:a,pushTask:i}=Be()
const c=new Map
const u=e=>c.get(e)
const p=(e,t)=>{const n=u(e)
n&&c.set(e,{...n,...t})}
const l=e=>c.delete(e)
return{clear:()=>{s()
c.clear()
return e()},getStatus:e=>({taskQueue:a(),taskStateMap:c.size,taskStateList:e?Array.from(c.entries()):void 0}),getQueueLength:a,getTaskState:u,startTask:e=>{const s=n(e)
return c.get(s)||((e,n)=>{const s=i(()=>o(e,{getTaskState:u,updateTaskState:p})).then(t=>p(e,{result:t,promise:null,endAt:J()})).catch(n=>{p(e,{error:n,promise:null,endAt:J()})
return t(n,e)})
const a=r({id:e,option:n,promise:s,error:null,result:null,startAt:J(),endAt:null})
c.set(e,a)
return a})(s,e)},endTask:l,autoEndTask:e=>{const t=J()-Math.abs(e)
c.forEach((e,n)=>{e.endAt&&e.endAt<=t&&l(n)})}}}
const Qe=({runnerList:e=[],getRunnerByTaskId:t,selectRunner:n=We})=>({clear:()=>e.map(e=>e.clear()),getStatus:t=>e.map(e=>e.getStatus(t)),getQueueLength:()=>e.map(e=>e.getQueueLength()),getTaskState:n=>{const r=t(e,n)
return r&&r.getTaskState(n)},startTask:t=>n(e,t).startTask(t),endTask:n=>{const r=t(e,n)
return r&&r.endTask(n)},autoEndTask:t=>e.forEach(e=>e.autoEndTask(t))})
const We=e=>e.reduce((e,t)=>e.getQueueLength()>t.getQueueLength()?t:e,e[0])
const Ze=({protocol:e,hostname:t,hash:n,search:r,pathname:o,href:s,port:a,username:i,password:c})=>{const u={protocol:e,hostname:t,hash:n,search:r,pathname:o,href:s,path:`${o}${r}`}
""!==a&&(u.port=Number(a));(i||c)&&(u.auth=`${i}:${c}`)
return u}
const Ke=(e,t=null)=>new Promise((n,r)=>{const o=("https:"===e.protocol?_.request:F.request)(e,n)
const s=t=>{o.destroy()
t.option=e
r(t)}
o.on("timeout",()=>s(new Error("NETWORK_TIMEOUT")))
o.on("error",s)
o.end(t)})
const Ye=async({url:e,body:t,wait:n=5e3,maxRetry:r=0,...o})=>{o={...o,...Ze(new ie.URL(e)),timeout:n}
await(async(e,t=1/0,n=0)=>{let r=0
for(;;){const o=q()
try{return await e(r,t)}catch(e){if(t<++r)throw e
const s=n-(q()-o)
s>0&&await G(s)}}})(async()=>{(await Ke(o,t)).destroy()},r,n)}
const Xe=async(e,{method:t="GET",headers:n,body:r,timeout:o=1e4}={})=>{const s={...Ze(new ie.URL(e)),method:t,headers:{"accept-encoding":"gzip",...n},timeout:o}
const a=await Ke(s,r)
const i=a.headers
const c=a.statusCode
const u=c>=200&&c<300
let p=!1
let l
process.nextTick(()=>{if(!l){a.destroy()
p=!0}})
const d=async()=>{if(void 0===l){if(p)throw new Error("PAYLOAD_ALREADY_DROPPED")
let e=!1
let t=!1
o&&setTimeout(()=>{if(!t){a.destroy()
e=!0}},o)
l=ye("gzip"===a.headers["content-encoding"]?a.pipe(Object(fe.createGunzip)()):a).then(n=>{if(e)throw new Error("PAYLOAD_TIMEOUT")
t=!0
return n})}return l}
const g=()=>d().then(e=>e.toString())
return{headers:i,status:c,ok:u,buffer:d,text:g,json:()=>g().then(e=>JSON.parse(e))}}
var et=n(8)
const tt=Object.entries({addSnapShotTask:"({ projectCid, canvasZoom, canvasClip, taskList }) => {\n  window.SNAPSHOT_CONTROL.addSnapShotTask({ projectCid, canvasZoom, canvasClip, taskList })\n}",checkReady:"() => {\n  const { isReady } = window.SNAPSHOT_CONTROL.getState()\n  return isReady\n}",checkWait:"() => {\n  const { isReady, isWait } = window.SNAPSHOT_CONTROL.getState()\n  return isReady && isWait\n}",getTaskResult:"() => {\n  const { state } = window.SNAPSHOT_CONTROL.getState()\n  return state\n}",sendResume:"() => {\n  window.SNAPSHOT_CONTROL.resume()\n}",sendReset:"() => {\n  window.SNAPSHOT_CONTROL.resetTaskQueue()\n  window.SNAPSHOT_CONTROL.resume()\n}"}).reduce((e,[t,n])=>{e[t]=Object.assign(()=>{},{toString:()=>n})
return e},{})
const nt={timeout:1e4}
const rt=()=>{process.exit(-1)}
const ot={timeout:1e4}
const st=e=>Object(M.createHash)("sha1").update(JSON.stringify(e),"utf8").digest("base64").replace(/\W/g,"")
const at=async({clusterSize:e,logger:t,urlSnapshotApp:n,urlServerPingTest:o})=>{const s=await(async({logger:e})=>{e.add("[Puppeteer|Browser] init")
const t=Object(et.a)("puppeteer")
if(!t){const t=new Error("[Puppeteer] failed to load package puppeteer, check peerDependency")
e.add(t)
throw t}const n=await t.launch({args:["--no-sandbox"],headless:!0,handleSIGHUP:!1,handleSIGINT:!1,handleSIGTERM:!1})
n.addListener("disconnected",rt)
e.add("[Puppeteer|Browser] init complete")
return n})({logger:t})
C(async()=>s&&(({puppeteerBrowser:e})=>{e.removeListener("disconnected",rt)
return e.close().catch(e=>{})})({puppeteerBrowser:s}))
const a=Ge(e=>{let a=null
const i=(e,n)=>{e&&t.add(`[Puppeteer|${n}] error: ${e.stack||e.toString()}`)
return a&&(({puppeteerPage:e})=>e.close().catch(e=>{}))({puppeteerPage:a}).then(()=>{a=null})}
return Ve({clearRunner:i,resetRunner:i,getTaskInitialState:e=>({...e,progress:0}),runTask:async(e,{getTaskState:i,updateTaskState:c})=>{a||(a=await(async({puppeteerBrowser:e,logger:t})=>{t.add("[Puppeteer|Page] init start")
const n=await e.newPage()
n.on("error",e=>t.add("[Puppeteer|Page] error:",e))
n.on("pageerror",e=>t.add("[Puppeteer|Page] pageerror:",e))
n.on("requestfailed",e=>t.add("[Puppeteer|Page] requestfailed:",{url:e.url(),method:e.method()}))
n.on("console",e=>t.add("[Puppeteer|Page] console:",e.type(),e.text()))
t.add("[Puppeteer|Page] init complete")
return n})({puppeteerBrowser:s,logger:t}))
t.add(`[Puppeteer|${e}] start`)
await Ye({url:o,wait:2e3,maxRetry:4})
a.url().includes(n)||await(async({urlSnapshotApp:e,puppeteerPage:t,logger:n})=>{n.add("[Puppeteer|Page] setup start")
await t.goto(e,{waitUntil:"networkidle2",...nt})
await t.setUserAgent("Phantom WebKit")
await t.setViewport({width:0,height:0})
await t.waitForFunction(tt.checkReady,nt)
n.add("[Puppeteer|Page] setup ready")})({urlSnapshotApp:n,puppeteerPage:a,logger:t})
const{option:u}=i(e)
const p=await(async({option:e,puppeteerPage:t,stepCallback:n,logger:o})=>{const{projectCid:s,canvasZoom:a,canvasClip:i,taskList:c,pathOutput:u}=e
c.forEach(e=>e.screenStateCid=e.screenStateCid||"default")
await t.waitForFunction(tt.checkReady,ot)
await t.evaluate(tt.addSnapShotTask,{projectCid:s,canvasZoom:a,canvasClip:i,taskList:c})
const p=[]
const l=c.length
for(let e=0;e<l;e++){const s=async()=>{o.add(`[snapshot|${e+1}/${l}] wait for puppeteerPage render`)
await t.waitForFunction(tt.checkWait,ot)
const{canvasData:s,error:d}=await t.evaluate(tt.getTaskResult)
if(d||!s){o.add(`[snapshot|${e+1}/${l}] error: ${d}, canvasData: ${JSON.stringify(s)}`)
await t.evaluate(tt.sendReset)
throw d}const{screenCid:g,screenStateCid:h,canvasWidth:m,canvasHeight:f}=s
const S=c.find(e=>e.screenCid===g&&e.screenStateCid===h)
if(!S)throw new Error(`[snapshot] error getting task: ${JSON.stringify({taskList:c,canvasData:s})}`)
const{fileName:w}=S
const y={x:0,y:0,width:m,height:f,...i}
const b=Object(r.join)(u,w||`${g}-${h}_${a}_${y.width}_${y.height}.png`)
await t.screenshot({path:b,clip:y,omitBackground:!0,type:"png"})
await t.evaluate(tt.sendResume)
p.push({screenCid:g,screenStateCid:h,canvasZoom:a,canvasClip:i,fileName:w,filePath:b})
n({progress:Math.round(100*(e+1)/l)})
o.add(`[snapshot|${e+1}/${l}] file ready: ${b}`)}
await Promise.race([s(),new Promise((e,t)=>setTimeout(()=>t(new Error("[TIMEOUT] snapshot task timeout after 20000")),2e4))])}return p})({option:u,puppeteerPage:a,stepCallback:({progress:t})=>c(e,{progress:t}),logger:{...t,add:(e=>{let t=Date.now()
return(...n)=>{const r=Date.now()
e(`[+${r-t}ms]`,...n)
t=r}})(t.add)}})
t.add(`[Puppeteer|${e}] complete`)
return p},getTaskId:t=>`TSS-${e.toString(36)}-${st(t)}`})},e)
return Qe({runnerList:a,getRunnerByTaskId:(e,t)=>{const n=t&&/^TSS-(\d+)-/.exec(t)
return n&&e[parseInt(n[1],36)]}})}
const it=(e,t)=>Math.floor(Math.random()*(t-e+1)+e);(()=>{try{const{crypto:e}=global
const t=t=>{const n=new ArrayBuffer(t)
for(let r=0;r<t;r+=65536)e.getRandomValues(new Uint8Array(n,r,Math.min(65536,t-r)))
return n}
if(32===t(32).byteLength)return t}catch(e){}try{const{randomFillSync:e}=Object(et.a)("crypto")
const t=t=>{const n=new DataView(new ArrayBuffer(t))
e(n)
return n.buffer}
if(32===t(32).byteLength)return t}catch(e){}})()
const ct=({clusterSize:e,logger:t})=>{const n=(e,n)=>e&&t.add(`[DebugTaskRunner|${n}] error: ${e.stack||e.toString()}`)
const r=async(e,{getTaskState:n,updateTaskState:r})=>{t.add(`[DebugTaskRunner|${e}] start`,JSON.stringify(n(e).option))
for(let n=0,o=((e,t=0)=>it(Math.min(e,t),Math.max(e,t)))(5,10);n<o;n++){await G(500)
t.add(`[DebugTaskRunner|${e}] step [${n}/${o}]`)
if(8===o&&4===n)throw new Error("[DebugError] predefined error at 4 of 8")
r(e,{progress:Math.round(100*(n+1)/o)})}t.add(`[DebugTaskRunner|${e}] complete`)
return{output:"DebugTaskRunner"}}
const o=Ge(e=>Ve({resetRunner:n,runTask:r,getTaskId:t=>`TASK-DEBUG-${e.toString(36)}-${st(t)}`}),e)
return Qe({runnerList:o,getRunnerByTaskId:(e,t)=>{const n=t&&/^TASK-DEBUG-(\d+)-/.exec(t)
return n&&e[parseInt(n[1],36)]}})}
const ut=async(e,t)=>{void 0===t&&(t=await w(e))
if(!t.isDirectory())throw new Error(`[getDirectorySubInfoList] error pathType: ${y(t)} for ${e}`)
const n=[]
for(const t of await c(e)){const o=Object(r.join)(e,t)
const s=await w(o)
const a=y(s)
n.push({path:o,name:t,stat:s,type:a})}return n}
const pt=Object(s.promisify)(o.utimes)
const lt=Object(s.promisify)(o.unlink)
const dt=["thumbnail","zoom-0.50","zoom-1.00","zoom-2.00"]
const gt=async(e,t)=>{for(const{path:n,name:r}of await ut(e))r.startsWith(t)&&await lt(n)}
const ht=async(e,t,n,o)=>(async({option:e,taskRunnerCluster:t,logger:n})=>{const{taskList:[{fileName:o,fileNamePrefix:s}],pathOutput:a,routeOutput:i}=e
const c=await w(a)
const u=Object(r.join)(a,o)
if(c.isDirectory()&&(await w(u)).isFile()){n.add(`[Task|sync] exist: ${o}`)
const e=J()
await pt(u,e,e)}else{c.isDirectory()?await gt(a,s).catch(e=>n.add(`[ERROR|Task|sync] delete expired file error: ${e.stack}`)):await b(a,c)
n.add(`[Task|sync] start: ${JSON.stringify(e)}`)
const{id:r,promise:o}=t.startTask(e)
o&&await o
const{error:i}=t.getTaskState(r)
if(i)throw i}n.add(`[Task|sync] end: ${o}`)
return{pathFile:u,routeFile:Object(r.join)("/",i,o)}})({option:await(async(e,t,n)=>{const r=e.get("mode")||"thumbnail"
if(!dt.includes(r))throw new Error(`[fetchSyncTaskConfig] invalid mode: ${r}`)
const o=`${n}?${new ie.URLSearchParams({mode:r,access_token:e.get("access-token"),screen_cid:e.get("screen-cid"),screenstate_cid:e.get("screenstate-cid")||"default"})}`
const s=await Xe(o,{method:"GET",headers:{cookie:t.cookie||""}})
if(!s.ok)throw new Error(`[fetchSyncTaskConfig] fetch failed, url: ${o}, status: ${s.status}`)
const a=await s.json()
if(a.taskList&&1!==a.taskList.length)throw new Error("expect to get single task taskList")
return a})(e.getState().url.searchParams,e.request.headers,t),taskRunnerCluster:n,logger:o})
const mt=({logger:e,urlSnapshotTask:t,taskRunnerCluster:n})=>{return{responderStartTask:(t,r)=>{const o=n.startTask(r)
e.add(`[Task|start] ${o.id}`)
return Te(t,{object:{taskId:o.id}})},responderDeleteTask:(t,r)=>{n.endTask(r)
e.add(`[Task|delete] ${r}`)
return ce(t)},responderGetTaskStatus:(t,r)=>{const o=n.getTaskState(r)
if(!o)return Te(t,{object:{}})
const{error:s,progress:a=1}=o
const i={taskId:r,error:s&&s.toString(),progress:a}
e.add(`[Task|status] ${JSON.stringify(i)}`)
return Te(t,{object:i})},responderSyncSnapshotTaskNginx:async r=>{const{routeFile:o}=await ht(r,t,n,e)
return((e,{statusCode:t=500,headerMap:n})=>{if(e.response.finished)return e
!e.response.headersSent&&e.response.writeHead(t,n)
e.response.end()})(r,{statusCode:200,headerMap:{"x-accel-redirect":encodeURI(o)}})},responderSyncSnapshotTaskServe:async r=>{const{pathFile:o}=await ht(r,t,n,e)
r.response.setHeader("access-control-allow-origin","*")
return((e,{buffer:t,entityTag:n,type:r=Se,length:o=t.length})=>ke(e,n,r,o)&&o&&be(e.response,t))(r,{buffer:await u(o),type:we.png})}}}
const ft=()=>{const e=Oe(Buffer.from(Ae(["<style>\n*, *::before, *::after { margin: 0; padding: 0; box-sizing: border-box; outline-color: #f00; }\n::-webkit-scrollbar-thumb { background: #0004; }\n::-webkit-scrollbar-thumb:hover { background: #0006; }\nbody { overflow: hidden; display: flex; flex-flow: column; width: 100vw; height: 100vh; font-family: monospace; font-size: 16px; }\nbutton, .button { text-decoration: none; cursor: pointer; margin: 4px; padding: 4px; min-width: 32px; border: 0; border-radius: 4px; background: hsla(0, 0%, 70%, 0.4); box-shadow: inset 0 0 0 1px #888; }\nbutton:hover, .button:hover { background: hsla(0, 0%, 80%, 0.4); box-shadow: inset 0 0 0 1px #aaa; }\nbutton.select, button:hover.select, .button.select, .button:hover.select { color: #e00; box-shadow: inset 0 0 0 1px #e00; }\nbutton:disabled, button:disabled:hover, .button:disabled, .button:disabled:hover { cursor: default; background: hsla(0, 0%, 100%, 0.4); box-shadow: unset; }\n@media (pointer: fine) {\n  ::-webkit-scrollbar { width: 14px; height: 14px; }\n  button, .button, .auto-height { min-height: 20px; font-size: 14px; } \n}\n@media (pointer: coarse) {\n  ::-webkit-scrollbar { width: 6px; height: 6px; }\n  button, .button, .auto-height { min-height: 32px; font-size: 18px; } \n}\n</style>",(e=>{const t={}
const n=[]
Object.entries({qS:Pe,qSA:Re,cE:je,aCL:Ce,mECN:De,mEA:Ie,iDR:Me,tDR:Fe,...e}).forEach(([e,r])=>{"function"==typeof r?n.push(`<script>window[${JSON.stringify(e)}] = ${r.toString()}<\/script>`):t[e]=r})
return[`<script>Object.assign(window, ${JSON.stringify(t)})<\/script>`,...n].join("\n")})({onload:wt})],[St])),we.html)
return t=>xe(t,e)}
const St='\n<div style="flex-flow: row;">\n  <button onclick="getStatus()">getStatus</button>\n  <button onclick="getStatusDetail()">getStatusDetail</button>\n  <button onclick="startDebugTask()">startDebugTask</button>\n  <button onclick="startDebugTask10()">startDebugTask10</button>\n  <button onclick="startDebugSyncTask()">startDebugSyncTask</button>\n  <button onclick="resetLog()">resetLog</button>\n</div>\n<pre style="display: flex; flex-flow: row; font-size: 12px;">\n  <div id="status" style="overflow: auto; border-right: 2px solid #eee; font-size: 8px;">STATUS</div>\n  <div id="log" style="overflow: auto;">LOG</div>\n</pre>\n'
const wt=()=>{const{fetch:e,performance:t,qS:n}=window
const r=e=>{console.log("[STATUS]",e)
n("#status",JSON.stringify(e,null," "))}
const o=e=>{console.log("[LOG]",e)
n("#log").innerHTML+=`\n${e}`}
const s=async()=>{const n=await(await e("/task",{method:"POST",body:JSON.stringify(t.now().toString(36))})).text()
o(` - [Task] ${n}`)}
Object.assign(window,{resetLog:()=>{n("#log","LOG")},getStatus:async()=>{r(await(await e("/status",{method:"GET"})).json())},getStatusDetail:async()=>{r(await(await e("/status?verbose",{method:"GET"})).json())},startDebugTask:s,startDebugTask10:()=>{for(let e=0;e<10;e++)s().catch(console.warn)},startDebugSyncTask:async()=>{const n=`[SYNC]${t.now().toString(36)}`
o(`[SyncTask|${n}] start`)
const r=await(await e("/debug-sync-task",{method:"POST",body:JSON.stringify(n)})).text()
o(`[SyncTask|${n}] end: ${r}`)}})}
const yt=async({option:e,logger:t,routePrefix:n="",clusterSize:r,urlSnapshotApp:o,urlServerPingTest:s,urlSnapshotTask:a,isTaskRunnerDebugOnly:i})=>{const c=`${n}/task`
const u=`${n}/nginx-sync-snapshot`
const p=`${n}/debug-sync-snapshot`
const l=await(i?ct:at)({clusterSize:r,logger:t,urlSnapshotApp:o,urlServerPingTest:s})
const d=setInterval(()=>l.autoEndTask(30),3e4)
j(()=>clearInterval(d))
C(async()=>Promise.all([].concat(l.clear())))
const{responderStartTask:g,responderDeleteTask:h,responderGetTaskStatus:m,responderSyncSnapshotTaskNginx:f,responderSyncSnapshotTaskServe:S}=mt({logger:t,urlSnapshotTask:a,taskRunnerCluster:l})
const w=[[c,"POST",async e=>g(e,JSON.parse(await ye(e.request)))],[`${c}/:task-id`,"GET",e=>m(e,Ue(e,"task-id"))],[`${c}/:task-id`,"DELETE",e=>h(e,Ue(e,"task-id"))],[[u,`${u}.png`],"GET",f],[[p,`${p}.png`],"GET",S]]
if(i){const e=`${n}/debug`
const r=`${n}/debug-sync-task`
const o=((e,t)=>async(n,r)=>{t.add(`[Task|sync] start: ${JSON.stringify(r)}`)
const{id:o,promise:s}=e.startTask(r)
s&&await s
const{error:a,progress:i=1}=e.getTaskState(o)
const c={taskId:o,error:a&&a.toString(),progress:i}
t.add(`[Task|sync] end: ${JSON.stringify(c)}`)
return Te(n,{object:c})})(l,t)
w.push([e,"GET",ft()],[r,"POST",async e=>o(e,JSON.parse(await ye(e.request)))])}return{URL_TASK:c,URL_SYNC_SNAPSHOT_NGINX:u,URL_SYNC_SNAPSHOT_SERVE:p,routeList:w,taskRunnerCluster:l,getTaskRunnerClusterStatus:({isVerbose:e,isRaw:t})=>{const n=l.getStatus(e)
return t?n:e?n.map(({taskQueue:e,taskStateMap:t,taskStateList:n})=>({taskQueue:e,taskStateMap:t,taskStateList:n.map(([e,t])=>`[${t.error||`${t.progress||0}%`}] ${e}`)})):n.map(({taskQueue:e,taskStateMap:t})=>`${e}|${t}`)}}}
const bt=async({urlServerPingTest:e,urlSnapshotApp:t,urlSnapshotTask:n,taskRunnerCount:r,isTaskRunnerDebugOnly:o},{server:s,option:a,logger:i})=>{const{routeList:c,getTaskRunnerClusterStatus:u}=await yt({option:a,logger:i,routePrefix:"",clusterSize:r,urlSnapshotApp:t,urlServerPingTest:e,urlSnapshotTask:n,isTaskRunnerDebugOnly:o})
const p=pe(i.add)
const l=e=>{const{url:{searchParams:t}}=e.getState()
const n=t.has("verbose")
const r=t.has("raw")
i.add(`[Status] isVerbose: ${n}, isRaw: ${r}`)
return Te(e,{object:{taskRunnerCluster:u({isVerbose:n,isRaw:r})}})}
const d=(e=>e.reduce((e,[t,n,r])=>ze(e,t,n,r),{}))([...c,["/status","GET",l],["/","GET",o?((e,t)=>{let n
return async r=>{void 0===n&&(n=await Oe(Buffer.from(Je(e(),t)),we.html))
return xe(r,n)}})(()=>d):l],[["/favicon","/favicon.ico"],"GET",(()=>{const e=Oe(Buffer.from("iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mNMXvf/PwAGnQMR4CJUOAAAAABJRU5ErkJggg==","base64"),we.png)
return t=>xe(t,e)})()]])
s.on("request",(({responderList:e=[],responderEnd:t=he,responderError:n=((e,t)=>e.setState({error:t}))})=>async(r,o)=>{const s=(e=>({getState:()=>e,setState:t=>e={...e,...t}}))({time:q(),error:null})
s.request=r
s.response=o
try{for(const t of e)await t(s)}catch(e){await n(s,e)}await t(s)})({responderList:[(e=>t=>{e(ue(t.request),"|",t.request.headers["user-agent"]||"no-user-agent")})(i.add),(({baseUrl:e="",baseUrlObject:t=new ie.URL(e)})=>e=>{const{url:n,method:r}=e.request
e.setState({url:new ie.URL(n,t),method:r})})(a),(e=>t=>{const{url:n,method:r}=t.getState()
if(!n||!r)throw new Error(`[responderRouter] missing state: ${JSON.stringify({url:n,method:r})}`)
if(!_e[r])throw new Error(`[responderRouter] invalid method [${r}] from route: ${n.pathname}`)
const{routeNode:o,paramValueList:s}=Ne(e,n.pathname)
if(!o[_e[r]])throw new Error(`[responderRouter] invalid method [${r}] for route: ${n.pathname}`)
const{route:a,paramNameList:i,routeResponder:c}=o[_e[r]]
const u=i.reduce((e,t,n)=>{e[t]=s[n]
return e},{})
return c(t,t.setState({route:a,paramMap:u}))})(d)],responderEnd:e=>{ce(e)
p(e)}}))}
const vt={name:"",nameENV:"",nameJSON:"",shortName:"",aliasNameList:[],optional:!1,argumentCount:"0",argumentLengthMin:0,argumentLengthMax:0,argumentListNormalize:e=>e,argumentListVerify:e=>{},description:"",extendFormatList:[]}
const kt=/^(\d+)(-)?(\d+)?$/
const xt=(e,t)=>{"function"!=typeof e&&(e=!!e&&Tt)
return t?(n,r,o)=>e&&e(n,r,o)||!r.has(t):e}
const Tt=()=>!0
const Ot=(e,t,n)=>{e={...vt,...e}
!$t.test(e.name)&&Et(`name '${e.name}'`,e,t,n)
e.shortName&&!Lt.test(e.shortName)&&Et(`shortName '${e.shortName}'`,e,t,n)
{const r=e.aliasNameList.findIndex(e=>!$t.test(e));-1!==r&&Et(`aliasNameList #${r} '${e.aliasNameList[r]}'`,e,t,n)}{!kt.test(e.argumentCount)&&Et(`argumentCount '${e.argumentCount}'`,e,t,n)
const[,r,,o]=kt.exec(e.argumentCount)
o&&parseInt(o)<parseInt(r)&&Et(`argumentCount '${e.argumentCount}'`,e,t,n)}e.extendFormatList.length&&(e.extendFormatList=e.extendFormatList.map((t,n)=>Ot(t,n,e)))
return e}
const $t=/^[A-Za-z][A-Za-z0-9-]*$/
const Lt=/^[A-Za-z]$/
const Et=(e,t,n,r)=>{throw new Error(`[Format] ${Ft(t)} #${n}${r?` of ${Ft(r)}`:""} | ${e}`)}
const Nt=(e,t)=>n=>{const r=[]
const o=()=>r[r.length-1].argumentList
for(let s=0,a=n.length;s<a;s++){const a=n[s]
if(At.test(a)){const[,t,,n]=At.exec(a)
const s=e.get(t)
!s&&Rt(t)
r.push({format:s,argumentList:[]})
n&&o().push(n)}else if(Pt.test(a)){const[,e,,n]=Pt.exec(a)
e.split("").forEach(n=>{const o=t.get(n)
!o&&Rt(n,`from '${e}'`)
r.push({format:o,argumentList:[]})})
n&&o().push(n)}else{!r.length&&Rt(a,"no leading option found")
"--"===a?o().push(...n.slice(s)):o().push(a)}}return r}
const At=/^--([A-Za-z][A-Za-z0-9-]*)(=(.*))?$/
const Pt=/^-([A-Za-z]+)(=(.*))?$/
const Rt=(e,t="invalid option")=>{throw new Error(`[ParseArgv] unexpected '${e}', ${t}`)}
const jt=e=>(t,n={})=>e(t).reduce((e,{format:t,argumentList:n})=>{e[t.name]?e[t.name].argumentList.push(...n):e[t.name]={format:t,argumentList:n,source:"CLI"}
return e},n)
const Ct=e=>(t,n={})=>{e.forEach((e,r)=>{let o=t[r]
if(o){try{o=JSON.parse(o)}catch(e){}n[e.name]={format:e,argumentList:Array.isArray(o)?o:[o],source:"ENV"}}})
return n}
const Dt=e=>(t,n={})=>{e.forEach((e,r)=>{const o=t[r]
o&&(n[e.name]={format:e,argumentList:Array.isArray(o)?o:[o],source:"JSON"})})
return n}
const It=(e,t)=>(n,r)=>{const o=new Set
Object.entries(n).forEach(([e,t])=>{const{format:n,argumentList:s}=t
n.argumentLengthMin>s.length&&Mt(`expected ${n.argumentLengthMin-s.length} more argument`,n)
n.argumentLengthMax<s.length&&Mt(`expected ${s.length-n.argumentLengthMax} less argument`,n)
t.argumentList=n.argumentListNormalize(s,r)
n.argumentListVerify(t.argumentList,r)
o.add(n)})
e.forEach(e=>!o.has(e)&&Mt("non-optional option",e))
t.forEach(({format:e,checkOptional:t})=>!t(n,o,e)&&!o.has(e)&&Mt("non-optional option",e))
return n}
const Mt=(e,t)=>{throw new Error(`[Process] ${Ft(t)} | ${e}`)}
const Ft=({name:e,shortName:t,aliasNameList:n})=>`${e}${n.length?`|${n.join("|")}`:""}${t?` [-${t}]`:""}`
const _t=e=>Qt(e,zt)
const zt=e=>Wt(Ht(e,`--${e.name}${e.aliasNameList.length?` --${e.aliasNameList.join(" --")}`:""}`,e.shortName&&`-${e.shortName}`),e.description&&Zt(e.description,4),Bt(e.extendFormatList,zt,2))
const Ut=e=>Wt('"',Zt(`#!/usr/bin/env bash\n${Qt(e,qt)}`),'"')
const qt=e=>Wt(`export ${e.nameENV}="${Ht(e)}"`,Bt(e.extendFormatList,qt,0))
const Jt=e=>Wt("{",Zt(Qt(e,Gt)),"}")
const Gt=e=>Wt(`"${e.nameJSON}": [ "${Ht(e)}" ],`,Bt(e.extendFormatList,Gt,0))
const Ht=({optional:e,argumentLengthMin:t,argumentLengthMax:n},...r)=>[...r,e&&(e===Tt?"[OPTIONAL]":"[OPTIONAL-CHECK]"),(t||n)&&`[ARGUMENT=${Vt(t,n)}]`].filter(Boolean).join(" ")
const Bt=(e,t,n)=>e.length&&Zt(Qt(e,t),n)
const Vt=(e,t)=>`${e}${t===1/0?"+":t>e?`-${t}`:""}`
const Qt=(e,t)=>Wt(...e.map(t))
const Wt=(...e)=>e.filter(Boolean).join("\n")
const Zt=(e,t=2)=>t?((e,t="  ")=>`${t}${e.replace(/\n/g,`\n${t}`)}`)(e," ".repeat(t)):e
const Kt=e=>se(e,1,"single argument expected")
const Yt=(e,t)=>n=>{Kt(n)
e(n[0],`single ${t} argument expected`)}
const Xt=(e,t)=>n=>{n.forEach((n,r)=>e(n,`${t} expected at #${r}`))}
const en=Xt(ne,"String")
const tn=Xt(re,"Number")
const nn=Xt(oe,"Integer")
const rn=Xt(ae,"Function")
const on=e=>e.map(String)
const sn=e=>e.map(Number)
const an=e=>e.map(parseInt)
const cn=(e,t=(()=>{}),n=(e=>e),r="",o=!1)=>({argumentCount:e,argumentListNormalize:n,argumentListVerify:t,description:r,optional:o})
const un=(e,t)=>n=>{e(n)
return cn(1,(e=>t=>{Kt(t);((e,t,n)=>((e,t)=>t.includes(e))(e,t)||ee("OneOf",n,`expect one of: [${t}], get: ${X(e)}`))(t[0],e)})(n),t,`one of:\n  ${((e,t)=>{const n=[]
for(let r=0,o=e.length;r<o;r+=t)n.push(e.slice(r,r+t))
return n})(n,4).map(e=>e.join(" ")).join("\n  ")}`)}
const pn={SingleString:cn(1,Yt(ne,"String"),on),SingleNumber:cn(1,Yt(re,"Number"),sn),SingleInteger:cn(1,Yt(oe,"Integer"),an),SingleFunction:cn(1,Yt(ae,"Function"),void 0),AllString:cn("1-",en,on),AllNumber:cn("1-",tn,sn),AllInteger:cn("1-",nn,an),AllFunction:cn("1-",rn,void 0),OneOfString:un(on,en),OneOfNumber:un(sn,tn),OneOfInteger:un(an,nn),BooleanFlag:cn("0-",void 0,()=>[!0],"set to enable",!0),Any:cn("0-",void 0,void 0,"optional",!0)}
const ln={...pn,SinglePath:{...pn.SingleString,isPath:!0},AllPath:{...pn.AllString,isPath:!0},Config:{...pn.SingleString,description:"# from JSON: set to 'path/to/config.json'\n# from ENV: set to 'env'",optional:!0,name:"config",shortName:"c"}}
const dn=(e,t)=>{Object.values(e).forEach(({format:{isPath:e},argumentList:n})=>e&&n.forEach((e,o)=>n[o]=Object(r.resolve)(t,e)))
return e}
const{SingleString:gn,SingleInteger:hn,SinglePath:mn,BooleanFlag:fn}=ln
const{SingleString:Sn,SingleInteger:wn,BooleanFlag:yn,Config:bn}=ln
const vn={prefixENV:"imock-snapshot",formatList:[bn,{...yn,name:"help",shortName:"h"},{...yn,name:"version",shortName:"v"},((e=[])=>({...gn,optional:!0,name:"hostname",shortName:"H",extendFormatList:[{...hn,name:"port",shortName:"P"},{...fn,name:"https",shortName:"S",extendFormatList:[{...mn,name:"file-SSL-key"},{...mn,name:"file-SSL-cert"},{...mn,name:"file-SSL-chain"},{...mn,name:"file-SSL-dhparam"}]},{...mn,optional:!0,name:"log-path",extendFormatList:[{...gn,optional:!0,name:"log-file-prefix"}]},{...mn,optional:!0,name:"pid-file",extendFormatList:[{...fn,name:"pid-ignore-exist"}]},...e]}))([{...Sn,name:"url-server-ping-test"},{...Sn,name:"url-snapshot-app"},{...Sn,name:"url-snapshot-task"},{...wn,name:"task-runner-count"},{...yn,name:"task-runner-debug-only",shortName:"D"}])]}
const{parseOption:kn,formatUsage:xn}=(e=>{const{parseCLI:t,parseENV:n,parseJSON:o,processOptionMap:s,formatUsage:a}=(({formatList:e,prefixENV:t="",prefixJSON:n=""})=>{const r=new Map
const o=new Map
const s=new Map
const a=new Map
const i=new Set
const c=new Set
const u=(e,p,l)=>{const{name:d,shortName:g,aliasNameList:h,argumentCount:m}=e
const[,f,S,w]=kt.exec(m.toString())
e.nameENV=(t?`${t}-${d}`:d).split("-").join("_").toUpperCase()
e.nameJSON=((e,t=1)=>e.reduce((e,n,r)=>r>=t?e+n[0].toUpperCase()+n.slice(1):e+n,""))((n?`${n}-${d}`:d).split("-"))
e.optional=xt(e.optional,l)
e.argumentLengthMin=parseInt(f)
e.argumentLengthMax=S?w?parseInt(w):1/0:e.argumentLengthMin
r.has(d)&&Et(`duplicate name '${d}'`,e,p,l)
r.set(d,e)
g&&o.has(g)&&Et(`duplicate shortName '${g}'`,e,p,l)
g&&o.set(g,e)
{const t=h.find(e=>r.has(e))
t&&Et(`duplicate aliasName '${t}'`,e,p,l)
h.forEach(t=>r.set(t,e))}s.set(e.nameENV,e)
a.set(e.nameJSON,e)
e.optional?e.optional!==Tt&&c.add({format:e,checkOptional:e.optional}):i.add(e)
e.extendFormatList.forEach((t,n)=>u(t,n,e))};(e=e.map((e,t)=>Ot(e,t,null))).forEach((e,t)=>u(e,t,null))
return{parseCLI:jt(Nt(r,o)),parseENV:Ct(s),parseJSON:Dt(a),processOptionMap:It(i,c),formatUsage:(t,n=!1)=>Wt(t&&`Message:\n${Zt(t.toString())}`,`CLI Usage:\n${Zt(_t(e))}`,!n&&`ENV Usage:\n${Zt(Ut(e))}`,!n&&`JSON Usage:\n${Zt(Jt(e))}`)}})(e)
return{parseOption:async()=>(e=>{const t=t=>e[t]?e[t].argumentList:void 0
const n=(e,n)=>{const r=t(e)
if(!r)throw new Error(`[getOption] expecting option ${e}`)
if(void 0!==n&&r.length!==n)throw new Error(`[getOption] expecting option ${e} has ${n} value instead of ${r.length}`)
return r}
return{optionMap:e,getOptionOptional:t,getOption:n,getSingleOptionOptional:t=>e[t]?e[t].argumentList[0]:void 0,getSingleOption:e=>n(e,1)[0]}})(await(async({parseCLI:e,parseENV:t,parseJSON:n,processOptionMap:o})=>{const s=dn(e(process.argv.slice(2)),process.cwd())
const a=s.config&&s.config.argumentList.length&&s.config.argumentList[0]
return o({...a?"env"===a?dn(t(process.env),process.cwd()):dn(n(JSON.parse(await u(a,"utf8"))),Object(r.dirname)(a)):null,...s})})({parseCLI:t,parseENV:n,parseJSON:o,processOptionMap:s})),formatUsage:a}})(vn)
var Tn=n(9)
const On=async(e,{getOptionOptional:t,getSingleOption:n,getSingleOptionOptional:s})=>{await(async({filePid:e,shouldIgnoreExistPid:t=!1})=>{if(e){!t&&k(()=>{const t=Object(o.readFileSync)(e,{encoding:"utf8"})
if(t){console.warn(`[FilePid] get existing pid: ${t}, exit process...`)
return process.exit(-1)}})
await b(Object(r.dirname)(e))
await p(e,`${process.pid}`)
j(t=>{k(o.unlinkSync,e)})}})({filePid:s("pid-file"),shouldIgnoreExistPid:s("pid-ignore-exist")})
const{server:a,start:i,option:c}=await me({protocol:t("https")?"https:":"http:",hostname:n("hostname"),port:n("port"),fileSSLKey:s("file-SSL-key"),fileSSLCert:s("file-SSL-cert"),fileSSLChain:s("file-SSL-chain"),fileSSLDHParam:s("file-SSL-dhparam")})
const u=await I({pathLogDirectory:s("log-path"),logFilePrefix:s("log-file-prefix")})
await bt({urlServerPingTest:n("url-server-ping-test"),urlSnapshotApp:n("url-snapshot-app"),urlSnapshotTask:n("url-snapshot-task"),taskRunnerCount:n("task-runner-count"),isTaskRunnerDebugOnly:Boolean(t("task-runner-debug-only"))},{server:a,option:c,logger:u})
i()
u.add(`[SERVER UP] version: ${Tn.b}, pid: ${process.pid}, at: ${c.baseUrl}`)};(async()=>{const e=await kn()
const t=e.getSingleOptionOptional("hostname")
if(!t)return e.getOptionOptional("version")?console.log(JSON.stringify({packageName:Tn.a,packageVersion:Tn.b},null,"  ")):console.log(xn(null,e.getOptionOptional("help")?null:"simple"))
await On(0,e).catch(e=>{console.warn("[Error] server:",e.stack||e)
process.exit(2)})})().catch(e=>{console.warn(xn(e.stack||e,"simple"))
process.exit(1)})}])