Commit: 3cca2405d075fb8f2d08ae53183cfb4ef08c45be - pragger (git)

Commit MetaInfo

• Revision: 3cca2405d075fb8f2d08ae53183cfb4ef08c45be (tree)
• Zeit: 2007-02-27 20:40:56
• Autor: soutaro <soutaro@f836...>
• Commiter: soutaro

Log Message

plugin_from_uri plugin and filter::invert plugin

git-svn-id: http://dev.ikejima.org/src/svn/pragger/trunk@340 f8368ae4-1e99-dc11-9799-0018f35ab5fa

Ändern Zusammenfassung

• add: plugin/filter/invert.rb
• modified: plugin/plagger.rb
• add: plugin/plugin_from_uri.rb

Diff

--- /dev/null
+++ b/plugin/filter/invert.rb
@@ -0,0 +1,15 @@
+## filter::invert
+##
+## Apply filter of config: section and invert the result.
+##
+## - module: filter::invert
+##   config:
+##     - module: grep
+##       config: 
+##         regex: "理系の人々"
+##
+
+def invert(config, data)
+  data2 = eval_pragger(config, data)
+  data.delete_if {|d| data2.include? d }
+end

--- a/plugin/plagger.rb
+++ b/plugin/plagger.rb
@@ -1,106 +1,91 @@
-# ** what's this **
-#
-# interleave plagger processing.
-# 
-# ** example **
-#
-# - module: load_rss
-#   config:
-#     url: http://d.hatena.ne.jp/sumii/rss
-# - module: plagger
-#   config:
-#     input: feed
-#     debug: on
-#     plugins: 
-#       - module: Publish::CSV
-#         config: 
-#           dir: /var
-#           filename: a.csv
-# - module: print
-#   config:
-#     a: nil
-#
+## ** what's this **
+##
+## interleave plagger processing.
+## 
+## ** example **
+##
+## - module: load_rss
+##   config:
+##     url: http://d.hatena.ne.jp/sumii/rss
+## - module: plagger
+##   config:
+##     input: feed
+##     debug: on
+##     plugins: 
+##       - module: Publish::CSV
+##         config: 
+##           dir: /var
+##           filename: a.csv
+## - module: print
+##   config:
+##     a: nil
+##
 
-def plagger(config, data)
-  require 'open-uri'
-  require 'rss/1.0'
-  require 'rss/2.0'
-  require 'pathname'
-  require File.join(File.dirname(__FILE__),'save_rss.rb')
-
-  Plagger.new.plagger(config, data)
-end
+require 'open-uri'
+require 'rss/1.0'
+require 'rss/2.0'
+require 'pathname'
 
-class Plagger
-  def plagger(config, data)
-    pla_con = config["plugins"]
-    
-    if input_option(config) == :feed
-      pla_con = [{"module" => "Subscription::Feed", "config"=>{ "url" => "file:#{pla_input(config)}" }}] + pla_con
-      save_rss({ "filename" => pla_input(config).to_s }, data)
-    end
-    
-    pla_con.push({"module" => "Publish::Feed",
-                   "config" =>
-                   {"dir" => "/var",
-                     "format" => "RSS",
-                     "filename" => pla_output(config).basename.to_s}})
-
-    pla_config(config).open("w") {|io|
-      io.write to_plagger_yaml(YAML.dump({ "plugins" => pla_con }))
-    }
-    
-    system "plagger -c #{pla_config(config)}"
-    
-    begin
-      RSS::Parser.parse(pla_output(config).read).items
-    rescue
-      []
-    ensure
-      unless config.has_key?("debug")
-        begin
-          pla_config(config).delete
-          pla_input(config).delete
-          pla_output(config).delete
-        rescue => a
-          pp a
-        end
-      end
-    end
-  end
+def plagger(config, data)
+  pla_con = config["plugins"]
   
-  def pla_dir(config)
-    Pathname.new(config.has_key?("dir") ? config["dir"] : "/var")
+  if input_option(config) == :feed
+    pla_con = [{"module" => "Subscription::Feed", "config"=>{ "url" => "file:#{pla_input(config)}" }}] + pla_con
+    eval_pragger([{"module" => "save_rss", "config" => { "filename" => pla_input(config).to_s }}], data)
   end
   
-  def pla_config(config)
-    pla_dir(config) + "pla.yaml"
-  end
+  pla_con.push({"module" => "Publish::Feed",
+                 "config" =>
+                 {"dir" => "/var",
+                   "format" => "RSS",
+                   "filename" => pla_output(config).basename.to_s}})
   
-  def pla_output(config)
-    pla_dir(config) + "pla_output"
-  end
+  pla_config(config).open("w") {|io| io.write to_plagger_yaml(YAML.dump({ "plugins" => pla_con })) }
   
-  def pla_input(config)
-    pla_dir(config) + "pla_input"
-  end
+  system "plagger -c #{pla_config(config)}"
   
-  def input_option(config)
-    opt = config.has_key?("input") ? config["input"] : "nothing"
-    case opt
-    when "feed": :feed
-    when "nothing": :nothing
-    else
-      :nothing
+  begin
+    RSS::Parser.parse(pla_output(config).read).items
+  rescue
+    []
+  ensure
+    unless config.has_key?("debug")
+      pla_config(config).delete
+      pla_input(config).delete
+      pla_output(config).delete
     end
   end
+end
+
+def pla_dir(config)
+  Pathname.new(config.has_key?("dir") ? config["dir"] : "/var")
+end
 
-  def to_plagger_yaml(yaml)
-    a = yaml.split(/\n/)
-    ret = a[1]+"\n"
-    ret + a[2..(a.size-1)].collect {|x|
-      "  "+x
-    }.join("\n")+"\n"
+def pla_config(config)
+  pla_dir(config) + "pla.yaml"
+end
+
+def pla_output(config)
+  pla_dir(config) + "pla_output"
+end
+
+def pla_input(config)
+  pla_dir(config) + "pla_input"
+end
+
+def input_option(config)
+  opt = config.has_key?("input") ? config["input"] : "nothing"
+  case opt
+  when "feed": :feed
+  when "nothing": :nothing
+  else
+    :nothing
   end
 end
 
+def to_plagger_yaml(yaml)
+  a = yaml.split(/\n/)
+  ret = a[1]+"\n"
+  ret + a[2..(a.size-1)].collect {|x| "  "+x }.join("\n")+"\n"
+end
+

--- /dev/null
+++ b/plugin/plugin_from_uri.rb
@@ -0,0 +1,33 @@
+## author "Soutaro Matsumoto"
+## descr "load plugin from uri and evaluate it"
+## example <<EOE
+## - module: plugin_from_uri
+##   config:
+##     uri: http://some_host/some_path
+##     name: super_plugin
+##     config:
+##       configuration for the plugin
+## EOE
+## config({ :uri => Field.new("uri for ruby programs", String, true),
+##          :name => Field.new("name of pragger plugin", String),
+##          :config => Field.new("configuration for the plugin",{}) })
+
+require 'open-uri'
+require 'uri'
+
+def plugin_from_uri(config, data)
+  uri = URI(config["uri"])
+  name = config["name"] || uri.path.split("/").last.gsub(/\..*$/,'')
+  
+  body = open(uri.to_s) {|io| io.read}
+  
+  plugin = Class.new(Plugin)
+  plugin.class_eval {
+    def initialize()
+    end
+  }
+  plugin.class_eval(body, uri.to_s, 1)
+  
+  plugin.new().send(name, config["config"], data)
+end
+