1use anyhow::Result;
5use gize_core::naming::table_name;
6use gize_core::{Api, 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 api: Option<Api>,
150 timestamp: &str,
151) -> Plan {
152 let mut manifest = Manifest::new(name);
153 manifest.features.authentication = true;
156 manifest.features.openapi = with_openapi;
157 manifest.api = api;
160 manifest.stack.database = dialect.sqlx_feature().to_string();
162 if with_user {
163 manifest.upsert_module(Module {
166 name: "users".to_string(),
167 fields: user::spec().to_field_tokens(),
168 belongs_to: Vec::new(),
169 });
170 }
171
172 let mut app_mod = project::app_mod_rs();
175 for module in [(with_user, "users"), (with_openapi, "openapi")] {
176 if module.0 {
177 app_mod = registry::register_module(&app_mod, module.1)
178 .expect("app_mod_rs template carries the gize markers")
179 .content;
180 }
181 }
182
183 let mut plan = Plan::new()
184 .create("Cargo.toml", project::cargo_toml(name, dialect))
185 .create("gize.toml", project::gize_toml(&manifest))
186 .create(".env.example", project::env_example(name, dialect))
187 .create(".gitignore", "/target\n.env\n")
188 .create("src/main.rs", project::main_rs())
189 .create("src/state.rs", project::state_rs(dialect))
190 .create(
191 "src/router.rs",
192 project::router_rs(manifest.api.as_ref().map(Api::mount_path).as_deref()),
193 )
194 .create("src/config/mod.rs", project::config_mod_rs())
195 .create("src/auth/mod.rs", auth::mod_rs())
196 .create("src/app/mod.rs", app_mod)
197 .mkdir("src/database")
199 .mkdir("src/middleware")
200 .mkdir("src/shared")
201 .mkdir("migrations");
202
203 if with_user {
204 plan = plan.extend(user_slice(dialect, timestamp));
205 }
206 if with_openapi {
207 plan = plan
209 .extend(openapi_slice(&manifest).expect("fresh manifest yields a valid OpenAPI spec"));
210 }
211 plan
212}
213
214fn user_slice(dialect: Dialect, timestamp: &str) -> Plan {
217 crud_files(&user::spec(), "src/app/users", true, dialect).create(
218 format!("migrations/{timestamp}_create_users.sql"),
219 user::migration_sql(dialect),
220 )
221}
222
223pub fn make_app(module: &str) -> Plan {
229 let dir = format!("src/app/{module}");
230 Plan::new()
231 .create(format!("{dir}/mod.rs"), module::mod_rs(module))
232 .create(
233 format!("{dir}/model.rs"),
234 module::model_placeholder_rs(module),
235 )
236 .create(format!("{dir}/dto.rs"), module::dto_rs(module))
237 .create(
238 format!("{dir}/repository.rs"),
239 module::repository_rs(module),
240 )
241 .create(format!("{dir}/service.rs"), module::service_rs(module))
242 .create(format!("{dir}/error.rs"), module::error_rs(module))
243 .create(format!("{dir}/handler.rs"), module::handler_rs(module))
244 .create(format!("{dir}/routes.rs"), module::routes_rs(module))
245 .create(format!("{dir}/tests.rs"), module::tests_rs(module))
246}
247
248pub fn make_model(model: &ModelSpec, dialect: Dialect, timestamp: &str) -> Plan {
254 let module = table_name(&model.name);
255 let table = &module;
256
257 Plan::new()
258 .create(format!("src/app/{module}/model.rs"), model::model_rs(model))
259 .create(
260 format!("migrations/{timestamp}_create_{table}.sql"),
261 model::migration_sql(model, dialect),
262 )
263}
264
265pub fn make_crud(model: &ModelSpec, dialect: Dialect, timestamp: &str) -> Plan {
269 let table = table_name(&model.name);
270 let dir = format!("src/app/{table}");
271
272 crud_files(model, &dir, false, dialect).create(
273 format!("migrations/{timestamp}_create_{table}.sql"),
274 model::migration_sql(model, dialect),
275 )
276}
277
278pub fn make_migration(name: &str, timestamp: &str) -> Plan {
282 Plan::new().create(
283 format!("migrations/{timestamp}_{name}.sql"),
284 model::blank_migration_sql(name),
285 )
286}
287
288#[cfg(test)]
289mod tests {
290 use super::*;
291
292 fn paths_of(plan: &Plan) -> Vec<String> {
293 plan.ops
294 .iter()
295 .map(|o| o.path.display().to_string())
296 .collect()
297 }
298
299 fn content_of<'a>(plan: &'a Plan, path: &str) -> &'a str {
300 plan.ops
301 .iter()
302 .find(|o| o.path.display().to_string() == path)
303 .map(|o| o.contents.as_str())
304 .unwrap_or_else(|| panic!("plan has no op for {path}"))
305 }
306
307 #[test]
308 fn new_project_plan_includes_core_files() {
309 let plan = new_project(
310 "shop",
311 false,
312 false,
313 Dialect::Postgres,
314 None,
315 "20260704120000",
316 );
317 let paths = paths_of(&plan);
318 assert!(paths.contains(&"Cargo.toml".to_string()));
319 assert!(paths.contains(&"gize.toml".to_string()));
320 assert!(paths.contains(&"src/main.rs".to_string()));
321 assert!(paths.contains(&"src/app/mod.rs".to_string()));
322 }
323
324 #[test]
325 fn new_project_without_user_omits_users_slice() {
326 let plan = new_project(
327 "shop",
328 false,
329 false,
330 Dialect::Postgres,
331 None,
332 "20260704120000",
333 );
334 let paths = paths_of(&plan);
335 assert!(!paths.iter().any(|p| p.starts_with("src/app/users/")));
336 assert!(!paths.iter().any(|p| p.ends_with("_create_users.sql")));
337 assert!(!content_of(&plan, "src/app/mod.rs").contains("mod users;"));
339 assert!(!content_of(&plan, "gize.toml").contains("users"));
340 }
341
342 #[test]
343 fn new_project_scaffolds_and_wires_users_by_default() {
344 let plan = new_project(
345 "shop",
346 true,
347 false,
348 Dialect::Postgres,
349 None,
350 "20260704120000",
351 );
352 let paths = paths_of(&plan);
353 for file in ["mod.rs", "model.rs", "dto.rs", "repository.rs", "routes.rs"] {
354 assert!(
355 paths.contains(&format!("src/app/users/{file}")),
356 "missing users/{file}"
357 );
358 }
359 assert!(paths.contains(&"migrations/20260704120000_create_users.sql".to_string()));
360
361 let app_mod = content_of(&plan, "src/app/mod.rs");
363 assert!(app_mod.contains("mod users;"));
364 assert!(app_mod.contains(".merge(users::routes())"));
365 assert!(content_of(&plan, "gize.toml").contains("users"));
366
367 let migration = content_of(&plan, "migrations/20260704120000_create_users.sql");
369 assert!(migration.contains("is_admin BOOLEAN NOT NULL DEFAULT false"));
370 }
371
372 #[test]
373 fn make_model_plan_has_model_and_migration() {
374 let model = ModelSpec::parse("User", &["name:String".to_string()]).unwrap();
375 let plan = make_model(&model, Dialect::Postgres, "20260704120000");
376 let paths: Vec<_> = plan
377 .ops
378 .iter()
379 .map(|o| o.path.display().to_string())
380 .collect();
381 assert!(paths.contains(&"src/app/users/model.rs".to_string()));
382 assert!(paths.contains(&"migrations/20260704120000_create_users.sql".to_string()));
383 }
384
385 #[test]
386 fn make_crud_plan_has_slice_and_migration() {
387 let model = ModelSpec::parse("Product", &["name:String".to_string()]).unwrap();
388 let plan = make_crud(&model, Dialect::Postgres, "20260704120000");
389 let paths: Vec<_> = plan
390 .ops
391 .iter()
392 .map(|o| o.path.display().to_string())
393 .collect();
394 assert!(paths.contains(&"src/app/products/repository.rs".to_string()));
395 assert!(paths.contains(&"src/app/products/handler.rs".to_string()));
396 assert!(paths.contains(&"src/app/products/dto.rs".to_string()));
397 assert!(paths.contains(&"migrations/20260704120000_create_products.sql".to_string()));
398 }
399
400 #[test]
401 fn make_migration_plan_is_single_timestamped_file() {
402 let plan = make_migration("add_index_to_users", "20260704120000");
403 let paths: Vec<_> = plan
404 .ops
405 .iter()
406 .map(|o| o.path.display().to_string())
407 .collect();
408 assert_eq!(
409 paths,
410 vec!["migrations/20260704120000_add_index_to_users.sql".to_string()]
411 );
412 }
413
414 #[test]
415 fn new_project_with_openapi_includes_spec_and_module() {
416 let plan = new_project(
417 "blog",
418 true,
419 true,
420 Dialect::Postgres,
421 None,
422 "20260704120000",
423 );
424 let paths: Vec<_> = plan
425 .ops
426 .iter()
427 .map(|o| o.path.display().to_string())
428 .collect();
429 assert!(paths.contains(&"src/app/openapi.rs".to_string()));
430 assert!(paths.contains(&"openapi.json".to_string()));
431 let spec = plan
433 .ops
434 .iter()
435 .find(|o| o.path.display().to_string() == "openapi.json")
436 .map(|o| o.contents.as_str())
437 .unwrap();
438 assert!(spec.contains("\"/users\""));
439 let app_mod = plan
440 .ops
441 .iter()
442 .find(|o| o.path.display().to_string() == "src/app/mod.rs")
443 .map(|o| o.contents.as_str())
444 .unwrap();
445 assert!(app_mod.contains("mod openapi;"));
446 assert!(app_mod.contains(".merge(openapi::routes())"));
447 }
448
449 #[test]
450 fn new_project_without_openapi_omits_it() {
451 let plan = new_project(
452 "blog",
453 true,
454 false,
455 Dialect::Postgres,
456 None,
457 "20260704120000",
458 );
459 let paths: Vec<_> = plan
460 .ops
461 .iter()
462 .map(|o| o.path.display().to_string())
463 .collect();
464 assert!(!paths.contains(&"openapi.json".to_string()));
465 assert!(!paths.iter().any(|p| p == "src/app/openapi.rs"));
466 }
467
468 #[test]
469 fn make_app_plan_has_full_module() {
470 let plan = make_app("users");
471 let paths: Vec<_> = plan
472 .ops
473 .iter()
474 .map(|o| o.path.display().to_string())
475 .collect();
476 for file in [
477 "mod.rs",
478 "model.rs",
479 "dto.rs",
480 "repository.rs",
481 "service.rs",
482 "error.rs",
483 "handler.rs",
484 "routes.rs",
485 "tests.rs",
486 ] {
487 assert!(
488 paths.contains(&format!("src/app/users/{file}")),
489 "missing {file}"
490 );
491 }
492 }
493}