]> rtime.felk.cvut.cz Git - coffee/mt-apps.git/blobdiff - mt_rfid.c
mt_server: Use "%s" format string in syslog()
[coffee/mt-apps.git] / mt_rfid.c
index 6b2b42540b397d155d363d7124f64cbf340c5736..76a94c52d8f162431fd29238dbd6e90ec52d185d 100644 (file)
--- a/mt_rfid.c
+++ b/mt_rfid.c
-/*
- ============================================================================
- Name        : main.c
- Author      : Digital Logic
- Version     : 1.0
- Copyright   :
- Description : Very simple test of uFR library
- ============================================================================
- */
-
 #include <stdio.h>
 #include <stdlib.h>
 #include <unistd.h>
-#include <pthread.h>
-#include <signal.h>
+#include <fcntl.h>
+#include <termios.h>
+#include <sys/ioctl.h>
 
-#include "uFCoder.h"
+#include <uFCoder.h>
 
-#define READER_TYPE    1              //uFR type (1Mbps)
-#ifndef PORT_NAME
-#define PORT_NAME      "/dev/ttyUSB0" //"" for auto
-#endif
-#define PORT_INTERFACE 1              //Serial
+#include "mt_rfid.h"
+#include "signal_exit.h"
+#include "json_helpers.h"
 
-#define JSON_NUM(NAME) printf("\"" #NAME "\": %d", NAME)
-#define JSON_STR(NAME) printf("\"" #NAME "\": \"%s\"", NAME)
-#define JSON_START() printf("{\n")
-#define JSON_NEXT() printf(",\n")
-#define JSON_END() printf("\n}\n")
+// shit to avoid constant repetition
+#define CONCAT_AGAIN(A,B) A ## B
+#define CONCAT(A,B) CONCAT_AGAIN(A,B)
 
-static int run = 1;
+static int set_nonblock(int fd)
+{
+    int flags = fcntl(fd, F_GETFL, 0);
+    if (flags == -1) {
+        perror("fcntl (get)");
+        return -1;
+    }
+    if (fcntl(fd, F_SETFL, flags | O_NONBLOCK) == -1) {
+        perror("fcntl (set)");
+        return -1;
+    }
+    fprintf(stderr, "set %d non-blocking\n", fd);
+    return 0;
+}
 
-static void signal_exit(int sig)
+static int set_rts(int fd, int level)
 {
-    run = 0;
-    fprintf(stderr, "signal %d, terminating\n", sig);
+    int uart_status;
+
+    if (ioctl(fd, TIOCMGET, &uart_status) == -1) {
+        perror("ioctl (TIOCMGET)");
+        return -1;
+    }
+
+    if (level) {
+        uart_status |= TIOCM_RTS;
+    } else {
+        uart_status &= ~TIOCM_RTS;
+    }
+
+    if (ioctl(fd, TIOCMSET, &uart_status) == -1) {
+        perror("TIOCMSET");
+        return -1;
+    }
+
+    fprintf(stderr, "set %d rts %d\n", fd, level);
+
+    return 0;
 }
 
-static void *read_cards(void *ptr)
+static void set_baud_rate(int fd, int br) //TODO add some checking
 {
-    UFR_STATUS status;
+    struct termios options;
+
+    tcgetattr(fd, &options);
+    cfsetispeed(&options, br);
+    cfsetospeed(&options, br);
+    tcsetattr(fd, TCSANOW, &options);
+}
+
+static int tty_open(const char *port, int br)
+{
+
+    int fd = open(port, O_RDONLY | O_NOCTTY);
+    if (fd < 0) {
+        perror("open");
+        return fd;
+    } else {
+        fprintf(stderr, "opened %s as %d\n", port, fd);
+    }
+
+    set_nonblock(fd);
+    set_rts(fd, 0);        //disable
+    set_baud_rate(fd, br);
+    usleep(1200000);       //value by d-logic
+    tcflush(fd, TCIFLUSH);
 
+    return fd;
+}
+
+static void ufr_read(char *uid, int fd)
+{
+    UFR_STATUS status;
     uint8_t card_type;
-    uint8_t sak;
-    uint8_t uid_num[10];
-    uint8_t uid_size;
-    char uid[24];
+    uint8_t sak;           //select acknowledge
+    uint8_t uid_bytes[10]; //uid as bytes
+    uint8_t size;
+
+    status = GetDlogicCardType(&card_type);
+    if (status != UFR_OK) {
+        fprintf(stderr, "GetDlogicCardType: %s\n", UFR_Status2String(status));
+        return;
+    }
+
+    status = GetCardIdEx(&sak, uid_bytes, &size);
+    if (status != UFR_OK) {
+        fprintf(stderr, "GetCardIdEx: %s\n", UFR_Status2String(status));
+        return;
+    }
+
+    rfid_json_print(fd, card_type, sak, uid, size);
+
+#ifdef UFR_BEEP
+    ReaderUISignal(0, 1); // no light, one beep
+#endif
+}
 
-    fprintf(stderr, "uFCoder library version: %s\n", GetDllVersionStr());
+#define UFR_ASYNC_SUFFIX 0 // keep it zero: separates uids, terminates strings
 
