Add HTTPS support and fix Minor Planet Center URLs

From https://www.clearskyinstitute.com/xephem/contrib/contrib.html which
says it was contributed in January 2018.
This commit is contained in:
Lutz Mändle 2021-02-12 11:33:25 -05:00 committed by Brandon Rhodes
parent 10d7c79bca
commit 1abfa0c522
13 changed files with 319 additions and 53 deletions

View File

@ -11,6 +11,7 @@ RUN apt install -y -y \
build-essential \ build-essential \
groff-base \ groff-base \
libmotif-dev \ libmotif-dev \
libssl-dev \
libxext-dev \ libxext-dev \
libxmu-dev \ libxmu-dev \
libxp-dev \ libxp-dev \

View File

@ -11,6 +11,7 @@ RUN apt install -y -y \
build-essential \ build-essential \
groff-base \ groff-base \
libmotif-dev \ libmotif-dev \
libssl-dev \
libxext-dev \ libxext-dev \
libxmu-dev \ libxmu-dev \
libxt-dev libxt-dev

View File

@ -11,6 +11,7 @@ RUN apt install -y -y \
build-essential \ build-essential \
groff-base \ groff-base \
libmotif-dev \ libmotif-dev \
libssl-dev \
libxext-dev \ libxext-dev \
libxmu-dev \ libxmu-dev \
libxt-dev libxt-dev

View File

@ -34,7 +34,7 @@ CLDFLAGS = -g
CFLAGS = $(LIBINC) $(CLDFLAGS) -O2 -Wall -I$(MOTIFI) -I/opt/X11/include CFLAGS = $(LIBINC) $(CLDFLAGS) -O2 -Wall -I$(MOTIFI) -I/opt/X11/include
LDFLAGS = $(LIBLNK) $(CLDFLAGS) -L$(MOTIFL) -L/opt/X11/lib LDFLAGS = $(LIBLNK) $(CLDFLAGS) -L$(MOTIFL) -L/opt/X11/lib
XLIBS = -lXm -lXt -lXext -lXmu -lX11 XLIBS = -lXm -lXt -lXext -lXmu -lX11
LIBS = $(XLIBS) $(LIBLIB) -lm LIBS = $(XLIBS) $(LIBLIB) -lm -lssl
# static linking on Apple using X11 libs from ports # static linking on Apple using X11 libs from ports
# CC = gcc # CC = gcc

View File

@ -78,7 +78,7 @@ EOF
# setup cutoff mag # setup cutoff mag
my $dimmag = 13; # dimmest mag to be saved in "bright" file my $dimmag = 13; # dimmest mag to be saved in "bright" file
# set site and file in case of -f # set site and file in case of -f
my $MPCSITE = "http://www.minorplanetcenter.net"; my $MPCSITE = "https://www.minorplanetcenter.net";
my $MPCFTPDIR = "/iau/MPCORB"; my $MPCFTPDIR = "/iau/MPCORB";
my $MPCFILE = "MPCORB.DAT"; my $MPCFILE = "MPCORB.DAT";
my $MPCZIPFILE = "MPCORB.DAT.gz"; my $MPCZIPFILE = "MPCORB.DAT.gz";

View File

