Skip to content

Instantly share code, notes, and snippets.

@nLight
Last active August 3, 2018 20:11
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save nLight/d44bde6ae8dba933275de6215de1722b to your computer and use it in GitHub Desktop.
Save nLight/d44bde6ae8dba933275de6215de1722b to your computer and use it in GitHub Desktop.
Mesos stream replay server
const http = require('http')
const port = 3000
var fs = require('fs');
const requestHandler = (request, response) => {
console.log("Connected")
response.setHeader("Access-Control-Allow-Origin", "*")
response.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept")
request.on("close", function() {
console.log("request closed unexpectedly");
})
request.on("end", function() {
console.log("request ended normally");
})
fs.readFile(process.argv[2], 'utf8', function(err, contents) {
if (err) console.log(err)
response.write(contents.substr(0, contents.length - 1))
setInterval(function() {
console.log("heartbeat")
response.write("20\n{type:\"HEARTBEAT\"}")
}, 10000)
})
}
const server = http.createServer(requestHandler)
server.listen(port, (err) => {
if (err) {
return console.log('something bad happened', err)
}
console.log(`server is listening on ${port}`)
})
if (!process.argv[2]) {
console.log("Usage: node stream.js <stream_log.json>");
exit();
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment