Compare commits
4 Commits
pull-to-va
...
master
| Author | SHA1 | Date |
|---|---|---|
 Fabien Benetou
|
334f9c56c4 | 10 months ago |
|
Fabien Benetou
|
819b71534f | 10 months ago |
|
Fabien Benetou
|
9b728c8210 | 10 months ago |
|
Fabien Benetou
|
18d0bd4f02 | 2 years ago |
File diff suppressed because it is too large
Load Diff
@ -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) |
|
||||||
); |
|
||||||
Loading…
Reference in new issue