ソースを張っておきますので、ご自由にお使いください。動作無保証です。未実装のメソッドもあります。テストも不完全です。無い無い尽くしでアレですが、ご自身の責任範囲でお使いください。
本来であればGitHubからForkさせるべきなんでしょうけど、使い方を把握していないので・・すみません・・
※注：すでに同じ様な事やってらっしゃる方がいました。http://github.com/bemurphy/right_aws/blob/add_sns/lib/sns/right_sns_interface.rb
require "right_aws"
module RightAws
class SnsInterface < RightAwsBase
include RightAwsBaseInterface
DEFAULT_HOST = 'sns.us-east-1.amazonaws.com'
DEFAULT_PORT = 443
DEFAULT_PROTOCOL = 'https'
DEFAULT_PATH = '/'
API_VERSION = '2010-03-31'
@@bench = AwsBenchmarkingBlock.new
def self.bench_xml; @@bench.xml; end
def self.bench_sns; @@bench.service; end
# Creates new RightSns instance.
#
# Example:
#
# sns = RightAws::SnsInterface.new(aws_access_key_id, aws_secret_key)
#
def initialize(aws_access_key_id=nil, aws_secret_access_key=nil, params={})
params.delete(:nil_representation)
init({
:name => 'SNS',
:default_host => ENV['SNS_URL'] ? URI.parse(ENV['SNS_URL']).host : DEFAULT_HOST,
:default_port => ENV['SNS_URL'] ? URI.parse(ENV['SNS_URL']).port : DEFAULT_PORT,
:default_service => DEFAULT_PATH,
:default_protocol => ENV['SNS_URL'] ? URI.parse(ENV['SNS_URL']).scheme : DEFAULT_PROTOCOL,
:default_api_version => API_VERSION
},
aws_access_key_id || ENV['AWS_ACCESS_KEY_ID'],
aws_secret_access_key || ENV['AWS_SECRET_ACCESS_KEY'],
params)
end
#--------------------
# APIs
#--------------------
def add_permission()
raise 'Sorry! Not Implemented!'
end
def confirm_subscription()
raise 'Sorry! Not Implemented!'
end
def set_topic_attributes(topic_arn, attribute_name, attribute_value)
request_params = {'TopicArn' => topic_arn, 'AttributeName' => attribute_name, 'AttributeValue' => attribute_value}
link = generate_request("SetTopicAttributes", request_params)
result = request_info(link, QSnsSetTopicAttributesParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
def get_topic_attributes(topic_arn)
request_params = {'TopicArn' => topic_arn}
link = generate_request("GetTopicAttributes", request_params)
result = request_info(link, QSnsGetTopicAttributesParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
def create_topic(topic_name)
request_params = {'Name' => topic_name}
link = generate_request("CreateTopic", request_params)
result = request_info(link, QSnsCreateTopicParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
def delete_topic(topic_arn)
request_params = {'TopicArn' => topic_arn}
link = generate_request("DeleteTopic", request_params)
result = request_info(link, QSnsDeleteTopicParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
def list_topics(next_token = nil )
request_params = {'NextToken' => next_token}
link = generate_request("ListTopics", request_params)
result = request_info(link, QSnsListTopicsParser.new(:logger => @logger))
# return result if no block given
return result unless block_given?
# loop if block if given
begin
# the block must return true if it wanna continue
break unless yield(result) && result[:next_token]
# make new request
request_params['NextToken'] = result[:next_token]
link = generate_request("ListTopics", request_params)
result = request_info(link, QSnsListTopicsParser.new(:logger => @logger))
end while true
rescue Exception
on_exception
end
def subscribe(topic_arn, protocol, endpoint)
request_params = {'TopicArn' => topic_arn, 'Protocol' => protocol, 'Endpoint' => endpoint}
link = generate_request("Subscribe", request_params)
result = request_info(link, QSnsSubscribeParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
def unsubscribe(subscription_arn)
request_params = {'SubscriptionArn' => subscription_arn}
link = generate_request("Unsubscribe", request_params)
result = request_info(link, QSnsUnubscribeParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
# return {:subscritions => []}
def list_subscriptions(next_token = nil )
request_params = {'NextToken' => next_token }
link = generate_request("ListSubscriptions", request_params)
result = request_info(link, QSnsListSubscriptionsParser.new(:logger => @logger))
# return result if no block given
return result unless block_given?
# loop if block if given
begin
# the block must return true if it wanna continue
break unless yield(result) && result[:next_token]
# make new request
request_params['NextToken'] = result[:next_token]
link = generate_request("ListSubscriptions", request_params)
result = request_info(link, QSnsListSubscriptionsParser.new(:logger => @logger))
end while true
rescue Exception
on_exception
end
# return {:subscritions => []}
def list_subscriptions_by_topic(topic_arn, next_token = nil )
request_params = {'TopicArn' => topic_arn, 'NextToken' => next_token}
link = generate_request("ListSubscriptionsByTopic", request_params)
result = request_info(link, QSnsListSubscriptionsParser.new(:logger => @logger))
# return result if no block given
return result unless block_given?
# loop if block if given
begin
# the block must return true if it wanna continue
break unless yield(result) && result[:next_token]
# make new request
request_params['NextToken'] = result[:next_token]
link = generate_request("ListSubscriptionsByTopic", request_params)
result = request_info(link, QSnsListSubscriptionsParser.new(:logger => @logger))
end while true
rescue Exception
on_exception
end
def publish(topic_arn, subject, message)
request_params = {'TopicArn' => topic_arn, 'Subject' => subject, 'Message' => message}
link = generate_request("Publish", request_params)
result = request_info(link, QSnsPublishParser.new(:logger => @logger))
return result
rescue Exception
on_exception
end
#--------------------
# Requests
#--------------------
def generate_request(action, params={}) #:nodoc:
generate_request_impl(:get, action, params )
end
# Sends request to Amazon and parses the response
# Raises AwsError if any banana happened
def request_info(request, parser) #:nodoc:
request_info_impl(:sdb_connection, @@bench, request, parser)
end
#--------------------
# PARSERS:
#--------------------
class QSnsCreateTopicParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'TopicArn' then @result[:topic_arn] = @text
when 'RequestId' then @result[:request_id] = @text
end
end
end
class QSnsDeleteTopicParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'RequestId' then @result[:request_id] = @text
end
end
end
class QSnsListTopicsParser < RightAWSParser #:nodoc:
def reset
@result = { :topics => [] }
end
def tagend(name)
case name
when 'NextToken' then @result[:next_token] = @text
when 'TopicArn' then @result[:topics] << @text
end
end
end
class QSnsSubscribeParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'SubscriptionArn' then @result[:subscription_arn] = @text
when 'RequestId' then @result[:request_id] = @text
end
end
end
# same with QSnsDeleteParser...
class QSnsUnubscribeParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'RequestId' then @result[:request_id] = @text
end
end
end
class QSnsListSubscriptionsParser < RightAWSParser #:nodoc:
def reset
new_member()
@result = {:subscriptions => [] }
end
def tagend(name)
case name
when 'NextToken' then @result[:next_token] = @text
when 'TopicArn' then @member[:topic_arn] = @text
when 'Protocol' then @member[:protocol] = @text
when 'SubscriptionArn' then @member[:subscription_arn] = @text
when 'Owner' then @member[:owner] = @text
when 'Endpoint' then @member[:endpoint] = @text; @result[:subscriptions] << @member; new_member();
end
end
private
def new_member
@member = {:topic_arn => '', :protocol => '', :subscription_arn => '', :owner => '', :endpoint => ''}
end
end
class QSnsPublishParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'MessageId' then @result[:message_id] = @text
when 'RequestId' then @result[:request_id] = @text
end
end
end
# same with QSnsDeleteTopicParser...
class QSnsSetTopicAttributesParser < RightAWSParser #:nodoc:
def reset
@result = {}
end
def tagend(name)
case name
when 'RequestId' then @result[:request_id] = @text
end
end
end
class QSnsGetTopicAttributesParser < RightAWSParser #:nodoc:
def reset
@result = {:attributes => []}
end
def tagend(name)
case name
when 'key' then @key = @text
when 'value' then @result[:attributes] << {:key => @key, :value => @text}
when 'RequestId' then @result[:request_id] = @text
end
end
end
end
end
0 件のコメント :
コメントを投稿