add discord handlers

Author: AchoArnold

api/cmd/experiments/main.go

@@ -3,7 +3,6 @@ package main
 import (
 	"log"
 
-	"github.com/NdoleStudio/httpsms/pkg/di"
 	"github.com/joho/godotenv"
 )
 
@@ -12,5 +11,4 @@ func main() {
 	if err != nil {
 		log.Fatal("Error loading .env file")
 	}
-	_ = di.NewContainer("http-sms", "")
 }

api/go.mod

@@ -31,6 +31,7 @@ require (
 	github.com/redis/go-redis/v9 v9.0.2
 	github.com/rs/zerolog v1.29.0
 	github.com/sendgrid/sendgrid-go v3.12.0+incompatible
+	github.com/stretchr/testify v1.8.2
 	github.com/swaggo/swag v1.8.10
 	github.com/thedevsaddam/govalidator v1.9.10
 	github.com/uptrace/uptrace-go v1.13.0
@@ -105,6 +106,7 @@ require (
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/olekukonko/tablewriter v0.0.5 // indirect
 	github.com/philhofer/fwd v1.1.2 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/rivo/uniseg v0.4.4 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
 	github.com/savsgio/dictpool v0.0.0-20221023140959-7bf2e61cea94 // indirect

api/go.sum

@@ -403,6 +403,7 @@ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/
 github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
+github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/swaggo/files v0.0.0-20220728132757-551d4a08d97a/go.mod h1:lKJPbtWzJ9JhsTN1k1gZgleJWY/cqq0psdoMmaThG3w=
 github.com/swaggo/files v1.0.0 h1:1gGXVIeUFCS/dta17rnP0iOpr6CXFwKD7EO5ID233e4=
 github.com/swaggo/files v1.0.0/go.mod h1:N59U6URJLyU1PQgFqPM7wXLMhJx7QAolnvfQkqO13kc=

api/pkg/di/container.go

@@ -9,6 +9,8 @@ import (
 	"strconv"
 	"time"
 
+	"github.com/NdoleStudio/httpsms/pkg/discord"
+
 	mexporter "github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/metric"
 	cloudtrace "github.com/GoogleCloudPlatform/opentelemetry-operations-go/exporter/trace"
 	"go.opentelemetry.io/otel/sdk/metric"
@@ -113,6 +115,7 @@ func NewContainer(projectID string, version string) (container *Container) {
 	container.RegisterWebhookListeners()
 
 	container.RegisterLemonsqueezyRoutes()
+	container.RegisterDiscordRoutes()
 
 	// this has to be last since it registers the /* route
 	container.RegisterSwaggerRoutes()
@@ -241,6 +244,10 @@ func (container *Container) DB() (db *gorm.DB) {
 		container.logger.Fatal(stacktrace.Propagate(err, fmt.Sprintf("cannot migrate %T", &entities.Webhook{})))
 	}
 
+	if err = db.AutoMigrate(&entities.Discord{}); err != nil {
+		container.logger.Fatal(stacktrace.Propagate(err, fmt.Sprintf("cannot migrate %T", &entities.Discord{})))
+	}
+
 	return container.db
 }
 
@@ -424,6 +431,16 @@ func (container *Container) BillingHandlerValidator() (validator *validators.Bil
 	)
 }
 
+// DiscordHandlerValidator creates a new instance of validators.DiscordHandlerValidator
+func (container *Container) DiscordHandlerValidator() (validator *validators.DiscordHandlerValidator) {
+	container.logger.Debug(fmt.Sprintf("creating %T", validator))
+	return validators.NewDiscordHandlerValidator(
+		container.Logger(),
+		container.Tracer(),
+		container.DiscordClient(),
+	)
+}
+
 // WebhookHandlerValidator creates a new instance of validators.WebhookHandlerValidator
 func (container *Container) WebhookHandlerValidator() (validator *validators.WebhookHandlerValidator) {
 	container.logger.Debug(fmt.Sprintf("creating %T", validator))
@@ -520,6 +537,16 @@ func (container *Container) BillingUsageRepository() (repository repositories.Bi
 	)
 }
 
+// DiscordRepository creates a new instance of repositories.DiscordRepository
+func (container *Container) DiscordRepository() (repository repositories.DiscordRepository) {
+	container.logger.Debug("creating GORM repositories.DiscordRepository")
+	return repositories.NewGormDiscordRepository(
+		container.Logger(),
+		container.Tracer(),
+		container.DB(),
+	)
+}
+
 // WebhookRepository creates a new instance of repositories.WebhookRepository
 func (container *Container) WebhookRepository() (repository repositories.WebhookRepository) {
 	container.logger.Debug("creating GORM repositories.WebhookRepository")
@@ -606,6 +633,17 @@ func (container *Container) BillingService() (service *services.BillingService)
 	)
 }
 
+// DiscordService creates a new instance of services.DiscordService
+func (container *Container) DiscordService() (service *services.DiscordService) {
+	container.logger.Debug(fmt.Sprintf("creating %T", service))
+	return services.NewDiscordService(
+		container.Logger(),
+		container.Tracer(),
+		container.DiscordClient(),
+		container.DiscordRepository(),
+	)
+}
+
 // WebhookService creates a new instance of services.WebhookService
 func (container *Container) WebhookService() (service *services.WebhookService) {
 	container.logger.Debug(fmt.Sprintf("creating %T", service))
@@ -813,6 +851,18 @@ func (container *Container) LemonsqueezyHandler() (handler *handlers.Lemonsqueez
 	)
 }
 
+// DiscordHandler creates a new instance of handlers.DiscordHandler
+func (container *Container) DiscordHandler() (handler *handlers.DiscordHandler) {
+	container.logger.Debug(fmt.Sprintf("creating %T", handler))
+
+	return handlers.NewDiscordHandler(
+		container.Logger(),
+		container.Tracer(),
+		container.DiscordHandlerValidator(),
+		container.DiscordService(),
+	)
+}
+
 // LemonsqueezyHandlerValidator creates a new instance of validators.LemonsqueezyHandlerValidator
 func (container *Container) LemonsqueezyHandlerValidator() (validator *validators.LemonsqueezyHandlerValidator) {
 	container.logger.Debug(fmt.Sprintf("creating %T", validator))
@@ -833,12 +883,27 @@ func (container *Container) LemonsqueezyClient() (client *lemonsqueezy.Client) {
 	)
 }
 
-// RegisterLemonsqueezyRoutes registers routes for the /project-settings prefix
+// DiscordClient creates a new instance of discord.Client
+func (container *Container) DiscordClient() (client *discord.Client) {
+	container.logger.Debug(fmt.Sprintf("creating %T", client))
+	return discord.New(
+		discord.WithHTTPClient(container.HTTPClient("discord")),
+		discord.WithBotToken(os.Getenv("DISCORD_BOT_TOKEN")),
+	)
+}
+
+// RegisterLemonsqueezyRoutes registers routes for the /lemonsqueezy prefix
 func (container *Container) RegisterLemonsqueezyRoutes() {
 	container.logger.Debug(fmt.Sprintf("registering %T routes", &handlers.LemonsqueezyHandler{}))
 	container.LemonsqueezyHandler().RegisterRoutes(container.App())
 }
 
+// RegisterDiscordRoutes registers routes for the /discord prefix
+func (container *Container) RegisterDiscordRoutes() {
+	container.logger.Debug(fmt.Sprintf("registering %T routes", &handlers.DiscordHandler{}))
+	container.DiscordHandler().RegisterRoutes(container.App(), container.AuthenticatedMiddleware())
+}
+
 // RegisterMessageThreadListeners registers event listeners for listeners.MessageThreadListener
 func (container *Container) RegisterMessageThreadListeners() {
 	container.logger.Debug(fmt.Sprintf("registering listners for %T", listeners.MessageThreadListener{}))

api/pkg/discord/application.go

@@ -0,0 +1,43 @@
+package discord
+
+// CommandCreateRequest is the request for creating a new command
+type CommandCreateRequest struct {
+	Name        string                        `json:"name"`
+	Type        int                           `json:"type"`
+	Description string                        `json:"description"`
+	Options     []CommandCreateRequestOptions `json:"options"`
+}
+
+// CommandCreateRequestOptions are options for creating a command
+type CommandCreateRequestOptions struct {
+	Name        string `json:"name"`
+	Description string `json:"description"`
+	Type        int    `json:"type"`
+	Required    bool   `json:"required"`
+}
+
+// CommandCreateResponse is the response after creating a command
+type CommandCreateResponse struct {
+	ID                       string                         `json:"id"`
+	ApplicationID            string                         `json:"application_id"`
+	Version                  string                         `json:"version"`
+	DefaultMemberPermissions any                            `json:"default_member_permissions"`
+	Type                     int                            `json:"type"`
+	Name                     string                         `json:"name"`
+	NameLocalizations        any                            `json:"name_localizations"`
+	Description              string                         `json:"description"`
+	DescriptionLocalizations any                            `json:"description_localizations"`
+	GuildID                  string                         `json:"guild_id"`
+	Options                  []CommandCreateResponseOptions `json:"options"`
+	Nsfw                     bool                           `json:"nsfw"`
+}
+
+// CommandCreateResponseOptions are options after creating a command
+type CommandCreateResponseOptions struct {
+	Type                     int    `json:"type"`
+	Name                     string `json:"name"`
+	NameLocalizations        any    `json:"name_localizations"`
+	Description              string `json:"description"`
+	DescriptionLocalizations any    `json:"description_localizations"`
+	Required                 bool   `json:"required"`
+}

api/pkg/discord/application_service.go

@@ -0,0 +1,34 @@
+package discord
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+)
+
+// ApplicationService is the API client for the interacting with commands
+type ApplicationService service
+
+// CreateCommand creates a new guild command
+//
+// API Docs: https://discord.com/developers/docs/interactions/application-commands#create-guild-application-command
+func (service *ApplicationService) CreateCommand(ctx context.Context, serverID string, channelID string, params *CommandCreateRequest) (*CommandCreateResponse, *Response, error) {
+	url := fmt.Sprintf("/applications/%s/guilds/%s/commands", serverID, channelID)
+	request, err := service.client.newRequest(ctx, http.MethodPost, url, params)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	response, err := service.client.do(request)
+	if err != nil {
+		return nil, response, err
+	}
+
+	message := new(CommandCreateResponse)
+	if err = json.Unmarshal(*response.Body, message); err != nil {
+		return nil, response, err
+	}
+
+	return message, response, nil
+}

api/pkg/discord/channel_service.go

@@ -0,0 +1,55 @@
+package discord
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+)
+
+// ChannelService is the API client for interacting with channels
+type ChannelService service
+
+// CreateMessage sends a message to a guild text or DM channel.
+//
+// API Docs: https://discord.com/developers/docs/resources/channel#create-message
+func (service *ChannelService) CreateMessage(ctx context.Context, channelID string, payload map[string]any) (*map[string]any, *Response, error) {
+	request, err := service.client.newRequest(ctx, http.MethodPost, fmt.Sprintf("/channels/%s/messages", channelID), payload)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	response, err := service.client.do(request)
+	if err != nil {
+		return nil, response, err
+	}
+
+	message := new(map[string]any)
+	if err = json.Unmarshal(*response.Body, message); err != nil {
+		return nil, response, err
+	}
+
+	return message, response, nil
+}
+
+// Get a channel by ID
+//
+// API Docs: https://discord.com/developers/docs/resources/channel#get-channel
+func (service *ChannelService) Get(ctx context.Context, channelID string) (*map[string]any, *Response, error) {
+	request, err := service.client.newRequest(ctx, http.MethodGet, fmt.Sprintf("/channels/%s", channelID), nil)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	response, err := service.client.do(request)
+	if err != nil {
+		return nil, response, err
+	}
+
+	channel := new(map[string]any)
+	if err = json.Unmarshal(*response.Body, channel); err != nil {
+		return nil, response, err
+	}
+
+	return channel, response, nil
+}