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
|
package main
import (
"fmt"
"net/http"
"github.com/getwtxt/registry"
)
// Requests to apiEndpointPOSTHandler are passed off to this
// function. apiPostUser then fetches the twtxt data, then if
// it's an individual user's file, adds it. If it's registry
// output, it scrapes the users/urls/statuses from the remote
// registry before adding each user to the local cache.
func apiPostUser(w http.ResponseWriter, r *http.Request) {
if err := r.ParseForm(); err != nil {
_, _ = w.Write([]byte(fmt.Sprintf("400 Bad Request: %v\n", err)))
log400(r, err)
return
}
nick := r.FormValue("nickname")
urls := r.FormValue("url")
if nick == "" || urls == "" {
_, _ = w.Write([]byte("400 Bad Request: Nickname or URL Missing\n"))
log400(r, fmt.Errorf("nickname or URL missing"))
return
}
uip := getIPFromCtx(r.Context())
out, remoteRegistry, err := registry.GetTwtxt(urls)
if err != nil {
_, _ = w.Write([]byte(fmt.Sprintf("400 Bad Request: %v\n", err)))
log400(r, err)
return
}
if remoteRegistry {
remoteRegistries.Mu.Lock()
remoteRegistries.List = append(remoteRegistries.List, urls)
remoteRegistries.Mu.Unlock()
err := twtxtCache.ScrapeRemoteRegistry(urls)
if err != nil {
_, _ = w.Write([]byte(fmt.Sprintf("400 Bad Request: %v\n", err)))
log400(r, err)
return
}
log200(r)
return
}
statuses, err := registry.ParseUserTwtxt(out, nick, urls)
if err != nil {
_, _ = w.Write([]byte(fmt.Sprintf("400 Bad Request: %v\n", err)))
log400(r, err)
return
}
err = twtxtCache.AddUser(nick, urls, uip, statuses)
if err != nil {
_, _ = w.Write([]byte(fmt.Sprintf("400 Bad Request: %v\n", err)))
log400(r, err)
return
}
log200(r)
_, _ = w.Write([]byte(fmt.Sprintf("200 OK\n")))
}
|