log.js

const bunyan = require('bunyan')
const prettyStream = require('bunyan-prettystream')

const stream = require('stream')
const fetch = require('node-fetch')

const out_pretty = new prettyStream
out_pretty.pipe(process.stdout)

const remote_url = "http://45.55.38.183:4002/log"

// Utility function, returns a promise that 
// resolves after the given number of seconds
const pause = function(duration) {
	return new Promise(function(resolve, reject){
		setTimeout(resolve, duration * 1000)
	})
}

// Sends a post request to the remote_url with the given data
const write_remote = async function(event, data){
	const request = fetch(remote_url, {
			headers: {
				'Accept': 'application/json',
				'Content-Type': 'application/json'
			},
			method: "POST",
			body: JSON.stringify({ 
				event: event,
				data: data,
				sender: "(N)EAL" 
			})
		}).catch(err => console.log('heartbeat failed to send'))

	await request
}

const begin_heartbeat = async function(period){
	while(true){
		await pause(period)
		console.log("sending heartbeat")
		await write_remote('HEARTBEAT')
	}
}

const remote = new stream.Writable({
	write: async function(chunk, encoding, next){
		fetch(remote_url, {
			headers: {
				'Accept': 'application/json',
				'Content-Type': 'application/json'
			},
			method: "POST",
			body: JSON.stringify({ 
				event: "LOG",
				data: chunk.toString('utf8'),
				sender: "(N)EAL" 
			})
		}).catch(err => {})
		next()
	}
})

const log = bunyan.createLogger({
	name: "neal",
	streams: [
	{
		level: 'debug',
		type: 'raw',
		stream: out_pretty
	},
	{
		level: 'info',
		type: 'stream',
		stream: remote
	}
	]
})

begin_heartbeat(5);
module.exports = log