(eventType string, source string, payload any)
| 16 | type service struct{} |
| 17 | |
| 18 | func (service *service) createEvent(eventType string, source string, payload any) (cloudevents.Event, error) { |
| 19 | event := cloudevents.NewEvent() |
| 20 | |
| 21 | event.SetSource(source) |
| 22 | event.SetType(eventType) |
| 23 | event.SetTime(time.Now().UTC()) |
| 24 | event.SetID(uuid.New().String()) |
| 25 | |
| 26 | if err := event.SetData(cloudevents.ApplicationJSON, payload); err != nil { |
| 27 | msg := fmt.Sprintf("cannot encode %T [%#+v] as JSON", payload, payload) |
| 28 | return event, stacktrace.Propagate(err, msg) |
| 29 | } |
| 30 | |
| 31 | return event, nil |
| 32 | } |
| 33 | |
| 34 | func (service *service) getFormattedNumber(ctxLogger telemetry.Logger, phoneNumber string) string { |
| 35 | matched, err := regexp.MatchString("^\\+?[1-9]\\d{9,14}$", phoneNumber) |
no test coverage detected