"use strict"; // npm modules window.EventEmitter = require("event-emitter-es6"); window.FaviconNotification = require("favicon-notification"); window.panzoom = require("pan-zoom"); // Our files import RippleLink from './RippleLink'; import CursorSyncer from './CursorSyncer'; import OtherClient from './OtherClient'; import Pencil from './Pencil'; import { get } from './Utilities'; import Keyboard from './Utilities/Keyboard'; import Interface from './Interface'; import ChunkCache from './ChunkCache'; class BoardWindow extends EventEmitter { constructor(canvas) { super(); // Run the parent constructor // The maximum target fps. this.maxFps = 60; // The target fps at which we should send cursor updates. this.cursorUpdateFrequency = 5; // The radius of other clients' cursors. this.otherCursorRadius = 10; // The width of the lines in other clients' cursors. this.otherCursorWidth = 2; this.currentPlaneName = "(You haven't landed yet!)"; // Whether to display the chunk grid or not this.displayGrid = false; this.gridLineWidth = 2; this.gridLineColour = "rgba(22, 123, 228, 0.53)"; this.primaryGridLineWidth = 4; this.primaryGridLineColour = "rgba(31, 223, 4, 0.68)"; // --~~~-- // Setup the fps indicator in the top right corner this.renderTimeIndicator = document.createElement("span"); this.renderTimeIndicator.innerHTML = "0ms"; document.querySelector(".fps").appendChild(this.renderTimeIndicator); // --~~~-- // Our unique id this.Id = -1; // Our colour this.Colour = "rgba(255, 255, 255, 0.3)"; // The current state of the viewport. this.viewport = { // The x coordinate of the viewport. x: 0, // The y coordinate of the viewport. y: 0, // The width of the viewport get width() { return canvas.width * 1/this.zoomLevel }, // The height of the viewport get height() { return canvas.height * 1/this.zoomLevel }, // The zoom level of the viewport. 1 = normal. zoomLevel: 1 }; // The current grid size this.gridSize = -1; // --~~~-- // Setup the canvas this.canvas = canvas; this.context = canvas.getContext("2d"); // Grab a reference to the sidebar and wrap it in an Interface class instance this.interface = new Interface(document.getElementById("sidebar")); // Create a map to store information about other clients in this.otherClients = new Map(); /** * The currents tate of the keyboard. * @type {Keyboard} */ this.keyboard = new Keyboard(); // Toggle the grid display when the g key is released this.keyboard.on("keyup-g", (function(event) { this.displayGrid = this.displayGrid ? false : true; console.info(`[BoardWindow/KeyboardHandler] Grid display set to ${this.displayGrid ? "on" : "off"}`); }).bind(this)); this.keyboard.on("keyup-left", (function(event) { this.interface.seekColour("backwards"); }).bind(this)); this.keyboard.on("keyup-right", (function(event) { this.interface.seekColour("forwards"); }).bind(this)); this.keyboard.on("keyup-up", (function(event) { this.interface.updateBrushWidth(this.interface.currentBrushWidth + 2, true); }).bind(this)); this.keyboard.on("keyup-down", (function(event) { this.interface.updateBrushWidth(this.interface.currentBrushWidth - 2, true); }).bind(this)); // --~~~-- // Setup the favicon thingy FaviconNotification.init({ color: '#ff6333' }); FaviconNotification.add(); // Setup the input controls window.panzoom(canvas, this.handleCanvasMovement.bind(this)); // --~~~-- // Fetch the RippleLink connection information and other settings from // the server get("/Settings.json").then(JSON.parse).then((function(settings) { console.info("[setup]", "Obtained settings from server:", settings); this.settings = settings; this.setup(); }).bind(this), function(errorMessage) { console.error(`Error: Failed to fetch settings from server! Response: ${errorMessage}`); }); // --~~~-- // Setup a bunch of event listeners // The ones that depend on the RippleLink will get setup later // Make the canvas track the window size this.trackWindowSize(); } /** * Setup ready for user input. * This mainly consists of establishing the RippleLink connection to the server. */ setup() { this.rippleLink = new RippleLink(`ws${this.settings.SecureWebSocket ? "s" : ""}://${location.host}/${this.settings.WebSocketPath}`, this); this.rippleLink.on("connect", (function(event) { // Send the handshake request this.rippleLink.send({ Event: "HandshakeRequest", InitialViewport: { // TODO: Add support for persisting this between sessions X: 0, Y: 0, Width: window.innerWidth, Height: window.innerHeight }, InitialAbsCursorPosition: this.cursorPosition }); }).bind(this)); this.rippleLink.on("disconnect", (function(event) { this.interface.setConnectedStatus(false); }).bind(this)) // Keep the server up to date on our viewport and cursor position this.cursorSyncer = new CursorSyncer(this.rippleLink, this.cursorUpdateFrequency) // RippleLink message bindings // Handle the HandshakeResponse when it comes in this.rippleLink.on("HandshakeResponse", this.handleHandshakeResponse.bind(this)); // Handle other clients' state updates this.rippleLink.on("ClientStates", this.handlePeerUpdates.bind(this)); // Handle the plane change confirmations this.rippleLink.on("PlaneChangeOk", this.handlePlaneChangeOk.bind(this)); } /** * Renders the next frame. */ nextFrame() { // The time at which the current frame started rendering. let frameStart = +new Date(); if(frameStart - this.lastFrameStart >= (1 / this.maxFps) * 1000) { this.update(); this.render(this.canvas, this.context); } // Update the time the last frame started rendering this.lastFrameStart = frameStart; // Update the time we took rendering the last frame this.lastFrameTime = +new Date() - frameStart; this.renderTimeIndicator.innerHTML = `${this.lastFrameTime}ms`; // Limit the maximum fps requestAnimationFrame(this.nextFrame.bind(this)); } /** * Updates everything ready for the next frame to be rendered. */ update() { } /** * Renders the next frame. */ render(canvas, context) { context.clearRect(0, 0, canvas.width, canvas.height); context.save(); // Draw the grid if it's enabled if(this.displayGrid) this.renderGrid(canvas, context); // Only render the visible chunks if the chunk cache has been created // The chunk cache is only created once the ripple link connects successfully // to the nibriboard server. if(typeof this.chunkCache != "undefined" && this.gridSize != -1) this.chunkCache.renderVisible(this.viewport, canvas, context); this.renderOthers(canvas, context); // Render the currently active line if(typeof this.pencil !== "undefined") this.pencil.render(canvas, context); context.restore(); } renderGrid(canvas, context) { context.save(); context.scale(this.viewport.zoomLevel, this.viewport.zoomLevel); for(let ax = (this.viewport.x + (this.gridSize - (this.viewport.x % this.gridSize))) - this.gridSize; ax < (this.viewport.x + this.viewport.width); ax += this.gridSize) { context.beginPath(); context.moveTo(ax - this.viewport.x, 0); context.lineTo(ax - this.viewport.x, this.viewport.height); if(Math.round(ax) == 0) { context.lineWidth = this.primaryGridLineWidth; context.strokeStyle = this.primaryGridLineColour; } else { context.lineWidth = this.gridLineWidth; context.strokeStyle = this.gridLineColour; } context.stroke(); } for(let ay = (this.viewport.y + (this.gridSize - (this.viewport.y % this.gridSize))) - this.gridSize; ay < (this.viewport.y + this.viewport.height); ay += this.gridSize) { context.beginPath(); context.moveTo(0, ay - this.viewport.y); context.lineTo(this.viewport.width, ay - this.viewport.y); if(Math.round(ay) == 0) { context.lineWidth = this.primaryGridLineWidth; context.strokeStyle = this.primaryGridLineColour; } else { context.lineWidth = this.gridLineWidth; context.strokeStyle = this.gridLineColour; } context.stroke(); } context.restore(); } renderOthers(canvas, context) { context.save(); for (let [otherClientId, otherClient] of this.otherClients) { // TODO: Filter rendering by working out if this client is actually inside our viewport or not here context.save(); context.translate(otherClient.CursorPosition.x, otherClient.CursorPosition.y); context.beginPath(); // Horizontal line context.moveTo(-this.otherCursorRadius, 0); context.lineTo(this.otherCursorRadius, 0); // Vertical line context.moveTo(0, -this.otherCursorRadius); context.lineTo(0, this.otherCursorRadius); context.strokeStyle = otherClient.Colour; context.lineWidth = this.otherCursorWidth context.stroke(); context.restore(); } context.restore(); } /** * Updates the canvas size to match the current viewport size. */ matchWindowSize() { this.canvas.width = window.innerWidth; this.canvas.height = window.innerHeight; this.render(this.canvas, this.context); } /** * Makes the canvas size track the window size. */ trackWindowSize() { this.matchWindowSize(); window.addEventListener("resize", this.matchWindowSize.bind(this)); } /** * Handles events generated by pan-zoom, the package that handles the * dragging and zooming of the whiteboard. */ handleCanvasMovement(event) { // Don't bother processing it if it's a mouse / touch interaction and // the control key isn't pressed if([ "mouse", "touch" ].includes(event.type) && !this.keyboard.DownKeys.includes(17)) return; // Store the viewport information for later this.viewportState = event; this.viewport.x -= event.dx * 1/this.viewport.zoomLevel; this.viewport.y -= event.dy * 1/this.viewport.zoomLevel; this.viewport.zoomLevel += event.dz / 1000; console.debug(`Viewport now at (${this.viewport.x}, ${this.viewport.y}) @ ${this.viewport.zoomLevel}x zoom`); } /** * Handles the server's response to our handshake request * @param {object} message The server's response to our handshake request. */ handleHandshakeResponse(message) { console.log("Received handshake response"); // Store the information send by the server this.Id = message.Id; this.Colour = message.Colour; this.interface.OurColour = this.Colour; this.interface.setConnectedStatus(true); // The pencil that draws the lines this.pencil = new Pencil(this.rippleLink, this, this.canvas); // The cache for the chunks this.chunkCache = new ChunkCache(this); // Land on a default plane // future ask the user which plane they want to join this.rippleLink.send({ "Event": "PlaneChange", "NewPlaneName": "default-plane" }); } /** * Store the details about the new plane we've landed on that the server * sends us. * @param {object} message The plane change confirmation message to handle. */ handlePlaneChangeOk(message) { this.currentPlaneName = message.NewPlaneName; this.gridSize = message.GridSize; console.info(`Plane changed to ${this.currentPlaneName} with a grid size of ${this.gridSize} successfully.`); } /** * Handles peer update messages recieved from the server via the RippleLink. */ handlePeerUpdates(message) { // Update our knowledge about other clients for (let otherClient of message.ClientStates) { // If this client is new, emit an event about it if(!this.otherClients.has(otherClient.Id)) { this.emit("OtherClientConnect", otherClient); // Convert the raw object into a class instance let otherClientObj = new OtherClient(); otherClientObj.Id = otherClient.Id; } else { // If not, emit a normal update message about it this.emit("OtherClientUpdate", otherClient); } // Get the OtherClient instance to pull in the rest of the data this.otherClients.get(otherClient.Id).update(otherClient); } } } export default BoardWindow;