Example mini-curl: add method exec.

Author: jmjoy

examples/mini-curl/src/lib.rs

@@ -1,15 +1,15 @@
 use curl::easy::Easy;
 use phper::{
-    c_str_ptr, php_fn, php_function, php_minfo, php_minfo_function, php_minit, php_minit_function,
+    c_str_ptr,
+    main::php::error_doc_ref,
+    php_fn, php_function, php_minfo, php_minfo_function, php_minit, php_minit_function,
     php_mshutdown, php_mshutdown_function, php_rinit, php_rinit_function, php_rshutdown,
     php_rshutdown_function,
-    sys::{
-        php_error_docref0, php_info_print_table_end, php_info_print_table_start, E_WARNING,
-        PHP_INI_SYSTEM,
-    },
+    sys::{php_info_print_table_end, php_info_print_table_start, PHP_INI_SYSTEM},
     zend::{
         api::{FunctionEntries, FunctionEntryBuilder},
         compile::{create_zend_arg_info, MultiInternalArgInfo, Visibility},
+        errors::Level,
         ini::{create_ini_entry, IniEntries},
         modules::{create_zend_module_entry, ModuleArgs, ModuleEntry},
         types::{ClassEntry, ExecuteData, ReturnValue, SetVal, Value},
@@ -60,7 +60,7 @@ static ARG_INFO_VOID: MultiInternalArgInfo<0> = MultiInternalArgInfo::new(0, fal
 static ARG_INFO_MINI_CURL_CONSTRUCT: MultiInternalArgInfo<1> =
     MultiInternalArgInfo::new(0, false, [create_zend_arg_info(c_str_ptr!("url"), false)]);
 
-static MINI_CURL_METHODS: FunctionEntries<2> = FunctionEntries::new([
+static MINI_CURL_METHODS: FunctionEntries<3> = FunctionEntries::new([
     FunctionEntryBuilder::new(
         c_str_ptr!("__construct"),
         Some(php_fn!(mini_curl_construct)),
@@ -70,6 +70,9 @@ static MINI_CURL_METHODS: FunctionEntries<2> = FunctionEntries::new([
     FunctionEntryBuilder::new(c_str_ptr!("__destruct"), Some(php_fn!(mini_curl_destruct)))
         .arg_info(&ARG_INFO_VOID)
         .build(),
+    FunctionEntryBuilder::new(c_str_ptr!("exec"), Some(php_fn!(mini_curl_exec)))
+        .arg_info(&ARG_INFO_VOID)
+        .build(),
 ]);
 
 #[php_function]
@@ -85,13 +88,7 @@ pub fn mini_curl_construct(execute_data: &mut ExecuteData) -> impl SetVal {
 
     if !url.is_empty() {
         if let Err(e) = easy.url(url) {
-            unsafe {
-                php_error_docref0(
-                    null(),
-                    E_WARNING as i32,
-                    format!("curl set failed: {}\0", e).as_ptr().cast(),
-                );
-            }
+            error_doc_ref(Level::Warning, format!("curl set failed: {}\0", e));
             return ReturnValue::Bool(false);
         }
     }
@@ -101,6 +98,35 @@ pub fn mini_curl_construct(execute_data: &mut ExecuteData) -> impl SetVal {
     ReturnValue::Null
 }
 
+#[php_function]
+pub fn mini_curl_exec(execute_data: &mut ExecuteData) -> impl SetVal {
+    if execute_data.parse_parameters::<()>().is_none() {
+        return ReturnValue::Bool(false);
+    }
+
+    let mut data = Vec::new();
+
+    let this = execute_data.get_this();
+    let ptr = MINI_CURL_CE.read_property(this, "_rust_easy_ptr");
+    let value = ptr.try_into_value().unwrap();
+    let ptr = value.into_long().unwrap();
+
+    let mut handle = unsafe { Box::from_raw(ptr as *mut Easy) };
+    let mut transfer = handle.transfer();
+    transfer
+        .write_function(|new_data| {
+            data.extend_from_slice(new_data);
+            Ok(new_data.len())
+        })
+        .unwrap();
+    transfer.perform().unwrap();
+    drop(transfer);
+
+    Box::into_raw(handle);
+
+    ReturnValue::String(String::from_utf8(data).unwrap())
+}
+
 #[php_function]
 pub fn mini_curl_destruct(execute_data: &mut ExecuteData) -> impl SetVal {
     if execute_data.parse_parameters::<()>().is_none() {

examples/mini-curl/tests/php/test.php

@@ -5,7 +5,8 @@
 error_reporting(E_ALL);
 
 $mc = new MiniCurl("http://httpbin.org/ip");
-var_dump($mc);
+$response = $mc->exec();
+var_dump($response);
 
 function assert_eq($left, $right) {
     if ($left !== $right) {

phper/src/lib.rs

@@ -30,6 +30,7 @@ Version `0.1.x` will be a preview version.
 */
 
 mod error;
+pub mod main;
 mod utils;
 pub mod zend;
 

phper/src/main/mod.rs

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

phper/src/main/php.rs

@@ -0,0 +1,20 @@
+use crate::zend::errors::Level;
+use std::{os::raw::c_int, ptr::null};
+
+pub fn error_doc_ref(level: Level, message: impl ToString) {
+    let mut message = message.to_string();
+    message.push('\0');
+
+    unsafe {
+        #[cfg(phper_php_version = "7.4")]
+        crate::sys::php_error_docref(null(), level as c_int, message.as_ptr().cast());
+
+        #[cfg(any(
+            phper_php_version = "7.3",
+            phper_php_version = "7.2",
+            phper_php_version = "7.1",
+            phper_php_version = "7.0",
+        ))]
+        crate::sys::php_error_docref0(null(), level as c_int, message.as_ptr().cast());
+    }
+}

phper/src/zend/errors.rs

@@ -0,0 +1,9 @@
+use crate::sys::{E_ERROR, E_NOTICE, E_WARNING};
+
+#[repr(u32)]
+#[derive(Copy, Clone, PartialEq)]
+pub enum Level {
+    Error = E_ERROR,
+    Warning = E_WARNING,
+    Notice = E_NOTICE,
+}

phper/src/zend/mod.rs

@@ -1,5 +1,6 @@
 pub mod api;
 pub mod compile;
+pub mod errors;
 pub mod exceptions;
 pub mod ini;
 pub mod modules;

phper/src/zend/types.rs

@@ -703,6 +703,13 @@ impl<'a> Value<'a> {
             }
         }
     }
+
+    pub fn into_long(self) -> Option<i64> {
+        match self {
+            Self::Long(l) => Some(l),
+            _ => None,
+        }
+    }
 }
 
 pub enum ReturnValue<'a> {