Method ToUpsertParams

api/pkg/requests/phone_update_request.go:51–97

ToUpsertParams converts PhoneUpsert to services.PhoneUpsertParams. The body parameter is the raw JSON request body used to detect which fields were explicitly sent.

(user entities.AuthContext, source string, body []byte)

// ToUpsertParams converts PhoneUpsert to services.PhoneUpsertParams.
// The body parameter is the raw JSON request body used to detect which fields were explicitly sent.
func (input *PhoneUpsert) ToUpsertParams(user entities.AuthContext, source string, body []byte) *services.PhoneUpsertParams {
	phone, _ := phonenumbers.Parse(input.PhoneNumber, phonenumbers.UNKNOWN_REGION)

	fields := make(map[string]json.RawMessage)
	_ = json.Unmarshal(body, &fields)

	var messagesPerMinute *uint
	if _, exists := fields["messages_per_minute"]; exists {
		messagesPerMinute = &input.MessagesPerMinute
	}

	var fcmToken *string
	if _, exists := fields["fcm_token"]; exists {
		fcmToken = &input.FcmToken
	}

	var timeout *time.Duration
	if _, exists := fields["message_expiration_seconds"]; exists {
		duration := time.Duration(input.MessageExpirationSeconds) * time.Second
		timeout = &duration
	}

	var maxSendAttempts *uint
	if _, exists := fields["max_send_attempts"]; exists {
		maxSendAttempts = &input.MaxSendAttempts
	}

	var scheduleID *uuid.UUID
	if _, exists := fields["message_send_schedule_id"]; exists {
		if parsed, err := uuid.Parse(strings.TrimSpace(input.MessageSendScheduleID)); err == nil {
			scheduleID = &parsed
		}
	}

	return &services.PhoneUpsertParams{
		Source:                    source,
		PhoneNumber:               phone,
		MessagesPerMinute:         messagesPerMinute,
		MissedCallAutoReply:       input.MissedCallAutoReply,
		MessageExpirationDuration: timeout,
		MaxSendAttempts:           maxSendAttempts,
		FcmToken:                  fcmToken,
		UserID:                    user.ID,
		SIM:                       entities.SIM(input.SIM),
		MessageSendScheduleID:     scheduleID,
	}
}