import {del, get, set} from 'idb-keyval';

import {encode} from '@/packets/index.js';

import Engine from '../../engine.js';
import Server from './server.js';

class WorkerServer extends Server {
  constructor() {
    super();
    this.fs = {};
  }
  static qualify(path) {
    return ['UNIVERSE', path].join('/');
  }
  async readAsset(path) {
    return fetch(path).then((response) => (
      response.ok ? response.arrayBuffer() : new ArrayBuffer(0)
    ));
  }
  async readData(path) {
    const data = await get(this.constructor.qualify(path));
    if ('undefined' !== typeof data) {
      return data;
    }
    const error = new Error();
    error.code = 'ENOENT';
    throw error;
  }
  async removeData(path) {
    await del(this.constructor.qualify(path));
  }
  async writeData(path, view) {
    await set(this.constructor.qualify(path), view);
  }
  transmit(connection, packed) { postMessage(packed); }
}

const engine = new Engine(WorkerServer);

onmessage = async (event) => {
  if (0 === event.data) {
    engine.stop();
    await engine.disconnectPlayer(0);
    await engine.saveEcses();
    postMessage(0);
    return;
  }
  engine.server.accept(0, event.data);
};

(async () => {
  await engine.load();
  engine.start();
  await engine.connectPlayer(0, 0);
  postMessage(encode({type: 'ConnectionStatus', payload: 'connected'}));
})();

if (import.meta.hot) {
  import.meta.hot.accept('../../engine.js', async ({default: Engine}) => {
    await engine.disconnectPlayer(0);
    if (Engine.prototype.createHomestead.toString() !== engine.createHomestead.toString()) {
      delete engine.ecses['homesteads/0'];
      await engine.server.removeData('homesteads/0');
      const newEngine = new Engine(WorkerServer);
      await newEngine.createHomestead(0);
    }
    postMessage(encode({type: 'ConnectionStatus', payload: 'aborted'}));
    close();
  });
}