commit cb52f6f54e023334dd979f638a6239f692eac576 Author: Peter Selby Date: Sat Dec 16 23:24:55 2017 -0800 initial checkin diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..c53038e --- /dev/null +++ b/.gitignore @@ -0,0 +1,11 @@ +/target +/classes +/checkouts +pom.xml +pom.xml.asc +*.jar +*.class +/.lein-* +/.nrepl-port +.hgignore +.hg/ diff --git a/CHANGELOG.md b/CHANGELOG.md new file mode 100644 index 0000000..98a9156 --- /dev/null +++ b/CHANGELOG.md @@ -0,0 +1,24 @@ +# Change Log +All notable changes to this project will be documented in this file. This change log follows the conventions of [keepachangelog.com](http://keepachangelog.com/). + +## [Unreleased] +### Changed +- Add a new arity to `make-widget-async` to provide a different widget shape. + +## [0.1.1] - 2017-12-05 +### Changed +- Documentation on how to make the widgets. + +### Removed +- `make-widget-sync` - we're all async, all the time. + +### Fixed +- Fixed widget maker to keep working when daylight savings switches over. + +## 0.1.0 - 2017-12-05 +### Added +- Files from the new template. +- Widget maker public API - `make-widget-sync`. + +[Unreleased]: https://github.com/your-name/flux-led/compare/0.1.1...HEAD +[0.1.1]: https://github.com/your-name/flux-led/compare/0.1.0...0.1.1 diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..d921d3d --- /dev/null +++ b/LICENSE @@ -0,0 +1,214 @@ +THE ACCOMPANYING PROGRAM IS PROVIDED UNDER THE TERMS OF THIS ECLIPSE PUBLIC +LICENSE ("AGREEMENT"). ANY USE, REPRODUCTION OR DISTRIBUTION OF THE PROGRAM +CONSTITUTES RECIPIENT'S ACCEPTANCE OF THIS AGREEMENT. + +1. DEFINITIONS + +"Contribution" means: + +a) in the case of the initial Contributor, the initial code and +documentation distributed under this Agreement, and + +b) in the case of each subsequent Contributor: + +i) changes to the Program, and + +ii) additions to the Program; + +where such changes and/or additions to the Program originate from and are +distributed by that particular Contributor. A Contribution 'originates' from +a Contributor if it was added to the Program by such Contributor itself or +anyone acting on such Contributor's behalf. Contributions do not include +additions to the Program which: (i) are separate modules of software +distributed in conjunction with the Program under their own license +agreement, and (ii) are not derivative works of the Program. + +"Contributor" means any person or entity that distributes the Program. + +"Licensed Patents" mean patent claims licensable by a Contributor which are +necessarily infringed by the use or sale of its Contribution alone or when +combined with the Program. + +"Program" means the Contributions distributed in accordance with this +Agreement. + +"Recipient" means anyone who receives the Program under this Agreement, +including all Contributors. + +2. GRANT OF RIGHTS + +a) Subject to the terms of this Agreement, each Contributor hereby grants +Recipient a non-exclusive, worldwide, royalty-free copyright license to +reproduce, prepare derivative works of, publicly display, publicly perform, +distribute and sublicense the Contribution of such Contributor, if any, and +such derivative works, in source code and object code form. + +b) Subject to the terms of this Agreement, each Contributor hereby grants +Recipient a non-exclusive, worldwide, royalty-free patent license under +Licensed Patents to make, use, sell, offer to sell, import and otherwise +transfer the Contribution of such Contributor, if any, in source code and +object code form. This patent license shall apply to the combination of the +Contribution and the Program if, at the time the Contribution is added by the +Contributor, such addition of the Contribution causes such combination to be +covered by the Licensed Patents. The patent license shall not apply to any +other combinations which include the Contribution. No hardware per se is +licensed hereunder. + +c) Recipient understands that although each Contributor grants the licenses +to its Contributions set forth herein, no assurances are provided by any +Contributor that the Program does not infringe the patent or other +intellectual property rights of any other entity. Each Contributor disclaims +any liability to Recipient for claims brought by any other entity based on +infringement of intellectual property rights or otherwise. As a condition to +exercising the rights and licenses granted hereunder, each Recipient hereby +assumes sole responsibility to secure any other intellectual property rights +needed, if any. For example, if a third party patent license is required to +allow Recipient to distribute the Program, it is Recipient's responsibility +to acquire that license before distributing the Program. + +d) Each Contributor represents that to its knowledge it has sufficient +copyright rights in its Contribution, if any, to grant the copyright license +set forth in this Agreement. + +3. REQUIREMENTS + +A Contributor may choose to distribute the Program in object code form under +its own license agreement, provided that: + +a) it complies with the terms and conditions of this Agreement; and + +b) its license agreement: + +i) effectively disclaims on behalf of all Contributors all warranties and +conditions, express and implied, including warranties or conditions of title +and non-infringement, and implied warranties or conditions of merchantability +and fitness for a particular purpose; + +ii) effectively excludes on behalf of all Contributors all liability for +damages, including direct, indirect, special, incidental and consequential +damages, such as lost profits; + +iii) states that any provisions which differ from this Agreement are offered +by that Contributor alone and not by any other party; and + +iv) states that source code for the Program is available from such +Contributor, and informs licensees how to obtain it in a reasonable manner on +or through a medium customarily used for software exchange. + +When the Program is made available in source code form: + +a) it must be made available under this Agreement; and + +b) a copy of this Agreement must be included with each copy of the Program. + +Contributors may not remove or alter any copyright notices contained within +the Program. + +Each Contributor must identify itself as the originator of its Contribution, +if any, in a manner that reasonably allows subsequent Recipients to identify +the originator of the Contribution. + +4. COMMERCIAL DISTRIBUTION + +Commercial distributors of software may accept certain responsibilities with +respect to end users, business partners and the like. While this license is +intended to facilitate the commercial use of the Program, the Contributor who +includes the Program in a commercial product offering should do so in a +manner which does not create potential liability for other Contributors. +Therefore, if a Contributor includes the Program in a commercial product +offering, such Contributor ("Commercial Contributor") hereby agrees to defend +and indemnify every other Contributor ("Indemnified Contributor") against any +losses, damages and costs (collectively "Losses") arising from claims, +lawsuits and other legal actions brought by a third party against the +Indemnified Contributor to the extent caused by the acts or omissions of such +Commercial Contributor in connection with its distribution of the Program in +a commercial product offering. The obligations in this section do not apply +to any claims or Losses relating to any actual or alleged intellectual +property infringement. In order to qualify, an Indemnified Contributor must: +a) promptly notify the Commercial Contributor in writing of such claim, and +b) allow the Commercial Contributor to control, and cooperate with the +Commercial Contributor in, the defense and any related settlement +negotiations. The Indemnified Contributor may participate in any such claim +at its own expense. + +For example, a Contributor might include the Program in a commercial product +offering, Product X. That Contributor is then a Commercial Contributor. If +that Commercial Contributor then makes performance claims, or offers +warranties related to Product X, those performance claims and warranties are +such Commercial Contributor's responsibility alone. Under this section, the +Commercial Contributor would have to defend claims against the other +Contributors related to those performance claims and warranties, and if a +court requires any other Contributor to pay any damages as a result, the +Commercial Contributor must pay those damages. + +5. NO WARRANTY + +EXCEPT AS EXPRESSLY SET FORTH IN THIS AGREEMENT, THE PROGRAM IS PROVIDED ON +AN "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, EITHER +EXPRESS OR IMPLIED INCLUDING, WITHOUT LIMITATION, ANY WARRANTIES OR +CONDITIONS OF TITLE, NON-INFRINGEMENT, MERCHANTABILITY OR FITNESS FOR A +PARTICULAR PURPOSE. Each Recipient is solely responsible for determining the +appropriateness of using and distributing the Program and assumes all risks +associated with its exercise of rights under this Agreement , including but +not limited to the risks and costs of program errors, compliance with +applicable laws, damage to or loss of data, programs or equipment, and +unavailability or interruption of operations. + +6. DISCLAIMER OF LIABILITY + +EXCEPT AS EXPRESSLY SET FORTH IN THIS AGREEMENT, NEITHER RECIPIENT NOR ANY +CONTRIBUTORS SHALL HAVE ANY LIABILITY FOR ANY DIRECT, INDIRECT, INCIDENTAL, +SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING WITHOUT LIMITATION +LOST PROFITS), HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN +CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) +ARISING IN ANY WAY OUT OF THE USE OR DISTRIBUTION OF THE PROGRAM OR THE +EXERCISE OF ANY RIGHTS GRANTED HEREUNDER, EVEN IF ADVISED OF THE POSSIBILITY +OF SUCH DAMAGES. + +7. GENERAL + +If any provision of this Agreement is invalid or unenforceable under +applicable law, it shall not affect the validity or enforceability of the +remainder of the terms of this Agreement, and without further action by the +parties hereto, such provision shall be reformed to the minimum extent +necessary to make such provision valid and enforceable. + +If Recipient institutes patent litigation against any entity (including a +cross-claim or counterclaim in a lawsuit) alleging that the Program itself +(excluding combinations of the Program with other software or hardware) +infringes such Recipient's patent(s), then such Recipient's rights granted +under Section 2(b) shall terminate as of the date such litigation is filed. + +All Recipient's rights under this Agreement shall terminate if it fails to +comply with any of the material terms or conditions of this Agreement and +does not cure such failure in a reasonable period of time after becoming +aware of such noncompliance. If all Recipient's rights under this Agreement +terminate, Recipient agrees to cease use and distribution of the Program as +soon as reasonably practicable. However, Recipient's obligations under this +Agreement and any licenses granted by Recipient relating to the Program shall +continue and survive. + +Everyone is permitted to copy and distribute copies of this Agreement, but in +order to avoid inconsistency the Agreement is copyrighted and may only be +modified in the following manner. The Agreement Steward reserves the right to +publish new versions (including revisions) of this Agreement from time to +time. No one other than the Agreement Steward has the right to modify this +Agreement. The Eclipse Foundation is the initial Agreement Steward. The +Eclipse Foundation may assign the responsibility to serve as the Agreement +Steward to a suitable separate entity. Each new version of the Agreement will +be given a distinguishing version number. The Program (including +Contributions) may always be distributed subject to the version of the +Agreement under which it was received. In addition, after a new version of +the Agreement is published, Contributor may elect to distribute the Program +(including its Contributions) under the new version. Except as expressly +stated in Sections 2(a) and 2(b) above, Recipient receives no rights or +licenses to the intellectual property of any Contributor under this +Agreement, whether expressly, by implication, estoppel or otherwise. All +rights in the Program not expressly granted under this Agreement are +reserved. + +This Agreement is governed by the laws of the State of New York and the +intellectual property laws of the United States of America. No party to this +Agreement will bring a legal action under this Agreement more than one year +after the cause of action arose. Each party waives its rights to a jury trial +in any resulting litigation. diff --git a/README.md b/README.md new file mode 100644 index 0000000..39e9118 --- /dev/null +++ b/README.md @@ -0,0 +1,14 @@ +# flux-led + +A Clojure library designed to ... well, that part is up to you. + +## Usage + +FIXME + +## License + +Copyright © 2017 FIXME + +Distributed under the Eclipse Public License either version 1.0 or (at +your option) any later version. diff --git a/doc/intro.md b/doc/intro.md new file mode 100644 index 0000000..4568d60 --- /dev/null +++ b/doc/intro.md @@ -0,0 +1,3 @@ +# Introduction to flux-led + +TODO: write [great documentation](http://jacobian.org/writing/what-to-write/) diff --git a/project.clj b/project.clj new file mode 100644 index 0000000..b926032 --- /dev/null +++ b/project.clj @@ -0,0 +1,13 @@ +(defproject flux-led "0.1.0-SNAPSHOT" + :description "FIXME: write description" + :url "http://example.com/FIXME" + :license {:name "Eclipse Public License" + :url "http://www.eclipse.org/legal/epl-v10.html"} + :dependencies [[org.clojure/clojure "1.9.0"] + [org.clojure/core.async "0.3.465"] + [clj-time "0.14.2"] + [clj-http "3.7.0"] + [tick "0.3.5"] + [org.clojure/data.json "0.2.6"] + [amalloy/ring-buffer "1.2.1"] + [tick "0.3.5"]]) diff --git a/src/flux_led/core.clj b/src/flux_led/core.clj new file mode 100644 index 0000000..40ab23f --- /dev/null +++ b/src/flux_led/core.clj @@ -0,0 +1,6 @@ +(ns flux-led.core) + +(defn foo + "I don't do a whole lot." + [x] + (println x "Hello, World!")) diff --git a/src/fudo/flux_led/coinmarketcap_api.clj b/src/fudo/flux_led/coinmarketcap_api.clj new file mode 100644 index 0000000..952a0dd --- /dev/null +++ b/src/fudo/flux_led/coinmarketcap_api.clj @@ -0,0 +1,127 @@ +(ns fudo.flux-led.coinmarketcap-api + (:require [clj-http.client :as http] + [clojure.data.json :as json] + [clj-time.coerce :as time-coerce] + [clojure.core.async :as async :refer [! >!! + go thread go-loop]] + [amalloy.ring-buffer :as ring] + [tick.core :refer [minutes]] + [tick.timeline :refer [timeline periodic-seq]] + [tick.clock :refer [now] :as clock] + [tick.schedule :as schedule])) + +(def base-url "https://api.coinmarketcap.com/v1/") + +(def ring-size 1000) + +(def interesting-coins [:bitcoin + :ethereum + :bitcoin-cash + :litecoin + :cardano + :bitcoin-gold + :monero]) + +(defn- list-keys [obj] + (cond (map? obj) (into #{} (keys obj)) + (coll? obj) (apply clojure.set/union (map list-keys obj)) + :else #{})) + +(let [key-types { + :percent_change_7d :float + :available_supply :float + :price_usd :float + :symbol :keyword + :name :string + :market_cap_usd :float + :rank :int + :last_updated :time + :total_supply :float + :24h_volume_usd :float + :max_supply :float + :price_btc :float + :id :keyword + :percent_change_1h :float + :percent_change_24h :float + }] + (defn consider-converting [key obj] + (if-let [type (key key-types)] + (try + (case type + :float (BigDecimal. obj) + :string obj + :int (biginteger obj) + :time (time-coerce/from-long (* 1000 (Long. obj))) + :keyword (keyword obj)) + (catch Exception _ + nil)) + obj))) + +(defn- sanitize + ([key val] (let [kw (keyword key)] + (cond (map? val) [kw (map sanitize val)] + (coll? val) [kw (map sanitize val)] + :else [kw (consider-converting kw val)]))) + ([obj] + (cond (map? obj) (into {} + (map (fn [[key val]] + [(keyword key) + (consider-converting (keyword key) val)]) + obj)) + (coll? obj) (map sanitize obj) + :else obj))) + +(defn get-coin [coin] + (let [coin-name (name coin) + coin-url (str base-url "ticker/" coin-name "/")] + (sanitize (first (json/read-str (:body (http/get coin-url))))))) + +(defn get-coins [& [limit]] + (let [coins-url (if limit + (str base-url "ticker/?limit=" limit) + (str base-url "ticker/"))] + (sanitize (json/read-str (:body (http/get coins-url)))))) + +(defn coins-summary [] + (let [global-url (str base-url "global/")] + (sanitize (json/read-str (:body (http/get global-url)))))) + +(defn start-collector [interesting-coins timing] + (let [measures-chan (async/chan + (async/sliding-buffer + (count interesting-coins))) + build-measure-fetcher (fn [coin-id] + (fn [time] + (>!! measures-chan + (get-coin coin-id)))) + fetch-schedules (map (fn [coin-id] + { + :coin-id coin-id + :schedule (schedule/schedule + (build-measure-fetcher coin-id) + (timeline (periodic-seq (now) + timing))) + }) + interesting-coins)] + (doseq [{schedule :schedule} fetch-schedules] + (thread (schedule/start schedule (clock/clock-ticking-in-seconds)))) + {:measures-chan measures-chan :schedules fetch-schedules})) + +(defn coin-measures [{agent :measures-agent} coin] + (get @agent coin [])) + +(defn- add-coin-measure [agent measure] + (send agent (fn [measures] + (assoc measures + (:id measure) + (conj (get measures + (:id measure) + (ring/ring-buffer ring-size)) + measure))))) + +(defn listen-for-measures [{measures-chan :measures-chan :as state}] + (let [measures-agent (agent {})] + (go-loop [measure (! !! > (enumeration-seq (NetworkInterface/getNetworkInterfaces)) + (filter #(and (.isUp %) (not (.isLoopback %)))) + (mapcat #(.getInterfaceAddresses %)) + (map #(.getBroadcast %)) + (filter some?))) + +(defn broadcast-address-count! [] (count (broadcast-addresses!))) + +(defn datagram-socket [timeout] + (doto (DatagramSocket.) + (.setBroadcast true) + (.setSoTimeout timeout))) + +(defn datagram-packet + ([] (datagram-packet 64)) + ([len] (DatagramPacket. (byte-array len) len)) + ([message ^InetAddress addr port] + (DatagramPacket. (.getBytes message) + (count message) + addr + port))) + +(defn send! [packet timeout] + (let [socket (datagram-socket timeout)] + (.send socket packet) + socket)) + +(defn debug-listen! [port] + (let [server (DatagramSocket. port)] + (async/thread + (while true (let [packet (java.net.DatagramPacket. + (make-array Byte/TYPE 512) + 512)] + (.receive server packet) + (println (String. (.getData packet)))))))) + +(defn send-broadcast! [message port timeout] + (map #(send! (datagram-packet message % port) timeout) + (broadcast-addresses!))) + +(defn listen-until-timeout! [^DatagramSocket socket] + (let [output-chan (async/chan chan-buffer-size)] + (async/go + (while (not (.isClosed socket)) + (let [receive-packet (datagram-packet)] + (try (do (.receive socket receive-packet) + (>! output-chan (String. (.getData receive-packet)))) + (catch SocketTimeoutException _)))) + (async/close! output-chan)) + output-chan)) + +(defn broadcast-and-listen! [message port & [chan-size]] + (let [timeout broadcast-timeout + sockets (send-broadcast! message port timeout) + out-chan (async/chan (or chan-size chan-buffer-size))] + (go-loop [response (! out-chan response)) + out-chan)) + +(defn parse-flux-broadcast-response [response] + (let [parse-response (fn [message] + (let [[ip id model] (str/split message #",")] + {:ip (InetAddress/getByName ip) + :id id + :model model}))] + (->> response + (remove (comp zero? int)) + (clojure.string/join) + (parse-response)))) + +(defn flux-scan-for-devices! [] + (let [response-chan (async/chan (broadcast-address-count!)) + request-chan (broadcast-and-listen! flux-broadcast-message + flux-broadcast-port + (broadcast-address-count!))] + (go-loop [response (! response-chan (parse-flux-broadcast-response response))) + response-chan)) + +(defn unsigned-get-idx [^bytes array idx] + (bit-and (aget array idx) 0xFF)) + +(defn with-checksum [^bytes bytes] + (let [bytes-vec (vec bytes) + cs (reduce + bytes-vec)] + (byte-array (concat bytes-vec [cs])))) + +(defn send-command [{ip :ip + port :port + command :command + timeout :timeout + response-length :response-length + :or {port default-port + timeout default-timeout}}] + (let [cmd-bytes (with-checksum (byte-array command))] + (with-open [socket (doto (Socket. ip port) + (.setSoTimeout timeout)) + output (output-stream socket) + input (input-stream socket)] + (.write output cmd-bytes) + (.flush output) + (when response-length + (let [buffer (byte-array response-length)] + (.read input buffer response-length) + (String. buffer)))))) + +(defn change-power-state [{on :on :as state}] + (let [cmd [0x71 (if on 0x23 0x24) 0x0F]] + (send-command (assoc state :command cmd)))) + +(defn power-on [state] + (change-power-state (assoc state :on true))) + +(defn power-off [state] + (change-power-state (assoc state :on false))) + +(defn percent->byte [pct] + (if (or (> pct 100) (< pct 0)) + (throw (RuntimeException. (str "Not a percentange: " pct))) + (int (/ (* pct 255) 100)))) + +(defn persist-byte [{persist :persist}] + (if persist 0x31 0x41)) + +(defn rgb [{r :r + g :g + b :b + persist :persist + :as state}] + (send-command (assoc state :command + [(persist-byte state) r g b 0x00 0xF0 0x0F]))) + +(defn warm-white [{brightness :brightness :as state}] + (send-command (assoc state + :command (concat [(persist-byte state)] + [0x00 0x00 0x00] + [(percent->byte brightness)] + [0x0F 0x0F])))) + +(defn valid-state? [pattern] + (let [pattern-ids (set (keys light-patterns))] + (pattern-ids pattern))) + +(defn power-state [resp] + (condp = (unsigned-get-idx resp 2) + 0x23 :on + 0x24 :off + (throw (RuntimeException. "Unrecognized power state.")))) + +(defn bulb-mode-state [resp] + (let [pattern (unsigned-get-idx resp 3) + warm-white-level (unsigned-get-idx resp 9)] + (cond + (#{0x61 0x62} pattern) (if (not (zero? warm-white-level)) + :warm-white + :color) + (= 0x60 pattern) :custom + (valid-state? pattern) :preset + :else :unknown))) + +(defn pattern-speed-state [resp] + (let [raw-delay (dec (unsigned-get-idx resp 5)) + max-delay (dec 0x1F) + delay (-> raw-delay (max 0) (min max-delay))] + (- 100 (int (/ (* delay 100) max-delay))))) + +(defn rgb-state [resp] + (let [[r g b] (mapv #(unsigned-get-idx resp %) (range 6 9))] + {:r r :g g :b b})) + +(defn warm-white-state [resp] + (let [warm-white-raw (unsigned-get-idx resp 9) + warm-white-norm (-> warm-white-raw (max 0) (min 255))] + (int (Math/ceil (/ (* warm-white-norm 100) 255))))) + +(defn pattern-state [resp] + (let [pattern (unsigned-get-idx resp 3)] + (get light-patterns pattern))) + +(defn bulb-state [resp] + {:power (power-state resp) + :mode (bulb-mode-state resp) + :speed (pattern-speed-state resp) + :rgb (rgb-state resp) + :warm-white-pct (warm-white-state resp) + :pattern (pattern-state resp)}) + +(defn get-bulb-state [state] + (-> (send-command (assoc state + :command [0x81 0x8A 0x8B] + :response-length 14)) + (bulb-state))) + +(defn get-clock-state [state] + (let [clock-resp (send-command (assoc state + :command [0x11 0x1A 0x1B 0x0F] + :response-length 12)) + time-components (map #(unsigned-get-idx % clock-resp) + (range 3 9))] + (update (zipmap [:year :month :day :hour :minute :second] + time-components) + :year + #(+ 2000 %)))) + +(defn synchronize-clock [state] + (let [encoded-time ((juxt #(- (t/year %) 2000) + t/month + t/day + t/hour + t/minute + t/second + t/day-of-week) (l/local-now))] + (send-command (assoc state + :command (concat [0x10 0x14] + encoded-time + [0x00 0x0F]))))) + +(defn bytes->timer [bytes] + (let [[active-mask + year + month + day + hour + minute + repeat-mask + pattern-code + delay] + (map (partial nth bytes) (range 0 10))] + {:active? (= 0xF0 active-mask) + :year (+ year 2000) + :month month + :day day + :hour hour + :minute minute + :pattern-code pattern-code + :mode (condp = pattern-code + 0x61 :color + 0x00 :default + :preset) + :rgb (mapv #(nth bytes %) [9 10 11]) + :delay delay})) + +(defn get-timers [state] + (let [resp-len 88 + timer-len 14 + resp (send-command (assoc state + :command [0x22 0x2A 0x2B 0xF0] + :response-length resp-len))] + (->> (partition timer-len (range 2 (inc resp-len))) + (map (fn [offsets] (mapv #(unsigned-get-idx %) offsets))) + (map bytes->timer)))) + +(defn pulse [req & [color]] + (let [rgb-fn (fn [] (rgb (merge req (get colors color :blue)))) + off-fn (fn [] (rgb (merge req (:none colors)))) + sleep-fn (fn [] (Thread/sleep 1000))] + (map (fn [f] + (f)) + (interpose sleep-fn (flatten (repeat [rgb-fn off-fn])))))) + +;; (defn bulb-mode-state [resp] +;; (let [pattern (get-unsigned-byte resp 3) +;; ww-level (get-unsigned-byte resp 9)] +;; (cond +;; (#{0x61 0x62} pattern) (if (not (zero? ww-level)) :warm-white :color) +;; (= 0x60 pattern) :custom +;; (valid? pattern) :preset +;; :else :unknown))) diff --git a/src/fudo/flux_led/spec.clj b/src/fudo/flux_led/spec.clj new file mode 100644 index 0000000..ea65995 --- /dev/null +++ b/src/fudo/flux_led/spec.clj @@ -0,0 +1,56 @@ +(ns fudo.flux-led.spec + (require [clojure.spec.alpha :as s])) + +(def byte? [i] + (and (int? i) + (>= i 0) + (< i 256))) + +(def ip? [val] + (instance? java.net.InetAddress val)) + +(def pct? [val] + (and (int? i) + (>= i 0) + (<= i 100))) + +(def port? [val] + (and (int? val) + (>= 0 val) + (< 65536))) + +(s/def :flux/red byte?) +(s/def :flux/green byte?) +(s/def :flux/blue byte?) +(s/def :flux/color ...) + +(s/def :flux/warm-white-level pct?) +(s/def :flux/cool-white-level pct?) + +(s/def :flux/pattern valid-pattern?) + +(s/def ::ip ip?) + +(s/def ::port port?) + +(s/def :flux/id string?) + +(s/def :flux/model string?) + +(s/def :flux/device + (s/keys* :req [::ip :flux/id :flux/model] + :opt [::port])) + +(s/def :flux/color (s/keys [:flux/red :flux/green :flux/blue])) + +(defmulti device-state :flux/state-type) +(defmethod device-state :flux/state-rgb [_] + (s/keys :req [:flux/red :flux/green :flux/blue])) +(defmethod device-state :flux/warm-white [_] + (s/keys :req [:flux/warm-white-level])) +(defmethod device-state :flux/cool-white [_] + (s/keys :req [:flux/pattern])) + +(s/def :flux/device-state + (s/merge :flux/device + (s/keys ))) diff --git a/test/flux_led/core_test.clj b/test/flux_led/core_test.clj new file mode 100644 index 0000000..0c2c87a --- /dev/null +++ b/test/flux_led/core_test.clj @@ -0,0 +1,7 @@ +(ns flux-led.core-test + (:require [clojure.test :refer :all] + [flux-led.core :refer :all])) + +(deftest a-test + (testing "FIXME, I fail." + (is (= 0 1))))