path: root/post.go

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")))
}