feat: add add_line_processor, aka line_socket.setup_line_processor

CHANGELOG.md

@@ -7,9 +7,10 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/).
 ### [1.7.0] - 2024-04-29
 
 - feat: added HarakaMx #89
+- feat: add add_line_processor, aka line_socket.setup_line_processor
+- fix(get_public_ip): set timeout in stun request, fixes #84
 - test: added get_implicit_mx tests #89
 - change: get_mx: don't filter implicit MX errors #89
-- fix(get_public_ip): set timeout in stun request, fixes #84
 
 ### [1.6.0] - 2024-04-17
 

index.js

@@ -363,3 +363,25 @@ exports.get_public_ip = require('./lib/get_public_ip').get_public_ip
 exports.get_public_ip_async = require('./lib/get_public_ip').get_public_ip_async
 
 exports.HarakaMx = require('./lib/HarakaMx')
+
+exports.add_line_processor = (socket) => {
+    const line_regexp = /^([^\n]*\n)/; // utils.line_regexp
+    let current_data = '';
+
+    socket.on('data', (data) => {
+        current_data += data;
+        let results;
+        while ((results = line_regexp.exec(current_data))) {
+            const this_line = results[1];
+            current_data = current_data.slice(this_line.length);
+            socket.emit('line', this_line);
+        }
+    })
+
+    socket.on('end', () => {
+        if (current_data.length) {
+            socket.emit('line', current_data);
+        }
+        current_data = '';
+    })
+}