initial checkin
This commit is contained in:
commit
cb52f6f54e
|
|
@ -0,0 +1,11 @@
|
|||
/target
|
||||
/classes
|
||||
/checkouts
|
||||
pom.xml
|
||||
pom.xml.asc
|
||||
*.jar
|
||||
*.class
|
||||
/.lein-*
|
||||
/.nrepl-port
|
||||
.hgignore
|
||||
.hg/
|
||||
|
|
@ -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
|
||||
|
|
@ -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.
|
||||
|
|
@ -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.
|
||||
|
|
@ -0,0 +1,3 @@
|
|||
# Introduction to flux-led
|
||||
|
||||
TODO: write [great documentation](http://jacobian.org/writing/what-to-write/)
|
||||
|
|
@ -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"]])
|
||||
|
|
@ -0,0 +1,6 @@
|
|||
(ns flux-led.core)
|
||||
|
||||
(defn foo
|
||||
"I don't do a whole lot."
|
||||
[x]
|
||||
(println x "Hello, World!"))
|
||||
|
|
@ -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 (<! measures-chan)]
|
||||
(add-coin-measure measures-agent measure)
|
||||
(recur (<! measures-chan)))
|
||||
(assoc state :measures-agent measures-agent)))
|
||||
|
|
@ -0,0 +1,338 @@
|
|||
(ns fudo.flux-led.core
|
||||
(:require [clojure.core.async :as async :refer [>! <! >!! <!!
|
||||
go go-loop alts!]]
|
||||
[clojure.string :as str]
|
||||
[clojure.java.io :refer [output-stream input-stream]]
|
||||
[clj-time.core :as t]
|
||||
[clj-time.local :as l])
|
||||
(:import (java.net Socket
|
||||
DatagramSocket
|
||||
DatagramPacket
|
||||
InetAddress
|
||||
SocketTimeoutException
|
||||
NetworkInterface)))
|
||||
|
||||
(def colors {:red {:r 255 :g 0 :b 0}
|
||||
:green {:r 0 :g 128 :b 0}
|
||||
:yellow {:r 255 :g 255 :b 0}
|
||||
:purple {:r 128 :g 0 :b 128}
|
||||
:blue {:r 0 :g 0 :b 205}
|
||||
:indigo {:r 75 :g 0 :b 130}
|
||||
:orange {:r 255 :g 165 :b 0}
|
||||
:brown {:r 165 :g 42 :b 42}
|
||||
:pink {:r 255 :g 192 :b 203}
|
||||
:white {:r 255 :g 255 :b 255}
|
||||
:none {:r 0 :g 0 :b 0}})
|
||||
|
||||
(def default-port 5577)
|
||||
|
||||
(def light-patterns {0x25 :seven-color-cross-fade
|
||||
0x26 :red-gradual-change
|
||||
0x27 :green-gradual-change
|
||||
0x28 :blue-gradual-change
|
||||
0x29 :yellow-gradual-change
|
||||
0x2A :cyan-gradual-change
|
||||
0x2B :purple-gradual-change
|
||||
0x2C :white-gradual-change
|
||||
0x2D :red-green-cross-fade
|
||||
0x2E :red-blue-cross-fade
|
||||
0x2F :green-blue-cross-fade
|
||||
0x30 :seven-color-strobe-flash
|
||||
0x31 :red-strobe-flash
|
||||
0x32 :green-strobe-flash
|
||||
0x33 :blue-strobe-flash
|
||||
0x34 :yellow-strobe-flash
|
||||
0x35 :cyan-strobe-flash
|
||||
0x36 :purple-strobe-flash
|
||||
0x37 :white-strobe-flash
|
||||
0x38 :seven-color-jumping})
|
||||
|
||||
(def chan-buffer-size 32)
|
||||
|
||||
(def broadcast-timeout 1000)
|
||||
|
||||
(def default-timeout 100)
|
||||
|
||||
(def flux-broadcast-message "HF-A11ASSISTHREAD")
|
||||
(def flux-broadcast-port 48899)
|
||||
|
||||
(defn ncpus [] (.availableProcessors (Runtime/getRuntime)))
|
||||
|
||||
(defn parallelism [] (+ (ncpus) 2))
|
||||
|
||||
(defn transduce-channel
|
||||
"Return a new channel by applying transducer 'xf' to channel 'chan'."
|
||||
[xf chan] (let [out (async/chan chan-buffer-size)]
|
||||
(async/pipeline (parallelism) out xf chan)
|
||||
out))
|
||||
|
||||
(defn broadcast-addresses! []
|
||||
"Return a list of broadcast addresses for all interfaces"
|
||||
(->> (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 (<! (async/merge (map listen-until-timeout! sockets)))]
|
||||
(>! 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 (<! request-chan)]
|
||||
(>! 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)))
|
||||
|
|
@ -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 )))
|
||||
|
|
@ -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))))
|
||||
Loading…
Reference in New Issue