Files
adamantium/lib/adamantium/syndication/mastodon.rb
2023-02-04 14:27:06 +11:00

76 lines
2.2 KiB
Ruby

require "digest"
require "dry/monads"
require "httparty"
require "tempfile"
require "open-uri"
module Adamantium
module Syndication
class Mastodon
include Dry::Monads[:result]
include Deps["settings", "logger"]
def call(post:)
unless settings.mastodon_token && settings.mastodon_server
logger.info("No Mastodon credentials")
return Failure(:no_mastodon_credentials)
end
content = if post[:name]
"#{post[:name]}#{settings.micropub_site_url}/post/#{post[:slug]}"
else
post[:content]
end
tags = post[:category].map { |tag| "##{tag}" }.join(" ")
text_with_tags = "#{content} #{tags}"
key = Digest::MD5.hexdigest text_with_tags
mastodon_token = settings.mastodon_token
mastodon_server = settings.mastodon_server.split("@").first
logger.info("Photos: #{post[:photos].inspect}")
media_ids = post[:photos]&.map do |photo|
file = Tempfile.new(SecureRandom.uuid)
file.write(URI.open(photo["value"]).read)
file.rewind
response = HTTParty.post("#{mastodon_server}api/v2/media", {
headers: {
Authorization: "Bearer #{mastodon_token}"
},
body: {
file: file.read,
description: photo["alt"]
}
})
file.close
file.unlink
logger.info(response.body)
JSON.parse(response.body, symbolize_names: true).fetch(:id, nil)
end&.compact
raise media_ids.inspect
response = HTTParty.post("#{mastodon_server}api/v1/statuses", {
headers: {
"Idempotency-Key": key,
Authorization: "Bearer #{mastodon_token}"
},
body: {
status: text_with_tags,
media_ids: media_ids
}
})
if response.code >= 200 && response.code < 300
status = JSON.parse(response.body, symbolize_names: true)
Success("#{mastodon_server}/#{status[:id]}")
else
logger.info("Failed to syndicate to Mastodon: #{response.message}")
Failure(response.message)
end
end
end
end
end