mirror of
https://github.com/nvbn/thefuck.git
synced 2025-04-19 01:00:42 +01:00
#1 Add history of last commands, allow fuck more than once
This commit is contained in:
parent
fb7376f5a5
commit
ba601644d6
44
tests/test_history.py
Normal file
44
tests/test_history.py
Normal file
@ -0,0 +1,44 @@
|
|||||||
|
import pytest
|
||||||
|
from mock import patch, Mock
|
||||||
|
from thefuck.history import History
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.fixture
|
||||||
|
def process(monkeypatch):
|
||||||
|
Process = Mock()
|
||||||
|
Process.return_value.parent.return_value.pid = 1
|
||||||
|
monkeypatch.setattr('thefuck.history.Process', Process)
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.fixture
|
||||||
|
def db(monkeypatch):
|
||||||
|
class DBMock(dict):
|
||||||
|
def __init__(self):
|
||||||
|
super(DBMock, self).__init__()
|
||||||
|
self.sync = Mock()
|
||||||
|
|
||||||
|
def __call__(self, *args, **kwargs):
|
||||||
|
return self
|
||||||
|
|
||||||
|
db = DBMock()
|
||||||
|
monkeypatch.setattr('thefuck.history.shelve.open', db)
|
||||||
|
return db
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.mark.usefixtures('process')
|
||||||
|
class TestHistory(object):
|
||||||
|
def test_set(self, db):
|
||||||
|
history = History()
|
||||||
|
history.update(last_script='ls',
|
||||||
|
last_fixed_script=None)
|
||||||
|
assert db == {'1-last_script': 'ls',
|
||||||
|
'1-last_fixed_script': None}
|
||||||
|
|
||||||
|
def test_get(self, db):
|
||||||
|
history = History()
|
||||||
|
db['1-last_script'] = 'cd ..'
|
||||||
|
assert history.last_script == 'cd ..'
|
||||||
|
|
||||||
|
def test_get_without_value(self, db):
|
||||||
|
history = History()
|
||||||
|
assert history.last_script is None
|
@ -46,15 +46,30 @@ def test_get_command():
|
|||||||
return_value=True):
|
return_value=True):
|
||||||
Popen.return_value.stdout.read.return_value = b'stdout'
|
Popen.return_value.stdout.read.return_value = b'stdout'
|
||||||
Popen.return_value.stderr.read.return_value = b'stderr'
|
Popen.return_value.stderr.read.return_value = b'stderr'
|
||||||
assert main.get_command(Mock(), ['thefuck', 'apt-get',
|
assert main.get_command(Mock(), Mock(),
|
||||||
'search', 'vim']) \
|
['thefuck', 'apt-get', 'search', 'vim']) \
|
||||||
== Command('apt-get search vim', 'stdout', 'stderr')
|
== Command('apt-get search vim', 'stdout', 'stderr')
|
||||||
Popen.assert_called_once_with('apt-get search vim',
|
Popen.assert_called_once_with('apt-get search vim',
|
||||||
shell=True,
|
shell=True,
|
||||||
stdout=PIPE,
|
stdout=PIPE,
|
||||||
stderr=PIPE,
|
stderr=PIPE,
|
||||||
env={'LANG': 'C'})
|
env={'LANG': 'C'})
|
||||||
assert main.get_command(Mock(), ['']) is None
|
assert main.get_command(Mock(), Mock(), ['']) is None
|
||||||
|
# When command is `fuck`:
|
||||||
|
assert main.get_command(
|
||||||
|
Mock(),
|
||||||
|
Mock(last_script='ls', last_fixed_script='ls -la'),
|
||||||
|
['thefuck', 'fuck']).script == 'ls -la'
|
||||||
|
# When command equals to last command:
|
||||||
|
assert main.get_command(
|
||||||
|
Mock(),
|
||||||
|
Mock(last_script='ls', last_fixed_script='ls -la'),
|
||||||
|
['thefuck', 'ls']).script == 'ls -la'
|
||||||
|
# When last command is `fuck` and no last fixed script:
|
||||||
|
assert main.get_command(
|
||||||
|
Mock(),
|
||||||
|
Mock(last_script='ls', last_fixed_script=''),
|
||||||
|
['thefuck', 'ls']).script == 'ls'
|
||||||
|
|
||||||
|
|
||||||
def test_get_matched_rule(capsys):
|
def test_get_matched_rule(capsys):
|
||||||
@ -72,20 +87,24 @@ def test_get_matched_rule(capsys):
|
|||||||
def test_run_rule(capsys):
|
def test_run_rule(capsys):
|
||||||
with patch('thefuck.main.confirm', return_value=True):
|
with patch('thefuck.main.confirm', return_value=True):
|
||||||
main.run_rule(Rule(get_new_command=lambda *_: 'new-command'),
|
main.run_rule(Rule(get_new_command=lambda *_: 'new-command'),
|
||||||
None, None)
|
Command(), Mock(), None)
|
||||||
assert capsys.readouterr() == ('new-command\n', '')
|
assert capsys.readouterr() == ('new-command\n', '')
|
||||||
# With side effect:
|
# With side effect:
|
||||||
side_effect = Mock()
|
side_effect = Mock()
|
||||||
settings = Mock()
|
settings = Mock()
|
||||||
command = Mock()
|
command = Mock(script='ls')
|
||||||
|
history = Mock()
|
||||||
main.run_rule(Rule(get_new_command=lambda *_: 'new-command',
|
main.run_rule(Rule(get_new_command=lambda *_: 'new-command',
|
||||||
side_effect=side_effect),
|
side_effect=side_effect),
|
||||||
command, settings)
|
command, history, settings)
|
||||||
assert capsys.readouterr() == ('new-command\n', '')
|
assert capsys.readouterr() == ('new-command\n', '')
|
||||||
side_effect.assert_called_once_with(command, settings)
|
side_effect.assert_called_once_with(command, settings)
|
||||||
|
# Ensure that history updated:
|
||||||
|
history.update.assert_called_once_with(last_script='ls',
|
||||||
|
last_fixed_script='new-command')
|
||||||
with patch('thefuck.main.confirm', return_value=False):
|
with patch('thefuck.main.confirm', return_value=False):
|
||||||
main.run_rule(Rule(get_new_command=lambda *_: 'new-command'),
|
main.run_rule(Rule(get_new_command=lambda *_: 'new-command'),
|
||||||
None, None)
|
Command(), Mock(), None)
|
||||||
assert capsys.readouterr() == ('', '')
|
assert capsys.readouterr() == ('', '')
|
||||||
|
|
||||||
|
|
||||||
|
27
thefuck/history.py
Normal file
27
thefuck/history.py
Normal file
@ -0,0 +1,27 @@
|
|||||||
|
import os
|
||||||
|
import shelve
|
||||||
|
from tempfile import gettempdir
|
||||||
|
from psutil import Process
|
||||||
|
|
||||||
|
|
||||||
|
class History(object):
|
||||||
|
"""Temporary history of commands/fixed-commands dependent on
|
||||||
|
current shell instance.
|
||||||
|
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self._path = os.path.join(gettempdir(), '.thefuck_history')
|
||||||
|
self._pid = Process(os.getpid()).parent().pid
|
||||||
|
self._db = shelve.open(self._path)
|
||||||
|
|
||||||
|
def _prepare_key(self, key):
|
||||||
|
return '{}-{}'.format(self._pid, key)
|
||||||
|
|
||||||
|
def update(self, **kwargs):
|
||||||
|
self._db.update({self._prepare_key(k): v for k,v in kwargs.items()})
|
||||||
|
self._db.sync()
|
||||||
|
return self
|
||||||
|
|
||||||
|
def __getattr__(self, item):
|
||||||
|
return self._db.get(self._prepare_key(item))
|
@ -6,6 +6,7 @@ import os
|
|||||||
import sys
|
import sys
|
||||||
from psutil import Process, TimeoutExpired
|
from psutil import Process, TimeoutExpired
|
||||||
import colorama
|
import colorama
|
||||||
|
from .history import History
|
||||||
from . import logs, conf, types
|
from . import logs, conf, types
|
||||||
|
|
||||||
|
|
||||||
@ -59,16 +60,21 @@ def wait_output(settings, popen):
|
|||||||
return False
|
return False
|
||||||
|
|
||||||
|
|
||||||
def get_command(settings, args):
|
def get_command(settings, history, args):
|
||||||
"""Creates command from `args` and executes it."""
|
"""Creates command from `args` and executes it."""
|
||||||
if sys.version_info[0] < 3:
|
if sys.version_info[0] < 3:
|
||||||
script = ' '.join(arg.decode('utf-8') for arg in args[1:])
|
script = ' '.join(arg.decode('utf-8') for arg in args[1:])
|
||||||
else:
|
else:
|
||||||
script = ' '.join(args[1:])
|
script = ' '.join(args[1:])
|
||||||
|
|
||||||
|
if script == 'fuck' or script == history.last_script:
|
||||||
|
script = history.last_fixed_script or history.last_script
|
||||||
|
|
||||||
if not script:
|
if not script:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
history.update(last_script=script,
|
||||||
|
last_fixed_script=None)
|
||||||
result = Popen(script, shell=True, stdout=PIPE, stderr=PIPE,
|
result = Popen(script, shell=True, stdout=PIPE, stderr=PIPE,
|
||||||
env=dict(os.environ, LANG='C'))
|
env=dict(os.environ, LANG='C'))
|
||||||
if wait_output(settings, result):
|
if wait_output(settings, result):
|
||||||
@ -101,20 +107,17 @@ def confirm(new_command, side_effect, settings):
|
|||||||
return False
|
return False
|
||||||
|
|
||||||
|
|
||||||
def run_rule(rule, command, settings):
|
def run_rule(rule, command, history, settings):
|
||||||
"""Runs command from rule for passed command."""
|
"""Runs command from rule for passed command."""
|
||||||
new_command = rule.get_new_command(command, settings)
|
new_command = rule.get_new_command(command, settings)
|
||||||
if confirm(new_command, rule.side_effect, settings):
|
if confirm(new_command, rule.side_effect, settings):
|
||||||
if rule.side_effect:
|
if rule.side_effect:
|
||||||
rule.side_effect(command, settings)
|
rule.side_effect(command, settings)
|
||||||
|
history.update(last_script=command.script,
|
||||||
|
last_fixed_script=new_command)
|
||||||
print(new_command)
|
print(new_command)
|
||||||
|
|
||||||
|
|
||||||
def is_second_run(command):
|
|
||||||
"""Is it the second run of `fuck`?"""
|
|
||||||
return command.script.startswith('fuck')
|
|
||||||
|
|
||||||
|
|
||||||
def alias():
|
def alias():
|
||||||
print("\nalias fuck='eval $(thefuck $(fc -ln -1))'\n")
|
print("\nalias fuck='eval $(thefuck $(fc -ln -1))'\n")
|
||||||
|
|
||||||
@ -123,17 +126,14 @@ def main():
|
|||||||
colorama.init()
|
colorama.init()
|
||||||
user_dir = setup_user_dir()
|
user_dir = setup_user_dir()
|
||||||
settings = conf.get_settings(user_dir)
|
settings = conf.get_settings(user_dir)
|
||||||
|
history = History()
|
||||||
|
|
||||||
command = get_command(settings, sys.argv)
|
command = get_command(settings, history, sys.argv)
|
||||||
if command:
|
if command:
|
||||||
if is_second_run(command):
|
|
||||||
logs.failed("Can't fuck twice", settings)
|
|
||||||
return
|
|
||||||
|
|
||||||
rules = get_rules(user_dir, settings)
|
rules = get_rules(user_dir, settings)
|
||||||
matched_rule = get_matched_rule(command, rules, settings)
|
matched_rule = get_matched_rule(command, rules, settings)
|
||||||
if matched_rule:
|
if matched_rule:
|
||||||
run_rule(matched_rule, command, settings)
|
run_rule(matched_rule, command, history, settings)
|
||||||
return
|
return
|
||||||
|
|
||||||
logs.failed('No fuck given', settings)
|
logs.failed('No fuck given', settings)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user