From ebe8adc1a65ff72da3fa9292d681f7da061696f0 Mon Sep 17 00:00:00 2001 From: pdp8 Date: Mon, 29 May 2023 11:18:46 +0200 Subject: html rendering --- application.rb | 123 ++++++++++++++++++++++++++++++++++++++++++--------------- 1 file changed, 92 insertions(+), 31 deletions(-) (limited to 'application.rb') diff --git a/application.rb b/application.rb index fe84d61..c8a657c 100644 --- a/application.rb +++ b/application.rb @@ -1,8 +1,10 @@ # TODO -# run as service +# unwrap and save object from create +# boost +# archive +# threads # federation # client post media -# client get media # test with pleroma etc require 'json' require 'net/http' @@ -41,6 +43,7 @@ class Application case object["type"] when "Create" File.open(File.join("inbox", SecureRandom.uuid + ".json"), "w+") { |f| f.puts input } + # File.open(File.join("inbox", input["published"] + ".json"), "w+") { |f| f.puts input["object"] } when "Delete" puts input when "Follow" @@ -53,19 +56,16 @@ class Application send accept, [accept["object"]["actor"]] when "Undo" o = object["object"] - # puts o case o["type"] when "Follow" Dir["followers/*.json"].each do |follower| - puts follower - # puts JSON.parse(File.read(follower))["actor"] if JSON.parse(File.read(follower))["actor"] == o["actor"] FileUtils.rm follower end end - # ordered_collection("followers") + else + puts input end - # puts input else puts input end @@ -80,6 +80,12 @@ class Application response = "Key verification failed for POST to #{env["REQUEST_URI"]}." end + when %r{/delete} # receive from client + if auth(env) + FileUtils.rm env["REQUEST_URI"].sub("/delete/", "") + return [302, { "Location" => "/inbox" }, []] + end + when "/outbox" # receive from client if auth(env) code, response = parse input @@ -144,7 +150,13 @@ class Application when "/inbox" if auth(env) - type, response = format ordered_collection(env["REQUEST_PATH"]), env["HTTP_ACCEPT"] + case env["HTTP_ACCEPT"] + when /json/ + response = ordered_collection(env["REQUEST_PATH"]).to_json + else + type = "text/html" + response = html env["REQUEST_PATH"] + end code = 200 else code = 403 @@ -160,6 +172,76 @@ class Application [code, { "Content-Type" => type }, [response]] end + def html path + html = "\n\n\t" + Dir[File.join(path.sub(/^\//, ''), "*")].sort_by { |f| File.stat(f).ctime }.each do |file| + item = JSON.parse(File.read(file)) + html << "\n\t\t#{mention item["actor"]} #{item["object"]["published"].sub("T", + " ")}

#{item["object"]["content"]}" + if item["object"]["attachment"] + item["object"]["attachment"].each do |att| + case att["mediaType"] + when /audio/ + html << "\n
" + when /image/ + html << "\n
" + when /video/ + html << "\n
" + else + html << att + "
" + html << "\n#{att["url"]}" + end + end + end + html << "

+ + + +

" + end + html << "\n\t\n" + end +=begin +=end + +=begin + def html o + html = " + + + #{mention o["actor"]} #{o["object"]["published"]} +

#{o["object"]["content"]} + " + if o["object"]["attachment"] + o["object"]["attachment"].each do |att| + case att["mediaType"] + when /audio/ + html<< "\n
" + when /image/ + html << "\n
" + when /video/ + html<< "\n
" + else + html<< att + "
" + html << "\n#{att["url"]}" + end + end + end + end + html << "\n\t\n" + html + end +=end + def parse input date = Time.now.strftime("%Y-%m-%dT%H:%M:%S") # TODO media attachments, hashtags @@ -210,25 +292,6 @@ class Application [code, response] end - def format response, accept - if accept == "text/plain" - response = response["orderedItems"].collect.with_index do |r, i| - object = r["object"] - doc = Nokogiri::HTML(object["content"]) - str = "#{i}\t#{object["published"]}\t#{mention r["actor"]}\n\n#{doc.text}" - str << "\n" + object["attachment"].collect { |att| - `kitty +kitten icat #{att["url"]}` - }.join("\n") if object["attachment"] - str - end.join("\n\n") - type = "text/plain" - else - response = response.to_json - type = 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"' - end - [type, response] - end - def actor mention mention = mention.sub(/^@/, '').chomp user, server = mention.split("@") @@ -243,7 +306,6 @@ class Application end def send object, urls - # puts object, urls # https://github.com/mastodon/mastodon/blob/main/app/lib/request.rb keypair = OpenSSL::PKey::RSA.new(File.read('private.pem')) responses = [] @@ -280,9 +342,7 @@ class Application def ordered_collection dir collection = dir.sub(/^\//, "") - posts = Dir[File.join(collection, "*.json")].collect { |f| - p f; JSON.parse(File.read f) - }.sort_by { |o| o["published"] } + posts = Dir[File.join(collection, "*.json")].collect { |f| JSON.parse(File.read f) }.sort_by { |o| o["published"] } { "@context" => "https://www.w3.org/ns/activitystreams", "summary" => "#{USER} #{collection}", @@ -350,5 +410,6 @@ class Application usr = File.read(".usr").chomp pwd = File.read(".pwd").chomp auth.provided? && auth.basic? && auth.credentials && auth.credentials == [usr, pwd] + true end end -- cgit v1.2.3