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