Merge pull request #2073 from OpenBazaar/brian.addBulkUpdatePrices

Adjust listing prices by percentage bulk

Author: cpacia

api/endpoints.go

@@ -117,6 +117,8 @@ func post(i *jsonAPIHandler, path string, w http.ResponseWriter, r *http.Request
 		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")
 	}

api/jsonapi.go

@@ -4116,6 +4116,35 @@ func (i *jsonAPIHandler) GETPeerInfo(w http.ResponseWriter, r *http.Request) {
 	SanitizedResponse(w, string(out))
 }
 
+// Enable bulk updating prices for your listings by percentage
+func (i *jsonAPIHandler) POSTBulkUpdatePrices(w http.ResponseWriter, r *http.Request) {
+	type BulkUpdatePriceRequest struct {
+		Percentage float64 `json:"percentage"`
+	}
+
+	var bulkUpdate BulkUpdatePriceRequest
+	err := json.NewDecoder(r.Body).Decode(&bulkUpdate)
+	if err != nil {
+		http.Error(w, err.Error(), 400)
+		return
+	}
+
+	// Check for bad input
+	if bulkUpdate.Percentage == 0 {
+		SanitizedResponse(w, `{"success": "true"}`)
+		return
+	}
+
+	log.Infof("Updating all listing prices by %v percent\n", bulkUpdate.Percentage)
+	err = i.node.SetPriceOnListings(bulkUpdate.Percentage)
+	if err != nil {
+		http.Error(w, err.Error(), 400)
+		return
+	}
+
+	SanitizedResponse(w, `{"success": "true"}`)
+}
+
 func (i *jsonAPIHandler) POSTBulkUpdateCurrency(w http.ResponseWriter, r *http.Request) {
 	// Retrieve attribute and values to update
 	type BulkUpdateRequest struct {

core/listings.go

@@ -651,6 +651,51 @@ func (n *OpenBazaarNode) GetListingFromSlug(slug string) (*pb.SignedListing, err
 	return sl, nil
 }
 
+func (n *OpenBazaarNode) SetPriceOnListings(percentage float64) error {
+	absPath, err := filepath.Abs(path.Join(n.RepoPath, "root", "listings"))
+	if err != nil {
+		return err
+	}
+	walkpath := func(p string, f os.FileInfo, err error) error {
+		if !f.IsDir() && filepath.Ext(p) == ".json" {
+			signedProto, err := GetSignedListingFromPath(p)
+			if err != nil {
+				return err
+			}
+
+			oldSL := repo.NewSignedListingFromProtobuf(signedProto)
+			l := oldSL.GetListing()
+
+			err = l.SetPrices(percentage)
+			if err != nil {
+				return err
+			}
+
+			lb, err := l.MarshalJSON()
+			if err != nil {
+				return fmt.Errorf("marshaling signed listing (%s): %s", l.GetSlug(), err.Error())
+			}
+			err = n.UpdateListing(lb, false)
+			if err != nil {
+				return err
+			}
+		}
+
+		return nil
+	}
+
+	err = filepath.Walk(absPath, walkpath)
+	if err != nil {
+		return err
+	}
+
+	err = n.SeedNode()
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
 // SetCurrencyOnListings - set currencies accepted for a listing
 func (n *OpenBazaarNode) SetCurrencyOnListings(currencies []string) error {
 	absPath, err := filepath.Abs(path.Join(n.RepoPath, "root", "listings"))

repo/listing.go

@@ -502,6 +502,31 @@ func (l *Listing) GetAcceptedCurrencies() []string {
 	return l.listingProto.Metadata.AcceptedCurrencies
 }
 
+// SetPrices
+func (l *Listing) SetPrices(percentage float64) error {
+
+	currentPrice, ok := new(big.Float).SetString(l.listingProto.Item.BigPrice)
+	if !ok {
+		return nil
+	}
+
+	multiple := percentage/100 + 1
+	floatFactor := new(big.Float).SetFloat64(multiple)
+
+	newPrice := new(big.Float).Mul(currentPrice, floatFactor)
+	newPriceInt, _ := newPrice.Int(nil)
+
+	// Check if new price is negative
+	zeroInt, _ := new(big.Int).SetString("0", 10)
+	if newPriceInt.Cmp(zeroInt) == -1 {
+		l.listingProto.Item.BigPrice = "1"
+	} else {
+		l.listingProto.Item.BigPrice = newPriceInt.String()
+	}
+
+	return nil
+}
+
 // SetAcceptedCurrencies the listing's accepted currency codes. Assumes the node
 // serving the listing has already validated the wallet supports the currencies.
 func (l *Listing) SetAcceptedCurrencies(codes ...string) error {