refactor: use gql for 7tv integration

Author: Satont

apps/api-gql/cmd/main.go

@@ -38,6 +38,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles_users"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles_with_roles_users"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/seventv_integration"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/song_requests"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/streamelements"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/timers"
@@ -92,6 +93,12 @@ import (
 	variablesrepository "github.com/twirapp/twir/libs/repositories/variables"
 	variablespgx "github.com/twirapp/twir/libs/repositories/variables/pgx"
 
+	seventvintegrationrepository "github.com/twirapp/twir/libs/repositories/seventv_integration"
+	seventvintegrationpostgres "github.com/twirapp/twir/libs/repositories/seventv_integration/datasource/postgres"
+
+	botsrepository "github.com/twirapp/twir/libs/repositories/bots"
+	botspostgres "github.com/twirapp/twir/libs/repositories/bots/datasource/postgres"
+
 	channelscommandsprefixrepository "github.com/twirapp/twir/libs/repositories/channels_commands_prefix"
 	channelscommandsprefixpgx "github.com/twirapp/twir/libs/repositories/channels_commands_prefix/pgx"
 	"go.uber.org/fx"
@@ -182,6 +189,14 @@ func main() {
 				channelsintegrationsspotifypgx.NewFx,
 				fx.As(new(channelsintegrationsspotify.Repository)),
 			),
+			fx.Annotate(
+				seventvintegrationpostgres.NewFx,
+				fx.As(new(seventvintegrationrepository.Repository)),
+			),
+			fx.Annotate(
+				botspostgres.NewFx,
+				fx.As(new(botsrepository.Repository)),
+			),
 		),
 		// services
 		fx.Provide(
@@ -214,6 +229,7 @@ func main() {
 			community_redemptions.New,
 			streamelements.New,
 			dashboard.New,
+			seventv_integration.New,
 		),
 		// grpc clients
 		fx.Provide(

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

@@ -0,0 +1,29 @@
+package mappers
+
+import (
+	"github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/gqlmodel"
+	"github.com/twirapp/twir/apps/api-gql/internal/entity"
+)
+
+func MapSevenTvIntegrationDataToGql(
+	data entity.SevenTvIntegrationData,
+) *gqlmodel.SevenTvIntegration {
+	return &gqlmodel.SevenTvIntegration{
+		IsEditor:                   data.IsEditor,
+		BotSeventvProfile:          MapSevenTvProfileToGql(data.BotSeventvProfile),
+		UserSeventvProfile:         MapSevenTvProfileToGql(data.UserSeventvProfile),
+		RewardIDForAddEmote:        data.RewardIDForAddEmote,
+		RewardIDForRemoveEmote:     data.RewardIDForRemoveEmote,
+		EmoteSetID:                 data.EmoteSetID,
+		DeleteEmotesOnlyAddedByApp: data.DeleteEmotesOnlyAddedByApp,
+	}
+}
+
+func MapSevenTvProfileToGql(profile *entity.SevenTvProfile) *gqlmodel.SevenTvProfile {
+	return &gqlmodel.SevenTvProfile{
+		ID:          profile.ID,
+		Username:    profile.Username,
+		DisplayName: profile.DisplayName,
+		AvatarURI:   profile.AvatarURI,
+	}
+}

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

@@ -30,6 +30,7 @@ import (
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles_users"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/roles_with_roles_users"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/seventv_integration"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/song_requests"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/streamelements"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/timers"
@@ -95,6 +96,7 @@ type Deps struct {
 	CommunityRedemptionsService           *community_redemptions.Service
 	StreamElementsService                 *streamelements.Service
 	DashboardService                      *dashboard.Service
+	SevenTvIntegrationService             *seventv_integration.Service
 	Config                                config.Config
 }
 

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

@@ -0,0 +1,30 @@
+extend type Subscription {
+	sevenTvData: SevenTvIntegration! @isAuthenticated
+}
+
+extend type Mutation {
+	sevenTvUpdate(input: SevenTvUpdateInput!): Boolean! @isAuthenticated
+}
+
+type SevenTvProfile {
+	id: String!
+	username: String!
+	displayName: String!
+	avatarUri: String!
+}
+
+type SevenTvIntegration {
+	isEditor: Boolean!
+	botSeventvProfile: SevenTvProfile!
+	userSeventvProfile: SevenTvProfile!
+	rewardIdForAddEmote: String
+	rewardIdForRemoveEmote: String
+	emoteSetId: String
+	deleteEmotesOnlyAddedByApp: Boolean!
+}
+
+input SevenTvUpdateInput {
+	rewardIdForAddEmote: String
+	rewardIdForRemoveEmote: String
+	deleteEmotesOnlyAddedByApp: Boolean!
+}

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

@@ -0,0 +1,27 @@
+package entity
+
+type SevenTvIntegrationData struct {
+	IsEditor                   bool
+	BotSeventvProfile          *SevenTvProfile
+	UserSeventvProfile         *SevenTvProfile
+	RewardIDForAddEmote        *string
+	RewardIDForRemoveEmote     *string
+	EmoteSetID                 *string
+	DeleteEmotesOnlyAddedByApp bool
+}
+
+type SevenTvProfile struct {
+	ID          string
+	Username    string
+	DisplayName string
+	Editors     []SevenTvProfileEditor
+	EmoteSetID  *string
+	AvatarURI   string
+}
+
+type SevenTvProfileEditor struct {
+	ID          string
+	Permissions int
+	Visible     bool
+	AddedAt     int64
+}