@ -747,10 +747,10 @@ String fallbacks[] = {
"XEphem*WebDB*URL1.value: http://celestrak.com/NORAD/elements/science.txt", "XEphem*WebDB*URL1.value: http://celestrak.com/NORAD/elements/science.txt",
"XEphem*WebDB*URL2.value: http://celestrak.com/NORAD/elements/tle-new.txt", "XEphem*WebDB*URL2.value: http://celestrak.com/NORAD/elements/tle-new.txt",
"XEphem*WebDB*URL3.value: http://celestrak.com/NORAD/elements/amateur.txt", "XEphem*WebDB*URL3.value: http://celestrak.com/NORAD/elements/amateur.txt",
"XEphem*WebDB*URL4.value: http://www.minorplanetcenter.org/iau/Ephemerides/Comets/Soft03Cmt.txt", "XEphem*WebDB*URL4.value: https://www.minorplanetcenter.org/iau/Ephemerides/Comets/Soft03Cmt.txt",
"XEphem*WebDB*URL5.value: http://www.minorplanetcenter.org/iau/Ephemerides/CritList/Soft03CritList.txt", "XEphem*WebDB*URL5.value: https://www.minorplanetcenter.org/iau/Ephemerides/CritList/Soft03CritList.txt",
"XEphem*WebDB*URL6.value: http://www.minorplanetcenter.org/iau/Ephemerides/Distant/Soft03Distant.txt", "XEphem*WebDB*URL6.value: https://www.minorplanetcenter.org/iau/Ephemerides/Distant/Soft03Distant.txt",
"XEphem*WebDB*URL7.value: http://www.minorplanetcenter.org/iau/Ephemerides/Unusual/Soft03Unusual.txt", "XEphem*WebDB*URL7.value: https://www.minorplanetcenter.org/iau/Ephemerides/Unusual/Soft03Unusual.txt",
"XEphem*WebDB.x: 200", "XEphem*WebDB.x: 200",
"XEphem*WebDB.y: 200", "XEphem*WebDB.y: 200",
"XEphem*WeekStart.Monday.set: False", "XEphem*WeekStart.Monday.set: False",

View File

@ -20,6 +20,13 @@
#include <sys/select.h> #include <sys/select.h>
#endif #endif
#include <openssl/ssl.h>
typedef struct {
int fd; //file desciptor for the underlying connection socket
SSL *ssl; //ssl connection for use with SSL_read( )and SSL_write()
} XE_SSL_FD;
/* support functions */ /* support functions */
extern int httpGET (char *host, char *GETcmd, char msg[]); extern int httpGET (char *host, char *GETcmd, char msg[]);
@ -29,7 +36,10 @@ extern int readbytes (int fd, unsigned char buf[], int n);
extern int recvline (int fd, char buf[], int max); extern int recvline (int fd, char buf[], int max);
extern int recvlineb (int sock, char *buf, int size); extern int recvlineb (int sock, char *buf, int size);
extern int sendbytes (int fd, unsigned char buf[], int n); extern int sendbytes (int fd, unsigned char buf[], int n);
extern int httpsGET (char *host, char *GETcmd, char msg[], XE_SSL_FD *ssl_fd);
extern int ssl_recvbytes (XE_SSL_FD *ssl_fd, unsigned char buf[], int n);
extern int ssl_readbytes (XE_SSL_FD *ssl_fd, unsigned char buf[], int n);
extern int ssl_recvline (XE_SSL_FD *ssl_fd, char buf[], int max);
extern int ssl_recvlineb (XE_SSL_FD *ssl_fd, char *buf, int size);
#endif /* _NET_H */ #endif /* _NET_H */

View File

@ -9,6 +9,8 @@
#include <string.h> #include <string.h>
#include <unistd.h> #include <unistd.h>
#include <openssl/ssl.h>
#include <Xm/Form.h> #include <Xm/Form.h>
#include <Xm/Label.h> #include <Xm/Label.h>
#include <Xm/PushB.h> #include <Xm/PushB.h>
@ -70,12 +72,24 @@ static int rb_unk; /* index of first unknown char */
static char netcategory[] = "Network"; /* Save category */ static char netcategory[] = "Network"; /* Save category */
static SSL_METHOD *ssl_method; /* global ssl dispatch structure for creating a ssl context */
static SSL_CTX *ssl_ctx; /* global ssl context structure for creating ssl connections */
/* call to set up without actually bringing up the menus. /* call to set up without actually bringing up the menus.
*/ */
void void
net_create() net_create()
{ {
if (!netshell_w) { if (!netshell_w) {
if (SSL_library_init() < 0) {
fprintf (stderr, "Could not initialize the OpenSSL library !\n");
} else {
ssl_method = SSLv23_client_method(); /* deprecated since openssl 1.1.x */
// ssl_method = TLS_client_method(); /* since openssl 1.1.x */
ssl_ctx = SSL_CTX_new (ssl_method);
SSL_CTX_set_options (ssl_ctx, SSL_OP_NO_SSLv2);
};
net_create_form(); net_create_form();
(void) net_save(); /* confirming here is just annoying */ (void) net_save(); /* confirming here is just annoying */
} }
@ -251,8 +265,8 @@ char msg[]) /* return diagnostic message here, if returning -1 */
struct { struct {
unsigned char VN; /* version number */ unsigned char VN; /* version number */
unsigned char CD; /* command code */ unsigned char CD; /* command code */
unsigned short DSTPORT; /* destination port */ uint16_t DSTPORT; /* destination port */
unsigned long DSTIP; /* destination IP addres */ uint32_t DSTIP; /* destination IP address */
} SocksPacket; } SocksPacket;
struct hostent *hs = gethostbyname (socks_host); struct hostent *hs = gethostbyname (socks_host);
@ -390,7 +404,7 @@ readbytes (int fd, unsigned char buf[], int n)
/* read up to and including the next '\n' from socket fd into buf[max]. /* read up to and including the next '\n' from socket fd into buf[max].
* we silently ignore all '\r'. we add a trailing '\0'. * we silently ignore all '\r'. we add a trailing '\0'.
* return line lenth (not counting \0) if all ok, else -1. * return line length (not counting \0) if all ok, else -1.
* N.B. this never reads ahead -- if that's ok, recvlineb() is better * N.B. this never reads ahead -- if that's ok, recvlineb() is better
*/ */
int int
@ -466,6 +480,216 @@ recvlineb (int sock, char *buf, int size)
return (ok); return (ok);
} }
/* open the host, do the given GET cmd, and return a socket fd for the result.
* on success it fills the XE_SSL_FD structure for later use by SSL_read() and necessary cleanup.
* return -1 and with excuse in msg[], else 0 if ok.
* N.B. can be called before we are created if net set in app defaults.
*/
int
httpsGET (char *host, char *GETcmd, char msg[], XE_SSL_FD *ssl_fd)
{
char buf[2048];
int fd;
int connected;
SSL *ssl;
int n;
int ret;
int httpsport = 443;
/* open connection */
if (proxy_on) {
fd = mkconnection (proxy_host, proxy_port, msg);
if (fd < 0)
return (-1);
/* fill buf with CONNECT */
(void) sprintf (buf, "CONNECT %1$s:%2$d HTTP/1.0\r\nUser-Agent: xephem/%3$s\r\nHost: %1$s:%2$d\r\n\r\n", host, httpsport, PATCHLEVEL);
/* add proxy auth if enabled */
if (!auth_w)
net_create_form();
if (XmToggleButtonGetState (auth_w))
addAuth(buf);
/* log it */
xe_msg (0, "https proxy connect: %s", buf);
/* send it */
n = strlen (buf);
if (sendbytes(fd, (unsigned char *)buf, n) < 0) {
(void) sprintf (msg, "%s: send error: %s", proxy_host, syserrstr());
(void) close (fd);
return (-1);
}
connected = 0;
while (recvline (fd, buf, sizeof(buf)) > 1) {
xe_msg (0, "Rcv: %s", buf);
if (strstr (buf, "200 "))
connected = 1;
}
if (!connected) {
(void) sprintf (msg, "%s: connect error: %s", proxy_host, syserrstr());
(void) close (fd);
return (-1);
}
} else {
/* SOCKS or direct are both handled by mkconnection() */
fd = mkconnection (host, httpsport, msg);
if (fd < 0)
return (-1);
}
/* fill buf with GETcmd */
(void) sprintf (buf, "%s", GETcmd);
/* start ssl connection */
ssl = SSL_new (ssl_ctx);
SSL_set_fd (ssl, fd);
SSL_connect (ssl);
/* log it */
xe_msg (0, "https: %s", buf);
/* send it */
n = strlen (buf);
ret = SSL_write (ssl, (unsigned char *)buf, n);
if (ret <= 0) {
(void) sprintf (msg, "%s: ssl send error code: %d", host, SSL_get_error (ssl, ret));
(void) SSL_free (ssl);
(void) close (fd);
return (-1);
}
/* caller can read response */
ssl_fd->fd = fd;
ssl_fd->ssl = ssl;
return (fd);
}
/* receive exactly n bytes from ssl connection ssl_fd into buf.
* return -1, 0 or n.
* N.B. with fallback to ordinary read from socket if ssl_fd->ssl is NULL
*/
int
ssl_recvbytes (XE_SSL_FD *ssl_fd, unsigned char buf[], int n)
{
int ns, tot;
for (tot = 0; tot < n; tot += ns) {
if (tout (TOUT, ssl_fd->fd, 0) < 0)
return (-1);
if (ssl_fd->ssl)
ns = SSL_read (ssl_fd->ssl, (void *)(buf+tot), n-tot);
else
ns = read (ssl_fd->fd, (void *)(buf+tot), n-tot);
if (ns <= 0)
return (ns);
}
return (n);
}
/* like read(2) except we time out and allow user to cancel.
* receive up to n bytes from ssl connection ssl_fd into buf.
* return count, or 0 on eof or -1 on error.
* N.B. with fallback to ordinary read from socket if ssl_fd->ssl is NULL
*/
int
ssl_readbytes (XE_SSL_FD *ssl_fd, unsigned char buf[], int n)
{
int ns;
if (tout (TOUT, ssl_fd->fd, 0) < 0)
return (-1);
if (ssl_fd->ssl)
ns = SSL_read (ssl_fd->ssl, (void *)buf, n);
else
ns = read (ssl_fd->fd, (void *)buf, n);
return (ns);
}
/* read up to and including the next '\n' from ssl into buf[max].
* we silently ignore all '\r'. we add a trailing '\0'.
* return line length (not counting \0) if all ok, else -1.
* N.B. with fallback to ordinary read from socket if ssl_fd->ssl is NULL
*/
int
ssl_recvline (XE_SSL_FD *ssl_fd, char buf[], int max)
{
unsigned char c;
int n;
max--; /* leave room for trailing \0 */
for (n = 0; n < max && ssl_recvbytes (ssl_fd, &c, 1) == 1; ) {
if (c != '\r') {
buf[n++] = c;
if (c == '\n') {
buf[n] = '\0';
return (n);
}
}
}
return (-1);
}
/* rather like ssl_recvline but reads ahead in big chunk for efficiency.
* return length if read a line ok, 0 if hit eof, -1 if error.
* N.B. we silently swallow all '\r'.
* N.B. we read ahead and can hide bytes after each call.
* N.B. with fallback to ordinary read from socket if ssl_fd->ssl is NULL
*/
int
ssl_recvlineb (XE_SSL_FD *ssl_fd, char *buf, int size)
{
char *origbuf = buf; /* save to prevent overfilling buf */
char c = '\0';
int ok = 1;
/* always leave room for trailing \n */
size -= 1;
/* read and copy linebuf[next] to buf until buf fills or copied a \n */
do {
if (rb_next >= rb_unk) {
/* linebuf is empty -- refill */
int nr;
if (tout (TOUT, ssl_fd->fd, 0) < 0) {
nr = -1;
break;
}
if (ssl_fd->ssl)
nr = SSL_read (ssl_fd->ssl, rb_linebuf, sizeof(rb_linebuf));
else
nr = read (ssl_fd->fd, rb_linebuf, sizeof(rb_linebuf));
if (nr <= 0) {
ok = nr;
rb_next = 0;
rb_unk = 0;
break;
}
rb_next = 0;
rb_unk = nr;
}
if ((c = rb_linebuf[rb_next++]) != '\r')
*buf++ = c;
} while (buf-origbuf < size && c != '\n');
/* always give back a real line regardless, else status */
if (ok > 0) {
*buf = '\0';
ok = buf - origbuf;
}
return (ok);
}
static void static void
net_create_form() net_create_form()
{ {

View File

@ -884,9 +884,11 @@ readSOHOImage()
int isjpeg, jpegl; int isjpeg, jpegl;
int njpeg; int njpeg;
unsigned char *jpeg; unsigned char *jpeg;
XE_SSL_FD ssl_fd;
int fd, nr; int fd, nr;
struct tm tm; struct tm tm;
memset(&ssl_fd, 0, sizeof(ssl_fd));
memset(&tm, 0, sizeof(struct tm)); memset(&tm, 0, sizeof(struct tm));
/* get desired type and size */ /* get desired type and size */
@ -901,16 +903,16 @@ readSOHOImage()
sprintf (get, "GET http://%s%s HTTP/1.0\r\nUser-Agent: xephem/%s\r\n\r\n", sohohost, fn, PATCHLEVEL); sprintf (get, "GET http://%s%s HTTP/1.0\r\nUser-Agent: xephem/%s\r\n\r\n", sohohost, fn, PATCHLEVEL);
/* query server */ /* query server */
fd = httpGET (sohohost, get, buf); fd = httpsGET (sohohost, get, buf, &ssl_fd);
if (fd < 0) { if (fd < 0) {
xe_msg (1, "http get: %s", buf); xe_msg (1, "https get: %s", buf);
return (-1); return (-1);
} }
/* read header (everything to first blank line), looking for jpeg */ /* read header (everything to first blank line), looking for jpeg */
isjpeg = 0; isjpeg = 0;
jpegl = 0; jpegl = 0;
while (recvline (fd, buf, sizeof(buf)) > 1) { while (ssl_recvline (&ssl_fd, buf, sizeof(buf)) > 1) {
xe_msg (0, "Rcv: %s", buf); xe_msg (0, "Rcv: %s", buf);
if (strstr (buf, "Content-Type:") && strstr (buf, "image/jpeg")) if (strstr (buf, "Content-Type:") && strstr (buf, "image/jpeg"))
isjpeg = 1; isjpeg = 1;
@ -923,15 +925,17 @@ readSOHOImage()
} }
} }
if (!isjpeg) { if (!isjpeg) {
while (recvline (fd, buf, sizeof(buf)) > 0) while (ssl_recvline (&ssl_fd, buf, sizeof(buf)) > 0)
xe_msg (0, "Rcv: %s", buf); xe_msg (0, "Rcv: %s", buf);
xe_msg (1, "Error talking to SOHO .. see File->System log\n"); xe_msg (1, "Error talking to SOHO .. see File->System log\n");
close (fd); SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
return (-1); return (-1);
} }
if (jpegl == 0) { if (jpegl == 0) {
xe_msg (1, "No Content-Length in header"); xe_msg (1, "No Content-Length in header");
close (fd); SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
return (-1); return (-1);
} }
@ -941,20 +945,22 @@ readSOHOImage()
for (njpeg = 0; njpeg < jpegl; njpeg += nr) { for (njpeg = 0; njpeg < jpegl; njpeg += nr) {
pm_set (100*njpeg/jpegl); pm_set (100*njpeg/jpegl);
jpeg = (unsigned char *) XtRealloc ((char*)jpeg, njpeg+NSREAD); jpeg = (unsigned char *) XtRealloc ((char*)jpeg, njpeg+NSREAD);
nr = readbytes (fd, jpeg+njpeg, NSREAD); nr = SSL_read (ssl_fd.ssl, jpeg+njpeg, NSREAD);
if (nr < 0) { if (nr <= 0) {
xe_msg (1, "%s:\n%s", sohohost, syserrstr()); xe_msg (1, "%s: ssl read error code: %d", sohohost, SSL_get_error(ssl_fd.ssl, nr));
pm_down(); pm_down();
close (fd); SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
return (-1); return (-1);
} }
if (nr == 0) if (nr == 0)
break; break;
} }
pm_down(); pm_down();
close (fd); SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
sprintf (fn, "/%s_%s.jpg", filetime, filetype); sprintf (fn, "/%s_%s.jpg", filetime, filetype);
/* display jpeg */ /* display jpeg */
if (displayPic (fn, jpeg, njpeg) < 0) if (displayPic (fn, jpeg, njpeg) < 0)
return (-1); return (-1);

