mirror of
https://github.com/andwati/telecom-platform.git
synced 2026-10-18 02:52:53 +00:00
feat: Add carrier-connector HTTP handlers with MVNO onboarding, management, and statistics endpoints
- Add Handler struct with StartOnboarding, GetMVNO, and ListMVNOs methods in handler_mvno.go - Add ManagementHandler struct with GetMVNO, ListMVNOs, UpdateMVNOStatus, and GetMVNOStats methods in handler_management.go - Add RegisterRoutes method for /mvno/onboarding, /mvno, and /mvno/:id route registration - Add query parameter parsing for status, plan, and limit filters in ListMVNOs - Add structured logging
This commit is contained in:
nutcas3
@@ -0,0 +1,122 @@
|
||||
package handlers
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"github.com/sirupsen/logrus"
|
||||
|
||||
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/monitor"
|
||||
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/mvno"
|
||||
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/repository"
|
||||
)
|
||||
|
||||
// ManagementHandler handles MVNO management HTTP requests
|
||||
type ManagementHandler struct {
|
||||
repo repository.Repository
|
||||
logger *logrus.Logger
|
||||
}
|
||||
|
||||
// NewManagementHandler creates a new management handler
|
||||
func NewManagementHandler(repo repository.Repository, logger *logrus.Logger) *ManagementHandler {
|
||||
return &ManagementHandler{
|
||||
repo: repo,
|
||||
logger: logger,
|
||||
}
|
||||
}
|
||||
|
||||
// GetMVNO handles GET /mvno/{id}
|
||||
func (h *ManagementHandler) GetMVNO(c *gin.Context) {
|
||||
id := c.Param("id")
|
||||
if id == "" {
|
||||
c.JSON(http.StatusBadRequest, gin.H{"error": "MVNO ID is required"})
|
||||
return
|
||||
}
|
||||
|
||||
mvno, err := h.repo.GetMVNO(c.Request.Context(), id)
|
||||
if err != nil {
|
||||
h.logger.WithError(err).WithField("mvno_id", id).Error("Failed to get MVNO")
|
||||
c.JSON(http.StatusNotFound, gin.H{"error": "MVNO not found"})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, mvno)
|
||||
}
|
||||
|
||||
// ListMVNOs handles GET /mvno
|
||||
func (h *ManagementHandler) ListMVNOs(c *gin.Context) {
|
||||
filter := &mvno.MVNOFilter{}
|
||||
|
||||
// Parse query parameters
|
||||
if status := c.Query("status"); status != "" {
|
||||
filter.Status = mvno.MVNOStatus(status)
|
||||
}
|
||||
if plan := c.Query("plan"); plan != "" {
|
||||
filter.Plan = mvno.MVNOPlan(plan)
|
||||
}
|
||||
if limit := c.Query("limit"); limit != "" {
|
||||
if l, err := strconv.Atoi(limit); err == nil {
|
||||
filter.Limit = l
|
||||
}
|
||||
}
|
||||
|
||||
mvnos, err := h.repo.ListMVNOs(c.Request.Context(), filter)
|
||||
if err != nil {
|
||||
h.logger.WithError(err).Error("Failed to list MVNOs")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to list MVNOs"})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"mvnos": mvnos,
|
||||
"count": len(mvnos),
|
||||
})
|
||||
}
|
||||
|
||||
// UpdateMVNOStatus handles PUT /mvno/{id}/status
|
||||
func (h *ManagementHandler) UpdateMVNOStatus(c *gin.Context) {
|
||||
id := c.Param("id")
|
||||
if id == "" {
|
||||
c.JSON(http.StatusBadRequest, gin.H{"error": "MVNO ID is required"})
|
||||
return
|
||||
}
|
||||
|
||||
var req struct {
|
||||
Status monitor.MVNOStatus `json:"status" binding:"required"`
|
||||
}
|
||||
if err := c.ShouldBindJSON(&req); err != nil {
|
||||
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
if err := h.repo.UpdateMVNOStatus(c.Request.Context(), id, req.Status); err != nil {
|
||||
h.logger.WithError(err).WithField("mvno_id", id).Error("Failed to update MVNO status")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to update status"})
|
||||
return
|
||||
}
|
||||
|
||||
h.logger.WithFields(logrus.Fields{
|
||||
"mvno_id": id,
|
||||
"new_status": req.Status,
|
||||
}).Info("MVNO status updated")
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"mvno_id": id,
|
||||
"status": req.Status,
|
||||
})
|
||||
}
|
||||
|
||||
// GetMVNOStats handles GET /mvno/stats
|
||||
func (h *ManagementHandler) GetMVNOStats(c *gin.Context) {
|
||||
stats, err := h.repo.GetMVNOStats(c.Request.Context())
|
||||
if err != nil {
|
||||
h.logger.WithError(err).Error("Failed to get MVNO stats")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to get statistics"})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{
|
||||
"stats": stats,
|
||||
})
|
||||
}
|
||||
@@ -0,0 +1,111 @@
|
||||
package handlers
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"strconv"
|
||||
|
||||
"github.com/gin-gonic/gin"
|
||||
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/repository"
|
||||
"github.com/nutcas3/telecom-platform/apps/carrier-connector/internal/services"
|
||||
"github.com/sirupsen/logrus"
|
||||
)
|
||||
|
||||
// Handler handles HTTP requests for MVNO operations
|
||||
type Handler struct {
|
||||
service *services.OnboardingService
|
||||
repo repository.Repository
|
||||
logger *logrus.Logger
|
||||
}
|
||||
|
||||
// NewHandler creates a new HTTP handler
|
||||
func NewHandler(service *services.OnboardingService, repo repository.Repository, logger *logrus.Logger) *Handler {
|
||||
return &Handler{
|
||||
service: service,
|
||||
repo: repo,
|
||||
logger: logger,
|
||||
}
|
||||
}
|
||||
|
||||
// StartOnboarding handles POST /mvno/onboarding
|
||||
func (h *Handler) StartOnboarding(c *gin.Context) {
|
||||
var req monitor.OnboardingRequest
|
||||
if err := c.ShouldBindJSON(&req); err != nil {
|
||||
h.logger.WithError(err).Error("Invalid onboarding request")
|
||||
c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
mvno, err := h.service.StartOnboarding(c.Request.Context(), &req)
|
||||
if err != nil {
|
||||
h.logger.WithError(err).Error("Failed to start onboarding")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
||||
return
|
||||
}
|
||||
|
||||
if err := h.repo.CreateMVNO(c.Request.Context(), mvno); err != nil {
|
||||
h.logger.WithError(err).Error("Failed to save MVNO")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to save MVNO"})
|
||||
return
|
||||
}
|
||||
|
||||
h.logger.WithField("mvno_id", mvno.ID).Info("Onboarding started")
|
||||
c.JSON(http.StatusCreated, gin.H{
|
||||
"mvno_id": mvno.ID,
|
||||
"business_id": mvno.BusinessID,
|
||||
"status": mvno.Status,
|
||||
"plan": mvno.Plan,
|
||||
})
|
||||
}
|
||||
|
||||
// GetMVNO handles GET /mvno/{id}
|
||||
func (h *Handler) GetMVNO(c *gin.Context) {
|
||||
id := c.Param("id")
|
||||
if id == "" {
|
||||
c.JSON(http.StatusBadRequest, gin.H{"error": "MVNO ID is required"})
|
||||
return
|
||||
}
|
||||
|
||||
mvno, err := h.repo.GetMVNO(c.Request.Context(), id)
|
||||
if err != nil {
|
||||
h.logger.WithError(err).WithField("mvno_id", id).Error("Failed to get MVNO")
|
||||
c.JSON(http.StatusNotFound, gin.H{"error": "MVNO not found"})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, mvno)
|
||||
}
|
||||
|
||||
// ListMVNOs handles GET /mvno
|
||||
func (h *Handler) ListMVNOs(c *gin.Context) {
|
||||
filter := &monitor.MVNOFilter{}
|
||||
if status := c.Query("status"); status != "" {
|
||||
filter.Status = monitor.MVNOStatus(status)
|
||||
}
|
||||
if plan := c.Query("plan"); plan != "" {
|
||||
filter.Plan = monitor.MVNOPlan(plan)
|
||||
}
|
||||
if limit := c.Query("limit"); limit != "" {
|
||||
if l, err := strconv.Atoi(limit); err == nil {
|
||||
filter.Limit = l
|
||||
}
|
||||
}
|
||||
|
||||
mvnos, err := h.repo.ListMVNOs(c.Request.Context(), filter)
|
||||
if err != nil {
|
||||
h.logger.WithError(err).Error("Failed to list MVNOs")
|
||||
c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to list MVNOs"})
|
||||
return
|
||||
}
|
||||
|
||||
c.JSON(http.StatusOK, gin.H{"mvnos": mvnos, "count": len(mvnos)})
|
||||
}
|
||||
|
||||
// RegisterRoutes registers all MVNO routes
|
||||
func (h *Handler) RegisterRoutes(router *gin.RouterGroup) {
|
||||
mvno := router.Group("/mvno")
|
||||
{
|
||||
mvno.POST("/onboarding", h.StartOnboarding)
|
||||
mvno.GET("", h.ListMVNOs)
|
||||
mvno.GET("/:id", h.GetMVNO)
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user