+++ /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