attachments.rs 84.4%

27 of 32 lines run, 4 of 12 functions · run #545 on main · run missed

//! Attachments (oxygenhub#350): files people attach to issues, comments and
//! proposals, by content in the assets store.

use super::{now_ms, Pool};

#[derive(Clone, Debug, sqlx::FromRow)]
pub struct Attachment {
    pub id: i64,
    pub repo_id: i64,
    pub name: String,
    pub size: i64,
    pub hash: String,
    pub content_type: String,
    pub uploader_id: Option<i64>,
    pub created_ms: i64,
}

pub async fn add(
    pool: &Pool,
    repo_id: i64,
    name: &str,
    size: i64,
    hash: &str,
    content_type: &str,
    uploader_id: Option<i64>,
) -> sqlx::Result<Attachment> {
    sqlx::query_as(
        "INSERT INTO attachments (repo_id, name, size, hash, content_type, uploader_id, created_ms) VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING *",
    )
    .bind(repo_id)
    .bind(name)
    .bind(size)
    .bind(hash)
    .bind(content_type)
    .bind(uploader_id)
    .bind(now_ms())
    .fetch_one(pool)
    .await
}

/// One of a repository's attachments.
pub async fn get(pool: &Pool, repo_id: i64, id: i64) -> sqlx::Result<Option<Attachment>> {
    sqlx::query_as("SELECT * FROM attachments WHERE repo_id = $1 AND id = $2").bind(repo_id).bind(id).fetch_optional(pool).await
}

/// Whether any attachment keeps the blob `hash`.
pub async fn hash_in_use(pool: &Pool, hash: &str) -> sqlx::Result<bool> {
    let n: i64 = sqlx::query_scalar("SELECT COUNT(*) FROM attachments WHERE hash = $1").bind(hash).fetch_one(pool).await?;
    Ok(n > 0)
}

1		//! Attachments (oxygenhub#350): files people attach to issues, comments and
2		//! proposals, by content in the assets store.
3
4		use super::{now_ms, Pool};
5
6		#[derive(Clone, Debug, sqlx::FromRow)]
7		pub struct Attachment {
8		pub id: i64,
9		pub repo_id: i64,
10		pub name: String,
11		pub size: i64,
12		pub hash: String,
13		pub content_type: String,
14		pub uploader_id: Option<i64>,
15		pub created_ms: i64,
16		}
17
18	6×	pub async fn add(
19	6×	pool: &Pool,
20	6×	repo_id: i64,
21	6×	name: &str,
22	6×	size: i64,
23	6×	hash: &str,
24	6×	content_type: &str,
25	6×	uploader_id: Option<i64>,
26	6×	) -> sqlx::Result<Attachment> {
27	6×	sqlx::query_as(
28	6×	"INSERT INTO attachments (repo_id, name, size, hash, content_type, uploader_id, created_ms) VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING *",
29	6×	)
30	6×	.bind(repo_id)
31	6×	.bind(name)
32	6×	.bind(size)
33	6×	.bind(hash)
34	6×	.bind(content_type)
35	6×	.bind(uploader_id)
36	6×	.bind(now_ms())
37	6×	.fetch_one(pool)
38	6×	.await
39	6×	}
40
41		/// One of a repository's attachments.
42	3×	pub async fn get(pool: &Pool, repo_id: i64, id: i64) -> sqlx::Result<Option<Attachment>> {
43	3×	sqlx::query_as("SELECT * FROM attachments WHERE repo_id = $1 AND id = $2").bind(repo_id).bind(id).fetch_optional(pool).await
44	3×	}
45
46		/// Whether any attachment keeps the blob `hash`.
47	0×	pub async fn hash_in_use(pool: &Pool, hash: &str) -> sqlx::Result<bool> {
48	0×	let n: i64 = sqlx::query_scalar("SELECT COUNT(*) FROM attachments WHERE hash = $1").bind(hash).fetch_one(pool).await?;
49	0×	Ok(n > 0)
50	0×	}

`/`	Search
`g` `c`	Code
`g` `h`	History
`g` `b`	Bookmarks
`g` `t`	Trust
`y`	Permalink to this state (files and trees)
`?`	This sheet

Coverage / crates/hub/src/db/attachments.rs 84.4%

Keyboard