Function process_service_file

crates/qsync/src/processor.rs:316–469

(
    endpoint_prefix: &str,
    base_input_path: &Path,
    input_path: PathBuf,
    state: &mut BuildState,
    input: &QsyncInput,
)

#[allow(clippy::too_many_lines)]
fn process_service_file(
    endpoint_prefix: &str,
    base_input_path: &Path,
    input_path: PathBuf,
    state: &mut BuildState,
    input: &QsyncInput,
) {
    if state.is_debug {
        println!(
            "processing rust file: {:?}",
            input_path.clone().into_os_string().into_string().unwrap()
        );
    }

    let file = File::open(&input_path);

    if file.is_err() {
        state.unprocessed_files.push(input_path);
        return;
    }

    let mut file = file.unwrap();

    let mut src = String::new();
    if file.read_to_string(&mut src).is_err() {
        state.unprocessed_files.push(input_path);
        return;
    }

    let syntax = syn::parse_file(&src);

    if syntax.is_err() {
        state.unprocessed_files.push(input_path);
        return;
    }

    let syntax = syntax.unwrap();

    for item in syntax.items {
        if let syn::Item::Fn(exported_fn) = item {
            let qsync_props = has_qsync_attribute(state.is_debug, &exported_fn.attrs);

            let has_qsync_attribute = qsync_props.is_some();

            if state.is_debug {
                if has_qsync_attribute {
                    println!(
                        "Encountered #[get|post|put|delete] struct: {}",
                        exported_fn.sig.ident
                    );
                } else {
                    println!("Encountered non-query struct: {}", exported_fn.sig.ident);
                }
            }

            if has_qsync_attribute {
                let qsync_props = qsync_props.unwrap();
                let mut hook = Hook {