Added PPL functions for getting web requests.

Author: mkrueger

crates/icy_board_engine/src/executable/func_op_codes.rs

@@ -306,9 +306,10 @@ pub enum FuncOpCode {
     MemberCall = -292,
     NewConfInfo = -293,
     AreaId = -294,
+    WebRequest = -295,
 }
 
-pub const LAST_FUNC: i16 = -293;
+pub const LAST_FUNC: i16 = -295;
 
 impl FuncOpCode {
     pub fn get_definition(self) -> &'static FunctionDefinition {
@@ -361,7 +362,7 @@ impl FunctionDefinition {
     }
 }
 lazy_static::lazy_static! {
-    pub static ref FUNCTION_DEFINITIONS: [FunctionDefinition; 298] = [
+    pub static ref FUNCTION_DEFINITIONS: [FunctionDefinition; 299] = [
         FunctionDefinition {
             name: "END",
             version: 100,
@@ -3082,6 +3083,17 @@ lazy_static::lazy_static! {
             arg_descr: 0x02,
         },
 
+        FunctionDefinition {
+            name: "WebRequest",
+            version: 400,
+            opcode: FuncOpCode::AreaId,
+            return_type: VariableType::MessageAreaID,
+            args: Some(vec![
+                ArgumentDefinition::new("url", VariableType::String),
+            ]),
+            arg_descr: 0x02,
+        },
+
         // ALIASES (need to be last in the list)
         FunctionDefinition {
             name: "ToString",

crates/icy_board_engine/src/executable/smt_op_codes.rs

@@ -266,8 +266,9 @@ pub enum OpCode {
     ShortDesc = 227,
     MoveMsg = 228,
     SetBankBal = 229,
+    WebRequest = 230,
 }
-pub const LAST_STMT: i16 = OpCode::SetBankBal as i16;
+pub const LAST_STMT: i16 = OpCode::WebRequest as i16;
 
 impl OpCode {
     pub fn get_definition(self) -> &'static StatementDefinition {
@@ -530,7 +531,7 @@ lazy_static::lazy_static! {
     // "WAIT FOR" == "WAITFOR"
     // "GO SUB"
     // " GO TO"
-    pub static ref STATEMENT_DEFINITIONS: [StatementDefinition; 235] = [
+    pub static ref STATEMENT_DEFINITIONS: [StatementDefinition; 236] = [
         StatementDefinition {
             // helps to map opcode to array index.
             name: "Placeholder",
@@ -2698,6 +2699,17 @@ lazy_static::lazy_static! {
             ]),
             sig: StatementSignature::ArgumentsWithVariable(0, 1),
         },
+
+        StatementDefinition {
+            name: "WebRequest",
+            version: 400,
+            opcode: OpCode::WebRequest,
+            args: Some(vec![
+                ArgumentDefinition::new("url", VariableType::String),
+                ArgumentDefinition::new("FileName", VariableType::String),
+            ]),
+            sig: StatementSignature::ArgumentsWithVariable(0, 1),
+        },
     ];
 }
 

crates/icy_board_engine/src/vm/expressions/mod.rs

@@ -309,5 +309,6 @@ pub async fn run_function(opcode: FuncOpCode, arg: &mut VirtualMachine<'_>, argu
         FuncOpCode::MemberCall => predefined_functions::invalid(arg, arguments).await,
         FuncOpCode::NewConfInfo => predefined_functions::new_confinfo(arg, arguments).await,
         FuncOpCode::AreaId => predefined_functions::area_id(arg, arguments).await,
+        FuncOpCode::WebRequest => predefined_functions::web_request(arg, arguments).await,
     }
 }

crates/icy_board_engine/src/vm/expressions/predefined_functions.rs

@@ -2313,6 +2313,12 @@ pub fn fix_casing(param: String) -> String {
     res
 }
 
+pub async fn web_request(vm: &mut VirtualMachine<'_>, args: &[PPEExpr]) -> Res<VariableValue> {
+    let url = vm.eval_expr(&args[0]).await?.as_string();
+    let response = reqwest::get(url).await?.text().await?;
+    Ok(VariableValue::new_string(response))
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;

crates/icy_board_engine/src/vm/statements/mod.rs

@@ -246,5 +246,6 @@ pub async fn run_predefined_statement(opcode: OpCode, arg: &mut VirtualMachine<'
         OpCode::ShortDesc => predefined_procedures::shortdesc(arg, arguments).await,
         OpCode::MoveMsg => predefined_procedures::move_msg(arg, arguments).await,
         OpCode::SetBankBal => predefined_procedures::set_bank_bal(arg, arguments).await,
+        OpCode::WebRequest => predefined_procedures::web_request(arg, arguments).await,
     }
 }

crates/icy_board_engine/src/vm/statements/predefined_procedures.rs

@@ -1,4 +1,10 @@
-use std::{env, fs, thread, time::Duration};
+use std::{
+    env,
+    fs::{self, File},
+    io::Write,
+    thread,
+    time::Duration,
+};
 
 use crate::{
     Res,
@@ -1960,3 +1966,12 @@ pub async fn set_bank_bal(vm: &mut VirtualMachine<'_>, args: &[PPEExpr]) -> Res<
     }
     Ok(())
 }
+
+pub async fn web_request(vm: &mut VirtualMachine<'_>, args: &[PPEExpr]) -> Res<()> {
+    let url = vm.eval_expr(&args[0]).await?.as_string();
+    let file = vm.eval_expr(&args[1]).await?.as_string();
+    let response = reqwest::get(url).await?.bytes().await?;
+    let mut file = File::create(file)?;
+    file.write_all(&response)?;
+    Ok(())
+}