# client-server post "/outbox" do protected! request.body.rewind # in case someone already read it body = request.body.read date = Time.now.strftime("%Y-%m-%dT%H:%M:%S") # TODO hashtags, replys outbox_path = File.join("public/outbox", date + ".json") object_path = File.join("public/objects", date + ".json") create = { "@context" => "https://www.w3.org/ns/activitystreams", "id" => File.join(SOCIAL_URL, outbox_path), "type" => "Create", "actor" => ACTOR, "object" => { "id" => File.join(SOCIAL_URL, object_path), "type" => "Note", "attributedTo" => ACTOR, "published" => date, "content" => "", "to" => ["https://www.w3.org/ns/activitystreams#Public"] }, "published" => date, "to" => ["https://www.w3.org/ns/activitystreams#Public"] } recipients = [] if /^@/.match body mentions, body = body.split("\n", 2) mentions.split(/, */).each do |m| recipients << actor(m.chomp) end end create["object"]["content"] = body.lines.select { |l| !l.empty? }.join("
") recipients += Dir[File.join("public/followers", "*.json")].collect { |f| JSON.parse(File.read(f))["actor"] } recipients.delete ACTOR recipients.uniq! create["object"]["to"] += recipients create["to"] += recipients File.open(outbox_path, "w+") { |f| f.puts create.to_json } File.open(object_path, "w+") { |f| f.puts create["object"].to_json } recipients.each { |r| send_signed create, r } end post "/archive" do protected! FileUtils.mv params['file'], "archive/" redirect to(params['redirect']) end post "/delete" do protected! FileUtils.rm params['file'] redirect to(params['redirect']) end post "/delete_all" do protected! FileUtils.rm Dir["inbox/*.json"] redirect to("/") end post "/follow/*" do protected! mention = params['splat'][0] actor = actor(mention) p mention p actor follow = { "@context" => "https://www.w3.org/ns/activitystreams", "id" => File.join(SOCIAL_URL, "following", mention + ".json"), "type" => "Follow", "actor" => ACTOR, "object" => actor } send_signed follow, actor redirect to("/") end post "/unfollow/*" do protected! mention = params['splat'][0] actor = actor(mention) following_path = File.join("public", "following", mention + ".json") if File.exists?(following_path) undo = { "@context" => "https://www.w3.org/ns/activitystreams", "id" => File.join(SOCIAL_URL + "#undo", SecureRandom.uuid), "type" => "Undo", "actor" => ACTOR, "object" => JSON.parse(File.read(following_path)) } send_signed undo, actor FileUtils.rm following_path redirect to("/") end end post "/login" do session["client"] = true if params["secret"] == File.read(".pwd").chomp redirect to("/") end # private ["/", "/archive"].each do |path| get path, :provides => 'html' do protected! if path == '/' @dir = 'inbox' @alt_dir = '/archive' @alt_name = 'archive' else @dir = path.sub('/','') @alt_dir = '/' @alt_name = 'inbox' end threads erb :index end end