Skip to content

feat: decode event routes, match topics and gate them per route and key (INC-976) #594

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
arzafran wants to merge 3 commits into
base: main
Choose a base branch
from
+3,630 −38
Draft

feat: decode event routes, match topics and gate them per route and key (INC-976) #594

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
c02173d
feat: decode event routes, match topics and gate them per route and k…
arzafran Nov 12, 2026
29a05ed
feat: tap agent events into the route engine and report route counter…
arzafran Nov 12, 2026
5b26208
feat: run notify, review and run route actions and let a notify route…
arzafran Nov 12, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions CLI/V2MethodNames.swift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@ enum V2MethodNames {
static let debugPanelSnapshot = "debug.panel_snapshot"
static let debugPanelSnapshotReset = "debug.panel_snapshot.reset"
static let debugPortalStats = "debug.portal.stats"
static let debugRoutesLoad = "debug.routes.load"
static let debugSamplesReset = "debug.samples.reset"
static let debugSamplesStats = "debug.samples.stats"
static let debugSettle = "debug.settle"
Expand Down Expand Up @@ -92,6 +93,7 @@ enum V2MethodNames {
static let reviewOpen = "review.open"
static let reviewRefresh = "review.refresh"
static let reviewSendComments = "review.send_comments"
static let routesList = "routes.list"
static let settingsOpen = "settings.open"
static let snapshotList = "snapshot.list"
static let snapshotRestore = "snapshot.restore"
Expand Down
40 changes: 40 additions & 0 deletions GhosttyTabs.xcodeproj/project.pbxproj
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -246,6 +246,12 @@
A5001208 /* UpdateTitlebarAccessory.swift in Sources */ = {isa = PBXBuildFile; fileRef = A5001218 /* UpdateTitlebarAccessory.swift */; };
A5001610 /* SessionPersistence.swift in Sources */ = {isa = PBXBuildFile; fileRef = A5001611 /* SessionPersistence.swift */; };
A5001650 /* ProgramaConfig.swift in Sources */ = {isa = PBXBuildFile; fileRef = A5001651 /* ProgramaConfig.swift */; };
EVRT00000000000000000002 /* ProgramaRoutes.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000001 /* ProgramaRoutes.swift */; };
EVRT00000000000000000004 /* RouteMatching.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000003 /* RouteMatching.swift */; };
EVRT00000000000000000006 /* RouteGate.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000005 /* RouteGate.swift */; };
EVRT00000000000000000008 /* RouteEngine.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000007 /* RouteEngine.swift */; };
EVRT0000000000000000000A /* RouteActions.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000009 /* RouteActions.swift */; };
EVRT0000000000000000000C /* TerminalController+Routes.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT0000000000000000000B /* TerminalController+Routes.swift */; };
A5001652 /* ProgramaConfigExecutor.swift in Sources */ = {isa = PBXBuildFile; fileRef = A5001653 /* ProgramaConfigExecutor.swift */; };
NRPA00001 /* FileWatcher.swift in Sources */ = {isa = PBXBuildFile; fileRef = NRPA00002 /* FileWatcher.swift */; };
A5001654 /* ProgramaDirectoryTrust.swift in Sources */ = {isa = PBXBuildFile; fileRef = A5001655 /* ProgramaDirectoryTrust.swift */; };
Expand Down Expand Up @@ -398,6 +404,10 @@
7C135CU00000000000000004 /* ClosedTerminalUndoStoreTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 7C135CU00000000000000003 /* ClosedTerminalUndoStoreTests.swift */; };
7C10SE2A0000000000000002 /* WorkspaceCloseConfirmationTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 7C10SE2A0000000000000001 /* WorkspaceCloseConfirmationTests.swift */; };
C1A2B3C4D5E6F70800000001 /* ProgramaConfigTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = C1A2B3C4D5E6F70800000002 /* ProgramaConfigTests.swift */; };
EVRT0000000000000000000E /* ProgramaRouteDecodingTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT0000000000000000000D /* ProgramaRouteDecodingTests.swift */; };
EVRT00000000000000000010 /* RouteGateTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT0000000000000000000F /* RouteGateTests.swift */; };
EVRT00000000000000000012 /* RouteEngineTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000011 /* RouteEngineTests.swift */; };
EVRT00000000000000000014 /* RouteActionsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = EVRT00000000000000000013 /* RouteActionsTests.swift */; };
9EAF4699346282F2171FCDB7 /* ProgramaDirectoryTrustTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 3CA3597273B50CC0592C0164 /* ProgramaDirectoryTrustTests.swift */; };
C7A10002 /* V2MethodNames.swift in Sources */ = {isa = PBXBuildFile; fileRef = C7A10001 /* V2MethodNames.swift */; };
B0F65D90C522CCE8ECCBE4AF /* V2MethodNames.swift in Sources */ = {isa = PBXBuildFile; fileRef = C7A10001 /* V2MethodNames.swift */; };
Expand Down Expand Up @@ -720,6 +730,12 @@
A5001223 /* UpdateLogStore.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Update/UpdateLogStore.swift; sourceTree = "<group>"; };
A5001611 /* SessionPersistence.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = SessionPersistence.swift; sourceTree = "<group>"; };
A5001651 /* ProgramaConfig.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaConfig.swift; sourceTree = "<group>"; };
EVRT00000000000000000001 /* ProgramaRoutes.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaRoutes.swift; sourceTree = "<group>"; };
EVRT00000000000000000003 /* RouteMatching.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteMatching.swift; sourceTree = "<group>"; };
EVRT00000000000000000005 /* RouteGate.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteGate.swift; sourceTree = "<group>"; };
EVRT00000000000000000007 /* RouteEngine.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteEngine.swift; sourceTree = "<group>"; };
EVRT00000000000000000009 /* RouteActions.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteActions.swift; sourceTree = "<group>"; };
EVRT0000000000000000000B /* TerminalController+Routes.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "TerminalController+Routes.swift"; sourceTree = "<group>"; };
A5001653 /* ProgramaConfigExecutor.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaConfigExecutor.swift; sourceTree = "<group>"; };
NRPA00002 /* FileWatcher.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = FileWatcher.swift; sourceTree = "<group>"; };
A5001655 /* ProgramaDirectoryTrust.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaDirectoryTrust.swift; sourceTree = "<group>"; };
Expand Down Expand Up @@ -864,6 +880,10 @@
7C135CU00000000000000003 /* ClosedTerminalUndoStoreTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ClosedTerminalUndoStoreTests.swift; sourceTree = "<group>"; };
7C10SE2A0000000000000001 /* WorkspaceCloseConfirmationTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = WorkspaceCloseConfirmationTests.swift; sourceTree = "<group>"; };
C1A2B3C4D5E6F70800000002 /* ProgramaConfigTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaConfigTests.swift; sourceTree = "<group>"; };
EVRT0000000000000000000D /* ProgramaRouteDecodingTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaRouteDecodingTests.swift; sourceTree = "<group>"; };
EVRT0000000000000000000F /* RouteGateTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteGateTests.swift; sourceTree = "<group>"; };
EVRT00000000000000000011 /* RouteEngineTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteEngineTests.swift; sourceTree = "<group>"; };
EVRT00000000000000000013 /* RouteActionsTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = RouteActionsTests.swift; sourceTree = "<group>"; };
3CA3597273B50CC0592C0164 /* ProgramaDirectoryTrustTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ProgramaDirectoryTrustTests.swift; sourceTree = "<group>"; };
C7A10001 /* V2MethodNames.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = V2MethodNames.swift; sourceTree = "<group>"; };
/* End PBXFileReference section */
Expand Down Expand Up @@ -1218,6 +1238,12 @@
A5001222 /* WindowAccessor.swift */,
A5001611 /* SessionPersistence.swift */,
A5001651 /* ProgramaConfig.swift */,
EVRT00000000000000000001 /* ProgramaRoutes.swift */,
EVRT00000000000000000003 /* RouteMatching.swift */,
EVRT00000000000000000005 /* RouteGate.swift */,
EVRT00000000000000000007 /* RouteEngine.swift */,
EVRT00000000000000000009 /* RouteActions.swift */,
EVRT0000000000000000000B /* TerminalController+Routes.swift */,
A5001653 /* ProgramaConfigExecutor.swift */,
NRPA00002 /* FileWatcher.swift */,
A5001655 /* ProgramaDirectoryTrust.swift */,
Expand Down Expand Up @@ -1445,6 +1471,10 @@
7C135CU00000000000000003 /* ClosedTerminalUndoStoreTests.swift */,
7C10SE2A0000000000000001 /* WorkspaceCloseConfirmationTests.swift */,
C1A2B3C4D5E6F70800000002 /* ProgramaConfigTests.swift */,
EVRT0000000000000000000D /* ProgramaRouteDecodingTests.swift */,
EVRT0000000000000000000F /* RouteGateTests.swift */,
EVRT00000000000000000011 /* RouteEngineTests.swift */,
EVRT00000000000000000013 /* RouteActionsTests.swift */,
3CA3597273B50CC0592C0164 /* ProgramaDirectoryTrustTests.swift */,
A9A8BC17CBD749D48C344001 /* MCPSocketBridgeTests.swift */,
);
Expand Down Expand Up @@ -1839,6 +1869,12 @@
A500120C /* WindowAccessor.swift in Sources */,
A5001610 /* SessionPersistence.swift in Sources */,
A5001650 /* ProgramaConfig.swift in Sources */,
EVRT00000000000000000002 /* ProgramaRoutes.swift in Sources */,
EVRT00000000000000000004 /* RouteMatching.swift in Sources */,
EVRT00000000000000000006 /* RouteGate.swift in Sources */,
EVRT00000000000000000008 /* RouteEngine.swift in Sources */,
EVRT0000000000000000000A /* RouteActions.swift in Sources */,
EVRT0000000000000000000C /* TerminalController+Routes.swift in Sources */,
A5001652 /* ProgramaConfigExecutor.swift in Sources */,
NRPA00001 /* FileWatcher.swift in Sources */,
A5001654 /* ProgramaDirectoryTrust.swift in Sources */,
Expand Down Expand Up @@ -1942,6 +1978,10 @@
7C135CU00000000000000004 /* ClosedTerminalUndoStoreTests.swift in Sources */,
7C10SE2A0000000000000002 /* WorkspaceCloseConfirmationTests.swift in Sources */,
C1A2B3C4D5E6F70800000001 /* ProgramaConfigTests.swift in Sources */,
EVRT0000000000000000000E /* ProgramaRouteDecodingTests.swift in Sources */,
EVRT00000000000000000010 /* RouteGateTests.swift in Sources */,
EVRT00000000000000000012 /* RouteEngineTests.swift in Sources */,
EVRT00000000000000000014 /* RouteActionsTests.swift in Sources */,
9EAF4699346282F2171FCDB7 /* ProgramaDirectoryTrustTests.swift in Sources */,
F6D8BDB710C64A444F3DE4F0 /* MCPSocketBridgeTests.swift in Sources */,
386AE1E1270DD8B6AA427C61 /* SocketPathResolution.swift in Sources */,
Expand Down
119 changes: 119 additions & 0 deletions Resources/Localizable.xcstrings
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18555,6 +18555,125 @@
}
}
}
},
"routes.loadIssues.title": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "Some event routes did not load"
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "一部のイベントルートを読み込めませんでした"
}
}
}
},
"routes.loadIssues.bodyOne": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "“%@” in programa.json has a problem and was skipped."
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "programa.json の「%@」に問題があるため、スキップしました。"
}
}
}
},
"routes.loadIssues.bodyMany": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "“%1$@” and %2$lld more routes in programa.json have problems and were skipped."
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "programa.json の「%1$@」ほか %2$lld 件のルートに問題があるため、スキップしました。"
}
}
}
},
"routes.run.failed.title": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "Route “%@” failed"
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "ルート「%@」が失敗しました"
}
}
}
},
"routes.run.failed.exitStatus": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "Exited with status %lld"
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "終了ステータス %lld で終了しました"
}
}
}
},
"routes.run.failed.timedOut": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "Timed out after %lld seconds"
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "%lld 秒でタイムアウトしました"
}
}
}
},
"routes.run.failed.launch": {
"extractionState": "manual",
"localizations": {
"en": {
"stringUnit": {
"state": "translated",
"value": "The command could not start"
}
},
"ja": {
"stringUnit": {
"state": "translated",
"value": "コマンドを開始できませんでした"
}
}
}
}
},
"version": "1.0"
Expand Down
Loading
Loading