-    status = ReaderOpenEx(READER_TYPE, PORT_NAME, PORT_INTERFACE, 0);
+static void ufr_cb(EV_P_ ev_io *w_, int revents)
+{
+    ev_io_ufr *w = (ev_io_ufr *)w_;
+    char uid;
+
+    read(w->w.fd, &uid, 1);
+    *(w->uid++) = uid;
+
+    if (uid == UFR_ASYNC_SUFFIX) {
+        //*(w->uid - 1) = 0; // no need if UFR_ASYNC_SUFFIX is 0
+        w->uid = w->uid_data;
+        ufr_read(w->uid, w->fd);
+    }
+}
+
+static int ufr_open(unsigned reader_type, char *port_name,
+                    unsigned port_interface)
+{
+    UFR_STATUS status;
+
+    fprintf(stderr, "uFCoder version: %s\n", GetDllVersionStr());
+
+    status = ReaderOpenEx(reader_type, port_name, port_interface, 0);
     if (status != UFR_OK) {
         fprintf(stderr, "ReaderOpenEx: %s\n", UFR_Status2String(status));
-        return NULL;
+        return -1;
     }
 
-    //status = ReaderUISignal(0, 0);
-    //printf("ReaderUISignal: %s\n", UFR_Status2String(status));
-
-    fputs(GetReaderDescription(), stderr);
-
-    while (run) {
-        status = GetDlogicCardType(&card_type);
-        if (status != UFR_OK) {
-            if (status != UFR_NO_CARD) {
-                fprintf(stderr, "GetDlogicCardType: %s\n", UFR_Status2String(status));
-            }
-            usleep(10000);
-            continue;
-        }
-
-        status = GetCardIdEx(&sak, uid_num, &uid_size);
-        if (status != UFR_OK) {
-            if (status != UFR_NO_CARD) {
-                fprintf(stderr, "GetCardIdEx: %s\n", UFR_Status2String(status));
-            }
-            usleep(10000);
-            continue;
-        }
-
-        for (uint8_t i = 0; i < uid_size; i++) {
-            sprintf(&uid[2*i], "%02x", uid_num[i]);
-        }
-
-        JSON_START();
-        JSON_NUM(card_type); JSON_NEXT();
-        JSON_NUM(sak);       JSON_NEXT();
-        JSON_NUM(uid_size);  JSON_NEXT();
-        JSON_STR(uid);       JSON_END();
-
-        usleep(500000);
+    fprintf(stderr, "%s\n", GetReaderDescription());
+
+    status = SetAsyncCardIdSendConfig(
+                 1,                  //enable send
+                 0,                  //disable prefix
+                 0,                  //prefix
+                 UFR_ASYNC_SUFFIX,   //suffix
+                 0,                  //disable send removed
+                 UFR_ASYNC_BAUD_RATE
+             );
+    fprintf(stderr, "SetAsyncCardIdSendConfig: %s\n", UFR_Status2String(status));
+    if (status != UFR_OK) {
+        return -1;
     }
 
-    status = ReaderClose();
-    fprintf(stderr, "ReaderClose: %s\n", UFR_Status2String(status));
+    return 0;
+}
+
+int mt_rfid_init(mt_rfid_t *self, struct ev_loop *loop, int fd)
+{
+    if (ufr_open(UFR_READER_TYPE, UFR_PORT_NAME, UFR_PORT_INTERFACE) == -1) {
+        return -1;
+    }
+
+    int tty = tty_open(UFR_PORT_NAME, CONCAT(B, UFR_ASYNC_BAUD_RATE));
+    if (tty < 0) {
+        return -2;
+    }
+    self->fd = tty;
+
+    ev_io_ufr *w = &(self->w);
+    w->uid = w->uid_data;
+    w->fd = fd;
+    ev_io_init(&(w->w), ufr_cb, tty, EV_READ);
+    ev_io_start(loop, (ev_io *)w);
 
-    return NULL;
+    return 0;
 }
 
-int main(void)
+void mt_rfid_deinit(mt_rfid_t *self)
 {
-    pthread_t t;
+    if (close(self->fd) == 0) {
+        fprintf(stderr, "closed %d\n", self->fd);
+    } else {
+        perror("close");
+    }
 
-    signal(SIGINT, signal_exit);
-    signal(SIGTERM, signal_exit);
+    UFR_STATUS status = ReaderClose();
+    fprintf(stderr, "ReaderClose: %s\n", UFR_Status2String(status));
+}
 
-    if (pthread_create(&t, NULL, read_cards, NULL)) {
-        perror("pthread_create");
+#ifndef NO_MAIN
+int main(int argc, char **argv)
+{
+    struct ev_loop *loop = EV_DEFAULT;
+    mt_rfid_t rfid;
+
+    set_signal_exit(loop);
+
+    if (mt_rfid_init(&rfid, loop, STDOUT_FILENO) != 0) {
         return -1;
     }
 
-    pthread_join(t, NULL);
+    ev_run(loop, 0);
+
+    mt_rfid_deinit(&rfid);
+    ev_loop_destroy(loop);
 
     return 0;
 }
+#endif