'+inner.replace(/\n/g,'')+'

'); h = h.replace(/\n/g,'
'); if(!/^<[hpu]/.test(h)) h = '

'+h+'

autour des éléments de bloc (évite les gros espaces blancs) h = h.replace(/(<\/h[1-6]>|<\/ul>|<\/ol>|<\/pre>|

|<\/p>)\s*
/g, '$1'); h = h.replace(/
\s*(|

|
|

|
|<\/p>)/g, '$1');
    h = h.replace(/
\s*(|
|
|
)/g, '$1');
    h = h.replace(/(<\/h[1-6]>|<\/ul>|<\/ol>|<\/pre>)\s*<\/p>/g, '$1');

    return h.replace(/
\s*<\/p>/g,'');
  }

  inp.addEventListener('input',function(){
    inp.style.height='auto';inp.style.height=Math.min(inp.scrollHeight,100)+'px';
    sendBtn.disabled=!inp.value.trim();
  });
  
  inp.addEventListener('keydown',function(e){
    if(e.key==='Enter'&&!e.shiftKey){e.preventDefault();if(inp.value.trim()&&!busy)doSend();}
  });
  
  sendBtn.addEventListener('click',function(){if(inp.value.trim()&&!busy)doSend();});

  async function doSend(){
    var text=inp.value.trim();
    if(!text||busy)return;
    busy=true;sendBtn.disabled=true;
    inp.value='';inp.style.height='auto';

    var w=msgs.querySelector('.kk-welcome');if(w)w.remove();
    addUser(text);showTyping();

    try{
      var resp=await fetch(WEBHOOK+'?action=sendMessage',{
        method:'POST',
        headers:{'Content-Type':'application/json'},
        body:JSON.stringify({chatInput:text,sessionId:getSid()})
      });

      if(!resp.ok){hideTyping();addBot('
Désolé, une erreur est survenue.
');busy=false;sendBtn.disabled=false;return;}

      // ── Lecture du flux de n8n ──
      if(resp.body && resp.body.getReader){
        var reader=resp.body.getReader();
        var decoder=new TextDecoder();
        var full='', buf='', bubble=null;

        while(true){
          var chunk=await reader.read();
          if(chunk.done) break;
          buf += decoder.decode(chunk.value, {stream:true});

          buf = extractObjects(buf, function(obj){
            // Pour le NDJSON de n8n en streaming
            if(obj.type==='item' && obj.content){
              if(!bubble){hideTyping();bubble=addBot('');}
              full += obj.content;
              bubble.innerHTML = md(full);
              scrl();
            }
            // En cas de fallback vers un objet JSON non-streamé
            else if(obj.output || obj.text){
              if(!bubble){hideTyping();bubble=addBot('');}
              full += (obj.output || obj.text);
              bubble.innerHTML = md(full);
              scrl();
            }
          });
        }

        buf = extractObjects(buf, function(obj){
          if(obj.type==='item' && obj.content){
            if(!bubble){hideTyping();bubble=addBot('');}
            full += obj.content;
          } else if(obj.output || obj.text){
             if(!bubble){hideTyping();bubble=addBot('');}
             full += (obj.output || obj.text);
          }
        });

        if(!bubble){
          hideTyping();
          addBot(full ? md(full) : '
...
');
        } else {
          bubble.innerHTML=md(full||'...');
          scrl();
        }

      // ── Fallback standard (si le stream n'est pas possible) ──
      }else{
        hideTyping();
        var raw=await resp.text();
        var out='';
        try{
          var json=JSON.parse(raw);
          if(typeof json==='string') out=json;
          else if(Array.isArray(json)&&json.length) out=json[0].output||json[0].text||JSON.stringify(json[0]);
          else if(json.output) out=json.output;
          else if(json.text) out=json.text;
          else out=JSON.stringify(json);
        }catch(e){out=raw;}
        addBot(md(out));
      }
    }catch(err){
      console.error('Kokokhas:',err);
      hideTyping();
      addBot('
Désolé, impossible de se connecter.
');
    }
    busy=false;sendBtn.disabled=false;inp.focus();
  }
})();