feat: DSL operator codegen

Cargo.toml

@@ -1,3 +1,3 @@
 [workspace]
-members = ["optd-core"]
+members = [ "optd-core", "optd-dsl"]
 resolver = "2"

optd-core/Cargo.toml

@@ -14,6 +14,4 @@ tokio = { version = "1.43.0", features = ["full"] }
 serde = { version = "1.0", features = ["derive"] }
 serde_json = { version = "1", features = ["raw_value"] }
 dotenvy = "0.15"
-async-recursion = "1.1.1"
-pest = "2.7.15"
-pest_derive = "2.7.15"
+async-recursion = "1.1.1"

optd-core/src/lib.rs

@@ -1,6 +1,5 @@
 #[allow(dead_code)]
 pub mod cascades;
-pub mod dsl;
 pub mod engine;
 pub mod operators;
 pub mod plans;

optd-dsl/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "optd-dsl"
+version = "0.1.0"
+edition = "2021"
+
+[lib]
+proc-macro = true
+
+[dependencies]
+pest = "2.7.15"
+pest_derive = "2.7.15"
+syn = { version = "2.0", features = ["full", "extra-traits"] }
+quote = "1.0"
+proc-macro2 = "1.0.93"
+prettyplease = "0.2"

optd-core/src/dsl/analyzer/semantic.rs → optd-dsl/src/analyzer/semantic.rs

@@ -1,8 +1,6 @@
 use std::collections::HashSet;
 
-use crate::dsl::ast::upper_layer::{
-    Expr, File, Function, Operator, OperatorKind, Pattern, Properties, Type,
-};
+use crate::ast::{Expr, File, Function, Operator, OperatorKind, Pattern, Properties, Type};
 
 /// SemanticAnalyzer performs static analysis on the DSL code to ensure semantic correctness.
 /// It validates properties, operators, functions, and expressions while maintaining scope information.
@@ -387,8 +385,8 @@ impl SemanticAnalyzer {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::dsl::{
-        ast::upper_layer::{
+    use crate::{
+        ast::{
             Expr, Field, File, Function, Literal, LogicalOp, Operator, Properties, ScalarOp, Type,
         },
         parser::parse_file,
@@ -443,7 +441,7 @@ mod tests {
     }
 
     #[test]
-    fn parse_working_file() {
+    fn test_working_file() {
         let input = include_str!("../programs/working.optd");
         let out = parse_file(input).unwrap();
         let mut analyzer = SemanticAnalyzer::new();

optd-dsl/src/gen/mod.rs

@@ -0,0 +1 @@
+pub mod operator;