tsk-59: Tweaking code
This commit is contained in:
@@ -1,6 +1,8 @@
|
|||||||
package handler
|
package handler
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -47,6 +49,8 @@ func (e *EventResponseHandler) RecordResponse(w http.ResponseWriter, r *http.Req
|
|||||||
var rp message.MessageEventResponse
|
var rp message.MessageEventResponse
|
||||||
var resp RecordEventResponse
|
var resp RecordEventResponse
|
||||||
|
|
||||||
|
defer RespondWithJSON(w, statusCode, &resp)
|
||||||
|
|
||||||
if req.Sent == nil {
|
if req.Sent == nil {
|
||||||
statusCode = http.StatusBadRequest
|
statusCode = http.StatusBadRequest
|
||||||
resp.Message = "Sent time is empty"
|
resp.Message = "Sent time is empty"
|
||||||
@@ -60,31 +64,42 @@ func (e *EventResponseHandler) RecordResponse(w http.ResponseWriter, r *http.Req
|
|||||||
statusCode = http.StatusBadRequest
|
statusCode = http.StatusBadRequest
|
||||||
resp.Message = "Scheduled message event Id is empty"
|
resp.Message = "Scheduled message event Id is empty"
|
||||||
} else {
|
} else {
|
||||||
|
log.Println("Starting process to record Message Event Response")
|
||||||
rp.ScheduledMessageEventId = req.ScheduledMessageEventId
|
rp.ScheduledMessageEventId = req.ScheduledMessageEventId
|
||||||
|
fmt.Println(req.Response)
|
||||||
rp.Response = req.Response
|
rp.Response = req.Response
|
||||||
rp.UserId = req.UserId
|
rp.UserId = req.UserId
|
||||||
rp.Sent = *req.Sent
|
rp.Sent = *req.Sent
|
||||||
|
|
||||||
if req.Status == message.Message_Event_Response_Status_Instant {
|
switch req.Status {
|
||||||
|
case message.Message_Event_Response_Status_Instant: {
|
||||||
|
log.Println("Status:", req.Status)
|
||||||
rp.Status = req.Status
|
rp.Status = req.Status
|
||||||
rp.MessageId = req.MessageId
|
rp.MessageId = req.MessageId
|
||||||
rp.ContactId = req.ContactId
|
rp.ContactId = req.ContactId
|
||||||
} else if req.Status == message.Message_Event_Response_Status_Scheduled {
|
}
|
||||||
|
case message.Message_Event_Response_Status_Scheduled: {
|
||||||
|
log.Println("Status:", req.Status)
|
||||||
rp.Status = req.Status
|
rp.Status = req.Status
|
||||||
}
|
}
|
||||||
|
default: {
|
||||||
|
statusCode = http.StatusBadRequest
|
||||||
|
resp.Message = "Status is invalid"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
ctx := r.Context()
|
ctx := r.Context()
|
||||||
if err := e.MessageEventResponseStore.Create(ctx, &rp); err != nil {
|
if err := e.MessageEventResponseStore.Create(ctx, &rp); err != nil {
|
||||||
|
log.Println("Error:", err)
|
||||||
resp.Message = err.Error()
|
resp.Message = err.Error()
|
||||||
statusCode = http.StatusInternalServerError
|
statusCode = http.StatusInternalServerError
|
||||||
} else {
|
} else {
|
||||||
|
log.Println("Created Message Event Response")
|
||||||
statusCode = http.StatusCreated
|
statusCode = http.StatusCreated
|
||||||
resp.Message = "Successful"
|
resp.Message = "Successful"
|
||||||
resp.Data = append(resp.Data, &rp)
|
resp.Data = append(resp.Data, &rp)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
RespondWithJSON(w, statusCode, &resp)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type GetMessageEventResponseFetchedResponse struct {
|
type GetMessageEventResponseFetchedResponse struct {
|
||||||
|
|||||||
Reference in New Issue
Block a user