File content resource

Author: adityapatwardhan

dsc/examples/filesys_filecontent.yaml

@@ -0,0 +1,9 @@
+# Example configuration mixing native app resources with classic PS resources
+$schema: https://raw.githubusercontent.com/PowerShell/DSC/main/schemas/2024/04/config/document.json
+resources:
+- name: Set file content
+  type: Microsoft.DSC/FileContent
+  properties:
+    path: "[path('d:\\', 'temp', 'a.txt')]"
+    content: "Hello, World!"
+    _exist: true

resources/filesys/filecontent.dsc.resource.json

@@ -26,6 +26,17 @@
         ],
         "input": "stdin"
     },
+    "delete": {
+        "executable": "filesys",
+        "args": [
+            "delete",
+            {
+                "jsonInputArg": "--input",
+                "mandatory": true
+            }
+        ],
+        "input": "stdin"
+    },
     "schema": {
         "command": {
             "executable": "filesys",

resources/filesys/src/filecontent_helper.rs

@@ -4,6 +4,7 @@
 use crate::config::{FileContent, Encoding};
 use std::path::Path;
 use std::io;
+use std::io::Write;
 use tracing::{debug};
 
 impl Encoding {
@@ -48,16 +49,35 @@ pub fn get_file_content(filecontent: &FileContent) -> Result<FileContent, Box<dy
 }
 
 pub fn set_file_content(filecontent: &FileContent) -> Result<FileContent, Box<dyn std::error::Error>> {
-    // debug!("In set_file_content");
-    // let path = Path::new(&filecontent.path);
-    // let content = filecontent.content.as_ref().unwrap_or(&String::new());
-    // let encoding = filecontent.encoding.unwrap_or(Encoding::Utf8).to_encoding_rs().unwrap_or(encoding_rs::UTF_8);
-    // let mut file = fsFile::create(path)?;
+    debug!("In set_file_content");
+    let path = Path::new(&filecontent.path);
+    //let content = filecontent.content.as_ref().unwrap_or(&String::new());
+    //let encoding = filecontent.encoding.unwrap_or(Encoding::Utf8).to_encoding_rs().unwrap_or(encoding_rs::UTF_8);
+    let file_expected_exists = filecontent.exist.unwrap_or(true);
+
+    if path.exists() && !file_expected_exists {
+        std::fs::remove_file(path)?;
+        return Ok(filecontent.clone())
+    }
+    else if !path.exists() && !file_expected_exists {
+        return Ok(filecontent.clone())
+    }
+
+    let mut file = std::fs::File::create(path)?;
+
     // let mut encoder = encoding.new_encoder();
     // let mut bytes = vec![0; content.len() * encoding.new_encoder().max_buffer_length()];
     // let (bytes_written, _, _) = encoder.encode_to_slice(content, &mut bytes, true);
     // file.write_all(&bytes[..bytes_written])?;
-    // Ok(filecontent.clone())
+
+    match &filecontent.content {
+        Some(content) => {
+            file.write_all(content.as_bytes())?;
+        },
+        None => {
+        }
+    }
+
     Ok(filecontent.clone())
 }
 
@@ -126,7 +146,9 @@ pub fn compare_filecontent_state(filecontent: &FileContent) -> Result<FileConten
     else {
         match filecontent.exist {
             Some(true) | None => {
-                return Err("File does not exist")?;
+                let mut updated_file_content = filecontent.clone();
+                updated_file_content.exist = Some(false);
+                return Ok(updated_file_content);
             },
             Some(false) => {
                 return Ok(filecontent.clone());

resources/filesys/src/main.rs

@@ -8,7 +8,7 @@ use tracing::{debug, error};
 use crate::config::{File, Directory, FileContent};
 use file_helper::{get_file, set_file, delete_file, export_file_path};
 use dir_helpers::{get_dir, set_dir, delete_dir, export_dir_path};
-use filecontent_helper::{get_file_content, delete_file_content};
+use filecontent_helper::{get_file_content, set_file_content, delete_file_content};
 use schemars::schema_for;
 
 mod args;
@@ -40,7 +40,7 @@ fn main() {
                             println!("{}", json);
                         }
                         None => {
-                            let filecontent = match is_fillecontent_type(input.as_str()) {
+                            let filecontent = match is_filecontent_type(input.as_str()) {
                                 Some(filecontent) => {
                                     let filecontent = get_file_content(&filecontent).unwrap();
                                     let json = serde_json::to_string(&filecontent).unwrap();
@@ -73,7 +73,7 @@ fn main() {
                             println!("{}", json);
                         }
                         None => {
-                            let filecontent = match is_fillecontent_type(input.as_str()) {
+                            let filecontent = match is_filecontent_type(input.as_str()) {
                                 Some(filecontent) => {
                                     let filecontent = delete_file_content(&filecontent).unwrap();
                                     let json = serde_json::to_string(&filecontent).unwrap();
@@ -107,11 +107,11 @@ fn main() {
                             println!("{}", json);
                         }
                         None => {
-                            let filecontent = match is_fillecontent_type(input.as_str()) {
+                            let filecontent = match is_filecontent_type(input.as_str()) {
                                 Some(filecontent) => {
-                                    // let filecontent = get_file(&filecontent).unwrap();
-                                    // let json = serde_json::to_string(&filecontent).unwrap();
-                                    // println!("{}", json);
+                                    let filecontent = set_file_content(&filecontent).unwrap();
+                                    let json = serde_json::to_string(&filecontent).unwrap();
+                                    println!("{}", json);
                                 }
                                 None => {
                                     error!("Invalid input.");
@@ -142,11 +142,11 @@ fn main() {
                             debug!("File exported successfully.");
                         }
                         None => {
-                            let filecontent = match is_fillecontent_type(input.as_str()) {
+                            let filecontent = match is_filecontent_type(input.as_str()) {
                                 Some(filecontent) => {
-                                    // let filecontent = get_file(&filecontent).unwrap();
-                                    // let json = serde_json::to_string(&filecontent).unwrap();
-                                    // println!("{}", json);
+                                    let filecontent = get_file_content(&filecontent).unwrap();
+                                    let json = serde_json::to_string(&filecontent).unwrap();
+                                    println!("{}", json);
                                 }
                                 None => {
                                     error!("Invalid input.");
@@ -200,7 +200,7 @@ fn is_directory_type(input: &str) -> Option<Directory> {
     Some(dir)
 }
 
-fn is_fillecontent_type(input: &str) -> Option<FileContent> {
+fn is_filecontent_type(input: &str) -> Option<FileContent> {
     let filecontent: FileContent = match serde_json::from_str(input) {
         Ok(input) => input,
         Err(_) => return None,