Example http-server, add method onRequest.

Author: jmjoy

examples/http-client/src/client.rs

@@ -9,7 +9,7 @@ use phper::{
     objects::Object,
 };
 use reqwest::blocking::{Client, ClientBuilder, RequestBuilder};
-use std::{time::Duration};
+use std::time::Duration;
 
 const HTTP_CLIENT_BUILDER_CLASS_NAME: &'static str = "HttpClient\\HttpClientBuilder";
 const HTTP_CLIENT_CLASS_NAME: &'static str = "HttpClient\\HttpClient";

examples/http-server/src/lib.rs

@@ -1,10 +1,7 @@
 use crate::{errors::make_exception_class, server::make_server_class};
 use phper::{modules::Module, php_get_module};
-use std::{
-    mem::{forget},
-    sync::{Arc},
-};
-use tokio::{runtime};
+use std::{mem::forget, sync::Arc};
+use tokio::runtime;
 
 pub mod errors;
 pub mod server;
@@ -31,7 +28,7 @@ pub fn get_module() -> Module {
         true
     });
 
-    module.on_module_shutdown(move |_| false);
+    module.on_module_shutdown(move |_| true);
 
     module.add_class(make_exception_class());
     module.add_class(make_server_class());

examples/http-server/src/server.rs

@@ -10,7 +10,7 @@ use phper::{
     values::Val,
 };
 use std::{convert::Infallible, mem::replace, net::SocketAddr};
-use tokio::{runtime::Handle};
+use tokio::runtime::Handle;
 
 const HTTP_SERVER_CLASS_NAME: &'static str = "HttpServer\\HttpServer";
 
@@ -19,6 +19,7 @@ pub fn make_server_class() -> DynamicClass<Option<Builder<AddrIncoming>>> {
 
     class.add_property("host", Visibility::Private, "127.0.0.1");
     class.add_property("port", Visibility::Private, 8080);
+    class.add_property("onRequestHandle", Visibility::Private, ());
 
     class.add_method(
         "__construct",
@@ -36,6 +37,16 @@ pub fn make_server_class() -> DynamicClass<Option<Builder<AddrIncoming>>> {
         vec![Argument::by_val("host"), Argument::by_val("port")],
     );
 
+    class.add_method(
+        "onRequest",
+        Visibility::Public,
+        |this, arguments| {
+            this.set_property("onRequestHandle", Val::new(arguments[0].duplicate()?));
+            Ok::<_, phper::Error>(())
+        },
+        vec![Argument::by_val("handle")],
+    );
+
     class.add_method(
         "start",
         Visibility::Public,

examples/http-server/tests/php/test.php

@@ -7,4 +7,8 @@
 error_reporting(E_ALL);
 
 $server = new HttpServer("127.0.0.1", 9000);
-$server->start();
+$server->onRequest(function ($request, $response) {
+    $response->header('Content-Type', 'text/plain');
+    $response->end("Hello World\n");
+});
+// $server->start();

phper-sys/php_wrapper.c

@@ -172,3 +172,7 @@ bool phper_zend_hash_index_exists(const HashTable *ht, zend_ulong h) {
 void phper_zval_ptr_dtor_nogc(zval *zval_ptr) {
     zval_ptr_dtor_nogc(zval_ptr);
 }
+
+bool phper_z_refcounted_p(zval *zval_ptr) {
+    return Z_REFCOUNTED_P(zval_ptr);
+}

phper-sys/php_wrapper.h

@@ -60,4 +60,6 @@ bool phper_zend_hash_index_exists(const HashTable *ht, zend_ulong h);
 
 void phper_zval_ptr_dtor_nogc(zval *zval_ptr);
 
+bool phper_z_refcounted_p(zval *zval_ptr);
+
 #endif //PHPER_PHP_WRAPPER_H

phper/src/errors.rs

@@ -77,6 +77,10 @@ pub enum Error {
     #[error(transparent)]
     #[throwable(transparent)]
     InitializeObject(#[from] InitializeObjectError),
+
+    #[error(transparent)]
+    #[throwable(transparent)]
+    NotRefCountedType(#[from] NotRefCountedTypeError),
 }
 
 impl Error {
@@ -146,3 +150,9 @@ pub struct CallMethodError {
 pub struct InitializeObjectError {
     class_name: String,
 }
+
+#[derive(Debug, thiserror::Error, crate::Throwable)]
+#[error("the type is not refcounted")]
+#[throwable_class("TypeError")]
+#[throwable_crate]
+pub struct NotRefCountedTypeError;

phper/src/values.rs

@@ -4,7 +4,7 @@ use crate::{
     alloc::{EAllocatable, EBox},
     arrays::Array,
     classes::ClassEntry,
-    errors::{CallFunctionError, Throwable, TypeError},
+    errors::{CallFunctionError, NotRefCountedTypeError, Throwable, TypeError},
     functions::ZendFunction,
     objects::Object,
     strings::ZendString,
@@ -242,6 +242,21 @@ impl Val {
         }
     }
 
+    /// Only add refcount.
+    ///
+    /// TODO Make a reference type to wrap self.
+    pub fn duplicate(&mut self) -> Result<EBox<Self>, NotRefCountedTypeError> {
+        unsafe {
+            if !phper_z_refcounted_p(self.as_mut_ptr()) {
+                Err(NotRefCountedTypeError)
+            } else {
+                (*self.inner.value.counted).gc.refcount += 1;
+                let val = EBox::from_raw(self.as_mut_ptr().cast());
+                Ok(val)
+            }
+        }
+    }
+
     /// Call only when self is a callable.
     ///
     /// # Errors