1use anyhow::Result;
5use gize_core::naming::table_name;
6use gize_core::{Dialect, Manifest, ModelSpec, Module};
7use gize_templates::{auth, crud, model, module, openapi, project, user};
8
9use crate::plan::Plan;
10use crate::registry;
11
12fn crud_files(model: &ModelSpec, dir: &str, is_user: bool, dialect: Dialect) -> Plan {
16 let (model_rs, dto_rs, error_rs, handler_rs, routes_rs) = if is_user {
20 (
21 user::model_rs(),
22 user::dto_rs(),
23 user::error_rs(dialect),
24 user::handler_rs(dialect),
25 user::routes_rs(),
26 )
27 } else {
28 (
29 model::model_rs(model),
30 crud::dto_rs(model),
31 crud::error_rs(model, dialect),
32 crud::handler_rs(model),
33 crud::routes_rs(model),
34 )
35 };
36 Plan::new()
37 .create(format!("{dir}/mod.rs"), crud::mod_rs(model))
38 .create(format!("{dir}/model.rs"), model_rs)
39 .create(format!("{dir}/dto.rs"), dto_rs)
40 .create(format!("{dir}/error.rs"), error_rs)
41 .create(
42 format!("{dir}/repository.rs"),
43 crud::repository_rs(model, dialect),
44 )
45 .create(
46 format!("{dir}/service.rs"),
47 crud::service_rs(model, dialect),
48 )
49 .create(format!("{dir}/handler.rs"), handler_rs)
50 .create(format!("{dir}/routes.rs"), routes_rs)
51 .create(format!("{dir}/tests.rs"), crud::tests_rs(model))
52}
53
54pub fn auth_mod_rs() -> String {
57 auth::mod_rs()
58}
59
60pub fn openapi_module_rs() -> String {
63 openapi::module_rs()
64}
65
66pub fn openapi_json(manifest: &Manifest) -> Result<String> {
69 let spec = gize_openapi::spec_json(manifest)?;
70 serde_json::to_string_pretty(&spec).map_err(Into::into)
71}
72
73pub fn openapi_slice(manifest: &Manifest) -> Result<Plan> {
79 Ok(Plan::new()
80 .create("src/app/openapi.rs", openapi::module_rs())
81 .create("openapi.json", openapi_json(manifest)?))
82}
83
84pub fn admin_resources_ts(manifest: &Manifest) -> Result<String> {
87 gize_admin::resources_ts(manifest)
88}
89
90pub fn admin_shell_plan(manifest: &Manifest) -> Plan {
95 let project = &manifest.project.name;
96 Plan::new()
97 .create("admin/package.json", gize_admin::package_json(project))
98 .create("admin/vite.config.ts", gize_admin::vite_config())
99 .create("admin/tsconfig.json", gize_admin::tsconfig())
100 .create("admin/index.html", gize_admin::index_html())
101 .create("admin/.env.example", gize_admin::env_example())
102 .create("admin/.gitignore", gize_admin::gitignore())
103 .create("admin/src/main.tsx", gize_admin::main_tsx())
104 .create("admin/src/styles.css", gize_admin::styles_css())
105 .create("admin/src/theme.ts", gize_admin::theme_ts())
106 .create("admin/src/icons.tsx", gize_admin::icons_tsx())
107 .create("admin/src/toast.tsx", gize_admin::toast_tsx())
108 .create("admin/src/api.ts", gize_admin::api_ts())
109 .create("admin/src/auth.tsx", gize_admin::auth_tsx())
110 .create("admin/src/App.tsx", gize_admin::app_tsx())
111 .create("admin/src/Resource.tsx", gize_admin::resource_tsx())
112 .create(
113 "admin/src/ResourceForm.tsx",
114 gize_admin::resource_form_tsx(),
115 )
116}
117
118pub fn module_code(module: &Module, dialect: Dialect) -> Result<Plan> {
121 let model = module.model_spec()?;
122 let dir = format!("src/app/{}", module.name);
123 Ok(crud_files(&model, &dir, module.name == "users", dialect))
124}
125
126pub fn module_migration_sql(module: &Module, dialect: Dialect) -> Result<String> {
129 let model = module.model_spec()?;
130 Ok(if module.name == "users" {
131 user::migration_sql(dialect)
132 } else {
133 model::migration_sql(&model, dialect)
134 })
135}
136
137pub fn new_project(
145 name: &str,
146 with_user: bool,
147 with_openapi: bool,
148 dialect: Dialect,
149 timestamp: &str,
150) -> Plan {
151 let mut manifest = Manifest::new(name);
152 manifest.features.authentication = true;
155 manifest.features.openapi = with_openapi;
156 manifest.stack.database = match dialect {
158 Dialect::Postgres => "postgres".to_string(),
159 Dialect::Sqlite => "sqlite".to_string(),
160 };
161 if with_user {
162 manifest.upsert_module(Module {
165 name: "users".to_string(),
166 fields: user::spec().to_field_tokens(),
167 belongs_to: Vec::new(),
168 });
169 }
170
171 let mut app_mod = project::app_mod_rs();
174 for module in [(with_user, "users"), (with_openapi, "openapi")] {
175 if module.0 {
176 app_mod = registry::register_module(&app_mod, module.1)
177 .expect("app_mod_rs template carries the gize markers")
178 .content;
179 }
180 }
181
182 let mut plan = Plan::new()
183 .create("Cargo.toml", project::cargo_toml(name, dialect))
184 .create("gize.toml", project::gize_toml(&manifest))
185 .create(".env.example", project::env_example(name, dialect))
186 .create(".gitignore", "/target\n.env\n")
187 .create("src/main.rs", project::main_rs())
188 .create("src/state.rs", project::state_rs(dialect))
189 .create("src/router.rs", project::router_rs())
190 .create("src/config/mod.rs", project::config_mod_rs())
191 .create("src/auth/mod.rs", auth::mod_rs())
192 .create("src/app/mod.rs", app_mod)
193 .mkdir("src/database")
195 .mkdir("src/middleware")
196 .mkdir("src/shared")
197 .mkdir("migrations");
198
199 if with_user {
200 plan = plan.extend(user_slice(dialect, timestamp));
201 }
202 if with_openapi {
203 plan = plan
205 .extend(openapi_slice(&manifest).expect("fresh manifest yields a valid OpenAPI spec"));
206 }
207 plan
208}
209
210fn user_slice(dialect: Dialect, timestamp: &str) -> Plan {
213 crud_files(&user::spec(), "src/app/users", true, dialect).create(
214 format!("migrations/{timestamp}_create_users.sql"),
215 user::migration_sql(dialect),
216 )
217}
218
219pub fn make_app(module: &str) -> Plan {
225 let dir = format!("src/app/{module}");
226 Plan::new()
227 .create(format!("{dir}/mod.rs"), module::mod_rs(module))
228 .create(
229 format!("{dir}/model.rs"),
230 module::model_placeholder_rs(module),
231 )
232 .create(format!("{dir}/dto.rs"), module::dto_rs(module))
233 .create(
234 format!("{dir}/repository.rs"),
235 module::repository_rs(module),
236 )
237 .create(format!("{dir}/service.rs"), module::service_rs(module))
238 .create(format!("{dir}/error.rs"), module::error_rs(module))
239 .create(format!("{dir}/handler.rs"), module::handler_rs(module))
240 .create(format!("{dir}/routes.rs"), module::routes_rs(module))
241 .create(format!("{dir}/tests.rs"), module::tests_rs(module))
242}
243
244pub fn make_model(model: &ModelSpec, dialect: Dialect, timestamp: &str) -> Plan {
250 let module = table_name(&model.name);
251 let table = &module;
252
253 Plan::new()
254 .create(format!("src/app/{module}/model.rs"), model::model_rs(model))
255 .create(
256 format!("migrations/{timestamp}_create_{table}.sql"),
257 model::migration_sql(model, dialect),
258 )
259}
260
261pub fn make_crud(model: &ModelSpec, dialect: Dialect, timestamp: &str) -> Plan {
265 let table = table_name(&model.name);
266 let dir = format!("src/app/{table}");
267
268 crud_files(model, &dir, false, dialect).create(
269 format!("migrations/{timestamp}_create_{table}.sql"),
270 model::migration_sql(model, dialect),
271 )
272}
273
274pub fn make_migration(name: &str, timestamp: &str) -> Plan {
278 Plan::new().create(
279 format!("migrations/{timestamp}_{name}.sql"),
280 model::blank_migration_sql(name),
281 )
282}
283
284#[cfg(test)]
285mod tests {
286 use super::*;
287
288 fn paths_of(plan: &Plan) -> Vec<String> {
289 plan.ops
290 .iter()
291 .map(|o| o.path.display().to_string())
292 .collect()
293 }
294
295 fn content_of<'a>(plan: &'a Plan, path: &str) -> &'a str {
296 plan.ops
297 .iter()
298 .find(|o| o.path.display().to_string() == path)
299 .map(|o| o.contents.as_str())
300 .unwrap_or_else(|| panic!("plan has no op for {path}"))
301 }
302
303 #[test]
304 fn new_project_plan_includes_core_files() {
305 let plan = new_project("shop", false, false, Dialect::Postgres, "20260704120000");
306 let paths = paths_of(&plan);
307 assert!(paths.contains(&"Cargo.toml".to_string()));
308 assert!(paths.contains(&"gize.toml".to_string()));
309 assert!(paths.contains(&"src/main.rs".to_string()));
310 assert!(paths.contains(&"src/app/mod.rs".to_string()));
311 }
312
313 #[test]
314 fn new_project_without_user_omits_users_slice() {
315 let plan = new_project("shop", false, false, Dialect::Postgres, "20260704120000");
316 let paths = paths_of(&plan);
317 assert!(!paths.iter().any(|p| p.starts_with("src/app/users/")));
318 assert!(!paths.iter().any(|p| p.ends_with("_create_users.sql")));
319 assert!(!content_of(&plan, "src/app/mod.rs").contains("mod users;"));
321 assert!(!content_of(&plan, "gize.toml").contains("users"));
322 }
323
324 #[test]
325 fn new_project_scaffolds_and_wires_users_by_default() {
326 let plan = new_project("shop", true, false, Dialect::Postgres, "20260704120000");
327 let paths = paths_of(&plan);
328 for file in ["mod.rs", "model.rs", "dto.rs", "repository.rs", "routes.rs"] {
329 assert!(
330 paths.contains(&format!("src/app/users/{file}")),
331 "missing users/{file}"
332 );
333 }
334 assert!(paths.contains(&"migrations/20260704120000_create_users.sql".to_string()));
335
336 let app_mod = content_of(&plan, "src/app/mod.rs");
338 assert!(app_mod.contains("mod users;"));
339 assert!(app_mod.contains(".merge(users::routes())"));
340 assert!(content_of(&plan, "gize.toml").contains("users"));
341
342 let migration = content_of(&plan, "migrations/20260704120000_create_users.sql");
344 assert!(migration.contains("is_admin BOOLEAN NOT NULL DEFAULT false"));
345 }
346
347 #[test]
348 fn make_model_plan_has_model_and_migration() {
349 let model = ModelSpec::parse("User", &["name:String".to_string()]).unwrap();
350 let plan = make_model(&model, Dialect::Postgres, "20260704120000");
351 let paths: Vec<_> = plan
352 .ops
353 .iter()
354 .map(|o| o.path.display().to_string())
355 .collect();
356 assert!(paths.contains(&"src/app/users/model.rs".to_string()));
357 assert!(paths.contains(&"migrations/20260704120000_create_users.sql".to_string()));
358 }
359
360 #[test]
361 fn make_crud_plan_has_slice_and_migration() {
362 let model = ModelSpec::parse("Product", &["name:String".to_string()]).unwrap();
363 let plan = make_crud(&model, Dialect::Postgres, "20260704120000");
364 let paths: Vec<_> = plan
365 .ops
366 .iter()
367 .map(|o| o.path.display().to_string())
368 .collect();
369 assert!(paths.contains(&"src/app/products/repository.rs".to_string()));
370 assert!(paths.contains(&"src/app/products/handler.rs".to_string()));
371 assert!(paths.contains(&"src/app/products/dto.rs".to_string()));
372 assert!(paths.contains(&"migrations/20260704120000_create_products.sql".to_string()));
373 }
374
375 #[test]
376 fn make_migration_plan_is_single_timestamped_file() {
377 let plan = make_migration("add_index_to_users", "20260704120000");
378 let paths: Vec<_> = plan
379 .ops
380 .iter()
381 .map(|o| o.path.display().to_string())
382 .collect();
383 assert_eq!(
384 paths,
385 vec!["migrations/20260704120000_add_index_to_users.sql".to_string()]
386 );
387 }
388
389 #[test]
390 fn new_project_with_openapi_includes_spec_and_module() {
391 let plan = new_project("blog", true, true, Dialect::Postgres, "20260704120000");
392 let paths: Vec<_> = plan
393 .ops
394 .iter()
395 .map(|o| o.path.display().to_string())
396 .collect();
397 assert!(paths.contains(&"src/app/openapi.rs".to_string()));
398 assert!(paths.contains(&"openapi.json".to_string()));
399 let spec = plan
401 .ops
402 .iter()
403 .find(|o| o.path.display().to_string() == "openapi.json")
404 .map(|o| o.contents.as_str())
405 .unwrap();
406 assert!(spec.contains("\"/users\""));
407 let app_mod = plan
408 .ops
409 .iter()
410 .find(|o| o.path.display().to_string() == "src/app/mod.rs")
411 .map(|o| o.contents.as_str())
412 .unwrap();
413 assert!(app_mod.contains("mod openapi;"));
414 assert!(app_mod.contains(".merge(openapi::routes())"));
415 }
416
417 #[test]
418 fn new_project_without_openapi_omits_it() {
419 let plan = new_project("blog", true, false, Dialect::Postgres, "20260704120000");
420 let paths: Vec<_> = plan
421 .ops
422 .iter()
423 .map(|o| o.path.display().to_string())
424 .collect();
425 assert!(!paths.contains(&"openapi.json".to_string()));
426 assert!(!paths.iter().any(|p| p == "src/app/openapi.rs"));
427 }
428
429 #[test]
430 fn make_app_plan_has_full_module() {
431 let plan = make_app("users");
432 let paths: Vec<_> = plan
433 .ops
434 .iter()
435 .map(|o| o.path.display().to_string())
436 .collect();
437 for file in [
438 "mod.rs",
439 "model.rs",
440 "dto.rs",
441 "repository.rs",
442 "service.rs",
443 "error.rs",
444 "handler.rs",
445 "routes.rs",
446 "tests.rs",
447 ] {
448 assert!(
449 paths.contains(&format!("src/app/users/{file}")),
450 "missing {file}"
451 );
452 }
453 }
454}