refactor(api): use service for alerts

apps/api-gql/cmd/main.go

@@ -15,6 +15,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/server"
 	"github.com/twirapp/twir/apps/api-gql/internal/server/middlewares"
 	admin_actions "github.com/twirapp/twir/apps/api-gql/internal/services/admin-actions"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/alerts"
 	audit_logs "github.com/twirapp/twir/apps/api-gql/internal/services/audit-logs"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/badges"
 	badges_users "github.com/twirapp/twir/apps/api-gql/internal/services/badges-users"
@@ -60,6 +61,9 @@ import (
 
 	userswithchannelrepository "github.com/twirapp/twir/libs/repositories/users-with-channel"
 	userswithchannelrepositorypgx "github.com/twirapp/twir/libs/repositories/users-with-channel/pgx"
+
+	alertsrepository "github.com/twirapp/twir/libs/repositories/alerts"
+	alertsrepositorypgx "github.com/twirapp/twir/libs/repositories/alerts/pgx"
 )
 
 func main() {
@@ -86,6 +90,7 @@ func main() {
 			users.New,
 			twitch_channels.New,
 			twir_users.New,
+			alerts.New,
 		),
 		// repositories
 		fx.Provide(
@@ -121,6 +126,10 @@ func main() {
 				userswithchannelrepositorypgx.NewFx,
 				fx.As(new(userswithchannelrepository.Repository)),
 			),
+			fx.Annotate(
+				alertsrepositorypgx.NewFx,
+				fx.As(new(alertsrepository.Repository)),
+			),
 		),
 		// grpc clients
 		fx.Provide(

apps/api-gql/internal/delivery/gql/mappers/alerts.go

@@ -0,0 +1,19 @@
+package mappers
+
+import (
+	"github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/gqlmodel"
+	"github.com/twirapp/twir/apps/api-gql/internal/entity"
+)
+
+func AlertEntityTo(e entity.Alert) gqlmodel.ChannelAlert {
+	return gqlmodel.ChannelAlert{
+		ID:           e.ID,
+		Name:         e.Name,
+		AudioID:      e.AudioID,
+		AudioVolume:  &e.AudioVolume,
+		CommandIds:   e.CommandIDS,
+		RewardIds:    e.RewardIDS,
+		GreetingsIds: e.GreetingsIDS,
+		KeywordsIds:  e.KeywordsIDS,
+	}
+}

apps/api-gql/internal/delivery/gql/resolvers/resolver.go

@@ -14,6 +14,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/auth"
 	twir_stats "github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/twir-stats"
 	admin_actions "github.com/twirapp/twir/apps/api-gql/internal/services/admin-actions"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/alerts"
 	audit_logs "github.com/twirapp/twir/apps/api-gql/internal/services/audit-logs"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/badges"
 	badges_users "github.com/twirapp/twir/apps/api-gql/internal/services/badges-users"
@@ -61,6 +62,7 @@ type Resolver struct {
 	badgesUsersService           *badges_users.Service
 	usersService                 *users.Service
 	twirUsersService             *twir_users.Service
+	alertsService                *alerts.Service
 }
 
 type Opts struct {
@@ -89,6 +91,7 @@ type Opts struct {
 	BadgesUsersService           *badges_users.Service
 	UsersService                 *users.Service
 	TwirUsersService             *twir_users.Service
+	AlertsService                *alerts.Service
 }
 
 func New(opts Opts) (*Resolver, error) {
@@ -121,6 +124,7 @@ func New(opts Opts) (*Resolver, error) {
 		badgesUsersService:           opts.BadgesUsersService,
 		usersService:                 opts.UsersService,
 		twirUsersService:             opts.TwirUsersService,
+		alertsService:                opts.AlertsService,
 	}, nil
 }
 

apps/api-gql/internal/entity/alert.go

@@ -0,0 +1,19 @@
+package entity
+
+import (
+	"github.com/google/uuid"
+)
+
+type Alert struct {
+	ID           uuid.UUID
+	Name         string
+	ChannelID    string
+	AudioID      *string
+	AudioVolume  int
+	CommandIDS   []string
+	RewardIDS    []string
+	GreetingsIDS []string
+	KeywordsIDS  []string
+}
+
+var AlertNil = Alert{}