diff options
| -rw-r--r-- | src/turris-lcd.cpp | 125 |
1 files changed, 123 insertions, 2 deletions
diff --git a/src/turris-lcd.cpp b/src/turris-lcd.cpp index 034fc94..a3a8de8 100644 --- a/src/turris-lcd.cpp +++ b/src/turris-lcd.cpp @@ -1,17 +1,138 @@ #include <iostream> +#include <cstring> +#include <cstdio> +#include <cstdlib> +#include <string> #include <LiquidCrystal_I2C.h> +#include <unistd.h> +#include <vector> +#include <sys/types.h> +#include <sys/stat.h> +#include <fcntl.h> +#include <cerrno> +#include <queue> +#include <sstream> + using namespace std; +const char omnia_str[] = "Turris Omnia feed:"; + +const int deftimeout = 2; +const char *pipe_path = "/tmp/turris-lcd"; + +void matrix_set(string str, int offset, int line, char (&matrix)[4][20]) { + for (int i = 0; i < 20; i++) { + if (str.length() > offset) { + matrix[line][i] = str[offset]; + offset++; + } else + matrix[line][i] = ' '; + } +} + +void read_pipe(vector<string> &messages, queue<int> &newone, int pipe) { + string msg = ""; + char c; + int ec; + while ((ec = read(pipe, &c, 1)) > 0) { + if (c == '\n') { + newone.push(messages.size()); + messages.push_back(msg); + cout << "Input: " << msg << "\n"; + } else + msg += c; + } + if (ec < 0 && errno != EAGAIN) { + cout << "Input broken! " << strerror(errno) << "\n"; + exit(1); + } +} + int main(int argc, char *argv[]) { + /* + if (argc < 1) { + cout << "Please pass i2c device as first argument\n"; + exit(1); + }*/ // Initialize LCD LiquidCrystal_I2C lcd("/dev/i2c-7", 0x27, 2, 1, 0, 4, 5, 6, 7, 3, POSITIVE); lcd.begin(20, 4); + char matrix[4][20]; + lcd.on(); lcd.clear(); + // Autoscroll doesn't work as expected for some reason, probably cheap display + + mkfifo(pipe_path, NULL); + errno = 0; // ignore if file exists + int pipe = open(pipe_path, O_RDONLY | O_NONBLOCK); + + vector<string> messages; + queue<int> newone; + messages.push_back(""); + messages.push_back(""); + messages.push_back(""); + + int msgs[3] = {0, 1, 2}; + int offsets[3] = {0, 0, 0}; + int timeout[3] = {deftimeout, deftimeout, deftimeout}; + int number_timeout = 0; + + while (true) { + // Read new lones from pipe + read_pipe(messages, newone, pipe); + + if (number_timeout > 3) { + ostringstream ss; + ss << "In total #"; + ss << (messages.size() - 3); + matrix_set(ss.str(), 0, 0, matrix); + } else + matrix_set(omnia_str, 0, 0, matrix); + number_timeout++; + if (number_timeout > 6) + number_timeout = 0; + + // Update matrix + for (int i = 0; i < 3; i++) { + matrix_set(messages[msgs[i]], offsets[i], i + 1, matrix); + // Update offsets + if (messages[msgs[i]].length() - offsets[i] > 20) + offsets[i]++; + else if (timeout[i] > 0) + timeout[i]--; + else { + offsets[i] = 0; + timeout[i] = deftimeout; + if (newone.empty()) { + int nw; + bool fine = false; + while (!fine) { + nw = rand() % messages.size(); + fine = true; + for (int s = 0; s < 3; s++) { + if (s != i && msgs[s] == nw) + fine = false; + } + } + msgs[i] = nw; + } else { + msgs[i] = newone.front(); + newone.pop(); + } + } + } - lcd.print("Turris Omnia"); + // Render matrix + for (int i = 0; i < 4; i++) { + lcd.setCursor(0, i); + for (int y = 0; y < 20; y++) { + lcd.write(matrix[i][y]); + } + } - return 0; + usleep(600000); + } } |