GetMessage fetches a message by the ID
(ctx context.Context, userID entities.UserID, messageID uuid.UUID)
| 270 | |
| 271 | // GetMessage fetches a message by the ID |
| 272 | func (service *MessageService) GetMessage(ctx context.Context, userID entities.UserID, messageID uuid.UUID) (*entities.Message, error) { |
| 273 | ctx, span := service.tracer.Start(ctx) |
| 274 | defer span.End() |
| 275 | |
| 276 | message, err := service.repository.Load(ctx, userID, messageID) |
| 277 | if err != nil { |
| 278 | msg := fmt.Sprintf("could not fetch messages with ID [%s]", messageID) |
| 279 | return nil, service.tracer.WrapErrorSpan(span, stacktrace.PropagateWithCode(err, stacktrace.GetCode(err), msg)) |
| 280 | } |
| 281 | |
| 282 | return message, nil |
| 283 | } |
| 284 | |
| 285 | // MessageStoreEventParams parameters registering a message event |
| 286 | type MessageStoreEventParams struct { |
no test coverage detected