fix: triggers created by other triggers react to the current line again (#9458)

#### Brief overview of PR changes/additions
- A `tempTrigger()`/`tempRegexTrigger()`/`tempLineTrigger()` created
from another trigger's script matches the line being processed again,
instead of only starting on the next line
- Keeps #9267's snapshot iteration (its use-after-free fix stays
intact); root triggers registered during a pass are matched against the
current line afterwards
- New `TriggerSameLineMatchTest` with 6 cases - all fail without the fix

#### Motivation for adding to Mudlet
Long-standing behaviour that room-capture scripts rely on ("start
capture on the room title line, grab it and the following lines")
silently regressed in 4.21.0; reported on Discord with ~6 years of
scripts affected.

#### Other info (issues closed, discussion etc)
Regression from #9267, shipped in 4.21.0/4.21.1/4.22.0. Nested
`feedTriggers()` passes, chained trigger creation, and single-shot
(`expireAfter=1`) semantics all restored to match the old live-list
iteration.

**Test case:** Make a trigger matching some line that runs
`tempRegexTrigger("^(.*)$", [[echo("got: " .. matches[2] .. "\n")]],
2)`, then feed that line: the temp trigger must capture the creating
line itself, not start one line late. Or run `TriggerSameLineMatchTest`.

**Demo** (before: capture starts a line late; after: it includes the
creating line):


https://github.com/user-attachments/assets/be8d95aa-0691-4a9b-954e-e85f39e18a3d

---------

Signed-off-by: Vadim Peretokin <vadim.peretokin@mudlet.org>
This commit is contained in:
Vadim Peretokin 2026-07-27 20:19:14 +02:00 committed by GitHub
parent 2be2a6a5c2
commit eb2627383f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
4 changed files with 324 additions and 0 deletions

View file

@ -28,6 +28,7 @@
#include "TConsole.h"
#include "TTrigger.h"
#include <algorithm>
#include <functional>
/* We need an explicit constructor in this file as the Host class is forward
@ -197,6 +198,13 @@ void TriggerUnit::removeTriggerRootNode(TTrigger* pT)
}
mTriggerMap.remove(pT->getID());
mTriggerRootNodeList.remove(pT);
// A node can be removed and deleted mid-pass without going through the
// deferred-cleanup paths (e.g. XMLimport discarding its placeholder trigger
// when installPackage() runs from a trigger script), so it must not linger
// in the same-line match list. Null the slot instead of compacting:
// processDataStream() may be walking that list by index right now, and
// shifting entries under it would skip a trigger's same-line match.
std::replace(mRootNodesAddedWhileProcessing.begin(), mRootNodesAddedWhileProcessing.end(), pT, static_cast<TTrigger*>(nullptr));
}
TTrigger* TriggerUnit::getTrigger(int id)
@ -226,6 +234,9 @@ bool TriggerUnit::registerTrigger(TTrigger* pT)
return true;
}
addTriggerRootNode(pT);
if (mProcessingDepth > 0) {
mRootNodesAddedWhileProcessing.append(pT);
}
return true;
}
@ -317,17 +328,38 @@ void TriggerUnit::processDataStream(const QString& data, int line)
// current node → use-after-free on the next ++). AliasUnit dodges the
// same hazard for the same reason — see Mudlet issue #4297.
auto copyOfNodeList = mTriggerRootNodeList;
// Triggers registered by a script during this pass (tempTrigger() & Co.)
// are missing from the snapshot but must still match the current line:
// before the snapshot the loop walked the live std::list, which a push_back
// extends in front of end(), so a trigger created mid-pass was reached in
// the same iteration - long-standing behaviour capture scripts depend on.
// Entries below this index were added by outer (nested-feedTriggers) passes
// and are already part of this pass's snapshot.
const qsizetype firstNodeAddedThisPass = mRootNodesAddedWhileProcessing.size();
for (auto trigger : copyOfNodeList) {
if (!trigger->isActive()) {
continue;
}
trigger->match(subject, data, line);
}
// Index-based loop: a match here can register yet more triggers, growing
// the list; they too get a shot at the current line, just as with the
// live-list iteration.
for (qsizetype i = firstNodeAddedThisPass; i < mRootNodesAddedWhileProcessing.size(); ++i) {
auto trigger = mRootNodesAddedWhileProcessing.at(i);
if (!trigger || !trigger->isActive()) {
continue;
}
trigger->match(subject, data, line);
}
free(subject);
mProcessingDepth--;
Q_ASSERT(mProcessingDepth >= 0);
if (mProcessingDepth == 0) {
// Deletion is deferred while any pass runs, so these pointers stayed
// valid; drop them before doCleanup() frees the underlying triggers.
mRootNodesAddedWhileProcessing.clear();
doCleanup();
}
}

View file

@ -111,6 +111,10 @@ private:
// Counter for nested processing; cleanup deferred until 0
int mProcessingDepth = 0;
const QString* mpCurrentExecutingTriggerName = nullptr;
// Root triggers registered while processDataStream() is running, so each
// pass can match the ones created during it against the line being
// processed - see processDataStream(). Cleared once the outermost pass ends.
QList<TTrigger*> mRootNodesAddedWhileProcessing;
};
#endif // MUDLET_TRIGGERUNIT_H

View file

@ -12,6 +12,7 @@ set(FUNCTIONAL_TEST_SOURCES
TUserWindowTest.cpp
TriggerEditorTest.cpp
TFeedTriggersRecursionTest.cpp
TriggerSameLineMatchTest.cpp
dlgTriggerEditorUndoRedoTest.cpp
TDiscordModeTest.cpp
MainConsoleSelectionTest.cpp

View file

@ -0,0 +1,287 @@
/***************************************************************************
* Copyright (C) 2026 by Vadim Peretokin - vadim.peretokin@mudlet.org *
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
* This program is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License *
* along with this program; if not, write to the *
* Free Software Foundation, Inc., *
* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
***************************************************************************/
#include <QtTest/QtTest>
#include "Host.h"
#include "MudletInstanceCoordinator.h"
#include "TLuaInterpreter.h"
#include "TMainConsole.h"
#include "TriggerUnit.h"
#include "TelnetServerStub.h"
#include "ctelnet.h"
#include "dlgConnectionProfiles.h"
#include "mudlet.h"
extern void qInitResources_mudlet();
extern void qInitResources_qm();
extern void qInitResources_additional_splash_screens();
extern void qInitResources_mudlet_fonts_common();
extern void qInitResources_mudlet_fonts_posix();
void initializeQRCResources();
// A trigger created from another trigger's script (tempTrigger() & Co.) must
// still get to match the line being processed. That has been observable
// behaviour for as long as trigger processing iterated the live root-node
// std::list - a push_back lands in front of end(), so the new trigger was
// reached within the same pass - and room-capture scripts ("start capture on
// the room title line, grab it and the following lines") depend on it.
// Iterating a snapshot (introduced by #9267 to fix a use-after-free) silently
// deferred such triggers to the next line and broke those scripts.
class TriggerSameLineMatchTest : public QObject
{
Q_OBJECT
private:
TelnetServerStub* mpServer = nullptr;
const QString mpHostname = "Test-TriggerSameLineMatch";
const QString mpPort = "4000";
const QString mpLocalhost = "localhost";
private slots:
void initTestCase() { initializeQRCResources(); }
void init()
{
mpServer = new TelnetServerStub(qApp);
mpServer->start(mpLocalhost, mpPort.toUShort());
mudlet::start();
mudlet::self()->setupConfig();
mudlet::self()->takeOwnershipOfInstanceCoordinator(std::make_unique<MudletInstanceCoordinator>("MudletInstanceCoordinator"));
mudlet::self()->init();
mudlet::self()->setStorePasswordsSecurely(false);
deleteProfileDirectory(mpHostname);
}
// The classic room-capture pattern: a trigger on the room title line
// creates a catch-all temp trigger, which must capture the title line
// itself, not start one line late.
void test_tempTriggerCreatedInTriggerMatchesCurrentLine()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("captured = {}\n"
"tempRegexTrigger('^Room 74042', [=[\n"
" tempRegexTrigger('^(.*)$', [[table.insert(captured, matches[2])]], 200)\n"
"]=])\n"
"feedTriggers('Room 74042: The Bitter Almond Grove\\n')\n"
"feedTriggers('Exits: North South West\\n')\n"
"echo('CAPTURED=' .. table.concat(captured, '|') .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("CAPTURED=Room 74042: The Bitter Almond Grove|Exits: North South West#")),
"Expected the temp trigger created on the room title line to capture that same line first, then the next line");
}
// The new trigger matches the current line after every pre-existing
// trigger, mirroring where the live-list iteration used to reach it (the
// end of the list), not right after its creator.
void test_newTriggerMatchesAfterExistingTriggers()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("order = {}\n"
"tempRegexTrigger('^o$', [=[\n"
" table.insert(order, 'first')\n"
" tempRegexTrigger('^o$', [[table.insert(order, 'created')]])\n"
"]=])\n"
"tempRegexTrigger('^o$', [[table.insert(order, 'second')]])\n"
"feedTriggers('o\\n')\n"
"echo('ORDER=' .. table.concat(order, ',') .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("ORDER=first,second,created#")), "Expected the mid-pass trigger to fire on the current line after all pre-existing triggers");
}
// A trigger created by a trigger that was itself created this pass must
// also match the current line - creation can chain within one line.
void test_chainedCreationAllMatchCurrentLine()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("chain = {}\n"
"tempRegexTrigger('^c$', [==[\n"
" table.insert(chain, 'creator')\n"
" tempRegexTrigger('^c$', [=[\n"
" table.insert(chain, 'A')\n"
" tempRegexTrigger('^c$', [[table.insert(chain, 'B')]])\n"
" ]=])\n"
"]==])\n"
"feedTriggers('c\\n')\n"
"echo('CHAIN=' .. table.concat(chain, ',') .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("CHAIN=creator,A,B#")), "Expected each generation of mid-pass triggers to still match the current line");
}
// A single-shot (expireAfter=1) temp trigger created mid-pass spends its
// one shot on the creating line and must not linger to the next one.
void test_singleShotFiresOnCreatingLine()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("expiryLine = ''\n"
"tempRegexTrigger('^e', [=[\n"
" tempRegexTrigger('^(.*)$', [[expiryLine = expiryLine .. matches[2] .. ';']], 1)\n"
"]=], 1)\n"
"feedTriggers('e one\\n')\n"
"feedTriggers('e two\\n')\n"
"echo('EXPIRYLINE=' .. expiryLine .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("EXPIRYLINE=e one;#")), "Expected the single-shot temp trigger to fire once, on the line that created it");
}
// tempLineTrigger(0, n, ...) created mid-pass starts counting from the
// current line, so its first capture is the creating line itself.
void test_lineTriggerStartsOnCurrentLine()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("lineGrabs = {}\n"
"tempRegexTrigger('^lstart$', [=[\n"
" tempLineTrigger(0, 2, [[table.insert(lineGrabs, getCurrentLine())]])\n"
"]=], 1)\n"
"feedTriggers('lstart\\n')\n"
"feedTriggers('second\\n')\n"
"feedTriggers('third\\n')\n"
"echo('LINEGRABS=' .. table.concat(lineGrabs, ',') .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("LINEGRABS=lstart,second#")), "Expected the mid-pass line trigger to grab the creating line and the one after it");
}
// With nested processing (the creator also calls feedTriggers()), the new
// trigger matches the nested line while it is being processed and still
// matches the outer line afterwards - in that order.
void test_nestedFeedTriggersMatchesBothLines()
{
startProfile(mpHostname, mpLocalhost, mpPort);
auto* host = mudlet::self()->getActiveHost();
host->mEchoLuaErrors = true;
host->getLuaInterpreter()->compileAndExecuteScript(qsl("nested = {}\n"
"tempRegexTrigger('^outer$', [=[\n"
" tempRegexTrigger('^(.*)$', [[table.insert(nested, matches[2])]], 10)\n"
" feedTriggers('inner\\n')\n"
"]=], 1)\n"
"feedTriggers('outer\\n')\n"
"echo('NESTED=' .. table.concat(nested, ',') .. '#\\n')\n"));
QCOMPARE(host->getTriggerUnit()->processingDepth(), 0);
QVERIFY2(bufferContains(qsl("NESTED=inner,outer#")), "Expected the mid-pass trigger to match the nested line first, then the outer line it was created on");
}
void cleanup()
{
delete mpServer;
mpServer = nullptr;
deleteProfileDirectory(mpHostname);
delete mudlet::self();
}
// Starts a profile the way a user would via the GUI (mirrors the helper in
// TelnetTextDisplayedTest).
void startProfile(const QString& hostname, const QString& address, const QString& port)
{
QTimer::singleShot(0, qApp, [hostname, address, port]() {
mudlet::self()->startAutoLogin({});
QTest::qWait(100);
QTest::mouseClick(mudlet::self()->mpConnectionDialog->new_profile_button, Qt::LeftButton);
QTest::qWait(100);
QTest::keyClicks(QApplication::focusWidget(), hostname);
QTest::qWait(100);
QTest::keyClick(QApplication::focusWidget(), Qt::Key_Tab);
QTest::qWait(100);
QTest::keyClicks(QApplication::focusWidget(), address);
QTest::qWait(100);
QTest::keyClick(QApplication::focusWidget(), Qt::Key_Tab);
QTest::qWait(100);
QTest::keyClicks(QApplication::focusWidget(), port);
QTest::qWait(100);
QTest::keyClick(QApplication::focusWidget(), Qt::Key_Return);
});
QSignalSpy spy(mudlet::self(), &mudlet::signal_profileLoaded);
if (!spy.wait(5000)) {
QFAIL("Profile took too long to load.");
}
auto host = mudlet::self()->getActiveHost();
if (!host) {
QFAIL("No active host available for the test.");
}
QSignalSpy spy2(&(host->mTelnet), &cTelnet::signal_connected);
if (!spy2.wait(2000)) {
QFAIL("Could not connect with the host.");
}
}
// Joins every physical buffer line and normalises whitespace before
// matching, so a needle the console word-wraps across lines is still found.
QString joinedBuffer()
{
auto console = mudlet::self()->getActiveHost()->mpConsole;
QString allText;
for (int i = 0; i <= console->buffer.getLastLineNumber(); ++i) {
allText.append(console->buffer.line(i)).append(QChar::Space);
}
return allText.simplified();
}
bool bufferContains(const QString& needle) { return joinedBuffer().contains(needle); }
void deleteProfileDirectory(const QString& profileName)
{
const QString path = mudlet::getMudletPath(enums::profileHomePath, profileName);
QDir dir(path);
if (!dir.exists()) {
return;
}
dir.removeRecursively();
}
};
void initializeQRCResources()
{
#ifdef INCLUDE_VARIABLE_SPLASH_SCREEN
qInitResources_additional_splash_screens();
#endif
#ifdef INCLUDE_FONTS
qInitResources_mudlet_fonts_common();
#if defined(Q_OS_LINUX) || defined(Q_OS_FREEBSD)
qInitResources_mudlet_fonts_posix();
#endif
#endif
qInitResources_mudlet();
qInitResources_qm();
}
#include "TriggerSameLineMatchTest.moc"
QTEST_MAIN(TriggerSameLineMatchTest)