ext/sockets: follow-up on AF_PACKET support.

support from socket_recvfrom and exposing basic PHP userland type.

Author: devnexen

ext/sockets/config.m4

@@ -5,7 +5,7 @@ PHP_ARG_ENABLE([sockets],
 
 if test "$PHP_SOCKETS" != "no"; then
   AC_CHECK_FUNCS([hstrerror if_nametoindex if_indextoname sockatmark])
-  AC_CHECK_HEADERS([sys/sockio.h linux/filter.h linux/if_packet.h linux/if_ether.h])
+  AC_CHECK_HEADERS([sys/sockio.h linux/filter.h linux/if_packet.h linux/if_ether.h netinet/ether.h])
   AC_DEFINE([HAVE_SOCKETS], [1],
     [Define to 1 if the PHP extension 'sockets' is available.])
 

ext/sockets/php_sockets.h

@@ -77,6 +77,10 @@ typedef struct {
 
 extern PHP_SOCKETS_API zend_class_entry *socket_ce;
 
+#ifdef AF_PACKET
+extern PHP_SOCKETS_API zend_class_entry *socket_ethinfo_ce;
+#endif
+
 static inline php_socket *socket_from_obj(zend_object *obj) {
 	return (php_socket *)((char *)(obj) - XtOffsetOf(php_socket, std));
 }

ext/sockets/sockets.c

@@ -41,6 +41,7 @@
 # include <netdb.h>
 # include <netinet/in.h>
 # include <netinet/tcp.h>
+# include <netinet/udp.h>
 # include <sys/un.h>
 # include <arpa/inet.h>
 # include <sys/time.h>
@@ -54,6 +55,10 @@
 # ifdef HAVE_IF_NAMETOINDEX
 #  include <net/if.h>
 # endif
+# ifdef HAVE_NETINET_ETHER_H
+#  include <netinet/ether.h>
+#  include <netinet/ip.h>
+# endif
 # if defined(HAVE_LINUX_SOCK_DIAG_H)
 #  include <linux/sock_diag.h>
 # else
@@ -120,6 +125,9 @@ static PHP_RSHUTDOWN_FUNCTION(sockets);
 
 zend_class_entry *socket_ce;
 static zend_object_handlers socket_object_handlers;
+#ifdef AF_PACKET
+zend_class_entry *socket_ethinfo_ce;
+#endif
 
 static zend_object *socket_create_object(zend_class_entry *class_type) {
 	php_socket *intern = zend_object_alloc(sizeof(php_socket), class_type);
@@ -482,6 +490,9 @@ static PHP_MINIT_FUNCTION(sockets)
 	socket_object_handlers.get_gc = socket_get_gc;
 	socket_object_handlers.compare = zend_objects_not_comparable;
 
+#if defined(AF_PACKET)
+	socket_ethinfo_ce = register_class_SocketEthernetInfo();
+#endif
 	address_info_ce = register_class_AddressInfo();
 	address_info_ce->create_object = address_info_create_object;
 	address_info_ce->default_object_handlers = &address_info_object_handlers;
@@ -1505,7 +1516,7 @@ PHP_FUNCTION(socket_recvfrom)
 	struct sockaddr_in6	sin6;
 #endif
 #ifdef AF_PACKET
-	//struct sockaddr_ll     sll;
+	struct sockaddr_ll     sll;
 #endif
 	char				addrbuf[INET6_ADDRSTRLEN];
 	socklen_t			slen;
@@ -1534,6 +1545,12 @@ PHP_FUNCTION(socket_recvfrom)
 		RETURN_FALSE;
 	}
 
+#ifdef AF_PACKET
+	if (php_sock->type == AF_PACKET && arg3 < 2048) {
+		RETURN_FALSE;
+	}
+#endif
+
 	recv_buf = zend_string_alloc(arg3 + 1, 0);
 
 	switch (php_sock->type) {
@@ -1612,14 +1629,14 @@ PHP_FUNCTION(socket_recvfrom)
 			break;
 #endif
 #ifdef AF_PACKET
-			/*
 		case AF_PACKET:
 			// TODO expose and use proper ethernet frame type instead i.e. src mac, dst mac and payload to userland
 			// ditto for socket_sendto
 			slen = sizeof(sll);
 			memset(&sll, 0, sizeof(sll));
 			sll.sll_family = AF_PACKET;
 			char ifrname[IFNAMSIZ];
+			zval zpayload;
 
 			retval = recvfrom(php_sock->bsd_socket, ZSTR_VAL(recv_buf), arg3, arg4, (struct sockaddr *)&sll, (socklen_t *)&slen);
 
@@ -1628,20 +1645,61 @@ PHP_FUNCTION(socket_recvfrom)
 				zend_string_efree(recv_buf);
 				RETURN_FALSE;
 			}
-			ZSTR_LEN(recv_buf) = retval;
-			ZSTR_VAL(recv_buf)[ZSTR_LEN(recv_buf)] = '\0';
 
 			if (UNEXPECTED(!if_indextoname(sll.sll_ifindex, ifrname))) {
 				PHP_SOCKET_ERROR(php_sock, "unable to get the interface name", errno);
 				zend_string_efree(recv_buf);
 				RETURN_FALSE;
 			}
 
-			ZEND_TRY_ASSIGN_REF_NEW_STR(arg2, recv_buf);
+			struct ethhdr *e = (struct ethhdr *)ZSTR_VAL(recv_buf);
+			unsigned short protocol = ntohs(e->h_proto);
+			unsigned char *payload = ((unsigned char *)e + sizeof(struct ethhdr));
+
+			object_init_ex(arg2, socket_ethinfo_ce);
+			zend_update_property_string(Z_OBJCE_P(arg2), Z_OBJ_P(arg2), ZEND_STRL("macsrc"), ether_ntoa((struct ether_addr *)e->h_source));
+			zend_update_property_string(Z_OBJCE_P(arg2), Z_OBJ_P(arg2), ZEND_STRL("macdst"), ether_ntoa((struct ether_addr *)e->h_dest));
+			array_init(&zpayload);
+
+			switch (protocol) {
+				case ETH_P_IP: {
+					struct iphdr *ip = (struct iphdr *)payload;
+					unsigned char *ipdata = payload + (ip->ihl * 4);
+					struct in_addr s, d;
+					s.s_addr = ip->saddr;
+					d.s_addr = ip->daddr;
+					add_assoc_string(&zpayload, "ipsrc", inet_ntoa(s));
+					add_assoc_string(&zpayload, "ipdst", inet_ntoa(d));
+
+					switch (ip->protocol) {
+						case IPPROTO_TCP: {
+							struct tcphdr *tcp = (struct tcphdr *)ipdata;
+							add_assoc_long(&zpayload, "portsrc", ntohs(tcp->th_sport));
+							add_assoc_long(&zpayload, "portdst", ntohs(tcp->th_dport));
+							break;
+						}
+						case IPPROTO_UDP: {
+							struct udphdr *udp = (struct udphdr *)ipdata;
+							add_assoc_long(&zpayload, "portsrc", ntohs(udp->uh_sport));
+							add_assoc_long(&zpayload, "portdst", ntohs(udp->uh_dport));
+							break;
+						}
+						default:
+							zend_value_error("unsupported ip header protocol");
+							RETURN_THROWS();
+					}
+					break;
+				}
+				default:
+					zend_value_error("unsupported ethernet protocol");
+					RETURN_THROWS();
+			}
+
+			zend_update_property(Z_OBJCE_P(arg2), Z_OBJ_P(arg2), ZEND_STRL("payload"), &zpayload);
+
 			ZEND_TRY_ASSIGN_REF_STRING(arg5, ifrname);
 			ZEND_TRY_ASSIGN_REF_LONG(arg6, sll.sll_ifindex);
 			break;
-			*/
 #endif
 		default:
 			zend_argument_value_error(1, "must be one of AF_UNIX, AF_INET, or AF_INET6");
@@ -1752,7 +1810,7 @@ PHP_FUNCTION(socket_sendto)
 
 			retval = sendto(php_sock->bsd_socket, buf, ((size_t)len > buf_len) ? buf_len : (size_t)len, flags, (struct sockaddr *) &sin, sizeof(sin));
 			break;
-		*/
+			*/
 #endif
 		default:
 			zend_argument_value_error(1, "must be one of AF_UNIX, AF_INET, or AF_INET6");

ext/sockets/sockets.stub.php

@@ -2149,3 +2149,17 @@ function socket_wsaprotocol_info_import(string $info_id): Socket|false {}
 
 function socket_wsaprotocol_info_release(string $info_id): bool {}
 #endif
+
+#ifdef AF_PACKET
+final class SocketEthernetInfo
+{
+    /** @readonly **/
+    public Socket $socket;
+    /** @readonly **/
+    public string $macsrc;
+    /** @readonly **/
+    public string $macdst;
+    /** @readonly **/
+    public array $payload;
+}
+#endif