Method constructor

worker/model-worker-manager.ts:67–121

(
    options: {
      tmpDir: string;
      config: {
        timeout: number;
        debug: boolean;
        logLevel: string;
      };
    }
  )

  private aesKey: AesKey;

  constructor(
    options: {
      tmpDir: string;
      config: {
        timeout: number;
        debug: boolean;
        logLevel: string;
      };
    }
  ) {
    this.tmpDir = options.tmpDir;
    this.timeout = options.config.timeout;
    this.aesKey = generateKey();

    const shared = new SharedArrayBuffer(SHARED_BUFFER_SIZE);
    this.view = new Int32Array(shared);
    this.dataBuffer = new Uint8Array(shared, 4, SHARED_BUFFER_SIZE - 4);

    this.worker = new Worker(new URL('./model-worker.js', import.meta.url), {
      workerData: {
        tmpDir: options.tmpDir,
        config: options.config,
        aesKey: this.aesKey,
        shared,
      },
    });
    
    this.worker.on('online', () => {
      getLogger().info('[WorkerManager] Worker Online');
    });
    
    this.worker.on('message', (msg) => {
      if (msg.type === 'log') {
        if (msg.level === 'warn') {
          getLogger().warn(`[WorkerManager] ${msg.message}`);
        } else if (msg.level === 'error') {
          getLogger().error(`[WorkerManager] ${msg.message}`);
        } else {
          getLogger().info(`[WorkerManager] ${msg.message}`);
        }
      }
    });
    
    this.worker.on('error', (err) => {
      getLogger().error(`[WorkerManager] Error: ${err}`);
      this.running = false;
    });
    
    this.worker.on('exit', (code) => {
      getLogger().warn(`[WorkerManager] Worker Exit: ${code}`);
      this.running = false;
    });
    
    getLogger().info('[WorkerManager] Worker Started');
  }

  call(request: WorkerRequest): WorkerResponse | null {
    const requestId = request.requestId;