--- /dev/null
+# Arguments are:
+# 1. Working directory.
+# 2. Rope folder
+
+import difflib
+import io
+import json
+import os
+import sys
+import traceback
+
+try:
+ import rope
+ from rope.base import libutils
+ from rope.refactor.rename import Rename
+ from rope.refactor.extract import ExtractMethod, ExtractVariable
+ import rope.base.project
+ import rope.base.taskhandle
+except:
+ jsonMessage = {'error': True, 'message': 'Rope not installed', 'traceback': '', 'type': 'ModuleNotFoundError'}
+ sys.stderr.write(json.dumps(jsonMessage))
+ sys.stderr.flush()
+
+WORKSPACE_ROOT = sys.argv[1]
+ROPE_PROJECT_FOLDER = '.vim/.ropeproject'
+
+
+class RefactorProgress():
+ """
+ Refactor progress information
+ """
+
+ def __init__(self, name='Task Name', message=None, percent=0):
+ self.name = name
+ self.message = message
+ self.percent = percent
+
+
+class ChangeType():
+ """
+ Change Type Enum
+ """
+ EDIT = 0
+ NEW = 1
+ DELETE = 2
+
+
+class Change():
+ """
+ """
+ EDIT = 0
+ NEW = 1
+ DELETE = 2
+
+ def __init__(self, filePath, fileMode=ChangeType.EDIT, diff=""):
+ self.filePath = filePath
+ self.diff = diff
+ self.fileMode = fileMode
+
+def get_diff(changeset):
+ """This is a copy of the code form the ChangeSet.get_description method found in Rope."""
+ new = changeset.new_contents
+ old = changeset.old_contents
+ if old is None:
+ if changeset.resource.exists():
+ old = changeset.resource.read()
+ else:
+ old = ''
+
+ # Ensure code has a trailing empty lines, before generating a diff.
+ # https://github.com/Microsoft/vscode-python/issues/695.
+ old_lines = old.splitlines(True)
+ if not old_lines[-1].endswith('\n'):
+ old_lines[-1] = old_lines[-1] + os.linesep
+ new = new + os.linesep
+
+ result = difflib.unified_diff(
+ old_lines, new.splitlines(True),
+ 'a/' + changeset.resource.path, 'b/' + changeset.resource.path)
+ return ''.join(list(result))
+
+class BaseRefactoring(object):
+ """
+ Base class for refactorings
+ """
+
+ def __init__(self, project, resource, name="Refactor", progressCallback=None):
+ self._progressCallback = progressCallback
+ self._handle = rope.base.taskhandle.TaskHandle(name)
+ self._handle.add_observer(self._update_progress)
+ self.project = project
+ self.resource = resource
+ self.changes = []
+
+ def _update_progress(self):
+ jobset = self._handle.current_jobset()
+ if jobset and not self._progressCallback is None:
+ progress = RefactorProgress()
+ # getting current job set name
+ if jobset.get_name() is not None:
+ progress.name = jobset.get_name()
+ # getting active job name
+ if jobset.get_active_job_name() is not None:
+ progress.message = jobset.get_active_job_name()
+ # adding done percent
+ percent = jobset.get_percent_done()
+ if percent is not None:
+ progress.percent = percent
+ if not self._progressCallback is None:
+ self._progressCallback(progress)
+
+ def stop(self):
+ self._handle.stop()
+
+ def refactor(self):
+ try:
+ self.onRefactor()
+ except rope.base.exceptions.InterruptedTaskError:
+ # we can ignore this exception, as user has cancelled refactoring
+ pass
+
+ def onRefactor(self):
+ """
+ To be implemented by each base class
+ """
+ pass
+
+
+class RenameRefactor(BaseRefactoring):
+
+ def __init__(self, project, resource, name="Rename", progressCallback=None, startOffset=None, newName="new_Name"):
+ BaseRefactoring.__init__(self, project, resource,
+ name, progressCallback)
+ self._newName = newName
+ self.startOffset = startOffset
+
+ def onRefactor(self):
+ renamed = Rename(self.project, self.resource, self.startOffset)
+ changes = renamed.get_changes(self._newName, task_handle=self._handle)
+ for item in changes.changes:
+ if isinstance(item, rope.base.change.ChangeContents):
+ self.changes.append(
+ Change(item.resource.real_path, ChangeType.EDIT, get_diff(item)))
+ else:
+ raise Exception('Unknown Change')
+
+
+class ExtractVariableRefactor(BaseRefactoring):
+
+ def __init__(self, project, resource, name="Extract Variable", progressCallback=None, startOffset=None, endOffset=None, newName="new_Name", similar=False, global_=False):
+ BaseRefactoring.__init__(self, project, resource,
+ name, progressCallback)
+ self._newName = newName
+ self._startOffset = startOffset
+ self._endOffset = endOffset
+ self._similar = similar
+ self._global = global_
+
+ def onRefactor(self):
+ renamed = ExtractVariable(
+ self.project, self.resource, self._startOffset, self._endOffset)
+ changes = renamed.get_changes(
+ self._newName, self._similar, self._global)
+ for item in changes.changes:
+ if isinstance(item, rope.base.change.ChangeContents):
+ self.changes.append(
+ Change(item.resource.real_path, ChangeType.EDIT, get_diff(item)))
+ else:
+ raise Exception('Unknown Change')
+
+
+class ExtractMethodRefactor(ExtractVariableRefactor):
+
+ def __init__(self, project, resource, name="Extract Method", progressCallback=None, startOffset=None, endOffset=None, newName="new_Name", similar=False, global_=False):
+ ExtractVariableRefactor.__init__(self, project, resource,
+ name, progressCallback, startOffset=startOffset, endOffset=endOffset, newName=newName, similar=similar, global_=global_)
+
+ def onRefactor(self):
+ renamed = ExtractMethod(
+ self.project, self.resource, self._startOffset, self._endOffset)
+ changes = renamed.get_changes(
+ self._newName, self._similar, self._global)
+ for item in changes.changes:
+ if isinstance(item, rope.base.change.ChangeContents):
+ self.changes.append(
+ Change(item.resource.real_path, ChangeType.EDIT, get_diff(item)))
+ else:
+ raise Exception('Unknown Change')
+
+
+class RopeRefactoring(object):
+
+ def __init__(self):
+ self.default_sys_path = sys.path
+ self._input = io.open(sys.stdin.fileno(), encoding='utf-8')
+
+ def _rename(self, filePath, start, newName, indent_size):
+ """
+ Renames a variable
+ """
+ project = rope.base.project.Project(
+ WORKSPACE_ROOT, ropefolder=ROPE_PROJECT_FOLDER, save_history=False, indent_size=indent_size)
+ resourceToRefactor = libutils.path_to_resource(project, filePath)
+ refactor = RenameRefactor(
+ project, resourceToRefactor, startOffset=start, newName=newName)
+ refactor.refactor()
+ changes = refactor.changes
+ project.close()
+ valueToReturn = []
+ for change in changes:
+ valueToReturn.append({'diff': change.diff})
+ return valueToReturn
+
+ def _extractVariable(self, filePath, start, end, newName, indent_size):
+ """
+ Extracts a variable
+ """
+ project = rope.base.project.Project(
+ WORKSPACE_ROOT, ropefolder=ROPE_PROJECT_FOLDER, save_history=False, indent_size=indent_size)
+ resourceToRefactor = libutils.path_to_resource(project, filePath)
+ refactor = ExtractVariableRefactor(
+ project, resourceToRefactor, startOffset=start, endOffset=end, newName=newName, similar=True)
+ refactor.refactor()
+ changes = refactor.changes
+ project.close()
+ valueToReturn = []
+ for change in changes:
+ valueToReturn.append({'diff': change.diff})
+ return valueToReturn
+
+ def _extractMethod(self, filePath, start, end, newName, indent_size):
+ """
+ Extracts a method
+ """
+ project = rope.base.project.Project(
+ WORKSPACE_ROOT, ropefolder=ROPE_PROJECT_FOLDER, save_history=False, indent_size=indent_size)
+ resourceToRefactor = libutils.path_to_resource(project, filePath)
+ refactor = ExtractMethodRefactor(
+ project, resourceToRefactor, startOffset=start, endOffset=end, newName=newName, similar=True)
+ refactor.refactor()
+ changes = refactor.changes
+ project.close()
+ valueToReturn = []
+ for change in changes:
+ valueToReturn.append({'diff': change.diff})
+ return valueToReturn
+
+ def _serialize(self, identifier, results):
+ """
+ Serializes the refactor results
+ """
+ return json.dumps({'id': identifier, 'results': results})
+
+ def _deserialize(self, request):
+ """Deserialize request from VSCode.
+
+ Args:
+ request: String with raw request from VSCode.
+
+ Returns:
+ Python dictionary with request data.
+ """
+ return json.loads(request)
+
+ def _process_request(self, request):
+ """Accept serialized request from VSCode and write response.
+ """
+ request = self._deserialize(request)
+ lookup = request.get('lookup', '')
+
+ if lookup == '':
+ pass
+ elif lookup == 'rename':
+ changes = self._rename(request['file'], int(
+ request['start']), request['name'], int(request['indent_size']))
+ return self._write_response(self._serialize(request['id'], changes))
+ elif lookup == 'extract_variable':
+ changes = self._extractVariable(request['file'], int(
+ request['start']), int(request['end']), request['name'], int(request['indent_size']))
+ return self._write_response(self._serialize(request['id'], changes))
+ elif lookup == 'extract_method':
+ changes = self._extractMethod(request['file'], int(
+ request['start']), int(request['end']), request['name'], int(request['indent_size']))
+ return self._write_response(self._serialize(request['id'], changes))
+
+ def _write_response(self, response):
+ sys.stdout.write(response + '\n')
+ sys.stdout.flush()
+
+ def watch(self):
+ self._write_response("STARTED")
+ while True:
+ try:
+ self._process_request(self._input.readline())
+ except:
+ exc_type, exc_value, exc_tb = sys.exc_info()
+ tb_info = traceback.extract_tb(exc_tb)
+ jsonMessage = {'error': True, 'message': str(exc_value), 'traceback': str(tb_info), 'type': str(exc_type)}
+ sys.stderr.write(json.dumps(jsonMessage))
+ sys.stderr.flush()
+
+if __name__ == '__main__':
+ RopeRefactoring().watch()
projects / dotfiles / .git / blobdiff