Skip to content

erp5
erp5
Commit 3a63261c authored by Roque's avatar Roque
Browse files
Options

[WEB-WORKER] [WIP] Romain's initial work

parent 2018ca53
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 2071 additions and 0 deletions
erp5_drone_simulator/PathTemplateItem/web_page_module/drone_web_worker_logic_js.js 0 → 100644
View file @ 3a63261c
/*global window, rJS, jIO, RSVP, domsugar, console,
requestAnimationFrame, cancelAnimationFrame,
Worker,
DroneGameManager*/
/*jslint nomen: true, indent: 2, maxerr: 3, maxlen: 80 */
var runGame;
// game.js
(function () {
"use strict";
console.log('game logic');
runGame = function (canvas) {
console.log('runGame', canvas);
// Create the Babylon engine
var engine = new BABYLON.Engine(canvas, true);
engine.enableOfflineSupport = false;
// Create the base scene
var scene = new BABYLON.Scene(engine);
scene.clearColor = new BABYLON.Color4(88/255,171/255,217/255,255/255);
// this._scene.debugLayer.show();
// Collisions
scene.collisionsEnabled = true;
// Camera
//cap camera distance to 1km
var camera = new BABYLON.ArcRotateCamera("camera", 3, 1.25, 800, new BABYLON.Vector3(1, 0, 1), scene);
camera.wheelPrecision = 10;
//camera.attachControl(scene.getEngine().getRenderingCanvas());
camera.maxz = 40000
scene.render();
};
/*
// Resize canvas on window resize
window.addEventListener('resize', function () {
engine.resize();
});
*/
}(this));
\ No newline at end of file
erp5_drone_simulator/PathTemplateItem/web_page_module/drone_web_worker_page_html.html 0 → 100644
View file @ 3a63261c
<!DOCTYPE html>
<html>
<!--
data-i18n=Others
data-i18n=Tools
-->
<head>
<meta http-equiv="Content-type" content="text/html; charset=utf-8" />
<meta name="viewport" content="width=device-width" />
<title>Play Drone in WebWorker</title>
<link rel="http://www.renderjs.org/rel/interface" href="interface_page.html">
<!-- renderjs -->
<script src="rsvp.js" type="text/javascript"></script>
<script src="renderjs.js" type="text/javascript"></script>
<!-- custom script -->
<script src="jiodev.js" type="text/javascript"></script>
<script src="gadget_global.js" type="text/javascript"></script>
<script src="domsugar.js" type="text/javascript"></script>
<script src="gadget_erp5_page_game.js" type="text/javascript"></script>
</head>
<body>
</body>
</html>
\ No newline at end of file
erp5_drone_simulator/PathTemplateItem/web_page_module/drone_web_worker_page_js.js 0 → 100644
View file @ 3a63261c
/*global window, rJS, jIO, RSVP, domsugar, console,
requestAnimationFrame, cancelAnimationFrame,
Worker,
DroneGameManager*/
/*jslint nomen: true, indent: 2, maxerr: 3, maxlen: 80 */
// game.js
(function (RSVP, requestAnimationFrame, cancelAnimationFrame) {
"use strict";
console.log('game');
//////////////////////////////////////////
// Webworker
//////////////////////////////////////////
function handleWorker(url, callback) {
var worker;
function canceller() {
worker.terminate();
}
function resolver(resolve, reject) {
worker = new Worker(url);
function handleError(error) {
canceller();
reject(error);
}
worker.onerror = handleError;
var result;
try {
result = callback(worker);
} catch (e) {
return handleError(e);
}
new RSVP.Queue(result)
.push(function (value) {
canceller();
console.log('resolve handle worker', value);
resolve(value);
}, handleError);
}
return new RSVP.Promise(resolver, canceller);
}
//////////////////////////////////////////
// promiseAnimationFrame
//////////////////////////////////////////
function promiseAnimationFrame() {
var request_id;
function canceller() {
cancelAnimationFrame(request_id);
}
function resolver(resolve) {
request_id = requestAnimationFrame(resolve);
}
return new RSVP.Promise(resolver, canceller);
}
//////////////////////////////////////////
// DroneGameManager
//////////////////////////////////////////
function DroneGameManager() {
if (!(this instanceof DroneGameManager)) {
return new DroneGameManager();
}
}
DroneGameManager.prototype = {
constructor: DroneGameManager,
pause: function pauseGameManager() {
console.log('pausing', this.loop_promise);
if (!this.hasOwnProperty('loop_promise')) {
throw new Error('Can not pause the game if not started');
}
if (this.hasOwnProperty('pause_defer')) {
throw new Error('Can not pause the game if already paused');
}
this.pause_defer = RSVP.defer();
var pause_defer = this.pause_defer;
this.loop_promise
.push(function () {
return pause_defer.promise;
});
},
unpause: function continueGameManager() {
if (!this.hasOwnProperty('loop_promise')) {
throw new Error('Can not unpause the game if not started');
}
if (!this.hasOwnProperty('pause_defer')) {
throw new Error('Can not unpause the game if not paused');
}
this.pause_defer.resolve('unpause');
var pause_defer = this.pause_defer;
delete this.pause_defer;
},
quit: function stopGameManager() {
if (!this.hasOwnProperty('loop_promise')) {
throw new Error('Can not quit the game if not started');
}
this.loop_promise.cancel('Stopping game manager');
console.log('stopping game manager');
delete this.loop_promise;
delete this.pause_defer;
},
play: function startGameManager(options) {
if (this.hasOwnProperty('loop_promise')) {
throw new Error('Can not start the game if already started');
}
this.loop_promise = new RSVP.Queue();
var loop_promise = this.loop_promise,
context = this;
this.pause();
return RSVP.Queue(RSVP.any([
loop_promise,
handleWorker('gadget_erp5_page_game_worker.js', function (worker) {
var message_error_handler_defer = RSVP.defer(),
update_defer = null;
function step() {
context.loop_promise
.push(function () {
console.log('loop step');
worker.postMessage({
type: 'update'
});
update_defer = RSVP.defer();
return RSVP.all([
promiseAnimationFrame(),
update_defer.promise
]);
})
.push(function () {
step();
});
}
console.log('got worker ', worker, options);
worker.onmessage = function (evt) {
//console.log('Message received from worker', evt.data);
var type = evt.data.type;
if (type === 'loaded') {
console.log('loaded');
return worker.postMessage({
type: 'start',
logic_url: options.logic_url,
canvas: options.canvas
}, [options.canvas]);
}
if (type === 'started') {
console.log('started');
context.unpause();
return step();
}
if (type === 'updated') {
return update_defer.resolve('updated');
}
message_error_handler_defer.reject(
new Error('Unsupported message ' + JSON.stringify(evt.data))
);
};
// Always quit the game when the worker callback usage is over
// to prevent trying to call pause
//context.quit();
return message_error_handler_defer.promise;
})
]))
.push(undefined, function (error) {
// As the loop_promise will be cancelled at some point when calling
// quit, we will get a CancellationError as result.
// This is expected, and play must be successfully resolved
if (!(error instanceof RSVP.CancellationError)) {
throw error;
}
});
}
};
window.DroneGameManager = DroneGameManager;
}(RSVP, requestAnimationFrame, cancelAnimationFrame));
// droneaailefixe.js
(function () {
"use strict";
console.log('droneaailefixe');
}());
// page gadget.js
(function (window, rJS, domsugar, DroneGameManager) {
"use strict";
rJS(window)
/////////////////////////////////////////////////////////////////
// Acquired methods
/////////////////////////////////////////////////////////////////
.declareAcquiredMethod("updateHeader", "updateHeader")
.declareMethod('render', function renderHeader() {
var gadget = this,
// XXX hardcoded
parameter_gamelogic = 'gadget_erp5_page_game_logic.js',
// https://doc.babylonjs.com/divingDeeper/scene/offscreenCanvas
canvas = domsugar('canvas'),
offscreen;
domsugar(gadget.element, [canvas]);
/*
canvas.width = canvas.clientWidth;
canvas.height = canvas.clientHeight;
*/
offscreen = canvas.transferControlToOffscreen();
gadget.runGame({
logic_url: parameter_gamelogic,
canvas: offscreen
});
return gadget.updateHeader({
page_title: 'Game',
page_icon: 'puzzle-piece'
});
})
.declareJob('runGame', function runGame(options) {
var gadget = this,
game_manager = DroneGameManager();
return game_manager.play(options);
/*
return RSVP.any([
RSVP.Queue(game_manager.play(options))
.push(function (result) {
console.log('play finished', result);
}),
RSVP.Queue(RSVP.delay(1000))
.push(function () {
game_manager.pause();
return RSVP.delay(1000);
})
.push(function () {
game_manager.unpause();
return RSVP.delay(1000);
})
.push(function () {
game_manager.quit();
})
]);
*/
});
}(window, rJS, domsugar, DroneGameManager));
\ No newline at end of file
erp5_drone_simulator/PathTemplateItem/web_page_module/drone_web_worker_web_worker_js.js 0 → 100644
View file @ 3a63261c
/*global window, rJS, jIO, RSVP, domsugar, console,
requestAnimationFrame, cancelAnimationFrame,
Worker, importScripts,
DroneGameManager*/
/*jslint nomen: true, indent: 2, maxerr: 3, maxlen: 80 */
// game.js
(function (worker) {
"use strict";
var window = {};
console.log('worker loading');
worker.onmessage = function (evt) {
//console.log('Worker: Message received from main script', evt.data);
var type = evt.data.type;
if (type === 'start') {
console.log('Worker: Message received from main script', evt.data);
importScripts('babylon.js', evt.data.logic_url);
runGame(evt.data.canvas);
return worker.postMessage({'type': 'started'});
}
if (type === 'update') {
var i;
for (i = 0; i < 100000000; i += 1) {
1+1;
}
return worker.postMessage({'type': 'updated'});
}
throw new Error('Unsupported message ' + JSON.stringify(evt.data));
//self.postMessage('nutnut', evt);
};
worker.postMessage({
'type': 'loaded'
});
//throw new Error('argh');
}(this));
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7