Compare commits
25 Commits
29a6c3eb42
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| fd5fe5b328 | |||
| 4ed3f4d6ab | |||
| 2cb83632f9 | |||
| 0c4fe50606 | |||
| 15f2435749 | |||
| 3897b63068 | |||
| f1a8e6af21 | |||
| bd54ec0edb | |||
| b9518f52ec | |||
| c143c9a561 | |||
| 7e2f927596 | |||
| 788e678ed6 | |||
| ea89e90c2f | |||
| ce43d64e77 | |||
| 618987546a | |||
| 604221a29d | |||
| 89b85c6f17 | |||
| 6e3d7fee94 | |||
| 089850ac18 | |||
| 5b7c08260a | |||
| d4b2fec1db | |||
| 1f7aa99cc0 | |||
| d853e1b24d | |||
| e8bc34eaf5 | |||
| f84167a7fb |
@@ -460,13 +460,14 @@ setting <action> [parameters]
|
|||||||
- `speech#voice=voice_name` - Voice selection (e.g., "en-us+f3")
|
- `speech#voice=voice_name` - Voice selection (e.g., "en-us+f3")
|
||||||
- `speech#module=module_name` - TTS module (e.g., "espeak-ng")
|
- `speech#module=module_name` - TTS module (e.g., "espeak-ng")
|
||||||
- `speech#driver=driver_name` - Speech driver (speechdDriver/genericDriver/dectalkDriver/litetalkDriver/doubletalkDriver/tripletalkDriver)
|
- `speech#driver=driver_name` - Speech driver (speechdDriver/genericDriver/dectalkDriver/litetalkDriver/doubletalkDriver/tripletalkDriver)
|
||||||
- `speech#hardware_device=auto` - Hardware synth serial device for dectalkDriver/litetalkDriver
|
- `speech#hardware_device=/dev/ttyS0` - Hardware synth serial device for dectalkDriver/litetalkDriver
|
||||||
- `speech#hardware_baud_rate=9600` - Hardware synth serial baud rate
|
- `speech#hardware_baud_rate=9600` - Hardware synth serial baud rate
|
||||||
- `speech#history_size=50` - Number of spoken items kept in runtime speech history
|
- `speech#history_size=50` - Number of spoken items kept in runtime speech history
|
||||||
|
|
||||||
USB hardware synths are supported only when Linux exposes them as a serial tty
|
USB hardware synths are supported only when Linux exposes them as a serial tty
|
||||||
such as `/dev/ttyACM0` or `/dev/ttyUSB0`. A USB-only TripleTalk with no tty
|
such as `/dev/ttyACM0` or `/dev/ttyUSB0`. A USB-only TripleTalk with no tty
|
||||||
device would require a separate USB protocol driver.
|
device would require a separate USB protocol driver. Use an explicit
|
||||||
|
`speech#hardware_device` path for hardware speech.
|
||||||
- `speech#auto_read_incoming=True/False` - Auto-read new text
|
- `speech#auto_read_incoming=True/False` - Auto-read new text
|
||||||
|
|
||||||
*Sound Settings:*
|
*Sound Settings:*
|
||||||
@@ -652,6 +653,10 @@ Building...
|
|||||||
- **Non-blocking**: Progress tones don't interrupt speech or other functionality
|
- **Non-blocking**: Progress tones don't interrupt speech or other functionality
|
||||||
- **Configurable**: Can be enabled/disabled as needed
|
- **Configurable**: Can be enabled/disabled as needed
|
||||||
|
|
||||||
|
Fenrir detects stable progress structures rather than application-specific
|
||||||
|
status formats. Application-specific formats change too frequently to support
|
||||||
|
reliably.
|
||||||
|
|
||||||
### Usage Examples
|
### Usage Examples
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
@@ -735,7 +740,7 @@ send_fenrir_command("setting set speech#rate=0.9")
|
|||||||
|
|
||||||
**Commands not working:**
|
**Commands not working:**
|
||||||
- Verify `enable_command_remote=True` in settings
|
- Verify `enable_command_remote=True` in settings
|
||||||
- Check Fenrir debug logs: `/var/log/fenrir.log`
|
- Check Fenrir debug logs: `/tmp/fenrir.log`
|
||||||
- Test with simple command: `echo "command interrupt" | socat - UNIX-CLIENT:/tmp/fenrirscreenreader-daemon.sock`
|
- Test with simple command: `echo "command interrupt" | socat - UNIX-CLIENT:/tmp/fenrirscreenreader-daemon.sock`
|
||||||
|
|
||||||
## Command Line Options
|
## Command Line Options
|
||||||
|
|||||||
@@ -3,13 +3,13 @@ https://git.stormux.org/storm/fenrir/issues
|
|||||||
|
|
||||||
For bugs, please provide a debug file that shows the issue.
|
For bugs, please provide a debug file that shows the issue.
|
||||||
How to create a debug file:
|
How to create a debug file:
|
||||||
1. first delete old stuff:
|
1. start fenrir in debug mode
|
||||||
sudo rm /var/log/fenrir.log
|
|
||||||
2. start fenrir in debug mode
|
|
||||||
sudo fenrir -d
|
sudo fenrir -d
|
||||||
<do your stuff>
|
<do your stuff>
|
||||||
3.
|
2.
|
||||||
stop fenrir (fenrirKey + q)
|
stop fenrir (fenrirKey + q)
|
||||||
the debug file is in /var/log/fenrir.log
|
the debug file is in /tmp/fenrir.log
|
||||||
|
if another Fenrir debug instance is already using it, check /tmp/fenrir2.log,
|
||||||
|
/tmp/fenrir3.log, etc.
|
||||||
|
|
||||||
please be as precise as possible to make it easy to solve the problem.
|
please be as precise as possible to make it easy to solve the problem.
|
||||||
|
|||||||
@@ -79,12 +79,12 @@ volume=1.0
|
|||||||
# Used by dectalkDriver, litetalkDriver, doubletalkDriver, and tripletalkDriver.
|
# Used by dectalkDriver, litetalkDriver, doubletalkDriver, and tripletalkDriver.
|
||||||
# USB serial devices are supported if Linux exposes them as /dev/ttyACM*
|
# USB serial devices are supported if Linux exposes them as /dev/ttyACM*
|
||||||
# or /dev/ttyUSB*. USB-only synths with no tty device need a separate driver.
|
# or /dev/ttyUSB*. USB-only synths with no tty device need a separate driver.
|
||||||
# auto checks /dev/ttyACM* first, then /dev/ttyUSB*.
|
# Set an explicit device for hardware speech.
|
||||||
# Examples:
|
# Examples:
|
||||||
# hardware_device=/dev/ttyACM0 # RPITalk USB gadget mode
|
# hardware_device=/dev/ttyACM0 # RPITalk USB gadget mode
|
||||||
# hardware_device=/dev/ttyUSB0 # USB serial adapter
|
# hardware_device=/dev/ttyUSB0 # USB serial adapter
|
||||||
# hardware_device=/dev/ttyS0 # built-in serial port
|
# hardware_device=/dev/ttyS0 # built-in serial port
|
||||||
hardware_device=auto
|
hardware_device=/dev/ttyS0
|
||||||
|
|
||||||
# Serial baud rate for hardware speech synthesizers.
|
# Serial baud rate for hardware speech synthesizers.
|
||||||
hardware_baud_rate=9600
|
hardware_baud_rate=9600
|
||||||
@@ -183,7 +183,8 @@ double_tap_timeout=0.2
|
|||||||
# The default is 0, no logging.
|
# The default is 0, no logging.
|
||||||
debug_level=0
|
debug_level=0
|
||||||
# debugMode sets where the debug output should send to:
|
# debugMode sets where the debug output should send to:
|
||||||
# debugMode=File writes to debug_file (Default:/tmp/fenrir-PID.log)
|
# debugMode=File writes to debug_file (Default:/tmp/fenrir.log)
|
||||||
|
# If the default log is already in use, Fenrir uses /tmp/fenrir2.log, etc.
|
||||||
# debugMode=Print just prints on the screen
|
# debugMode=Print just prints on the screen
|
||||||
debug_mode=File
|
debug_mode=File
|
||||||
debug_file=
|
debug_file=
|
||||||
|
|||||||
@@ -114,7 +114,7 @@ sudo ./fenrir -f -d -p
|
|||||||
|
|
||||||
# Debug output goes to:
|
# Debug output goes to:
|
||||||
# - Console (with -p flag)
|
# - Console (with -p flag)
|
||||||
# - /var/log/fenrir.log
|
# - /tmp/fenrir.log
|
||||||
```
|
```
|
||||||
|
|
||||||
## Creating Commands
|
## Creating Commands
|
||||||
|
|||||||
+4
-2
@@ -50,7 +50,9 @@ Multiple settings can be separated by semicolons.
|
|||||||
|
|
||||||
.TP
|
.TP
|
||||||
.BR \-d ", " \-\-debug
|
.BR \-d ", " \-\-debug
|
||||||
Enable debug mode. Debug information will be logged to /var/log/fenrir.log.
|
Enable debug mode. Debug information will be logged to /tmp/fenrir.log by
|
||||||
|
default. If another Fenrir debug instance is already using it, Fenrir uses
|
||||||
|
/tmp/fenrir2.log, /tmp/fenrir3.log, etc.
|
||||||
|
|
||||||
.TP
|
.TP
|
||||||
.BR \-p ", " \-\-print
|
.BR \-p ", " \-\-print
|
||||||
@@ -476,7 +478,7 @@ User sound themes
|
|||||||
User scripts
|
User scripts
|
||||||
|
|
||||||
.TP
|
.TP
|
||||||
.B /var/log/fenrir.log
|
.B /tmp/fenrir.log
|
||||||
Debug log file
|
Debug log file
|
||||||
|
|
||||||
.TP
|
.TP
|
||||||
|
|||||||
+4
-7
@@ -1684,12 +1684,9 @@ the pico module:
|
|||||||
language=de-DE
|
language=de-DE
|
||||||
....
|
....
|
||||||
|
|
||||||
Hardware speech drivers use a serial device. The default `+auto+` checks
|
Hardware speech drivers use a serial device. Set an explicit path.
|
||||||
`+/dev/ttyACM*+` first, then `+/dev/ttyUSB*+`. Set an explicit path for
|
|
||||||
stable systems.
|
|
||||||
|
|
||||||
....
|
....
|
||||||
hardware_device=auto
|
|
||||||
hardware_device=/dev/ttyACM0
|
hardware_device=/dev/ttyACM0
|
||||||
hardware_device=/dev/ttyUSB0
|
hardware_device=/dev/ttyUSB0
|
||||||
hardware_device=/dev/ttyS0
|
hardware_device=/dev/ttyS0
|
||||||
@@ -2279,13 +2276,13 @@ that shows the issue.
|
|||||||
|
|
||||||
==== How-to create a debug file
|
==== How-to create a debug file
|
||||||
|
|
||||||
. Delete old debug stuff +
|
|
||||||
`+sudo rm /var/log/fenrir.log+`
|
|
||||||
. Start fenrir in debug mode +
|
. Start fenrir in debug mode +
|
||||||
`+sudo fenrir -d+`
|
`+sudo fenrir -d+`
|
||||||
. Do your stuff to reproduce the problem
|
. Do your stuff to reproduce the problem
|
||||||
. Stop fenrir (`+fenrirKey + q+`)
|
. Stop fenrir (`+fenrirKey + q+`)
|
||||||
|
|
||||||
the debug file is located in `+/var/log/fenrir.log+`
|
the debug file is located in `+/tmp/fenrir.log+`. If another Fenrir debug
|
||||||
|
instance is already using it, check `+/tmp/fenrir2.log+`,
|
||||||
|
`+/tmp/fenrir3.log+`, etc.
|
||||||
|
|
||||||
Please be as precise as possible to make it easy to solve the problem.
|
Please be as precise as possible to make it easy to solve the problem.
|
||||||
|
|||||||
+9
-6
@@ -101,7 +101,7 @@ driver=speechdDriver
|
|||||||
rate=0.5
|
rate=0.5
|
||||||
pitch=0.5
|
pitch=0.5
|
||||||
volume=1.0
|
volume=1.0
|
||||||
hardware_device=auto
|
hardware_device=/dev/ttyS0
|
||||||
hardware_baud_rate=9600
|
hardware_baud_rate=9600
|
||||||
history_size=50
|
history_size=50
|
||||||
|
|
||||||
@@ -312,6 +312,9 @@ Fenrir automatically detects and provides audio feedback for progress indicators
|
|||||||
- **Automatic**: Works with downloads, compilations, installations
|
- **Automatic**: Works with downloads, compilations, installations
|
||||||
- **Remote control**: Enable via socket commands
|
- **Remote control**: Enable via socket commands
|
||||||
|
|
||||||
|
Fenrir detects stable progress structures rather than application-specific
|
||||||
|
status formats, which change too frequently to support reliably.
|
||||||
|
|
||||||
### Spell Checking
|
### Spell Checking
|
||||||
- `Fenrir + S` - Spell check current word
|
- `Fenrir + S` - Spell check current word
|
||||||
- `Fenrir + S S` - Add word to dictionary
|
- `Fenrir + S S` - Add word to dictionary
|
||||||
@@ -341,10 +344,10 @@ Fenrir automatically detects and provides audio feedback for progress indicators
|
|||||||
- **doubletalkDriver** - Serial DoubleTalk LT-compatible hardware speech
|
- **doubletalkDriver** - Serial DoubleTalk LT-compatible hardware speech
|
||||||
- **tripletalkDriver** - Serial TripleTalk-compatible hardware speech
|
- **tripletalkDriver** - Serial TripleTalk-compatible hardware speech
|
||||||
|
|
||||||
For hardware speech, set `speech#hardware_device` to `auto` or an explicit
|
For hardware speech, set `speech#hardware_device` to an explicit serial path.
|
||||||
serial path. RPITalk gadget mode usually appears as `/dev/ttyACM0`; USB serial
|
RPITalk gadget mode usually appears as `/dev/ttyACM0`; USB serial adapters
|
||||||
adapters usually appear as `/dev/ttyUSB0`; built-in serial ports may be
|
usually appear as `/dev/ttyUSB0`; built-in serial ports may be `/dev/ttyS0`.
|
||||||
`/dev/ttyS0`. The default baud rate is `9600`. `doubletalkDriver` targets
|
The default baud rate is `9600`. `doubletalkDriver` targets
|
||||||
DoubleTalk LT-style serial devices, not the internal DoubleTalk PC ISA card.
|
DoubleTalk LT-style serial devices, not the internal DoubleTalk PC ISA card.
|
||||||
USB TripleTalk devices work only if Linux exposes them as a serial tty such as
|
USB TripleTalk devices work only if Linux exposes them as a serial tty such as
|
||||||
`/dev/ttyACM0` or `/dev/ttyUSB0`; USB-only models with no tty device need a
|
`/dev/ttyACM0` or `/dev/ttyUSB0`; USB-only models with no tty device need a
|
||||||
@@ -428,7 +431,7 @@ For a dedicated PTY/terminal screen reader, see TDSR: https://github.com/tspivey
|
|||||||
### Debug Mode
|
### Debug Mode
|
||||||
```bash
|
```bash
|
||||||
sudo fenrir -f -d
|
sudo fenrir -f -d
|
||||||
# Debug output goes to /var/log/fenrir.log
|
# Debug output goes to /tmp/fenrir.log
|
||||||
```
|
```
|
||||||
|
|
||||||
## Getting Help
|
## Getting Help
|
||||||
|
|||||||
+4
-4
@@ -927,8 +927,7 @@ Select the language you want Fenrir to use.
|
|||||||
language=english-us
|
language=english-us
|
||||||
Values: Text, see your TTS synths documentation what is available.
|
Values: Text, see your TTS synths documentation what is available.
|
||||||
|
|
||||||
Hardware speech drivers use a serial device. The default ''auto'' checks /dev/ttyACM* first, then /dev/ttyUSB*. Set an explicit path for stable systems.
|
Hardware speech drivers use a serial device. Set an explicit path.
|
||||||
hardware_device=auto
|
|
||||||
hardware_device=/dev/ttyACM0
|
hardware_device=/dev/ttyACM0
|
||||||
hardware_device=/dev/ttyUSB0
|
hardware_device=/dev/ttyUSB0
|
||||||
hardware_device=/dev/ttyS0
|
hardware_device=/dev/ttyS0
|
||||||
@@ -1316,10 +1315,11 @@ Please report Bugs and feature requests to:
|
|||||||
|
|
||||||
for bugs please provide a [[#Howto create a debug file|debug]] file that shows the issue.
|
for bugs please provide a [[#Howto create a debug file|debug]] file that shows the issue.
|
||||||
==== How-to create a debug file ====
|
==== How-to create a debug file ====
|
||||||
- Delete old debug stuff\\ ''sudo rm /var/log/fenrir.log''
|
|
||||||
- Start fenrir in debug mode\\ ''sudo fenrir -d''
|
- Start fenrir in debug mode\\ ''sudo fenrir -d''
|
||||||
- Do your stuff to reproduce the problem
|
- Do your stuff to reproduce the problem
|
||||||
- Stop fenrir (''fenrirKey + q'')
|
- Stop fenrir (''fenrirKey + q'')
|
||||||
the debug file is located in ''/var/log/fenrir.log''
|
the debug file is located in ''/tmp/fenrir.log''. If another Fenrir debug
|
||||||
|
instance is already using it, check ''/tmp/fenrir2.log'',
|
||||||
|
''/tmp/fenrir3.log'', etc.
|
||||||
|
|
||||||
Please be as precise as possible to make it easy to solve the problem.
|
Please be as precise as possible to make it easy to solve the problem.
|
||||||
|
|||||||
@@ -112,9 +112,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=True,
|
interrupt=True,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
if line_break:
|
if line_break:
|
||||||
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
||||||
|
|||||||
@@ -49,9 +49,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=True,
|
interrupt=True,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
if line_break:
|
if line_break:
|
||||||
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
||||||
|
|||||||
@@ -50,9 +50,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=True,
|
interrupt=True,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
|
|
||||||
def set_callback(self, callback):
|
def set_callback(self, callback):
|
||||||
|
|||||||
@@ -95,9 +95,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=False,
|
interrupt=False,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
if line_break:
|
if line_break:
|
||||||
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
||||||
|
|||||||
@@ -60,9 +60,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=True,
|
interrupt=True,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
if line_break:
|
if line_break:
|
||||||
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
||||||
|
|||||||
@@ -50,9 +50,9 @@ class command:
|
|||||||
"review", "end_of_screen"
|
"review", "end_of_screen"
|
||||||
):
|
):
|
||||||
self.env["runtime"]["OutputManager"].present_text(
|
self.env["runtime"]["OutputManager"].present_text(
|
||||||
_("end of screen"),
|
_("start of screen"),
|
||||||
interrupt=True,
|
interrupt=True,
|
||||||
sound_icon="EndOfScreen",
|
sound_icon="StartOfScreen",
|
||||||
)
|
)
|
||||||
if line_break:
|
if line_break:
|
||||||
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
if self.env["runtime"]["SettingsManager"].get_setting_as_bool(
|
||||||
|
|||||||
@@ -81,12 +81,13 @@ class command:
|
|||||||
delta_length = len(delta_text)
|
delta_length = len(delta_text)
|
||||||
if (
|
if (
|
||||||
delta_length > 200
|
delta_length > 200
|
||||||
): # Allow longer progress lines like Claude Code's status
|
): # Allow longer progress lines such as terminal status output
|
||||||
self.env["runtime"]["DebugManager"].write_debug_out(
|
if not self.is_explicit_progress_delta(delta_text):
|
||||||
f"Progress filter: delta too long ({delta_length})",
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
debug.DebugLevel.INFO,
|
f"Progress filter: delta too long ({delta_length})",
|
||||||
)
|
debug.DebugLevel.INFO,
|
||||||
return False
|
)
|
||||||
|
return False
|
||||||
|
|
||||||
# If delta contains newlines and is substantial, let incoming handler
|
# If delta contains newlines and is substantial, let incoming handler
|
||||||
# deal with it to avoid interfering with multi-line text output
|
# deal with it to avoid interfering with multi-line text output
|
||||||
@@ -107,6 +108,25 @@ class command:
|
|||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
def is_explicit_progress_delta(self, text):
|
||||||
|
"""Allow long single-line deltas that still look like progress output."""
|
||||||
|
import re
|
||||||
|
|
||||||
|
if "\n" in text or self.contains_url(text):
|
||||||
|
return False
|
||||||
|
|
||||||
|
has_percentage = re.search(r"(^|\s)\d+(?:\.\d+)?\s*%", text)
|
||||||
|
if not has_percentage:
|
||||||
|
return False
|
||||||
|
|
||||||
|
return bool(
|
||||||
|
re.search(
|
||||||
|
r"[|\[\]#=*>█▉▊▋▌▍▎▏▒▓░]"
|
||||||
|
r"|\b\d+(?:\.\d+)?\s*[kKmMgGtT](?:i?B)?/s\b",
|
||||||
|
text,
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
def reset_progress_state(self):
|
def reset_progress_state(self):
|
||||||
"""Reset progress state when a prompt is detected, allowing new progress operations to start fresh"""
|
"""Reset progress state when a prompt is detected, allowing new progress operations to start fresh"""
|
||||||
self.env["runtime"]["DebugManager"].write_debug_out(
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
@@ -306,43 +326,27 @@ class command:
|
|||||||
self.env["commandBuffer"]["lastProgressTime"] = current_time
|
self.env["commandBuffer"]["lastProgressTime"] = current_time
|
||||||
return
|
return
|
||||||
|
|
||||||
# Pattern 6: Claude Code working indicators (various symbols + activity text + "esc/ctrl+c to interrupt")
|
# Pattern 6: Interruptible terminal activity indicators
|
||||||
# Matches any: [symbol] [Task description]… (... to interrupt ...)
|
# Matches any: [symbol] [Task description][…] (... to interrupt ...)
|
||||||
# Symbols include: * ✢ ✽ ✶ ✻ · • ◦ ○ ● ◆ and similar decorative characters
|
# Symbols include: * ✢ ✽ ✶ ✻ · • ◦ ○ ● ◆ and similar decorative characters
|
||||||
# Example: ✽ Reviewing script for issues… (ctrl+c to interrupt · 33s · ↑ 1.6k tokens · thought for 4s)
|
# Keep this structural rather than adding application-specific formats,
|
||||||
claude_progress_match = re.search(
|
# which change too frequently to support reliably.
|
||||||
r'[*✢✽✶✻·•◦○●◆]\s+\w+.*?…\s*\(.*(?:esc|ctrl\+c) to interrupt.*\)',
|
interruptible_activity_match = re.search(
|
||||||
|
r'[*✢✽✶✻·•◦○●◆]\s+\w+.*?(?:…\s*)?\(.*(?:esc|ctrl\+c) to interrupt.*\)',
|
||||||
text,
|
text,
|
||||||
re.IGNORECASE,
|
re.IGNORECASE,
|
||||||
)
|
)
|
||||||
if claude_progress_match:
|
if interruptible_activity_match:
|
||||||
if current_time - self.env["commandBuffer"]["lastProgressTime"] >= 1.0:
|
if current_time - self.env["commandBuffer"]["lastProgressTime"] >= 1.0:
|
||||||
self.env["runtime"]["DebugManager"].write_debug_out(
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
"Playing Claude Code activity beep",
|
"Playing interruptible activity beep",
|
||||||
debug.DebugLevel.INFO,
|
debug.DebugLevel.INFO,
|
||||||
)
|
)
|
||||||
self.play_activity_beep()
|
self.play_activity_beep()
|
||||||
self.env["commandBuffer"]["lastProgressTime"] = current_time
|
self.env["commandBuffer"]["lastProgressTime"] = current_time
|
||||||
return
|
return
|
||||||
|
|
||||||
# Pattern 6b: Claude Code tool invocation indicators (● Tool Name(...))
|
# Pattern 6b: Bullet/white bullet activity lines (•/◦ ...)
|
||||||
# Example: ● Web Search("query here")
|
|
||||||
tool_invocation_match = re.search(
|
|
||||||
r'[●○◉•◦]\s+(?:Web\s*Search|Read|Write|Edit|Bash|Glob|Grep|Task|WebFetch)\s*\(',
|
|
||||||
text,
|
|
||||||
re.IGNORECASE,
|
|
||||||
)
|
|
||||||
if tool_invocation_match:
|
|
||||||
if current_time - self.env["commandBuffer"]["lastProgressTime"] >= 1.0:
|
|
||||||
self.env["runtime"]["DebugManager"].write_debug_out(
|
|
||||||
"Playing Claude Code tool invocation beep",
|
|
||||||
debug.DebugLevel.INFO,
|
|
||||||
)
|
|
||||||
self.play_activity_beep()
|
|
||||||
self.env["commandBuffer"]["lastProgressTime"] = current_time
|
|
||||||
return
|
|
||||||
|
|
||||||
# Pattern 6c: Bullet/white bullet activity lines (•/◦ ...)
|
|
||||||
bullet_activity_match = re.search(
|
bullet_activity_match = re.search(
|
||||||
(
|
(
|
||||||
r'^\s*[•◦]\s+.*(?:…|\.{3,}|\b(?:thinking|working|processing|'
|
r'^\s*[•◦]\s+.*(?:…|\.{3,}|\b(?:thinking|working|processing|'
|
||||||
|
|||||||
@@ -127,7 +127,7 @@ class config_command:
|
|||||||
self.config.set("speech", "rate", "0.75")
|
self.config.set("speech", "rate", "0.75")
|
||||||
self.config.set("speech", "pitch", "0.5")
|
self.config.set("speech", "pitch", "0.5")
|
||||||
self.config.set("speech", "volume", "1.0")
|
self.config.set("speech", "volume", "1.0")
|
||||||
self.config.set("speech", "hardware_device", "auto")
|
self.config.set("speech", "hardware_device", "/dev/ttyS0")
|
||||||
self.config.set("speech", "hardware_baud_rate", "9600")
|
self.config.set("speech", "hardware_baud_rate", "9600")
|
||||||
|
|
||||||
self.config.add_section("sound")
|
self.config.add_section("sound")
|
||||||
|
|||||||
+1
-1
@@ -108,7 +108,7 @@ class command(config_command):
|
|||||||
"rate": "0.5",
|
"rate": "0.5",
|
||||||
"pitch": "0.5",
|
"pitch": "0.5",
|
||||||
"volume": "1.0",
|
"volume": "1.0",
|
||||||
"hardware_device": "auto",
|
"hardware_device": "/dev/ttyS0",
|
||||||
"hardware_baud_rate": "9600",
|
"hardware_baud_rate": "9600",
|
||||||
"auto_read_incoming": "True",
|
"auto_read_incoming": "True",
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,24 +3,22 @@
|
|||||||
|
|
||||||
import os
|
import os
|
||||||
import pathlib
|
import pathlib
|
||||||
|
import fcntl
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
from fenrirscreenreader.core import debug
|
from fenrirscreenreader.core import debug
|
||||||
|
|
||||||
|
|
||||||
class DebugManager:
|
class DebugManager:
|
||||||
|
DEFAULT_LOG_DIR = "/tmp"
|
||||||
|
DEFAULT_LOG_BASENAME = "fenrir"
|
||||||
|
DEFAULT_LOG_EXTENSION = ".log"
|
||||||
|
|
||||||
def __init__(self, file_name=""):
|
def __init__(self, file_name=""):
|
||||||
self._file = None
|
self._file = None
|
||||||
self._fileOpened = False
|
self._fileOpened = False
|
||||||
self._fileName = (
|
self._fileName = file_name
|
||||||
"/tmp/fenrir_"
|
self._useDefaultLogName = file_name == ""
|
||||||
+ str(os.getpid())
|
|
||||||
+ "_"
|
|
||||||
+ str(datetime.utcnow().strftime("%Y-%m-%d_%H-%M-%S"))
|
|
||||||
+ ".log"
|
|
||||||
)
|
|
||||||
if file_name != "":
|
|
||||||
self._fileName = file_name
|
|
||||||
|
|
||||||
def initialize(self, environment):
|
def initialize(self, environment):
|
||||||
self.env = environment
|
self.env = environment
|
||||||
@@ -39,6 +37,10 @@ class DebugManager:
|
|||||||
self._fileOpened = False
|
self._fileOpened = False
|
||||||
if file_name != "":
|
if file_name != "":
|
||||||
self._fileName = file_name
|
self._fileName = file_name
|
||||||
|
self._useDefaultLogName = False
|
||||||
|
if self._useDefaultLogName:
|
||||||
|
self._open_default_debug_file()
|
||||||
|
return
|
||||||
if self._fileName != "":
|
if self._fileName != "":
|
||||||
directory = os.path.dirname(self._fileName)
|
directory = os.path.dirname(self._fileName)
|
||||||
if not os.path.exists(directory):
|
if not os.path.exists(directory):
|
||||||
@@ -51,6 +53,43 @@ class DebugManager:
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(e)
|
print(e)
|
||||||
|
|
||||||
|
def _open_default_debug_file(self):
|
||||||
|
pathlib.Path(self.DEFAULT_LOG_DIR).mkdir(parents=True, exist_ok=True)
|
||||||
|
log_number = 1
|
||||||
|
while True:
|
||||||
|
log_file = self._default_log_file_name(log_number)
|
||||||
|
try:
|
||||||
|
fd = os.open(
|
||||||
|
log_file,
|
||||||
|
os.O_CREAT | os.O_RDWR | os.O_NOFOLLOW,
|
||||||
|
0o644,
|
||||||
|
)
|
||||||
|
file_obj = os.fdopen(fd, "a")
|
||||||
|
fcntl.flock(file_obj.fileno(), fcntl.LOCK_EX | fcntl.LOCK_NB)
|
||||||
|
file_obj.seek(0)
|
||||||
|
file_obj.truncate()
|
||||||
|
os.chmod(log_file, 0o644)
|
||||||
|
self._file = file_obj
|
||||||
|
self._fileName = log_file
|
||||||
|
self._fileOpened = True
|
||||||
|
return
|
||||||
|
except BlockingIOError:
|
||||||
|
try:
|
||||||
|
file_obj.close()
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
log_number += 1
|
||||||
|
except OSError as e:
|
||||||
|
print(e)
|
||||||
|
return
|
||||||
|
|
||||||
|
def _default_log_file_name(self, log_number):
|
||||||
|
suffix = "" if log_number == 1 else str(log_number)
|
||||||
|
return os.path.join(
|
||||||
|
self.DEFAULT_LOG_DIR,
|
||||||
|
self.DEFAULT_LOG_BASENAME + suffix + self.DEFAULT_LOG_EXTENSION,
|
||||||
|
)
|
||||||
|
|
||||||
def write_debug_out(
|
def write_debug_out(
|
||||||
self, text, level=debug.DebugLevel.DEACTIVE, on_any_level=False
|
self, text, level=debug.DebugLevel.DEACTIVE, on_any_level=False
|
||||||
):
|
):
|
||||||
@@ -120,3 +159,4 @@ class DebugManager:
|
|||||||
def set_debug_file(self, file_name):
|
def set_debug_file(self, file_name):
|
||||||
self.close_debug_file()
|
self.close_debug_file()
|
||||||
self._fileName = file_name
|
self._fileName = file_name
|
||||||
|
self._useDefaultLogName = file_name == ""
|
||||||
|
|||||||
@@ -311,7 +311,10 @@ class FenrirManager:
|
|||||||
self.singleKeyCommand = True
|
self.singleKeyCommand = True
|
||||||
elif (
|
elif (
|
||||||
(
|
(
|
||||||
self.environment["runtime"]["DiffReviewManager"].is_active()
|
self.environment["runtime"]["VmenuManager"].get_active()
|
||||||
|
or self.environment["runtime"][
|
||||||
|
"DiffReviewManager"
|
||||||
|
].is_active()
|
||||||
or self.environment["runtime"][
|
or self.environment["runtime"][
|
||||||
"SpeechHistoryManager"
|
"SpeechHistoryManager"
|
||||||
].is_active()
|
].is_active()
|
||||||
|
|||||||
@@ -28,7 +28,7 @@ settings_data = {
|
|||||||
"module": "",
|
"module": "",
|
||||||
"voice": "en-us",
|
"voice": "en-us",
|
||||||
"language": "",
|
"language": "",
|
||||||
"hardware_device": "auto",
|
"hardware_device": "/dev/ttyS0",
|
||||||
"hardware_baud_rate": 9600,
|
"hardware_baud_rate": 9600,
|
||||||
"auto_read_incoming": True,
|
"auto_read_incoming": True,
|
||||||
"read_numbers_as_digits": False,
|
"read_numbers_as_digits": False,
|
||||||
|
|||||||
@@ -6,6 +6,7 @@
|
|||||||
|
|
||||||
import inspect
|
import inspect
|
||||||
import os
|
import os
|
||||||
|
from argparse import Namespace
|
||||||
from configparser import ConfigParser
|
from configparser import ConfigParser
|
||||||
|
|
||||||
from fenrirscreenreader.core import applicationManager
|
from fenrirscreenreader.core import applicationManager
|
||||||
@@ -67,6 +68,15 @@ class SettingsManager:
|
|||||||
def shutdown(self):
|
def shutdown(self):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
def format_cli_args(self, cliArgs):
|
||||||
|
if cliArgs is None:
|
||||||
|
return "{}"
|
||||||
|
if isinstance(cliArgs, Namespace):
|
||||||
|
args = vars(cliArgs)
|
||||||
|
else:
|
||||||
|
args = vars(cliArgs) if hasattr(cliArgs, "__dict__") else {}
|
||||||
|
return str({key: args[key] for key in sorted(args)})
|
||||||
|
|
||||||
def get_binding_backup(self):
|
def get_binding_backup(self):
|
||||||
return self.bindingsBackup.copy()
|
return self.bindingsBackup.copy()
|
||||||
|
|
||||||
@@ -644,6 +654,11 @@ class SettingsManager:
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
environment["runtime"]["DebugManager"].initialize(environment)
|
environment["runtime"]["DebugManager"].initialize(environment)
|
||||||
|
environment["runtime"]["DebugManager"].write_debug_out(
|
||||||
|
"Fenrir startup CLI arguments: " + self.format_cli_args(cliArgs),
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
|
|
||||||
if cliArgs.force_all_screens:
|
if cliArgs.force_all_screens:
|
||||||
environment["runtime"]["force_all_screens"] = True
|
environment["runtime"]["force_all_screens"] = True
|
||||||
|
|||||||
@@ -164,7 +164,7 @@ class SpeechHistoryManager:
|
|||||||
str([1, ["KEY_KPENTER"]]): "SPEECH_HISTORY_COPY",
|
str([1, ["KEY_KPENTER"]]): "SPEECH_HISTORY_COPY",
|
||||||
str([1, ["KEY_ESC"]]): "SPEECH_HISTORY_CLOSE",
|
str([1, ["KEY_ESC"]]): "SPEECH_HISTORY_CLOSE",
|
||||||
}
|
}
|
||||||
self.env["rawBindings"] = {
|
modal_raw_bindings = {
|
||||||
str([1, ["KEY_UP"]]): [1, ["KEY_UP"]],
|
str([1, ["KEY_UP"]]): [1, ["KEY_UP"]],
|
||||||
str([1, ["KEY_DOWN"]]): [1, ["KEY_DOWN"]],
|
str([1, ["KEY_DOWN"]]): [1, ["KEY_DOWN"]],
|
||||||
str([1, ["KEY_SPACE"]]): [1, ["KEY_SPACE"]],
|
str([1, ["KEY_SPACE"]]): [1, ["KEY_SPACE"]],
|
||||||
@@ -172,6 +172,9 @@ class SpeechHistoryManager:
|
|||||||
str([1, ["KEY_KPENTER"]]): [1, ["KEY_KPENTER"]],
|
str([1, ["KEY_KPENTER"]]): [1, ["KEY_KPENTER"]],
|
||||||
str([1, ["KEY_ESC"]]): [1, ["KEY_ESC"]],
|
str([1, ["KEY_ESC"]]): [1, ["KEY_ESC"]],
|
||||||
}
|
}
|
||||||
|
self.env["rawBindings"] = self.raw_bindings_backup.copy()
|
||||||
|
self.env["rawBindings"].update(modal_raw_bindings)
|
||||||
|
self._refresh_input_bindings()
|
||||||
|
|
||||||
def _restore_bindings(self):
|
def _restore_bindings(self):
|
||||||
if self.bindings_backup is not None:
|
if self.bindings_backup is not None:
|
||||||
@@ -180,3 +183,21 @@ class SpeechHistoryManager:
|
|||||||
self.env["rawBindings"] = self.raw_bindings_backup
|
self.env["rawBindings"] = self.raw_bindings_backup
|
||||||
self.bindings_backup = None
|
self.bindings_backup = None
|
||||||
self.raw_bindings_backup = None
|
self.raw_bindings_backup = None
|
||||||
|
self._reset_input_state()
|
||||||
|
self._refresh_input_bindings()
|
||||||
|
|
||||||
|
def _reset_input_state(self):
|
||||||
|
try:
|
||||||
|
self.env["runtime"]["InputManager"].reset_input_state()
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
|
||||||
|
def _refresh_input_bindings(self):
|
||||||
|
try:
|
||||||
|
refresh_grabs = getattr(
|
||||||
|
self.env["runtime"]["InputDriver"], "refresh_grabs", None
|
||||||
|
)
|
||||||
|
if refresh_grabs:
|
||||||
|
refresh_grabs(force=True)
|
||||||
|
except Exception:
|
||||||
|
pass
|
||||||
|
|||||||
@@ -132,13 +132,6 @@ class TabCompletionManager:
|
|||||||
if candidate_text:
|
if candidate_text:
|
||||||
return self._clean_text(candidate_text)
|
return self._clean_text(candidate_text)
|
||||||
|
|
||||||
delta_text = self.env["screen"]["new_delta"]
|
|
||||||
if (
|
|
||||||
delta_text
|
|
||||||
and not self.env["screen"].get("new_delta_is_typing", False)
|
|
||||||
):
|
|
||||||
return self._clean_text(delta_text)
|
|
||||||
|
|
||||||
return ""
|
return ""
|
||||||
|
|
||||||
def _get_cursor_line_inserted_text(
|
def _get_cursor_line_inserted_text(
|
||||||
@@ -184,26 +177,19 @@ class TabCompletionManager:
|
|||||||
return "".join(inserted_parts)
|
return "".join(inserted_parts)
|
||||||
|
|
||||||
def _get_candidate_text(self, old_lines, new_lines, cursor_y):
|
def _get_candidate_text(self, old_lines, new_lines, cursor_y):
|
||||||
if len(old_lines) != len(new_lines):
|
|
||||||
return self._get_inserted_lines(old_lines, new_lines, cursor_y)
|
|
||||||
|
|
||||||
changed_lines = []
|
|
||||||
old_cursor_line = (
|
old_cursor_line = (
|
||||||
old_lines[cursor_y].strip() if cursor_y < len(old_lines) else ""
|
old_lines[cursor_y].strip() if cursor_y < len(old_lines) else ""
|
||||||
)
|
)
|
||||||
for index, old_line in enumerate(old_lines):
|
return self._get_inserted_lines(
|
||||||
if index == cursor_y:
|
old_lines,
|
||||||
continue
|
new_lines,
|
||||||
if index < len(new_lines) and old_line != new_lines[index]:
|
self.env["screen"]["new_cursor"]["y"],
|
||||||
if new_lines[index].strip() == old_cursor_line:
|
old_cursor_line,
|
||||||
continue
|
|
||||||
changed_lines.append(new_lines[index])
|
|
||||||
|
|
||||||
return "\n".join(
|
|
||||||
line.rstrip() for line in changed_lines if line.strip()
|
|
||||||
)
|
)
|
||||||
|
|
||||||
def _get_inserted_lines(self, old_lines, new_lines, cursor_y):
|
def _get_inserted_lines(
|
||||||
|
self, old_lines, new_lines, new_cursor_y, old_cursor_line
|
||||||
|
):
|
||||||
matcher = difflib.SequenceMatcher(
|
matcher = difflib.SequenceMatcher(
|
||||||
None, old_lines, new_lines, autojunk=False
|
None, old_lines, new_lines, autojunk=False
|
||||||
)
|
)
|
||||||
@@ -217,10 +203,15 @@ class TabCompletionManager:
|
|||||||
) in matcher.get_opcodes():
|
) in matcher.get_opcodes():
|
||||||
if tag not in ["insert", "replace"]:
|
if tag not in ["insert", "replace"]:
|
||||||
continue
|
continue
|
||||||
if new_end <= cursor_y:
|
if new_start > new_cursor_y:
|
||||||
|
continue
|
||||||
|
if tag == "replace" and any(
|
||||||
|
line.strip() for line in old_lines[old_start:old_end]
|
||||||
|
):
|
||||||
continue
|
continue
|
||||||
for line in new_lines[new_start:new_end]:
|
for line in new_lines[new_start:new_end]:
|
||||||
if line.strip():
|
stripped_line = line.strip()
|
||||||
|
if stripped_line and stripped_line != old_cursor_line:
|
||||||
inserted_lines.append(line.rstrip())
|
inserted_lines.append(line.rstrip())
|
||||||
return "\n".join(inserted_lines)
|
return "\n".join(inserted_lines)
|
||||||
|
|
||||||
|
|||||||
@@ -4,5 +4,5 @@
|
|||||||
# Fenrir TTY screen reader
|
# Fenrir TTY screen reader
|
||||||
# By Chrys, Storm Dragon, and contributors.
|
# By Chrys, Storm Dragon, and contributors.
|
||||||
|
|
||||||
version = "2026.05.21"
|
version = "2026.06.01"
|
||||||
code_name = "testing"
|
code_name = "master"
|
||||||
|
|||||||
@@ -162,6 +162,7 @@ class driver(inputDriver):
|
|||||||
self.fenrir_keys = set()
|
self.fenrir_keys = set()
|
||||||
self.failed_grabs = 0
|
self.failed_grabs = 0
|
||||||
self.modifier_state = 0
|
self.modifier_state = 0
|
||||||
|
self.modifier_interrupt_state = 0
|
||||||
|
|
||||||
def initialize(self, environment):
|
def initialize(self, environment):
|
||||||
self.env = environment
|
self.env = environment
|
||||||
@@ -194,6 +195,7 @@ class driver(inputDriver):
|
|||||||
)
|
)
|
||||||
self.num_lock_mask = self.find_num_lock_mask()
|
self.num_lock_mask = self.find_num_lock_mask()
|
||||||
self.refresh_modifier_state()
|
self.refresh_modifier_state()
|
||||||
|
self.modifier_interrupt_state = self.modifier_state
|
||||||
self.refresh_interesting_keys()
|
self.refresh_interesting_keys()
|
||||||
self.refresh_grabs(force=True)
|
self.refresh_grabs(force=True)
|
||||||
self.env["runtime"]["ProcessManager"].add_custom_event_thread(
|
self.env["runtime"]["ProcessManager"].add_custom_event_thread(
|
||||||
@@ -274,6 +276,7 @@ class driver(inputDriver):
|
|||||||
while active.value:
|
while active.value:
|
||||||
try:
|
try:
|
||||||
self.refresh_grabs()
|
self.refresh_grabs()
|
||||||
|
self.poll_modifier_interrupt_keys()
|
||||||
if not self.display.pending_events():
|
if not self.display.pending_events():
|
||||||
time.sleep(0.01)
|
time.sleep(0.01)
|
||||||
continue
|
continue
|
||||||
@@ -371,6 +374,56 @@ class driver(inputDriver):
|
|||||||
"event_x_time": getattr(event, "time", X.CurrentTime),
|
"event_x_time": getattr(event, "time", X.CurrentTime),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
def poll_modifier_interrupt_keys(self):
|
||||||
|
if not self.active or not self.should_poll_modifier_interrupt_keys():
|
||||||
|
return
|
||||||
|
try:
|
||||||
|
pointer = self.root.query_pointer()
|
||||||
|
current_state = getattr(pointer, "mask", 0)
|
||||||
|
except Exception:
|
||||||
|
return
|
||||||
|
previous_state = self.modifier_interrupt_state
|
||||||
|
self.modifier_interrupt_state = current_state
|
||||||
|
self.modifier_state = current_state
|
||||||
|
for key_name, modifier_mask in self.interrupt_modifier_masks():
|
||||||
|
if current_state & modifier_mask and not previous_state & modifier_mask:
|
||||||
|
self.interrupt_output_on_modifier_key(key_name)
|
||||||
|
|
||||||
|
def should_poll_modifier_interrupt_keys(self):
|
||||||
|
try:
|
||||||
|
settings_manager = self.env["runtime"]["SettingsManager"]
|
||||||
|
except Exception:
|
||||||
|
return False
|
||||||
|
if not settings_manager.get_setting_as_bool(
|
||||||
|
"keyboard", "interrupt_on_key_press"
|
||||||
|
):
|
||||||
|
return False
|
||||||
|
return (
|
||||||
|
settings_manager.get_setting(
|
||||||
|
"keyboard", "interrupt_on_key_press_filter"
|
||||||
|
).strip()
|
||||||
|
== ""
|
||||||
|
)
|
||||||
|
|
||||||
|
def interrupt_modifier_masks(self):
|
||||||
|
return [
|
||||||
|
("KEY_CTRL", X.ControlMask),
|
||||||
|
("KEY_SHIFT", X.ShiftMask),
|
||||||
|
("KEY_ALT", X.Mod1Mask),
|
||||||
|
]
|
||||||
|
|
||||||
|
def interrupt_output_on_modifier_key(self, key_name):
|
||||||
|
try:
|
||||||
|
self.env["runtime"]["OutputManager"].interrupt_output_async()
|
||||||
|
except Exception as e:
|
||||||
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
|
"x11Driver modifier interrupt failed for "
|
||||||
|
+ key_name
|
||||||
|
+ ": "
|
||||||
|
+ str(e),
|
||||||
|
debug.DebugLevel.ERROR,
|
||||||
|
)
|
||||||
|
|
||||||
def refresh_modifier_state(self):
|
def refresh_modifier_state(self):
|
||||||
try:
|
try:
|
||||||
pointer = self.root.query_pointer()
|
pointer = self.root.query_pointer()
|
||||||
|
|||||||
@@ -333,10 +333,79 @@ class driver(screenDriver):
|
|||||||
def handle_stdin_input(self, msg_bytes, event_queue):
|
def handle_stdin_input(self, msg_bytes, event_queue):
|
||||||
if self.synthesize_backspace_shortcut(msg_bytes, event_queue):
|
if self.synthesize_backspace_shortcut(msg_bytes, event_queue):
|
||||||
return
|
return
|
||||||
|
if self.handle_vmenu_stdin_input(msg_bytes, event_queue):
|
||||||
|
return
|
||||||
self.record_stdin_keypress(msg_bytes)
|
self.record_stdin_keypress(msg_bytes)
|
||||||
self.interrupt_output_on_stdin_input(msg_bytes)
|
self.interrupt_output_on_stdin_input(msg_bytes)
|
||||||
self.inject_text_to_screen(msg_bytes)
|
self.inject_text_to_screen(msg_bytes)
|
||||||
|
|
||||||
|
def handle_vmenu_stdin_input(self, msg_bytes, event_queue):
|
||||||
|
if not self.is_vmenu_active():
|
||||||
|
return False
|
||||||
|
key_name = self.vmenu_stdin_key_name(msg_bytes)
|
||||||
|
if key_name and not self.vmenu_key_already_handled(key_name):
|
||||||
|
self.queue_keypress(key_name, event_queue)
|
||||||
|
return True
|
||||||
|
|
||||||
|
def is_vmenu_active(self):
|
||||||
|
try:
|
||||||
|
return self.env["runtime"]["VmenuManager"].get_active()
|
||||||
|
except Exception:
|
||||||
|
return False
|
||||||
|
|
||||||
|
def vmenu_stdin_key_name(self, msg_bytes):
|
||||||
|
key_map = {
|
||||||
|
b"\x1b": "KEY_ESC",
|
||||||
|
b"\x1b[A": "KEY_UP",
|
||||||
|
b"\x1b[B": "KEY_DOWN",
|
||||||
|
b"\x1b[C": "KEY_RIGHT",
|
||||||
|
b"\x1b[D": "KEY_LEFT",
|
||||||
|
b"\x1b[5~": "KEY_PAGEUP",
|
||||||
|
b"\x1b[6~": "KEY_PAGEDOWN",
|
||||||
|
b"\r": "KEY_ENTER",
|
||||||
|
b"\n": "KEY_ENTER",
|
||||||
|
b" ": "KEY_SPACE",
|
||||||
|
}
|
||||||
|
if msg_bytes in key_map:
|
||||||
|
return key_map[msg_bytes]
|
||||||
|
if len(msg_bytes) != 1:
|
||||||
|
return None
|
||||||
|
char = chr(msg_bytes[0])
|
||||||
|
if "a" <= char <= "z" or "A" <= char <= "Z":
|
||||||
|
return "KEY_" + char.upper()
|
||||||
|
return None
|
||||||
|
|
||||||
|
def vmenu_key_already_handled(self, key_name):
|
||||||
|
try:
|
||||||
|
return key_name in self.env["input"]["curr_input"]
|
||||||
|
except Exception:
|
||||||
|
return False
|
||||||
|
|
||||||
|
def queue_keypress(self, key_name, event_queue):
|
||||||
|
event_time = time.time()
|
||||||
|
for event_state in [1, 0]:
|
||||||
|
try:
|
||||||
|
event_queue.put(
|
||||||
|
{
|
||||||
|
"Type": FenrirEventType.keyboard_input,
|
||||||
|
"data": {
|
||||||
|
"event_name": key_name,
|
||||||
|
"event_value": 0,
|
||||||
|
"event_sec": int(event_time),
|
||||||
|
"event_usec": int((event_time % 1) * 1000000),
|
||||||
|
"event_state": event_state,
|
||||||
|
"event_type": 0,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
block=False,
|
||||||
|
)
|
||||||
|
except Full:
|
||||||
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
|
"ptyDriver queue_keypress: Event queue full, dropping "
|
||||||
|
+ key_name,
|
||||||
|
debug.DebugLevel.WARNING,
|
||||||
|
)
|
||||||
|
|
||||||
def record_stdin_keypress(self, msg_bytes):
|
def record_stdin_keypress(self, msg_bytes):
|
||||||
if msg_bytes != b"\t":
|
if msg_bytes != b"\t":
|
||||||
return
|
return
|
||||||
|
|||||||
@@ -4,7 +4,6 @@
|
|||||||
# Fenrir TTY screen reader
|
# Fenrir TTY screen reader
|
||||||
# By Chrys, Storm Dragon, and contributors.
|
# By Chrys, Storm Dragon, and contributors.
|
||||||
|
|
||||||
import glob
|
|
||||||
import os
|
import os
|
||||||
import termios
|
import termios
|
||||||
import threading
|
import threading
|
||||||
@@ -43,14 +42,22 @@ class hardware_serial_driver(speech_driver):
|
|||||||
self.env = environment
|
self.env = environment
|
||||||
self._is_initialized = False
|
self._is_initialized = False
|
||||||
settings_manager = self.env["runtime"]["SettingsManager"]
|
settings_manager = self.env["runtime"]["SettingsManager"]
|
||||||
self.device = settings_manager.get_setting(
|
self.device = self._clean_device_setting(
|
||||||
"speech", "hardware_device"
|
settings_manager.get_setting("speech", "hardware_device")
|
||||||
)
|
)
|
||||||
self.baud_rate = settings_manager.get_setting_as_int(
|
self.baud_rate = settings_manager.get_setting_as_int(
|
||||||
"speech", "hardware_baud_rate"
|
"speech", "hardware_baud_rate"
|
||||||
)
|
)
|
||||||
|
self._debug(
|
||||||
|
"Hardware speech initialize: "
|
||||||
|
f"requested_device={self.device}, baud_rate={self.baud_rate}",
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
self._open_serial_port()
|
self._open_serial_port()
|
||||||
self._is_initialized = self.serial_port is not None
|
self._is_initialized = self.serial_port is not None
|
||||||
|
if not self._is_initialized:
|
||||||
|
raise RuntimeError("hardware speech device is not available")
|
||||||
if self._is_initialized:
|
if self._is_initialized:
|
||||||
self._stop_worker = False
|
self._stop_worker = False
|
||||||
self.worker_thread = threading.Thread(
|
self.worker_thread = threading.Thread(
|
||||||
@@ -58,6 +65,12 @@ class hardware_serial_driver(speech_driver):
|
|||||||
)
|
)
|
||||||
self.worker_thread.start()
|
self.worker_thread.start()
|
||||||
|
|
||||||
|
def _clean_device_setting(self, device):
|
||||||
|
if not isinstance(device, str):
|
||||||
|
return ""
|
||||||
|
device = device.split("#", 1)[0].split(";", 1)[0].strip()
|
||||||
|
return device
|
||||||
|
|
||||||
def shutdown(self):
|
def shutdown(self):
|
||||||
if not self._is_initialized:
|
if not self._is_initialized:
|
||||||
return
|
return
|
||||||
@@ -76,6 +89,12 @@ class hardware_serial_driver(speech_driver):
|
|||||||
self.cancel()
|
self.cancel()
|
||||||
if not isinstance(text, str) or text == "":
|
if not isinstance(text, str) or text == "":
|
||||||
return
|
return
|
||||||
|
self._debug(
|
||||||
|
"Hardware speech queued text: "
|
||||||
|
f"{len(text)} chars, queue_size={self.text_queue.qsize()}",
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
self.text_queue.put(text)
|
self.text_queue.put(text)
|
||||||
|
|
||||||
def cancel(self):
|
def cancel(self):
|
||||||
@@ -83,7 +102,7 @@ class hardware_serial_driver(speech_driver):
|
|||||||
return
|
return
|
||||||
self.clear_buffer()
|
self.clear_buffer()
|
||||||
if self.cancel_command:
|
if self.cancel_command:
|
||||||
self._write_bytes(self.cancel_command)
|
self._write_bytes(self.cancel_command, "cancel")
|
||||||
|
|
||||||
def clear_buffer(self):
|
def clear_buffer(self):
|
||||||
if not self._is_initialized:
|
if not self._is_initialized:
|
||||||
@@ -95,37 +114,58 @@ class hardware_serial_driver(speech_driver):
|
|||||||
return
|
return
|
||||||
if not isinstance(rate, float):
|
if not isinstance(rate, float):
|
||||||
return
|
return
|
||||||
self._write_bytes(self._rate_command(rate))
|
self._write_bytes(self._rate_command(rate), "rate")
|
||||||
|
|
||||||
def set_pitch(self, pitch):
|
def set_pitch(self, pitch):
|
||||||
if not self._is_initialized:
|
if not self._is_initialized:
|
||||||
return
|
return
|
||||||
if not isinstance(pitch, float):
|
if not isinstance(pitch, float):
|
||||||
return
|
return
|
||||||
self._write_bytes(self._pitch_command(pitch))
|
self._write_bytes(self._pitch_command(pitch), "pitch")
|
||||||
|
|
||||||
def set_volume(self, volume):
|
def set_volume(self, volume):
|
||||||
if not self._is_initialized:
|
if not self._is_initialized:
|
||||||
return
|
return
|
||||||
if not isinstance(volume, float):
|
if not isinstance(volume, float):
|
||||||
return
|
return
|
||||||
self._write_bytes(self._volume_command(volume))
|
self._write_bytes(self._volume_command(volume), "volume")
|
||||||
|
|
||||||
def _worker(self):
|
def _worker(self):
|
||||||
while not self._stop_worker:
|
while not self._stop_worker:
|
||||||
text = self.text_queue.get()
|
text = self.text_queue.get()
|
||||||
if text is None:
|
if text is None:
|
||||||
return
|
return
|
||||||
self._write_bytes(self._speak_bytes(text))
|
try:
|
||||||
|
data = self._speak_bytes(text)
|
||||||
|
self._debug(
|
||||||
|
"Hardware speech worker prepared speech bytes: "
|
||||||
|
f"{len(data)} bytes",
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
|
self._write_bytes(data, "speech")
|
||||||
|
except Exception as error:
|
||||||
|
self._debug(
|
||||||
|
f"Hardware speech worker failed: {error}",
|
||||||
|
debug.DebugLevel.ERROR,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
|
|
||||||
def _open_serial_port(self):
|
def _open_serial_port(self):
|
||||||
device = self._resolve_device(self.device)
|
if not self.device or self.device == "auto":
|
||||||
if not device:
|
|
||||||
self._debug(
|
self._debug(
|
||||||
"Hardware speech device not found",
|
"Hardware speech requires an explicit serial device",
|
||||||
debug.DebugLevel.ERROR,
|
debug.DebugLevel.ERROR,
|
||||||
|
on_any_level=True,
|
||||||
)
|
)
|
||||||
return
|
return
|
||||||
|
|
||||||
|
port = self._open_configured_serial_port(self.device)
|
||||||
|
if port is not None:
|
||||||
|
self._activate_serial_port(self.device, port)
|
||||||
|
|
||||||
|
def _open_configured_serial_port(self, device):
|
||||||
|
port = None
|
||||||
try:
|
try:
|
||||||
port = os.open(device, os.O_RDWR | os.O_NOCTTY)
|
port = os.open(device, os.O_RDWR | os.O_NOCTTY)
|
||||||
tty.setraw(port)
|
tty.setraw(port)
|
||||||
@@ -138,52 +178,73 @@ class hardware_serial_driver(speech_driver):
|
|||||||
attrs[6][termios.VTIME] = 0
|
attrs[6][termios.VTIME] = 0
|
||||||
attrs[0] &= ~(termios.IXON | termios.IXOFF | termios.IXANY)
|
attrs[0] &= ~(termios.IXON | termios.IXOFF | termios.IXANY)
|
||||||
termios.tcsetattr(port, termios.TCSANOW, attrs)
|
termios.tcsetattr(port, termios.TCSANOW, attrs)
|
||||||
self.serial_port = port
|
return port
|
||||||
self.device = device
|
except (OSError, termios.error) as error:
|
||||||
except OSError as error:
|
self._close_port(port)
|
||||||
self._debug(
|
self._debug(
|
||||||
f"Hardware speech device open failed: {device}: {error}",
|
f"Hardware speech device open failed: {device}: {error}",
|
||||||
debug.DebugLevel.ERROR,
|
debug.DebugLevel.ERROR,
|
||||||
|
on_any_level=True,
|
||||||
)
|
)
|
||||||
self.serial_port = None
|
return None
|
||||||
|
|
||||||
|
def _activate_serial_port(self, device, port):
|
||||||
|
self.serial_port = port
|
||||||
|
self.device = device
|
||||||
|
self._debug(
|
||||||
|
"Hardware speech device opened: "
|
||||||
|
f"{device}, baud_rate={self.baud_rate}",
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
|
|
||||||
def _close_serial_port(self):
|
def _close_serial_port(self):
|
||||||
with self.lock:
|
with self.lock:
|
||||||
if self.serial_port is None:
|
if self.serial_port is None:
|
||||||
return
|
return
|
||||||
try:
|
self._close_port(self.serial_port)
|
||||||
os.close(self.serial_port)
|
self.serial_port = None
|
||||||
except OSError as error:
|
|
||||||
self._debug(
|
|
||||||
f"Hardware speech device close failed: {error}",
|
|
||||||
debug.DebugLevel.WARNING,
|
|
||||||
)
|
|
||||||
finally:
|
|
||||||
self.serial_port = None
|
|
||||||
|
|
||||||
def _write_bytes(self, data):
|
def _close_port(self, port):
|
||||||
|
if port is None:
|
||||||
|
return
|
||||||
|
try:
|
||||||
|
os.close(port)
|
||||||
|
except OSError as error:
|
||||||
|
self._debug(
|
||||||
|
f"Hardware speech device close failed: {error}",
|
||||||
|
debug.DebugLevel.WARNING,
|
||||||
|
)
|
||||||
|
|
||||||
|
def _write_bytes(self, data, description="data"):
|
||||||
if not data:
|
if not data:
|
||||||
return
|
return
|
||||||
with self.lock:
|
with self.lock:
|
||||||
if self.serial_port is None:
|
if self.serial_port is None:
|
||||||
return
|
return
|
||||||
try:
|
try:
|
||||||
os.write(self.serial_port, data)
|
total_written = 0
|
||||||
|
while total_written < len(data):
|
||||||
|
bytes_written = os.write(
|
||||||
|
self.serial_port, data[total_written:]
|
||||||
|
)
|
||||||
|
if bytes_written == 0:
|
||||||
|
raise OSError("serial write returned 0 bytes")
|
||||||
|
total_written += bytes_written
|
||||||
|
preview = self._format_bytes_preview(data)
|
||||||
|
self._debug(
|
||||||
|
"Hardware speech wrote "
|
||||||
|
f"{total_written} {description} bytes: {preview}",
|
||||||
|
debug.DebugLevel.INFO,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
except OSError as error:
|
except OSError as error:
|
||||||
self._debug(
|
self._debug(
|
||||||
f"Hardware speech write failed: {error}",
|
f"Hardware speech write failed: {error}",
|
||||||
debug.DebugLevel.ERROR,
|
debug.DebugLevel.ERROR,
|
||||||
|
on_any_level=True,
|
||||||
)
|
)
|
||||||
|
|
||||||
def _resolve_device(self, device):
|
|
||||||
if device and device != "auto":
|
|
||||||
return device
|
|
||||||
for pattern in ("/dev/ttyACM*", "/dev/ttyUSB*"):
|
|
||||||
matches = sorted(glob.glob(pattern))
|
|
||||||
if matches:
|
|
||||||
return matches[0]
|
|
||||||
return ""
|
|
||||||
|
|
||||||
def _termios_baud_rate(self, baud_rate):
|
def _termios_baud_rate(self, baud_rate):
|
||||||
baud_name = f"B{baud_rate}"
|
baud_name = f"B{baud_rate}"
|
||||||
if hasattr(termios, baud_name):
|
if hasattr(termios, baud_name):
|
||||||
@@ -205,10 +266,23 @@ class hardware_serial_driver(speech_driver):
|
|||||||
value = max(0.0, min(1.0, value))
|
value = max(0.0, min(1.0, value))
|
||||||
return int(round(minimum + value * (maximum - minimum)))
|
return int(round(minimum + value * (maximum - minimum)))
|
||||||
|
|
||||||
def _debug(self, message, level):
|
def _format_bytes_preview(self, data, limit=32):
|
||||||
|
preview = data[:limit]
|
||||||
|
hex_preview = " ".join(f"{byte:02x}" for byte in preview)
|
||||||
|
ascii_preview = "".join(
|
||||||
|
chr(byte) if 0x20 <= byte <= 0x7E else "."
|
||||||
|
for byte in preview
|
||||||
|
)
|
||||||
|
suffix = "" if len(data) <= limit else " ..."
|
||||||
|
return (
|
||||||
|
f"hex=[{hex_preview}{suffix}] "
|
||||||
|
f"ascii=[{ascii_preview}{suffix}]"
|
||||||
|
)
|
||||||
|
|
||||||
|
def _debug(self, message, level, on_any_level=False):
|
||||||
try:
|
try:
|
||||||
self.env["runtime"]["DebugManager"].write_debug_out(
|
self.env["runtime"]["DebugManager"].write_debug_out(
|
||||||
message, level
|
message, level, on_any_level=on_any_level
|
||||||
)
|
)
|
||||||
except Exception:
|
except Exception:
|
||||||
pass
|
pass
|
||||||
|
|||||||
@@ -47,7 +47,6 @@ def get_up_char(curr_x, curr_y, curr_text):
|
|||||||
curr_y -= 1
|
curr_y -= 1
|
||||||
if curr_y < 0:
|
if curr_y < 0:
|
||||||
curr_y = 0
|
curr_y = 0
|
||||||
else:
|
|
||||||
end_of_screen = True
|
end_of_screen = True
|
||||||
curr_char = ""
|
curr_char = ""
|
||||||
if not end_of_screen:
|
if not end_of_screen:
|
||||||
@@ -63,7 +62,6 @@ def get_down_char(curr_x, curr_y, curr_text):
|
|||||||
curr_y += 1
|
curr_y += 1
|
||||||
if curr_y >= len(wrapped_lines):
|
if curr_y >= len(wrapped_lines):
|
||||||
curr_y = len(wrapped_lines) - 1
|
curr_y = len(wrapped_lines) - 1
|
||||||
else:
|
|
||||||
end_of_screen = True
|
end_of_screen = True
|
||||||
curr_char = ""
|
curr_char = ""
|
||||||
if not end_of_screen:
|
if not end_of_screen:
|
||||||
|
|||||||
@@ -0,0 +1,59 @@
|
|||||||
|
from fenrirscreenreader.core.debugManager import DebugManager
|
||||||
|
|
||||||
|
|
||||||
|
def test_default_debug_file_uses_flat_name(tmp_path, monkeypatch):
|
||||||
|
monkeypatch.setattr(DebugManager, "DEFAULT_LOG_DIR", str(tmp_path))
|
||||||
|
manager = DebugManager()
|
||||||
|
try:
|
||||||
|
manager.open_debug_file()
|
||||||
|
|
||||||
|
assert manager.get_debug_file() == str(tmp_path / "fenrir.log")
|
||||||
|
assert (tmp_path / "fenrir.log").exists()
|
||||||
|
finally:
|
||||||
|
manager.close_debug_file()
|
||||||
|
|
||||||
|
|
||||||
|
def test_default_debug_file_uses_next_number_when_locked(
|
||||||
|
tmp_path, monkeypatch
|
||||||
|
):
|
||||||
|
monkeypatch.setattr(DebugManager, "DEFAULT_LOG_DIR", str(tmp_path))
|
||||||
|
first_manager = DebugManager()
|
||||||
|
second_manager = DebugManager()
|
||||||
|
try:
|
||||||
|
first_manager.open_debug_file()
|
||||||
|
second_manager.open_debug_file()
|
||||||
|
|
||||||
|
assert first_manager.get_debug_file() == str(tmp_path / "fenrir.log")
|
||||||
|
assert second_manager.get_debug_file() == str(
|
||||||
|
tmp_path / "fenrir2.log"
|
||||||
|
)
|
||||||
|
assert (tmp_path / "fenrir2.log").exists()
|
||||||
|
finally:
|
||||||
|
second_manager.close_debug_file()
|
||||||
|
first_manager.close_debug_file()
|
||||||
|
|
||||||
|
|
||||||
|
def test_default_debug_file_reuses_unlocked_flat_name(tmp_path, monkeypatch):
|
||||||
|
monkeypatch.setattr(DebugManager, "DEFAULT_LOG_DIR", str(tmp_path))
|
||||||
|
first_manager = DebugManager()
|
||||||
|
second_manager = DebugManager()
|
||||||
|
try:
|
||||||
|
first_manager.open_debug_file()
|
||||||
|
first_manager.close_debug_file()
|
||||||
|
second_manager.open_debug_file()
|
||||||
|
|
||||||
|
assert second_manager.get_debug_file() == str(tmp_path / "fenrir.log")
|
||||||
|
finally:
|
||||||
|
second_manager.close_debug_file()
|
||||||
|
|
||||||
|
|
||||||
|
def test_explicit_debug_file_uses_exact_path(tmp_path):
|
||||||
|
debug_file = tmp_path / "custom.log"
|
||||||
|
manager = DebugManager(str(debug_file))
|
||||||
|
try:
|
||||||
|
manager.open_debug_file()
|
||||||
|
|
||||||
|
assert manager.get_debug_file() == str(debug_file)
|
||||||
|
assert debug_file.exists()
|
||||||
|
finally:
|
||||||
|
manager.close_debug_file()
|
||||||
@@ -22,6 +22,7 @@ def test_speech_history_plain_key_modal_command_is_dispatched():
|
|||||||
)
|
)
|
||||||
speech_history_manager = Mock(is_active=Mock(return_value=True))
|
speech_history_manager = Mock(is_active=Mock(return_value=True))
|
||||||
diff_review_manager = Mock(is_active=Mock(return_value=False))
|
diff_review_manager = Mock(is_active=Mock(return_value=False))
|
||||||
|
vmenu_manager = Mock(get_active=Mock(return_value=False))
|
||||||
|
|
||||||
manager.environment = {
|
manager.environment = {
|
||||||
"input": {
|
"input": {
|
||||||
@@ -32,6 +33,7 @@ def test_speech_history_plain_key_modal_command_is_dispatched():
|
|||||||
"runtime": {
|
"runtime": {
|
||||||
"InputManager": input_manager,
|
"InputManager": input_manager,
|
||||||
"EventManager": event_manager,
|
"EventManager": event_manager,
|
||||||
|
"VmenuManager": vmenu_manager,
|
||||||
"DiffReviewManager": diff_review_manager,
|
"DiffReviewManager": diff_review_manager,
|
||||||
"SpeechHistoryManager": speech_history_manager,
|
"SpeechHistoryManager": speech_history_manager,
|
||||||
},
|
},
|
||||||
@@ -42,3 +44,43 @@ def test_speech_history_plain_key_modal_command_is_dispatched():
|
|||||||
event_manager.put_to_event_queue.assert_called_once_with(
|
event_manager.put_to_event_queue.assert_called_once_with(
|
||||||
FenrirEventType.execute_command, "SPEECH_HISTORY_PREV"
|
FenrirEventType.execute_command, "SPEECH_HISTORY_PREV"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_vmenu_plain_key_modal_command_is_dispatched():
|
||||||
|
manager = FenrirManager.__new__(FenrirManager)
|
||||||
|
manager.modifierInput = False
|
||||||
|
manager.singleKeyCommand = False
|
||||||
|
manager.command = ""
|
||||||
|
|
||||||
|
event_manager = Mock(put_to_event_queue=Mock())
|
||||||
|
input_manager = Mock(
|
||||||
|
is_key_press=Mock(return_value=False),
|
||||||
|
no_key_pressed=Mock(return_value=False),
|
||||||
|
get_curr_shortcut=Mock(return_value=str([1, ["KEY_UP"]])),
|
||||||
|
get_command_for_shortcut=Mock(return_value="PREV_VMENU_ENTRY"),
|
||||||
|
)
|
||||||
|
vmenu_manager = Mock(get_active=Mock(return_value=True))
|
||||||
|
speech_history_manager = Mock(is_active=Mock(return_value=False))
|
||||||
|
diff_review_manager = Mock(is_active=Mock(return_value=False))
|
||||||
|
|
||||||
|
manager.environment = {
|
||||||
|
"input": {
|
||||||
|
"key_forward": 0,
|
||||||
|
"prev_input": ["KEY_UP"],
|
||||||
|
"curr_input": ["KEY_UP"],
|
||||||
|
},
|
||||||
|
"runtime": {
|
||||||
|
"InputManager": input_manager,
|
||||||
|
"EventManager": event_manager,
|
||||||
|
"VmenuManager": vmenu_manager,
|
||||||
|
"DiffReviewManager": diff_review_manager,
|
||||||
|
"SpeechHistoryManager": speech_history_manager,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
manager.detect_shortcut_command()
|
||||||
|
|
||||||
|
event_manager.put_to_event_queue.assert_called_once_with(
|
||||||
|
FenrirEventType.execute_command, "PREV_VMENU_ENTRY"
|
||||||
|
)
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
import os
|
import os
|
||||||
import select
|
import select
|
||||||
import time
|
import time
|
||||||
|
from unittest.mock import ANY
|
||||||
from unittest.mock import Mock
|
from unittest.mock import Mock
|
||||||
|
|
||||||
import pytest
|
import pytest
|
||||||
@@ -103,6 +104,67 @@ def test_litetalk_driver_writes_settings_and_cancel(serial_pair):
|
|||||||
speech_driver.shutdown()
|
speech_driver.shutdown()
|
||||||
|
|
||||||
|
|
||||||
|
def test_configured_device_supports_classic_serial(serial_pair):
|
||||||
|
master_fd, slave_name = serial_pair
|
||||||
|
speech_driver = litetalkDriver.driver()
|
||||||
|
speech_driver.initialize(build_environment(slave_name))
|
||||||
|
try:
|
||||||
|
assert speech_driver.device == slave_name
|
||||||
|
speech_driver.speak("Serial")
|
||||||
|
assert read_available(master_fd, 7) == b"Serial\r"
|
||||||
|
finally:
|
||||||
|
speech_driver.shutdown()
|
||||||
|
|
||||||
|
|
||||||
|
def test_configured_device_strips_inline_comment(serial_pair):
|
||||||
|
master_fd, slave_name = serial_pair
|
||||||
|
device_setting = f"{slave_name} # built-in serial port"
|
||||||
|
speech_driver = litetalkDriver.driver()
|
||||||
|
speech_driver.initialize(build_environment(device_setting))
|
||||||
|
try:
|
||||||
|
assert speech_driver.device == slave_name
|
||||||
|
speech_driver.speak("Specific")
|
||||||
|
assert read_available(master_fd, 9) == b"Specific\r"
|
||||||
|
finally:
|
||||||
|
speech_driver.shutdown()
|
||||||
|
|
||||||
|
|
||||||
|
def test_auto_device_is_rejected():
|
||||||
|
speech_driver = litetalkDriver.driver()
|
||||||
|
|
||||||
|
with pytest.raises(RuntimeError, match="hardware speech device"):
|
||||||
|
speech_driver.initialize(build_environment("auto"))
|
||||||
|
|
||||||
|
debug_manager = speech_driver.env["runtime"]["DebugManager"]
|
||||||
|
debug_manager.write_debug_out.assert_called_with(
|
||||||
|
"Hardware speech requires an explicit serial device",
|
||||||
|
ANY,
|
||||||
|
on_any_level=True,
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def test_hardware_driver_retries_partial_serial_writes(monkeypatch):
|
||||||
|
speech_driver = litetalkDriver.driver()
|
||||||
|
speech_driver.env = build_environment("/dev/ttyUSB0")
|
||||||
|
speech_driver.serial_port = 12
|
||||||
|
written_chunks = []
|
||||||
|
|
||||||
|
def fake_write(port, data):
|
||||||
|
assert port == 12
|
||||||
|
chunk = data[:2]
|
||||||
|
written_chunks.append(chunk)
|
||||||
|
return len(chunk)
|
||||||
|
|
||||||
|
monkeypatch.setattr(
|
||||||
|
"fenrirscreenreader.speechDriver.hardwareSerialDriver.os.write",
|
||||||
|
fake_write,
|
||||||
|
)
|
||||||
|
|
||||||
|
speech_driver._write_bytes(b"abcdef", "speech")
|
||||||
|
|
||||||
|
assert written_chunks == [b"ab", b"cd", b"ef"]
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize("driver_class", [doubletalkDriver, tripletalkDriver])
|
@pytest.mark.parametrize("driver_class", [doubletalkDriver, tripletalkDriver])
|
||||||
def test_litetalk_compatible_alias_drivers(driver_class, serial_pair):
|
def test_litetalk_compatible_alias_drivers(driver_class, serial_pair):
|
||||||
speech_driver, master_fd = initialized_driver(driver_class, serial_pair)
|
speech_driver, master_fd = initialized_driver(driver_class, serial_pair)
|
||||||
|
|||||||
@@ -39,3 +39,104 @@ def test_progress_detector_skips_typing_delta():
|
|||||||
|
|
||||||
command.is_real_progress_update.assert_not_called()
|
command.is_real_progress_update.assert_not_called()
|
||||||
command.detect_progress.assert_not_called()
|
command.detect_progress.assert_not_called()
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_progress_detector_allows_long_tqdm_transfer_delta():
|
||||||
|
progress_module = _load_progress_module()
|
||||||
|
command = progress_module.command()
|
||||||
|
sample = (
|
||||||
|
"88%|"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"█████████████████████████▊ "
|
||||||
|
"| 843M/954M [00:54<00:07, 15.2MB/s]"
|
||||||
|
)
|
||||||
|
command.env = {
|
||||||
|
"commandBuffer": {"progress_monitoring": True},
|
||||||
|
"runtime": {
|
||||||
|
"DebugManager": Mock(write_debug_out=Mock()),
|
||||||
|
"ScreenManager": Mock(is_screen_change=Mock(return_value=False)),
|
||||||
|
"CursorManager": Mock(is_cursor_vertical_move=Mock(return_value=False)),
|
||||||
|
},
|
||||||
|
"screen": {
|
||||||
|
"new_delta": sample,
|
||||||
|
"new_content_text": sample,
|
||||||
|
"old_cursor": {"x": 0, "y": 0},
|
||||||
|
"new_cursor": {"x": 0, "y": 0},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
assert len(sample) > 200
|
||||||
|
assert command.is_real_progress_update()
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_progress_detector_beeps_for_long_tqdm_transfer_delta():
|
||||||
|
progress_module = _load_progress_module()
|
||||||
|
command = progress_module.command()
|
||||||
|
sample = (
|
||||||
|
"90%|"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"████████████████████████████████████████████████████████████████"
|
||||||
|
"█████████████████████████████████████▍ "
|
||||||
|
"| 856M/954M [00:56<00:14, 6.78MB/s]"
|
||||||
|
)
|
||||||
|
command.env = {
|
||||||
|
"commandBuffer": {
|
||||||
|
"progress_monitoring": True,
|
||||||
|
"lastProgressValue": -1,
|
||||||
|
"lastProgressTime": 0,
|
||||||
|
},
|
||||||
|
"runtime": {
|
||||||
|
"DebugManager": Mock(write_debug_out=Mock()),
|
||||||
|
"ScreenManager": Mock(is_screen_change=Mock(return_value=False)),
|
||||||
|
"CursorManager": Mock(is_cursor_vertical_move=Mock(return_value=False)),
|
||||||
|
},
|
||||||
|
"screen": {
|
||||||
|
"new_delta": sample,
|
||||||
|
"new_delta_is_typing": False,
|
||||||
|
"new_content_text": sample,
|
||||||
|
"old_cursor": {"x": 0, "y": 0},
|
||||||
|
"new_cursor": {"x": 0, "y": 0},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
command.play_progress_tone = Mock()
|
||||||
|
|
||||||
|
command.run()
|
||||||
|
|
||||||
|
command.play_progress_tone.assert_called_once_with(90.0)
|
||||||
|
assert command.env["commandBuffer"]["lastProgressValue"] == 90.0
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_progress_detector_beeps_for_interruptible_status_without_ellipsis():
|
||||||
|
progress_module = _load_progress_module()
|
||||||
|
command = progress_module.command()
|
||||||
|
sample = "◦ Files: (1m 04s • esc to interrupt)"
|
||||||
|
command.env = {
|
||||||
|
"commandBuffer": {
|
||||||
|
"progress_monitoring": True,
|
||||||
|
"lastProgressValue": -1,
|
||||||
|
"lastProgressTime": 0,
|
||||||
|
},
|
||||||
|
"runtime": {
|
||||||
|
"DebugManager": Mock(write_debug_out=Mock()),
|
||||||
|
"ScreenManager": Mock(is_screen_change=Mock(return_value=False)),
|
||||||
|
"CursorManager": Mock(is_cursor_vertical_move=Mock(return_value=False)),
|
||||||
|
},
|
||||||
|
"screen": {
|
||||||
|
"new_delta": sample,
|
||||||
|
"new_delta_is_typing": False,
|
||||||
|
"new_content_text": sample,
|
||||||
|
"old_cursor": {"x": 0, "y": 0},
|
||||||
|
"new_cursor": {"x": 0, "y": 0},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
command.play_activity_beep = Mock()
|
||||||
|
|
||||||
|
command.run()
|
||||||
|
|
||||||
|
command.play_activity_beep.assert_called_once_with()
|
||||||
|
|||||||
@@ -160,6 +160,90 @@ def test_pty_plain_stdin_does_not_record_tab_keypress():
|
|||||||
pty_driver.inject_text_to_screen.assert_called_once_with(b"a")
|
pty_driver.inject_text_to_screen.assert_called_once_with(b"a")
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
@pytest.mark.parametrize(
|
||||||
|
("sequence", "key_name"),
|
||||||
|
[
|
||||||
|
(b"\x1b[A", "KEY_UP"),
|
||||||
|
(b"\x1b[B", "KEY_DOWN"),
|
||||||
|
(b"\x1b[C", "KEY_RIGHT"),
|
||||||
|
(b"\x1b[D", "KEY_LEFT"),
|
||||||
|
(b"\x1b[5~", "KEY_PAGEUP"),
|
||||||
|
(b"\x1b[6~", "KEY_PAGEDOWN"),
|
||||||
|
(b"\x1b", "KEY_ESC"),
|
||||||
|
(b"\r", "KEY_ENTER"),
|
||||||
|
(b" ", "KEY_SPACE"),
|
||||||
|
(b"a", "KEY_A"),
|
||||||
|
(b"Z", "KEY_Z"),
|
||||||
|
],
|
||||||
|
)
|
||||||
|
def test_pty_vmenu_stdin_is_consumed_and_synthesizes_key_events(
|
||||||
|
sequence,
|
||||||
|
key_name,
|
||||||
|
):
|
||||||
|
pty_driver = PtyDriver()
|
||||||
|
event_queue = Mock()
|
||||||
|
settings_manager = Mock()
|
||||||
|
settings_manager.get_setting_as_bool.return_value = False
|
||||||
|
pty_driver.env = {
|
||||||
|
"input": {"curr_input": []},
|
||||||
|
"runtime": {
|
||||||
|
"DebugManager": Mock(write_debug_out=Mock()),
|
||||||
|
"SettingsManager": settings_manager,
|
||||||
|
"VmenuManager": Mock(get_active=Mock(return_value=True)),
|
||||||
|
},
|
||||||
|
}
|
||||||
|
pty_driver.inject_text_to_screen = Mock()
|
||||||
|
|
||||||
|
pty_driver.handle_stdin_input(sequence, event_queue)
|
||||||
|
|
||||||
|
pty_driver.inject_text_to_screen.assert_not_called()
|
||||||
|
assert event_queue.put.call_count == 2
|
||||||
|
first_event = event_queue.put.call_args_list[0].args[0]
|
||||||
|
second_event = event_queue.put.call_args_list[1].args[0]
|
||||||
|
assert first_event["Type"] == FenrirEventType.keyboard_input
|
||||||
|
assert first_event["data"]["event_name"] == key_name
|
||||||
|
assert first_event["data"]["event_state"] == 1
|
||||||
|
assert second_event["data"]["event_name"] == key_name
|
||||||
|
assert second_event["data"]["event_state"] == 0
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_pty_vmenu_unknown_stdin_is_consumed_without_injection():
|
||||||
|
pty_driver = PtyDriver()
|
||||||
|
event_queue = Mock()
|
||||||
|
pty_driver.env = {
|
||||||
|
"input": {"curr_input": []},
|
||||||
|
"runtime": {
|
||||||
|
"VmenuManager": Mock(get_active=Mock(return_value=True)),
|
||||||
|
},
|
||||||
|
}
|
||||||
|
pty_driver.inject_text_to_screen = Mock()
|
||||||
|
|
||||||
|
pty_driver.handle_stdin_input(b"\x1b[1;5A", event_queue)
|
||||||
|
|
||||||
|
pty_driver.inject_text_to_screen.assert_not_called()
|
||||||
|
event_queue.put.assert_not_called()
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_pty_vmenu_stdin_does_not_duplicate_current_x11_key():
|
||||||
|
pty_driver = PtyDriver()
|
||||||
|
event_queue = Mock()
|
||||||
|
pty_driver.env = {
|
||||||
|
"input": {"curr_input": ["KEY_RIGHT"]},
|
||||||
|
"runtime": {
|
||||||
|
"VmenuManager": Mock(get_active=Mock(return_value=True)),
|
||||||
|
},
|
||||||
|
}
|
||||||
|
pty_driver.inject_text_to_screen = Mock()
|
||||||
|
|
||||||
|
pty_driver.handle_stdin_input(b"\x1b[C", event_queue)
|
||||||
|
|
||||||
|
pty_driver.inject_text_to_screen.assert_not_called()
|
||||||
|
event_queue.put.assert_not_called()
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.unit
|
@pytest.mark.unit
|
||||||
def test_pty_stdin_input_honors_interrupt_disabled():
|
def test_pty_stdin_input_honors_interrupt_disabled():
|
||||||
pty_driver = PtyDriver()
|
pty_driver = PtyDriver()
|
||||||
|
|||||||
@@ -0,0 +1,126 @@
|
|||||||
|
import importlib.util
|
||||||
|
from pathlib import Path
|
||||||
|
from unittest.mock import Mock
|
||||||
|
|
||||||
|
import pytest
|
||||||
|
|
||||||
|
from fenrirscreenreader.utils import char_utils
|
||||||
|
|
||||||
|
|
||||||
|
COMMANDS_DIR = (
|
||||||
|
Path(__file__).resolve().parents[2]
|
||||||
|
/ "src"
|
||||||
|
/ "fenrirscreenreader"
|
||||||
|
/ "commands"
|
||||||
|
/ "commands"
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
def load_command(name):
|
||||||
|
spec = importlib.util.spec_from_file_location(
|
||||||
|
f"fenrir_{name}", COMMANDS_DIR / f"{name}.py"
|
||||||
|
)
|
||||||
|
module = importlib.util.module_from_spec(spec)
|
||||||
|
spec.loader.exec_module(module)
|
||||||
|
return module.command()
|
||||||
|
|
||||||
|
|
||||||
|
def build_environment(cursor):
|
||||||
|
settings_manager = Mock()
|
||||||
|
settings_manager.get_setting_as_bool.return_value = True
|
||||||
|
output_manager = Mock()
|
||||||
|
cursor_manager = Mock()
|
||||||
|
cursor_manager.enter_review_mode_curr_text_cursor.return_value = None
|
||||||
|
cursor_manager.get_review_or_text_cursor.return_value = cursor
|
||||||
|
|
||||||
|
return {
|
||||||
|
"punctuation": {"PUNCTDICT": {" ": "space"}},
|
||||||
|
"screen": {
|
||||||
|
"newCursorReview": cursor.copy(),
|
||||||
|
"new_cursor": cursor.copy(),
|
||||||
|
"new_content_text": "abc\ndef",
|
||||||
|
},
|
||||||
|
"runtime": {
|
||||||
|
"AttributeManager": Mock(has_attributes=Mock(return_value=False)),
|
||||||
|
"CursorManager": cursor_manager,
|
||||||
|
"OutputManager": output_manager,
|
||||||
|
"SettingsManager": settings_manager,
|
||||||
|
"TableManager": Mock(is_table_mode=Mock(return_value=False)),
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
def run_command(name, cursor):
|
||||||
|
env = build_environment(cursor)
|
||||||
|
command = load_command(name)
|
||||||
|
command.initialize(env)
|
||||||
|
command.run()
|
||||||
|
return env["runtime"]["OutputManager"]
|
||||||
|
|
||||||
|
|
||||||
|
def boundary_call(output_manager):
|
||||||
|
return output_manager.present_text.call_args_list[-1]
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_previous_line_uses_start_of_screen_sound_at_top():
|
||||||
|
output_manager = run_command("review_prev_line", {"x": 0, "y": 0})
|
||||||
|
|
||||||
|
call = boundary_call(output_manager)
|
||||||
|
assert call.args[0] == "start of screen"
|
||||||
|
assert call.kwargs["sound_icon"] == "StartOfScreen"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_next_line_uses_end_of_screen_sound_at_bottom():
|
||||||
|
output_manager = run_command("review_next_line", {"x": 0, "y": 1})
|
||||||
|
|
||||||
|
call = boundary_call(output_manager)
|
||||||
|
assert call.args[0] == "end of screen"
|
||||||
|
assert call.kwargs["sound_icon"] == "EndOfScreen"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_previous_character_uses_start_of_screen_sound_at_top_left():
|
||||||
|
output_manager = run_command("review_prev_char", {"x": 0, "y": 0})
|
||||||
|
|
||||||
|
call = boundary_call(output_manager)
|
||||||
|
assert call.args[0] == "start of screen"
|
||||||
|
assert call.kwargs["sound_icon"] == "StartOfScreen"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_next_character_uses_end_of_screen_sound_at_bottom_right():
|
||||||
|
output_manager = run_command("review_next_char", {"x": 2, "y": 1})
|
||||||
|
|
||||||
|
call = boundary_call(output_manager)
|
||||||
|
assert call.args[0] == "end of screen"
|
||||||
|
assert call.kwargs["sound_icon"] == "EndOfScreen"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_vertical_character_navigation_reports_boundaries_only_at_edges():
|
||||||
|
assert char_utils.get_up_char(0, 1, "abc\ndef") == (
|
||||||
|
0,
|
||||||
|
0,
|
||||||
|
"a",
|
||||||
|
False,
|
||||||
|
)
|
||||||
|
assert char_utils.get_up_char(0, 0, "abc\ndef") == (
|
||||||
|
0,
|
||||||
|
0,
|
||||||
|
"",
|
||||||
|
True,
|
||||||
|
)
|
||||||
|
assert char_utils.get_down_char(0, 0, "abc\ndef") == (
|
||||||
|
0,
|
||||||
|
1,
|
||||||
|
"d",
|
||||||
|
False,
|
||||||
|
)
|
||||||
|
assert char_utils.get_down_char(0, 1, "abc\ndef") == (
|
||||||
|
0,
|
||||||
|
1,
|
||||||
|
"",
|
||||||
|
True,
|
||||||
|
)
|
||||||
@@ -5,6 +5,8 @@ Tests the _validate_setting_value method to ensure proper input validation
|
|||||||
for all configurable settings that could cause crashes or accessibility issues.
|
for all configurable settings that could cause crashes or accessibility issues.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
|
from argparse import Namespace
|
||||||
|
|
||||||
import pytest
|
import pytest
|
||||||
import sys
|
import sys
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
@@ -206,6 +208,30 @@ def test_focus_settings_define_tui_toggle():
|
|||||||
assert settings_data["focus"]["tui"] is False
|
assert settings_data["focus"]["tui"] is False
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
@pytest.mark.settings
|
||||||
|
def test_format_cli_args_reports_startup_flags_in_stable_order():
|
||||||
|
manager = SettingsManager()
|
||||||
|
cli_args = Namespace(
|
||||||
|
debug=True,
|
||||||
|
foreground=False,
|
||||||
|
force_all_screens=False,
|
||||||
|
ignore_screen=["7"],
|
||||||
|
options="speech#rate=1.2",
|
||||||
|
print=False,
|
||||||
|
setting="/tmp/settings.conf",
|
||||||
|
x11=True,
|
||||||
|
x11_window_id="0x123",
|
||||||
|
)
|
||||||
|
|
||||||
|
assert manager.format_cli_args(cli_args) == (
|
||||||
|
"{'debug': True, 'force_all_screens': False, 'foreground': False, "
|
||||||
|
"'ignore_screen': ['7'], 'options': 'speech#rate=1.2', "
|
||||||
|
"'print': False, 'setting': '/tmp/settings.conf', 'x11': True, "
|
||||||
|
"'x11_window_id': '0x123'}"
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.unit
|
@pytest.mark.unit
|
||||||
@pytest.mark.settings
|
@pytest.mark.settings
|
||||||
class TestSettingsPathSelection:
|
class TestSettingsPathSelection:
|
||||||
|
|||||||
@@ -16,11 +16,15 @@ def build_speech_history_manager(history_size=3):
|
|||||||
settings_manager = Mock()
|
settings_manager = Mock()
|
||||||
settings_manager.get_setting_as_int.return_value = history_size
|
settings_manager.get_setting_as_int.return_value = history_size
|
||||||
memory_manager = Mock(add_value_to_first_index=Mock())
|
memory_manager = Mock(add_value_to_first_index=Mock())
|
||||||
|
input_manager = Mock(reset_input_state=Mock())
|
||||||
|
input_driver = Mock(refresh_grabs=Mock())
|
||||||
env = {
|
env = {
|
||||||
"runtime": {
|
"runtime": {
|
||||||
"OutputManager": output_manager,
|
"OutputManager": output_manager,
|
||||||
"SettingsManager": settings_manager,
|
"SettingsManager": settings_manager,
|
||||||
"MemoryManager": memory_manager,
|
"MemoryManager": memory_manager,
|
||||||
|
"InputManager": input_manager,
|
||||||
|
"InputDriver": input_driver,
|
||||||
},
|
},
|
||||||
"bindings": {"original": "COMMAND"},
|
"bindings": {"original": "COMMAND"},
|
||||||
"rawBindings": {"original": [1, ["KEY_FENRIR"]]},
|
"rawBindings": {"original": [1, ["KEY_FENRIR"]]},
|
||||||
@@ -90,6 +94,7 @@ def test_open_history_installs_modal_bindings_and_replay_is_not_recorded():
|
|||||||
manager, env, spoken_messages, _memory_manager = (
|
manager, env, spoken_messages, _memory_manager = (
|
||||||
build_speech_history_manager()
|
build_speech_history_manager()
|
||||||
)
|
)
|
||||||
|
env["rawBindings"]["ctrl_shut_up"] = [1, ["KEY_CTRL"]]
|
||||||
manager.add_text("first")
|
manager.add_text("first")
|
||||||
manager.add_text("second")
|
manager.add_text("second")
|
||||||
|
|
||||||
@@ -101,10 +106,14 @@ def test_open_history_installs_modal_bindings_and_replay_is_not_recorded():
|
|||||||
assert manager.curr_index == -1
|
assert manager.curr_index == -1
|
||||||
assert manager.history == ["second", "first"]
|
assert manager.history == ["second", "first"]
|
||||||
assert "original" not in env["bindings"]
|
assert "original" not in env["bindings"]
|
||||||
assert "original" not in env["rawBindings"]
|
assert env["rawBindings"]["original"] == [1, ["KEY_FENRIR"]]
|
||||||
|
assert env["rawBindings"]["ctrl_shut_up"] == [1, ["KEY_CTRL"]]
|
||||||
assert env["bindings"][str([1, ["KEY_UP"]])] == "SPEECH_HISTORY_PREV"
|
assert env["bindings"][str([1, ["KEY_UP"]])] == "SPEECH_HISTORY_PREV"
|
||||||
assert env["bindings"][str([1, ["KEY_ENTER"]])] == "SPEECH_HISTORY_COPY"
|
assert env["bindings"][str([1, ["KEY_ENTER"]])] == "SPEECH_HISTORY_COPY"
|
||||||
assert env["bindings"][str([1, ["KEY_ESC"]])] == "SPEECH_HISTORY_CLOSE"
|
assert env["bindings"][str([1, ["KEY_ESC"]])] == "SPEECH_HISTORY_CLOSE"
|
||||||
|
assert env["rawBindings"][str([1, ["KEY_UP"]])] == [1, ["KEY_UP"]]
|
||||||
|
input_driver = env["runtime"]["InputDriver"]
|
||||||
|
input_driver.refresh_grabs.assert_called_once_with(force=True)
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.unit
|
@pytest.mark.unit
|
||||||
@@ -145,3 +154,22 @@ def test_copy_current_adds_clipboard_and_restores_bindings():
|
|||||||
assert not manager.is_active()
|
assert not manager.is_active()
|
||||||
assert env["bindings"] == {"original": "COMMAND"}
|
assert env["bindings"] == {"original": "COMMAND"}
|
||||||
assert env["rawBindings"] == {"original": [1, ["KEY_FENRIR"]]}
|
assert env["rawBindings"] == {"original": [1, ["KEY_FENRIR"]]}
|
||||||
|
env["runtime"]["InputManager"].reset_input_state.assert_called_once_with()
|
||||||
|
assert env["runtime"]["InputDriver"].refresh_grabs.call_count == 2
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_close_history_restores_keyboard_state_and_grabs():
|
||||||
|
manager, env, _spoken_messages, _memory_manager = (
|
||||||
|
build_speech_history_manager()
|
||||||
|
)
|
||||||
|
manager.add_text("first")
|
||||||
|
manager.open_history()
|
||||||
|
|
||||||
|
manager.close_history()
|
||||||
|
|
||||||
|
assert not manager.is_active()
|
||||||
|
assert env["bindings"] == {"original": "COMMAND"}
|
||||||
|
assert env["rawBindings"] == {"original": [1, ["KEY_FENRIR"]]}
|
||||||
|
env["runtime"]["InputManager"].reset_input_state.assert_called_once_with()
|
||||||
|
assert env["runtime"]["InputDriver"].refresh_grabs.call_count == 2
|
||||||
|
|||||||
@@ -140,6 +140,93 @@ def test_candidate_list_speaks_visible_list_without_cursor_advance():
|
|||||||
assert manager.process_update() == "Documents/ Downloads/"
|
assert manager.process_update() == "Documents/ Downloads/"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_full_screen_scroll_speaks_only_inserted_candidate_list():
|
||||||
|
old_text = "\n".join(
|
||||||
|
[
|
||||||
|
"old top".ljust(30),
|
||||||
|
"old middle".ljust(30),
|
||||||
|
"old lower".ljust(30),
|
||||||
|
"old bottom".ljust(30),
|
||||||
|
"$ ./Toby".ljust(30),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
manager, env, _input_manager = _build_env(old_text, {"x": 8, "y": 4})
|
||||||
|
|
||||||
|
manager.capture_if_tab()
|
||||||
|
_set_screen_update(
|
||||||
|
env,
|
||||||
|
"\n".join(
|
||||||
|
[
|
||||||
|
"old middle".ljust(30),
|
||||||
|
"old lower".ljust(30),
|
||||||
|
"old bottom".ljust(30),
|
||||||
|
"TobyAccMod_V10-0.pk3 TobyConfig.ini".ljust(30),
|
||||||
|
"$ ./Toby".ljust(30),
|
||||||
|
]
|
||||||
|
),
|
||||||
|
{"x": 8, "y": 4},
|
||||||
|
delta="\n".join(
|
||||||
|
[
|
||||||
|
"old middle",
|
||||||
|
"old lower",
|
||||||
|
"old bottom",
|
||||||
|
"TobyAccMod_V10-0.pk3 TobyConfig.ini",
|
||||||
|
"$ ./Toby",
|
||||||
|
]
|
||||||
|
),
|
||||||
|
)
|
||||||
|
|
||||||
|
assert manager.process_update() == "TobyAccMod_V10-0.pk3 TobyConfig.ini"
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_same_height_repaint_without_inserted_candidates_stays_silent():
|
||||||
|
old_text = "\n".join(
|
||||||
|
[
|
||||||
|
"old top".ljust(30),
|
||||||
|
"old middle".ljust(30),
|
||||||
|
"old lower".ljust(30),
|
||||||
|
"$ ./Toby".ljust(30),
|
||||||
|
]
|
||||||
|
)
|
||||||
|
manager, env, _input_manager = _build_env(old_text, {"x": 8, "y": 3})
|
||||||
|
|
||||||
|
manager.capture_if_tab()
|
||||||
|
_set_screen_update(
|
||||||
|
env,
|
||||||
|
"\n".join(
|
||||||
|
[
|
||||||
|
"status line".ljust(30),
|
||||||
|
"old prompt history".ljust(30),
|
||||||
|
"unrelated output".ljust(30),
|
||||||
|
"$ ./Toby".ljust(30),
|
||||||
|
]
|
||||||
|
),
|
||||||
|
{"x": 8, "y": 3},
|
||||||
|
delta="status line\nold prompt history\nunrelated output\n$ ./Toby",
|
||||||
|
)
|
||||||
|
|
||||||
|
assert manager.process_update() == ""
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
def test_recent_tab_does_not_speak_delta_without_detected_completion():
|
||||||
|
old_text = "\n".join(["$ ./Toby".ljust(20), "".ljust(20)])
|
||||||
|
manager, env, _input_manager = _build_env(old_text, {"x": 8, "y": 0})
|
||||||
|
|
||||||
|
manager.capture_if_tab()
|
||||||
|
_set_screen_update(
|
||||||
|
env,
|
||||||
|
old_text,
|
||||||
|
{"x": 8, "y": 0},
|
||||||
|
delta="old unrelated screen content\n$ ./Toby",
|
||||||
|
)
|
||||||
|
|
||||||
|
assert manager.process_update() == ""
|
||||||
|
assert env["commandBuffer"]["tabCompletion"]["pending"] is not None
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.unit
|
@pytest.mark.unit
|
||||||
def test_no_screen_change_stays_silent_and_keeps_pending_briefly():
|
def test_no_screen_change_stays_silent_and_keeps_pending_briefly():
|
||||||
manager, env, _input_manager = _build_env(
|
manager, env, _input_manager = _build_env(
|
||||||
|
|||||||
@@ -217,6 +217,47 @@ def test_x11_build_passive_grabs_for_fenrir_keys_and_shortcuts():
|
|||||||
assert ("KEY_BACKSPACE", X.Mod4Mask, True) in grabs
|
assert ("KEY_BACKSPACE", X.Mod4Mask, True) in grabs
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.unit
|
||||||
|
@pytest.mark.parametrize(
|
||||||
|
"modifier_mask",
|
||||||
|
[X.ControlMask, X.ShiftMask, X.Mod1Mask],
|
||||||
|
)
|
||||||
|
def test_x11_poll_modifier_interrupt_keys_interrupts_without_input_events(
|
||||||
|
modifier_mask,
|
||||||
|
):
|
||||||
|
x11 = X11Driver()
|
||||||
|
x11.active = True
|
||||||
|
x11.modifier_interrupt_state = 0
|
||||||
|
x11.modifier_state = 0
|
||||||
|
x11.root = Mock()
|
||||||
|
x11.root.query_pointer.return_value = Mock(mask=modifier_mask)
|
||||||
|
settings_manager = Mock()
|
||||||
|
settings_manager.get_setting_as_bool.return_value = True
|
||||||
|
settings_manager.get_setting.return_value = ""
|
||||||
|
output_manager = Mock()
|
||||||
|
x11.env = {
|
||||||
|
"input": {"event_buffer": []},
|
||||||
|
"runtime": {
|
||||||
|
"SettingsManager": settings_manager,
|
||||||
|
"OutputManager": output_manager,
|
||||||
|
"DebugManager": Mock(),
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
x11.poll_modifier_interrupt_keys()
|
||||||
|
|
||||||
|
output_manager.interrupt_output_async.assert_called_once()
|
||||||
|
assert x11.env["input"]["event_buffer"] == []
|
||||||
|
|
||||||
|
output_manager.interrupt_output_async.reset_mock()
|
||||||
|
x11.root.query_pointer.return_value = Mock(mask=0)
|
||||||
|
|
||||||
|
x11.poll_modifier_interrupt_keys()
|
||||||
|
|
||||||
|
output_manager.interrupt_output_async.assert_not_called()
|
||||||
|
assert x11.env["input"]["event_buffer"] == []
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.unit
|
@pytest.mark.unit
|
||||||
def test_x11_optional_modifier_masks_can_exclude_numlock():
|
def test_x11_optional_modifier_masks_can_exclude_numlock():
|
||||||
x11 = X11Driver()
|
x11 = X11Driver()
|
||||||
|
|||||||
Reference in New Issue
Block a user