Merge pull request #3053 from huginn/enhance_twitter_publish_agent

Enhance TwitterPublishAgent

app/models/agents/twitter_publish_agent.rb

@@ -12,6 +12,7 @@ class TwitterPublishAgent < Agent
       To be able to use this Agent you need to authenticate with Twitter in the [Services](/services) section first.
 
       You must also specify a `message` parameter, you can use [Liquid](https://github.com/huginn/huginn/wiki/Formatting-Events-using-Liquid) to format the message.
+      Additional parameters can be passed via `parameters`.
 
       Set `expected_update_period_in_days` to the maximum amount of time that you'd expect to pass between Events being created by this Agent.
 
@@ -24,7 +25,7 @@ class TwitterPublishAgent < Agent
           "success": true,
           "published_tweet": "...",
           "tweet_id": ...,
-          "tweet_id_str": "...",
+          "tweet_url": "...",
           "agent_id": ...,
           "event_id": ...
         }
@@ -56,6 +57,7 @@ def default_options
       {
         'expected_update_period_in_days' => "10",
         'message' => "{{text}}",
+        'parameters' => {},
         'output_mode' => 'clean'
       }
     end
@@ -66,10 +68,10 @@ def receive(incoming_events)
         incoming_events = incoming_events.first(20)
       end
       incoming_events.each do |event|
-        tweet_text = interpolated(event)['message']
+        tweet_text, parameters = interpolated(event).values_at('message', 'parameters')
         new_event = interpolated['output_mode'].to_s == 'merge' ? event.payload.dup : {}
         begin
-          tweet = publish_tweet tweet_text
+          tweet = publish_tweet(tweet_text, parameters.presence || {})
         rescue Twitter::Error => e
           new_event.update(
             'success' => false,
@@ -83,6 +85,7 @@ def receive(incoming_events)
             'success' => true,
             'published_tweet' => tweet_text,
             'tweet_id' => tweet.id,
+            'tweet_url' => tweet.url,
             'agent_id' => event.agent_id,
             'event_id' => event.id
           )
@@ -91,8 +94,8 @@ def receive(incoming_events)
       end
     end
 
-    def publish_tweet(text)
-      twitter.update(text)
+    def publish_tweet(text, parameters = {})
+      twitter.update(text, parameters)
     end
   end
 end