webhooks.go

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"net/http"
	"strconv"

	"github.com/gin-gonic/gin"
)

func WebhookHandler(c *gin.Context) {
	var webhookEvent WebhookEvent

	raw, err := c.GetRawData()
	if err != nil {
		fmt.Println(err)
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}

	var buf bytes.Buffer

	if err := json.Compact(&buf, raw); err != nil {
		fmt.Println(err)
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}

	data := buf.Bytes()

	if err := json.Unmarshal(data, &webhookEvent); err != nil {
		fmt.Println(err)
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}

	switch webhookEvent.Event {

	case "message_created":

		var message MessageCreatedEvent
		if err := json.Unmarshal(data, &message); err != nil {
			fmt.Println(err)
			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
			return
		}
		fmt.Println("message received", message.Content)

		if err := MessageCreatedHandler(message, c.Query("furl"), c.Query("fbear")); err != nil {
			fmt.Println(err)
			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
		}

	case "conversation_status_changed":

		var conversation ConversationStatusChangedEvent
		if err := json.Unmarshal(data, &conversation); err != nil {
			fmt.Println(err)
			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
			return
		}
		fmt.Println("conversation status changed", conversation.Status)

		if err := ConversationStatusChangedHandler(conversation, c.Query("furl"), c.Query("fbear")); err != nil {
			fmt.Println(err)
			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
		}
	}

	c.JSON(http.StatusOK, gin.H{"status": "ok"})

}

func SendTestHandler(c *gin.Context) {
	accountID, err := strconv.Atoi(c.Query("account_id"))
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}
	conversationID, err := strconv.Atoi(c.Query("conversation_id"))
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}
	accessToken := c.Query("access_token")

	var sendMessage MessageCreatedEvent = MessageCreatedEvent{
		Content:     "Hello, test message sent",
		MessageType: "outgoing",
		ContentType: "text",
		Private:     false,
		Account: MC_Account{
			ID: accountID,
		},
		Conversation: MC_Conversation{
			ID: conversationID,
		},
	}

	resp, err := SendTextMessage(sendMessage, accessToken)
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}

	if resp.StatusCode != http.StatusOK {
		c.JSON(http.StatusBadRequest, gin.H{"error": resp.Status})
		return
	}

	c.JSON(http.StatusOK, gin.H{"status": "ok"})
}

func AssingConversationHandler(c *gin.Context) {
	accountID := "1"
	conversationID := "16"
	assigneeID := 3

	resp, err := AssignConversationToAnAgent(accountID, conversationID, assigneeID)
	if err != nil {
		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
		return
	}

	if resp.StatusCode != http.StatusOK {
		c.JSON(http.StatusBadRequest, gin.H{"error": resp.Status})
		return
	}

	c.JSON(http.StatusOK, gin.H{"status": "ok"})
}