Module: LiveAST::Linker

Extended by:
Attacher
Defined in:
lib/live_ast/linker.rb

Constant Summary collapse

REVISION_TOKEN = 
"|ast@"

Constants included from Attacher

Attacher::VAR_NAME

Class Method Summary collapse

Methods included from Attacher

attach_to_method, attach_to_proc, fetch_method_attachment, fetch_proc_attachment

Class Method Details

.fetch_from_cache(file, line) ⇒ Object 



81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
 
# File 'lib/live_ast/linker.rb', line 81

def fetch_from_cache(file, line)
  cache = @caches[file]
  if !cache and !file.index(REVISION_TOKEN)
    _, cache =
      if defined?(IRB) and file == "(irb)"
        new_cache(IRBSpy.code_at(line), file, line, false)
      else
        #
        # File was loaded by 'require'.
        # Play catch-up: assume it has not changed in the meantime.
        #
        new_cache(Reader.read(file), file, 1, true)
      end
  end
  cache.fetch_ast(line) if cache
end

.find_ast(*location) ⇒ Object

Raises:



73
74
75
76
77
78
79
 
# File 'lib/live_ast/linker.rb', line 73

def find_ast(*location)
  raise ASTNotFoundError unless location.size == 2
  raise RawEvalError if location.first == "(eval)"
  ast = fetch_from_cache(*location)
  raise MultipleDefinitionsOnSameLineError if ast == :multiple
  ast
end

.find_method_ast(klass, name, *location) ⇒ Object 



62
63
64
65
66
67
68
69
70
71
 
# File 'lib/live_ast/linker.rb', line 62

def find_method_ast(klass, name, *location)
  @mutex.synchronize do
    case ast = find_ast(*location)
    when nil
      fetch_method_attachment(klass, name) or raise ASTNotFoundError
    else
      attach_to_method(klass, name, ast)
    end
  end
end

.find_proc_ast(obj) ⇒ Object 



53
54
55
56
57
58
59
60
 
# File 'lib/live_ast/linker.rb', line 53

def find_proc_ast(obj)
  @mutex.synchronize do
    fetch_proc_attachment(obj) or (
      ast = find_ast(*obj.source_location) or raise ASTNotFoundError
      attach_to_proc(obj, ast)
    )
  end
end

.flush_cache ⇒ Object 



115
116
117
118
119
 
# File 'lib/live_ast/linker.rb', line 115

def flush_cache
  @mutex.synchronize do
    @caches.delete_if { |key, _| key.index REVISION_TOKEN }
  end
end

.new_cache(contents, file, user_line, file_is_key) ⇒ Object

create a cache along with a unique key for it



101
102
103
104
105
106
107
 
# File 'lib/live_ast/linker.rb', line 101

def new_cache(contents, file, user_line, file_is_key)
  key = file_is_key ? file : file + REVISION_TOKEN + @counter
  cache = Cache.new(contents, user_line)
  @caches[key] = cache
  @counter.next!
  return key, cache
end

.new_cache_synced(*args) ⇒ Object 



109
110
111
112
113
 
# File 'lib/live_ast/linker.rb', line 109

def new_cache_synced(*args)
  @mutex.synchronize do
    new_cache(*args)
  end
end