bean talker update

src/core.rb

@@ -6,7 +6,7 @@
 require "concurrent"
 require "require_all"
 #==========<[ Local Libs ]>==========#
-require_rel "lib/*.rb"
+require_rel "lib"
 
 #@@@@@@ USERS MAY EDIT THEIR SETTINGS BELOW:
 #[[[[[[ INITIALIZE CONFIG & ALL LIBRARY CLASSES HERE]]]]]]

src/lib/bean_talker.rb

@@ -1,14 +1,36 @@
-require "yaml"
-require "app_settings.rb"
+require "beaneater"
+require "shiki_gram"
+require "app_settings"
 
 class BeanTalker
-  @@config_hash = YAML.load(File.read("#{Dir.home}/.config/shikigami/config.yml"))
+  tube.put ARGV[0]
 
-  def self.exists?(key)
-    return @@config_hash.has_key?(key)
+  def initialize(mod_name)
+    @mod_name = mod_name # Declare the name of the module, NOTE:
+    # Module names MUST match their parent folder inside the 'modules' subdir
+    # Any module should be able to talk to any other by referencing this name
+    # All modules may talk to the 'core' via the tube of the same name ("core")
+    core_config = AppSettings.new
+    beanstalk_host = core_config.get("beanstalk_host")
+    beanstalk_port = core_config.get("beanstalk_port")
+    @beanstalk = Beaneater.new("#{beanstalk_host}\:#{beanstalk_port}")
+    @all_tubes = @beanstalk.tubes.all
+    @tube = @beanstalk.tubes[@mod_name]
   end
 
-  def get(key)
-    return @@config_hash[key]
+  def send_msg(msg, to)
+    postman = ShikiGram.new
+    mail = postman.wrap_msg(msg)
+    if @all_tubes.route = @beanstalk.tubes[to]
+      route.put(mail)
+    end
+  end
+
+  def recv_msg(msg)
+    puts "not implemented"
+  end
+
+  def shut_up
+    @beanstalk.close
   end
 end

src/manual.rb

@@ -9,7 +9,7 @@
 #| mainly with ad-hoc tasks, or schedulers like cron.            ||
 #\===============================================================//
 require "beaneater"
-require_relative "lib/lib_core_config"
+require_relative "lib/app_settings"
 
 # Get user settings
 core_config = AppSettings.new