19ee6ba0a1
- Implemented German and English localization for password reset functionality. - Added WebSocket URL resolution logic in chat services to support various environments and configurations. - Created centralized chat configuration for event keys and payload mappings. - Developed RoomsView component for admin chat room management, including create, edit, and delete functionalities.
308 lines
11 KiB
JavaScript
308 lines
11 KiB
JavaScript
import net from 'net';
|
|
import fs from 'fs';
|
|
import path from 'path';
|
|
|
|
const DEFAULT_CONFIG = { host: 'localhost', port: 1235 };
|
|
|
|
function loadBridgeConfig() {
|
|
try {
|
|
const cfgPath = path.resolve(process.cwd(), 'backend/config/chatBridge.json');
|
|
if (fs.existsSync(cfgPath)) {
|
|
const raw = fs.readFileSync(cfgPath, 'utf-8');
|
|
const json = JSON.parse(raw);
|
|
return { ...DEFAULT_CONFIG, ...json };
|
|
}
|
|
} catch (e) {
|
|
console.warn('Failed to load chatBridge.json, using defaults:', e.message);
|
|
}
|
|
return { ...DEFAULT_CONFIG };
|
|
}
|
|
|
|
export default class ChatTcpBridge {
|
|
constructor(ioSocket, user) {
|
|
this.ioSocket = ioSocket;
|
|
this.user = user || {};
|
|
this.token = null;
|
|
this.tcp = null;
|
|
this.buffer = '';
|
|
this.config = loadBridgeConfig();
|
|
this.pending = [];
|
|
this.objStart = -1;
|
|
this.depthCurly = 0;
|
|
this.depthSquare = 0;
|
|
this.inString = false;
|
|
this.escapeNext = false;
|
|
}
|
|
|
|
connect(initialRoomName = '') {
|
|
if (this.tcp) return;
|
|
const { host, port } = this.config;
|
|
|
|
this.ioEmitStatus('connecting', `${host}:${port}`);
|
|
console.log(`[ChatBridge] Connecting to ${host}:${port}`);
|
|
this.tcp = new net.Socket();
|
|
|
|
this.tcp.on('connect', () => {
|
|
this.ioEmitStatus('connected', `${host}:${port}`);
|
|
console.log(`[ChatBridge] Connected to ${host}:${port}`);
|
|
// Erstnachricht: init
|
|
const initPayload = {
|
|
type: 'init',
|
|
name: this.user.username || '',
|
|
room: initialRoomName || '',
|
|
};
|
|
this.sendRaw(initPayload);
|
|
});
|
|
|
|
this.tcp.on('data', (data) => {
|
|
this.processChunk(data.toString('utf-8'));
|
|
});
|
|
|
|
this.tcp.on('error', (err) => {
|
|
this.ioEmitStatus('error', err.message);
|
|
console.error('[ChatBridge] Error:', err.message);
|
|
});
|
|
|
|
this.tcp.on('close', () => {
|
|
this.ioEmitStatus('disconnected');
|
|
console.warn('[ChatBridge] Disconnected');
|
|
});
|
|
|
|
this.tcp.connect(port, host);
|
|
}
|
|
|
|
handleIncomingLine(line) {
|
|
try {
|
|
const obj = JSON.parse(line);
|
|
this.handleIncoming(obj);
|
|
} catch (e) {
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: line });
|
|
}
|
|
}
|
|
|
|
processChunk(chunk) {
|
|
if (!chunk) return;
|
|
for (let i = 0; i < chunk.length; i++) {
|
|
const ch = chunk[i];
|
|
this.buffer += ch;
|
|
if (this.escapeNext) {
|
|
this.escapeNext = false;
|
|
continue;
|
|
}
|
|
if (this.inString) {
|
|
if (ch === '\\') { this.escapeNext = true; }
|
|
else if (ch === '"') { this.inString = false; }
|
|
continue;
|
|
}
|
|
if (ch === '"') { this.inString = true; continue; }
|
|
if (ch === '{') { this.depthCurly++; if (this.objStart === -1) this.objStart = this.buffer.length - 1; }
|
|
else if (ch === '}') { this.depthCurly--; }
|
|
else if (ch === '[') { this.depthSquare++; }
|
|
else if (ch === ']') { this.depthSquare--; }
|
|
|
|
// Wenn ein komplettes Objekt abgeschlossen ist (außerhalb von Strings und beide Tiefen 0)
|
|
if (this.objStart !== -1 && this.depthCurly === 0) {
|
|
const jsonStr = this.buffer.slice(this.objStart, this.buffer.length);
|
|
// Alles vor objStart (falls vorhanden) rausfiltern
|
|
const prefix = this.buffer.slice(0, this.objStart);
|
|
if (prefix.trim()) {
|
|
// Unerwarteter Text, als System ausgeben
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: prefix.trim() });
|
|
}
|
|
this.buffer = '';
|
|
this.objStart = -1;
|
|
this.parseAndHandle(jsonStr);
|
|
}
|
|
}
|
|
}
|
|
|
|
parseAndHandle(jsonStr) {
|
|
try {
|
|
const obj = JSON.parse(jsonStr);
|
|
// Forward raw parsed inbound message to browser console
|
|
this.ioSocket.emit('chat:debug', { dir: 'in', payload: obj });
|
|
this.handleIncoming(obj);
|
|
} catch (e) {
|
|
// Wenn mehrere Objekte direkt aneinander hängen (}{), versuchen sie zu splitten
|
|
const parts = jsonStr.split('}{').map((p, idx, arr) => (idx === 0 ? p + '}' : (idx === arr.length - 1 ? '{' + p : '{' + p + '}')));
|
|
if (parts.length > 1) {
|
|
parts.forEach(p => {
|
|
try {
|
|
const o = JSON.parse(p);
|
|
this.ioSocket.emit('chat:debug', { dir: 'in', payload: o });
|
|
this.handleIncoming(o);
|
|
} catch (_) {
|
|
this.ioSocket.emit('chat:debug', { dir: 'in', raw: p });
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: p });
|
|
}
|
|
});
|
|
} else {
|
|
this.ioSocket.emit('chat:debug', { dir: 'in', raw: jsonStr });
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: jsonStr });
|
|
}
|
|
}
|
|
}
|
|
|
|
handleIncoming(obj) {
|
|
if (!obj) return;
|
|
// Map numeric type codes
|
|
if (typeof obj.type === 'number') {
|
|
switch (obj.type) {
|
|
case 1: // token
|
|
if (typeof obj.message === 'string' && obj.message) {
|
|
this.token = obj.message;
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: 'Token received' });
|
|
const actions = this.pending; this.pending = [];
|
|
actions.forEach(fn => { try { fn(); } catch (_) { } });
|
|
return;
|
|
}
|
|
break;
|
|
case 3: // room list
|
|
if (Array.isArray(obj.message)) {
|
|
const names = obj.message.map(r => r.name).filter(Boolean).join(', ');
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: names ? `Rooms: ${names}` : 'Rooms updated' });
|
|
return;
|
|
}
|
|
break;
|
|
case 5: {
|
|
// generic server event (room entered, color changes, etc.)
|
|
const msg = obj.message;
|
|
if (!msg) break;
|
|
if (typeof msg === 'string') {
|
|
if (msg === 'room_entered') {
|
|
const to = obj.to || obj.name || obj.room || '';
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', code: 'room_entered', tr: 'room_entered', to });
|
|
return;
|
|
}
|
|
if (msg === 'color_changed' || msg === 'user_color_changed') {
|
|
this.ioSocket.emit('chat:incoming', {
|
|
type: 'system',
|
|
code: msg,
|
|
color: obj.color,
|
|
userName: obj.userName || ''
|
|
});
|
|
return;
|
|
}
|
|
// unknown message string; fallthrough to text echo
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: msg });
|
|
return;
|
|
}
|
|
if (typeof msg === 'object') {
|
|
const tr = msg.tr || 'room_entered';
|
|
const to = msg.to || msg.name || msg.room || '';
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', code: tr, tr, to });
|
|
return;
|
|
}
|
|
break;
|
|
}
|
|
case 6: {
|
|
// scream
|
|
const userName = obj.userName || obj.user || obj.name || '';
|
|
const message = obj.message || '';
|
|
this.ioSocket.emit('chat:incoming', {
|
|
type: 'scream',
|
|
userName,
|
|
message,
|
|
color: obj.color || null
|
|
});
|
|
return;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
if (obj.type === 'token' && obj.message) {
|
|
this.token = obj.message;
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: 'Token received' });
|
|
// Ausstehende Aktionen jetzt mit Token senden
|
|
const actions = this.pending;
|
|
this.pending = [];
|
|
actions.forEach(fn => {
|
|
try { fn(); } catch (_) { }
|
|
});
|
|
return;
|
|
}
|
|
// Normalize generic messages
|
|
if (typeof obj.message === 'string' && obj.message && (obj.userName || obj.user || obj.name)) {
|
|
this.ioSocket.emit('chat:incoming', {
|
|
type: 'message',
|
|
message: obj.message,
|
|
userName: obj.userName || obj.user || obj.name,
|
|
color: obj.color || null
|
|
});
|
|
return;
|
|
}
|
|
// As system fallback
|
|
this.ioSocket.emit('chat:incoming', { type: 'system', text: JSON.stringify(obj) });
|
|
}
|
|
|
|
sendRaw(obj) {
|
|
if (!this.tcp) return;
|
|
try {
|
|
const str = JSON.stringify(obj) + '\n';
|
|
// Forward outbound payload to browser console
|
|
this.ioSocket.emit('chat:debug', { dir: 'out', payload: obj });
|
|
this.tcp.write(str);
|
|
} catch (e) {
|
|
this.ioEmitStatus('error', e.message);
|
|
}
|
|
}
|
|
|
|
sendWithToken(obj) {
|
|
if (this.token) obj.token = this.token;
|
|
this.sendRaw(obj);
|
|
}
|
|
|
|
withTokenOrQueue(fn) {
|
|
if (this.token) {
|
|
fn();
|
|
} else {
|
|
this.pending.push(fn);
|
|
}
|
|
}
|
|
|
|
joinRoom(roomName, password = '') {
|
|
// Prefer keys name/room if server expects them for room switch; fallback to newroom if required elsewhere
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'join', room: roomName, name: this.user.username || '', password }));
|
|
}
|
|
|
|
sendMessage(text) {
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'message', message: text, userName: this.user.username }));
|
|
}
|
|
|
|
scream(text) {
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'scream', message: text }));
|
|
}
|
|
|
|
doAction(text) {
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'do', message: text }));
|
|
}
|
|
|
|
dice(expr) {
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'dice', message: expr || '' }));
|
|
}
|
|
|
|
color(hex) {
|
|
let value = typeof hex === 'string' ? hex.trim() : '';
|
|
if (!value) return;
|
|
if (!value.startsWith('#')) value = '#' + value;
|
|
// Normalize 3-digit to 6-digit when possible
|
|
const m3 = /^#([0-9a-fA-F]{3})$/.exec(value);
|
|
if (m3) {
|
|
value = '#' + m3[1].split('').map(c => c + c).join('');
|
|
}
|
|
const m6 = /^#([0-9a-fA-F]{6})$/.exec(value);
|
|
if (!m6) return;
|
|
this.withTokenOrQueue(() => this.sendWithToken({ type: 'color', value }));
|
|
}
|
|
|
|
close() {
|
|
try { this.tcp?.destroy(); } catch (_) { }
|
|
this.tcp = null;
|
|
}
|
|
|
|
ioEmitStatus(type, detail) {
|
|
this.ioSocket.emit('chat:status', { type, detail });
|
|
}
|
|
}
|