Skip to content

Commit df23b06

Browse files
committed
Remove turbofishes from .get_result() calls
This makes the code a little more readable and helps `intellij-rust` in understanding the types of the variables
1 parent d22905f commit df23b06

File tree

8 files changed

+31
-35
lines changed

8 files changed

+31
-35
lines changed

src/controllers/token.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,7 @@ pub fn new(req: &mut dyn RequestExt) -> EndpointResult {
7272
let user = authenticated_user.user();
7373

7474
let max_token_per_user = 500;
75-
let count = ApiToken::belonging_to(&user)
76-
.count()
77-
.get_result::<i64>(&*conn)?;
75+
let count: i64 = ApiToken::belonging_to(&user).count().get_result(&*conn)?;
7876
if count >= max_token_per_user {
7977
return Err(bad_request(&format!(
8078
"maximum tokens per user is: {}",

src/controllers/user/me.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -149,13 +149,13 @@ pub fn update_user(req: &mut dyn RequestExt) -> EndpointResult {
149149
email: user_email,
150150
};
151151

152-
let token = insert_into(emails::table)
152+
let token: String = insert_into(emails::table)
153153
.values(&new_email)
154154
.on_conflict(user_id)
155155
.do_update()
156156
.set(&new_email)
157157
.returning(emails::token)
158-
.get_result::<String>(&*conn)
158+
.get_result(&*conn)
159159
.map_err(|_| server_error("Error in creating token"))?;
160160

161161
crate::email::send_user_confirm_email(user_email, &user.gh_login, &token);
@@ -202,9 +202,9 @@ pub fn regenerate_token_and_send(req: &mut dyn RequestExt) -> EndpointResult {
202202
}
203203

204204
conn.transaction(|| {
205-
let email = update(Email::belonging_to(&user))
205+
let email: Email = update(Email::belonging_to(&user))
206206
.set(emails::token.eq(sql("DEFAULT")))
207-
.get_result::<Email>(&*conn)
207+
.get_result(&*conn)
208208
.map_err(|_| bad_request("Email could not be found"))?;
209209

210210
email::try_send_user_confirm_email(&email.email, &user.gh_login, &email.token)

src/models/krate.rs

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -163,10 +163,10 @@ impl<'a> NewCrate<'a> {
163163
use diesel::dsl::exists;
164164
use diesel::select;
165165

166-
let reserved_name = select(exists(
166+
let reserved_name: bool = select(exists(
167167
reserved_crate_names.filter(canon_crate_name(name).eq(canon_crate_name(self.name))),
168168
))
169-
.get_result::<bool>(conn)?;
169+
.get_result(conn)?;
170170
if reserved_name {
171171
Err(cargo_err("cannot upload a crate with a reserved name"))
172172
} else {
@@ -178,11 +178,11 @@ impl<'a> NewCrate<'a> {
178178
use crate::schema::crates::dsl::*;
179179

180180
conn.transaction(|| {
181-
let maybe_inserted = diesel::insert_into(crates)
181+
let maybe_inserted: Option<Crate> = diesel::insert_into(crates)
182182
.values(self)
183183
.on_conflict_do_nothing()
184184
.returning(ALL_COLUMNS)
185-
.get_result::<Crate>(conn)
185+
.get_result(conn)
186186
.optional()?;
187187

188188
if let Some(ref krate) = maybe_inserted {
@@ -445,15 +445,16 @@ impl Crate {
445445
match owner {
446446
// Users are invited and must accept before being added
447447
Owner::User(user) => {
448-
let maybe_inserted = insert_into(crate_owner_invitations::table)
449-
.values(&NewCrateOwnerInvitation {
450-
invited_user_id: user.id,
451-
invited_by_user_id: req_user.id,
452-
crate_id: self.id,
453-
})
454-
.on_conflict_do_nothing()
455-
.get_result::<CrateOwnerInvitation>(conn)
456-
.optional()?;
448+
let maybe_inserted: Option<CrateOwnerInvitation> =
449+
insert_into(crate_owner_invitations::table)
450+
.values(&NewCrateOwnerInvitation {
451+
invited_user_id: user.id,
452+
invited_by_user_id: req_user.id,
453+
crate_id: self.id,
454+
})
455+
.on_conflict_do_nothing()
456+
.get_result(conn)
457+
.optional()?;
457458

458459
if let Some(ownership_invitation) = maybe_inserted {
459460
if let Ok(Some(email)) = user.verified_email(&conn) {

src/models/token.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ impl ApiToken {
4343
crate::util::generate_secure_alphanumeric_string(TOKEN_LENGTH)
4444
);
4545

46-
let model = diesel::insert_into(api_tokens::table)
46+
let model: ApiToken = diesel::insert_into(api_tokens::table)
4747
.values((
4848
api_tokens::user_id.eq(user_id),
4949
api_tokens::name.eq(name),
5050
api_tokens::token.eq(digest(&plaintext, "sha256")),
5151
))
52-
.get_result::<ApiToken>(conn)?;
52+
.get_result(conn)?;
5353

5454
Ok(CreatedApiToken { plaintext, model })
5555
}
@@ -71,7 +71,7 @@ impl ApiToken {
7171
conn.transaction(|| {
7272
update(tokens)
7373
.set(last_used_at.eq(now.nullable()))
74-
.get_result::<ApiToken>(conn)
74+
.get_result(conn)
7575
})
7676
.or_else(|_| tokens.first(conn))
7777
.map_err(Into::into)

src/models/user.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ impl<'a> NewUser<'a> {
6363
use diesel::sql_types::Integer;
6464

6565
conn.transaction(|| {
66-
let user = insert_into(users)
66+
let user: User = insert_into(users)
6767
.values(self)
6868
// We need the `WHERE gh_id > 0` condition here because `gh_id` set
6969
// to `-1` indicates that we were unable to find a GitHub ID for
@@ -81,7 +81,7 @@ impl<'a> NewUser<'a> {
8181
gh_avatar.eq(excluded(gh_avatar)),
8282
gh_access_token.eq(excluded(gh_access_token)),
8383
))
84-
.get_result::<User>(conn)?;
84+
.get_result(conn)?;
8585

8686
// To send the user an account verification email
8787
if let Some(user_email) = email {
@@ -90,11 +90,11 @@ impl<'a> NewUser<'a> {
9090
email: user_email,
9191
};
9292

93-
let token = insert_into(emails::table)
93+
let token: Option<String> = insert_into(emails::table)
9494
.values(&new_email)
9595
.on_conflict_do_nothing()
9696
.returning(emails::token)
97-
.get_result::<String>(conn)
97+
.get_result(conn)
9898
.optional()?;
9999

100100
if let Some(token) = token {

src/models/version.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -210,9 +210,7 @@ impl NewVersion {
210210
)));
211211
}
212212

213-
let version = insert_into(versions)
214-
.values(self)
215-
.get_result::<Version>(conn)?;
213+
let version: Version = insert_into(versions).values(self).get_result(conn)?;
216214

217215
insert_into(versions_published_by::table)
218216
.values((

src/tasks/update_downloads.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,10 +51,10 @@ fn collect(conn: &PgConnection, rows: &[VersionDownload]) -> QueryResult<()> {
5151

5252
conn.transaction::<_, diesel::result::Error, _>(|| {
5353
// Update the total number of version downloads
54-
let crate_id = update(versions::table.find(download.version_id))
54+
let crate_id: i32 = update(versions::table.find(download.version_id))
5555
.set(versions::downloads.eq(versions::downloads + amt))
5656
.returning(versions::crate_id)
57-
.get_result::<i32>(conn)?;
57+
.get_result(conn)?;
5858

5959
// Update the total number of crate downloads
6060
update(crates::table.find(crate_id))

src/tests/read_only_mode.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -52,9 +52,8 @@ fn can_download_crate_in_read_only_mode() {
5252
use cargo_registry::schema::version_downloads::dsl::*;
5353
use diesel::dsl::sum;
5454

55-
let dl_count = version_downloads
56-
.select(sum(downloads))
57-
.get_result::<Option<i64>>(conn);
55+
let dl_count: Result<Option<i64>, _> =
56+
version_downloads.select(sum(downloads)).get_result(conn);
5857
assert_eq!(Ok(None), dl_count);
5958
})
6059
}

0 commit comments

Comments
 (0)