endpoints.go

package api

import (
	"net/http"
	"strings"
)

func put(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request) {
	switch {
	case strings.HasPrefix(path, "/ob/profile"):
		i.PUTProfile(w, r)
	case strings.HasPrefix(path, "/ob/settings"):
		i.PUTSettings(w, r)
	case strings.HasPrefix(path, "/ob/moderator"):
		i.PUTModerator(w, r)
	case strings.HasPrefix(path, "/ob/listing"):
		i.PUTListing(w, r)
	case strings.HasPrefix(path, "/ob/post"):
		i.PUTPost(w, r)
	default:
		ErrorResponse(w, http.StatusNotFound, "Not Found")
	}
}

//nolint:dupl
func post(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request) {
	switch {
	case strings.HasPrefix(path, "/ob/listing"):
		i.POSTListing(w, r)
	case strings.HasPrefix(path, "/ob/follow"):
		blockingStartupMiddleware(i, w, r, i.POSTFollow)
	case strings.HasPrefix(path, "/ob/unfollow"):
		blockingStartupMiddleware(i, w, r, i.POSTUnfollow)
	case strings.HasPrefix(path, "/ob/profile"):
		i.POSTProfile(w, r)
	case strings.HasPrefix(path, "/ob/images"):
		i.POSTImage(w, r)
	case strings.HasPrefix(path, "/wallet/spend"):
		i.POSTSpendCoins(w, r)
	case strings.HasPrefix(path, "/ob/settings"):
		i.POSTSettings(w, r)
	case strings.HasPrefix(path, "/ob/inventory"):
		i.POSTInventory(w, r)
	case strings.HasPrefix(path, "/ob/avatar"):
		i.POSTAvatar(w, r)
	case strings.HasPrefix(path, "/ob/header"):
		i.POSTHeader(w, r)
	case strings.HasPrefix(path, "/ob/orderconfirmation"):
		blockingStartupMiddleware(i, w, r, i.POSTOrderConfirmation)
	case strings.HasPrefix(path, "/ob/ordercancel"):
		blockingStartupMiddleware(i, w, r, i.POSTOrderCancel)
	case strings.HasPrefix(path, "/ob/orderfulfillment"):
		blockingStartupMiddleware(i, w, r, i.POSTOrderFulfill)
	case strings.HasPrefix(path, "/ob/ordercompletion"):
		blockingStartupMiddleware(i, w, r, i.POSTOrderComplete)
	case strings.HasPrefix(path, "/ob/orderspend"):
		blockingStartupMiddleware(i, w, r, i.POSTSpendCoinsForOrder)
	case strings.HasPrefix(path, "/ob/refund"):
		blockingStartupMiddleware(i, w, r, i.POSTRefund)
	case strings.HasPrefix(path, "/wallet/resyncblockchain"):
		i.POSTResyncBlockchain(w, r)
	case strings.HasPrefix(path, "/wallet/bumpfee"):
		i.POSTBumpFee(w, r)
	case strings.HasPrefix(path, "/ob/opendispute"):
		blockingStartupMiddleware(i, w, r, i.POSTOpenDispute)
	case strings.HasPrefix(path, "/ob/closedispute"):
		blockingStartupMiddleware(i, w, r, i.POSTCloseDispute)
	case strings.HasPrefix(path, "/ob/releasefunds"):
		blockingStartupMiddleware(i, w, r, i.POSTReleaseFunds)
	case strings.HasPrefix(path, "/ob/releaseescrow"):
		blockingStartupMiddleware(i, w, r, i.POSTReleaseEscrow)
	case strings.HasPrefix(path, "/ob/chat"):
		blockingStartupMiddleware(i, w, r, i.POSTChat)
	case strings.HasPrefix(path, "/ob/signmessage"):
		i.POSTSignMessage(w, r)
	case strings.HasPrefix(path, "/ob/verifymessage"):
		i.POSTVerifyMessage(w, r)
	case strings.HasPrefix(path, "/ob/groupchat"):
		blockingStartupMiddleware(i, w, r, i.POSTGroupChat)
	case strings.HasPrefix(path, "/ob/markchatasread"):
		blockingStartupMiddleware(i, w, r, i.POSTMarkChatAsRead)
	case strings.HasPrefix(path, "/ob/marknotificationasread"):
		i.POSTMarkNotificationAsRead(w, r)
	case strings.HasPrefix(path, "/ob/marknotificationsasread"):
		i.POSTMarkNotificationsAsRead(w, r)
	case strings.HasPrefix(path, "/ob/fetchprofiles"):
		i.POSTFetchProfiles(w, r)
	case strings.HasPrefix(path, "/ob/blocknode"):
		i.POSTBlockNode(w, r)
	case strings.HasPrefix(path, "/ob/shutdown"):
		i.POSTShutdown(w, r)
	case strings.HasPrefix(path, "/ob/estimatetotal"):
		i.POSTEstimateTotal(w, r)
	case strings.HasPrefix(path, "/ob/checkoutbreakdown"):
		i.POSTCheckoutBreakdown(w, r)
	case strings.HasPrefix(path, "/ob/fetchratings"):
		i.POSTFetchRatings(w, r)
	case strings.HasPrefix(path, "/ob/sales"):
		i.POSTSales(w, r)
	case strings.HasPrefix(path, "/ob/purchases"):
		i.POSTPurchases(w, r)
	case strings.HasPrefix(path, "/ob/purchase"):
		blockingStartupMiddleware(i, w, r, i.POSTPurchase)
	case strings.HasPrefix(path, "/ob/cases"):
		i.POSTCases(w, r)
	case strings.HasPrefix(path, "/ob/publish"):
		i.POSTPublish(w, r)
	case strings.HasPrefix(path, "/ob/importlistings"):
		i.POSTImportListings(w, r)
	case strings.HasPrefix(path, "/ob/purgecache"):
		i.POSTPurgeCache(w, r)
	case strings.HasPrefix(path, "/ob/testemailnotifications"):
		i.POSTTestEmailNotifications(w, r)
	case strings.HasPrefix(path, "/ob/post"):
		i.POSTPost(w, r)
	case strings.HasPrefix(path, "/ob/bulkupdatecurrency"):
		i.POSTBulkUpdateCurrency(w, r)
	case strings.HasPrefix(path, "/ob/resendordermessage"):
		i.POSTResendOrderMessage(w, r)
	case strings.HasPrefix(path, "/ob/hashmessage"):
		i.POSTHashMessage(w, r)
	case strings.HasPrefix(path, "/ob/bulkupdateprices"):
		i.POSTBulkUpdatePrices(w, r)
	default:
		ErrorResponse(w, http.StatusNotFound, "Not Found")
	}
}

