update events Bot (#49)

* update events Bot

* update bot publish path

* adding gem for bluesky social media

* update publisher to allow no setting social media

* update blueSky script

* remove atproton from install gem

* fixing bluesky connection

* fixing empty key on bluesky

* fixing blueslky

* refactory mastodon

* update publisher and check integrations

* update and compatibilize integrations and publisher

* udpate post text

Author: ggerman

.github/workflows/bot.yml

@@ -4,7 +4,7 @@ on:
   pull_request:
   workflow_dispatch:
   schedule:
-    - cron: "0 9 * * *"
+    - cron: "1 0 * * 0"
 
 permissions:
   contents: write
@@ -25,21 +25,21 @@ jobs:
 
       - run: sudo apt-get update && sudo apt-get install -y libgd-dev
 
-      - run: gem install ruby-libgd x
+      - run: gem install ruby-libgd
 
       - run: ruby demo/rsn_events_bot/social_event_image.rb
 
       - name: Commit image
         if: github.ref == 'refs/heads/main'
         run: |
           git config --global user.name "rsn-bot"
-          git config --global user.email "bot@rubystacknews.com"
+          git config --global user.email "ggerman@gmail.com"
 
           git add demo/rsn_events_bot/rsn_events.png
-          git commit -m "update events image" || echo "no changes"
+          git commit -m "Update Events image" || echo "no changes"
           git push
 
-      - run: ruby demo/rsn_events_bot/post_to_mastodon.rb
+      - run: ruby demo/rsn_events_bot/publish.rb
         env:
           MASTODON_TOKEN: ${{ secrets.MASTODON_TOKEN }}
           MASTODON_INSTANCE: https://ruby.social

demo/rsn_events_bot/post_to_mastodon.rb

@@ -0,0 +1,19 @@
+require_relative "publishers/mastodon"
+require_relative "publishers/bluesky"
+require_relative "publishers/discord"
+
+message = "Ruby events this week 🧵\n🤖 Generated automatically by RubyEventsBot using ruby-libgd.
+Updated every 7 days.\n#Ruby #RubyEvents #RubyLanguage #RubyOnRails"
+image   = "demo/rsn_events_bot/rsn_events.png"
+
+publishers = [
+  Publishers::Mastodon.new,
+  Publishers::Bluesky.new,
+  Publishers::Discord.new
+]
+
+publishers.each do |publisher|
+  puts publisher.post(message, image) ? "x" : "."
+end
+
+puts "Publishing finished"

demo/rsn_events_bot/publish.rb

@@ -0,0 +1,74 @@
+require "net/http"
+require "json"
+require "time"
+
+module Publishers
+  class Bluesky
+    def post(text, _image)
+      user = ENV["BSKY_USER"]
+      pass = ENV["BSKY_PASS"]
+
+      return unless user && pass
+
+      # -------------------------
+      # login
+      # -------------------------
+
+      login_uri = URI("https://bsky.social/xrpc/com.atproto.server.createSession")
+
+      login_body = {
+        identifier: user,
+        password: pass
+      }
+
+      login_res = http_post(login_uri, login_body, {
+        "Content-Type" => "application/json"
+      })
+
+      return false unless login_res.code.to_i == 200
+
+      session = JSON.parse(login_res.body)
+
+      access_token = session["accessJwt"]
+      did = session["did"]
+
+      # -------------------------
+      # create post
+      # -------------------------
+
+      post_uri = URI("https://bsky.social/xrpc/com.atproto.repo.createRecord")
+
+      post_body = {
+        repo: did,
+        collection: "app.bsky.feed.post",
+        record: {
+          text: text,
+          createdAt: Time.now.utc.iso8601
+        }
+      }
+
+      post_res = http_post(post_uri, post_body, {
+        "Authorization" => "Bearer #{access_token}",
+        "Content-Type" => "application/json"
+      })
+
+      post_res.code.to_i == 200
+    end
+
+    private
+
+    def http_post(uri, body, headers = {})
+      req = Net::HTTP::Post.new(uri)
+
+      headers.each { |k, v| req[k] = v }
+
+      req.body = body.to_json
+
+      res = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true) do |http|
+        http.request(req)
+      end
+
+      return res.code.to_i == 200
+    end
+  end
+end

demo/rsn_events_bot/publishers/bluesky.rb

@@ -0,0 +1,28 @@
+require "net/http"
+require "uri"
+
+module Publishers
+  class Discord
+    def post(text, image_path)
+      webhook = ENV["DISCORD_WEBHOOK"]
+
+      exit unless webhook
+
+      uri = URI(webhook)
+      req = Net::HTTP::Post.new(uri)
+
+      form = [
+        ["content", text],
+        ["file", File.open(image_path)]
+      ]
+
+      req.set_form form, "multipart/form-data"
+
+      res = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true) do |http|
+        http.request(req)
+      end
+
+     return res.code.to_i == 200
+    end
+  end
+end

demo/rsn_events_bot/publishers/discord.rb

@@ -0,0 +1,44 @@
+require "net/http"
+require "json"
+
+module Publishers
+  class Mastodon
+    def post(text, image_path)
+      instance = ENV["MASTODON_INSTANCE"]
+      token    = ENV["MASTODON_TOKEN"]
+
+      exit unless instance && token
+
+      abort "Image not found" unless File.exist?(image_path)
+
+      uri = URI("#{instance}/api/v1/media")
+
+      req = Net::HTTP::Post.new(uri)
+      req["Authorization"] = "Bearer #{token}"
+
+      form_data = [
+        ["file", File.open(image_path), { filename: "rsn_events.png" }]
+      ]
+
+      req.set_form form_data, "multipart/form-data"
+
+      res = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true) { |http| http.request(req) }
+
+      media = JSON.parse(res.body)
+      media_id = media["id"]
+
+      uri = URI("#{instance}/api/v1/statuses")
+
+      req = Net::HTTP::Post.new(uri)
+      req["Authorization"] = "Bearer #{token}"
+
+      req.set_form_data(
+        "status" => text,
+        "media_ids[]" => media_id
+      )
+
+      res = Net::HTTP.start(uri.hostname, uri.port, use_ssl: true) { |http| http.request(req) }
+      return res.code.to_i == 200
+    end
+  end
+end