add man page for bluetooth, fix bluetooth race-condition

src/modules/bluetooth.cpp

@@ -3,20 +3,24 @@
 #include <linux/rfkill.h>
 #include <time.h>
 
-#include <iostream>
-
 waybar::modules::Bluetooth::Bluetooth(const std::string& id, const Json::Value& config)
-    : ALabel(config, "bluetooth", id, "{status}", 10),
+    : ALabel(config, "bluetooth", id, "{icon}", 10),
       status_("disabled"),
-      rfkill_(*(new waybar::util::Rfkill(RFKILL_TYPE_BLUETOOTH))) {
+      rfkill_{RFKILL_TYPE_BLUETOOTH} {
   thread_ = [this] {
     dp.emit();
     rfkill_.waitForEvent();
   };
+  intervall_thread_ = [this] {
+    auto now = std::chrono::system_clock::now();
+    auto timeout = std::chrono::floor<std::chrono::seconds>(now + interval_);
+    auto diff = std::chrono::seconds(timeout.time_since_epoch().count() % interval_.count());
+    thread_.sleep_until(timeout - diff);
+    dp.emit();
+  };
 }
 
 auto waybar::modules::Bluetooth::update() -> void {
-  status_ = "enabled";
   if (rfkill_.getState()) {
     status_ = "disabled";
   } else {
@@ -24,16 +28,18 @@ auto waybar::modules::Bluetooth::update() -> void {
   }
 
   label_.set_markup(
-      fmt::format(format_, fmt::arg("status", status_), fmt::arg("icon", getIcon(0, status_))));
-  label_.get_style_context()->add_class(status_);
+      fmt::format(
+        format_,
+        fmt::arg("status", status_),
+        fmt::arg("icon", getIcon(0, status_))));
 
-  //if (tooltipEnabled()) {
-    //if (config_["tooltip-format"].isString()) {
-      //auto tooltip_format = config_["tooltip-format"].asString();
-      ////auto tooltip_text = fmt::format(tooltip_format, localtime);
-      //label_.set_tooltip_text(tooltip_text);
-    //} else {
-      //label_.set_tooltip_text(status_);
-    //}
-  //}
+  if (tooltipEnabled()) {
+    if (config_["tooltip-format"].isString()) {
+      auto tooltip_format = config_["tooltip-format"].asString();
+      auto tooltip_text = fmt::format(tooltip_format, status_);
+      label_.set_tooltip_text(tooltip_text);
+    } else {
+      label_.set_tooltip_text(status_);
+    }
+  }
 }

src/modules/network.cpp

@@ -3,9 +3,9 @@
 #include <sys/eventfd.h>
 #include <fstream>
 #include <cassert>
+#include <linux/rfkill.h>
 #include "util/format.hpp"
 #include "util/rfkill.hpp"
-#include <linux/rfkill.h>
 
 namespace {
 
@@ -88,8 +88,7 @@ waybar::modules::Network::Network(const std::string &id, const Json::Value &conf
       signal_strength_dbm_(0),
       signal_strength_(0),
       frequency_(0),
-      rfkill_(*(new waybar::util::Rfkill(RFKILL_TYPE_WLAN))) {
-
+      rfkill_{RFKILL_TYPE_WLAN} {
   auto down_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_DOWN_TOTAL_KEY);
   auto up_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_UP_TOTAL_KEY);
   if (down_octets) {
@@ -199,6 +198,7 @@ void waybar::modules::Network::createInfoSocket() {
 }
 
 void waybar::modules::Network::worker() {
+  // update via here not working
   thread_timer_ = [this] {
     {
       std::lock_guard<std::mutex> lock(mutex_);
@@ -209,6 +209,16 @@ void waybar::modules::Network::worker() {
     }
     thread_timer_.sleep_for(interval_);
   };
+  thread_rfkill_ = [this] {
+    rfkill_.waitForEvent();
+    {
+      std::lock_guard<std::mutex> lock(mutex_);
+      if (ifid_ > 0) {
+        getInfo();
+        dp.emit();
+      }
+    }
+  };
   thread_ = [this] {
     std::array<struct epoll_event, EPOLL_MAX> events{};
 
@@ -226,7 +236,7 @@ void waybar::modules::Network::worker() {
 
 const std::string waybar::modules::Network::getNetworkState() const {
   if (ifid_ == -1) {
-    if (rfkill_.isDisabled())
+    if (rfkill_.getState())
       return "disabled";
     return "disconnected";
   }

src/util/rfkill.cpp

@@ -1,11 +1,12 @@
 #include "util/rfkill.hpp"
+#include <linux/rfkill.h>
 #include <unistd.h>
 #include <stdlib.h>
 #include <cstring>
 #include <fcntl.h>
 #include <sys/poll.h>
 #include <cerrno>
-#include <stdio.h>
+#include <stdexcept>
 
 waybar::util::Rfkill::Rfkill(const enum rfkill_type rfkill_type)
   : rfkill_type_(rfkill_type) {
@@ -19,7 +20,7 @@ void waybar::util::Rfkill::waitForEvent() {
 
   fd = open("/dev/rfkill", O_RDONLY);
   if (fd < 0) {
-    //perror("Can't open RFKILL control device");
+    throw std::runtime_error("Can't open RFKILL control device");
     return;
   }
 
@@ -30,7 +31,7 @@ void waybar::util::Rfkill::waitForEvent() {
   while (1) {
     n = poll(&p, 1, -1);
     if (n < 0) {
-      //perror("Failed to poll RFKILL control device");
+      throw std::runtime_error("Failed to poll RFKILL control device");
       break;
     }
 
@@ -39,22 +40,18 @@ void waybar::util::Rfkill::waitForEvent() {
 
     len = read(fd, &event, sizeof(event));
     if (len < 0) {
-      //perror("Reading of RFKILL events failed");
+      throw std::runtime_error("Reading of RFKILL events failed");
       break;
     }
 
     if (len != RFKILL_EVENT_SIZE_V1) {
-      //fprintf(stderr, "Wrong size of RFKILL event\n");
+      throw std::runtime_error("Wrong size of RFKILL event");
       continue;
     }
 
-    if(event.type == rfkill_type_) {
+    if(event.type == rfkill_type_ && event.op == RFKILL_OP_CHANGE) {
       state_ = event.soft || event.hard;
-      if (prev_state_ != state_) {
-        prev_state_ = state_;
-        break;
-      }
-      //ret = event.soft || event.hard;
+      break;
     }
   }
 
@@ -63,49 +60,6 @@ void waybar::util::Rfkill::waitForEvent() {
 }
 
 
-int waybar::util::Rfkill::getState() {
+int waybar::util::Rfkill::getState() const {
   return state_;
 }
-
-bool waybar::util::Rfkill::isDisabled() const {
-  struct rfkill_event event;
-  ssize_t len;
-  int fd;
-  int ret;
-  ret = false;
-
-  fd = open("/dev/rfkill", O_RDONLY);
-  if (fd < 0) {
-    //perror("Can't open RFKILL control device");
-    return false;
-  }
-
-  if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0) {
-    //perror("Can't set RFKILL control device to non-blocking");
-    close(fd);
-    return false;
-  }
-
-  while(true) {
-    len = read(fd, &event, sizeof(event));
-    if (len < 0) {
-      if (errno == EAGAIN)
-        return 1;
-      //perror("Reading of RFKILL events failed");
-      return false;
-    }
-
-    if (len != RFKILL_EVENT_SIZE_V1) {
-      //fprintf(stderr, "Wrong size of RFKILL event\n");
-      return false;
-    }
-
-    if(event.type == rfkill_type_) {
-      ret = event.soft || event.hard;
-      break;
-    }
-  }
-
-  close(fd);
-  return ret;
-}