humus-old/client/index.js

// 3rd party.
import msgpack from 'msgpack-lite';
import React from 'react';
import ReactDOM from 'react-dom';
// 2nd party.
import {create as createClient} from '@avocado/client/socket';
import {EntityList} from '@avocado/entity';
import {ActionRegistry, InputPacket} from '@avocado/input';
import {Stage} from '@avocado/graphics';
import {Vector} from '@avocado/math';
import {SocketIoParser} from '@avocado/packet';
import {
  StateKeysPacket,
  StatePacket,
  Synchronizer,
  Unpacker,
} from '@avocado/state';
import {Room, RoomView} from '@avocado/topdown';
import {World} from '@avocado/physics/matter/world';
import {clearAnimation, setAnimation, Ticker} from '@avocado/timing';
// 1st party.
import {augmentParserWithThroughput} from '../common/parser-throughput';
import {WorldTime} from '../common/world-time';
import {App} from './app';
import Ui from './ui';
import DebugUi from './ui/debug';
// Application.
const app = new App();
const config = app.readConfig();
// DOM.
const appNode = document.querySelector('.app');
// Graphics stage.
const stage = new Stage(config.visibleSize, config.visibleScale);
// Create room.
const room = new Room();
room.world = new World();
const roomView = new RoomView(room, stage.renderer);
stage.addChild(roomView);
// Time.
const worldTime = new WorldTime();
// Synchronize state.
let state = undefined;
const synchronizer = new Synchronizer({
  room,
  worldTime,
});
room.on('entityAdded', (entity) => {
  // Traits that shouldn't be on client.
  const noClientTraits = [
    'behaved',
    'informed',
  ];
  // If there's no physics, then remove physical trait.
  if (!room.world) {
    noClientTraits.push('physical');
  }
  // Traits that only make sense for our self entity on the client.
  const selfEntityOnlyTraits = [
    'controllable',
    'followed',
  ];
  const nixedTraits = selfEntityOnlyTraits.concat(noClientTraits);
  for (let i = 0; i < nixedTraits.length; ++i) {
    const type = nixedTraits[i];
    if (entity.is(type)) {
      entity.removeTrait(type);
    }
  }
  // Client only traits.
  const clientOnlyTraits = [
    'staged',
  ];
  for (let i = 0; i < clientOnlyTraits.length; ++i) {
    const type = clientOnlyTraits[i];
    entity.addTrait(type);
  }
  entity.stage = stage;
  // Set self entity.
  if (app.selfEntityUuid) {
    if (entity === room.findEntity(app.selfEntityUuid)) {
      app.selfEntity = entity;
      app.selfEntityUuid = undefined;
      // Add back our self entity traits.
      for (const type of selfEntityOnlyTraits) {
        entity.addTrait(type);
      }
      const {camera} = entity;
      stage.camera = camera;
      // Avoid the initial 'lerp.
      camera.realPosition = camera.position;
    }
  }
});
// Accept input.
window.addEventListener('keydown', (event) => {
  event = event || window.event;
  if ('F2' === event.key) {
    app.isDebugging = !app.isDebugging;
  }
});
const actionRegistry = new ActionRegistry();
actionRegistry.mapKeysToActions({
  'w': 'MoveUp',
  'a': 'MoveLeft',
  's': 'MoveDown',
  'd': 'MoveRight',
});
actionRegistry.listen(stage.element);
// Lol Apple
appNode.addEventListener('touchmove', (event) => {
  event.preventDefault();
});
// Mouse/touch movement.
function createMoveToNormal(position) {
  if (!app.selfEntity) {
    return;
  }
  const realEntityPosition = Vector.sub(
    app.selfEntity.position,
    app.selfEntity.camera.realOffset,
  );
  const magnitude = Vector.magnitude(position, realEntityPosition);
  if (magnitude < 8) {
    return;
  }
  const diff = Vector.sub(position, realEntityPosition);
  return Vector.normalize(diff);
}
let pointingAt = [-1, -1];
function isPointingAtAnything() {
  return -1 !== pointingAt[0] && -1 !== pointingAt[1];
}
function isInUi(node) {
  let walk = node;
  while (walk) {
    if (walk === stage.ui) {
      return true;
    }
    walk = walk.parentNode;
  }
  return false;
}
stage.on('pointerDown', (event) => {
  if (!isInUi(event.target)) {
    return;
  }
  pointingAt = event.position;
});
stage.on('pointerMove', (event) => {
  if (!isInUi(event.target)) {
    return;
  }
  if (!isPointingAtAnything()) {
    return;
  }
  pointingAt = event.position;
});
stage.on('pointerUp', (event) => {
  pointingAt = [-1, -1];
});
let actionState = actionRegistry.state;
// Create the socket connection.
const AugmentedParser = augmentParserWithThroughput(SocketIoParser);
const socket = createClient(window.location.href, {
  parser: AugmentedParser,
});
let isConnected = false;
socket.on('connect', () => {
  room.layers.destroy();
  app.selfEntity = undefined;
  app.selfEntityUuid = undefined;
  isConnected = true;
});
socket.on('disconnect', () => {
  isConnected = false;
});
// Mouse/touch movement.
const pointerMovementHandle = setInterval(() => {
  do {
    let normal;
    if (isPointingAtAnything()) {
      const toVector = Vector.scale(pointingAt, app.isDebugging ? 2 : 1);
      normal = createMoveToNormal(toVector);
      if (normal) {
        actionRegistry.state = actionRegistry.state.withMutations((state) => {
          if (normal[0]) {
            state.set('MoveToX', Math.floor(normal[0] * 127));
          }
          if (normal[1]) {
            state.set('MoveToY', Math.floor(normal[1] * 127));
          }
        });
        break;
      }
    }
    actionRegistry.state = actionRegistry.state.withMutations((state) => {
      if (!normal || 0 === normal[0]) {
        state.delete('MoveToX');
      }
      if (!normal || 0 === normal[1]) {
        state.delete('MoveToY');
      }
    });
  } while (false);
}, 1000 / 15);
// Input messages.
const inputHandle = setInterval(() => {
  if (!isConnected) {
    return;
  }
  if (actionState !== actionRegistry.state) {
    actionState = actionRegistry.state;
    socket.send(InputPacket.fromState(actionState));
  }
}, 1000 / 60);
// Prediction.
let mayRender = false;
const renderTicker = new Ticker(1 / 60);
renderTicker.on('tick', () => {
  mayRender = true;
});
let lastTime = performance.now();
const predictionHandle = setInterval(() => {
  if (!isConnected) {
    return;
  }
  const now = performance.now();
  const elapsed = (now - lastTime) / 1000;
  lastTime = now;
  if (app.selfEntity) {
    app.selfEntity.inputState = actionState.toJS();
  }
  // Tick synchronized.
  synchronizer.tick(elapsed);
  state = synchronizer.state;
  // Render timing.
  renderTicker.tick(elapsed);
}, 1000 / 60);
// State updates.
const unpacker = new Unpacker();
function onPacket(packet) {
  if (packet instanceof StateKeysPacket) {
    unpacker.registerKeys(packet.data);
  }
  if (packet instanceof StatePacket) {
    const patch = unpacker.unpack(packet.data);
    // Yank out self entity.
    if (!app.selfEntityUuid) {
      for (const step of patch) {
        const {op, path, value} = step;
        if ('add' === op && '/selfEntity' === path) {
          app.selfEntityUuid = value;
        }
      }
    }
    synchronizer.patchState(patch);
  }
}
socket.on('packet', onPacket);
// Apply stage lighting.
let isFocused = false;
stage.element.addEventListener('blur', () => {
  isFocused = false;
});
stage.element.addEventListener('focus', () => {
  isFocused = true;
});
let lastIntensity = undefined;
let lastIsFocused = undefined;
function applyStageLighting() {
  let intensity = 0;
  if (worldTime.hour >= 21 || worldTime.hour < 4) {
    intensity = 0.8;
  }
  if (worldTime.hour >= 4 && worldTime.hour < 7) {
    intensity = 0.8 * ((7 - worldTime.hour) / 3);
  }
  if (worldTime.hour >= 18 && worldTime.hour < 21) {
    intensity = 0.8 * ((3 - (21 - worldTime.hour)) / 3);
  }
  intensity = Math.floor(intensity * 1000) / 1000;
  if (intensity !== lastIntensity || isFocused !== lastIsFocused) {
    stage.removeAllFilters();
    if (!isFocused) {
      stage.paused(intensity);
    }
    else {
      stage.night(intensity);
    }
    lastIntensity = intensity;
    lastIsFocused = isFocused;
  }
}
// Render.
function render() {
  if (!isConnected) {
    return;
  }
  if (!mayRender) {
    return false;
  }
  mayRender = false;
  // Lighting.
  applyStageLighting();
  stage.render();
}
const renderHandle = setAnimation(render);
// UI.
const UiComponent = <Ui
  socket={socket}
  worldTime={worldTime}
/>;
// Create UI layer for react.
const reactContainer = window.document.createElement('div');
reactContainer.className = 'react';
stage.on('displaySizeChanged', () => {
  const displaySize = stage.displaySize;
  reactContainer.style.width = '100%';
  reactContainer.style.height = '100%';
})
stage.ui.appendChild(reactContainer);
ReactDOM.render(UiComponent, reactContainer);
// Debug UI.
const debugUiNode = document.querySelector('.debug-container');
const DebugUiComponent = <DebugUi
  actionRegistry={actionRegistry}
  app={app}
  Parser={AugmentedParser}
  socket={socket}
  stage={stage}
/>;
ReactDOM.render(DebugUiComponent, debugUiNode, () => {
  stage.resolveUiRendered();
});
// Inject the stage last.
stage.addToDom(appNode);
// Eval.
const evaluationContext = {
  room,
  selfEntity: app.selfEntity,
  stage,
};
app.on('selfEntityChanged', () => {
  evaluationContext.selfEntity = app.selfEntity;
});
// Just inject it into global for now.
window.humus = evaluationContext;