Compare commits
No commits in common. "601ce9eae7455902e22cbcb3f2f854c7c1f948f3" and "909e84fe1c6483685c421300a792c241ff65d090" have entirely different histories.
601ce9eae7
...
909e84fe1c
@ -155,65 +155,3 @@ func (s *server) removeTask(taskID string) {
|
|||||||
fn()
|
fn()
|
||||||
delete(s.ctx, taskID)
|
delete(s.ctx, taskID)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *server) GetUserMessages(ctx context.Context, message *gRPC.GetMessagesRequest) (*gRPC.GetMessagesResponse, error) {
|
|
||||||
ctx, span := tracer.Start(ctx, "GetUserMessages")
|
|
||||||
defer span.End()
|
|
||||||
|
|
||||||
sourceID := models.UserSourceID(message.UserSourceId)
|
|
||||||
userSource := models.UserSource{BaseModel: models.BaseModel[models.UserSourceID]{ID: sourceID}}
|
|
||||||
|
|
||||||
messages, err := s.getMessageExecution(ctx, userSource)
|
|
||||||
if err != nil {
|
|
||||||
span.RecordError(err)
|
|
||||||
span.SetStatus(codes.Error, err.Error())
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
var response gRPC.GetMessagesResponse
|
|
||||||
for _, message := range messages {
|
|
||||||
response.Messages = append(response.Messages, &gRPC.Message{
|
|
||||||
FromUserSourceId: string(userSource.ID),
|
|
||||||
CreatedAt: message.CreatedAt,
|
|
||||||
Body: message.Body,
|
|
||||||
Title: message.Title,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
return &response, err
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *server) SendMessage(ctx context.Context, message *gRPC.SendMessageRequest) (*gRPC.SendMessageResponse, error) {
|
|
||||||
ctx, span := tracer.Start(ctx, "SendMessage")
|
|
||||||
defer span.End()
|
|
||||||
|
|
||||||
response := &gRPC.SendMessageResponse{
|
|
||||||
Success: false,
|
|
||||||
}
|
|
||||||
|
|
||||||
sourceID := models.UserSourceID(message.UserSourceId)
|
|
||||||
userSource := models.UserSource{BaseModel: models.BaseModel[models.UserSourceID]{ID: sourceID}}
|
|
||||||
|
|
||||||
err := s.sendMessageExecution(ctx, userSource, message.Message)
|
|
||||||
if err != nil {
|
|
||||||
span.RecordError(err)
|
|
||||||
span.SetStatus(codes.Error, err.Error())
|
|
||||||
|
|
||||||
return response, err
|
|
||||||
}
|
|
||||||
|
|
||||||
response.Success = true
|
|
||||||
return response, err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *server) Ping(ctx context.Context, ping *gRPC.PingRequest) (*gRPC.PongResponse, error) {
|
|
||||||
ctx, span := tracer.Start(ctx, "Ping")
|
|
||||||
defer span.End()
|
|
||||||
|
|
||||||
var pong gRPC.PongResponse
|
|
||||||
pong.Message = ping.Message
|
|
||||||
pong.Timestamp = ping.Timestamp
|
|
||||||
|
|
||||||
return &pong, nil
|
|
||||||
}
|
|
||||||
|
Loading…
Reference in New Issue
Block a user