Merge branch 'master' of https://github.com/bitcoin-sv/spv-wallet int…

…o BUX-246/Linters

actions/contacts/accept.go

@@ -0,0 +1,44 @@
+package contacts
+
+import (
+	"errors"
+	"net/http"
+
+	"github.com/bitcoin-sv/spv-wallet/engine"
+	"github.com/bitcoin-sv/spv-wallet/server/auth"
+	"github.com/gin-gonic/gin"
+)
+
+// accept will accept contact request
+// Accept contact godoc
+// @Summary		Accept contact
+// @Description	Accept contact. For contact with status "awaiting" change status to "unconfirmed"
+// @Tags		Contact
+// @Produce		json
+// @Param		paymail path string true "Paymail address of the contact the user wants to accept"
+// @Success		200
+// @Failure		404	"Contact not found"
+// @Failure		422	"Contact status not awaiting"
+// @Failure		500	"Internal server error"
+// @Router		/v1/contact/accepted/{paymail} [PATCH]
+// @Security	x-auth-xpub
+func (a *Action) accept(c *gin.Context) {
+	reqXPubID := c.GetString(auth.ParamXPubHashKey)
+	paymail := c.Param("paymail")
+
+	err := a.Services.SpvWalletEngine.AcceptContact(c, reqXPubID, paymail)
+
+	if err != nil {
+		switch {
+		case errors.Is(err, engine.ErrContactNotFound):
+			c.JSON(http.StatusNotFound, err.Error())
+		case errors.Is(err, engine.ErrContactIncorrectStatus):
+			c.JSON(http.StatusUnprocessableEntity, err.Error())
+		default:
+			c.JSON(http.StatusInternalServerError, err.Error())
+		}
+		return
+	}
+
+	c.Status(http.StatusOK)
+}

actions/contacts/confirm.go

@@ -0,0 +1,43 @@
+package contacts
+
+import (
+	"errors"
+	"net/http"
+
+	"github.com/bitcoin-sv/spv-wallet/engine"
+	"github.com/bitcoin-sv/spv-wallet/server/auth"
+	"github.com/gin-gonic/gin"
+)
+
+// confirm will confirm contact request
+// Confirm contact godoc
+// @Summary		Confirm contact
+// @Description	Confirm contact. For contact with status "unconfirmed" change status to "confirmed"
+// @Tags		Contact
+// @Produce		json
+// @Param		paymail path string true "Paymail address of the contact the user wants to confirm"
+// @Success		200
+// @Failure		404	"Contact not found"
+// @Failure		422	"Contact status not unconfirmed"
+// @Failure		500	"Internal server error"
+// @Router		/v1/contact/confirmed/{paymail} [PATCH]
+// @Security	x-auth-xpub
+func (a *Action) confirm(c *gin.Context) {
+	reqXPubID := c.GetString(auth.ParamXPubHashKey)
+	paymail := c.Param("paymail")
+
+	err := a.Services.SpvWalletEngine.ConfirmContact(c, reqXPubID, paymail)
+
+	if err != nil {
+		switch {
+		case errors.Is(err, engine.ErrContactNotFound):
+			c.JSON(http.StatusNotFound, err.Error())
+		case errors.Is(err, engine.ErrContactIncorrectStatus):
+			c.JSON(http.StatusUnprocessableEntity, err.Error())
+		default:
+			c.JSON(http.StatusInternalServerError, err.Error())
+		}
+		return
+	}
+	c.Status(http.StatusOK)
+}

actions/contacts/models.go

@@ -23,13 +23,3 @@ func (p *UpsertContact) validate() error {
 
 	return nil
 }
-
-// UpdateContact is the model for updating a contact
-type UpdateContact struct {
-	XPubID   string          `json:"xpub_id"`
-	FullName string          `json:"full_name"`
-	Paymail  string          `json:"paymail"`
-	PubKey   string          `json:"pubKey"`
-	Status   string          `json:"status"`
-	Metadata engine.Metadata `json:"metadata"`
-}

actions/contacts/reject.go

@@ -0,0 +1,43 @@
+package contacts
+
+import (
+	"errors"
+	"net/http"
+
+	"github.com/bitcoin-sv/spv-wallet/engine"
+	"github.com/bitcoin-sv/spv-wallet/server/auth"
+	"github.com/gin-gonic/gin"
+)
+
+// reject will reject contact request
+// Reject contact godoc
+// @Summary		Reject contact
+// @Description	Reject contact. For contact with status "awaiting" delete contact
+// @Tags		Contact
+// @Produce		json
+// @Param		paymail path string true "Paymail address of the contact the user wants to reject"
+// @Success		200
+// @Failure		404	"Contact not found"
+// @Failure		422	"Contact status not awaiting"
+// @Failure		500	"Internal server error"
+// @Router		/v1/contact/rejected/{paymail} [PATCH]
+// @Security	x-auth-xpub
+func (a *Action) reject(c *gin.Context) {
+	reqXPubID := c.GetString(auth.ParamXPubHashKey)
+	paymail := c.Param("paymail")
+
+	err := a.Services.SpvWalletEngine.RejectContact(c, reqXPubID, paymail)
+
+	if err != nil {
+		switch {
+		case errors.Is(err, engine.ErrContactNotFound):
+			c.JSON(http.StatusNotFound, err.Error())
+		case errors.Is(err, engine.ErrContactIncorrectStatus):
+			c.JSON(http.StatusUnprocessableEntity, err.Error())
+		default:
+			c.JSON(http.StatusInternalServerError, err.Error())
+		}
+		return
+	}
+	c.Status(http.StatusOK)
+}

