/*

   +----------------------------------------------------------------------+

   | Copyright © The PHP Group and Contributors.                          |

   +----------------------------------------------------------------------+

   | This source file is subject to the Modified BSD License that is      |

   | bundled with this package in the file LICENSE, and is available      |

   | through the World Wide Web at <https://www.php.net/license/>.        |

   |                                                                      |

   | SPDX-License-Identifier: BSD-3-Clause                                |

   +----------------------------------------------------------------------+

   | Authors: Paul Panotzki - Bunyip Information Systems                  |

   |          Jim Winstead <jimw@php.net>                                 |

   |          Sascha Schumann <sascha@schumann.cx>                        |

   +----------------------------------------------------------------------+

*/

#include "php.h"

#include "php_globals.h"

#include <stdlib.h>

#include <stddef.h>

#include "php_network.h"

#include "file.h"

#include "streams/php_streams_int.h"

static size_t php_fsockopen_format_host_port(char **message, const char *prefix, size_t prefix_len,

  const char *host, size_t host_len, zend_long port)

{

    char portbuf[32];

    int portlen = snprintf(portbuf, sizeof(portbuf), ":" ZEND_LONG_FMT, port);

    size_t total_len = prefix_len + host_len + portlen;

    *message = zend_cstr_concat3(

        prefix, prefix_len,

        host, host_len,

        portbuf, portlen);

  return total_len;

}

/* {{{ php_fsockopen() */

static void php_fsockopen_stream(INTERNAL_FUNCTION_PARAMETERS, int persistent)

{

  char *host;

  size_t host_len;

  zend_long port = -1;

  zval *zerrno = NULL, *zerrstr = NULL;

  double timeout;

  bool timeout_is_null = 1;

#ifndef PHP_WIN32

  time_t conv;

#else

  long conv;

#endif

  struct timeval tv;

  char *hashkey = NULL;

  php_stream *stream = NULL;

  int err;

  char *hostname = NULL;

  size_t hostname_len;

  zend_string *errstr = NULL;

  ZEND_PARSE_PARAMETERS_START(1, 5)

    Z_PARAM_STRING(host, host_len)

    Z_PARAM_OPTIONAL

    Z_PARAM_LONG(port)

    Z_PARAM_ZVAL(zerrno)

    Z_PARAM_ZVAL(zerrstr)

    Z_PARAM_DOUBLE_OR_NULL(timeout, timeout_is_null)

  ZEND_PARSE_PARAMETERS_END();

  RETVAL_FALSE;

  if (timeout_is_null) {

    timeout = (double)FG(default_socket_timeout);

  }

  if (persistent) {

    zend_string *escaped = php_stream_escape_persistent_key(host, host_len);

    spprintf(&hashkey, 0, "pfsockopen__%s:"  ZEND_LONG_FMT, ZSTR_VAL(escaped), port);

    zend_string_release_ex(escaped, false);

  }

  if (port > 0) {

    hostname_len = php_fsockopen_format_host_port(&hostname, "", 0, host, host_len, port);

  } else {

    hostname_len = host_len;

    hostname = host;

  }

  /* prepare the timeout value for use */

  if (timeout != -1.0 && !(timeout >= 0.0 && timeout <= (double) PHP_TIMEOUT_ULL_MAX / 1000000.0)) {

    if (port > 0) {

      efree(hostname);

    }

    if (hashkey) {

      efree(hashkey);

    }

    zend_argument_value_error(6, "must be -1 or between 0 and " ZEND_ULONG_FMT, ((double) PHP_TIMEOUT_ULL_MAX / 1000000.0));

    RETURN_THROWS();

  } else {

#ifndef PHP_WIN32

    conv = (time_t) (timeout * 1000000.0);

    tv.tv_sec = conv / 1000000;

#else

    conv = (long) (timeout * 1000000.0);

    tv.tv_sec = conv / 1000000;

#endif

    tv.tv_usec = conv % 1000000;

  }

  stream = php_stream_xport_create(hostname, hostname_len, REPORT_ERRORS,

      STREAM_XPORT_CLIENT | STREAM_XPORT_CONNECT, hashkey, &tv, NULL, &errstr, &err);

  if (port > 0) {

    efree(hostname);

  }

  if (stream == NULL) {

    php_error_docref(NULL, E_WARNING, "Unable to connect to %s:" ZEND_LONG_FMT " (%s)", host, port, errstr == NULL ? "Unknown error" : ZSTR_VAL(errstr));

  }

  if (hashkey) {

    efree(hashkey);

  }

  if (stream == NULL) {

    if (zerrno) {

      ZEND_TRY_ASSIGN_REF_LONG(zerrno, err);

    }

    if (errstr) {

      if (zerrstr) {

        ZEND_TRY_ASSIGN_REF_STR(zerrstr, errstr);

      } else {

        zend_string_release(errstr);

      }

    }

    RETURN_FALSE;

  }

  if (zerrno) {

    ZEND_TRY_ASSIGN_REF_LONG(zerrno, 0);

  }

  if (zerrstr) {

    ZEND_TRY_ASSIGN_REF_EMPTY_STRING(zerrstr);

  }

  if (errstr) {

    zend_string_release_ex(errstr, 0);

  }

  php_stream_to_zval(stream, return_value);

}

/* }}} */

/* {{{ Open Internet or Unix domain socket connection */

PHP_FUNCTION(fsockopen)

{

  php_fsockopen_stream(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0);

}

/* }}} */

/* {{{ Open persistent Internet or Unix domain socket connection */

PHP_FUNCTION(pfsockopen)

{

  php_fsockopen_stream(INTERNAL_FUNCTION_PARAM_PASSTHRU, 1);

}

/* }}} */