//nolint:dupl
func get(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request) {
	switch {
	case strings.HasPrefix(path, "/ob/status"):
		i.GETStatus(w, r)
	case strings.HasPrefix(path, "/ob/peers"):
		i.GETPeers(w, r)
	case strings.HasPrefix(path, "/ob/config"):
		i.GETConfig(w, r)
	case strings.HasPrefix(path, "/wallet/currencies"):
		i.GETWalletCurrencyDictionary(w, r)
	case strings.HasPrefix(path, "/wallet/address"):
		i.GETAddress(w, r)
	case strings.HasPrefix(path, "/wallet/mnemonic"):
		i.GETMnemonic(w, r)
	case strings.HasPrefix(path, "/wallet/balance"):
		i.GETBalance(w, r)
	case strings.HasPrefix(path, "/wallet/transactions"):
		i.GETTransactions(w, r)
	case strings.HasPrefix(path, "/ob/settings"):
		i.GETSettings(w, r)
	case strings.HasPrefix(path, "/ob/closestpeers"):
		i.GETClosestPeers(w, r)
	case strings.HasPrefix(path, "/ob/exchangerate"):
		i.GETExchangeRate(w, r)
	case strings.HasPrefix(path, "/ob/followers"):
		i.GETFollowers(w, r)
	case strings.HasPrefix(path, "/ob/following"):
		i.GETFollowing(w, r)
	case strings.HasPrefix(path, "/ob/inventory"):
		i.GETInventory(w, r)
	case strings.HasPrefix(path, "/ob/profile"):
		i.GETProfile(w, r)
	case strings.HasPrefix(path, "/ob/listings"):
		i.GETListings(w, r)
	case strings.HasPrefix(path, "/ob/listing"):
		i.GETListing(w, r)
	case strings.HasPrefix(path, "/ob/followsme"):
		i.GETFollowsMe(w, r)
	case strings.HasPrefix(path, "/ob/isfollowing"):
		i.GETIsFollowing(w, r)
	case strings.HasPrefix(path, "/ob/order"):
		i.GETOrder(w, r)
	case strings.HasPrefix(path, "/ob/moderators"):
		i.GETModerators(w, r)
	case strings.HasPrefix(path, "/ob/chatmessages"):
		i.GETChatMessages(w, r)
	case strings.HasPrefix(path, "/ob/chatconversations"):
		i.GETChatConversations(w, r)
	case strings.HasPrefix(path, "/ob/notifications"):
		i.GETNotifications(w, r)
	case strings.HasPrefix(path, "/ob/image"):
		i.GETImage(w, r)
	case strings.HasPrefix(path, "/ob/avatar"):
		i.GETAvatar(w, r)
	case strings.HasPrefix(path, "/ob/header"):
		i.GETHeader(w, r)
	case strings.HasPrefix(path, "/ob/purchases"):
		i.GETPurchases(w, r)
	case strings.HasPrefix(path, "/ob/sales"):
		i.GETSales(w, r)
	case strings.HasPrefix(path, "/ob/cases"):
		i.GETCases(w, r)
	case strings.HasPrefix(path, "/ob/case"):
		i.GETCase(w, r)
	case strings.HasPrefix(path, "/wallet/estimatefee"):
		i.GETEstimateFee(w, r)
	case strings.HasPrefix(path, "/wallet/fees"):
		i.GETFees(w, r)
	case strings.HasPrefix(path, "/ob/ratings"):
		i.GETRatings(w, r)
	case strings.HasPrefix(path, "/ob/rating"):
		i.GETRating(w, r)
	case strings.HasPrefix(path, "/ob/healthcheck"):
		i.GETHealthCheck(w, r)
	case strings.HasPrefix(path, "/wallet/status"):
		i.GETWalletStatus(w, r)
	case strings.HasPrefix(path, "/ob/ipns"):
		i.GETIPNS(w, r)
	case strings.HasPrefix(path, "/ob/resolveipns"):
		i.GETResolveIPNS(w, r)
	case strings.HasPrefix(path, "/ob/peerinfo"):
		i.GETPeerInfo(w, r)
	case strings.HasPrefix(path, "/ob/posts"):
		i.GETPosts(w, r)
	case strings.HasPrefix(path, "/ob/post"):
		i.GETPost(w, r)
	case strings.HasPrefix(path, "/ob/scanofflinemessages"):
		i.GETScanOfflineMessages(w, r)
	default:
		ErrorResponse(w, http.StatusNotFound, "Not Found")
	}
}

