Posting automation

Author: marcheiligers

README.md

@@ -51,6 +51,29 @@ bin/bridgetown console
 
 > Learn more: [Bridgetown CLI Documentation](https://www.bridgetownrb.com/docs/command-line-usage)
 
+## Managing Events & Social Media
+
+We use a custom CLI script (`bin/event`) to manage meetup posts and automatically publish them to our social media channels (Mastodon and Bluesky).
+
+**1. Create a new event**
+```sh
+bin/event new 2026-08-20 "Intro to Hotwire"
+```
+This generates a new markdown post in `src/_posts/` with the correct boilerplate front matter. You can then edit the file to add details like the `meetup_link`.
+
+**2. Publish and announce on social media**
+```sh
+bin/event publish
+```
+This launches an interactive wizard that lets you:
+- Select an event from a reverse-chronological list of all posts.
+- Choose a post template (Original Announcement, Reminder, or Post-Event Recap).
+- Edit the social media post text inline.
+- Automatically publish the post to **Mastodon** and **Bluesky** using credentials stored in 1Password.
+
+**Threaded Replies**: 
+The first time you publish an event, `bin/event publish` will save the generated Mastodon and Bluesky URLs directly into the post's markdown front matter. If you run `bin/event publish` again for the *same* event (e.g. to send a Reminder or Post-Event recap), it will automatically fetch those URLs and post your new updates as **threaded replies** to the original post on both platforms!
+
 ## Deployment
 
 You can deploy Bridgetown sites on hosts like statichost.eu and Render as well as traditional web servers by simply building and copying the output folder to your HTML root.

bin/event

@@ -3,6 +3,14 @@
 
 require "date"
 require "fileutils"
+require_relative "../lib/publishers/publisher"
+require_relative "../lib/publishers/mastodon_publisher"
+require_relative "../lib/publishers/bluesky_publisher"
+
+PUBLISHERS = [
+  MastodonPublisher.new,
+  BlueskyPublisher.new
+].freeze
 
 def usage
   puts <<~USAGE
@@ -63,25 +71,144 @@ def cmd_new(args)
   puts "Created new event post at #{filename}"
 end
 
-def cmd_publish(args)
-  puts "Staging changes..."
-  unless system("git add src/_posts/")
-    puts "Failed to add changes to git."
-    exit 1
+def parse_front_matter(content)
+  match = content.match(/\A---\n(.*?\n)---\n(.*)\z/m)
+  return [{}, content] unless match
+  fm = {}
+  match[1].each_line do |line|
+    if line =~ /\A(\w[\w_]*):\s*(.*)\s*\z/
+      key = $1
+      val = $2.strip
+      val = val[1..-2] if val.start_with?('"') && val.end_with?('"')
+      fm[key] = val
+    end
   end
+  [fm, match[2]]
+end
 
-  puts "Committing changes..."
-  unless system("git commit -m 'Add new event post'")
-    puts "No new changes to commit, or commit failed."
+def update_front_matter_field(content, key, value)
+  if content =~ /^#{Regexp.escape(key)}:/
+    content.sub(/^#{Regexp.escape(key)}:.*$/, "#{key}: \"#{value}\"")
+  else
+    content.sub(/\A(---\n.*?)^(---\n)/m, "\\1#{key}: \"#{value}\"\n\\2")
   end
+end
+
+def cmd_publish(args)
+  require "readline"
+  
+  posts = Dir.glob("src/_posts/*.md").map do |path|
+    content = File.read(path)
+    fm, _ = parse_front_matter(content)
+    { path: path, fm: fm, content: content }
+  end
+
+  posts.sort_by! { |p| p[:fm]["event_date"] || File.basename(p[:path]) }.reverse!
 
-  puts "Pushing to remote to trigger deployment..."
-  unless system("git push")
-    puts "Failed to push to remote."
+  puts "Select an event to post about:"
+  posts.each_with_index do |p, i|
+    published = p[:fm]["mastodon_post_url"] ? "[Published]" : "[Unpublished]"
+    puts "  #{i + 1}) #{p[:fm]['event_date']} - #{p[:fm]['title']} #{published}"
+  end
+  print "Choice: "
+  choice = $stdin.gets.strip.to_i
+  if choice < 1 || choice > posts.length
+    puts "Invalid choice."
+    exit 1
+  end
+  
+  selected = posts[choice - 1]
+  
+  title = selected[:fm]["title"]
+  date = selected[:fm]["event_date"]
+  basename = File.basename(selected[:path], ".md")
+  if basename =~ /^(\d{4})-(\d{2})-(\d{2})-(.+)$/
+    website_url = "https://rubyaz.org/#{$1}/#{$2}/#{$3}/#{$4}/"
+  else
+    website_url = "https://rubyaz.org/"
+  end
+  
+  puts "\nSelect post type:"
+  puts "  1) Original (Announce the event)"
+  puts "  2) Reminder (A few days before)"
+  puts "  3) Post-Event (Thanks and recap)"
+  print "Choice: "
+  type_choice = $stdin.gets.strip
+  
+  case type_choice
+  when "1"
+    default_text = "Join us for #{title} on #{date}!\n\nRSVP & Details: #{website_url}\n\n#ruby #rubyaz"
+  when "2"
+    default_text = "Reminder! We're meeting for #{title} on #{date}.\n\nSee you there: #{website_url}\n\n#ruby #rubyaz"
+  when "3"
+    default_text = "Thanks to everyone who joined us for #{title}!\n\nCheck out the slides and recap: #{website_url}\n\n#ruby #rubyaz"
+  else
+    puts "Invalid choice."
     exit 1
   end
 
-  puts "Successfully published events!"
+  # Replace escaped newlines so they render correctly in Readline
+  default_text = default_text.gsub('\\n', "\n")
+
+  puts "\nEdit your post text (press Enter to accept):"
+  
+  Readline.pre_input_hook = -> {
+    Readline.insert_text(default_text)
+    Readline.redisplay
+    Readline.pre_input_hook = nil
+  }
+  
+  final_text = Readline.readline("> ", false)
+  
+  puts "\nFinal Text:"
+  puts "---"
+  puts final_text
+  puts "---"
+  print "Publish this? (y/n): "
+  unless $stdin.gets.strip.downcase == 'y'
+    puts "Aborted."
+    exit 0
+  end
+  
+  updates_made = false
+  new_content = selected[:content]
+
+  PUBLISHERS.each do |publisher|
+    existing_url = selected[:fm][publisher.front_matter_key]
+    reply_to = existing_url && !existing_url.empty? ? existing_url : nil
+    
+    if reply_to
+      puts "Posting to #{publisher.name} as a reply to #{reply_to}..."
+    else
+      puts "Posting to #{publisher.name}..."
+    end
+    
+    result = publisher.post(final_text, reply_to: reply_to)
+    
+    if result[:error]
+      puts "FAILED"
+      puts "  #{result[:error]}"
+    else
+      puts "OK"
+      puts "  #{result[:url]}"
+      unless reply_to
+        new_content = update_front_matter_field(new_content, publisher.front_matter_key, result[:url])
+        updates_made = true
+      end
+    end
+  end
+
+  if updates_made
+    File.write(selected[:path], new_content)
+    puts "\nStaging changes..."
+    system("git add src/_posts/")
+    puts "Committing changes..."
+    system("git commit -m 'Add social URLs to #{basename}'")
+    puts "Pushing to remote to trigger deployment..."
+    system("git push")
+  end
+  
+  puts "Done!"
 end
 
 case ARGV[0]

lib/publishers/bluesky_publisher.rb

@@ -0,0 +1,136 @@
+# frozen_string_literal: true
+
+require "net/http"
+require "json"
+require "uri"
+
+class BlueskyPublisher < Publisher
+  # TODO: Fill in these 1Password reference URIs
+  OP_HANDLE = "op://Ruby::AZ/Ruby::AZ Bluesky/Handle"
+  OP_APP_PASSWORD = "op://Private/Ruby::AZ Bluesky/App_Password"
+  API = "https://bsky.social"
+
+  def name = "Bluesky"
+  def front_matter_key = "bluesky_post_url"
+
+  def post(text, reply_to: nil)
+    handle = fetch_op_secret(OP_HANDLE)
+    return { error: "Failed to retrieve Bluesky handle from 1Password at #{OP_HANDLE}" } unless handle
+
+    app_password = fetch_op_secret(OP_APP_PASSWORD)
+    return { error: "Failed to retrieve Bluesky app password from 1Password at #{OP_APP_PASSWORD}" } unless app_password
+
+    session = create_session(handle, app_password)
+    return session if session[:error]
+
+    facets = detect_facets(text)
+
+    record = {
+      "$type" => "app.bsky.feed.post",
+      "text" => text,
+      "createdAt" => Time.now.utc.strftime("%Y-%m-%dT%H:%M:%S.%3NZ"),
+    }
+    record["facets"] = facets unless facets.empty?
+    
+    if reply_to
+      cid = fetch_cid(session, reply_to)
+      if cid
+        record["reply"] = {
+          "root" => { "uri" => reply_to, "cid" => cid },
+          "parent" => { "uri" => reply_to, "cid" => cid }
+        }
+      end
+    end
+
+    body = {
+      "repo" => session[:did],
+      "collection" => "app.bsky.feed.post",
+      "record" => record,
+    }
+
+    uri = URI("#{API}/xrpc/com.atproto.repo.createRecord")
+    response = https_post_json(uri, body, auth: session[:access_jwt])
+
+    unless response.is_a?(Net::HTTPSuccess)
+      return { error: "Bluesky API error: #{response.code} #{response.body}" }
+    end
+
+    data = JSON.parse(response.body)
+    rkey = data["uri"].split("/").last
+    { id: data["uri"], url: "https://bsky.app/profile/#{handle}/post/#{rkey}" }
+  end
+
+  private
+
+  def create_session(handle, app_password)
+    uri = URI("#{API}/xrpc/com.atproto.server.createSession")
+    body = { "identifier" => handle, "password" => app_password }
+    response = https_post_json(uri, body)
+
+    unless response.is_a?(Net::HTTPSuccess)
+      return { error: "Bluesky auth failed: #{response.code} #{response.body}" }
+    end
+
+    data = JSON.parse(response.body)
+    { did: data["did"], access_jwt: data["accessJwt"] }
+  end
+
+  def detect_facets(text)
+    facets = []
+
+    # URLs
+    text.scan(/(https?:\/\/[^\s)]+)/) do
+      match = Regexp.last_match
+      byte_start = text[0...match.begin(0)].bytesize
+      byte_end = byte_start + match[0].bytesize
+      facets << {
+        "index" => { "byteStart" => byte_start, "byteEnd" => byte_end },
+        "features" => [{ "$type" => "app.bsky.richtext.facet#link", "uri" => match[0] }],
+      }
+    end
+
+    # Hashtags
+    text.scan(/(?<=\s|^)#(\w+)/) do
+      match = Regexp.last_match
+      tag_with_hash = "##{match[1]}"
+      byte_start = text[0...match.begin(0)].bytesize
+      byte_end = byte_start + tag_with_hash.bytesize
+      facets << {
+        "index" => { "byteStart" => byte_start, "byteEnd" => byte_end },
+        "features" => [{ "$type" => "app.bsky.richtext.facet#tag", "tag" => match[1] }],
+      }
+    end
+
+    facets
+  end
+
+  def https_post_json(uri, body, auth: nil)
+    http = Net::HTTP.new(uri.host, uri.port)
+    http.use_ssl = true
+
+    request = Net::HTTP::Post.new(uri)
+    request["Content-Type"] = "application/json"
+    request["Authorization"] = "Bearer #{auth}" if auth
+    request.body = JSON.generate(body)
+
+    http.request(request)
+  end
+
+  def fetch_cid(session, uri)
+    parts = uri.sub("at://", "").split("/")
+    repo = parts[0]
+    collection = parts[1]
+    rkey = parts[2]
+    
+    get_uri = URI("#{API}/xrpc/com.atproto.repo.getRecord?repo=#{repo}&collection=#{collection}&rkey=#{rkey}")
+    req = Net::HTTP::Get.new(get_uri)
+    req["Authorization"] = "Bearer #{session[:access_jwt]}"
+    
+    http = Net::HTTP.new(get_uri.host, get_uri.port)
+    http.use_ssl = true
+    res = http.request(req)
+    
+    return nil unless res.is_a?(Net::HTTPSuccess)
+    JSON.parse(res.body)["cid"]
+  end
+end

lib/publishers/mastodon_publisher.rb

@@ -0,0 +1,42 @@
+# frozen_string_literal: true
+
+require "net/http"
+require "json"
+require "uri"
+
+class MastodonPublisher < Publisher
+  # TODO: Fill in these 1Password reference URIs
+  OP_TOKEN = "op://Ruby::AZ/Ruby::AZ Mastodon/Access_Token"
+  INSTANCE = "https://ruby.social"
+
+  def name = "Mastodon"
+  def front_matter_key = "mastodon_post_url"
+
+  def post(text, reply_to: nil)
+    token = fetch_op_secret(OP_TOKEN)
+    return { error: "Failed to retrieve Mastodon token from 1Password at #{OP_TOKEN}" } unless token
+
+    uri = URI("#{INSTANCE}/api/v1/statuses")
+    http = Net::HTTP.new(uri.host, uri.port)
+    http.use_ssl = uri.scheme == "https"
+
+    request = Net::HTTP::Post.new(uri)
+    request["Authorization"] = "Bearer #{token}"
+    
+    if reply_to && reply_to.include?("/")
+      reply_to = reply_to.split("/").last
+    end
+
+    data = { "status" => text }
+    data["in_reply_to_id"] = reply_to if reply_to
+    request.set_form_data(data)
+
+    response = http.request(request)
+    unless response.is_a?(Net::HTTPSuccess)
+      return { error: "Mastodon API error: #{response.code} #{response.body}" }
+    end
+
+    data = JSON.parse(response.body)
+    { id: data["id"], url: data["url"] }
+  end
+end