https://ezioqwarks-mlfloweq-server.hf.space/static-files/Telemetry…metry-worker.d0f8ea2c83c08b63528f.worker.js

1(()=>{"use strict";const t={randomUUID:"undefined"!==typeof crypto&&crypto.randomUUID&&crypto.randomUUID.bind(crypto)};let e;const s=new Uint8Array(16);const o=[];for(let p=0;p<256;++p)o.push((p+256).toString(16).slice(1));function n(t,e=0){return(o[t[e+0]]+o[t[e+1]]+o[t[e+2]]+o[t[e+3]]+"-"+o[t[e+4]]+o[t[e+5]]+"-"+o[t[e+6]]+o[t[e+7]]+"-"+o[t[e+8]]+o[t[e+9]]+"-"+o[t[e+10]]+o[t[e+11]]+o[t[e+12]]+o[t[e+13]]+o[t[e+14]]+o[t[e+15]]).toLowerCase()}function u(t,o,u){const i=(t=t||{}).random??t.rng?.()??function(){if(!e){if("undefined"===typeof crypto||!crypto.getRandomValues)throw new Error("crypto.getRandomValues() not supported. See https://github.com/uuidjs/uuid#getrandomvalues-not-supported");e=crypto.getRandomValues.bind(crypto)}return e(s)}();if(i.length<16)throw new Error("Random bytes length must be >= 16");if(i[6]=15&i[6]|64,i[8]=63&i[8]|128,o){if((u=u||0)<0||u+16>o.length)throw new RangeError(`UUID byte range ${u}:${u+15} is out of buffer bounds`);for(let t=0;t<16;++t)o[u+t]=i[t];return o}return n(i)}const i=function(e,s,o){return!t.randomUUID||s||e?u(e,s,o):t.randomUUID()};let r=function(t){return t.READY="READY",t}({}),l=function(t){return t.LOG_EVENT="LOG_EVENT",t.SHUTDOWN="SHUTDOWN",t}({});const a="../ajax-api/3.0/mlflow/ui-telemetry";class h{constructor(){this.queue=[],this.flushTimer=null,this.startFlushTimer()}enqueue(t){null!==this.flushTimer&&this.queue.push(t)}startFlushTimer(){null===this.flushTimer&&this.scheduleNextFlush()}scheduleNextFlush(){this.flushTimer=self.setTimeout(()=>{this.flush(),this.scheduleNextFlush()},3e4)}stopFlushTimer(){null!==this.flushTimer&&(self.clearTimeout(this.flushTimer),this.flushTimer=null),this.flush()}async flush(){if(0===this.queue.length||!navigator.onLine)return;const t=[...this.queue];this.queue=[];try{const e=await fetch(a,{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify({records:t})});if(!e.ok)return console.error(`[LogQueue] Failed to upload batch: ${e.status}`),void this.queue.unshift(...t);"disabled"===(await e.json()).status&&this.destroy()}catch(e){console.error("[LogQueue] Error uploading batch:",e),this.queue.unshift(...t)}}clear(){this.queue=[]}destroy(){this.stopFlushTimer(),this.queue=[]}}const c=self;const d=new class{constructor(){this.config=async function(){try{const t=await fetch(a,{method:"GET",headers:{"Content-Type":"application/json"}});if(!t.ok)throw new Error(`Failed to fetch config: ${t.status}`);return await t.json()}catch{return null}}(),this.sessionId=i(),this.logQueue=new h,this.samplingValue=100*Math.random()}async addLogToQueue(t){var e,s,o,n,u;const i=await this.config;if(!i||null===(e=i.disable_ui_telemetry)||void 0===e||e)return;if(!(this.samplingValue<(null!==(s=i.ui_rollout_percentage)&&void 0!==s?s:0)))return;(null===(o=i.disable_ui_events)||void 0===o?void 0:o.includes(null!==(n=null===(u=t.params)||void 0===u?void 0:u.componentId)&&void 0!==n?n:""))||this.logQueue.enqueue({...t,session_id:this.sessionId})}destroy(){this.logQueue.destroy()}};function f(t){const e=t.data;switch(e.type){case l.LOG_EVENT:d.addLogToQueue(e.payload).catch(()=>{});break;case l.SHUTDOWN:d.destroy(),c.close()}}c.onconnect=t=>{const e=t.ports[0];e.onmessage=f,e.postMessage({type:r.READY})}})();