func patch(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request) {
	switch {
	case strings.HasPrefix(path, "/ob/settings"):
		i.PATCHSettings(w, r)
	case strings.HasPrefix(path, "/ob/profile"):
		i.PATCHProfile(w, r)
	default:
		ErrorResponse(w, http.StatusNotFound, "Not Found")
	}
}

func deleter(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request) {
	switch {
	case strings.HasPrefix(path, "/ob/moderator"):
		i.DELETEModerator(w, r)
	case strings.HasPrefix(path, "/ob/listing"):
		i.DELETEListing(w, r)
	case strings.HasPrefix(path, "/ob/chatmessage"):
		i.DELETEChatMessage(w, r)
	case strings.HasPrefix(path, "/ob/chatconversation"):
		i.DELETEChatConversation(w, r)
	case strings.HasPrefix(path, "/ob/notifications"):
		i.DELETENotification(w, r)
	case strings.HasPrefix(path, "/ob/blocknode"):
		i.DELETEBlockNode(w, r)
	case strings.HasPrefix(path, "/ob/post"):
		i.DELETEPost(w, r)
	default:
		ErrorResponse(w, http.StatusNotFound, "Not Found")
	}
}

func gatewayAllowedPath(path, method string) bool {
	allowedGets := []string{"/ob/followers", "/ob/following", "/ob/profile", "/ob/listing", "/ob/listings", "/ob/inventory", "/ob/image", "/ob/avatar", "/ob/header", "/ob/rating", "/ob/ratings", "/ob/posts", "/ob/post", "/ob/ipns"}
	allowedPosts := []string{"/ob/fetchprofiles", "/ob/fetchratings"}
	if method == "GET" {
		for _, p := range allowedGets {
			if strings.HasPrefix(path, p) {
				return true
			}
		}
	} else if method == "POST" {
		for _, p := range allowedPosts {
			if strings.HasPrefix(path, p) {
				return true
			}
		}
	}
	return false
}

func blockingStartupMiddleware(i *jsonAPIHandler, w http.ResponseWriter, r *http.Request, requestFunc func(w http.ResponseWriter, r *http.Request)) {
	i.node.Service.WaitForReady()
	requestFunc(w, r)
}