Add plugins subscription Gguide

ytsuyuzaki · ytsuyuzaki · commit 34b974200696 · 2013-06-28T03:25:27.000+09:00
diff --git a/plugins/subscription/g_guide.rb b/plugins/subscription/g_guide.rb
@@ -0,0 +1,49 @@
+# -*- coding: utf-8 -*-
+# Name::      Automatic::Plugin::Subscription::GGuide
+# Author::    soramugi <http://soramugi.net>
+# Created::   Jun 28, 2013
+# Updated::   Jun 28, 2013
+# Copyright:: Copyright (c) 2013 Automatic Ruby Developers.
+# License::   Licensed under the GNU GENERAL PUBLIC LICENSE, Version 3.0.
+
+module Automatic::Plugin
+  class SubscriptionGGuide
+    G_GUIDE_RSS = 'http://tv.so-net.ne.jp/rss/schedulesBySearch.action?'
+
+    def initialize(config, pipeline=[])
+      @config   = config
+      @pipeline = pipeline
+    end
+
+    def run
+      retries = 0
+      begin
+        @pipeline << Automatic::FeedParser.get(feed_url)
+      rescue
+        retries += 1
+        Automatic::Log.puts("error", "ErrorCount: #{retries}, Fault in parsing: #{retries}")
+        sleep @config['interval'].to_i unless @config['interval'].nil?
+        retry if retries <= @config['retry'].to_i unless @config['retry'].nil?
+      end
+
+      @pipeline
+    end
+
+    def feed_url
+        feed = G_GUIDE_RSS
+        unless @config['keyword'].nil?
+          feed += "condition.keyword=#{@config['keyword']}&"
+        end
+        feed += station_param
+        URI.encode(feed)
+    end
+
+    def station_param
+        station = 0
+        unless @config['station'].nil?
+          station = '1' if @config['station'] == '地上波'
+        end
+        "stationPlatformId=#{station}&"
+    end
+  end
+end
diff --git a/spec/plugins/subscription/g_guide_spec.rb b/spec/plugins/subscription/g_guide_spec.rb
@@ -0,0 +1,78 @@
+# -*- coding: utf-8 -*-
+# Name::      Automatic::Plugin::Subscription::g_guide
+# Author::    soramugi <http://soramugi.net>
+# Created::   May 21, 2013
+# Updated::   May 21, 2013
+# Copyright:: Copyright (c) 2012-2013 Automatic Ruby Developers.
+# License::   Licensed under the GNU GENERAL PUBLIC LICENSE, Version 3.0.
+
+require File.expand_path(File.dirname(__FILE__) + '../../../spec_helper')
+
+require 'subscription/g_guide'
+
+def g_guide(config = {}, pipeline = [])
+  Automatic::Plugin::SubscriptionGGuide.new(config,pipeline)
+end
+
+describe 'Automatic::Plugin::SubscriptionGGuide' do
+  context 'when config' do
+    describe 'is empty' do
+      subject { g_guide }
+
+      its(:feed_url) {
+        should == Automatic::Plugin::SubscriptionGGuide::G_GUIDE_RSS +
+        'stationPlatformId=0&'
+      }
+    end
+    describe 'keyword is anime' do
+      config = { 'keyword' => 'anime' }
+      subject { g_guide(config) }
+
+      its(:feed_url) {
+        should == URI.encode(
+          Automatic::Plugin::SubscriptionGGuide::G_GUIDE_RSS +
+            "condition.keyword=#{config['keyword']}&" +
+            'stationPlatformId=0&')
+      }
+    end
+    describe 'station is 地上波' do
+      config = { 'station' => '地上波' }
+      subject { g_guide(config) }
+
+      its(:feed_url) {
+        should == URI.encode(
+          Automatic::Plugin::SubscriptionGGuide::G_GUIDE_RSS +
+            'stationPlatformId=1&')
+      }
+    end
+  end
+  context 'when feed is empty' do
+
+    describe 'attestation error' do
+      subject { g_guide }
+      before do
+        subject.should_receive(:feed_url).and_return('')
+      end
+      its(:run) { should be_empty }
+    end
+
+    describe 'interval & retry was used error' do
+      config = {'interval' => 1, 'retry' => 1}
+      subject { g_guide(config) }
+      before do
+        subject.should_receive(:feed_url).exactly(2).times.and_return('')
+      end
+      its(:run) { should be_empty }
+    end
+
+  end
+
+  context 'when feed' do
+    describe 'config keyword' do
+      config = { 'keyword' => 'アニメ', 'station' => '地上波' }
+      subject { g_guide(config) }
+      its(:run) { should have(1).feed }
+    end
+
+  end
+end
