Compare commits
121 Commits
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,144 @@ |
||||
/* 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