tcpforwarding.go 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package repository
  2. import (
  3. "context"
  4. "github.com/go-nunu/nunu-layout-advanced/internal/model"
  5. )
  6. type TcpforwardingRepository interface {
  7. GetTcpforwarding(ctx context.Context, id int64) (*model.Tcpforwarding, error)
  8. AddTcpforwarding(ctx context.Context, req *model.Tcpforwarding) error
  9. EditTcpforwarding(ctx context.Context, req *model.Tcpforwarding) error
  10. DeleteTcpforwarding(ctx context.Context, id int64) error
  11. }
  12. func NewTcpforwardingRepository(
  13. repository *Repository,
  14. ) TcpforwardingRepository {
  15. return &tcpforwardingRepository{
  16. Repository: repository,
  17. }
  18. }
  19. type tcpforwardingRepository struct {
  20. *Repository
  21. }
  22. func (r *tcpforwardingRepository) GetTcpforwarding(ctx context.Context, id int64) (*model.Tcpforwarding, error) {
  23. var tcpforwarding model.Tcpforwarding
  24. return &tcpforwarding, nil
  25. }
  26. func (r *tcpforwardingRepository) AddTcpforwarding(ctx context.Context, req *model.Tcpforwarding) error {
  27. if err := r.db.Create(&req).Error; err != nil {
  28. return err
  29. }
  30. return nil
  31. }
  32. func (r *tcpforwardingRepository) EditTcpforwarding(ctx context.Context, req *model.Tcpforwarding) error {
  33. if err := r.db.Updates(&req).Error; err != nil {
  34. return err
  35. }
  36. return nil
  37. }
  38. func (r *tcpforwardingRepository) DeleteTcpforwarding(ctx context.Context, id int64) error {
  39. if err := r.db.Where("id = ?", id).Delete(&model.Tcpforwarding{}).Error; err != nil {
  40. return err
  41. }
  42. return nil
  43. }