Merge pull request #1591 from stakwork/feat/providers_list

Added Bounty Providers Endpoint

db/interface.go

@@ -134,6 +134,7 @@ type Database interface {
 	GetPersonByPubkey(pubkey string) Person
 	GetBountiesByDateRange(r PaymentDateRange, re *http.Request) []Bounty
 	GetBountiesByDateRangeCount(r PaymentDateRange, re *http.Request) int64
+	GetBountiesProviders(r PaymentDateRange, re *http.Request) []Person
 	PersonUniqueNameFromName(name string) (string, error)
 	ProcessAlerts(p Person)
 	UserHasAccess(pubKeyFromAuth string, uuid string, role string) bool

db/metrics.go

@@ -190,7 +190,7 @@ func (db database) GetBountiesByDateRange(r PaymentDateRange, re *http.Request)
 	} else {
 		orderQuery = " ORDER BY " + sortBy + "" + "DESC"
 	}
-	if limit > 1 {
+	if limit > 0 {
 		limitQuery = fmt.Sprintf("LIMIT %d  OFFSET %d", limit, offset)
 	}
 
@@ -247,3 +247,56 @@ func (db database) GetBountiesByDateRangeCount(r PaymentDateRange, re *http.Requ
 	db.db.Raw(allQuery).Scan(&count)
 	return count
 }
+
+func (db database) GetBountiesProviders(r PaymentDateRange, re *http.Request) []Person {
+	offset, limit, _, _, _ := utils.GetPaginationParams(re)
+	keys := re.URL.Query()
+	open := keys.Get("Open")
+	assingned := keys.Get("Assigned")
+	paid := keys.Get("Paid")
+	providers := keys.Get("provider")
+
+	var statusConditions []string
+
+	limitQuery := ""
+
+	if open == "true" {
+		statusConditions = append(statusConditions, "assignee = '' AND paid != true")
+	}
+	if assingned == "true" {
+		statusConditions = append(statusConditions, "assignee != '' AND paid = false")
+	}
+	if paid == "true" {
+		statusConditions = append(statusConditions, "paid = true")
+	}
+
+	var statusQuery string
+	if len(statusConditions) > 0 {
+		statusQuery = " AND (" + strings.Join(statusConditions, " OR ") + ")"
+	} else {
+		statusQuery = ""
+	}
+
+	providerCondition := ""
+	if len(providers) > 0 {
+		providerSlice := strings.Split(providers, ",")
+		providerCondition = " AND owner_id IN ('" + strings.Join(providerSlice, "','") + "')"
+	}
+
+	if limit > 0 {
+		limitQuery = fmt.Sprintf("LIMIT %d  OFFSET %d", limit, offset)
+	}
+
+	bountyOwners := []BountyOwners{}
+	bountyProviders := []Person{}
+
+	query := `SELECT DISTINCT owner_id FROM public.bounty WHERE created >= '` + r.StartDate + `'  AND created <= '` + r.EndDate + `'` + providerCondition
+	allQuery := query + " " + statusQuery + " " + limitQuery
+	db.db.Raw(allQuery).Scan(&bountyOwners)
+
+	for _, owner := range bountyOwners {
+		person := db.GetPersonByPubkey(owner.OwnerID)
+		bountyProviders = append(bountyProviders, person)
+	}
+	return bountyProviders
+}

db/structs.go

@@ -388,6 +388,10 @@ type Bounty struct {
 	CodingLanguages         pq.StringArray `gorm:"type:text[];not null default:'[]'" json:"coding_languages"`
 }
 
+type BountyOwners struct {
+	OwnerID string `json:"owner_id"`
+}
+
 type BountyData struct {
 	Bounty
 	BountyId          uint       `json:"bounty_id"`

handlers/metrics.go

@@ -233,6 +233,32 @@ func (mh *metricHandler) MetricsBountiesCount(w http.ResponseWriter, r *http.Req
 	json.NewEncoder(w).Encode(MetricsBountiesCount)
 }
 
+func (mh *metricHandler) MetricsBountiesProviders(w http.ResponseWriter, r *http.Request) {
+	ctx := r.Context()
+	pubKeyFromAuth, _ := ctx.Value(auth.ContextKey).(string)
+
+	if pubKeyFromAuth == "" {
+		fmt.Println("no pubkey from auth")
+		w.WriteHeader(http.StatusUnauthorized)
+		return
+	}
+
+	request := db.PaymentDateRange{}
+	body, err := io.ReadAll(r.Body)
+	r.Body.Close()
+
+	err = json.Unmarshal(body, &request)
+	if err != nil {
+		w.WriteHeader(http.StatusNotAcceptable)
+		json.NewEncoder(w).Encode("Request body not accepted")
+		return
+	}
+
+	bountiesProviders := mh.db.GetBountiesProviders(request, r)
+	w.WriteHeader(http.StatusOK)
+	json.NewEncoder(w).Encode(bountiesProviders)
+}
+
 func MetricsCsv(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	pubKeyFromAuth, _ := ctx.Value(auth.ContextKey).(string)

routes/metrics.go

@@ -11,7 +11,6 @@ func MetricsRoutes() chi.Router {
 	r := chi.NewRouter()
 	mh := handlers.NewMetricHandler(db.DB)
 	r.Group(func(r chi.Router) {
-		// Todo: change auth to superadmin context
 		r.Use(auth.PubKeyContextSuperAdmin)
 
 		r.Post("/payment", handlers.PaymentMetrics)
@@ -20,6 +19,7 @@ func MetricsRoutes() chi.Router {
 		r.Post("/bounty_stats", mh.BountyMetrics)
 		r.Post("/bounties", mh.MetricsBounties)
 		r.Post("/bounties/count", mh.MetricsBountiesCount)
+		r.Post("/bounties/providers", mh.MetricsBountiesProviders)
 		r.Post("/csv", handlers.MetricsCsv)
 	})
 	return r