Repository navigation
Expand file tree
/
Copy pathintegration_3cx_handler.go
More file actions
89 lines (77 loc) · 2.91 KB
/
Copy pathintegration_3cx_handler.go
File metadata and controls
89 lines (77 loc) · 2.91 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
package handlers
import (
"fmt"
"github.com/NdoleStudio/httpsms/pkg/requests"
"github.com/davecgh/go-spew/spew"
"github.com/NdoleStudio/httpsms/pkg/services"
"github.com/NdoleStudio/httpsms/pkg/telemetry"
"github.com/NdoleStudio/stacktrace"
"github.com/gofiber/fiber/v3"
)
// Integration3CXHandler handles 3CX events
type Integration3CXHandler struct {
handler
logger telemetry.Logger
tracer telemetry.Tracer
messageService *services.MessageService
billingService *services.BillingService
}
// NewIntegration3CxHandler creates a new Integration3CXHandler
func NewIntegration3CxHandler(
logger telemetry.Logger,
tracer telemetry.Tracer,
messageService *services.MessageService,
billingService *services.BillingService,
) (h *Integration3CXHandler) {
return &Integration3CXHandler{
logger: logger.WithService(fmt.Sprintf("%T", h)),
tracer: tracer,
messageService: messageService,
billingService: billingService,
}
}
// RegisterRoutes registers the routes for the MessageHandler
func (h *Integration3CXHandler) RegisterRoutes(app *fiber.App, middlewares ...fiber.Handler) {
router := app.Group("integration/3cx/")
h.register(router, fiber.MethodPost, "/messages", middlewares, h.Messages)
}
// Messages consumes a 3cx event
// @Summary Sends a 3CX SMS message
// @Description Sends an SMS message from the 3CX platform
// @Tags 3CXIntegration
// @Accept json
// @Produce json
// @Success 204 {object} responses.NoContent
// @Failure 400 {object} responses.BadRequest
// @Failure 401 {object} responses.Unauthorized
// @Failure 422 {object} responses.UnprocessableEntity
// @Failure 500 {object} responses.InternalServerError
// @Router /integration/3cx/messages [post]
func (h *Integration3CXHandler) Messages(c fiber.Ctx) error {
ctx, span, ctxLogger := h.tracer.StartFromFiberCtxWithLogger(c, h.logger)
defer span.End()
spew.Dump(string(c.Body()))
var request requests.Integration3CXMessage
if err := c.Bind().Body(&request); err != nil {
ctxLogger.Warn(stacktrace.Propagatef(err, "cannot marshall [%s] into %T", c.Body(), request))
return h.responseBadRequest(c, err)
}
if msg := h.billingService.IsEntitled(ctx, h.userIDFomContext(c)); msg != nil {
ctxLogger.Warn(stacktrace.NewErrorf("user with ID [%s] can't send a [3cx] message", h.userIDFomContext(c)))
return h.responsePaymentRequired(c, *msg)
}
request.Sanitize()
message, err := h.messageService.SendMessage(ctx, request.ToMessageSendParams(h.userIDFomContext(c), c.OriginalURL()))
if err != nil {
ctxLogger.Error(stacktrace.Propagatef(err, "cannot send [3cx] message with payload [%s]", c.Body()))
return h.responseInternalServerError(c)
}
ctxLogger.Info(fmt.Sprintf("[3cx] message sent with ID [%s]", message.ID))
return c.Status(fiber.StatusOK).JSON(fiber.Map{
"data": fiber.Map{
"payload": fiber.Map{
"id": message.ID.String(),
},
},
})
}