chore(backend): implement sdk config api

Author: abhaysood

backend/api/main.go

@@ -59,6 +59,7 @@ func main() {
 	// SDK routes
 	r.PUT("/events", measure.ValidateAPIKey(), measure.PutEvents)
 	r.PUT("/builds", measure.ValidateAPIKey(), measure.PutBuilds)
+	r.GET("/config", measure.ValidateAPIKey(), measure.GetConfig)
 
 	// Proxy routes
 	r.GET("/proxy/attachments", measure.ProxyAttachment)

backend/api/measure/session_targeting.go

@@ -7,9 +7,11 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"net/http"
 	"sort"
 	"time"
 
+	"github.com/gin-gonic/gin"
 	"github.com/google/uuid"
 	"github.com/leporo/sqlf"
 )
@@ -83,6 +85,16 @@ type STDashboardConfig struct {
 	OperatorTypes OperatorTypes `json:"operator_types"`
 }
 
+// Sesson targeting config response
+// used by the SDKs.
+type STConfigUnitResponse struct {
+	ID           uuid.UUID `json:"id"`
+	Name         string    `json:"name"`
+	Status       int       `json:"status"`
+	SamplingRate float64   `json:"sampling_rate"`
+	Rule         string    `json:"rule"`
+}
+
 // GetSTRules provides session targeting rules
 // that matches various filter criteria
 // in a paginated fashion.
@@ -342,6 +354,75 @@ func GetSTDashboardConfig(ctx context.Context, appId uuid.UUID, osName string) (
 	}, nil
 }
 
+// GetConfig returns the SDK config
+// for session targeting
+func GetConfig(c *gin.Context) {
+	appId, err := uuid.Parse(c.GetString("appId"))
+	if err != nil {
+		msg := `error parsing app's uuid`
+		fmt.Println(msg, err)
+		c.JSON(http.StatusInternalServerError, gin.H{"error": msg})
+		return
+	}
+
+	stmt := sqlf.PostgreSQL.From("session_targeting_rules").
+		Select("id").
+		Select("name").
+		Select("status").
+		Select("sampling_rate").
+		Select("rule").
+		Where("app_id = ?", appId).
+		Where("status = 1").
+		OrderBy("updated_at DESC")
+
+	defer stmt.Close()
+
+	rows, err := server.Server.PgPool.Query(c.Request.Context(), stmt.String(), stmt.Args()...)
+	if err != nil {
+		msg := "failed to fetch session targeting config"
+		fmt.Println(msg, err)
+		c.JSON(http.StatusInternalServerError, gin.H{
+			"error":   msg,
+			"details": err.Error(),
+		})
+		return
+	}
+	defer rows.Close()
+
+	configs := make([]STConfigUnitResponse, 0)
+	for rows.Next() {
+		var config STConfigUnitResponse
+		if err := rows.Scan(
+			&config.ID,
+			&config.Name,
+			&config.Status,
+			&config.SamplingRate,
+			&config.Rule,
+		); err != nil {
+			msg := "failed to scan session targeting config"
+			fmt.Println(msg, err)
+			c.JSON(http.StatusInternalServerError, gin.H{
+				"error":   msg,
+				"details": err.Error(),
+			})
+			return
+		}
+		configs = append(configs, config)
+	}
+
+	if err := rows.Err(); err != nil {
+		msg := "error iterating session targeting config"
+		fmt.Println(msg, err)
+		c.JSON(http.StatusInternalServerError, gin.H{
+			"error":   msg,
+			"details": err.Error(),
+		})
+		return
+	}
+
+	c.JSON(http.StatusOK, configs)
+}
+
 func getUDAttrKeys(ctx context.Context, appId uuid.UUID) (attributes []AttrConfig, err error) {
 	var table string = "user_def_attrs"
 	substmt := sqlf.From(table).