#include <can_config.h>

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <libgen.h>
#include <getopt.h>
#include <limits.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/uio.h>
#include <sys/ioctl.h>
#include <net/if.h>

#include <linux/can.h>
#include <linux/can/raw.h>

extern int optind, opterr, optopt;

static int running = 1;

enum {
	VERSION_OPTION = CHAR_MAX + 1,
};

void print_usage(char *prg)
{
        fprintf(stderr, "Usage: %s <can-interface> [<can-interface-out>] [Options]\n"
		"\n"
		"Send all messages received on <can-interface> to <can-interface-out>\n"
		"If <can-interface-out> is omitted, then <can_interface> is used for sending\n"
		"\n"
		"Options:\n"
		" -f, --family=FAMILY   Protocol family (default PF_CAN = %d)\n"
		" -t, --type=TYPE       Socket type, see man 2 socket (default SOCK_RAW = %d)\n"
		" -p, --protocol=PROTO  CAN protocol (default CAN_RAW = %d)\n"
		" -v, --verbose         be verbose\n"
		" -h, --help            this help\n"
		"     --version         print version information and exit\n",
		prg, PF_CAN, SOCK_RAW, CAN_RAW);
}

void sigterm(int signo)
{
	running = 0;
}

int main(int argc, char **argv)
{
	struct can_frame frame;
	struct ifreq ifr[2];
	struct sockaddr_can addr[2];
	char *intf_name[2];
	int family = PF_CAN, type = SOCK_RAW, proto = CAN_RAW;
	int nbytes, i, out;
	int opt;
	int s[2];
	int verbose = 0;

	signal(SIGTERM, sigterm);
	signal(SIGHUP, sigterm);
	signal(SIGINT, sigterm);

	struct option long_options[] = {
		{ "help", no_argument, 0, 'h' },
		{ "family", required_argument, 0, 'f' },
		{ "protocol", required_argument, 0, 'p' },
		{ "type", required_argument, 0, 't' },
		{ "version", no_argument, 0, VERSION_OPTION},
		{ "verbose", no_argument, 0, 'v'},
		{ 0, 0, 0, 0},
	};

	while ((opt = getopt_long(argc, argv, "hf:t:p:v", long_options, NULL)) != -1) {
		switch (opt) {
		case 'f':
			family = atoi(optarg);
			break;

		case 't':
			type = atoi(optarg);
			break;

		case 'p':
			proto = atoi(optarg);
			break;

		case 'v':
			verbose = 1;
			break;

		case 'h':
			print_usage(basename(argv[0]));
			exit(0);

		case VERSION_OPTION:
			printf("canecho %s\n",VERSION);
			exit(0);

		default:
			fprintf(stderr, "Unknown option %c\n", opt);
			break;
		}
	}

	if (optind == argc) {
		print_usage(basename(argv[0]));
		exit(0);
	}

	intf_name[0] = argv[optind++];
	if (optind == argc)
		intf_name[1] = intf_name[0];
	else
		intf_name[1] = argv[optind];

	printf("interface-in = %s, interface-out = %s, family = %d, type = %d, proto = %d\n",
	       intf_name[0], intf_name[1], family, type, proto);

	if (intf_name[0] == intf_name[1])
		out = 0;
	else
		out = 1;

	for (i = 0; i <= out; i++) {
		if ((s[i] = socket(family, type, proto)) < 0) {
			perror("socket");
			return 1;
		}

		addr[i].can_family = family;
		strcpy(ifr[i].ifr_name, intf_name[i]);
		ioctl(s[i], SIOCGIFINDEX, &ifr[i]);
		addr[i].can_ifindex = ifr[i].ifr_ifindex;

		if (bind(s[i], (struct sockaddr *)&addr[i], sizeof(addr)) < 0) {
			perror("bind");
			return 1;
		}
	}

	while (running) {
		if ((nbytes = read(s[0], &frame, sizeof(frame))) < 0) {
			perror("read");
			return 1;
		}
		if (verbose) {
			printf("%04x: ", frame.can_id);
			if (frame.can_id & CAN_RTR_FLAG) {
				printf("remote request");
			} else {
				printf("[%d]", frame.can_dlc);
				for (i = 0; i < frame.can_dlc; i++) {
					printf(" %02x", frame.data[i]);
				}
			}
			printf("\n");
		}
		frame.can_id++;
		write(s[out], &frame, sizeof(frame));
	}

	return 0;
}