1 files changed, 65 insertions, 0 deletions
diff --git a/svc/post.go b/svc/post.go
new file mode 100644
index 0000000..0355afa
--- /dev/null
+++ b/svc/post.go
@@ -0,0 +1,65 @@
+package svc // import "github.com/getwtxt/getwtxt/svc"
+
+import (
+	"fmt"
+	"log"
+	"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 {
+		log400(w, r, "Error Parsing Values: "+err.Error())
+		return
+	}
+
+	nick := r.FormValue("nickname")
+	urls := r.FormValue("url")
+	if nick == "" || urls == "" {
+		log400(w, r, "Nickname or URL missing")
+		return
+	}
+
+	uip := getIPFromCtx(r.Context())
+
+	out, remoteRegistry, err := registry.GetTwtxt(urls)
+	if err != nil {
+		log400(w, r, "Error Fetching twtxt Data: "+err.Error())
+		return
+	}
+
+	if remoteRegistry {
+		remoteRegistries.Mu.Lock()
+		remoteRegistries.List = append(remoteRegistries.List, urls)
+		remoteRegistries.Mu.Unlock()
+
+		if err := twtxtCache.CrawlRemoteRegistry(urls); err != nil {
+			log400(w, r, "Error Crawling Remote Registry: "+err.Error())
+			return
+		}
+		log200(r)
+		return
+	}
+
+	statuses, err := registry.ParseUserTwtxt(out, nick, urls)
+	if err != nil {
+		log.Printf("Error Parsing User Data: %v\n", err.Error())
+	}
+
+	if err := twtxtCache.AddUser(nick, urls, "", uip, statuses); err != nil {
+		log400(w, r, "Error Adding User to Cache: "+err.Error())
+		return
+	}
+
+	log200(r)
+	_, err = w.Write([]byte(fmt.Sprintf("200 OK\n")))
+	if err != nil {
+		log.Printf("%v\n", err.Error())
+	}
+}