import { Unix_Socket } from './unix-socket.mjs';
import readline from 'node:readline';
import net from 'node:net';
import fs from 'node:fs';

const listening_socket = new Unix_Socket('./logrelay.sock');

const server = net.createServer((socket) => {

	console.log("socket connected");

	const rli = readline.createInterface({
		input: socket,
		crlfDelay: Infinity
	});

	rli.on('line', (line) => {
		console.log({ line });
	});

	socket.on('close', () => {
		console.log("socket closed");
	});

	socket.on('error', (err) => {
		console.log("socket error", { err });
	});

});


server.on('error', (err) => {
	console.log("server error", { err });
});

listening_socket.listen(server);