chore(api-gql): change gql schema directory

Author: Satont

.graphqlrc.yml

@@ -1 +1 @@
-schema: './apps/api-gql/schema/*.graphqls'
+schema: './apps/api-gql/internal/delivery/gql/schema/*.graphqls'

apps/api-gql/cmd/main.go

@@ -38,6 +38,7 @@ import (
 	"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/song_requests"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/streamelements"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/timers"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/twir-users"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/twitch"
@@ -211,6 +212,7 @@ func main() {
 			tts.New,
 			song_requests.New,
 			community_redemptions.New,
+			streamelements.New,
 		),
 		// grpc clients
 		fx.Provide(

apps/api-gql/gqlgen.yml apps/api-gql/internal/delivery/gql/gqlgen.yml

@@ -1,6 +1,6 @@
 # Where are all the schema files located? globs are supported eg  src/**/*.graphqls
 schema:
-  - apps/api-gql/schema/*.graphqls
+  - apps/api-gql/internal/delivery/gql/schema/*.graphqls
 
 # Where should the generated server code go?
 exec:

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

@@ -1,9 +1,13 @@
 package mappers
 
 import (
+	"github.com/google/uuid"
+	"github.com/samber/lo"
 	model "github.com/satont/twir/libs/gomodels"
 	"github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/gqlmodel"
 	"github.com/twirapp/twir/apps/api-gql/internal/entity"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/commands"
+	"github.com/twirapp/twir/libs/integrations/streamelements"
 )
 
 var commandsExpiresAtMap = map[model.ChannelCommandExpiresType]gqlmodel.CommandExpiresType{
@@ -110,3 +114,75 @@ func CommandResponseTo(e entity.CommandResponse) gqlmodel.CommandResponse {
 
 	return m
 }
+
+func CommandGqlInputToService(
+	channelID, actorID string,
+	input gqlmodel.CommandsCreateOpts,
+) commands.CreateInput {
+	responses := make([]commands.CreateInputResponse, len(input.Responses))
+	for idx, res := range input.Responses {
+		responses[idx] = commands.CreateInputResponse{
+			Text:              &res.Text,
+			Order:             idx,
+			TwitchCategoryIDs: res.TwitchCategoriesIds,
+		}
+	}
+
+	var groupId *uuid.UUID
+	if input.GroupID.IsSet() && input.GroupID.Value() != nil {
+		parsedGroupId, err := uuid.Parse(*input.GroupID.Value())
+		if err == nil {
+			groupId = &parsedGroupId
+		}
+	}
+
+	var expiresType *string
+	if input.ExpiresType.IsSet() && input.ExpiresType.Value() != nil {
+		expiresType = lo.ToPtr(input.ExpiresType.Value().String())
+	}
+
+	return commands.CreateInput{
+		ChannelID:                 channelID,
+		ActorID:                   actorID,
+		Name:                      input.Name,
+		Cooldown:                  input.Cooldown,
+		CooldownType:              input.CooldownType,
+		Enabled:                   input.Enabled,
+		Aliases:                   input.Aliases,
+		Description:               input.Description,
+		Visible:                   input.Visible,
+		IsReply:                   input.IsReply,
+		KeepResponsesOrder:        input.KeepResponsesOrder,
+		DeniedUsersIDS:            input.DeniedUsersIds,
+		AllowedUsersIDS:           input.AllowedUsersIds,
+		RolesIDS:                  input.RolesIds,
+		OnlineOnly:                input.OnlineOnly,
+		CooldownRolesIDs:          input.CooldownRolesIds,
+		EnabledCategories:         input.EnabledCategories,
+		RequiredWatchTime:         input.RequiredWatchTime,
+		RequiredMessages:          input.RequiredMessages,
+		RequiredUsedChannelPoints: input.RequiredUsedChannelPoints,
+		GroupID:                   groupId,
+		ExpiresAt:                 input.ExpiresAt.Value(),
+		ExpiresType:               expiresType,
+		Responses:                 responses,
+	}
+}
+
+func StreamElementsCommandToGql(m streamelements.Command) gqlmodel.StreamElementsCommand {
+	return gqlmodel.StreamElementsCommand{
+		ID:             m.ID,
+		Name:           m.Name,
+		Enabled:        m.Enabled,
+		Cooldown:       m.Cooldown.Global,
+		Aliases:        m.Aliases,
+		Response:       m.Response,
+		AccessLevel:    m.AccessLevel,
+		EnabledOnline:  m.EnabledOnline,
+		EnabledOffline: m.EnabledOffline,
+		Hidden:         m.Hidden,
+		Type:           m.Type,
+		CreatedAt:      m.CreatedAt,
+		UpdatedAt:      m.UpdatedAt,
+	}
+}

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

@@ -3,6 +3,7 @@ package mappers
 import (
 	"github.com/twirapp/twir/apps/api-gql/internal/delivery/gql/gqlmodel"
 	"github.com/twirapp/twir/apps/api-gql/internal/entity"
+	"github.com/twirapp/twir/libs/integrations/streamelements"
 )
 
 func TimerEntityToGql(m entity.Timer) gqlmodel.Timer {
@@ -27,3 +28,15 @@ func TimerEntityToGql(m entity.Timer) gqlmodel.Timer {
 		Responses:       responses,
 	}
 }
+
+func StreamElementsTimerToGql(m streamelements.Timer) gqlmodel.StreamElementsTimer {
+	return gqlmodel.StreamElementsTimer{
+		ID:        m.Id,
+		Name:      m.Name,
+		Enabled:   m.Enabled,
+		ChatLines: m.ChatLines,
+		Message:   m.Message,
+		CreatedAt: m.CreatedAt,
+		UpdatedAt: m.UpdatedAt,
+	}
+}

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

@@ -30,6 +30,7 @@ import (
 	"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/song_requests"
+	"github.com/twirapp/twir/apps/api-gql/internal/services/streamelements"
 	"github.com/twirapp/twir/apps/api-gql/internal/services/timers"
 	twir_users "github.com/twirapp/twir/apps/api-gql/internal/services/twir-users"
 	twitchservice "github.com/twirapp/twir/apps/api-gql/internal/services/twitch"
@@ -91,6 +92,7 @@ type Deps struct {
 	TTSService                            *tts.Service
 	SongRequestsService                   *song_requests.Service
 	CommunityRedemptionsService           *community_redemptions.Service
+	StreamElementsService                 *streamelements.Service
 	Config                                config.Config
 }
 

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

@@ -7,6 +7,7 @@ extend type Mutation {
 	commandsCreate(opts: CommandsCreateOpts!): CommandCreatePayload! @isAuthenticated @hasAccessToSelectedDashboard @hasChannelRolesDashboardPermission(permission: MANAGE_COMMANDS)
 	commandsUpdate(id: UUID!, opts: CommandsUpdateOpts!): Boolean! @isAuthenticated @hasAccessToSelectedDashboard @hasChannelRolesDashboardPermission(permission: MANAGE_COMMANDS)
 	commandsRemove(id: UUID!): Boolean! @isAuthenticated @hasAccessToSelectedDashboard @hasChannelRolesDashboardPermission(permission: MANAGE_COMMANDS)
+	commandsCreateMultiple(commands: [CommandsCreateOpts!]!): Boolean! @isAuthenticated @hasAccessToSelectedDashboard @hasChannelRolesDashboardPermission(permission: MANAGE_COMMANDS)
 }
 
 type Command {