Method startClient

wmiau.go:400–685

(userID string, textjid string, token string, kill chan bool)

				GetS3Manager().EnsureClientFromDB(userID)
			}(txtid)
		}
	}
	err = rows.Err()
	if err != nil {
		log.Error().Err(err).Msg("DB Problem")
	}
}

func parseJID(arg string) (types.JID, bool) {
	if arg == "" {
		return types.JID{}, false
	}
	if arg[0] == '+' {
		arg = arg[1:]
	}
	if !strings.ContainsRune(arg, '@') {
		return types.NewJID(arg, types.DefaultUserServer), true
	} else {
		recipient, err := types.ParseJID(arg)
		if err != nil {
			log.Error().Err(err).Msg("Invalid JID")
			return recipient, false
		} else if recipient.User == "" {
			log.Error().Err(err).Msg("Invalid JID no server specified")
			return recipient, false
		}
		return recipient, true
	}
}

// jidUserKey returns the phone/account part shared by users.jid and
// whatsmeow_device.jid even when formats differ (380...:8@ vs 380...@).
func jidUserKey(jid string) string {
	if jid == "" {
		return ""
	}
	userPart := strings.SplitN(jid, "@", 2)[0]
	return strings.SplitN(userPart, ":", 2)[0]
}

// jidLookupCandidates builds JID variants to try with sqlstore.GetDevice before
// falling back to account-key matching across all stored devices.
func jidLookupCandidates(textjid string) []types.JID {
	jid, ok := parseJID(textjid)
	if !ok {
		return nil
	}

	seen := make(map[string]struct{})
	var candidates []types.JID
	add := func(candidate types.JID) {
		if candidate.IsEmpty() {
			return
		}
		key := candidate.String()
		if _, exists := seen[key]; exists {
			return
		}