actions/contacts/routes.go

@@ -17,12 +17,14 @@ func NewHandler(appConfig *config.AppConfig, services *config.AppServices) route
 	action := &Action{actions.Action{AppConfig: appConfig, Services: services}}
 
 	apiEndpoints := routes.APIEndpointsFunc(func(router *gin.RouterGroup) {
-		contactGroup := router.Group("/contact")
-		contactGroup.PUT("/:paymail", action.upsert)
+		group := router.Group("/contact")
+		group.PUT("/:paymail", action.upsert)
 
-		contactGroup.PATCH("", action.update)
-		contactsGroup := router.Group("/contacts")
-		contactsGroup.GET("", action.search)
+		group.PATCH("/accepted/:paymail", action.accept)
+		group.PATCH("/rejected/:paymail", action.reject)
+		group.PATCH("/confirmed/:paymail", action.confirm)
+
+		group.POST("search", action.search)
 	})
 
 	return apiEndpoints

actions/contacts/routes_test.go

@@ -15,7 +15,10 @@ func (ts *TestSuite) TestContactsRegisterRoutes() {
 			url    string
 		}{
 			{"PUT", "/" + config.APIVersion + "/contact/:paymail"},
-			{"GET", "/" + config.APIVersion + "/contacts"},
+			{"PATCH", "/" + config.APIVersion + "/contact/accepted/:paymail"},
+			{"PATCH", "/" + config.APIVersion + "/contact/rejected/:paymail"},
+			{"PATCH", "/" + config.APIVersion + "/contact/confirmed/:paymail"},
+			{"POST", "/" + config.APIVersion + "/contact/search"},
 		}
 
 		ts.Router.Routes()

actions/contacts/search.go

@@ -4,9 +4,7 @@ import (
 	"net/http"
 
 	"github.com/bitcoin-sv/spv-wallet/actions"
-	"github.com/bitcoin-sv/spv-wallet/engine"
 	"github.com/bitcoin-sv/spv-wallet/mappings"
-	"github.com/bitcoin-sv/spv-wallet/models"
 	"github.com/bitcoin-sv/spv-wallet/server/auth"
 	"github.com/gin-gonic/gin"
 )
@@ -25,42 +23,29 @@ import (
 // @Success		200 {object} []models.Contact "List of contacts"
 // @Failure		400	"Bad request - Error while parsing SearchRequestParameters from request body"
 // @Failure 	500	"Internal server error - Error while searching for contacts"
-// @Router		/v1/contacts [get]
+// @Router		/v1/contact/search [POST]
 // @Security	x-auth-xpub
 func (a *Action) search(c *gin.Context) {
 	reqXPubID := c.GetString(auth.ParamXPubHashKey)
 
-	params := c.Request.URL.Query()
-
-	queryParams, metadata, _, err := actions.GetSearchQueryParameters(c)
+	queryParams, metadata, conditions, err := actions.GetSearchQueryParameters(c)
 	if err != nil {
 		c.JSON(http.StatusExpectationFailed, err.Error())
 		return
 	}
 
-	dbConditions := make(map[string]interface{})
-
-	for key, value := range params {
-		dbConditions[key] = value
-	}
-
-	dbConditions["xpub_id"] = reqXPubID
-
-	var contacts []*engine.Contact
-	if contacts, err = a.Services.SpvWalletEngine.GetContacts(
+	contacts, err := a.Services.SpvWalletEngine.GetContacts(
 		c.Request.Context(),
+		reqXPubID,
 		metadata,
-		&dbConditions,
+		*conditions,
 		queryParams,
-	); err != nil {
-		c.JSON(http.StatusExpectationFailed, err.Error())
-		return
-	}
+	)
 
-	contactContracts := make([]*models.Contact, 0)
-	for _, contact := range contacts {
-		contactContracts = append(contactContracts, mappings.MapToContactContract(contact))
+	if err != nil {
+		c.JSON(http.StatusInternalServerError, err.Error())
+		return
 	}
 
-	c.JSON(http.StatusOK, contactContracts)
+	c.JSON(http.StatusOK, mappings.MapToContactContracts(contacts))
 }