1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
// rocie - An enterprise grocery management system
//
// Copyright (C) 2026 Benedikt Peetz <benedikt.peetz@b-peetz.de>
// SPDX-License-Identifier: GPL-3.0-or-later
//
// This file is part of Rocie.
//
// You should have received a copy of the License along with this program.
// If not, see <https://www.gnu.org/licenses/gpl-3.0.txt>.
use crate::{
app::App,
storage::sql::{
recipe::{CooklangRecipe, Recipe, RecipeId},
recipe_parent::RecipeParentId,
},
};
use sqlx::query;
pub(crate) mod parse {
use crate::storage::sql::recipe::conversion;
#[derive(thiserror::Error, Debug)]
pub(crate) enum Error {
#[error("Failed to convert from cooklang recipe to our own struct")]
Conversion(#[from] conversion::Error),
}
}
async fn recipe_from_content(app: &App, content: &str) -> Result<CooklangRecipe, parse::Error> {
// NOTE: We can ignore warnings here, as we should already have handled them at the recipe
// insert point. <2026-01-31>
let (output, _warnings) = cooklang::parse(content)
.into_result()
.expect("The values in the db should always be valid, as we checked before inserting them");
Ok(CooklangRecipe::from(app, output).await?)
}
impl Recipe {
pub(crate) async fn from_id(app: &App, id: RecipeId) -> Result<Option<Self>, from_id::Error> {
let record = query!(
"
SELECT name, parent, content
FROM recipies
WHERE id = ?
",
id
)
.fetch_optional(&app.db)
.await?;
if let Some(record) = record {
Ok(Some(Self {
id,
content: recipe_from_content(app, &record.content).await?,
name: record.name,
parent: record.parent.map(|id| RecipeParentId::from_db(&id)),
}))
} else {
Ok(None)
}
}
pub(crate) async fn from_name(app: &App, name: String) -> Result<Option<Self>, from_id::Error> {
let record = query!(
"
SELECT id, parent, content
FROM recipies
WHERE name = ?
",
name
)
.fetch_optional(&app.db)
.await?;
if let Some(record) = record {
Ok(Some(Self {
id: RecipeId::from_db(&record.id),
content: recipe_from_content(app, &record.content).await?,
name,
parent: record.parent.map(|id| RecipeParentId::from_db(&id)),
}))
} else {
Ok(None)
}
}
pub(crate) async fn get_all(app: &App) -> Result<Vec<Self>, get_all::Error> {
let records = query!(
"
SELECT id, name, parent, content
FROM recipies
",
)
.fetch_all(&app.db)
.await?;
let mut output = vec![];
for record in records {
output.push(Self {
id: RecipeId::from_db(&record.id),
content: recipe_from_content(app, &record.content).await?,
name: record.name,
parent: record.parent.map(|id| RecipeParentId::from_db(&id)),
});
}
Ok(output)
}
}
pub(crate) mod from_id {
use actix_web::ResponseError;
use crate::storage::sql::get::recipe::parse;
#[derive(thiserror::Error, Debug)]
pub(crate) enum Error {
#[error("Failed to execute the sql query: `{0}`")]
SqlError(#[from] sqlx::Error),
#[error("Failed to parse the recipe content as cooklang recipe: `{0}`")]
RecipeParse(#[from] parse::Error),
}
impl ResponseError for Error {}
}
pub(crate) mod get_all {
use actix_web::ResponseError;
use crate::storage::sql::get::recipe::parse;
#[derive(thiserror::Error, Debug)]
pub(crate) enum Error {
#[error("Failed to execute the sql query")]
SqlError(#[from] sqlx::Error),
#[error("Failed to parse the recipe content as cooklang recipe")]
RecipeParse(#[from] parse::Error),
}
impl ResponseError for Error {}
}
|
