node-unix-socket

import { SeqpacketServer, SeqpacketSocket } from 'node-unix-socket'; import os from 'os'; import path from 'path'; import fs from 'fs'; const bindPath = path.resolve(os.tmpdir(), './my_seqpacket.sock'); // Ensure the socket file does not exist from previous runs try { fs.unlinkSync(bindPath); } catch (e) { // Ignore if file does not exist } // Create and start a Seqpacket server const server = new SeqpacketServer(); server.listen(bindPath); server.on('connection', (socket) => { console.log('Server: Client connected'); socket.on('data', (buf) => { console.log('Server: received', buf.toString()); }); socket.on('end', () => { console.log('Server: Client disconnected'); }); }); server.on('listening', () => { console.log(`Server listening on ${bindPath}`); }); server.on('error', (err) => { console.error('Server error:', err); }); // Create and connect a Seqpacket client const client = new SeqpacketSocket(); client.connect(bindPath, () => { console.log('Client: Connected to server'); const data = ['hello, ', 'w', 'o', 'r', 'l', 'd']; for (const str of data) { client.write(Buffer.from(str)); console.log(`Client: Sent '${str}'`); } client.end(() => { console.log('Client: Disconnected, closing server in 1 sec...'); setTimeout(() => server.close(), 1000); }); }); client.on('error', (err) => { console.error('Client error:', err); server.close(); // Ensure server closes on client error }); // Clean up on process exit process.on('exit', () => { try { fs.unlinkSync(bindPath); console.log('Cleaned up socket file.'); } catch (e) { // Ignore if file already removed or never created } });