parent
cc36b10d50
commit
0bbe99c2fa
@ -1,144 +0,0 @@ |
||||
/* nodejs server to grab the current URL as tridactyl command and serve back page with content */ |
||||
|
||||
// mkdir tabs polydata
|
||||
|
||||
// autocmd TabEnter .* js fetch("http://localhost:7777/?url="+window.location.href)
|
||||
// might be interesting to keep track of document.referrer too
|
||||
// consider instead Firefox Account
|
||||
|
||||
const fs = require('fs'); |
||||
const express = require('express') |
||||
const cors = require('cors') |
||||
const https = require('https') |
||||
const path = require('path') |
||||
const {execSync} = require('child_process'); |
||||
const fetch = require('node-fetch'); |
||||
|
||||
const app = express() |
||||
app.use(cors()) |
||||
|
||||
app.get('/getpoly', function(req, res){ |
||||
const polypath = "polydata" |
||||
const url = "https://static.poly.pizza/" |
||||
const extensions = [".glb",".webp"] |
||||
const filepath = path.join(__dirname, polypath, req.query.id+extensions[0]) |
||||
if (!fs.existsSync(filepath)){ |
||||
execSync("wget "+url+req.query.id+extensions[0], {cwd:path.join(__dirname,polypath)}) |
||||
execSync("wget "+url+req.query.id+extensions[1], {cwd:path.join(__dirname,polypath)}) |
||||
} |
||||
res.send("received"); |
||||
}); |
||||
|
||||
app.get('/voiceinput', function(req, res){ |
||||
console.log(req.query.keyword) |
||||
sseSend(req.query.keyword) |
||||
res.send("received"); |
||||
}); |
||||
|
||||
app.get('/search', async function(req, res){ |
||||
const response = await fetch('https://api.poly.pizza/v1/search/'+req.query.keyword, { |
||||
headers: {'x-auth-token': 'e821ece91d1a43c1ac70299368a72b8a'} |
||||
}); |
||||
const data = await response.json(); |
||||
|
||||
res.json(data); |
||||
}); |
||||
|
||||
app.get('/cabin', function(req, res){ |
||||
res.sendFile(path.join(__dirname, 'cabin.html')) |
||||
}); |
||||
|
||||
app.get('/', function(req, res){ |
||||
res.sendFile(path.join(__dirname, 'index.html')) |
||||
}); |
||||
|
||||
app.get('/tabs', function(req, res){ |
||||
res.json({"files":fs.readdirSync("tabs")}) |
||||
}); |
||||
|
||||
// resulting in possibly getting /static/screens/1652811988.png
|
||||
app.get('/screens', function(req, res){ |
||||
res.json({"files":fs.readdirSync("screens")}) |
||||
}); |
||||
|
||||
const container = "docker run --rm -e UID=$(id -u) -e GID=$(id -g) " |
||||
// could try losing priviledges instead, if possible
|
||||
fs.watch("cabin.html", (eventType, filename) => { |
||||
if (eventType == "change") sseSend(filename+" modified") |
||||
}) |
||||
|
||||
|
||||
// SSE to force reload client-side
|
||||
var connectedClients = [] |
||||
function sseSend(data){ |
||||
connectedClients.map( res => { |
||||
console.log("notifying client") // seems to be call very often (might try to send to closed clients?)
|
||||
res.write(`data: ${JSON.stringify({status: data})}\n\n`); |
||||
}) |
||||
} |
||||
|
||||
app.get('/streaming', (req, res) => { |
||||
res.setHeader('Cache-Control', 'no-cache'); |
||||
res.setHeader('Content-Type', 'text/event-stream'); |
||||
//res.setHeader('Access-Control-Allow-Origin', '*');
|
||||
// alread handled at the nginx level
|
||||
res.setHeader('Connection', 'keep-alive'); |
||||
res.setHeader('X-Accel-Buffering', 'no'); |
||||
res.flushHeaders(); // flush the headers to establish SSE with client
|
||||
|
||||
res.write(`data: ${JSON.stringify({event: "userconnect"})}\n\n`); // res.write() instead of res.send()
|
||||
connectedClients.push(res) |
||||
|
||||
// If client closes connection, stop sending events
|
||||
res.on('close', () => { |
||||
console.log('client dropped me'); |
||||
res.end(); |
||||
}); |
||||
}); |
||||
|
||||
// consider instead CloudInit so that it can be delegated to another machine
|
||||
// keeping a pool of available machine would start with a single one
|
||||
// namely that it is possible to run multiple containers on 1 instance, simultaneously or not.
|
||||
containersSupportedByLanguage = { |
||||
bash: "debian ",
|
||||
julia: "julia julia -E ", |
||||
python: "python python -c ", |
||||
// avoided file specific languages
|
||||
// could be done by writing to a file in the container e.g /tmp/file.c then passing it as parameter
|
||||
} |
||||
|
||||
|
||||
app.get('/invitereload', function(req, res){ |
||||
sseSend("reload") |
||||
res.json({"res":"reload requested"}) |
||||
}) |
||||
|
||||
app.get('/command', function(req, res){ |
||||
var req = req.query.command |
||||
var foundContainer = containersSupportedByLanguage[req.split(" ")[0]] |
||||
var code = req.split(" ").slice(1).join(" ") |
||||
if (foundContainer) |
||||
res.json({"res":execSync(container+foundContainer+code).toString()}) |
||||
else |
||||
res.json({"res":"language not supported"}) |
||||
}); |
||||
// could specify name, it then contiue instance
|
||||
|
||||
// ~/.openai-codex-test-xr
|
||||
// potential alt backend to generate
|
||||
|
||||
app.get('/currenturl', function(req, res){ |
||||
// could instead be the webxr page
|
||||
let now = + new Date() |
||||
fs.appendFile('currentURL.txt', now+" "+req.query.url+" "+req.query.referrer+"\n", function (err) { if (err) throw err; }); |
||||
// could be JSON instead
|
||||
res.json({"status":"test"}) |
||||
}); |
||||
|
||||
app.use('/static', express.static(path.join(__dirname, '.'))) |
||||
// including currentURL.txt
|
||||
|
||||
const port = 7777 |
||||
app.listen(port, () => |
||||
console.log('listening on port', port) |
||||
); |
||||
@ -1,83 +0,0 @@ |
||||
<html> |
||||
<head> |
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0"> |
||||
</head> |
||||
<body> |
||||
Send text and commands to the immersive space : |
||||
<form> |
||||
<textarea rows="5" cols="33"> |
||||
</textarea> |
||||
<br> |
||||
<input type=button onclick=replaceWithThisText(this) value=Clear></input> |
||||
<input type=button onclick=sendtovr(this) value=Send></input> |
||||
</form> |
||||
<br> |
||||
Examples, tap to add, optionally modify and send : |
||||
<ul> |
||||
<li><a onclick=replaceWithThisText(this)>jxr qs a-sphere sa color green</a></li> |
||||
<li><a onclick=replaceWithThisText(this)>jxr toggleVisibilityEntitiesFromClass('fot')</a></li> |
||||
</ul> |
||||
|
||||
Share this URL to the browser using e.g <a id="shareablelink" href="https://hmd.link">hmd.link</a> on the same WiFi network. |
||||
<hr> |
||||
<iframe width="100%" id="pastcommands"></iframe> |
||||
<hr> |
||||
Remote preview, if available :<br/> |
||||
<img height="400px" id="remotepreview" /> |
||||
<hr> |
||||
<br> |
||||
Documentation as : |
||||
|
||||
<ul> |
||||
<li><a href=https://fabien.benetou.fr/PIMVRdata/FoT>what has already been added by others</a> in a PIM as a wiki (also editable),</li> |
||||
<li><a href=https://fabien.benetou.fr/PIMVRdata/CabinCommands?action=source>example of instructions and commands already positioned</a>,</li> |
||||
<li><a href=https://fabien.benetou.fr/pub/home/future_of_text_demo/engine/>live result</a> (ideally in VR) and</li> |
||||
<li>open-source <a href=https://git.benetou.fr/utopiah/text-code-xr-engine/issues>code repository</a> of the code and to make your own suggestions via issues. </li> |
||||
<li><a href=qrcode.png>QRcode</a> of this page to share with others also on mobile.</li> |
||||
<li><a href=https://fabien.benetou.fr/pub/home/future_of_text_demo/engine/?background=../content/future_of_text_symposium/HORN-2001-FutureOfHumanCognomeCL.png&fontcolor=lightgray>background</a> as URL parameter. Feel free to use your own content.</li> |
||||
<li>to create a room to work together in, add or change the ?roomname=<b>YourRoomName</b> in the browser URL |
||||
</ul> |
||||
|
||||
<script> |
||||
function replaceWithThisText(element){ |
||||
document.querySelector("textarea").value = element.innerText |
||||
} |
||||
|
||||
let pagename |
||||
const queryString = window.location.search |
||||
const urlParams = new URLSearchParams(queryString) |
||||
let = forcedPagename = urlParams.get('roomname') |
||||
forcedPagename?pagename=forcedPagename:pagename='FoT' |
||||
|
||||
const baseURL = 'https://fabien.benetou.fr/PIMVRdata/'+pagename |
||||
const url = baseURL+'?action=' |
||||
|
||||
document.getElementById("pastcommands").src = baseURL+'?action=source' |
||||
document.getElementById("shareablelink").href = "https://hmd.link/?https://fabien.benetou.fr/pub/home/future_of_text_demo/engine/?roomname="+pagename |
||||
|
||||
function refreshPreview(){ |
||||
document.getElementById("remotepreview").src = "https://fabien.benetou.fr/uploads/PIMVRdata/"+pagename+".jpg#"+Date.now() |
||||
} |
||||
|
||||
// seems to get cached properly, i.e only transferring when update |
||||
setInterval( _ => refreshPreview(), 1000) |
||||
|
||||
function sendtovr(cabin){ |
||||
text = document.querySelector("textarea").value |
||||
document.querySelector("textarea").value = '' |
||||
|
||||
if (text) fetch(url+'source') |
||||
.then( response => { return response.text() } ) |
||||
.then( data => { |
||||
|
||||
fetch(url+'edit', { |
||||
method: 'POST', |
||||
headers: {'Content-Type':'application/x-www-form-urlencoded'}, |
||||
body: "post=1&author=PIMVR&authpw=edit_password&text="+ data+'%0a'+text }).then(res => res).then(res => console.log("saved remotely", res)) |
||||
}) |
||||
else alert("empty text, please write something and try again") |
||||
} |
||||
|
||||
</script> |
||||
</body> |
||||
</html> |
||||
Loading…
Reference in new issue