Project

General

Profile

Download (5.84 KB) Statistics
| Branch: | Tag: | Revision:
1
<?php
2
/*
3
 * xmlrpc_client.inc
4
 *
5
 * part of pfSense (https://www.pfsense.org)
6
 * Copyright (c) 2016 Electric Sheep Fencing
7
 * Copyright (c) 2016-2024 Rubicon Communications, LLC (Netgate)
8
 * All rights reserved.
9
 *
10
 * Licensed under the Apache License, Version 2.0 (the "License");
11
 * you may not use this file except in compliance with the License.
12
 * You may obtain a copy of the License at
13
 *
14
 * http://www.apache.org/licenses/LICENSE-2.0
15
 *
16
 * Unless required by applicable law or agreed to in writing, software
17
 * distributed under the License is distributed on an "AS IS" BASIS,
18
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
19
 * See the License for the specific language governing permissions and
20
 * limitations under the License.
21
 */
22

    
23
require_once("XML/RPC2/Client.php");
24

    
25
class pfsense_xmlrpc_client {
26

    
27
	private $username, $password, $url, $logurl, $filenotice, $error;
28

    
29
	public function __construct() {
30
		$hasync = config_get_path('hasync', []);
31
		/* XMLRPC sync is not configured, nothing to do.
32
		 * https://redmine.pfsense.org/issues/14182 */
33
		if (empty($hasync)) {
34
			$this->error = "XMLRPC Synchronization is not configured.";
35
			return;
36
		}
37

    
38
		if (empty($hasync['username'])) {
39
			$username = "admin";
40
		} else {
41
			$username = $hasync['username'];
42
		}
43
		/* if port is empty lets rely on the protocol selection */
44
		$port = config_get_path('system/webgui/port');
45
		if (empty($port)) {
46
			if (config_get_path('system/webgui/protocol') == "http") {
47
				$port = "80";
48
			} else {
49
				$port = "443";
50
			}
51
		}
52
		$this->setConnectionData($hasync['synchronizetoip'], $port, $username, $hasync['password']);
53
	}
54

    
55
	public function setConnectionData($syncip, $port, $username, $password, $scheme = "") {
56
		$this->username = $username;
57
		$this->password = $password;
58
		$this->filenotice = "sync_settings";
59
		if (empty($scheme)) {
60
			$scheme = "http";
61
			if ($port == "443") {
62
				$scheme = "https";
63
			} elseif (config_get_path('system/webgui/protocol') == "https") {
64
				$scheme = "https";
65
			}
66
		}
67
		if (is_ipaddrv6($syncip)) {
68
			$syncip = "[{$syncip}]";
69
		}
70
		$user = rawurlencode($this->username);
71
		$pass = rawurlencode($this->password);
72

    
73
		$this->logurl = "{$scheme}://{$syncip}:{$port}/xmlrpc.php";
74
		$this->url = "{$scheme}://{$user}:{$pass}@{$syncip}:{$port}/xmlrpc.php";
75
	}
76

    
77
	public function set_noticefile($noticefile) {
78
		$this->filenotice = $noticefile;
79
	}
80

    
81
	private function xmlrpc_internal($method, $parameter, $timeout = 240) {
82
		/* XMLRPC sync is not configured, nothing to do.
83
		 * https://redmine.pfsense.org/issues/14182 */
84
		if (empty($this->url) ||
85
		    empty($this->logurl)) {
86
			$this->error = "XMLRPC Synchronization is not configured.";
87
			return;
88
		}
89
		$options = array(
90
			'prefix' => 'pfsense.',
91
			'sslverify' => false,
92
			'connectionTimeout' => $timeout
93
		);
94

    
95
		$max_attempts = 4;
96
		$numberofruns = 0;
97
		while ($numberofruns < $max_attempts) {
98
			$numberofruns++;
99
			$this->error = null;
100

    
101
			log_error(sprintf(gettext("Beginning XMLRPC sync data to %s."), $this->logurl));
102
			$cli = XML_RPC2_Client::create($this->url, $options);
103
			if (!is_object($cli)) {
104
				$this->error = sprintf(gettext("A communications error occurred while attempting XMLRPC sync with %s (pfsense.%s)."), $this->logurl, $method);
105
			}
106
			try {//restore_config_section
107
				$REQUEST_URI = $_SERVER['REQUEST_URI'];
108
				unset($_SERVER['REQUEST_URI']); // force use of 'toText()' when setting XML_RPC2_CurlException message
109
				$resp = $cli->$method($parameter, $timeout);
110
			} catch (XML_RPC2_FaultException $e) {
111
				// The XMLRPC server returns a XMLRPC error
112
				$this->error = "Exception calling XMLRPC method {$method} #" . $e->getFaultCode() . ' : ' . $e->getFaultString();
113
				log_error($this->error);
114
				file_notice($this->filenotice, $this->error, "Communications error occurred", "");
115
			} catch (XML_RPC2_CurlException $e) {
116
				$previouserror = $e->getPrevious();// HTTP_Request2_ConnectionException
117
				if ($previouserror == null) {
118
					// CurlException doesnt get filled with PreviousError,
119
					// however we dont want to show the stacktrace included in the 'message' to non sysadmin users
120
					preg_match("/HTTP_Request2_ConnectionException: (.*) in \/.*/", $e->getMessage(), $errormsg);
121
					if (empty($errormsg) || (is_array($errormsg) && empty($errormsg[1]))) {
122
						$errormsg = $e->getMessage();
123
					}
124
					$this->error = "A communications error occurred while attempting to call XMLRPC method {$method}: {$errormsg}";
125
				} else {
126
					$this->error = "CurlException calling XMLRPC method {$method} #" . $previouserror->getMessage();
127
				}
128
			} catch (Exception $e) {
129
				// Other errors (HTTP or networking problems...)
130
				$this->error = "Exception calling XMLRPC method {$method} # " . $e->getMessage();
131
			} finally {
132
				if (isset($REQUEST_URI)) {
133
					// restore the unset variable to its previous state.
134
					$_SERVER['REQUEST_URI'] = $REQUEST_URI;
135
				}
136
			}
137

    
138
			if (!is_array($resp) && trim($resp) == "Authentication failed") {
139
				$this->error = "An authentication failure occurred while trying to access {$this->logurl} ({$method}).";
140
			}
141
			if (empty($this->error)) {
142
				log_error(sprintf(gettext("XMLRPC reload data success with %s (pfsense.{$method})."), $this->logurl));
143
				return $resp;
144
			} elseif ($numberofruns < $max_attempts) {
145
				log_error(sprintf(gettext("Retrying XMLRPC Request due to error: %s"), $this->error));
146
				sleep(1);
147
			} else {
148
				log_error($this->error);
149
				file_notice($this->filenotice, $this->error, "XMLRPC Error", "");
150
			}
151
		}
152
		return null;
153
	}
154

    
155
	public function xmlrpc_exec_php($execcmd, $timeout = 240) {
156
		$resp = $this->xmlrpc_internal("exec_php", $execcmd, $timeout);
157
		return $resp;
158
	}
159

    
160
	public function xmlrpc_method($method, $parameter = "", $timeout = 240) {
161
		$resp = $this->xmlrpc_internal($method, $parameter, $timeout);
162
		return $resp;
163
	}
164

    
165
	public function get_error() {
166
		return $this->error;
167
	}
168

    
169
	public function getUrl() {
170
		return $this->logurl;
171
	}
172
}
(61-61/61)