1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
# 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("<br>")
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)
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
|
