44 #include <sys/types.h>
51 #define DIR_SEP_STRING "\\"
52 #define DIR_SEP_CHAR '\\'
55 #define DIR_SEP_STRING "/"
56 #define DIR_SEP_CHAR '/'
71 RCReader* RCReader::_instance = 0;
76 static pthread_once_t instance_control = PTHREAD_ONCE_INIT;
83 RCReader::write_rc_file(
const string &pathname)
85 DBG(cerr <<
"Writing the RC file to " << pathname << endl);
86 ofstream fpo(pathname.c_str());
94 fpo <<
"# OPeNDAP client configuration file. See the OPeNDAP" << endl;
95 fpo <<
"# users guide for information." << endl;
96 fpo <<
"USE_CACHE=" << _dods_use_cache << endl;
97 fpo <<
"# Cache and object size are given in megabytes (20 ==> 20Mb)."
99 fpo <<
"MAX_CACHE_SIZE=" << _dods_cache_max << endl;
100 fpo <<
"MAX_CACHED_OBJ=" << _dods_cached_obj << endl;
101 fpo <<
"IGNORE_EXPIRES=" << _dods_ign_expires << endl;
102 fpo <<
"CACHE_ROOT=" << d_cache_root << endl;
103 fpo <<
"DEFAULT_EXPIRES=" << _dods_default_expires << endl;
104 fpo <<
"ALWAYS_VALIDATE=" << _dods_always_validate << endl;
105 fpo <<
"# Request servers compress responses if possible?" << endl;
106 fpo <<
"# 1 (yes) or 0 (false)." << endl;
107 fpo <<
"DEFLATE=" << _dods_deflate << endl;
109 fpo <<
"# Should SSL certificates and hosts be validated? SSL" << endl;
110 fpo <<
"# will only work with signed certificates." << endl;
111 fpo <<
"VALIDATE_SSL=" << d_validate_ssl << endl;
113 fpo <<
"# Proxy configuration (optional parts in []s)." << endl;
114 fpo <<
"# You may also use the 'http_proxy' environment variable"
116 fpo <<
"# but a value in this file will override that env variable."
118 fpo <<
"# PROXY_SERVER=[http://][username:password@]host[:port]"
120 if (!d_dods_proxy_server_host.empty()) {
121 fpo <<
"PROXY_SERVER=" << d_dods_proxy_server_protocol <<
"://"
122 << (d_dods_proxy_server_userpw.empty()
124 : d_dods_proxy_server_userpw +
"@")
125 + d_dods_proxy_server_host
129 fpo <<
"# NO_PROXY_FOR=<host|domain>" << endl;
130 if (!d_dods_no_proxy_for_host.empty()) {
131 fpo <<
"NO_PROXY_FOR=" << d_dods_no_proxy_for_host << endl;
134 fpo <<
"# AIS_DATABASE=<file or url>" << endl;
136 fpo <<
"# COOKIE_JAR=.dods_cookies" << endl;
137 fpo <<
"# The cookie jar is a file that holds cookies sent from"
139 fpo <<
"# servers such as single signon systems. Uncomment this"
141 fpo <<
"# option and provide a file name to activate this feature."
143 fpo <<
"# If the value is a filename, it will be created in this"
145 fpo <<
"# directory; a full pathname can be used to force a specific"
147 fpo <<
"# location." << endl;
157 RCReader::read_rc_file(
const string &pathname)
159 DBG(cerr <<
"Reading the RC file from " << pathname << endl);
161 ifstream fpi(pathname.c_str());
170 vector<char> tempstr(1024);
173 fpi.getline(&tempstr[0], 1023);
177 value = strchr(&tempstr[0],
'=');
180 tokenlength = value - &tempstr[0];
183 if ((strncmp(&tempstr[0],
"USE_CACHE", 9) == 0)
184 && tokenlength == 9) {
185 _dods_use_cache = atoi(value) ?
true :
false;
187 else if ((strncmp(&tempstr[0],
"MAX_CACHE_SIZE", 14) == 0)
188 && tokenlength == 14) {
189 _dods_cache_max = atoi(value);
191 else if ((strncmp(&tempstr[0],
"MAX_CACHED_OBJ", 14) == 0)
192 && tokenlength == 14) {
193 _dods_cached_obj = atoi(value);
195 else if ((strncmp(&tempstr[0],
"IGNORE_EXPIRES", 14) == 0)
196 && tokenlength == 14) {
197 _dods_ign_expires = atoi(value);
199 else if ((strncmp(&tempstr[0],
"DEFLATE", 7) == 0)
200 && tokenlength == 7) {
201 _dods_deflate = atoi(value) ?
true :
false;
203 else if ((strncmp(&tempstr[0],
"CACHE_ROOT", 10) == 0)
204 && tokenlength == 10) {
205 d_cache_root = value;
206 if (d_cache_root[d_cache_root.length() - 1] !=
DIR_SEP_CHAR)
209 else if ((strncmp(&tempstr[0],
"DEFAULT_EXPIRES", 15) == 0)
210 && tokenlength == 15) {
211 _dods_default_expires = atoi(value);
213 else if ((strncmp(&tempstr[0],
"ALWAYS_VALIDATE", 15) == 0)
214 && tokenlength == 15) {
215 _dods_always_validate = atoi(value);
217 else if ((strncmp(&tempstr[0],
"VALIDATE_SSL", 12) == 0)
218 && tokenlength == 12) {
219 d_validate_ssl = atoi(value);
221 else if (strncmp(&tempstr[0],
"AIS_DATABASE", 12) == 0
222 && tokenlength == 12) {
223 d_ais_database = value;
225 else if (strncmp(&tempstr[0],
"COOKIE_JAR", 10) == 0
226 && tokenlength == 10) {
230 if (value[0] ==
'/') {
231 d_cookie_jar = value;
234 d_cookie_jar = d_rc_file_path.substr(0, d_rc_file_path.find(
".dodsrc")) +
string(value);
236 DBG(cerr <<
"set cookie jar to: " << d_cookie_jar << endl);
238 else if ((strncmp(&tempstr[0],
"PROXY_SERVER", 12) == 0)
239 && tokenlength == 12) {
246 string proxy = value;
247 string::size_type comma = proxy.find(
',');
251 if (comma != string::npos) {
252 d_dods_proxy_server_protocol = proxy.substr(0, comma);
253 downcase(d_dods_proxy_server_protocol);
254 if (d_dods_proxy_server_protocol !=
"http")
255 throw Error(
"The only supported protocol for a proxy server is \"HTTP\". Correct your \".dodsrc\" file.");
256 proxy = proxy.substr(comma + 1);
259 d_dods_proxy_server_protocol =
"http";
263 string::size_type protocol = proxy.find(
"://");
264 if (protocol != string::npos) {
265 proxy = proxy.substr(protocol + 3);
269 string::size_type at_sign = proxy.find(
'@');
270 if (at_sign != string::npos) {
271 d_dods_proxy_server_userpw = proxy.substr(0, at_sign);
272 proxy = proxy.substr(at_sign + 1);
275 d_dods_proxy_server_userpw =
"";
278 string::size_type colon = proxy.find(
':');
279 if (colon != string::npos) {
280 d_dods_proxy_server_host = proxy.substr(0, colon);
281 d_dods_proxy_server_port
282 = strtol(proxy.substr(colon + 1).c_str(), 0, 0);
285 d_dods_proxy_server_host = proxy;
286 d_dods_proxy_server_port = 80;
289 else if ((strncmp(&tempstr[0],
"NO_PROXY_FOR", 12) == 0)
290 && tokenlength == 12) {
292 string no_proxy = value;
293 string::size_type comma = no_proxy.find(
',');
297 if (comma == string::npos) {
298 d_dods_no_proxy_for_protocol =
"http";
299 d_dods_no_proxy_for_host = no_proxy;
300 d_dods_no_proxy_for =
true;
303 d_dods_no_proxy_for_protocol = no_proxy.substr(0, comma);
304 d_dods_no_proxy_for_host = no_proxy.substr(comma + 1);
305 d_dods_no_proxy_for =
true;
324 RCReader::check_string(
string env_var)
326 DBG(cerr <<
"Entering check_string... (" << env_var <<
")" << endl);
327 struct stat stat_info;
329 if (stat(env_var.c_str(), &stat_info) != 0) {
330 DBG(cerr <<
"stat returned non-zero" << endl);
334 if (S_ISREG(stat_info.st_mode)) {
335 DBG(cerr <<
"S_ISREG: " << S_ISREG(stat_info.st_mode) << endl);
341 if (S_ISDIR(stat_info.st_mode)) {
342 DBG(cerr <<
"S_ISDIR: " << S_ISDIR(stat_info.st_mode) << endl);
350 env_var +=
".dodsrc";
351 if (stat(env_var.c_str(), &stat_info) == 0 &&
352 S_ISREG(stat_info.st_mode)) {
353 DBG(cerr <<
"Found .dodsrc in \"" << env_var <<
"\"" << endl);
360 if (write_rc_file(env_var)) {
361 DBG(cerr <<
"Wrote .dodsrc in \"" << env_var <<
"\"" << endl);
367 DBG(cerr <<
"could neither find nor create a .dodsrc file" << endl);
381 RCReader::check_env_var(
const string &variable_name)
383 char *ev = getenv(variable_name.c_str());
384 if (!ev || strlen(ev) == 0)
387 return check_string(ev);
390 RCReader::RCReader()
throw(Error)
397 _dods_use_cache =
false;
398 _dods_cache_max = 20;
399 _dods_cached_obj = 5;
400 _dods_ign_expires = 0;
401 _dods_default_expires = 86400;
402 _dods_always_validate = 0;
409 d_dods_proxy_server_protocol =
"";
410 d_dods_proxy_server_host =
"";
411 d_dods_proxy_server_port = 0;
412 d_dods_proxy_server_userpw =
"";
414 _dods_proxy_server_host_url =
"";
418 _dods_proxy_for =
false;
419 _dods_proxy_for_regexp =
"";
420 _dods_proxy_for_proxy_host_url =
"";
421 _dods_proxy_for_regexp_flags = 0;
425 d_dods_no_proxy_for =
false;
426 d_dods_no_proxy_for_protocol =
"";
427 d_dods_no_proxy_for_host =
"";
431 _dods_no_proxy_for_port = 0;
436 string homedir = string(
"C:") + string(
DIR_SEP_STRING) + string(
"Dods");
437 d_rc_file_path = check_string(homedir);
438 if (d_rc_file_path.empty()) {
439 homedir = string(
"C:") + string(
DIR_SEP_STRING) + string(
"opendap");
440 d_rc_file_path = check_string(homedir);
443 if (d_rc_file_path.empty())
444 d_rc_file_path = check_env_var(
"APPDATA");
445 if (d_rc_file_path.empty())
446 d_rc_file_path = check_env_var(
"TEMP");
447 if (d_rc_file_path.empty())
448 d_rc_file_path = check_env_var(
"TMP");
450 d_rc_file_path = check_env_var(
"DODS_CONF");
451 if (d_rc_file_path.empty())
452 d_rc_file_path = check_env_var(
"HOME");
454 DBG(cerr <<
"Looking for .dodsrc in: " << d_rc_file_path << endl);
456 if (!d_rc_file_path.empty())
457 read_rc_file(d_rc_file_path);
460 RCReader::~RCReader()
465 RCReader::delete_instance()
467 if (RCReader::_instance) {
468 delete RCReader::_instance;
469 RCReader::_instance = 0;
475 RCReader::initialize_instance()
477 DBGN(cerr <<
"RCReader::initialize_instance() ... ");
479 RCReader::_instance =
new RCReader;
480 atexit(RCReader::delete_instance);
482 DBG(cerr <<
"exiting." << endl);
488 DBG(cerr <<
"Entring RCReader::instance" << endl);
491 pthread_once(&instance_control, initialize_instance);
493 DBG(cerr <<
"Instance value: " << hex << _instance << dec << endl);
string long_to_string(long val, int base)