(ctx context.Context, source string, user *entities.User)
| 150 | } |
| 151 | |
| 152 | func (service *UserService) dispatchUserCreatedEvent(ctx context.Context, source string, user *entities.User) { |
| 153 | ctx, span, ctxLogger := service.tracer.StartWithLogger(ctx, service.logger) |
| 154 | defer span.End() |
| 155 | |
| 156 | event, err := service.createEvent(events.UserAccountCreated, source, &events.UserAccountCreatedPayload{ |
| 157 | UserID: user.ID, |
| 158 | Timestamp: time.Now().UTC(), |
| 159 | }) |
| 160 | if err != nil { |
| 161 | msg := fmt.Sprintf("cannot create event [%s] for user [%s]", events.UserAccountCreated, user.ID) |
| 162 | ctxLogger.Error(stacktrace.Propagate(err, msg)) |
| 163 | return |
| 164 | } |
| 165 | |
| 166 | if err = service.dispatcher.Dispatch(ctx, event); err != nil { |
| 167 | msg := fmt.Sprintf("cannot dispatch [%s] event for user [%s]", event.Type(), user.ID) |
| 168 | ctxLogger.Error(stacktrace.Propagate(err, msg)) |
| 169 | return |
| 170 | } |
| 171 | } |
| 172 | |
| 173 | // GetByID fetches an entities.User |
| 174 | func (service *UserService) GetByID(ctx context.Context, userID entities.UserID) (*entities.User, error) { |
no test coverage detected