app/concerns/liquid_interpolatable.rb

@@ -4,7 +4,7 @@ module LiquidInterpolatable

                   def interpolate_options(options, payload)
              

                     case options.class.to_s
              

                     when 'String'
              

                -      Liquid::Template.parse(options).render(payload)
              

                +      interpolate_string(options, payload)
              

                     when 'ActiveSupport::HashWithIndifferentAccess', 'Hash'
              

                       duped_options = options.dup
              

                       duped_options.each do |key, value|
              
@@ -18,17 +18,32 @@ module LiquidInterpolatable

                   end
              

                 
              

                   def interpolate_string(string, payload)
              

                -    Liquid::Template.parse(string).render(payload)
              

                +    Liquid::Template.parse(string).render!(payload, registers: {agent: self})
              

                   end
              

                 
              

                   require 'uri'
              

                   # Percent encoding for URI conforming to RFC 3986.
              

                   # Ref: http://tools.ietf.org/html/rfc3986#page-12
              

                -  module Huginn
              

                +  module Filters
              

                     def uri_escape(string)
              

                       CGI::escape string
              

                     end
              

                   end
              

                +  Liquid::Template.register_filter(LiquidInterpolatable::Filters)
              

                 
              

                -  Liquid::Template.register_filter(LiquidInterpolatable::Huginn)
              

                +  module Tags
              

                +    class Credential < Liquid::Tag
              

                +      def initialize(tag_name, name, tokens)
              

                +        super
              

                +        @credential_name = name.strip
              

                +      end
              

                +
              

                +      def render(context)
              

                +        credential = context.registers[:agent].credential(@credential_name)
              

                +        raise "No user credential named '#{@credential_name}' defined" if credential.nil?
              

                +        credential
              

                +      end
              

                +    end
              

                +  end
              

                +  Liquid::Template.register_tag('credential', LiquidInterpolatable::Tags::Credential)
              

                 end
              

spec/models/concerns/liquid_interpolatable.rb

@@ -49,8 +49,19 @@ shared_examples_for LiquidInterpolatable do

                     end
              

                 
              

                     it "should work for strings" do
              

                -      @checker.send(:interpolate_string, "{{variable}}", @event.payload).should == "hello"
              

                -      @checker.send(:interpolate_string, "{{variable}} you", @event.payload).should == "hello you"
              

                +      @checker.interpolate_string("{{variable}}", @event.payload).should == "hello"
              

                +      @checker.interpolate_string("{{variable}} you", @event.payload).should == "hello you"
              

                +    end
              

                +  end
              

                +  describe "liquid tags" do
              

                +    it "should work with existing credentials" do
              

                +      @checker.interpolate_string("{% credential aws_key %}", {}).should == '2222222222-jane'
              

                +    end
              

                +
              

                +    it "should raise an exception for undefined credentials" do
              

                +      expect {
              

                +        @checker.interpolate_string("{% credential unknown %}", {})
              

                +      }.to raise_error
              

                     end
              

                   end
              

                 end