View File

@ -18,15 +18,15 @@
#define MAXFOV 15.0 /* max fov, degs */ #define MAXFOV 15.0 /* max fov, degs */
typedef unsigned char UC; /* byte */ typedef unsigned char XE_UC; /* byte */
typedef unsigned int UI; /* unsigned integer */ typedef unsigned int XE_UI; /* unsigned integer */
/* access an I*2 or I*4 at offset i in UC array a in little-endian byte order. /* access an I*2 or I*4 at offset i in UC array a in little-endian byte order.
* a bit slow but ultra portable. * a bit slow but ultra portable.
*/ */
#define I2(a,i) ((int)(short)((((UI)(a)[i]) | (((UI)(a)[i+1])<<8)))) #define I2(a,i) ((int)(short)((((XE_UI)(a)[i]) | (((XE_UI)(a)[i+1])<<8))))
#define I4(a,i) ((int)((((UI)(a)[i]) | (((UI)(a)[i+1])<<8) | \ #define I4(a,i) ((int)((((XE_UI)(a)[i]) | (((XE_UI)(a)[i+1])<<8) | \
(((UI)(a)[i+2])<<16) | (((UI)(a)[i+3])<<24)))) (((XE_UI)(a)[i+2])<<16) | (((XE_UI)(a)[i+3])<<24))))
/* keep track of an array of ObjF */ /* keep track of an array of ObjF */
typedef struct { typedef struct {
@ -48,9 +48,9 @@ typedef struct {
#define DPMAS (1.0/3600000.0) /* degrees per milliarcsecond */ #define DPMAS (1.0/3600000.0) /* degrees per milliarcsecond */
typedef UC U2Star[44]; /* UCAC2 record */ typedef XE_UC U2Star[44]; /* UCAC2 record */
typedef UC U3Star[84]; /* UCAC3 record */ typedef XE_UC U3Star[84]; /* UCAC3 record */
typedef UC U4Star[78]; /* UCAC4 record */ typedef XE_UC U4Star[78]; /* UCAC4 record */
static char *basedir; /* full dir with zone files and index */ static char *basedir; /* full dir with zone files and index */
static FILE *indexfp; /* index file handle */ static FILE *indexfp; /* index file handle */
@ -293,7 +293,7 @@ static int
read4Index (int rz, int dz, int *nskip, int *nnew) read4Index (int rz, int dz, int *nskip, int *nnew)
{ {
off_t offset; off_t offset;
UC i4[4]; XE_UC i4[4];
offset = (rz*NZH4 + dz)*sizeof(i4); offset = (rz*NZH4 + dz)*sizeof(i4);
if (fseek (indexfp, offset, SEEK_SET) < 0) { if (fseek (indexfp, offset, SEEK_SET) < 0) {
@ -508,7 +508,7 @@ static int
read3Index (int rz, int dz, int *nskip, int *nnew) read3Index (int rz, int dz, int *nskip, int *nnew)
{ {
off_t offset; off_t offset;
UC i4[4]; XE_UC i4[4];
offset = (rz*NZH + dz)*sizeof(i4); offset = (rz*NZH + dz)*sizeof(i4);
if (fseek (indexfp, offset, SEEK_SET) < 0) { if (fseek (indexfp, offset, SEEK_SET) < 0) {
@ -663,7 +663,7 @@ static int
get2N (int rz, int dz, int *idp) get2N (int rz, int dz, int *idp)
{ {
off_t offset; off_t offset;
UC nat[4]; XE_UC nat[4];
offset = (dz*NZW + rz)*sizeof(nat); offset = (dz*NZW + rz)*sizeof(nat);
if (fseek (indexfp, offset, SEEK_SET) < 0) if (fseek (indexfp, offset, SEEK_SET) < 0)

View File

@ -14,8 +14,8 @@
#define CATBPR 12 /* bytes per star record in .cat file */ #define CATBPR 12 /* bytes per star record in .cat file */
#define ACCBPR 30 /* bytes per record in .acc file */ #define ACCBPR 30 /* bytes per record in .acc file */
typedef unsigned int UI; typedef unsigned int XE_UI;
typedef unsigned char UC; typedef unsigned char XE_UC;
/* One Field star */ /* One Field star */
typedef struct { typedef struct {
@ -36,7 +36,7 @@ static int corner (double r0, double d0, double rov, int *nr, double fr[2],
double lr[2], int *nd, double fd[2], double ld[2], int zone[2], char msg[]); double lr[2], int *nd, double fd[2], double ld[2], int zone[2], char msg[]);
static int fetchSwath (int zone, double maxmag, double fr, double lr, static int fetchSwath (int zone, double maxmag, double fr, double lr,
double fd, double ld, StarArray *sap, char msg[]); double fd, double ld, StarArray *sap, char msg[]);
static int crackCatBuf (UC buf[CATBPR], FieldStar *fsp); static int crackCatBuf (XE_UC buf[CATBPR], FieldStar *fsp);
static int addGS (StarArray *sap, FieldStar *fsp); static int addGS (StarArray *sap, FieldStar *fsp);
static char *cdpath; /* where CD rom is mounted */ static char *cdpath; /* where CD rom is mounted */
@ -236,7 +236,7 @@ double ld, StarArray *sap, char msg[])
{ {
char fn[1024]; char fn[1024];
char buf[ACCBPR]; char buf[ACCBPR];
UC catbuf[CATBPR]; XE_UC catbuf[CATBPR];
FieldStar fs; FieldStar fs;
long frec; long frec;
long os; long os;
@ -314,13 +314,13 @@ double ld, StarArray *sap, char msg[])
* return 0 if ok, else -1. * return 0 if ok, else -1.
*/ */
static int static int
crackCatBuf (UC buf[CATBPR], FieldStar *fsp) crackCatBuf (XE_UC buf[CATBPR], FieldStar *fsp)
{ {
#define BEUPACK(b) (((UI)((b)[0])<<24) | ((UI)((b)[1])<<16) | ((UI)((b)[2])<<8)\ #define BEUPACK(b) (((XE_UI)((b)[0])<<24) | ((XE_UI)((b)[1])<<16) | ((XE_UI)((b)[2])<<8)\
| ((UI)((b)[3]))) | ((XE_UI)((b)[3])))
double ra, dec; double ra, dec;
int red, blu; int red, blu;
UI mag; XE_UI mag;
/* first 4 bytes are packed RA, big-endian */ /* first 4 bytes are packed RA, big-endian */
ra = BEUPACK(buf)/(100.0*3600.0*15.0); ra = BEUPACK(buf)/(100.0*3600.0*15.0);

View File

@ -404,6 +404,10 @@ getURL (url)
char *url; char *url;
{ {
static char http[] = "http://"; static char http[] = "http://";
static char https[] = "https://";
char *transport = http;
int ltransport = strlen (transport);
int ishttp = 0;
char buf[512], msg[1024]; char buf[512], msg[1024];
char l0[512], l1[512], l2[512]; char l0[512], l1[512], l2[512];
char *l0p = l0, *l1p = l1, *l2p = l2; char *l0p = l0, *l1p = l1, *l2p = l2;
@ -411,21 +415,31 @@ char *url;
char *slash, *dot; char *slash, *dot;
char filename[256]; char filename[256];
FILE *fp; FILE *fp;
XE_SSL_FD ssl_fd;
int sockfd; int sockfd;
int nfound; int nfound;
memset(&ssl_fd, 0, sizeof(ssl_fd));
/* start */ /* start */
watch_cursor(1); watch_cursor(1);
l0[0] = l1[0] = l2[0] = '\0'; l0[0] = l1[0] = l2[0] = '\0';
/* find transport and host */ /* find transport and host */
if (strncmp (url, http, 7)) { if (!strncmp (url, transport, ltransport)) {
xe_msg (1, "URL must begin with %s", http); ishttp = 1;
} else {
transport = https;
ltransport = strlen (transport);
}
if ((!ishttp) && (strncmp (url, transport, ltransport))) {
xe_msg (1, "URL must begin with %s or %s", http, https);
watch_cursor (0); watch_cursor (0);
return; return;
} }
slash = strchr (url+7, '/'); slash = strchr (url+ltransport, '/');
dot = strrchr (url, '.'); dot = strrchr (url, '.');
if (!slash || !dot) { if (!slash || !dot) {
xe_msg (1, "Badly formed URL"); xe_msg (1, "Badly formed URL");
@ -434,11 +448,16 @@ char *url;
} }
/* connect to check url */ /* connect to check url */
sprintf (host, "%.*s", (int)(slash-url-7), url+7); sprintf (host, "%.*s", (int)(slash-url-ltransport), url+ltransport);
sprintf (buf, "GET %s HTTP/1.1\r\nHost: %s\r\nConnection: close\r\nUser-Agent: xephem/%s\r\n\r\n", sprintf (buf, "GET %s HTTP/1.1\r\nHost: %s\r\nConnection: close\r\nUser-Agent: xephem/%s\r\n\r\n",
url, host, PATCHLEVEL); url, host, PATCHLEVEL);
stopd_up(); stopd_up();
sockfd = httpGET (host, buf, msg); if (ishttp) {
sockfd = httpGET (host, buf, msg);
ssl_fd.fd = sockfd;
} else {
sockfd = httpsGET (host, buf, msg, &ssl_fd);
}
if (sockfd < 0) { if (sockfd < 0) {
xe_msg (1, "http GET to %s failed: %s%s\n", host, buf, msg); xe_msg (1, "http GET to %s failed: %s%s\n", host, buf, msg);
stopd_down(); stopd_down();
@ -447,20 +466,22 @@ char *url;
} }
/* create local file */ /* create local file */
slash = strrchr (url+7, '/'); slash = strrchr (url+ltransport, '/');
sprintf (filename, "%s/%.*sedb", getPrivateDir(), (int)(dot-slash), slash+1); sprintf (filename, "%s/%.*sedb", getPrivateDir(), (int)(dot-slash), slash+1);
fp = fopen (filename, "w"); fp = fopen (filename, "w");
if (!fp) { if (!fp) {
xe_msg (1, "%s:\n%s", filename, syserrstr()); xe_msg (1, "%s:\n%s", filename, syserrstr());
watch_cursor (0); watch_cursor (0);
close (sockfd); if (!ishttp)
SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
return; return;
} }
/* copy to file, insuring only .edb lines. /* copy to file, insuring only .edb lines.
*/ */
nfound = 0; nfound = 0;
while (recvlineb (sockfd, l2p, sizeof(l2)) > 0) { while (ssl_recvlineb (&ssl_fd, l2p, sizeof(l2)) > 0) {
char *lrot; char *lrot;
Obj o; Obj o;
@ -484,7 +505,9 @@ char *url;
/* tidy up and done */ /* tidy up and done */
fclose (fp); fclose (fp);
close (sockfd); if (!ishttp)
SSL_free (ssl_fd.ssl);
close (ssl_fd.fd);
if (!nfound) { if (!nfound) {
xe_msg (1, "No objects in file"); xe_msg (1, "No objects in file");
remove (filename); remove (filename);

View File

@ -12,12 +12,12 @@
#include <stdarg.h> /* be kind to those who don't use xe_msg() */ #include <stdarg.h> /* be kind to those who don't use xe_msg() */
#include "net.h" /* has to be included before astro.h because of openssl */
#include "astro.h" #include "astro.h"
#include "ip.h" #include "ip.h"
/* local glue files */ /* local glue files */
#include "map.h" #include "map.h"
#include "net.h"
#include "patchlevel.h" #include "patchlevel.h"
#include "preferences.h" #include "preferences.h"
#include "db.h" #include "db.h"