refactor: use gql subscriptions and mutations for bot status and actions

Author: Satont

apps/api-gql/cmd/main.go

@@ -30,6 +30,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/services/commands_responses"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/commands_with_groups_and_responses"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/community_redemptions"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/dashboard"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/dashboard-widget-events"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/greetings"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/keywords"
@@ -93,7 +94,6 @@ import (
 
 	channelscommandsprefixrepository "github.com/twirapp/twir/libs/repositories/channels_commands_prefix"
 	channelscommandsprefixpgx "github.com/twirapp/twir/libs/repositories/channels_commands_prefix/pgx"
-	"github.com/twirapp/twir/libs/uptrace"
 	"go.uber.org/fx"
 )
 
@@ -213,6 +213,7 @@ func main() {
 			song_requests.New,
 			community_redemptions.New,
 			streamelements.New,
+			dashboard.New,
 		),
 		// grpc clients
 		fx.Provide(
@@ -247,7 +248,6 @@ func main() {
 		),
 		fx.Invoke(
 			gql.New,
-			uptrace.NewFx("api-gql"),
 			publicroutes.New,
 			http_webhooks.New,
 			authroutes.New,

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

@@ -0,0 +1,30 @@
+package mappers
+
+import (
+	"github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/gqlmodel"
+	"github.com/twirapp/twir/apps/api-gql/internal/entity"
+)
+
+func DashboardStatsEntityToGql(e entity.DashboardStats) gqlmodel.DashboardStats {
+	return gqlmodel.DashboardStats{
+		CategoryID:     e.StreamCategoryID,
+		CategoryName:   e.StreamCategoryName,
+		Viewers:        e.StreamViewers,
+		StartedAt:      e.StreamStartedAt,
+		Title:          e.StreamTitle,
+		ChatMessages:   e.StreamChatMessages,
+		Followers:      e.Followers,
+		UsedEmotes:     e.UsedEmotes,
+		RequestedSongs: e.RequestedSongs,
+		Subs:           e.Subs,
+	}
+}
+
+func DashboardBotInfoEntityToGql(e entity.BotStatus) gqlmodel.BotStatus {
+	return gqlmodel.BotStatus{
+		IsMod:   e.IsMod,
+		BotID:   e.BotID,
+		BotName: e.BotName,
+		Enabled: e.Enabled,
+	}
+}

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

@@ -22,6 +22,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/services/commands_responses"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/commands_with_groups_and_responses"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/community_redemptions"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/dashboard"
 	dashboard_widget_events "github.com/twirapp/twir/apps/api-gql/internal/services/dashboard-widget-events"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/greetings"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/keywords"
@@ -93,6 +94,7 @@ type Deps struct {
 	SongRequestsService                   *song_requests.Service
 	CommunityRedemptionsService           *community_redemptions.Service
 	StreamElementsService                 *streamelements.Service
+	DashboardService                      *dashboard.Service
 	Config                                config.Config
 }
 

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

@@ -1,5 +1,10 @@
 extend type Subscription {
 	dashboardStats: DashboardStats! @isAuthenticated
+	botStatus: BotStatus! @isAuthenticated
+}
+
+extend type Mutation {
+	botJoinLeave(action: BotJoinLeaveAction!): Boolean! @isAuthenticated
 }
 
 type DashboardStats {
@@ -14,3 +19,15 @@ type DashboardStats {
 	requestedSongs: Int!
 	subs: Int!
 }
+
+type BotStatus {
+	isMod: Boolean!
+	botId: String!
+	botName: String!
+	enabled: Boolean!
+}
+
+enum BotJoinLeaveAction {
+	JOIN
+	LEAVE
+}

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

@@ -0,0 +1,25 @@
+package entity
+
+import (
+	"time"
+)
+
+type DashboardStats struct {
+	StreamCategoryID   string
+	StreamCategoryName string
+	StreamViewers      *int
+	StreamStartedAt    *time.Time
+	StreamTitle        string
+	StreamChatMessages int
+	Followers          int
+	UsedEmotes         int
+	RequestedSongs     int
+	Subs               int
+}
+
+type BotStatus struct {
+	IsMod   bool
+	BotID   string
+	BotName string
+	Enabled bool
+}