diff --git a/.gitignore b/.gitignore index 75b9d55114..2510f33b20 100644 --- a/.gitignore +++ b/.gitignore @@ -1,4 +1,5 @@ venv/ +.clang-format .DS_Store .tags .ipynb_checkpoints diff --git a/common/params_pyx.pyx b/common/params_pyx.pyx index b104011e28..0356de536b 100755 --- a/common/params_pyx.pyx +++ b/common/params_pyx.pyx @@ -31,9 +31,11 @@ keys = { b"GitCommit": [TxType.PERSISTENT], b"GitRemote": [TxType.PERSISTENT], b"GithubSshKeys": [TxType.PERSISTENT], + b"HardwareSerial": [TxType.PERSISTENT], b"HasAcceptedTerms": [TxType.PERSISTENT], b"HasCompletedSetup": [TxType.PERSISTENT], b"IsDriverViewEnabled": [TxType.CLEAR_ON_MANAGER_START], + b"IMEI": [TxType.PERSISTENT], b"IsLdwEnabled": [TxType.PERSISTENT], b"IsMetric": [TxType.PERSISTENT], b"IsOffroad": [TxType.CLEAR_ON_MANAGER_START], diff --git a/selfdrive/registration.py b/selfdrive/registration.py index e2e77d9f41..d74cc091a4 100644 --- a/selfdrive/registration.py +++ b/selfdrive/registration.py @@ -26,7 +26,10 @@ def register(spinner=None): params.put("GitRemote", get_git_remote(default="")) params.put("SubscriberInfo", HARDWARE.get_subscriber_info()) - needs_registration = False + IMEI = params.get("IMEI", encoding='utf8') + HardwareSerial = params.get("HardwareSerial", encoding='utf8') + + needs_registration = (None in [IMEI, HardwareSerial]) # create a key for auth # your private key is kept on your device persist partition and never sent to our servers @@ -65,11 +68,15 @@ def register(spinner=None): cloudlog.exception("Error getting imei, trying again...") time.sleep(1) + serial = HARDWARE.get_serial() + params.put("IMEI", imei1) + params.put("HardwareSerial", serial) + while True: try: cloudlog.info("getting pilotauth") resp = api_get("v2/pilotauth/", method='POST', timeout=15, - imei=imei1, imei2=imei2, serial=HARDWARE.get_serial(), public_key=public_key, register_token=register_token) + imei=imei1, imei2=imei2, serial=serial, public_key=public_key, register_token=register_token) dongleauth = json.loads(resp.text) dongle_id = dongleauth["dongle_id"] params.put("DongleId", dongle_id) diff --git a/selfdrive/ui/SConscript b/selfdrive/ui/SConscript index 656913b945..1c532837bb 100644 --- a/selfdrive/ui/SConscript +++ b/selfdrive/ui/SConscript @@ -5,7 +5,6 @@ Import('env', 'qt_env', 'arch', 'common', 'messaging', 'gpucommon', 'visionipc', src = ['ui.cc', 'paint.cc', 'sidebar.cc', '#phonelibs/nanovg/nanovg.c'] libs = [common, 'zmq', 'capnp', 'kj', 'm', 'OpenCL', cereal, messaging, gpucommon, visionipc] - if qt_env is None: libs += ['EGL', 'GLESv3', 'gnustl_shared', 'log', 'utils', 'gui', 'hardware', 'ui', 'CB', 'gsl', 'adreno_utils', 'OpenSLES', 'cutils', 'uuid', 'OpenCL'] @@ -20,16 +19,18 @@ else: widgets = qt_env.Library("qt_widgets", ["qt/qt_window.cc", "qt/qt_sound.cc", "qt/widgets/keyboard.cc", "qt/widgets/input_field.cc", "qt/widgets/drive_stats.cc", - "qt/offroad/wifi.cc", "qt/offroad/wifiManager.cc", "qt/widgets/toggle.cc", "qt/widgets/offroad_alerts.cc"], + "qt/offroad/wifi.cc", "qt/offroad/wifiManager.cc", "qt/widgets/toggle.cc", "qt/widgets/offroad_alerts.cc", "qt/widgets/setup.cc", "qt/widgets/QrCode.cc"], LIBS=qt_libs) qt_libs.append(widgets) + if arch == "Darwin": # fix OpenCL del qt_libs[qt_libs.index('OpenCL')] qt_env['FRAMEWORKS'] += ['OpenCL'] - qt_src = ["qt/ui.cc", "qt/window.cc", "qt/home.cc", "qt/offroad/settings.cc", "qt/offroad/onboarding.cc"] + src + qt_src = ["qt/ui.cc", "qt/window.cc", "qt/home.cc", "qt/api.cc", "qt/offroad/settings.cc", "qt/offroad/onboarding.cc"] + src + qt_env.Program("_ui", qt_src, LIBS=qt_libs) # spinner and text window diff --git a/selfdrive/ui/qt/api.cc b/selfdrive/ui/qt/api.cc new file mode 100644 index 0000000000..3d9653dd6d --- /dev/null +++ b/selfdrive/ui/qt/api.cc @@ -0,0 +1,127 @@ +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include "api.hpp" +#include "home.hpp" +#include "common/params.h" +#include "common/util.h" +#if defined(QCOM) || defined(QCOM2) +const std::string private_key_path = "/persist/comma/id_rsa"; +#else +const std::string private_key_path = util::getenv_default("HOME", "/.comma/persist/comma/id_rsa", "/persist/comma/id_rsa"); +#endif + +QByteArray CommaApi::rsa_sign(QByteArray data) { + auto file = QFile(private_key_path.c_str()); + if (!file.open(QIODevice::ReadOnly)) { + qDebug() << "No RSA private key found, please run manager.py or registration.py"; + return QByteArray(); + } + auto key = file.readAll(); + file.close(); + file.deleteLater(); + BIO* mem = BIO_new_mem_buf(key.data(), key.size()); + assert(mem); + RSA* rsa_private = PEM_read_bio_RSAPrivateKey(mem, NULL, NULL, NULL); + assert(rsa_private); + auto sig = QByteArray(); + sig.resize(RSA_size(rsa_private)); + unsigned int sig_len; + int ret = RSA_sign(NID_sha256, (unsigned char*)data.data(), data.size(), (unsigned char*)sig.data(), &sig_len, rsa_private); + assert(ret == 1); + assert(sig_len == sig.size()); + BIO_free(mem); + RSA_free(rsa_private); + return sig; +} + +QString CommaApi::create_jwt(QVector> payloads, int expiry) { + QJsonObject header; + header.insert("alg", "RS256"); + QJsonObject payload; + QString dongle_id = QString::fromStdString(Params().get("DongleId")); + payload.insert("identity", dongle_id); + auto t = QDateTime::currentSecsSinceEpoch(); + payload.insert("nbf", t); + payload.insert("iat", t); + payload.insert("exp", t + expiry); + for (auto load : payloads) { + payload.insert(load.first, load.second); + } + QString jwt = + QJsonDocument(header).toJson(QJsonDocument::Compact).toBase64(QByteArray::Base64UrlEncoding | QByteArray::OmitTrailingEquals) + + '.' + + QJsonDocument(payload).toJson(QJsonDocument::Compact).toBase64(QByteArray::Base64UrlEncoding | QByteArray::OmitTrailingEquals); + auto hash = QCryptographicHash::hash(jwt.toUtf8(), QCryptographicHash::Sha256); + auto sig = rsa_sign(hash); + jwt += '.' + sig.toBase64(QByteArray::Base64UrlEncoding | QByteArray::OmitTrailingEquals); + return jwt; +} + +QString CommaApi::create_jwt() { + return create_jwt(*(new QVector>())); +} + +RequestRepeater::RequestRepeater(QWidget* parent, QString requestURL, int period_seconds, QVector> payloads, bool disableWithScreen) + : disableWithScreen(disableWithScreen) { + networkAccessManager = new QNetworkAccessManager(parent); + QTimer* timer = new QTimer(this); + QObject::connect(timer, &QTimer::timeout, [=](){sendRequest(requestURL, payloads);}); + timer->start(period_seconds * 1000); + networkTimer = new QTimer(this); + networkTimer->setSingleShot(true); + networkTimer->setInterval(20000); // 20s before aborting + connect(networkTimer, SIGNAL(timeout()), this, SLOT(requestTimeout())); +} + +void RequestRepeater::sendRequest(QString requestURL, QVector> payloads){ + // No network calls onroad + if(GLWindow::ui_state.started){ + return; + } + if (!active || (!GLWindow::ui_state.awake && disableWithScreen)) { + return; + } + if(reply != NULL){ + return; + } + aborted = false; + callId = QRandomGenerator::global()->bounded(1000); + QString token = CommaApi::create_jwt(payloads); + QNetworkRequest request; + request.setUrl(QUrl(requestURL)); + request.setRawHeader("Authorization", ("JWT " + token).toUtf8()); + reply = networkAccessManager->get(request); + networkTimer->start(); + connect(reply, SIGNAL(finished()), this, SLOT(requestFinished())); +} + +void RequestRepeater::requestTimeout(){ + aborted = true; + reply->abort(); +} + +// This function should always emit something +void RequestRepeater::requestFinished(){ + if(!aborted){ + networkTimer->stop(); + QString response = reply->readAll(); + if (reply->error() == QNetworkReply::NoError) { + emit receivedResponse(response); + } else { + emit failedResponse(reply->errorString()); + } + }else{ + emit failedResponse("Custom Openpilot network timeout"); + } + reply->deleteLater(); + reply = NULL; +} diff --git a/selfdrive/ui/qt/api.hpp b/selfdrive/ui/qt/api.hpp new file mode 100644 index 0000000000..4244c36324 --- /dev/null +++ b/selfdrive/ui/qt/api.hpp @@ -0,0 +1,47 @@ +#pragma once + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +class CommaApi : public QObject { + Q_OBJECT +public: + static QByteArray rsa_sign(QByteArray data); + static QString create_jwt(QVector> payloads, int expiry = 60); + static QString create_jwt(); +private: + QNetworkAccessManager* networkAccessManager; +}; + +/** + * Makes repeated requests to the request endpoint. + */ +class RequestRepeater : public QObject { + Q_OBJECT +public: + explicit RequestRepeater(QWidget* parent, QString requestURL, int period = 10, QVector> payloads = *(new QVector>()), bool disableWithScreen = true); + bool active = true; +private: + bool disableWithScreen; + int callId; + QNetworkReply* reply; + QNetworkAccessManager* networkAccessManager; + QTimer* networkTimer; + std::atomic aborted = false; // Not 100% sure we need atomic + void sendRequest(QString requestURL, QVector> payloads); +private slots: + void requestTimeout(); + void requestFinished(); +signals: + void receivedResponse(QString response); + void failedResponse(QString errorString); +}; \ No newline at end of file diff --git a/selfdrive/ui/qt/home.cc b/selfdrive/ui/qt/home.cc index a58b63be67..aeaec7b443 100644 --- a/selfdrive/ui/qt/home.cc +++ b/selfdrive/ui/qt/home.cc @@ -1,15 +1,15 @@ #include -#include #include +#include #include -#include -#include -#include -#include -#include -#include #include +#include +#include +#include +#include +#include +#include #include "common/params.h" @@ -17,23 +17,23 @@ #include "paint.hpp" #include "qt_window.hpp" #include "widgets/drive_stats.hpp" +#include "widgets/setup.hpp" #define BACKLIGHT_DT 0.25 #define BACKLIGHT_TS 2.00 - -OffroadHome::OffroadHome(QWidget *parent) : QWidget(parent) { - QVBoxLayout *main_layout = new QVBoxLayout(); +OffroadHome::OffroadHome(QWidget* parent) : QWidget(parent) { + QVBoxLayout* main_layout = new QVBoxLayout(); main_layout->setContentsMargins(sbr_w + 50, 50, 50, 50); // top header - QHBoxLayout *header_layout = new QHBoxLayout(); + QHBoxLayout* header_layout = new QHBoxLayout(); date = new QLabel(); date->setStyleSheet(R"(font-size: 55px;)"); header_layout->addWidget(date, 0, Qt::AlignTop | Qt::AlignLeft); - QLabel *version = new QLabel(QString::fromStdString("openpilot v" + Params().get("Version"))); + QLabel* version = new QLabel(QString::fromStdString("openpilot v" + Params().get("Version"))); version->setStyleSheet(R"(font-size: 45px;)"); header_layout->addWidget(version, 0, Qt::AlignTop | Qt::AlignRight); @@ -47,9 +47,19 @@ OffroadHome::OffroadHome(QWidget *parent) : QWidget(parent) { main_layout->addSpacing(25); center_layout = new QStackedLayout(); - DriveStats *drive = new DriveStats; + QHBoxLayout* statsAndSetup = new QHBoxLayout(); + + DriveStats* drive = new DriveStats; drive->setFixedSize(1000, 800); - center_layout->addWidget(drive); + statsAndSetup->addWidget(drive); + + SetupWidget* setup = new SetupWidget; + statsAndSetup->addWidget(setup); + + QWidget* statsAndSetupWidget = new QWidget(); + statsAndSetupWidget->setLayout(statsAndSetup); + + center_layout->addWidget(statsAndSetupWidget); alerts_widget = new OffroadAlert(); QObject::connect(alerts_widget, SIGNAL(closeAlerts()), this, SLOT(closeAlerts())); @@ -113,14 +123,13 @@ void OffroadHome::refresh() { font-weight: bold; background-color: #E22C2C; )"); - if (alerts_widget->updateAvailable){ + if (alerts_widget->updateAvailable) { style.replace("#E22C2C", "#364DEF"); } alert_notification->setStyleSheet(style); } - -HomeWindow::HomeWindow(QWidget *parent) : QWidget(parent) { +HomeWindow::HomeWindow(QWidget* parent) : QWidget(parent) { layout = new QGridLayout; layout->setMargin(0); @@ -145,8 +154,8 @@ void HomeWindow::setVisibility(bool offroad) { home->setVisible(offroad); } -void HomeWindow::mousePressEvent(QMouseEvent *e) { - UIState *ui_state = glWindow->ui_state; +void HomeWindow::mousePressEvent(QMouseEvent* e) { + UIState* ui_state = &glWindow->ui_state; glWindow->wake(); @@ -161,14 +170,13 @@ void HomeWindow::mousePressEvent(QMouseEvent *e) { } } - -static void handle_display_state(UIState *s, int dt, bool user_input) { - static int awake_timeout = 0; - awake_timeout = std::max(awake_timeout-dt, 0); +static void handle_display_state(UIState* s, bool user_input) { + static int awake_timeout = 0; // Somehow this only gets called on program start + awake_timeout = std::max(awake_timeout - 1, 0); if (user_input || s->ignition || s->started) { s->awake = true; - awake_timeout = 30*UI_FREQ; + awake_timeout = 30 * UI_FREQ; } else if (awake_timeout == 0) { s->awake = false; } @@ -182,9 +190,9 @@ static void set_backlight(int brightness) { } } - -GLWindow::GLWindow(QWidget *parent) : QOpenGLWidget(parent) { +GLWindow::GLWindow(QWidget* parent) : QOpenGLWidget(parent) { timer = new QTimer(this); + timer->start(1000 / UI_FREQ); QObject::connect(timer, SIGNAL(timeout()), this, SLOT(timerUpdate())); backlight_timer = new QTimer(this); @@ -211,13 +219,11 @@ void GLWindow::initializeGL() { std::cout << "OpenGL renderer: " << glGetString(GL_RENDERER) << std::endl; std::cout << "OpenGL language version: " << glGetString(GL_SHADING_LANGUAGE_VERSION) << std::endl; - ui_state = new UIState(); - ui_state->sound = &sound; - ui_init(ui_state); + ui_state.sound = &sound; + ui_init(&ui_state); wake(); - timer->start(0); backlight_timer->start(BACKLIGHT_DT * 1000); } @@ -225,11 +231,11 @@ void GLWindow::backlightUpdate() { // Update brightness float k = (BACKLIGHT_DT / BACKLIGHT_TS) / (1.0f + BACKLIGHT_DT / BACKLIGHT_TS); - float clipped_brightness = std::min(1023.0f, (ui_state->light_sensor*brightness_m) + brightness_b); + float clipped_brightness = std::min(1023.0f, (ui_state.light_sensor * brightness_m) + brightness_b); smooth_brightness = clipped_brightness * k + smooth_brightness * (1.0f - k); int brightness = smooth_brightness; - if (!ui_state->awake) { + if (!ui_state.awake) { brightness = 0; } @@ -237,19 +243,14 @@ void GLWindow::backlightUpdate() { } void GLWindow::timerUpdate() { - if (ui_state->started != onroad) { - onroad = ui_state->started; + if (ui_state.started != onroad) { + onroad = ui_state.started; emit offroadTransition(!onroad); -#ifdef QCOM2 - timer->setInterval(onroad ? 0 : 1000); -#endif } - // Fix awake timeout if running 1 Hz when offroad - int dt = timer->interval() == 0 ? 1 : 20; - handle_display_state(ui_state, dt, false); + handle_display_state(&ui_state, false); - ui_update(ui_state); + ui_update(&ui_state); repaint(); } @@ -258,17 +259,16 @@ void GLWindow::resizeGL(int w, int h) { } void GLWindow::paintGL() { - ui_draw(ui_state); + if(GLWindow::ui_state.awake){ + ui_draw(&ui_state); + } + } void GLWindow::wake() { - // UI state might not be initialized yet - if (ui_state != nullptr) { - handle_display_state(ui_state, 1, true); - } + handle_display_state(&ui_state, true); } - FramebufferState* framebuffer_init(const char* name, int32_t layer, int alpha, int *out_w, int *out_h) { *out_w = vwp_w; diff --git a/selfdrive/ui/qt/home.hpp b/selfdrive/ui/qt/home.hpp index 5f71e0e4f6..bdf0ded979 100644 --- a/selfdrive/ui/qt/home.hpp +++ b/selfdrive/ui/qt/home.hpp @@ -1,19 +1,18 @@ #pragma once +#include #include +#include +#include +#include +#include +#include #include #include -#include -#include -#include -#include -#include -#include #include "qt_sound.hpp" -#include "widgets/offroad_alerts.hpp" #include "ui/ui.hpp" - +#include "widgets/offroad_alerts.hpp" // container window for onroad NVG UI class GLWindow : public QOpenGLWidget, protected QOpenGLFunctions { @@ -21,11 +20,11 @@ class GLWindow : public QOpenGLWidget, protected QOpenGLFunctions { public: using QOpenGLWidget::QOpenGLWidget; - explicit GLWindow(QWidget *parent = 0); + explicit GLWindow(QWidget* parent = 0); void wake(); ~GLWindow(); - UIState *ui_state = nullptr; + inline static UIState ui_state = {0}; signals: void offroadTransition(bool offroad); @@ -36,8 +35,8 @@ protected: void paintGL() override; private: - QTimer *timer; - QTimer *backlight_timer; + QTimer* timer; + QTimer* backlight_timer; QtSound sound; @@ -58,42 +57,40 @@ class OffroadHome : public QWidget { Q_OBJECT public: - explicit OffroadHome(QWidget *parent = 0); + explicit OffroadHome(QWidget* parent = 0); private: - QTimer *timer; + QTimer* timer; // offroad home screen widgets - QLabel *date; - QStackedLayout *center_layout; - OffroadAlert *alerts_widget; - QPushButton *alert_notification; + QLabel* date; + QStackedLayout* center_layout; + OffroadAlert* alerts_widget; + QPushButton* alert_notification; public slots: - void closeAlerts(); + void closeAlerts(); void openAlerts(); void refresh(); }; - class HomeWindow : public QWidget { Q_OBJECT public: - explicit HomeWindow(QWidget *parent = 0); - GLWindow *glWindow; + explicit HomeWindow(QWidget* parent = 0); + GLWindow* glWindow; signals: void openSettings(); protected: - void mousePressEvent(QMouseEvent *e) override; + void mousePressEvent(QMouseEvent* e) override; private: - QGridLayout *layout; - OffroadHome *home; + QGridLayout* layout; + OffroadHome* home; private slots: void setVisibility(bool offroad); }; - diff --git a/selfdrive/ui/qt/widgets/QrCode.cc b/selfdrive/ui/qt/widgets/QrCode.cc new file mode 100644 index 0000000000..b9de86215e --- /dev/null +++ b/selfdrive/ui/qt/widgets/QrCode.cc @@ -0,0 +1,862 @@ +/* + * QR Code generator library (C++) + * + * Copyright (c) Project Nayuki. (MIT License) + * https://www.nayuki.io/page/qr-code-generator-library + * + * Permission is hereby granted, free of charge, to any person obtaining a copy of + * this software and associated documentation files (the "Software"), to deal in + * the Software without restriction, including without limitation the rights to + * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of + * the Software, and to permit persons to whom the Software is furnished to do so, + * subject to the following conditions: + * - The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * - The Software is provided "as is", without warranty of any kind, express or + * implied, including but not limited to the warranties of merchantability, + * fitness for a particular purpose and noninfringement. In no event shall the + * authors or copyright holders be liable for any claim, damages or other + * liability, whether in an action of contract, tort or otherwise, arising from, + * out of or in connection with the Software or the use or other dealings in the + * Software. + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include "QrCode.hpp" + +using std::int8_t; +using std::uint8_t; +using std::size_t; +using std::vector; + + +namespace qrcodegen { + +QrSegment::Mode::Mode(int mode, int cc0, int cc1, int cc2) : + modeBits(mode) { + numBitsCharCount[0] = cc0; + numBitsCharCount[1] = cc1; + numBitsCharCount[2] = cc2; +} + + +int QrSegment::Mode::getModeBits() const { + return modeBits; +} + + +int QrSegment::Mode::numCharCountBits(int ver) const { + return numBitsCharCount[(ver + 7) / 17]; +} + + +const QrSegment::Mode QrSegment::Mode::NUMERIC (0x1, 10, 12, 14); +const QrSegment::Mode QrSegment::Mode::ALPHANUMERIC(0x2, 9, 11, 13); +const QrSegment::Mode QrSegment::Mode::BYTE (0x4, 8, 16, 16); +const QrSegment::Mode QrSegment::Mode::KANJI (0x8, 8, 10, 12); +const QrSegment::Mode QrSegment::Mode::ECI (0x7, 0, 0, 0); + + +QrSegment QrSegment::makeBytes(const vector &data) { + if (data.size() > static_cast(INT_MAX)) + throw std::length_error("Data too long"); + BitBuffer bb; + for (uint8_t b : data) + bb.appendBits(b, 8); + return QrSegment(Mode::BYTE, static_cast(data.size()), std::move(bb)); +} + + +QrSegment QrSegment::makeNumeric(const char *digits) { + BitBuffer bb; + int accumData = 0; + int accumCount = 0; + int charCount = 0; + for (; *digits != '\0'; digits++, charCount++) { + char c = *digits; + if (c < '0' || c > '9') + throw std::domain_error("String contains non-numeric characters"); + accumData = accumData * 10 + (c - '0'); + accumCount++; + if (accumCount == 3) { + bb.appendBits(static_cast(accumData), 10); + accumData = 0; + accumCount = 0; + } + } + if (accumCount > 0) // 1 or 2 digits remaining + bb.appendBits(static_cast(accumData), accumCount * 3 + 1); + return QrSegment(Mode::NUMERIC, charCount, std::move(bb)); +} + + +QrSegment QrSegment::makeAlphanumeric(const char *text) { + BitBuffer bb; + int accumData = 0; + int accumCount = 0; + int charCount = 0; + for (; *text != '\0'; text++, charCount++) { + const char *temp = std::strchr(ALPHANUMERIC_CHARSET, *text); + if (temp == nullptr) + throw std::domain_error("String contains unencodable characters in alphanumeric mode"); + accumData = accumData * 45 + static_cast(temp - ALPHANUMERIC_CHARSET); + accumCount++; + if (accumCount == 2) { + bb.appendBits(static_cast(accumData), 11); + accumData = 0; + accumCount = 0; + } + } + if (accumCount > 0) // 1 character remaining + bb.appendBits(static_cast(accumData), 6); + return QrSegment(Mode::ALPHANUMERIC, charCount, std::move(bb)); +} + + +vector QrSegment::makeSegments(const char *text) { + // Select the most efficient segment encoding automatically + vector result; + if (*text == '\0'); // Leave result empty + else if (isNumeric(text)) + result.push_back(makeNumeric(text)); + else if (isAlphanumeric(text)) + result.push_back(makeAlphanumeric(text)); + else { + vector bytes; + for (; *text != '\0'; text++) + bytes.push_back(static_cast(*text)); + result.push_back(makeBytes(bytes)); + } + return result; +} + + +QrSegment QrSegment::makeEci(long assignVal) { + BitBuffer bb; + if (assignVal < 0) + throw std::domain_error("ECI assignment value out of range"); + else if (assignVal < (1 << 7)) + bb.appendBits(static_cast(assignVal), 8); + else if (assignVal < (1 << 14)) { + bb.appendBits(2, 2); + bb.appendBits(static_cast(assignVal), 14); + } else if (assignVal < 1000000L) { + bb.appendBits(6, 3); + bb.appendBits(static_cast(assignVal), 21); + } else + throw std::domain_error("ECI assignment value out of range"); + return QrSegment(Mode::ECI, 0, std::move(bb)); +} + + +QrSegment::QrSegment(Mode md, int numCh, const std::vector &dt) : + mode(md), + numChars(numCh), + data(dt) { + if (numCh < 0) + throw std::domain_error("Invalid value"); +} + + +QrSegment::QrSegment(Mode md, int numCh, std::vector &&dt) : + mode(md), + numChars(numCh), + data(std::move(dt)) { + if (numCh < 0) + throw std::domain_error("Invalid value"); +} + + +int QrSegment::getTotalBits(const vector &segs, int version) { + int result = 0; + for (const QrSegment &seg : segs) { + int ccbits = seg.mode.numCharCountBits(version); + if (seg.numChars >= (1L << ccbits)) + return -1; // The segment's length doesn't fit the field's bit width + if (4 + ccbits > INT_MAX - result) + return -1; // The sum will overflow an int type + result += 4 + ccbits; + if (seg.data.size() > static_cast(INT_MAX - result)) + return -1; // The sum will overflow an int type + result += static_cast(seg.data.size()); + } + return result; +} + + +bool QrSegment::isAlphanumeric(const char *text) { + for (; *text != '\0'; text++) { + if (std::strchr(ALPHANUMERIC_CHARSET, *text) == nullptr) + return false; + } + return true; +} + + +bool QrSegment::isNumeric(const char *text) { + for (; *text != '\0'; text++) { + char c = *text; + if (c < '0' || c > '9') + return false; + } + return true; +} + + +QrSegment::Mode QrSegment::getMode() const { + return mode; +} + + +int QrSegment::getNumChars() const { + return numChars; +} + + +const std::vector &QrSegment::getData() const { + return data; +} + + +const char *QrSegment::ALPHANUMERIC_CHARSET = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ $%*+-./:"; + + + +int QrCode::getFormatBits(Ecc ecl) { + switch (ecl) { + case Ecc::LOW : return 1; + case Ecc::MEDIUM : return 0; + case Ecc::QUARTILE: return 3; + case Ecc::HIGH : return 2; + default: throw std::logic_error("Assertion error"); + } +} + + +QrCode QrCode::encodeText(const char *text, Ecc ecl) { + vector segs = QrSegment::makeSegments(text); + return encodeSegments(segs, ecl); +} + + +QrCode QrCode::encodeBinary(const vector &data, Ecc ecl) { + vector segs{QrSegment::makeBytes(data)}; + return encodeSegments(segs, ecl); +} + + +QrCode QrCode::encodeSegments(const vector &segs, Ecc ecl, + int minVersion, int maxVersion, int mask, bool boostEcl) { + if (!(MIN_VERSION <= minVersion && minVersion <= maxVersion && maxVersion <= MAX_VERSION) || mask < -1 || mask > 7) + throw std::invalid_argument("Invalid value"); + + // Find the minimal version number to use + int version, dataUsedBits; + for (version = minVersion; ; version++) { + int dataCapacityBits = getNumDataCodewords(version, ecl) * 8; // Number of data bits available + dataUsedBits = QrSegment::getTotalBits(segs, version); + if (dataUsedBits != -1 && dataUsedBits <= dataCapacityBits) + break; // This version number is found to be suitable + if (version >= maxVersion) { // All versions in the range could not fit the given data + std::ostringstream sb; + if (dataUsedBits == -1) + sb << "Segment too long"; + else { + sb << "Data length = " << dataUsedBits << " bits, "; + sb << "Max capacity = " << dataCapacityBits << " bits"; + } + throw data_too_long(sb.str()); + } + } + if (dataUsedBits == -1) + throw std::logic_error("Assertion error"); + + // Increase the error correction level while the data still fits in the current version number + for (Ecc newEcl : vector{Ecc::MEDIUM, Ecc::QUARTILE, Ecc::HIGH}) { // From low to high + if (boostEcl && dataUsedBits <= getNumDataCodewords(version, newEcl) * 8) + ecl = newEcl; + } + + // Concatenate all segments to create the data bit string + BitBuffer bb; + for (const QrSegment &seg : segs) { + bb.appendBits(static_cast(seg.getMode().getModeBits()), 4); + bb.appendBits(static_cast(seg.getNumChars()), seg.getMode().numCharCountBits(version)); + bb.insert(bb.end(), seg.getData().begin(), seg.getData().end()); + } + if (bb.size() != static_cast(dataUsedBits)) + throw std::logic_error("Assertion error"); + + // Add terminator and pad up to a byte if applicable + size_t dataCapacityBits = static_cast(getNumDataCodewords(version, ecl)) * 8; + if (bb.size() > dataCapacityBits) + throw std::logic_error("Assertion error"); + bb.appendBits(0, std::min(4, static_cast(dataCapacityBits - bb.size()))); + bb.appendBits(0, (8 - static_cast(bb.size() % 8)) % 8); + if (bb.size() % 8 != 0) + throw std::logic_error("Assertion error"); + + // Pad with alternating bytes until data capacity is reached + for (uint8_t padByte = 0xEC; bb.size() < dataCapacityBits; padByte ^= 0xEC ^ 0x11) + bb.appendBits(padByte, 8); + + // Pack bits into bytes in big endian + vector dataCodewords(bb.size() / 8); + for (size_t i = 0; i < bb.size(); i++) + dataCodewords[i >> 3] |= (bb.at(i) ? 1 : 0) << (7 - (i & 7)); + + // Create the QR Code object + return QrCode(version, ecl, dataCodewords, mask); +} + + +QrCode::QrCode(int ver, Ecc ecl, const vector &dataCodewords, int msk) : + // Initialize fields and check arguments + version(ver), + errorCorrectionLevel(ecl) { + if (ver < MIN_VERSION || ver > MAX_VERSION) + throw std::domain_error("Version value out of range"); + if (msk < -1 || msk > 7) + throw std::domain_error("Mask value out of range"); + size = ver * 4 + 17; + size_t sz = static_cast(size); + modules = vector >(sz, vector(sz)); // Initially all white + isFunction = vector >(sz, vector(sz)); + + // Compute ECC, draw modules + drawFunctionPatterns(); + const vector allCodewords = addEccAndInterleave(dataCodewords); + drawCodewords(allCodewords); + + // Do masking + if (msk == -1) { // Automatically choose best mask + long minPenalty = LONG_MAX; + for (int i = 0; i < 8; i++) { + applyMask(i); + drawFormatBits(i); + long penalty = getPenaltyScore(); + if (penalty < minPenalty) { + msk = i; + minPenalty = penalty; + } + applyMask(i); // Undoes the mask due to XOR + } + } + if (msk < 0 || msk > 7) + throw std::logic_error("Assertion error"); + this->mask = msk; + applyMask(msk); // Apply the final choice of mask + drawFormatBits(msk); // Overwrite old format bits + + isFunction.clear(); + isFunction.shrink_to_fit(); +} + + +int QrCode::getVersion() const { + return version; +} + + +int QrCode::getSize() const { + return size; +} + + +QrCode::Ecc QrCode::getErrorCorrectionLevel() const { + return errorCorrectionLevel; +} + + +int QrCode::getMask() const { + return mask; +} + + +bool QrCode::getModule(int x, int y) const { + return 0 <= x && x < size && 0 <= y && y < size && module(x, y); +} + + +std::string QrCode::toSvgString(int border) const { + if (border < 0) + throw std::domain_error("Border must be non-negative"); + if (border > INT_MAX / 2 || border * 2 > INT_MAX - size) + throw std::overflow_error("Border too large"); + + std::ostringstream sb; + sb << "\n"; + sb << "\n"; + sb << "\n"; + sb << "\t\n"; + sb << "\t\n"; + sb << "\n"; + return sb.str(); +} + + +void QrCode::drawFunctionPatterns() { + // Draw horizontal and vertical timing patterns + for (int i = 0; i < size; i++) { + setFunctionModule(6, i, i % 2 == 0); + setFunctionModule(i, 6, i % 2 == 0); + } + + // Draw 3 finder patterns (all corners except bottom right; overwrites some timing modules) + drawFinderPattern(3, 3); + drawFinderPattern(size - 4, 3); + drawFinderPattern(3, size - 4); + + // Draw numerous alignment patterns + const vector alignPatPos = getAlignmentPatternPositions(); + size_t numAlign = alignPatPos.size(); + for (size_t i = 0; i < numAlign; i++) { + for (size_t j = 0; j < numAlign; j++) { + // Don't draw on the three finder corners + if (!((i == 0 && j == 0) || (i == 0 && j == numAlign - 1) || (i == numAlign - 1 && j == 0))) + drawAlignmentPattern(alignPatPos.at(i), alignPatPos.at(j)); + } + } + + // Draw configuration data + drawFormatBits(0); // Dummy mask value; overwritten later in the constructor + drawVersion(); +} + + +void QrCode::drawFormatBits(int msk) { + // Calculate error correction code and pack bits + int data = getFormatBits(errorCorrectionLevel) << 3 | msk; // errCorrLvl is uint2, msk is uint3 + int rem = data; + for (int i = 0; i < 10; i++) + rem = (rem << 1) ^ ((rem >> 9) * 0x537); + int bits = (data << 10 | rem) ^ 0x5412; // uint15 + if (bits >> 15 != 0) + throw std::logic_error("Assertion error"); + + // Draw first copy + for (int i = 0; i <= 5; i++) + setFunctionModule(8, i, getBit(bits, i)); + setFunctionModule(8, 7, getBit(bits, 6)); + setFunctionModule(8, 8, getBit(bits, 7)); + setFunctionModule(7, 8, getBit(bits, 8)); + for (int i = 9; i < 15; i++) + setFunctionModule(14 - i, 8, getBit(bits, i)); + + // Draw second copy + for (int i = 0; i < 8; i++) + setFunctionModule(size - 1 - i, 8, getBit(bits, i)); + for (int i = 8; i < 15; i++) + setFunctionModule(8, size - 15 + i, getBit(bits, i)); + setFunctionModule(8, size - 8, true); // Always black +} + + +void QrCode::drawVersion() { + if (version < 7) + return; + + // Calculate error correction code and pack bits + int rem = version; // version is uint6, in the range [7, 40] + for (int i = 0; i < 12; i++) + rem = (rem << 1) ^ ((rem >> 11) * 0x1F25); + long bits = static_cast(version) << 12 | rem; // uint18 + if (bits >> 18 != 0) + throw std::logic_error("Assertion error"); + + // Draw two copies + for (int i = 0; i < 18; i++) { + bool bit = getBit(bits, i); + int a = size - 11 + i % 3; + int b = i / 3; + setFunctionModule(a, b, bit); + setFunctionModule(b, a, bit); + } +} + + +void QrCode::drawFinderPattern(int x, int y) { + for (int dy = -4; dy <= 4; dy++) { + for (int dx = -4; dx <= 4; dx++) { + int dist = std::max(std::abs(dx), std::abs(dy)); // Chebyshev/infinity norm + int xx = x + dx, yy = y + dy; + if (0 <= xx && xx < size && 0 <= yy && yy < size) + setFunctionModule(xx, yy, dist != 2 && dist != 4); + } + } +} + + +void QrCode::drawAlignmentPattern(int x, int y) { + for (int dy = -2; dy <= 2; dy++) { + for (int dx = -2; dx <= 2; dx++) + setFunctionModule(x + dx, y + dy, std::max(std::abs(dx), std::abs(dy)) != 1); + } +} + + +void QrCode::setFunctionModule(int x, int y, bool isBlack) { + size_t ux = static_cast(x); + size_t uy = static_cast(y); + modules .at(uy).at(ux) = isBlack; + isFunction.at(uy).at(ux) = true; +} + + +bool QrCode::module(int x, int y) const { + return modules.at(static_cast(y)).at(static_cast(x)); +} + + +vector QrCode::addEccAndInterleave(const vector &data) const { + if (data.size() != static_cast(getNumDataCodewords(version, errorCorrectionLevel))) + throw std::invalid_argument("Invalid argument"); + + // Calculate parameter numbers + int numBlocks = NUM_ERROR_CORRECTION_BLOCKS[static_cast(errorCorrectionLevel)][version]; + int blockEccLen = ECC_CODEWORDS_PER_BLOCK [static_cast(errorCorrectionLevel)][version]; + int rawCodewords = getNumRawDataModules(version) / 8; + int numShortBlocks = numBlocks - rawCodewords % numBlocks; + int shortBlockLen = rawCodewords / numBlocks; + + // Split data into blocks and append ECC to each block + vector > blocks; + const vector rsDiv = reedSolomonComputeDivisor(blockEccLen); + for (int i = 0, k = 0; i < numBlocks; i++) { + vector dat(data.cbegin() + k, data.cbegin() + (k + shortBlockLen - blockEccLen + (i < numShortBlocks ? 0 : 1))); + k += static_cast(dat.size()); + const vector ecc = reedSolomonComputeRemainder(dat, rsDiv); + if (i < numShortBlocks) + dat.push_back(0); + dat.insert(dat.end(), ecc.cbegin(), ecc.cend()); + blocks.push_back(std::move(dat)); + } + + // Interleave (not concatenate) the bytes from every block into a single sequence + vector result; + for (size_t i = 0; i < blocks.at(0).size(); i++) { + for (size_t j = 0; j < blocks.size(); j++) { + // Skip the padding byte in short blocks + if (i != static_cast(shortBlockLen - blockEccLen) || j >= static_cast(numShortBlocks)) + result.push_back(blocks.at(j).at(i)); + } + } + if (result.size() != static_cast(rawCodewords)) + throw std::logic_error("Assertion error"); + return result; +} + + +void QrCode::drawCodewords(const vector &data) { + if (data.size() != static_cast(getNumRawDataModules(version) / 8)) + throw std::invalid_argument("Invalid argument"); + + size_t i = 0; // Bit index into the data + // Do the funny zigzag scan + for (int right = size - 1; right >= 1; right -= 2) { // Index of right column in each column pair + if (right == 6) + right = 5; + for (int vert = 0; vert < size; vert++) { // Vertical counter + for (int j = 0; j < 2; j++) { + size_t x = static_cast(right - j); // Actual x coordinate + bool upward = ((right + 1) & 2) == 0; + size_t y = static_cast(upward ? size - 1 - vert : vert); // Actual y coordinate + if (!isFunction.at(y).at(x) && i < data.size() * 8) { + modules.at(y).at(x) = getBit(data.at(i >> 3), 7 - static_cast(i & 7)); + i++; + } + // If this QR Code has any remainder bits (0 to 7), they were assigned as + // 0/false/white by the constructor and are left unchanged by this method + } + } + } + if (i != data.size() * 8) + throw std::logic_error("Assertion error"); +} + + +void QrCode::applyMask(int msk) { + if (msk < 0 || msk > 7) + throw std::domain_error("Mask value out of range"); + size_t sz = static_cast(size); + for (size_t y = 0; y < sz; y++) { + for (size_t x = 0; x < sz; x++) { + bool invert; + switch (msk) { + case 0: invert = (x + y) % 2 == 0; break; + case 1: invert = y % 2 == 0; break; + case 2: invert = x % 3 == 0; break; + case 3: invert = (x + y) % 3 == 0; break; + case 4: invert = (x / 3 + y / 2) % 2 == 0; break; + case 5: invert = x * y % 2 + x * y % 3 == 0; break; + case 6: invert = (x * y % 2 + x * y % 3) % 2 == 0; break; + case 7: invert = ((x + y) % 2 + x * y % 3) % 2 == 0; break; + default: throw std::logic_error("Assertion error"); + } + modules.at(y).at(x) = modules.at(y).at(x) ^ (invert & !isFunction.at(y).at(x)); + } + } +} + + +long QrCode::getPenaltyScore() const { + long result = 0; + + // Adjacent modules in row having same color, and finder-like patterns + for (int y = 0; y < size; y++) { + bool runColor = false; + int runX = 0; + std::array runHistory = {}; + for (int x = 0; x < size; x++) { + if (module(x, y) == runColor) { + runX++; + if (runX == 5) + result += PENALTY_N1; + else if (runX > 5) + result++; + } else { + finderPenaltyAddHistory(runX, runHistory); + if (!runColor) + result += finderPenaltyCountPatterns(runHistory) * PENALTY_N3; + runColor = module(x, y); + runX = 1; + } + } + result += finderPenaltyTerminateAndCount(runColor, runX, runHistory) * PENALTY_N3; + } + // Adjacent modules in column having same color, and finder-like patterns + for (int x = 0; x < size; x++) { + bool runColor = false; + int runY = 0; + std::array runHistory = {}; + for (int y = 0; y < size; y++) { + if (module(x, y) == runColor) { + runY++; + if (runY == 5) + result += PENALTY_N1; + else if (runY > 5) + result++; + } else { + finderPenaltyAddHistory(runY, runHistory); + if (!runColor) + result += finderPenaltyCountPatterns(runHistory) * PENALTY_N3; + runColor = module(x, y); + runY = 1; + } + } + result += finderPenaltyTerminateAndCount(runColor, runY, runHistory) * PENALTY_N3; + } + + // 2*2 blocks of modules having same color + for (int y = 0; y < size - 1; y++) { + for (int x = 0; x < size - 1; x++) { + bool color = module(x, y); + if ( color == module(x + 1, y) && + color == module(x, y + 1) && + color == module(x + 1, y + 1)) + result += PENALTY_N2; + } + } + + // Balance of black and white modules + int black = 0; + for (const vector &row : modules) { + for (bool color : row) { + if (color) + black++; + } + } + int total = size * size; // Note that size is odd, so black/total != 1/2 + // Compute the smallest integer k >= 0 such that (45-5k)% <= black/total <= (55+5k)% + int k = static_cast((std::abs(black * 20L - total * 10L) + total - 1) / total) - 1; + result += k * PENALTY_N4; + return result; +} + + +vector QrCode::getAlignmentPatternPositions() const { + if (version == 1) + return vector(); + else { + int numAlign = version / 7 + 2; + int step = (version == 32) ? 26 : + (version*4 + numAlign*2 + 1) / (numAlign*2 - 2) * 2; + vector result; + for (int i = 0, pos = size - 7; i < numAlign - 1; i++, pos -= step) + result.insert(result.begin(), pos); + result.insert(result.begin(), 6); + return result; + } +} + + +int QrCode::getNumRawDataModules(int ver) { + if (ver < MIN_VERSION || ver > MAX_VERSION) + throw std::domain_error("Version number out of range"); + int result = (16 * ver + 128) * ver + 64; + if (ver >= 2) { + int numAlign = ver / 7 + 2; + result -= (25 * numAlign - 10) * numAlign - 55; + if (ver >= 7) + result -= 36; + } + if (!(208 <= result && result <= 29648)) + throw std::logic_error("Assertion error"); + return result; +} + + +int QrCode::getNumDataCodewords(int ver, Ecc ecl) { + return getNumRawDataModules(ver) / 8 + - ECC_CODEWORDS_PER_BLOCK [static_cast(ecl)][ver] + * NUM_ERROR_CORRECTION_BLOCKS[static_cast(ecl)][ver]; +} + + +vector QrCode::reedSolomonComputeDivisor(int degree) { + if (degree < 1 || degree > 255) + throw std::domain_error("Degree out of range"); + // Polynomial coefficients are stored from highest to lowest power, excluding the leading term which is always 1. + // For example the polynomial x^3 + 255x^2 + 8x + 93 is stored as the uint8 array {255, 8, 93}. + vector result(static_cast(degree)); + result.at(result.size() - 1) = 1; // Start off with the monomial x^0 + + // Compute the product polynomial (x - r^0) * (x - r^1) * (x - r^2) * ... * (x - r^{degree-1}), + // and drop the highest monomial term which is always 1x^degree. + // Note that r = 0x02, which is a generator element of this field GF(2^8/0x11D). + uint8_t root = 1; + for (int i = 0; i < degree; i++) { + // Multiply the current product by (x - r^i) + for (size_t j = 0; j < result.size(); j++) { + result.at(j) = reedSolomonMultiply(result.at(j), root); + if (j + 1 < result.size()) + result.at(j) ^= result.at(j + 1); + } + root = reedSolomonMultiply(root, 0x02); + } + return result; +} + + +vector QrCode::reedSolomonComputeRemainder(const vector &data, const vector &divisor) { + vector result(divisor.size()); + for (uint8_t b : data) { // Polynomial division + uint8_t factor = b ^ result.at(0); + result.erase(result.begin()); + result.push_back(0); + for (size_t i = 0; i < result.size(); i++) + result.at(i) ^= reedSolomonMultiply(divisor.at(i), factor); + } + return result; +} + + +uint8_t QrCode::reedSolomonMultiply(uint8_t x, uint8_t y) { + // Russian peasant multiplication + int z = 0; + for (int i = 7; i >= 0; i--) { + z = (z << 1) ^ ((z >> 7) * 0x11D); + z ^= ((y >> i) & 1) * x; + } + if (z >> 8 != 0) + throw std::logic_error("Assertion error"); + return static_cast(z); +} + + +int QrCode::finderPenaltyCountPatterns(const std::array &runHistory) const { + int n = runHistory.at(1); + if (n > size * 3) + throw std::logic_error("Assertion error"); + bool core = n > 0 && runHistory.at(2) == n && runHistory.at(3) == n * 3 && runHistory.at(4) == n && runHistory.at(5) == n; + return (core && runHistory.at(0) >= n * 4 && runHistory.at(6) >= n ? 1 : 0) + + (core && runHistory.at(6) >= n * 4 && runHistory.at(0) >= n ? 1 : 0); +} + + +int QrCode::finderPenaltyTerminateAndCount(bool currentRunColor, int currentRunLength, std::array &runHistory) const { + if (currentRunColor) { // Terminate black run + finderPenaltyAddHistory(currentRunLength, runHistory); + currentRunLength = 0; + } + currentRunLength += size; // Add white border to final run + finderPenaltyAddHistory(currentRunLength, runHistory); + return finderPenaltyCountPatterns(runHistory); +} + + +void QrCode::finderPenaltyAddHistory(int currentRunLength, std::array &runHistory) const { + if (runHistory.at(0) == 0) + currentRunLength += size; // Add white border to initial run + std::copy_backward(runHistory.cbegin(), runHistory.cend() - 1, runHistory.end()); + runHistory.at(0) = currentRunLength; +} + + +bool QrCode::getBit(long x, int i) { + return ((x >> i) & 1) != 0; +} + + +/*---- Tables of constants ----*/ + +const int QrCode::PENALTY_N1 = 3; +const int QrCode::PENALTY_N2 = 3; +const int QrCode::PENALTY_N3 = 40; +const int QrCode::PENALTY_N4 = 10; + + +const int8_t QrCode::ECC_CODEWORDS_PER_BLOCK[4][41] = { + // Version: (note that index 0 is for padding, and is set to an illegal value) + //0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40 Error correction level + {-1, 7, 10, 15, 20, 26, 18, 20, 24, 30, 18, 20, 24, 26, 30, 22, 24, 28, 30, 28, 28, 28, 28, 30, 30, 26, 28, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30}, // Low + {-1, 10, 16, 26, 18, 24, 16, 18, 22, 22, 26, 30, 22, 22, 24, 24, 28, 28, 26, 26, 26, 26, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28, 28}, // Medium + {-1, 13, 22, 18, 26, 18, 24, 18, 22, 20, 24, 28, 26, 24, 20, 30, 24, 28, 28, 26, 30, 28, 30, 30, 30, 30, 28, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30}, // Quartile + {-1, 17, 28, 22, 16, 22, 28, 26, 26, 24, 28, 24, 28, 22, 24, 24, 30, 28, 28, 26, 28, 30, 24, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30, 30}, // High +}; + +const int8_t QrCode::NUM_ERROR_CORRECTION_BLOCKS[4][41] = { + // Version: (note that index 0 is for padding, and is set to an illegal value) + //0, 1, 2, 3, 4, 5, 6, 7, 8, 9,10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40 Error correction level + {-1, 1, 1, 1, 1, 1, 2, 2, 2, 2, 4, 4, 4, 4, 4, 6, 6, 6, 6, 7, 8, 8, 9, 9, 10, 12, 12, 12, 13, 14, 15, 16, 17, 18, 19, 19, 20, 21, 22, 24, 25}, // Low + {-1, 1, 1, 1, 2, 2, 4, 4, 4, 5, 5, 5, 8, 9, 9, 10, 10, 11, 13, 14, 16, 17, 17, 18, 20, 21, 23, 25, 26, 28, 29, 31, 33, 35, 37, 38, 40, 43, 45, 47, 49}, // Medium + {-1, 1, 1, 2, 2, 4, 4, 6, 6, 8, 8, 8, 10, 12, 16, 12, 17, 16, 18, 21, 20, 23, 23, 25, 27, 29, 34, 34, 35, 38, 40, 43, 45, 48, 51, 53, 56, 59, 62, 65, 68}, // Quartile + {-1, 1, 1, 2, 4, 4, 4, 5, 6, 8, 8, 11, 11, 16, 16, 18, 16, 19, 21, 25, 25, 25, 34, 30, 32, 35, 37, 40, 42, 45, 48, 51, 54, 57, 60, 63, 66, 70, 74, 77, 81}, // High +}; + + +data_too_long::data_too_long(const std::string &msg) : + std::length_error(msg) {} + + + +BitBuffer::BitBuffer() + : std::vector() {} + + +void BitBuffer::appendBits(std::uint32_t val, int len) { + if (len < 0 || len > 31 || val >> len != 0) + throw std::domain_error("Value out of range"); + for (int i = len - 1; i >= 0; i--) // Append bit by bit + this->push_back(((val >> i) & 1) != 0); +} + +} diff --git a/selfdrive/ui/qt/widgets/QrCode.hpp b/selfdrive/ui/qt/widgets/QrCode.hpp new file mode 100644 index 0000000000..7341e41029 --- /dev/null +++ b/selfdrive/ui/qt/widgets/QrCode.hpp @@ -0,0 +1,556 @@ +/* + * QR Code generator library (C++) + * + * Copyright (c) Project Nayuki. (MIT License) + * https://www.nayuki.io/page/qr-code-generator-library + * + * Permission is hereby granted, free of charge, to any person obtaining a copy of + * this software and associated documentation files (the "Software"), to deal in + * the Software without restriction, including without limitation the rights to + * use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of + * the Software, and to permit persons to whom the Software is furnished to do so, + * subject to the following conditions: + * - The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * - The Software is provided "as is", without warranty of any kind, express or + * implied, including but not limited to the warranties of merchantability, + * fitness for a particular purpose and noninfringement. In no event shall the + * authors or copyright holders be liable for any claim, damages or other + * liability, whether in an action of contract, tort or otherwise, arising from, + * out of or in connection with the Software or the use or other dealings in the + * Software. + */ + +#pragma once + +#include +#include +#include +#include +#include + + +namespace qrcodegen { + +/* + * A segment of character/binary/control data in a QR Code symbol. + * Instances of this class are immutable. + * The mid-level way to create a segment is to take the payload data + * and call a static factory function such as QrSegment::makeNumeric(). + * The low-level way to create a segment is to custom-make the bit buffer + * and call the QrSegment() constructor with appropriate values. + * This segment class imposes no length restrictions, but QR Codes have restrictions. + * Even in the most favorable conditions, a QR Code can only hold 7089 characters of data. + * Any segment longer than this is meaningless for the purpose of generating QR Codes. + */ +class QrSegment final { + + /*---- Public helper enumeration ----*/ + + /* + * Describes how a segment's data bits are interpreted. Immutable. + */ + public: class Mode final { + + /*-- Constants --*/ + + public: static const Mode NUMERIC; + public: static const Mode ALPHANUMERIC; + public: static const Mode BYTE; + public: static const Mode KANJI; + public: static const Mode ECI; + + + /*-- Fields --*/ + + // The mode indicator bits, which is a uint4 value (range 0 to 15). + private: int modeBits; + + // Number of character count bits for three different version ranges. + private: int numBitsCharCount[3]; + + + /*-- Constructor --*/ + + private: Mode(int mode, int cc0, int cc1, int cc2); + + + /*-- Methods --*/ + + /* + * (Package-private) Returns the mode indicator bits, which is an unsigned 4-bit value (range 0 to 15). + */ + public: int getModeBits() const; + + /* + * (Package-private) Returns the bit width of the character count field for a segment in + * this mode in a QR Code at the given version number. The result is in the range [0, 16]. + */ + public: int numCharCountBits(int ver) const; + + }; + + + + /*---- Static factory functions (mid level) ----*/ + + /* + * Returns a segment representing the given binary data encoded in + * byte mode. All input byte vectors are acceptable. Any text string + * can be converted to UTF-8 bytes and encoded as a byte mode segment. + */ + public: static QrSegment makeBytes(const std::vector &data); + + + /* + * Returns a segment representing the given string of decimal digits encoded in numeric mode. + */ + public: static QrSegment makeNumeric(const char *digits); + + + /* + * Returns a segment representing the given text string encoded in alphanumeric mode. + * The characters allowed are: 0 to 9, A to Z (uppercase only), space, + * dollar, percent, asterisk, plus, hyphen, period, slash, colon. + */ + public: static QrSegment makeAlphanumeric(const char *text); + + + /* + * Returns a list of zero or more segments to represent the given text string. The result + * may use various segment modes and switch modes to optimize the length of the bit stream. + */ + public: static std::vector makeSegments(const char *text); + + + /* + * Returns a segment representing an Extended Channel Interpretation + * (ECI) designator with the given assignment value. + */ + public: static QrSegment makeEci(long assignVal); + + + /*---- Public static helper functions ----*/ + + /* + * Tests whether the given string can be encoded as a segment in alphanumeric mode. + * A string is encodable iff each character is in the following set: 0 to 9, A to Z + * (uppercase only), space, dollar, percent, asterisk, plus, hyphen, period, slash, colon. + */ + public: static bool isAlphanumeric(const char *text); + + + /* + * Tests whether the given string can be encoded as a segment in numeric mode. + * A string is encodable iff each character is in the range 0 to 9. + */ + public: static bool isNumeric(const char *text); + + + + /*---- Instance fields ----*/ + + /* The mode indicator of this segment. Accessed through getMode(). */ + private: Mode mode; + + /* The length of this segment's unencoded data. Measured in characters for + * numeric/alphanumeric/kanji mode, bytes for byte mode, and 0 for ECI mode. + * Always zero or positive. Not the same as the data's bit length. + * Accessed through getNumChars(). */ + private: int numChars; + + /* The data bits of this segment. Accessed through getData(). */ + private: std::vector data; + + + /*---- Constructors (low level) ----*/ + + /* + * Creates a new QR Code segment with the given attributes and data. + * The character count (numCh) must agree with the mode and the bit buffer length, + * but the constraint isn't checked. The given bit buffer is copied and stored. + */ + public: QrSegment(Mode md, int numCh, const std::vector &dt); + + + /* + * Creates a new QR Code segment with the given parameters and data. + * The character count (numCh) must agree with the mode and the bit buffer length, + * but the constraint isn't checked. The given bit buffer is moved and stored. + */ + public: QrSegment(Mode md, int numCh, std::vector &&dt); + + + /*---- Methods ----*/ + + /* + * Returns the mode field of this segment. + */ + public: Mode getMode() const; + + + /* + * Returns the character count field of this segment. + */ + public: int getNumChars() const; + + + /* + * Returns the data bits of this segment. + */ + public: const std::vector &getData() const; + + + // (Package-private) Calculates the number of bits needed to encode the given segments at + // the given version. Returns a non-negative number if successful. Otherwise returns -1 if a + // segment has too many characters to fit its length field, or the total bits exceeds INT_MAX. + public: static int getTotalBits(const std::vector &segs, int version); + + + /*---- Private constant ----*/ + + /* The set of all legal characters in alphanumeric mode, where + * each character value maps to the index in the string. */ + private: static const char *ALPHANUMERIC_CHARSET; + +}; + + + +/* + * A QR Code symbol, which is a type of two-dimension barcode. + * Invented by Denso Wave and described in the ISO/IEC 18004 standard. + * Instances of this class represent an immutable square grid of black and white cells. + * The class provides static factory functions to create a QR Code from text or binary data. + * The class covers the QR Code Model 2 specification, supporting all versions (sizes) + * from 1 to 40, all 4 error correction levels, and 4 character encoding modes. + * + * Ways to create a QR Code object: + * - High level: Take the payload data and call QrCode::encodeText() or QrCode::encodeBinary(). + * - Mid level: Custom-make the list of segments and call QrCode::encodeSegments(). + * - Low level: Custom-make the array of data codeword bytes (including + * segment headers and final padding, excluding error correction codewords), + * supply the appropriate version number, and call the QrCode() constructor. + * (Note that all ways require supplying the desired error correction level.) + */ +class QrCode final { + + /*---- Public helper enumeration ----*/ + + /* + * The error correction level in a QR Code symbol. + */ + public: enum class Ecc { + LOW = 0 , // The QR Code can tolerate about 7% erroneous codewords + MEDIUM , // The QR Code can tolerate about 15% erroneous codewords + QUARTILE, // The QR Code can tolerate about 25% erroneous codewords + HIGH , // The QR Code can tolerate about 30% erroneous codewords + }; + + + // Returns a value in the range 0 to 3 (unsigned 2-bit integer). + private: static int getFormatBits(Ecc ecl); + + + + /*---- Static factory functions (high level) ----*/ + + /* + * Returns a QR Code representing the given Unicode text string at the given error correction level. + * As a conservative upper bound, this function is guaranteed to succeed for strings that have 2953 or fewer + * UTF-8 code units (not Unicode code points) if the low error correction level is used. The smallest possible + * QR Code version is automatically chosen for the output. The ECC level of the result may be higher than + * the ecl argument if it can be done without increasing the version. + */ + public: static QrCode encodeText(const char *text, Ecc ecl); + + + /* + * Returns a QR Code representing the given binary data at the given error correction level. + * This function always encodes using the binary segment mode, not any text mode. The maximum number of + * bytes allowed is 2953. The smallest possible QR Code version is automatically chosen for the output. + * The ECC level of the result may be higher than the ecl argument if it can be done without increasing the version. + */ + public: static QrCode encodeBinary(const std::vector &data, Ecc ecl); + + + /*---- Static factory functions (mid level) ----*/ + + /* + * Returns a QR Code representing the given segments with the given encoding parameters. + * The smallest possible QR Code version within the given range is automatically + * chosen for the output. Iff boostEcl is true, then the ECC level of the result + * may be higher than the ecl argument if it can be done without increasing the + * version. The mask number is either between 0 to 7 (inclusive) to force that + * mask, or -1 to automatically choose an appropriate mask (which may be slow). + * This function allows the user to create a custom sequence of segments that switches + * between modes (such as alphanumeric and byte) to encode text in less space. + * This is a mid-level API; the high-level API is encodeText() and encodeBinary(). + */ + public: static QrCode encodeSegments(const std::vector &segs, Ecc ecl, + int minVersion=1, int maxVersion=40, int mask=-1, bool boostEcl=true); // All optional parameters + + + + /*---- Instance fields ----*/ + + // Immutable scalar parameters: + + /* The version number of this QR Code, which is between 1 and 40 (inclusive). + * This determines the size of this barcode. */ + private: int version; + + /* The width and height of this QR Code, measured in modules, between + * 21 and 177 (inclusive). This is equal to version * 4 + 17. */ + private: int size; + + /* The error correction level used in this QR Code. */ + private: Ecc errorCorrectionLevel; + + /* The index of the mask pattern used in this QR Code, which is between 0 and 7 (inclusive). + * Even if a QR Code is created with automatic masking requested (mask = -1), + * the resulting object still has a mask value between 0 and 7. */ + private: int mask; + + // Private grids of modules/pixels, with dimensions of size*size: + + // The modules of this QR Code (false = white, true = black). + // Immutable after constructor finishes. Accessed through getModule(). + private: std::vector > modules; + + // Indicates function modules that are not subjected to masking. Discarded when constructor finishes. + private: std::vector > isFunction; + + + + /*---- Constructor (low level) ----*/ + + /* + * Creates a new QR Code with the given version number, + * error correction level, data codeword bytes, and mask number. + * This is a low-level API that most users should not use directly. + * A mid-level API is the encodeSegments() function. + */ + public: QrCode(int ver, Ecc ecl, const std::vector &dataCodewords, int msk); + + + + /*---- Public instance methods ----*/ + + /* + * Returns this QR Code's version, in the range [1, 40]. + */ + public: int getVersion() const; + + + /* + * Returns this QR Code's size, in the range [21, 177]. + */ + public: int getSize() const; + + + /* + * Returns this QR Code's error correction level. + */ + public: Ecc getErrorCorrectionLevel() const; + + + /* + * Returns this QR Code's mask, in the range [0, 7]. + */ + public: int getMask() const; + + + /* + * Returns the color of the module (pixel) at the given coordinates, which is false + * for white or true for black. The top left corner has the coordinates (x=0, y=0). + * If the given coordinates are out of bounds, then false (white) is returned. + */ + public: bool getModule(int x, int y) const; + + + /* + * Returns a string of SVG code for an image depicting this QR Code, with the given number + * of border modules. The string always uses Unix newlines (\n), regardless of the platform. + */ + public: std::string toSvgString(int border) const; + + + + /*---- Private helper methods for constructor: Drawing function modules ----*/ + + // Reads this object's version field, and draws and marks all function modules. + private: void drawFunctionPatterns(); + + + // Draws two copies of the format bits (with its own error correction code) + // based on the given mask and this object's error correction level field. + private: void drawFormatBits(int msk); + + + // Draws two copies of the version bits (with its own error correction code), + // based on this object's version field, iff 7 <= version <= 40. + private: void drawVersion(); + + + // Draws a 9*9 finder pattern including the border separator, + // with the center module at (x, y). Modules can be out of bounds. + private: void drawFinderPattern(int x, int y); + + + // Draws a 5*5 alignment pattern, with the center module + // at (x, y). All modules must be in bounds. + private: void drawAlignmentPattern(int x, int y); + + + // Sets the color of a module and marks it as a function module. + // Only used by the constructor. Coordinates must be in bounds. + private: void setFunctionModule(int x, int y, bool isBlack); + + + // Returns the color of the module at the given coordinates, which must be in range. + private: bool module(int x, int y) const; + + + /*---- Private helper methods for constructor: Codewords and masking ----*/ + + // Returns a new byte string representing the given data with the appropriate error correction + // codewords appended to it, based on this object's version and error correction level. + private: std::vector addEccAndInterleave(const std::vector &data) const; + + + // Draws the given sequence of 8-bit codewords (data and error correction) onto the entire + // data area of this QR Code. Function modules need to be marked off before this is called. + private: void drawCodewords(const std::vector &data); + + + // XORs the codeword modules in this QR Code with the given mask pattern. + // The function modules must be marked and the codeword bits must be drawn + // before masking. Due to the arithmetic of XOR, calling applyMask() with + // the same mask value a second time will undo the mask. A final well-formed + // QR Code needs exactly one (not zero, two, etc.) mask applied. + private: void applyMask(int msk); + + + // Calculates and returns the penalty score based on state of this QR Code's current modules. + // This is used by the automatic mask choice algorithm to find the mask pattern that yields the lowest score. + private: long getPenaltyScore() const; + + + + /*---- Private helper functions ----*/ + + // Returns an ascending list of positions of alignment patterns for this version number. + // Each position is in the range [0,177), and are used on both the x and y axes. + // This could be implemented as lookup table of 40 variable-length lists of unsigned bytes. + private: std::vector getAlignmentPatternPositions() const; + + + // Returns the number of data bits that can be stored in a QR Code of the given version number, after + // all function modules are excluded. This includes remainder bits, so it might not be a multiple of 8. + // The result is in the range [208, 29648]. This could be implemented as a 40-entry lookup table. + private: static int getNumRawDataModules(int ver); + + + // Returns the number of 8-bit data (i.e. not error correction) codewords contained in any + // QR Code of the given version number and error correction level, with remainder bits discarded. + // This stateless pure function could be implemented as a (40*4)-cell lookup table. + private: static int getNumDataCodewords(int ver, Ecc ecl); + + + // Returns a Reed-Solomon ECC generator polynomial for the given degree. This could be + // implemented as a lookup table over all possible parameter values, instead of as an algorithm. + private: static std::vector reedSolomonComputeDivisor(int degree); + + + // Returns the Reed-Solomon error correction codeword for the given data and divisor polynomials. + private: static std::vector reedSolomonComputeRemainder(const std::vector &data, const std::vector &divisor); + + + // Returns the product of the two given field elements modulo GF(2^8/0x11D). + // All inputs are valid. This could be implemented as a 256*256 lookup table. + private: static std::uint8_t reedSolomonMultiply(std::uint8_t x, std::uint8_t y); + + + // Can only be called immediately after a white run is added, and + // returns either 0, 1, or 2. A helper function for getPenaltyScore(). + private: int finderPenaltyCountPatterns(const std::array &runHistory) const; + + + // Must be called at the end of a line (row or column) of modules. A helper function for getPenaltyScore(). + private: int finderPenaltyTerminateAndCount(bool currentRunColor, int currentRunLength, std::array &runHistory) const; + + + // Pushes the given value to the front and drops the last value. A helper function for getPenaltyScore(). + private: void finderPenaltyAddHistory(int currentRunLength, std::array &runHistory) const; + + + // Returns true iff the i'th bit of x is set to 1. + private: static bool getBit(long x, int i); + + + /*---- Constants and tables ----*/ + + // The minimum version number supported in the QR Code Model 2 standard. + public: static constexpr int MIN_VERSION = 1; + + // The maximum version number supported in the QR Code Model 2 standard. + public: static constexpr int MAX_VERSION = 40; + + + // For use in getPenaltyScore(), when evaluating which mask is best. + private: static const int PENALTY_N1; + private: static const int PENALTY_N2; + private: static const int PENALTY_N3; + private: static const int PENALTY_N4; + + + private: static const std::int8_t ECC_CODEWORDS_PER_BLOCK[4][41]; + private: static const std::int8_t NUM_ERROR_CORRECTION_BLOCKS[4][41]; + +}; + + + +/*---- Public exception class ----*/ + +/* + * Thrown when the supplied data does not fit any QR Code version. Ways to handle this exception include: + * - Decrease the error correction level if it was greater than Ecc::LOW. + * - If the encodeSegments() function was called with a maxVersion argument, then increase + * it if it was less than QrCode::MAX_VERSION. (This advice does not apply to the other + * factory functions because they search all versions up to QrCode::MAX_VERSION.) + * - Split the text data into better or optimal segments in order to reduce the number of bits required. + * - Change the text or binary data to be shorter. + * - Change the text to fit the character set of a particular segment mode (e.g. alphanumeric). + * - Propagate the error upward to the caller/user. + */ +class data_too_long : public std::length_error { + + public: explicit data_too_long(const std::string &msg); + +}; + + + +/* + * An appendable sequence of bits (0s and 1s). Mainly used by QrSegment. + */ +class BitBuffer final : public std::vector { + + /*---- Constructor ----*/ + + // Creates an empty bit buffer (length 0). + public: BitBuffer(); + + + + /*---- Method ----*/ + + // Appends the given number of low-order bits of the given value + // to this buffer. Requires 0 <= len <= 31 and val < 2^len. + public: void appendBits(std::uint32_t val, int len); + +}; + +} diff --git a/selfdrive/ui/qt/widgets/drive_stats.cc b/selfdrive/ui/qt/widgets/drive_stats.cc index e9929083d6..9da32a4ace 100644 --- a/selfdrive/ui/qt/widgets/drive_stats.cc +++ b/selfdrive/ui/qt/widgets/drive_stats.cc @@ -1,27 +1,23 @@ #include #include -#include #include -#include -#include +#include #include #include -#include +#include #include -#include +#include +#include +#include -#include -#include -#include - -#include "drive_stats.hpp" +#include "api.hpp" #include "common/params.h" #include "common/util.h" +#include "drive_stats.hpp" +#include "home.hpp" - -constexpr double MILE_TO_KM = 1.60934; - +const double MILE_TO_KM = 1.60934; #if defined(QCOM) || defined(QCOM2) const std::string private_key_path = "/persist/comma/id_rsa"; @@ -29,128 +25,93 @@ const std::string private_key_path = "/persist/comma/id_rsa"; const std::string private_key_path = util::getenv_default("HOME", "/.comma/persist/comma/id_rsa", "/persist/comma/id_rsa"); #endif - -QByteArray rsa_sign(QByteArray data) { - auto file = QFile(private_key_path.c_str()); - bool r = file.open(QIODevice::ReadOnly); - assert(r); - - auto key = file.readAll(); - - BIO *mem = BIO_new_mem_buf(key.data(), key.size()); - assert(mem); - - RSA *rsa_private = PEM_read_bio_RSAPrivateKey(mem, NULL, NULL, NULL); - assert(rsa_private); - - auto sig = QByteArray(); - sig.resize(RSA_size(rsa_private)); - - unsigned int sig_len; - int ret = RSA_sign(NID_sha256, (unsigned char*)data.data(), data.size(), (unsigned char*)sig.data(), &sig_len, rsa_private); - - assert(ret == 1); - assert(sig_len == sig.size()); - - BIO_free(mem); - RSA_free(rsa_private); - - return sig; +void clearLayouts(QLayout* layout) { + while (QLayoutItem* item = layout->takeAt(0)) { + if (QWidget* widget = item->widget()) { + widget->deleteLater(); + } + if (QLayout* childLayout = item->layout()) { + clearLayouts(childLayout); + } + delete item; + } } -QString create_jwt(QString dongle_id, int expiry=3600) { - QJsonObject header; - header.insert("alg", "RS256"); - header.insert("typ", "JWT"); +QLayout* build_stat(QString name, int stat) { + QVBoxLayout* layout = new QVBoxLayout; - auto t = QDateTime::currentSecsSinceEpoch(); - QJsonObject payload; - payload.insert("identity", dongle_id); - payload.insert("nbf", t); - payload.insert("iat", t); - payload.insert("exp", t + expiry); - - QString jwt = - QJsonDocument(header).toJson(QJsonDocument::Compact).toBase64() + - '.' + - QJsonDocument(payload).toJson(QJsonDocument::Compact).toBase64(); - - auto hash = QCryptographicHash::hash(jwt.toUtf8(), QCryptographicHash::Sha256); - auto sig = rsa_sign(hash); - - jwt += '.' + sig.toBase64(); - - return jwt; -} - -QLayout *build_stat(QString name, int stat) { - QVBoxLayout *layout = new QVBoxLayout; - - QLabel *metric = new QLabel(QString("%1").arg(stat)); + QLabel* metric = new QLabel(QString("%1").arg(stat)); metric->setStyleSheet(R"( font-size: 72px; font-weight: 700; )"); layout->addWidget(metric, 0, Qt::AlignLeft); - - QLabel *label = new QLabel(name); + + QLabel* label = new QLabel(name); label->setStyleSheet(R"( font-size: 32px; font-weight: 600; )"); layout->addWidget(label, 0, Qt::AlignLeft); - + return layout; } -void DriveStats::replyFinished(QNetworkReply *l) { - QString answer = l->readAll(); - answer.chop(1); +void DriveStats::parseError(QString response) { + clearLayouts(vlayout); + vlayout->addWidget(new QLabel("No internet connection")); +} - QJsonDocument doc = QJsonDocument::fromJson(answer.toUtf8()); +void DriveStats::parseResponse(QString response) { + response.chop(1); + clearLayouts(vlayout); + QJsonDocument doc = QJsonDocument::fromJson(response.toUtf8()); if (doc.isNull()) { - qDebug() << "JSON Parse failed"; + qDebug() << "JSON Parse failed on getting past drives statistics"; + return; } + QString IsMetric = QString::fromStdString(Params().get("IsMetric")); - bool metric = (IsMetric =="1"); + bool metric = (IsMetric == "1"); QJsonObject json = doc.object(); auto all = json["all"].toObject(); auto week = json["week"].toObject(); - QGridLayout *gl = new QGridLayout(); + QGridLayout* gl = new QGridLayout(); - int all_distance = all["distance"].toDouble()*(metric ? MILE_TO_KM : 1); + int all_distance = all["distance"].toDouble() * (metric ? MILE_TO_KM : 1); gl->addWidget(new QLabel("ALL TIME"), 0, 0, 1, 3); gl->addLayout(build_stat("DRIVES", all["routes"].toDouble()), 1, 0, 3, 1); gl->addLayout(build_stat(metric ? "KM" : "MILES", all_distance), 1, 1, 3, 1); gl->addLayout(build_stat("HOURS", all["minutes"].toDouble() / 60), 1, 2, 3, 1); - int week_distance = week["distance"].toDouble()*(metric ? MILE_TO_KM : 1); + int week_distance = week["distance"].toDouble() * (metric ? MILE_TO_KM : 1); gl->addWidget(new QLabel("PAST WEEK"), 6, 0, 1, 3); gl->addLayout(build_stat("DRIVES", week["routes"].toDouble()), 7, 0, 3, 1); gl->addLayout(build_stat(metric ? "KM" : "MILES", week_distance), 7, 1, 3, 1); gl->addLayout(build_stat("HOURS", week["minutes"].toDouble() / 60), 7, 2, 3, 1); - setLayout(gl); + QWidget* q = new QWidget; + q->setLayout(gl); + + vlayout->addWidget(q); +} + +DriveStats::DriveStats(QWidget* parent) : QWidget(parent) { + vlayout = new QVBoxLayout(this); + setLayout(vlayout); setStyleSheet(R"( QLabel { font-size: 48px; font-weight: 600; } )"); -} - -DriveStats::DriveStats(QWidget *parent) : QWidget(parent) { - QString dongle_id = QString::fromStdString(Params().get("DongleId")); - QString token = create_jwt(dongle_id); - - QNetworkAccessManager *manager = new QNetworkAccessManager(this); - connect(manager, &QNetworkAccessManager::finished, this, &DriveStats::replyFinished); - - QNetworkRequest request; - request.setUrl(QUrl("https://api.commadotai.com/v1.1/devices/" + dongle_id + "/stats")); - request.setRawHeader("Authorization", ("JWT "+token).toUtf8()); - - manager->get(request); + + QString dongleId = QString::fromStdString(Params().get("DongleId")); + QString url = "https://api.commadotai.com/v1.1/devices/" + dongleId + "/stats"; + RequestRepeater* repeater = new RequestRepeater(this, url, 13); + QObject::connect(repeater, SIGNAL(receivedResponse(QString)), this, SLOT(parseResponse(QString))); + QObject::connect(repeater, SIGNAL(failedResponse(QString)), this, SLOT(parseError(QString))); + } diff --git a/selfdrive/ui/qt/widgets/drive_stats.hpp b/selfdrive/ui/qt/widgets/drive_stats.hpp index 991de7e2ce..bf4cdae000 100644 --- a/selfdrive/ui/qt/widgets/drive_stats.hpp +++ b/selfdrive/ui/qt/widgets/drive_stats.hpp @@ -1,15 +1,21 @@ #pragma once -#include #include +#include +#include +#include "api.hpp" class DriveStats : public QWidget { Q_OBJECT public: - explicit DriveStats(QWidget *parent = 0); + explicit DriveStats(QWidget* parent = 0); private: - void replyFinished(QNetworkReply *l); + QVBoxLayout* vlayout; + +private slots: + void parseError(QString response); + void parseResponse(QString response); }; diff --git a/selfdrive/ui/qt/widgets/setup.cc b/selfdrive/ui/qt/widgets/setup.cc new file mode 100644 index 0000000000..2a43a9ddba --- /dev/null +++ b/selfdrive/ui/qt/widgets/setup.cc @@ -0,0 +1,276 @@ +#include +#include +#include +#include +#include +#include +#include + +#include "QrCode.hpp" +#include "api.hpp" +#include "common/params.h" +#include "common/util.h" +#include "home.hpp" +#include "setup.hpp" + +using qrcodegen::QrCode; + +#if defined(QCOM) || defined(QCOM2) +const std::string private_key_path = "/persist/comma/id_rsa"; +#else +const std::string private_key_path = util::getenv_default("HOME", "/.comma/persist/comma/id_rsa", "/persist/comma/id_rsa"); +#endif + +PairingQRWidget::PairingQRWidget(QWidget* parent) : QWidget(parent) { + qrCode = new QLabel; + qrCode->setScaledContents(true); + QVBoxLayout* v = new QVBoxLayout; + v->addWidget(qrCode, 0, Qt::AlignCenter); + setLayout(v); + + QTimer* timer = new QTimer(this); + timer->start(30 * 1000);// HaLf a minute + connect(timer, SIGNAL(timeout()), this, SLOT(refresh())); + refresh(); // Not waiting for the first refresh +} + +void PairingQRWidget::refresh(){ + QString IMEI = QString::fromStdString(Params().get("IMEI")); + QString serial = QString::fromStdString(Params().get("HardwareSerial")); + + if (std::min(IMEI.length(), serial.length()) <= 5) { + qrCode->setText("Error getting serial: contact support"); + qrCode->setWordWrap(true); + qrCode->setStyleSheet(R"( + font-size: 60px; + )"); + return; + } + QVector> payloads; + payloads.push_back(qMakePair(QString("pair"), true)); + QString pairToken = CommaApi::create_jwt(payloads); + + QString qrString = IMEI + "--" + serial + "--" + pairToken; + this->updateQrCode(qrString); +} + +void PairingQRWidget::updateQrCode(QString text) { + QrCode qr = QrCode::encodeText(text.toUtf8().data(), QrCode::Ecc::LOW); + qint32 sz = qr.getSize(); + // We make the image larger so we can have a white border + QImage im(sz + 2, sz + 2, QImage::Format_RGB32); + QRgb black = qRgb(0, 0, 0); + QRgb white = qRgb(255, 255, 255); + + for (int y = 0; y < sz + 2; y++) { + for (int x = 0; x < sz + 2; x++) { + im.setPixel(x, y, white); + } + } + for (int y = 0; y < sz; y++) { + for (int x = 0; x < sz; x++) { + im.setPixel(x + 1, y + 1, qr.getModule(x, y) ? black : white); + } + } + // Integer division to prevent anti-aliasing + int approx500 = (500 / (sz + 2)) * (sz + 2); + qrCode->setPixmap(QPixmap::fromImage(im.scaled(approx500, approx500, Qt::KeepAspectRatio, Qt::FastTransformation), Qt::MonoOnly)); + qrCode->setFixedSize(approx500, approx500); +} + +PrimeUserWidget::PrimeUserWidget(QWidget* parent) : QWidget(parent) { + mainLayout = new QVBoxLayout(this); + QLabel* commaPrime = new QLabel("COMMA PRIME", this); + commaPrime->setStyleSheet(R"( + font-size: 60px; + )"); + mainLayout->addWidget(commaPrime); + + username = new QLabel("", this); + mainLayout->addWidget(username); + + mainLayout->addSpacing(200); + + QLabel* commaPoints = new QLabel("COMMA POINTS", this); + commaPoints->setStyleSheet(R"( + font-size: 60px; + color: #b8b8b8; + )"); + mainLayout->addWidget(commaPoints); + + points = new QLabel("", this); + mainLayout->addWidget(points); + + setLayout(mainLayout); + QString dongleId = QString::fromStdString(Params().get("DongleId")); + QString url = "https://api.commadotai.com/v1/devices/" + dongleId + "/owner"; + RequestRepeater* repeater = new RequestRepeater(this, url, 6); + + QObject::connect(repeater, SIGNAL(receivedResponse(QString)), this, SLOT(replyFinished(QString))); +} + +void PrimeUserWidget::replyFinished(QString response) { + QJsonDocument doc = QJsonDocument::fromJson(response.toUtf8()); + if (doc.isNull()) { + qDebug() << "JSON Parse failed on getting username and points"; + return; + } + QJsonObject json = doc.object(); + QString username_str = json["username"].toString(); + if (username_str.length()) { + username_str = "@" + username_str; + } + QString points_str = QString::number(json["points"].toInt()); + + username->setText(username_str); + points->setText(points_str); +} + +PrimeAdWidget::PrimeAdWidget(QWidget* parent) : QWidget(parent) { + QVBoxLayout* vlayout = new QVBoxLayout(this); + + QLabel* upgradeNow = new QLabel("Upgrade now", this); + vlayout->addWidget(upgradeNow); + + QLabel* description = new QLabel("Become a comma prime member in the comma app and get premium features!", this); + description->setStyleSheet(R"( + font-size: 50px; + color: #b8b8b8; + )"); + description->setWordWrap(true); + vlayout->addWidget(description); + + vlayout->addSpacing(50); + + QVector features = {"✓ REMOTE ACCESS", "✓ 14 DAYS OF STORAGE", "✓ DEVELOPER PERKS"}; + for (auto featureContent : features) { + QLabel* feature = new QLabel(featureContent, this); + feature->setStyleSheet(R"( + font-size: 40px; + )"); + + vlayout->addWidget(feature); + vlayout->addSpacing(15); + } + + setLayout(vlayout); +} + + + +SetupWidget::SetupWidget(QWidget* parent) : QWidget(parent) { + QVBoxLayout* backgroundLayout = new QVBoxLayout(this); + + backgroundLayout->addSpacing(100); + + QFrame* background = new QFrame(this); + + mainLayout = new QStackedLayout(this); + + QWidget* blankWidget = new QWidget(this); + mainLayout->addWidget(blankWidget); + + QWidget* finishRegistration = new QWidget(this); + + QVBoxLayout* finishRegistationLayout = new QVBoxLayout(this); + finishRegistationLayout->addSpacing(50); + QPushButton* finishButton = new QPushButton("Finish registration", this); + finishButton->setFixedHeight(200); + finishButton->setStyleSheet(R"( + border-radius: 30px; + font-size: 60px; + font-weight: bold; + background: #787878; + )"); + QObject::connect(finishButton, SIGNAL(released()), this, SLOT(showQrCode())); + finishRegistationLayout->addWidget(finishButton); + + QLabel* registrationDescription = new QLabel("Pair your comma account with comma connect", this); + registrationDescription->setStyleSheet(R"( + font-size: 50px; + )"); + + registrationDescription->setWordWrap(true); + finishRegistationLayout->addWidget(registrationDescription); + + finishRegistration->setLayout(finishRegistationLayout); + mainLayout->addWidget(finishRegistration); + + QVBoxLayout* qrLayout = new QVBoxLayout(this); + + QLabel* qrLabel = new QLabel("Pair with Comma Connect app!", this); + qrLabel->setStyleSheet(R"( + font-size: 40px; + )"); + qrLayout->addWidget(qrLabel); + + qrLayout->addWidget(new PairingQRWidget(this)); + + QWidget* q = new QWidget(this); + q->setLayout(qrLayout); + mainLayout->addWidget(q); + + PrimeAdWidget* primeAd = new PrimeAdWidget(this); + mainLayout->addWidget(primeAd); + + PrimeUserWidget* primeUserWidget = new PrimeUserWidget(this); + mainLayout->addWidget(primeUserWidget); + + background->setLayout(mainLayout); + background->setStyleSheet(R"( + .QFrame { + border-radius: 40px; + padding: 60px; + } + )"); + backgroundLayout->addWidget(background); + setLayout(backgroundLayout); + + QString dongleId = QString::fromStdString(Params().get("DongleId")); + QString url = "https://api.commadotai.com/v1.1/devices/" + dongleId + "/"; + RequestRepeater* repeater = new RequestRepeater(this, url, 5); + + QObject::connect(repeater, SIGNAL(receivedResponse(QString)), this, SLOT(replyFinished(QString))); + QObject::connect(repeater, SIGNAL(failedResponse(QString)), this, SLOT(parseError(QString))); + +} + +void SetupWidget::parseError(QString response) { + showQr = false; + mainLayout->setCurrentIndex(0); + setStyleSheet(R"( + font-size: 90px; + background-color: #000000; + )"); +} +void SetupWidget::showQrCode(){ + showQr = true; + mainLayout->setCurrentIndex(2); +} +void SetupWidget::replyFinished(QString response) { + QJsonDocument doc = QJsonDocument::fromJson(response.toUtf8()); + if (doc.isNull()) { + qDebug() << "JSON Parse failed on getting pairing and prime status"; + return; + } + if (mainLayout->currentIndex() == 0) { // If we are still on the blank widget + setStyleSheet(R"( + font-size: 90px; + font-weight: bold; + background-color: #292929; + )"); + } + QJsonObject json = doc.object(); + bool is_paired = json["is_paired"].toBool(); + bool is_prime = json["prime"].toBool(); + + if (!is_paired) { + mainLayout->setCurrentIndex(1 + showQr); + } else if (is_paired && !is_prime) { + showQr = false; + mainLayout->setCurrentIndex(3); + } else if (is_paired && is_prime) { + showQr = false; + mainLayout->setCurrentIndex(4); + } +} diff --git a/selfdrive/ui/qt/widgets/setup.hpp b/selfdrive/ui/qt/widgets/setup.hpp new file mode 100644 index 0000000000..0224ace560 --- /dev/null +++ b/selfdrive/ui/qt/widgets/setup.hpp @@ -0,0 +1,60 @@ +#pragma once + +#include +#include +#include +#include + +#include "api.hpp" + +class PairingQRWidget : public QWidget { + Q_OBJECT + +public: + explicit PairingQRWidget(QWidget* parent = 0); + +private: + QLabel* qrCode; + void updateQrCode(QString text); + +private slots: + void refresh(); +}; + +class PrimeUserWidget : public QWidget { + Q_OBJECT +public: + explicit PrimeUserWidget(QWidget* parent = 0); + +private: + QVBoxLayout* mainLayout; + QLabel* username; + QLabel* points; + CommaApi* api; + +private slots: + void replyFinished(QString response); +}; + +class PrimeAdWidget : public QWidget { + Q_OBJECT +public: + explicit PrimeAdWidget(QWidget* parent = 0); +}; + +class SetupWidget : public QWidget { + Q_OBJECT + +public: + explicit SetupWidget(QWidget* parent = 0); + +private: + QStackedLayout* mainLayout; + CommaApi* api; + bool showQr = false; + +private slots: + void parseError(QString response); + void replyFinished(QString response); + void showQrCode(); +};