tcpforwarding.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. package handler
  2. import (
  3. "github.com/gin-gonic/gin"
  4. v1 "github.com/go-nunu/nunu-layout-advanced/api/v1"
  5. "github.com/go-nunu/nunu-layout-advanced/internal/service"
  6. "github.com/mcuadros/go-defaults"
  7. "net/http"
  8. )
  9. type TcpforwardingHandler struct {
  10. *Handler
  11. tcpforwardingService service.TcpforwardingService
  12. }
  13. func NewTcpforwardingHandler(
  14. handler *Handler,
  15. tcpforwardingService service.TcpforwardingService,
  16. ) *TcpforwardingHandler {
  17. return &TcpforwardingHandler{
  18. Handler: handler,
  19. tcpforwardingService: tcpforwardingService,
  20. }
  21. }
  22. func (h *TcpforwardingHandler) GetTcpforwarding(ctx *gin.Context) {
  23. req := new(v1.GetForwardingRequest)
  24. if err := ctx.ShouldBind(req); err != nil {
  25. v1.HandleError(ctx, http.StatusBadRequest, v1.ErrBadRequest, err.Error())
  26. return
  27. }
  28. defaults.SetDefaults(req)
  29. res, err := h.tcpforwardingService.GetTcpforwarding(ctx, *req)
  30. if err != nil {
  31. v1.HandleError(ctx, http.StatusInternalServerError, err, err.Error())
  32. return
  33. }
  34. v1.HandleSuccess(ctx, res)
  35. }
  36. func (h *TcpforwardingHandler) AddTcpForwarding(ctx *gin.Context) {
  37. req := new(v1.TcpForwardingRequest)
  38. if err := ctx.ShouldBind(req); err != nil {
  39. v1.HandleError(ctx, http.StatusBadRequest, v1.ErrBadRequest, err.Error())
  40. return
  41. }
  42. defaults.SetDefaults(req)
  43. err := h.tcpforwardingService.AddTcpForwarding(ctx, req)
  44. if err != nil {
  45. v1.HandleError(ctx, http.StatusInternalServerError, err, err.Error())
  46. return
  47. }
  48. v1.HandleSuccess(ctx, nil)
  49. }
  50. func (h *TcpforwardingHandler) EditTcpForwarding(ctx *gin.Context) {
  51. req := new(v1.TcpForwardingRequest)
  52. if err := ctx.ShouldBind(req); err != nil {
  53. v1.HandleError(ctx, http.StatusBadRequest, v1.ErrBadRequest, err.Error())
  54. return
  55. }
  56. defaults.SetDefaults(req)
  57. err := h.tcpforwardingService.EditTcpForwarding(ctx, req)
  58. if err != nil {
  59. v1.HandleError(ctx, http.StatusInternalServerError, err, err.Error())
  60. return
  61. }
  62. v1.HandleSuccess(ctx, nil)
  63. }
  64. func (h *TcpforwardingHandler) DeleteTcpForwarding(ctx *gin.Context) {
  65. req := new(v1.DeleteTcpForwardingRequest)
  66. if err := ctx.ShouldBind(req); err != nil {
  67. v1.HandleError(ctx, http.StatusBadRequest, v1.ErrBadRequest, err.Error())
  68. return
  69. }
  70. defaults.SetDefaults(req)
  71. err := h.tcpforwardingService.DeleteTcpForwarding(ctx, *req)
  72. if err != nil {
  73. v1.HandleError(ctx, http.StatusInternalServerError, err, err.Error())
  74. return
  75. }
  76. v1.HandleSuccess(ctx, nil)
  77. }
  78. func (h *TcpforwardingHandler) GetTcpForwardingList(ctx *gin.Context) {
  79. req := new(v1.GetForwardingRequest)
  80. if err := ctx.ShouldBind(req); err != nil {
  81. v1.HandleError(ctx, http.StatusBadRequest, v1.ErrBadRequest, err.Error())
  82. return
  83. }
  84. defaults.SetDefaults(req)
  85. res, err := h.tcpforwardingService.GetTcpForwardingAllIpsByHostId(ctx, *req)
  86. if err != nil {
  87. v1.HandleError(ctx, http.StatusInternalServerError, err, err.Error())
  88. return
  89. }
  90. v1.HandleSuccess(ctx, res)
  91. }