* opa works (#106)

* cargo fix now works
* check_overwrite now doesn't delete entire dir but only warns about overwrite

Author: bird-dancer

src/generator/common.rs

@@ -27,15 +27,14 @@ macro_rules! cargo_command {
 /// checks if project with name already exists, if yes asks for permission to overwrite
 pub fn check_for_overwrite(output_path: &Path, project_title: &str) {
     if output_path.exists() {
-        println!("\nA project with the name {} already exists in the current directory: {}. Do you want to overwrite it? \n\n❗ WARNING: This will permanently delete all files in the directory! \n\nType 'y' to continue or anything else to exit.", project_title, output_path.to_string_lossy());
+        println!("\nA project with the name {} already exists in the current directory: {}. Do you want to overwrite it? \n\n❗ WARNING: Existing files within the folder will be permanently replaced by newly generated files. \n\nType 'y' to continue or anything else to exit.", project_title, output_path.to_string_lossy());
         let mut input = String::new();
         match std::io::stdin().read_line(&mut input) {
             Ok(_) => {
                 if input.trim() != "y" {
                     println!("Aborting generation...");
                     std::process::exit(0);
                 }
-                std::fs::remove_dir_all(output_path).unwrap();
             }
             Err(err) => {
                 println!("❌ Error reading input: {}", err);

src/main.rs

@@ -65,7 +65,8 @@ fn main() {
         "fix",
         "--manifest-path",
         output_path.join("Cargo.toml"),
-        "--allow-dirty"
+        "--allow-dirty",
+        "--allow-staged"
     );
 
     if args.doc {

templates/src/handler/$$producer$$.rs.go

@@ -41,7 +41,7 @@ use log::{debug, warn, error};
                     match serde_json::from_value::<{{ .payload.struct_reference }}>(payload) {
                         Ok(deserialized_message) => {
                             debug!("Received message {:#?}", deserialized_message);
-                            let policy_reply = opa_eval(message);
+                            let policy_reply = opa_eval(&deserialized_message);
                             // TODO: Replace this with your own handler code
                             {{ if eq .payload.model_type "enum"}}
                                 match deserialized_message {
@@ -87,12 +87,12 @@ use log::{debug, warn, error};
                     {{ end }}
                 match serde_json::from_value::<{{ .payload.struct_reference }}>(payload) {
                     Ok(deserialized_message) => {
+                        let policy_reply = opa_eval(&deserialized_message);
                         {{ if eq .payload.model_type "enum"}}
                             match deserialized_message {
                                 {{$enumName := .payload.unique_id}}
                                 {{ range .payload.related_models }}
                                     {{ $enumName }}::{{ .unique_id }}(payload) => {
-                            let policy_reply = opa_eval(message);
                                     // TODO: Replace this with your own handler code
                                     debug!("Received message payload {{ .unique_id }} {:?}", payload);
                                     }

templates/src/policy/mod.rs.go

@@ -1,2 +1,2 @@
 pub mod policy;
-use policy::*;
+use policy::*;

templates/src/policy/policy.rs.go

@@ -2,12 +2,11 @@ use anyhow::{anyhow, Result};
 use opa_wasm::Runtime;
 use reqwest::{self, Body, Client, IntoUrl, Response};
 use serde::Serialize;
-use std::{env, fs, path::Path};
+use std::env;
 use wasmtime::{Config, Engine, Module, Store};
 
-pub async fn opa_eval<I>(input: I) -> Result<serde_json::Value>
+pub async fn opa_eval<I>(input: &I) -> Result<serde_json::Value>
 where
-    Body: From<I>,
     I: Serialize,
 {
     if let Ok(enabled) = env::var("OPA_ENABLED") {
@@ -18,7 +17,7 @@ where
     }
     if let Ok(url) = env::var("OPA_REMOTE_URL") {
         let url: String = url.parse().unwrap();
-        return opa_eval_remote(url, input).await;
+        return opa_eval_remote(url, serde_json::to_string(&input)?).await;
     }
     if let Ok(path) = env::var("OPA_LOCAL_WASM_PATH") {
         let path: String = path.parse().unwrap();