12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289 |
- import { Lang } from '/lib/polyglot/language.js';
- import { Helpers } from '/helpers.js';
- import { IndexApp } from '/web/index-app.js';
- import { Widgets } from '/lib/widgets.js';
- class App {
- constructor() {
- console.log("app constructor");
- this.widgets = new Widgets;
- //globals
- window._app = this;
- window._cellWidgets = this.widgets;
- window._LangManager = new Lang;
- window._noty = new Noty;
- _LangManager.setLanguage().then(res => {
- return this.initDB()
- }).then(res => {
- this.helpers = new Helpers;
- this.initUser();
-
- //client routes
- page('/', this.HandleIndex);
- page('/setup', this.HandleSetupIndex);
- page('/profile', this.HandleUserIndex);
- page('/worlds', this.HandleIndex);
- page('/:user/worlds', this.HandleUserWorlds);
- page('/:user/worlds/:type', this.HandleUserWorldsWithType);
- page('/:user/:type/:name/edit/:file', this.HandleFileEdit);
- page('/:user/:space', this.HandleParsableRequestGenID);
- page('/:user/:space/:id', this.HandleParsableRequestWithID);
- page('/:user/:space/index.vwf/:id', this.HandleParsableRequestWithID);
- page('/:user/:space/load/:savename', this.HandleParsableLoadRequest);
- page('/:user/:space/:id/load/:savename', this.HandleParsableRequestWithID);
- page('/:user/:space/load/:savename/:rev', this.HandleParsableLoadRequestWithRev);
- page('/:user/:space/:id/load/:savename/:rev', this.HandleParsableRequestWithID);
- page('*', this.HandleNoPage);
- page();
- })
- }
- initDB() {
- var config = JSON.parse(localStorage.getItem('lcs_config'));
- if (!config) {
- config = {
- 'dbhost': 'https://' + window.location.hostname + ':8080/gun', //'http://localhost:8080/gun',
- 'reflector': 'https://' + window.location.hostname + ':3002',
- 'language': 'en'
- }
- localStorage.setItem('lcs_config', JSON.stringify(config));
- }
- const dbConnection = new Promise((resolve, reject) => {
- this.db = Gun(this.dbHost);
- this.user = this.db.user();
- window._LCSDB = this.db;
- window._LCSUSER = this.user;
- window._LCS_SYS_USER = undefined;
- window._LCS_WORLD_USER = undefined;
- _LCSDB.get('lcs/app').get('pub').once(res => {
- if (res) {
- window._LCS_SYS_USER = this.db.user(res);
- }
- });
- _LCSDB.on('hi', function (peer) {
- let msg = 'Connected to ' + peer.url;
- let noty = new Noty({
- text: msg,
- timeout: 2000,
- theme: 'mint',
- layout: 'bottomRight',
- type: 'success'
- });
- noty.show();
- console.log(msg)
- })
- _LCSDB.on('bye', function (peer) {
- let msg = 'No connection to ' + peer.url;
- let noty = new Noty({
- text: msg,
- timeout: 1000,
- theme: 'mint',
- layout: 'bottomRight',
- type: 'error'
- });
- noty.show();
- console.log(msg)
- })
- resolve('ok');
- });
- return dbConnection
- }
- initUser() {
- _LCSUSER.recall({ sessionStorage: 1 });
- }
- get reflectorHost() {
- var res = "";
- let config = localStorage.getItem('lcs_config');
- if (config) {
- res = JSON.parse(config).reflector;
- }
- return res;
- }
- get dbHost() {
- var res = "";
- let config = localStorage.getItem('lcs_config');
- if (config) {
- res = JSON.parse(config).dbhost;
- }
- return res;
- }
- async loadProxyDefaults() {
- //load to DB default proxy files (VWF & A-Frame components)
- let proxyResponse = await fetch('/proxy-files', { method: 'get' });
- let proxyFiles = await proxyResponse.json();
- let filterProxyFiles = proxyFiles.filter(el => (el !== null));
- console.log(filterProxyFiles);
- var origin = window.location.origin;
- //var userPub = _LCSUSER.is.pub;
- let proxyObj = {};
- for (var index in filterProxyFiles) {
- let el = filterProxyFiles[index];
- if (el) {
- var url = origin + el;
- var entryName = url.replace(origin + '/defaults/', "").split(".").join("_");
- let proxyFile = await fetch(url, { method: 'get' });
- let responseText = await proxyFile.text();
- if (responseText) {
- let obj = {
- //'owner': userPub,
- 'file': responseText
- }
- proxyObj[entryName] = obj;
- }
- }
- }
- console.log(proxyObj);
- Object.keys(proxyObj).forEach(el => {
- _LCSDB.user().get('proxy').get(el).put(proxyObj[el]);
- })
- }
- async loadWorldsDefaults() {
- //load to DB default worlds
- let worldsResponse = await fetch('/world-files', { method: 'get' });
- let worldFiles = await worldsResponse.json();
- let filterworldFiles = worldFiles.filter(el => (el !== null));
- console.log(filterworldFiles);
- let worldsObj = {};
- for (var index in filterworldFiles) {
- let el = filterworldFiles[index];
- if (el) {
- let url = window.location.origin + el;
- var entryName = url.replace(window.location.origin + '/defaults/worlds/', "").split(".").join("_");
- let worldName = entryName.split("/")[0];
- let userPub = _LCSUSER.is.pub;
- let worldFile = await fetch(url, { method: 'get' });
- let worldSource = await worldFile.text();
- if (worldSource) {
- let modified = new Date().valueOf();
- let obj = {
- 'file': worldSource,
- 'modified': modified
- }
- if (!worldsObj[worldName]) {
- worldsObj[worldName] = {
- 'parent': '-',
- 'owner': userPub,
- 'featured': true,
- 'published': true
- }
- }
- let entry = entryName.replace(worldName + '/', "");
- worldsObj[worldName][entry] = obj;
- }
- }
- }
- console.log(worldsObj);
- Object.entries(worldsObj).forEach(el => {
- let worldName = el[0];
- let files = el[1];
- Object.entries(files).forEach(file => {
- _LCSDB.user().get('worlds').get(worldName).get(file[0]).put(file[1]);
- })
- })
- }
- async loadEmptyDefaultProto() {
- //empty proto world
- let userPub = _LCSUSER.is.pub;
- let worldsObj = {};
- let emptyWorld = {
- "index_vwf_yaml": YAML.stringify(
- {
- "extends": "http://vwf.example.com/aframe/ascene.vwf"
- }, 4),
- "index_vwf_config_yaml": YAML.stringify(
- {
- "info": {
- "title": "Empty World"
- },
- "model": {
- "vwf/model/aframe": null
- },
- "view": {
- "vwf/view/aframe": null,
- "vwf/view/editor-new": null
- }
- }, 4),
- "index_vwf_html": "",
- "appui_js": "",
- "info_json": JSON.stringify ({
- "info": {
- "en": {
- "title": "Empty World",
- "imgUrl": "",
- "text": "Empty World"
- },
- "ru": {
- "title": "Новый Мир",
- "imgUrl": "",
- "text": "Новый Мир"
- }
- }
- })
- }
- worldsObj['empty'] = {
- 'parent': '-',
- 'owner': userPub,
- 'featured': true,
- 'published': true
- }
- Object.keys(emptyWorld).forEach(el=>{
- let modified = new Date().valueOf();
- let obj = {
- 'file': emptyWorld[el],
- 'modified': modified
- }
- worldsObj['empty'][el] = obj;
- })
- console.log(worldsObj);
- Object.entries(worldsObj).forEach(el => {
- let worldName = el[0];
- let files = el[1];
- Object.entries(files).forEach(file => {
- _LCSDB.user().get('worlds').get(worldName).get(file[0]).put(file[1]);
- })
- })
- }
- //load defaults for first registered user running ./setup
- HandleSetupIndex() {
- window._app.hideProgressBar();
- window._app.hideUIControl();
- let el = document.createElement("div");
- el.setAttribute("id", "admin");
- document.body.appendChild(el);
-
- _LCSDB.on('auth',
- async function (ack) {
- if (_LCSUSER.is) {
- let setPubKey = {
- $cell: true,
- $components: [
- {
- $type: "p",
- class: "mdc-typography--headline5",
- $text: "1. Set app system user PUB key"
- },
- {
- $type: "button",
- class: "mdc-button mdc-button--raised",
- $text: "Set app PUB key",
- onclick: function (e) {
- console.log("admin action");
- _LCSDB.get('lcs/app').get('pub').put(_LCSUSER.is.pub);
- }
- }
- ]
-
- }
-
- let adminComponents = [];
-
- let defaultPub = await _LCSDB.get('lcs/app').get('pub').once().then();
- if (!defaultPub) {
- adminComponents.push(setPubKey);
- }
- if (_LCSUSER.is.pub == defaultPub) {
- let loadEmpty = {
- $cell: true,
- $components: [
- {
- $type: "p",
- class: "mdc-typography--headline5",
- $text: "3. Initialize empty World proto"
- },
- {
- $type: "button",
- id: "loadDefaults",
- class: "mdc-button mdc-button--raised",
- $text: "Init empty world",
- onclick: function (e) {
- console.log("admin action");
- window._app.loadEmptyDefaultProto();
- }
- }
- ]
- }
-
- let loadDefaults = {
- $cell: true,
- $components: [
- {
- $type: "p",
- class: "mdc-typography--headline5",
- $text: "4. Load Sample Worlds protos from server (optional)"
- },
- {
- $type: "button",
- id: "loadDefaults",
- class: "mdc-button mdc-button--raised",
- $text: "Load default worlds (from server)",
- onclick: function (e) {
- console.log("admin action");
- window._app.loadWorldsDefaults();
- }
- }
- ]
- }
- let loadDefaultsProxy = {
- $cell: true,
- $components: [
- {
- $type: "p",
- class: "mdc-typography--headline5",
- $text: "3. Load VWF & A-Frame default components"
- },
- {
- $type: "button",
- class: "mdc-button mdc-button--raised",
- $text: "Load defaults Proxy",
- onclick: function (e) {
- console.log("admin action");
- window._app.loadProxyDefaults();
- }
- }
- ]
- }
- adminComponents.push(setPubKey, loadDefaultsProxy, loadEmpty, loadDefaults);
- }
- document.querySelector("#admin").$cell({
- $cell: true,
- id: 'adminComponents',
- $type: "div",
- $components: adminComponents
- });
- }
- })
- }
- //TODO: profile
- HandleUserIndex(ctx) {
- console.log("USER INDEX");
- window._app.hideProgressBar();
- window._app.hideUIControl();
- _LCSDB.on('auth',
- async function (ack) {
- if(ack.pub){
- document.querySelector("#profile")._status = "User: " + _LCSUSER.is.alias //+' pub: ' + _LCSUSER.is.pub;
- document.querySelector("#profile").$update();
- }
- })
- let el = document.createElement("div");
- el.setAttribute("id", "userProfile");
- document.body.appendChild(el);
- let userProfile = {
- $type: 'div',
- id: "profile",
- _status: "",
- $init: function(){
- this._status = "user is not signed in..."
- },
- $update: function(){
- this.$components = [
- {
- $type: "h1",
- class: "mdc-typography--headline4",
- $text: this._status //"Profile for: " + _LCSUSER.is.alias
- }
- ]
- }
- }
- document.querySelector("#userProfile").$cell({
- $cell: true,
- $type: "div",
- $components: [userProfile]
- })
- }
- async HandleUserWorlds(ctx) {
- console.log("USER WORLDS INDEX");
- console.log(ctx.params);
- let user = ctx.params.user;
- page.redirect('/' + user + '/worlds/protos');
- }
- async HandleFileEdit(ctx) {
- console.log("USER WORLD FILE EDIT");
- let user = ctx.params.user;
- let worldName = ctx.params.name;
- let fileOriginal = ctx.params.file;
- let type = ctx.params.type;
- window._app.hideProgressBar();
- window._app.hideUIControl();
- _LCSDB.on('auth',
- async function (ack) {
- if (_LCSUSER.is) {
- if (_LCSUSER.is.alias == user) {
- var worldType = 'worlds';
- var file = fileOriginal;
- if (type == 'state') {
- worldType = 'documents';
- file = _app.helpers.replaceSubStringALL(fileOriginal, "~", '/');
- }
- let worldFile = await _LCSUSER.get(worldType).get(worldName).get(file).once().then();
- if (worldFile) {
- console.log(worldFile.file);
- let el = document.createElement("div");
- el.setAttribute("id", "worldFILE");
- document.body.appendChild(el);
- let aceEditorCell = {
- $type: "div",
- $components: [
- {
- class: "aceEditor",
- id: "aceEditor",
- //style: "width:1200px; height: 800px",
- $type: "div",
- $text: worldFile.file,
- $init: function () {
- var mode = "ace/mode/json";
- if (file.includes('_yaml'))
- mode = "ace/mode/yaml"
- if (file.includes('_js'))
- mode = "ace/mode/javascript"
- var editor = ace.edit("aceEditor");
- editor.setTheme("ace/theme/monokai");
- editor.setFontSize(16);
- editor.getSession().setMode(mode);
- editor.setOptions({
- maxLines: Infinity
- });
- }
- },
- {
- $type: "button",
- class: "mdc-button mdc-button--raised",
- $text: "Save",
- onclick: async function (e) {
- console.log("save new info");
- let editor = document.querySelector("#aceEditor").env.editor;
- let newInfo = editor.getValue();
- _LCSUSER.get(worldType).get(worldName).get(file).get('file').put(newInfo, res => {
- if (res) {
- let modified = new Date().valueOf();
- _LCSUSER.get(worldType).get(worldName).get(file).get('modified').put(modified);
- }
- })
- }
- },
- {
- $type: "button",
- class: "mdc-button mdc-button--raised",
- $text: "Close",
- onclick: function (e) {
- console.log("close");
- if (type == "proto")
- window.location.pathname = "/" + user + '/worlds/protos'
- if (type == "state")
- window.location.pathname = "/" + user + '/worlds/states'
- }
- }
- ]
- }
- document.querySelector("#worldFILE").$cell({
- $cell: true,
- $type: "div",
- $components: [aceEditorCell
- ]
- })
- }
- }
- }
- })
- }
- async HandleUserWorldsWithType(ctx) {
- console.log("USER WORLDS INDEX");
- console.log(ctx.params);
- let user = ctx.params.user;
- let type = ctx.params.type;
- window._app.hideProgressBar();
- window._app.hideUIControl();
- if (!_app.indexApp) {
- _app.indexApp = new IndexApp;
- document.querySelector('head').innerHTML += '<link rel="stylesheet" href="/web/index-app.css">';
- }
- if (!document.querySelector('#app')) {
- await _app.indexApp.initApp();
- }
- if (type == 'protos') {
- await _app.indexApp.getWorldsProtosFromUserDB(user);
- } else if (type == 'states') {
- await _app.indexApp.getWorldsFromUserDB(user);
- }
- }
- async HandleIndex() {
- console.log("INDEX");
- window._app.hideProgressBar();
- window._app.hideUIControl();
- _app.indexApp = new IndexApp;
- document.querySelector('head').innerHTML += '<link rel="stylesheet" href="/web/index-app.css">';
- await _app.indexApp.generateFrontPage();
- await _app.indexApp.initApp();
- await _app.indexApp.getAppDetailsFromDB();
- }
- HandleNoPage() {
- console.log("no such page")
- }
- //handle parcable requests
- HandleParsableLoadRequest(ctx) {
- let app = window._app;
- console.log(ctx.params);
- //var pathname = ctx.pathname;
- var spaceName = ctx.params.space;
- var saveName = ctx.params.savename;
- let user = ctx.params.user;
- page.redirect('/' + user + '/' + spaceName + '/' + app.helpers.GenerateInstanceID() + '/load/' + saveName);
- }
- HandleParsableLoadRequestWithRev(ctx) {
- let app = window._app;
- console.log(ctx.params);
- //var pathname = ctx.pathname;
- var spaceName = ctx.params.space;
- var saveName = ctx.params.savename;
- var rev = ctx.params.rev;
- let user = ctx.params.user;
- page.redirect('/' + user + '/' + spaceName + '/' + app.helpers.GenerateInstanceID() + '/load/' + saveName + '/' + rev);
- }
- async setUserPaths(user) {
- await _LCSDB.get('users').get(user).get('pub').once(res => {
- if (res)
- window._LCS_WORLD_USER = _LCSDB.user(res);
- }).then();
- }
- async HandleParsableRequestGenID(ctx) {
- let app = window._app;
- console.log(ctx.params);
- let user = ctx.params.user;
- var pathname = ctx.pathname;
- await app.setUserPaths(user);
- if (pathname[pathname.length - 1] == '/') {
- pathname = pathname.slice(0, -1)
- }
- let pathToParse = pathname.replace('/' + user, "");
- app.helpers.Process(pathToParse).then(parsedRequest => {
- localStorage.setItem('lcs_app', JSON.stringify({ path: parsedRequest }));
- console.log(parsedRequest);
- if ((parsedRequest['instance'] == undefined) && (parsedRequest['private_path'] == undefined) && (parsedRequest['public_path'] !== "/") && (parsedRequest['application'] !== undefined)) {
- page.redirect(pathname + '/' + app.helpers.GenerateInstanceID());
- }
- });
- }
-
- async HandleParsableRequestWithID(ctx) {
- let app = window._app;
- console.log(ctx.params);
- var pathname = ctx.pathname;
- let user = ctx.params.user;
- if (pathname[pathname.length - 1] == '/') {
- pathname = pathname.slice(0, -1)
- }
- await app.setUserPaths(user);
- let pathToParse = pathname.replace('/' + user, "");
- app.helpers.Process(pathToParse).then(parsedRequest => {
- localStorage.setItem('lcs_app', JSON.stringify({ path: parsedRequest }));
- console.log(parsedRequest);
- var userLibraries = { model: {}, view: {} };
- var application;
- vwf.loadConfiguration(application, userLibraries, compatibilityCheck);
- });
- }
- async HandleParsableRequest(ctx) {
- let app = window._app;
- console.log(ctx.params);
- var pathname = ctx.pathname;
- if (pathname[pathname.length - 1] == '/') {
- pathname = pathname.slice(0, -1)
- }
- var parsedRequest = await app.helpers.Process(pathname);
- localStorage.setItem('lcs_app', JSON.stringify({ path: parsedRequest }));
- console.log(parsedRequest);
- if ((parsedRequest['instance'] == undefined) && (parsedRequest['private_path'] == undefined) && (parsedRequest['public_path'] !== "/") && (parsedRequest['application'] !== undefined)) {
- // Redirect if the url request does not include an application/file && a default 'index.vwf.yaml' exists
- // page.redirect(pathname + '/' + app.helpers.GenerateInstanceID());
- window.location.pathname = pathname + '/' + app.helpers.GenerateInstanceID()
- //return true;
- } else {
- //return false;
- }
- var userLibraries = { model: {}, view: {} };
- var application;
- vwf.loadConfiguration(application, userLibraries, compatibilityCheck);
- }
- //get DB application state information for reflector (called from VWF)
- async getApplicationState() {
- let dataJson = JSON.parse(localStorage.getItem('lcs_app'));
- if (dataJson) {
- if (!dataJson.path['instance']) return undefined;
- }
- let userAlias = await _LCS_WORLD_USER.get('alias').once().then();
- let userPub = await _LCSDB.get('users').get(userAlias).get('pub').once().then();
- let loadInfo = await this.getLoadInformation(dataJson);
- let saveInfo = await this.loadSaveObject(loadInfo);
- let loadObj = {
- loadInfo: loadInfo,
- path: dataJson.path,
- saveObject: saveInfo,
- user: userAlias
- }
- console.log(loadObj);
- //temporary solution for syncing DB replicas using Gun.load()
- await _LCS_SYS_USER.get('proxy').load(res=>{}, {wait: 200}).then();
- await _LCSDB.user(userPub).get('worlds').get(loadObj.path.public_path.slice(1)).load(res=>{}, {wait: 200}).then();
- return loadObj
- }
- // LookupSaveRevisions takes the public path and the name of a save, and provides
- // an array of all revisions for that save. (If the save does not exist, this will be
- // an empty array).
- async lookupSaveRevisions(public_path, save_name) {
- var result = [];
- var states = [];
- let docName = 'savestate_/' + public_path + '/' + save_name + '_vwf_json';
- let revs = await _LCS_WORLD_USER.get('documents').get(public_path).get(docName).get('revs').once().then();
- if (revs) {
- for (const res of Object.keys(revs)) {
- if (res !== '_') {
- let el = await _LCS_WORLD_USER.get('documents').get(public_path).get(docName).get('revs').get(res).once().then();
- if (el)
- result.push(parseInt(el.revision));
- }
- }
- return result
- }
- }
- // GetLoadInformation receives a parsed request {private_path, public_path, instance, application} and returns the
- // details of the save that is designated by the initial request. The details are returned in an object
- // composed of: save_name (name of the save) save_revision (revision of the save), explicit_revision (boolean, true if the request
- // explicitly specified the revision, false if it did not), and application_path (the public_path of the application this is a save for).
- async getLoadInformation(response) {
- let parsedRequest = response.path;
- var result = { 'save_name': undefined, 'save_revision': undefined, 'explicit_revision': undefined, 'application_path': undefined };
- if (parsedRequest['private_path']) {
- var segments = this.helpers.GenerateSegments(parsedRequest['private_path']);
- if ((segments.length > 1) && (segments[0] == "load")) {
- var potentialRevisions = await this.lookupSaveRevisions((parsedRequest['public_path']).slice(1), segments[1]);
- console.log('!!!!! - ', potentialRevisions);
- if (potentialRevisions.length > 0) {
- result['save_name'] = segments[1];
- if (segments.length > 2) {
- var requestedRevision = parseInt(segments[2]);
- if (requestedRevision) {
- if (potentialRevisions.indexOf(requestedRevision) > -1) {
- result['save_revision'] = requestedRevision;
- result['explicit_revision'] = true;
- result['application_path'] = parsedRequest['public_path'];
- }
- }
- }
- if (result['explicit_revision'] == undefined) {
- result['explicit_revision'] = false;
- potentialRevisions.sort();
- result['save_revision'] = potentialRevisions.pop();
- result['application_path'] = parsedRequest['public_path'];
- }
- }
- }
- }
- return result;
- }
- async loadSaveObject(loadInfo) {
- //let objName = loadInfo[ 'save_name' ] +'/'+ "savestate_" + loadInfo[ 'save_revision' ];
- let objName = "savestate_" + loadInfo['application_path'] + '/' + loadInfo['save_name'] + '_vwf_json';
- let objNameRev = "savestate_" + loadInfo['save_revision'] + loadInfo['application_path'] + '/' + loadInfo['save_name'] + '_vwf_json';
- // if(loadInfo[ 'save_revision' ]){
- // }
- let worldName = this.helpers.appPath //loadInfo[ 'application_path' ].slice(1);
- let saveObject = await _LCS_WORLD_USER.get('documents').get(worldName).get(objName).get('revs').get(objNameRev).once().then();
- let saveInfo = saveObject ? JSON.parse(saveObject.jsonState) : saveObject;
- return saveInfo;
- }
- // GetSaveInformation is a helper function that takes the application_path (/path/to/application).
- // It returns an array of all saves found for that
- // application (including separate entries for individual revisions of saves ).
- async getSaveInformation(application_path, userPUB) {
- var result = [];
- let user = _LCSDB.user(userPUB);
- var docName = application_path.slice(1);
- let potentialSaveNames = await user.get('documents').get(docName).once().then();
- if (potentialSaveNames) {
- for (const res of Object.keys(potentialSaveNames)) {
- if (res !== '_') {
- let el = await user.get('documents').path(docName).get(res).once().then();
- let revisionList = await this.lookupSaveRevisions(application_path.slice(1), el.filename);
- var latestsave = true;
- revisionList.sort();
- while (revisionList.length > 0) {
- var newEntry = {};
- newEntry['applicationpath'] = application_path;
- newEntry['savename'] = el.filename;
- newEntry['revision'] = revisionList.pop().toString();
- newEntry['latestsave'] = latestsave;
- if (latestsave) {
- newEntry['url'] = this.helpers.JoinPath(window.location.origin, application_path, "load", el.filename + "/");
- }
- else {
- newEntry['url'] = this.helpers.JoinPath(window.location.origin, application_path, "load", el.filename + "/", newEntry['revision'] + "/");
- }
- latestsave = false;
- result.push(newEntry);
- }
- }
- }
- }
- return result;
- }
- async getProtoWorldFiles(userPub, worldName, date) {
- let fileNamesAll = await _LCSDB.user(userPub).get('worlds').get(worldName).once().then();
- let worldFileNames = Object.keys(fileNamesAll).filter(el => (el !== '_') && (el !== 'owner') && (el !== 'parent')
- && (el !== 'info_json'));
- let worldObj = {};
- for (var el in worldFileNames) {
- let fn = worldFileNames[el];
- let res = await _LCSDB.user(userPub).get('worlds').get(worldName).get(fn).once().then();
- var data = {
- 'file': res.file,
- 'modified': res.modified
- }
- if (!date) {
- data = {
- 'file': res.file
- }
- }
- worldObj[fn] = data;
- }
- console.log(worldObj);
- return worldObj
- }
- async cloneWorldPrototype(worldName, userName, newWorldName) {
- let userPub = await _LCSDB.get('users').get(userName).get('pub').once().then();
- //let worldProto = await _LCSDB.user(userPub).get('worlds').get(worldName).once().then();
- var worldID = window._app.helpers.GenerateInstanceID().toString();
- if (newWorldName) {
- worldID = newWorldName
- }
- //let modified = new Date().valueOf();
- console.log('clone: ' + worldName + 'to: ' + worldID);
- let newOwner = _LCSUSER.is.pub;
- let worldObj = {
- 'owner': newOwner,
- 'parent': userName + '/' + worldName
- };
- let fileNamesAll = await _LCSDB.user(userPub).get('worlds').get(worldName).once().then();
- let worldFileNames = Object.keys(fileNamesAll).filter(el => (el !== '_') && (el !== 'owner') && (el !== 'parent'));
- for (var el in worldFileNames) {
- let fn = worldFileNames[el];
- let res = await _LCSDB.user(userPub).get('worlds').get(worldName).get(fn).once().then();
- let data = {
- 'file': res.file,
- 'modified': res.modified
- }
- worldObj[fn] = data;
- }
- console.log(worldObj);
- Object.keys(worldObj).forEach(el => {
- _LCSUSER.get('worlds').get(worldID).get(el).put(worldObj[el]);
- })
- }
- async cloneWorldState(filename) {
- let myWorldProtos = await _LCSUSER.get('worlds').once().then();
- let userName = this.helpers.worldUser;
- let userPub = await _LCSDB.get('users').get(userName).get('pub').once().then();
- let protoUserRoot = this.helpers.getRoot(true).root;
- //let myName = _LCSUSER.is.alias;
- //let proto = Object.keys(myWorldProtos).filter(el => el == protoUserRoot);
- var protosKeys = [];
- if (myWorldProtos)
- protosKeys = Object.keys(myWorldProtos);
- if (protosKeys.includes(protoUserRoot)) {
- let userProtoFiles = await this.getProtoWorldFiles(userPub, protoUserRoot);
- let myProtoFiles = await this.getProtoWorldFiles(_LCSUSER.is.pub, protoUserRoot);
- let hashUP = await this.helpers.sha256(JSON.stringify(userProtoFiles));
- let hashMP = await this.helpers.sha256(JSON.stringify(myProtoFiles));
- if (hashUP == hashMP) {
- this.saveStateAsFile(filename);
- } else {
- let noty = new Noty({
- text: 'world prototype is modified.. could not clone world state',
- timeout: 2000,
- theme: 'mint',
- layout: 'bottomRight',
- type: 'error'
- });
- noty.show();
- }
- } else {
- await this.cloneWorldPrototype(protoUserRoot, userName, protoUserRoot);
- this.saveStateAsFile(filename);
- }
- }
- //TODO: refactor and config save
- saveStateAsFile(filename, otherProto) // invoke with the view as "this"
- {
- console.log("Saving: " + filename);
- //var clients = this.nodes["http://vwf.example.com/clients.vwf"];
- // Save State Information
- var state = vwf.getState();
- state.nodes[0].children = {};
- var timestamp = state["queue"].time;
- timestamp = Math.round(timestamp * 1000);
- var objectIsTypedArray = function (candidate) {
- var typedArrayTypes = [
- Int8Array,
- Uint8Array,
- // Uint8ClampedArray,
- Int16Array,
- Uint16Array,
- Int32Array,
- Uint32Array,
- Float32Array,
- Float64Array
- ];
- var isTypedArray = false;
- if (typeof candidate == "object" && candidate != null) {
- typedArrayTypes.forEach(function (typedArrayType) {
- isTypedArray = isTypedArray || candidate instanceof typedArrayType;
- });
- }
- return isTypedArray;
- };
- var transitTransformation = function (object) {
- return objectIsTypedArray(object) ?
- Array.prototype.slice.call(object) : object;
- };
- let jsonValuePure = require("vwf/utility").transform(
- state, transitTransformation
- );
- //remove all Ohm generated grammarsfrom state
- let jsonValue = _app.helpers.removeGrammarObj(jsonValuePure);
- var jsonState = JSON.stringify(jsonValue);
- let rootPath = this.helpers.getRoot(true);
- var inst = rootPath.inst;
- if (filename == '') filename = inst;
- //if (root.indexOf('.vwf') != -1) root = root.substring(0, root.lastIndexOf('/'));
- var root = rootPath.root;
- var json = jsonState;
- if (otherProto) {
- console.log('need to modify state...');
- json = this.helpers.replaceSubStringALL(jsonState, '/' + root + '/', '/' + otherProto + '/');//jsonState.replace(('/' + root + '/'), ('/' + otherProto +'/') );
- root = otherProto;
- console.log(json);
- }
- //var documents = _LCSUSER.get('documents');
- var saveRevision = new Date().valueOf();
- var stateForStore = {
- "root": root,
- "filename": filename,
- "inst": inst,
- "timestamp": timestamp,
- "extension": ".vwf.json",
- "jsonState": json,
- "publish": true
- };
- //let objName = loadInfo[ 'save_name' ] +'/'+ "savestate_" + loadInfo[ 'save_revision' ];
- // "savestate_" + loadInfo[ 'save_revision' ] + '/' + loadInfo[ 'save_name' ] + '_vwf_json'
- var docName = 'savestate_/' + root + '/' + filename + '_vwf_json';
- _LCSUSER.get('documents').get(root).get(docName).put(stateForStore, res => {
- if (res) {
- let noty = new Noty({
- text: 'Saved to ' + docName,
- timeout: 2000,
- theme: 'mint',
- layout: 'bottomRight',
- type: 'success'
- });
- noty.show();
- }
- });
- _LCSUSER.get('worlds').get(root).get('info_json').once(res => {
- if (res) {
- let modified = new Date().valueOf();
- let newOwner = _LCSUSER.is.pub;
- let userName = _LCSUSER.is.alias;
- let obj = {
- 'parent': userName + '/' + root,
- 'owner': newOwner,
- 'file': res.file,
- 'modified': modified
- }
- let docInfoName = 'savestate_/' + root + '/' + filename + '_info_vwf_json';
- _LCSUSER.get('documents').get(root).get(docInfoName).not(res => {
- _LCSUSER.get('documents').get(root).get(docInfoName).put(obj);
- });
- }
- });
- var docNameRev = 'savestate_' + saveRevision.toString() + '/' + root + '/' + filename + '_vwf_json';
- _LCSUSER.get('documents').get(root).get(docName).get('revs').get(docNameRev).put(stateForStore)
- .path("revision").put(saveRevision);
- // Save Config Information
- var config = { "info": {}, "model": {}, "view": {} };
- // Save browser title
- config["info"]["title"] = document.title//$('title').html();
- // Save model drivers
- Object.keys(vwf_view.kernel.kernel.models).forEach(function (modelDriver) {
- if (modelDriver.indexOf('vwf/model/') != -1) config["model"][modelDriver] = "";
- });
- // If neither glge or threejs model drivers are defined, specify nodriver
- if (config["model"]["vwf/model/glge"] === undefined && config["model"]["vwf/model/threejs"] === undefined) config["model"]["nodriver"] = "";
- // Save view drivers and associated parameters, if any
- Object.keys(vwf_view.kernel.kernel.views).forEach(function (viewDriver) {
- if (viewDriver.indexOf('vwf/view/') != -1) {
- if (vwf_view.kernel.kernel.views[viewDriver].parameters) {
- config["view"][viewDriver] = vwf_view.kernel.kernel.views[viewDriver].parameters;
- }
- else config["view"][viewDriver] = "";
- }
- });
- //var jsonConfig = $.encoder.encodeForURL(JSON.stringify(config));
- var jsonConfig = JSON.stringify(config);
- let configStateForStore = {
- "root": root,
- "filename": filename,
- "inst": inst,
- "timestamp": timestamp,
- "extension": "config.vwf.json",
- "jsonState": jsonConfig
- };
- //let objName = loadInfo[ 'save_name' ] +'/'+ "savestate_" + loadInfo[ 'save_revision' ];
- // "savestate_" + loadInfo[ 'save_revision' ] + '/' + loadInfo[ 'save_name' ] + '_vwf_json'
- // let configName = 'savestate_/' + root + '/' + filename + '_config_vwf_json';
- // let documentSaveConfigState = _LCSUSER.get(configName).put(configStateForStore);
- // //documents.path(root).set(documentSaveConfigState);
- // let configNameRev = 'savestate_' + saveRevision.toString() + '/' + root + '/' + filename + '_config_vwf_json';
- // _LCSUSER.get(configNameRev).put(configStateForStore);
- // _LCSUSER.get(configNameRev).path("revision").put(saveRevision);
- //documentSaveConfigState.path('revs').set(documentSaveStateRevision);
- // Save config file to server
- // var xhrConfig = new XMLHttpRequest();
- // xhrConfig.open("POST", "/" + root + "/save/" + filename, true);
- // xhrConfig.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
- // xhrConfig.send("root=" + root + "/" + filename + "&filename=saveState&inst=" + inst + "×tamp=" + timestamp + "&extension=.vwf.config.json" + "&jsonState=" + jsonConfig);
- }
- // LoadSavedState
- async loadSavedState(filename, applicationpath, revision) {
- console.log("Loading: " + filename);
- let userName = await _LCS_WORLD_USER.get('alias').once().then();
- if (revision) {
- window.location.pathname = '/' + userName + applicationpath + '/load/' + filename + '/' + revision + '/';
- }
- else { // applicationpath + "/" + inst + '/load/' + filename + '/';
- window.location.pathname = '/' + userName + applicationpath + '/load/' + filename + '/';
- }
- }
- hideUIControl() {
- var el = document.getElementById("ui-controls");
- if (el) {
- el.classList.remove("visible");
- el.classList.add("not-visible");
- }
- }
- showUIControl() {
- var el = document.getElementById("ui-controls");
- if (el) {
- el.classList.remove("not-visible");
- el.classList.add("visible");
- }
- }
- hideProgressBar() {
- var progressbar = document.getElementById("load-progressbar");
- if (progressbar) {
- progressbar.classList.remove("visible");
- progressbar.classList.add("not-visible");
- progressbar.classList.add("mdc-linear-progress--closed");
- }
- }
- showProgressBar() {
- let progressbar = document.getElementById("load-progressbar");
- if (progressbar) {
- progressbar.classList.add("visible");
- progressbar.classList.add("mdc-linear-progress--indeterminate");
- }
- }
- }
- export { App }
|