acarsdec

main.c (7142B)

---

 /*
  *  Copyright (c) 2007 by Thierry Leconte (F4DWV)
  *            (c) 2010-12 by Christoph Lohmann <20h@r-36.net>
  *
  *      $Id: main.c,v 1.5 2007/04/22 16:14:41 f4dwv Exp $
  *
  *   This code is free software; you can redistribute it and/or modify
  *   it under the terms of the GNU Library General Public License version 2
  *   published by the Free Software Foundation.
  *
  *   This program is distributed in the hope that it will be useful,
  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  *   GNU Library General Public License for more details.
  *
  *   You should have received a copy of the GNU Library General Public
  *   License along with this library; if not, write to the Free Software
  *   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  *
  */
 
 #include <stdio.h>
 #include <stdlib.h>
 #include <unistd.h>
 #include <string.h>
 #include <time.h>
 
 #include "version.h"
 #include "acarsdec.h"
 
 extern int optind, opterr;
 extern char *optarg;
 
 #define RED      "\033[0;31m"        /* 0 -> normal ;  31 -> red */
 #define CYAN     "\033[1;36m"        /* 1 -> bold ;  36 -> cyan */
 #define GREEN    "\033[1;32m"        /* 1 -> bold ;  32 -> green */
 #define YELLOW   "\033[0;33m"        /* 0 -> normal ;  33 -> yellow */
 #define BLUE     "\033[1;34m"        /* 1 -> bold ;  34 -> blue */
 
 #define BLACK    "\033[0;30m"
 #define BROWN    "\033[0;33m"
 #define MAGENTA  "\033[7;35m"        /* 7 -> inverted; 35 -> magenta */
 #define GRAY     "\033[0;37m"
 
 #define NONE     "\033[0m"           /* to flush the previous property */
 
 
 static void usage(void)
 {
 	fprintf(stderr, "%s\n", version);
 	fprintf(stderr, "Usage: acarsdec [-vep][-LR][-s noport] -d "
 			"alsapcmdevice | -f sndfile | -t\n");
 	fprintf(stderr, " -f sndfile :\t\tdecode from file sndfile "
 			"(ie: a .wav file)\n");
 	fprintf(stderr, " -d alsapcmdevice :\tdecode from soundcard "
 			"input alsapcmdevice (ie: hw:0,0)\n");
 	fprintf(stderr, " -t :\t\t\tread from stdin.\n");
 	fprintf(stderr, " [-v] :\t\t\tbe verbose.\n");
 	fprintf(stderr, " [-c] :\t\t\tcolorful output.\n");
 	fprintf(stderr, " [-p] :\t\t\toutput should be parseable protocol.\n");
 	fprintf(stderr, " [-e] :\t\t\tturn on debugging\n");
 	fprintf(stderr, " [-LR] :\t\tdisable left or right channel "
 			"decoding of stereo signal\n");
 	fprintf(stderr, " [-s noport ] :\t\tact as an APRS local server, "
 			"on port : noport\n");
 	fprintf(stderr, "Input could be mono or stereo but with 48Khz "
 			"sampling frequency.\nIf stereo, acarsdec will "
 			"demod the 2 channels independantly (if no L ou "
 			"R options specified)\n\n");
 	exit(1);
 }
 
 void print_mesg(msg_t *msg, int colored, int messgnumb)
 {
 	time_t t;
 	struct tm *tmp;
 	char pos[128];
 	int i;
 
 	for (i = 0; i < msg->txtlen; i++) {
 		if (msg->txt[i] < ' ' && msg->txt[i] != '\r'
 				&& msg->txt[i] != '\n') {
 			msg->txt[i] = ' ';
 		}
 	}
 
 	if (colored) {
 		printf("ACARS mode: %s%c%s", RED, msg->mode, NONE);
 		printf(" Aircraft reg: %s%s%s\n", GREEN,msg->addr,NONE);
 		printf("Message label: %s%s%s", CYAN, msg->label, NONE);
 		printf(" Block id: %s%d%s", RED, (int)msg->bid, NONE);
 		printf(" Msg. no: %s%s%s\n", BLUE, msg->no, NONE);
 		printf("Flight id: %s%s%s\n", MAGENTA, msg->fid, NONE);
 		printf("Message content:-\n%s%s%s", YELLOW, msg->txt, NONE);
 		if (posconv(msg->txt, msg->label, pos)==0) {
 			printf("\n%sAPRS : Addr:%s Fid:%s Lbl:%s pos:%s%s\n",
 				RED, msg->addr, msg->fid, msg->label, pos, NONE);
 		}
 	} else {
 		printf("ACARS mode: %c", msg->mode);
 		printf(" Aircraft reg: %s\n", msg->addr);
 		printf("Message label: %s", msg->label);
 		printf(" Block id: %d", (int) msg->bid);
 		printf(" Msg. no: %s\n", msg->no);
 		printf("Flight id: %s\n", msg->fid);
 		printf("Message content:-\n%s", msg->txt);
 		if (posconv(msg->txt, msg->label, pos)==0) {
 			printf("\nAPRS : Addr:%s Fid:%s Lbl:%s pos:%s\n",
 				msg->addr, msg->fid, msg->label, pos);
 		}
 	}
 
 	t = time(NULL);
 	tmp = gmtime(&t);
 	printf("\n[%5d]-------------------------------------"
 		"--------------[%02d/%02d/%04d %02d:%02d:%02d]\n\n",
 		messgnumb,
 	        tmp->tm_mday, tmp->tm_mon + 1, tmp->tm_year + 1900,
 	        tmp->tm_hour, tmp->tm_min, tmp->tm_sec);
 	fflush(stdout);
 }
 
 void print_proto(msg_t *msg)
 {
 	time_t t;
 	struct tm *tmp;
 	char pos[128];
 	char timestamp[128];
 
 	printf("MESG\n");
 	printf("MODE: %c\n", msg->mode);
 	printf("REG: %s\n", msg->addr);
 	printf("LABEL: %s\n", msg->label);
 	printf("BLKID: %d\n", (int) msg->bid);
 	printf("MSGNO: %s\n", msg->no);
 	printf("FLIGHTID: %s\n", msg->fid);
 	printf("CONTENTLENGTH: %d\n", msg->txtlen);
 	printf("CONTENT:\n");
 	fwrite(msg->txt, msg->txtlen, 1, stdout);
 	printf("\n.\n");
 
 	if (posconv(msg->txt, msg->label, pos) == 0) {
 		printf("APRS-ADDR: %s\n", msg->addr);
 		printf("APRS-FID: %s\n", msg->fid);
 		printf("APRS-LABEL: %s\n", msg->label);
 		printf("APRS-POS: %s\n", pos);
 	}
 	t = time(NULL);
 	tmp = gmtime(&t);
 	strftime(timestamp, sizeof(timestamp) - 1,
 		"%FT%T+00:00", tmp);
 	printf("TIMESTAMP: %s\n", timestamp);
 	printf("END MESG\n\n");
 	fflush(stdout);
 }
 
 void do_output(int type, msg_t *msg, int colored, int messgnumb)
 {
 
 	if(type & OUT_NET)
 		send_mesg(msg);
 	if(type & OUT_PRINT)
 		print_mesg(msg,colored,messgnumb);
 	if(type & OUT_PROTO)
 		print_proto(msg);
 }
 
 int main(int argc, char **argv)
 {
 	int c;
 	unsigned char r[2];
 	msg_t msg[2];
 	int nbit[2] = {0, 0};
 	int nrbit[2] = {8, 8};
 	int nbch = 0;
 	int esel[2] = {1, 1};
 	short port = 0;
 	int debug = 0;
 	int output = 0;
 	int i;
 	int colored = 0;
 	int messgnumb = 0;
 
 	while ((c = getopt(argc, argv, "cptevd:f:RLs:")) != EOF) {
 		switch (c) {
 		case 'd':
 			nbch = initsample(optarg, IN_ALSA);
 			break;
 		case 'f':
 			nbch = initsample(optarg, IN_FILE);
 			break;
 		case 't':
 			nbch = initsample("stdin", IN_STDIN);
 			break;
 		case 'L':
 			esel[0] = 0;
 			break;
 		case 'R':
 			esel[1] = 0;
 			break;
 		case 's':
 			port=atoi(optarg);
 			output |= OUT_NET;
 			break;
 		case 'v':
 			output |= OUT_PRINT;
 			break;
 		case 'p':
 			output |= OUT_PROTO;
 			break;
 		case 'e':
 			debug++;
 			break;
 		case 'c':
 			colored = 1;
 			break;
 		default:
 			usage();
 			exit(1);
 		}
 	}
 
 	if (output == 0)
 		output = OUT_PRINT;
 
 	if (nbch == 0) {
 		usage();
 		exit(1);
 	}
 
 	if (debug)
 		fprintf(stderr, "Output = %d; channels = %d\n", output, nbch);
 
 	if (port) {
 		if (init_serv(port))
 			exit(1);
 		if (debug)
 			fprintf(stderr, "Server initialized.\n");
 	}
 
 	/* main loop */
 	init_bits();
 	init_mesg();
 
 	if(debug)
 		fprintf(stderr, "Starting receive loop.\n");
 	do {
 		short sample[4096];
 		int ind, len;
 
 		len = getsample(sample, 4096);
 		if (len <= 0)
 			break;
 
 		for (ind = 0; ind < len;) {
 			for (i = 0; i < nbch; i++, ind++) {
 				if (esel[i]) {
 					nbit[i] += getbit(sample[ind], &r[i],
 							(i? 1 : 0));
 					if (nbit[i] >= nrbit[i]) {
 						nrbit[i] = getmesg(r[i],
 							       &msg[i], (i? 1 : 0));
 						nbit[i] = 0;
 						if (nrbit[i] == 0) {
 							do_output(output,
 								&msg[i], colored, ++messgnumb);
 							nrbit[i] = 8;
 						}
 					}
 				}
 			}
 		}
 	} while (1);
 
 
 	if(port)
 		end_serv();
 
 	endsample();
 
 	exit(0);
 }