Class: RServiceBus2::HandlerLoader

Inherits:
Object
  • Object
show all
Defined in:
lib/rservicebus2/handler_loader.rb

Overview

Given a directory, this class is responsible for finding

msgnames,
handlernames, and
loading handlers

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(host, handler_manager) ⇒ HandlerLoader

Constructor

Parameters:

  • host (RServiceBus2::Host) —

    instance

  • appResources (Hash) —

    As hash where k is the name of a resource, and v is the resource



14
15
16
17
18
19
20
 
# File 'lib/rservicebus2/handler_loader.rb', line 14

def initialize(host, handler_manager)
  @host = host

  @handler_manager = handler_manager

  @list_of_loaded_paths = {}
end

Instance Attribute Details

#handlerList ⇒ Object (readonly)

Returns the value of attribute handlerList.



7
8
9
 
# File 'lib/rservicebus2/handler_loader.rb', line 7

def handlerList
  @handlerList
end

Instance Method Details

#get_list_of_files_for_dir(path) ⇒ Array

This method is overloaded for unit tests

Parameters:

  • path (String) —

    directory to check

Returns:

  • (Array) —

    a list of paths to files found in the given path



92
93
94
95
96
97
 
# File 'lib/rservicebus2/handler_loader.rb', line 92

def get_list_of_files_for_dir(path)
  list = Dir[path + '/*']
  RServiceBus2.rlog "HandlerLoader.getListOfFilesForDir. path: #{path},
    list: #{list}"
  list
end

#get_msg_name(file_path) ⇒ Object

Extract the top level dir or file name as it is the msg name

Parameters:

  • file_path (String) —

    path to check - this can be a directory or file



124
125
126
127
128
 
# File 'lib/rservicebus2/handler_loader.rb', line 124

def get_msg_name(file_path)
  base_name = File.basename(file_path)
  ext_name = File.extname(base_name)
  base_name.sub(ext_name, '')
end

#get_require_path(file_path) ⇒ Object

Cleans the given path to ensure it can be used for as a parameter for the require statement.

Parameters:

  • file_path (String) —

    the path to be cleaned



24
25
26
27
28
29
30
31
 
# File 'lib/rservicebus2/handler_loader.rb', line 24

def get_require_path(file_path)
  file_path = './' + file_path unless file_path.start_with?('/')

  return file_path.sub('.rb', '') if File.exist?(file_path)

  abort('Filepath, ' + file_path + ", given for messagehandler require
    doesn't exist")
end

#load_handler(msg_name, file_path, handler_name) ⇒ Object

Wrapper function

Parameters:

  • file_path (String)
  • handler_name (String) 


64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
 
# File 'lib/rservicebus2/handler_loader.rb', line 64

def load_handler(msg_name, file_path, handler_name)
  if @list_of_loaded_paths.key?(file_path)
    RServiceBus2.log "Not reloading, #{file_path}"
    return
  end

  begin
    RServiceBus2.rlog 'file_path: ' + file_path
    RServiceBus2.rlog 'handler_name: ' + handler_name

    handler = load_handler_from_file(handler_name, file_path)
    RServiceBus2.log 'Loaded Handler: ' + handler_name

    @handler_manager.add_handler(msg_name, handler)

    @list_of_loaded_paths[file_path] = 1
  rescue StandardError => e
    puts 'Exception loading handler from file: ' + file_path
    puts e.message
    puts e.backtrace[0]
    abort
  end
end

#load_handler_from_file(handler_name, file_path) ⇒ RServiceBus2::Handler

Instantiate the handler named in handlerName from the file name in file_path. Exceptions will be raised if encountered when loading handlers. This is a load time activity, so handlers should load correctly. As much information as possible is returned to enable the handler to be fixed, or configuration corrected.

Parameters:

  • handler_name (String) —

    name of the handler to instantiate

  • file_path (String) —

    the path to the file to be loaded

Returns:

  • (RServiceBus2::Handler) —

    the loader



41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/rservicebus2/handler_loader.rb', line 41

def load_handler_from_file(handler_name, file_path)
  require_path = get_require_path(file_path)

  require require_path
  begin
    handler = Object.const_get(handler_name).new
  rescue StandardError => e
    puts 'Expected class name: ' + handler_name + ', not found after
      require: ' + require_path
    puts '**** Check in ' + file_path + ' that the class is named : ' +
      handler_name
    puts '( In case its not that )'
    raise e
  end

  handler
end

#load_handlers_from_path(base_dir) ⇒ Object

Entry point for loading handlers

Parameters:

  • baseDir (String) —

    directory to check - should not have trailing slash



154
155
156
157
158
 
# File 'lib/rservicebus2/handler_loader.rb', line 154

def load_handlers_from_path(base_dir)
  load_handlers_from_top_level_path(base_dir)

  self
end

#load_handlers_from_second_level_path(msg_name, base_dir) ⇒ Object

Multiple handlers for the same msg can be placed inside a top level directory. The msg name is than taken from the directory, and the handlers from the files inside that directory

Parameters:

  • msg_name (String) —

    name of message

  • base_dir (String) —

    directory to check for handlers of [msg_name]



105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/rservicebus2/handler_loader.rb', line 105

def load_handlers_from_second_level_path(msg_name, base_dir)
  get_list_of_files_for_dir(base_dir).each do |file_path|
    next if file_path.end_with?('.')

    ext_name = File.extname(file_path)
    if !File.directory?(file_path) && ext_name == '.rb'
      file_name = File.basename(file_path).sub('.rb', '')
      handler_name = "message_handler_#{msg_name}_#{file_name}".gsub(/(?<=_|^)(\w)/){$1.upcase}.gsub(/(?:_)(\w)/,'\1') # Classify

      load_handler(msg_name, file_path, handler_name)
    end
  end

  self
end

#load_handlers_from_top_level_path(base_dir) ⇒ Object

Load top level handlers from the given directory

Parameters:

  • baseDir (String) —

    directory to check - should not have trailing slash



133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'lib/rservicebus2/handler_loader.rb', line 133

def load_handlers_from_top_level_path(base_dir)
  RServiceBus2.rlog "HandlerLoader.loadHandlersFromTopLevelPath. baseDir: #{base_dir}"
  get_list_of_files_for_dir(base_dir).each do |file_path|
    unless file_path.end_with?('.')
      msg_name = get_msg_name(file_path)
      if File.directory?(file_path)
        load_handlers_from_second_level_path(msg_name, file_path)
      else
        handler_name = "message_handler_#{msg_name}".gsub(/(?<=_|^)(\w)/){$1.upcase}.gsub(/(?:_)(\w)/,'\1') # Classify
        load_handler(msg_name, file_path, handler_name)
      end
    end
  end

  self
end