Method getIDByEmail

backend/plugin/webhook/lark/app.go:188–237

getIDByEmail gets user ids by emails, returns email to userID mapping. https://open.larksuite.com/document/server-docs/contact-v3/user/batch_get_id

(ctx context.Context, emails []string)

// getIDByEmail gets user ids by emails, returns email to userID mapping.
// https://open.larksuite.com/document/server-docs/contact-v3/user/batch_get_id
func (p *provider) getIDByEmail(ctx context.Context, emails []string) (map[string]string, error) {
	userID := make(map[string]string)
	var emailsToGet []string
	for _, email := range emails {
		id, ok := userIDCache.Get(email)
		if ok {
			// user.UserID == "" means the user is not found on lark.
			if id != "" {
				userID[email] = id
			}
		} else {
			emailsToGet = append(emailsToGet, email)
		}
	}
	if len(emailsToGet) == 0 {
		return userID, nil
	}

	const url = "https://open.larksuite.com/open-apis/contact/v3/users/batch_get_id"
	body, err := json.Marshal(&getIDByEmailRequest{Emails: emailsToGet})
	if err != nil {
		return nil, err
	}

	b, err := p.do(ctx, http.MethodPost, url, body)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to get user id by email")
	}

	var response emailsFindResponse
	if err := json.Unmarshal([]byte(b), &response); err != nil {
		return nil, err
	}

	if response.Code != 0 {
		return nil, errors.Errorf("failed to get id by email, code %d, msg %s", response.Code, response.Msg)
	}

	for _, user := range response.Data.UserList {
		if user.UserID == "" {
			continue
		}
		// user.UserID == "" means the user is not found on lark.
		// We store "" into the cache to prevent finding every time.
		userID[user.Email] = user.UserID
		userIDCache.Add(user.Email, user.UserID)
	}

	return userID, nil
}

// https://open.larksuite.com/document/server-docs/im-v1/message/create
func (p *provider) sendMessage(ctx context.Context, userID string, messageCard *WebhookCard) error {