Compare commits
2 commits
master
...
7ccfc3091e
| Author | SHA1 | Date | |
|---|---|---|---|
| 7ccfc3091e | |||
| 653c132672 |
24 changed files with 456 additions and 1143 deletions
5
.gitignore
vendored
5
.gitignore
vendored
|
|
@ -1,2 +1,7 @@
|
|||
__pycache__
|
||||
node_modules/
|
||||
|
||||
|
||||
# Added by cargo
|
||||
|
||||
/target
|
||||
|
|
|
|||
390
Cargo.lock
generated
Normal file
390
Cargo.lock
generated
Normal file
|
|
@ -0,0 +1,390 @@
|
|||
# This file is automatically @generated by Cargo.
|
||||
# It is not intended for manual editing.
|
||||
version = 3
|
||||
|
||||
[[package]]
|
||||
name = "anyhow"
|
||||
version = "1.0.51"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8b26702f315f53b6071259e15dd9d64528213b44d61de1ec926eca7715d62203"
|
||||
|
||||
[[package]]
|
||||
name = "async-trait"
|
||||
version = "0.1.52"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "061a7acccaa286c011ddc30970520b98fa40e00c9d644633fb26b5fc63a265e3"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"syn",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "autocfg"
|
||||
version = "1.0.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "cdb031dd78e28731d87d56cc8ffef4a8f36ca26c38fe2de700543e627f8a464a"
|
||||
|
||||
[[package]]
|
||||
name = "bitflags"
|
||||
version = "1.3.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
|
||||
|
||||
[[package]]
|
||||
name = "bytes"
|
||||
version = "1.1.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "c4872d67bab6358e59559027aa3b9157c53d9358c51423c17554809a8858e0f8"
|
||||
dependencies = [
|
||||
"serde",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "candela"
|
||||
version = "0.2.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "0d631822edd8b6f9f71ed5a62a55524971bd97c9b0f262756cc26323272fa248"
|
||||
dependencies = [
|
||||
"async-trait",
|
||||
"bytes",
|
||||
"prost",
|
||||
"prost-build",
|
||||
"serde",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "cfg-if"
|
||||
version = "1.0.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
|
||||
|
||||
[[package]]
|
||||
name = "either"
|
||||
version = "1.6.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "e78d4f1cc4ae33bbfc157ed5d5a5ef3bc29227303d595861deb238fcec4e9457"
|
||||
|
||||
[[package]]
|
||||
name = "fixedbitset"
|
||||
version = "0.2.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "37ab347416e802de484e4d03c7316c48f1ecb56574dfd4a46a80f173ce1de04d"
|
||||
|
||||
[[package]]
|
||||
name = "getrandom"
|
||||
version = "0.2.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "7fcd999463524c52659517fe2cea98493cfe485d10565e7b0fb07dbba7ad2753"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
"libc",
|
||||
"wasi",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "hashbrown"
|
||||
version = "0.11.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ab5ef0d4909ef3724cc8cce6ccc8572c5c817592e9285f5464f8e86f8bd3726e"
|
||||
|
||||
[[package]]
|
||||
name = "heck"
|
||||
version = "0.3.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "6d621efb26863f0e9924c6ac577e8275e5e6b77455db64ffa6c65c904e9e132c"
|
||||
dependencies = [
|
||||
"unicode-segmentation",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "indexmap"
|
||||
version = "1.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "bc633605454125dec4b66843673f01c7df2b89479b32e0ed634e43a91cff62a5"
|
||||
dependencies = [
|
||||
"autocfg",
|
||||
"hashbrown",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "itertools"
|
||||
version = "0.9.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "284f18f85651fe11e8a991b2adb42cb078325c996ed026d994719efcfca1d54b"
|
||||
dependencies = [
|
||||
"either",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "lazy_static"
|
||||
version = "1.4.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646"
|
||||
|
||||
[[package]]
|
||||
name = "leds"
|
||||
version = "0.1.0"
|
||||
dependencies = [
|
||||
"candela",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "libc"
|
||||
version = "0.2.112"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "1b03d17f364a3a042d5e5d46b053bbbf82c92c9430c592dd4c064dc6ee997125"
|
||||
|
||||
[[package]]
|
||||
name = "log"
|
||||
version = "0.4.14"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "51b9bbe6c47d51fc3e1a9b945965946b4c44142ab8792c50835a980d362c2710"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "multimap"
|
||||
version = "0.8.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "e5ce46fe64a9d73be07dcbe690a38ce1b293be448fd8ce1e6c1b8062c9f72c6a"
|
||||
|
||||
[[package]]
|
||||
name = "petgraph"
|
||||
version = "0.5.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "467d164a6de56270bd7c4d070df81d07beace25012d5103ced4e9ff08d6afdb7"
|
||||
dependencies = [
|
||||
"fixedbitset",
|
||||
"indexmap",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "ppv-lite86"
|
||||
version = "0.2.15"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ed0cfbc8191465bed66e1718596ee0b0b35d5ee1f41c5df2189d0fe8bde535ba"
|
||||
|
||||
[[package]]
|
||||
name = "proc-macro2"
|
||||
version = "1.0.34"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "2f84e92c0f7c9d58328b85a78557813e4bd845130db68d7184635344399423b1"
|
||||
dependencies = [
|
||||
"unicode-xid",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "prost"
|
||||
version = "0.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "9e6984d2f1a23009bd270b8bb56d0926810a3d483f59c987d77969e9d8e840b2"
|
||||
dependencies = [
|
||||
"bytes",
|
||||
"prost-derive",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "prost-build"
|
||||
version = "0.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "32d3ebd75ac2679c2af3a92246639f9fcc8a442ee420719cc4fe195b98dd5fa3"
|
||||
dependencies = [
|
||||
"bytes",
|
||||
"heck",
|
||||
"itertools",
|
||||
"log",
|
||||
"multimap",
|
||||
"petgraph",
|
||||
"prost",
|
||||
"prost-types",
|
||||
"tempfile",
|
||||
"which",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "prost-derive"
|
||||
version = "0.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "169a15f3008ecb5160cba7d37bcd690a7601b6d30cfb87a117d45e59d52af5d4"
|
||||
dependencies = [
|
||||
"anyhow",
|
||||
"itertools",
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"syn",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "prost-types"
|
||||
version = "0.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b518d7cdd93dab1d1122cf07fa9a60771836c668dde9d9e2a139f957f0d9f1bb"
|
||||
dependencies = [
|
||||
"bytes",
|
||||
"prost",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "quote"
|
||||
version = "1.0.10"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "38bc8cc6a5f2e3655e0899c1b848643b2562f853f114bfec7be120678e3ace05"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "rand"
|
||||
version = "0.8.4"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "2e7573632e6454cf6b99d7aac4ccca54be06da05aca2ef7423d22d27d4d4bcd8"
|
||||
dependencies = [
|
||||
"libc",
|
||||
"rand_chacha",
|
||||
"rand_core",
|
||||
"rand_hc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "rand_chacha"
|
||||
version = "0.3.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "e6c10a63a0fa32252be49d21e7709d4d4baf8d231c2dbce1eaa8141b9b127d88"
|
||||
dependencies = [
|
||||
"ppv-lite86",
|
||||
"rand_core",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "rand_core"
|
||||
version = "0.6.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "d34f1408f55294453790c48b2f1ebbb1c5b4b7563eb1f418bcfcfdbb06ebb4e7"
|
||||
dependencies = [
|
||||
"getrandom",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "rand_hc"
|
||||
version = "0.3.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "d51e9f596de227fda2ea6c84607f5558e196eeaf43c986b724ba4fb8fdf497e7"
|
||||
dependencies = [
|
||||
"rand_core",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "redox_syscall"
|
||||
version = "0.2.10"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8383f39639269cde97d255a32bdb68c047337295414940c68bdd30c2e13203ff"
|
||||
dependencies = [
|
||||
"bitflags",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "remove_dir_all"
|
||||
version = "0.5.3"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "3acd125665422973a33ac9d3dd2df85edad0f4ae9b00dafb1a05e43a9f5ef8e7"
|
||||
dependencies = [
|
||||
"winapi",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "serde"
|
||||
version = "1.0.132"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8b9875c23cf305cd1fd7eb77234cbb705f21ea6a72c637a5c6db5fe4b8e7f008"
|
||||
dependencies = [
|
||||
"serde_derive",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "serde_derive"
|
||||
version = "1.0.132"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ecc0db5cb2556c0e558887d9bbdcf6ac4471e83ff66cf696e5419024d1606276"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"syn",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "syn"
|
||||
version = "1.0.83"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "23a1dfb999630e338648c83e91c59a4e9fb7620f520c3194b6b89e276f2f1959"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"unicode-xid",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tempfile"
|
||||
version = "3.2.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "dac1c663cfc93810f88aed9b8941d48cabf856a1b111c29a40439018d870eb22"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
"libc",
|
||||
"rand",
|
||||
"redox_syscall",
|
||||
"remove_dir_all",
|
||||
"winapi",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "unicode-segmentation"
|
||||
version = "1.8.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8895849a949e7845e06bd6dc1aa51731a103c42707010a5b591c0038fb73385b"
|
||||
|
||||
[[package]]
|
||||
name = "unicode-xid"
|
||||
version = "0.2.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8ccb82d61f80a663efe1f787a51b16b5a51e3314d6ac365b08639f52387b33f3"
|
||||
|
||||
[[package]]
|
||||
name = "wasi"
|
||||
version = "0.10.2+wasi-snapshot-preview1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "fd6fbd9a79829dd1ad0cc20627bf1ed606756a7f77edff7b66b7064f9cb327c6"
|
||||
|
||||
[[package]]
|
||||
name = "which"
|
||||
version = "4.2.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ea187a8ef279bc014ec368c27a920da2024d2a711109bfbe3440585d5cf27ad9"
|
||||
dependencies = [
|
||||
"either",
|
||||
"lazy_static",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "winapi"
|
||||
version = "0.3.9"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419"
|
||||
dependencies = [
|
||||
"winapi-i686-pc-windows-gnu",
|
||||
"winapi-x86_64-pc-windows-gnu",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "winapi-i686-pc-windows-gnu"
|
||||
version = "0.4.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6"
|
||||
|
||||
[[package]]
|
||||
name = "winapi-x86_64-pc-windows-gnu"
|
||||
version = "0.4.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
|
||||
9
Cargo.toml
Normal file
9
Cargo.toml
Normal file
|
|
@ -0,0 +1,9 @@
|
|||
[package]
|
||||
name = "leds"
|
||||
version = "0.1.0"
|
||||
edition = "2021"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
[dependencies]
|
||||
candela = "0.2.1"
|
||||
|
|
@ -1,9 +0,0 @@
|
|||
{
|
||||
"leds": 450,
|
||||
"brightness": 150,
|
||||
"gpio": 18,
|
||||
"type": "grb",
|
||||
"fade_ticks": 25,
|
||||
"sleep_time": 100,
|
||||
"log_level": "INFO"
|
||||
}
|
||||
18
index.js
18
index.js
|
|
@ -1,18 +0,0 @@
|
|||
import * as server from './server.js';
|
||||
import * as lights from './lights.js';
|
||||
import * as fs from 'fs';
|
||||
|
||||
const cfg = JSON.parse(fs.readFileSync('./config.json'));
|
||||
|
||||
server.recv(
|
||||
(res) => {
|
||||
lights.set_pattern(JSON.parse(res));
|
||||
},
|
||||
(res) => {
|
||||
console.log(`error callback: ${res}`);
|
||||
}
|
||||
);
|
||||
|
||||
setInterval(() => {
|
||||
lights.tick();
|
||||
}, cfg.sleep_time || 500);
|
||||
235
lcd_manager.py
235
lcd_manager.py
|
|
@ -1,235 +0,0 @@
|
|||
from time import sleep
|
||||
|
||||
|
||||
class Adafruit_CharLCD:
|
||||
|
||||
# commands
|
||||
LCD_CLEARDISPLAY = 0x01
|
||||
LCD_RETURNHOME = 0x02
|
||||
LCD_ENTRYMODESET = 0x04
|
||||
LCD_DISPLAYCONTROL = 0x08
|
||||
LCD_CURSORSHIFT = 0x10
|
||||
LCD_FUNCTIONSET = 0x20
|
||||
LCD_SETCGRAMADDR = 0x40
|
||||
LCD_SETDDRAMADDR = 0x80
|
||||
|
||||
# flags for display entry mode
|
||||
LCD_ENTRYRIGHT = 0x00
|
||||
LCD_ENTRYLEFT = 0x02
|
||||
LCD_ENTRYSHIFTINCREMENT = 0x01
|
||||
LCD_ENTRYSHIFTDECREMENT = 0x00
|
||||
|
||||
# flags for display on/off control
|
||||
LCD_DISPLAYON = 0x04
|
||||
LCD_DISPLAYOFF = 0x00
|
||||
LCD_CURSORON = 0x02
|
||||
LCD_CURSOROFF = 0x00
|
||||
LCD_BLINKON = 0x01
|
||||
LCD_BLINKOFF = 0x00
|
||||
|
||||
# flags for display/cursor shift
|
||||
LCD_DISPLAYMOVE = 0x08
|
||||
LCD_CURSORMOVE = 0x00
|
||||
|
||||
# flags for display/cursor shift
|
||||
LCD_DISPLAYMOVE = 0x08
|
||||
LCD_CURSORMOVE = 0x00
|
||||
LCD_MOVERIGHT = 0x04
|
||||
LCD_MOVELEFT = 0x00
|
||||
|
||||
# flags for function set
|
||||
LCD_8BITMODE = 0x10
|
||||
LCD_4BITMODE = 0x00
|
||||
LCD_2LINE = 0x08
|
||||
LCD_1LINE = 0x00
|
||||
LCD_5x10DOTS = 0x04
|
||||
LCD_5x8DOTS = 0x00
|
||||
|
||||
def __init__(self, pin_rs=24, pin_e=23, pin_b=4, pins_db=[17, 25, 27, 22], GPIO=None):
|
||||
# Emulate the old behavior of using RPi.GPIO if we haven't been given
|
||||
# an explicit GPIO interface to use
|
||||
if not GPIO:
|
||||
import RPi.GPIO as GPIO
|
||||
self.GPIO = GPIO
|
||||
self.pin_rs = pin_rs
|
||||
self.pin_e = pin_e
|
||||
self.pin_b = pin_b
|
||||
self.pins_db = pins_db
|
||||
|
||||
self.GPIO.setwarnings(False)
|
||||
self.GPIO.setmode(GPIO.BCM)
|
||||
self.GPIO.setup(self.pin_e, GPIO.OUT)
|
||||
self.GPIO.setup(self.pin_rs, GPIO.OUT)
|
||||
self.GPIO.setup(self.pin_b, GPIO.OUT)
|
||||
|
||||
for pin in self.pins_db:
|
||||
self.GPIO.setup(pin, GPIO.OUT)
|
||||
|
||||
self.GPIO.output(self.pin_b, True)
|
||||
|
||||
self.write4bits(0x33) # initialization
|
||||
self.write4bits(0x32) # initialization
|
||||
self.write4bits(0x28) # 2 line 5x7 matrix
|
||||
self.write4bits(0x0C) # turn cursor off 0x0E to enable cursor
|
||||
self.write4bits(0x06) # shift cursor right
|
||||
|
||||
self.displaycontrol = self.LCD_DISPLAYON | self.LCD_CURSOROFF | self.LCD_BLINKOFF
|
||||
|
||||
self.displayfunction = self.LCD_4BITMODE | self.LCD_1LINE | self.LCD_5x8DOTS
|
||||
self.displayfunction |= self.LCD_2LINE
|
||||
|
||||
""" Initialize to default text direction (for romance languages) """
|
||||
self.displaymode = self.LCD_ENTRYLEFT | self.LCD_ENTRYSHIFTDECREMENT
|
||||
self.write4bits(self.LCD_ENTRYMODESET |
|
||||
self.displaymode) # set the entry mode
|
||||
|
||||
self.clear()
|
||||
|
||||
def begin(self, cols, lines):
|
||||
|
||||
if (lines > 1):
|
||||
self.numlines = lines
|
||||
self.displayfunction |= self.LCD_2LINE
|
||||
self.currline = 0
|
||||
|
||||
def home(self):
|
||||
|
||||
self.write4bits(self.LCD_RETURNHOME) # set cursor position to zero
|
||||
self.delayMicroseconds(3000) # this command takes a long time!
|
||||
|
||||
def clear(self):
|
||||
|
||||
self.write4bits(self.LCD_CLEARDISPLAY) # command to clear display
|
||||
# 3000 microsecond sleep, clearing the display takes a long time
|
||||
self.delayMicroseconds(3000)
|
||||
|
||||
def setCursor(self, col, row):
|
||||
|
||||
self.row_offsets = [0x00, 0x40, 0x14, 0x54]
|
||||
|
||||
if (row > self.numlines):
|
||||
row = self.numlines - 1 # we count rows starting w/0
|
||||
|
||||
self.write4bits(self.LCD_SETDDRAMADDR | (col + self.row_offsets[row]))
|
||||
|
||||
def noDisplay(self):
|
||||
""" Turn the display off (quickly) """
|
||||
self.GPIO.output(self.pin_b, False)
|
||||
self.displaycontrol &= ~self.LCD_DISPLAYON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def display(self):
|
||||
""" Turn the display on (quickly) """
|
||||
self.GPIO.output(self.pin_b, True)
|
||||
self.displaycontrol |= self.LCD_DISPLAYON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def noCursor(self):
|
||||
""" Turns the underline cursor on/off """
|
||||
|
||||
self.displaycontrol &= ~self.LCD_CURSORON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def cursor(self):
|
||||
""" Cursor On """
|
||||
|
||||
self.displaycontrol |= self.LCD_CURSORON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def noBlink(self):
|
||||
""" Turn on and off the blinking cursor """
|
||||
|
||||
self.displaycontrol &= ~self.LCD_BLINKON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def noBlink(self):
|
||||
""" Turn on and off the blinking cursor """
|
||||
|
||||
self.displaycontrol &= ~self.LCD_BLINKON
|
||||
self.write4bits(self.LCD_DISPLAYCONTROL | self.displaycontrol)
|
||||
|
||||
def DisplayLeft(self):
|
||||
""" These commands scroll the display without changing the RAM """
|
||||
|
||||
self.write4bits(self.LCD_CURSORSHIFT |
|
||||
self.LCD_DISPLAYMOVE | self.LCD_MOVELEFT)
|
||||
|
||||
def scrollDisplayRight(self):
|
||||
""" These commands scroll the display without changing the RAM """
|
||||
|
||||
self.write4bits(self.LCD_CURSORSHIFT |
|
||||
self.LCD_DISPLAYMOVE | self.LCD_MOVERIGHT)
|
||||
|
||||
def leftToRight(self):
|
||||
""" This is for text that flows Left to Right """
|
||||
|
||||
self.displaymode |= self.LCD_ENTRYLEFT
|
||||
self.write4bits(self.LCD_ENTRYMODESET | self.displaymode)
|
||||
|
||||
def rightToLeft(self):
|
||||
""" This is for text that flows Right to Left """
|
||||
self.displaymode &= ~self.LCD_ENTRYLEFT
|
||||
self.write4bits(self.LCD_ENTRYMODESET | self.displaymode)
|
||||
|
||||
def autoscroll(self):
|
||||
""" This will 'right justify' text from the cursor """
|
||||
|
||||
self.displaymode |= self.LCD_ENTRYSHIFTINCREMENT
|
||||
self.write4bits(self.LCD_ENTRYMODESET | self.displaymode)
|
||||
|
||||
def noAutoscroll(self):
|
||||
""" This will 'left justify' text from the cursor """
|
||||
|
||||
self.displaymode &= ~self.LCD_ENTRYSHIFTINCREMENT
|
||||
self.write4bits(self.LCD_ENTRYMODESET | self.displaymode)
|
||||
|
||||
def write4bits(self, bits, char_mode=False):
|
||||
""" Send command to LCD """
|
||||
|
||||
self.delayMicroseconds(1000) # 1000 microsecond sleep
|
||||
|
||||
bits = bin(bits)[2:].zfill(8)
|
||||
|
||||
self.GPIO.output(self.pin_rs, char_mode)
|
||||
|
||||
for pin in self.pins_db:
|
||||
self.GPIO.output(pin, False)
|
||||
|
||||
for i in range(4):
|
||||
if bits[i] == "1":
|
||||
self.GPIO.output(self.pins_db[::-1][i], True)
|
||||
|
||||
self.pulseEnable()
|
||||
|
||||
for pin in self.pins_db:
|
||||
self.GPIO.output(pin, False)
|
||||
|
||||
for i in range(4, 8):
|
||||
if bits[i] == "1":
|
||||
self.GPIO.output(self.pins_db[::-1][i-4], True)
|
||||
|
||||
self.pulseEnable()
|
||||
|
||||
def delayMicroseconds(self, microseconds):
|
||||
# divide microseconds by 1 million for seconds
|
||||
seconds = microseconds / float(1000000)
|
||||
sleep(seconds)
|
||||
|
||||
def pulseEnable(self):
|
||||
self.GPIO.output(self.pin_e, False)
|
||||
# 1 microsecond pause - enable pulse must be > 450ns
|
||||
self.delayMicroseconds(1)
|
||||
self.GPIO.output(self.pin_e, True)
|
||||
# 1 microsecond pause - enable pulse must be > 450ns
|
||||
self.delayMicroseconds(1)
|
||||
self.GPIO.output(self.pin_e, False)
|
||||
self.delayMicroseconds(1) # commands need > 37us to settle
|
||||
|
||||
def message(self, text):
|
||||
""" Send string to LCD. Newline wraps to second line"""
|
||||
|
||||
for char in text:
|
||||
if char == '\n':
|
||||
self.write4bits(0xC0) # next line
|
||||
else:
|
||||
self.write4bits(ord(char), True)
|
||||
100
leds.py
100
leds.py
|
|
@ -1,100 +0,0 @@
|
|||
#!/usr/bin/env python
|
||||
|
||||
#
|
||||
# based on code from lrvick and LiquidCrystal
|
||||
# lrvic - https://github.com/lrvick/raspi-hd44780/blob/master/hd44780.py
|
||||
# LiquidCrystal - https://github.com/arduino/Arduino/blob/master/libraries/LiquidCrystal/LiquidCrystal.cpp
|
||||
#
|
||||
|
||||
from time import sleep
|
||||
import sys
|
||||
import lcd_manager
|
||||
import light_manager
|
||||
import pattern
|
||||
import logger
|
||||
import threading
|
||||
import socket
|
||||
|
||||
this = sys.modules[__name__]
|
||||
|
||||
this.level = 0
|
||||
this.level_max = 14
|
||||
this.level_state = 0
|
||||
this.color_state = 0
|
||||
|
||||
|
||||
def lightlevel(lcd, level):
|
||||
logger.debug("display level")
|
||||
lcd.clear()
|
||||
lcd.message("Light Level:\n]" + "-"*level + "[")
|
||||
|
||||
|
||||
def query():
|
||||
level_state = 2
|
||||
|
||||
|
||||
def color(lcd):
|
||||
lcd.clear()
|
||||
lcd.message("new pattern loaded.")
|
||||
logger.debug("NYI")
|
||||
|
||||
|
||||
def get_state():
|
||||
if this.level_state > 0:
|
||||
this.level_state -= 1
|
||||
return "level"
|
||||
elif this.color_state > 0:
|
||||
this.color_state -= 1
|
||||
return "color"
|
||||
else:
|
||||
return "idle"
|
||||
|
||||
|
||||
def displayon(lcd):
|
||||
if lcd.displaycontrol & lcd.LCD_DISPLAYON != lcd.displaycontrol:
|
||||
lcd.display()
|
||||
|
||||
|
||||
def socket_loop():
|
||||
injected = False
|
||||
s = socket.create_server(('0.0.0.0', 29999))
|
||||
while True:
|
||||
if not injected:
|
||||
this.lights.set_pattern(pattern.pat)
|
||||
injected = True
|
||||
sock, addr = s.accept()
|
||||
with sock:
|
||||
length_data = sock.recv(4)
|
||||
logger.debug(length_data)
|
||||
length = int(length_data.decode())
|
||||
logger.debug(length)
|
||||
pattern_data = sock.recv(length)
|
||||
logger.debug(pattern_data)
|
||||
pattern.parse(pattern_data.decode())
|
||||
this.color_state = 7
|
||||
|
||||
|
||||
def loop():
|
||||
socket_thread = threading.Thread(target=socket_loop)
|
||||
lcd = lcd_manager.Adafruit_CharLCD()
|
||||
this.lights = light_manager.LightStrip(string_length=450, brightness=0.6, max_changes=10)
|
||||
socket_thread.start()
|
||||
while True:
|
||||
logger.debug("loop")
|
||||
this.lights.tick()
|
||||
query()
|
||||
state = get_state()
|
||||
|
||||
if state == "level":
|
||||
if this.lights.get_light_level() != (this.level / this.level_max):
|
||||
this.lights.set_light_level(this.level / this.level_max)
|
||||
lightlevel(lcd, this.level)
|
||||
elif state == "color":
|
||||
color(lcd)
|
||||
else:
|
||||
lcd.noDisplay()
|
||||
sleep(0.1)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
loop()
|
||||
|
|
@ -1,67 +0,0 @@
|
|||
from time import sleep
|
||||
import neopixel
|
||||
import board
|
||||
import logger
|
||||
import pattern
|
||||
|
||||
|
||||
def defaultPattern(n, t, pv):
|
||||
return (t % 255, 255, 255)
|
||||
|
||||
|
||||
class LightStrip:
|
||||
def __init__(self, data_pin=board.D18, string_length=300, brightness=0.7, pixel_order=neopixel.GRB, max_changes=5):
|
||||
self.data_pin = data_pin
|
||||
|
||||
self.np = neopixel.NeoPixel(
|
||||
self.data_pin, string_length, brightness=brightness, auto_write=True, pixel_order=pixel_order)
|
||||
self.pattern = defaultPattern
|
||||
self.cur_tick = 0
|
||||
self.cur_index = 0
|
||||
self.max_changes = max_changes
|
||||
self.cur_pattern = []
|
||||
|
||||
def get_light_level(self):
|
||||
return self.np.brightness
|
||||
|
||||
def set_light_level(self, level):
|
||||
self.np.brightness = level
|
||||
|
||||
def set_pattern(self, pattern_callback):
|
||||
self.pattern = pattern_callback
|
||||
|
||||
def get_next_pattern_tick(self):
|
||||
np = self.np
|
||||
n = np.n
|
||||
t = self.cur_tick
|
||||
if not len(self.cur_pattern) >= n - 1:
|
||||
li = [(255, 255, 255)] * (n - len(self.cur_pattern))
|
||||
self.cur_pattern.extend(li)
|
||||
for i in range(n):
|
||||
self.cur_pattern[i] = self.pattern(i, t, np[i])
|
||||
self.cur_tick = t + 1
|
||||
|
||||
def tick(self):
|
||||
np = self.np
|
||||
t = self.cur_tick
|
||||
n = np.n
|
||||
|
||||
if not len(self.cur_pattern) >= n - 1:
|
||||
self.get_next_pattern_tick()
|
||||
changes = 0
|
||||
ind = self.cur_index
|
||||
for i in range(ind, n):
|
||||
col = self.cur_pattern[i]
|
||||
self.cur_index = i
|
||||
logger.debug("TEST VALUES: np {} col {} same {}".format(
|
||||
tuple(np[i]), col, tuple(np[i]) != col))
|
||||
if tuple(np[i]) != col:
|
||||
changes = changes + 1
|
||||
np[i] = col
|
||||
logger.debug(
|
||||
"CHANGE COLOR OF PIXEL {} TO {} ON TICK {}".format(i, col, t))
|
||||
if changes >= self.max_changes:
|
||||
break
|
||||
if self.cur_index >= (n-1):
|
||||
self.get_next_pattern_tick()
|
||||
self.cur_index = 0
|
||||
308
lights.js
308
lights.js
|
|
@ -1,308 +0,0 @@
|
|||
import ws281x from "rpi-ws281x";
|
||||
import * as fs from "fs";
|
||||
import Logger, { levels } from "./logger.js";
|
||||
|
||||
const cfg = JSON.parse(fs.readFileSync("./config.json"));
|
||||
const log = new Logger(
|
||||
"lights",
|
||||
cfg.log_level ? levels[cfg.log_level] : levels.INFO
|
||||
);
|
||||
|
||||
const fade_ticks = cfg.fade_ticks || 20;
|
||||
var num_ticks = 0;
|
||||
var pixels = new Uint32Array(cfg.leds);
|
||||
var pixel_cache = new Uint32Array(cfg.leds);
|
||||
var next_pattern = new Uint32Array(cfg.leds);
|
||||
const targets = {};
|
||||
var pattern = {};
|
||||
|
||||
function rgb_to_int(r, g, b) {
|
||||
let rgb = r;
|
||||
rgb = (rgb << 8) + g;
|
||||
rgb = (rgb << 8) + b;
|
||||
return rgb;
|
||||
}
|
||||
function int_to_rgb(int) {
|
||||
var r = (int >> 16) & 0xff;
|
||||
var g = (int >> 8) & 0xff;
|
||||
var b = int & 0xff;
|
||||
return { r: r, g: g, b: b };
|
||||
}
|
||||
|
||||
ws281x.configure({
|
||||
leds: cfg.leds || 300,
|
||||
brightness: cfg.brightness || 200,
|
||||
gpio: cfg.gpio || 18,
|
||||
stripType: cfg.type || "grb",
|
||||
});
|
||||
|
||||
export function set_pattern(pat) {
|
||||
pattern = pat;
|
||||
log.debug("pattern set");
|
||||
}
|
||||
|
||||
export class Function {
|
||||
func;
|
||||
options;
|
||||
|
||||
constructor(func, options) {
|
||||
this.func = func;
|
||||
this.options = options;
|
||||
}
|
||||
}
|
||||
|
||||
export const functions = {
|
||||
random: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return Math.floor(Math.random() * 256);
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: false,
|
||||
convert_args: false,
|
||||
}
|
||||
),
|
||||
move: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return arg2;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
modulo: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return arg1 % arg2;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
swap: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
let temp = targets[arg2];
|
||||
targets[arg2] = targets[arg1];
|
||||
return temp;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: false,
|
||||
}
|
||||
),
|
||||
add: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return arg1 + arg2;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
subtract: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return arg1 - arg2;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
stagger: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return (index + arg2) % 255;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
slide: new Function(
|
||||
(index, arg1, arg2) => {
|
||||
return (num_ticks + arg2) % 255;
|
||||
},
|
||||
{
|
||||
requires_arg1: true,
|
||||
requires_arg2: true,
|
||||
convert_args: true,
|
||||
}
|
||||
),
|
||||
};
|
||||
|
||||
function tick_pattern() {
|
||||
// do the parsing stuff here
|
||||
log.debug("TICKING PATTERN");
|
||||
|
||||
let parsed = pattern.parsed;
|
||||
log.debug(`${JSON.stringify(pattern)} ${JSON.stringify(parsed)}`);
|
||||
|
||||
if (parsed && parsed.length > 0) {
|
||||
for (let i = 0; i < cfg.leds; i++) {
|
||||
for (let id in parsed) {
|
||||
let command = parsed[id];
|
||||
log.debug(`pattern ${id} ${command}`);
|
||||
let name = command["command"];
|
||||
log.debug(`${name} matches: ${functions[name]}`);
|
||||
if (functions[name] != undefined) {
|
||||
if (
|
||||
functions[name].options &&
|
||||
functions[name].options["convert_args"]
|
||||
) {
|
||||
let param_arg1 = parseInt(command.arg1) || targets[command.arg1];
|
||||
let param_arg2 = parseInt(command.arg2) || targets[command.arg2];
|
||||
let result = functions[name].func(i, param_arg1, param_arg2);
|
||||
log.debug(
|
||||
`convert ${command.arg1} ${param_arg1} ${command.arg2} ${param_arg2} ${result}`
|
||||
);
|
||||
targets[command.arg1] = result;
|
||||
} else {
|
||||
let result = functions[name].func(i, command.arg1, command.arg2);
|
||||
log.debug(`no convert ${command.arg1} = ${result}`);
|
||||
targets[command.arg1] = result;
|
||||
}
|
||||
}
|
||||
}
|
||||
log.debug(`next: ${targets["r"]}, ${targets["g"]}, ${targets["b"]}`);
|
||||
next_pattern[i] = rgb_to_int(
|
||||
targets["r"] || 0,
|
||||
targets["g"] || 0,
|
||||
targets["b"] || 0
|
||||
);
|
||||
targets["r"] = 0;
|
||||
targets["g"] = 0;
|
||||
targets["b"] = 0;
|
||||
}
|
||||
} else {
|
||||
getRandom();
|
||||
}
|
||||
num_ticks++;
|
||||
}
|
||||
|
||||
function getRandom() {
|
||||
for (let i = 0; i < cfg.leds; i++) {
|
||||
var r = Math.floor(Math.random() * 256);
|
||||
var g = Math.floor(Math.random() * 256);
|
||||
var b = Math.floor(Math.random() * 256);
|
||||
next_pattern[i] = rgb_to_int(r, g, b);
|
||||
}
|
||||
}
|
||||
|
||||
export function tick() {
|
||||
var changed = false;
|
||||
for (let i = 0; i < cfg.leds; i++) {
|
||||
if (next_pattern[i] != pixels[i]) {
|
||||
if (next_pattern[i] == pixel_cache[i]) {
|
||||
log.debug("INCONGRUENCE WITH " + i);
|
||||
pixels[i] = next_pattern[i];
|
||||
} else {
|
||||
changed = true;
|
||||
fade(i);
|
||||
}
|
||||
} else if (pixel_cache[i] != pixels[i]) {
|
||||
log.debug("PATTERN NOT STORED " + i);
|
||||
pixel_cache[i] = pixels[i];
|
||||
}
|
||||
}
|
||||
if (!changed) {
|
||||
tick_pattern();
|
||||
} else {
|
||||
ws281x.render(pixels);
|
||||
}
|
||||
//ws281x.sleep(cfg.sleep_time || 500);
|
||||
}
|
||||
|
||||
function fade(index) {
|
||||
var original = int_to_rgb(pixel_cache[index]);
|
||||
var current = int_to_rgb(pixels[index]);
|
||||
var final = int_to_rgb(next_pattern[index]);
|
||||
var diff_r = final.r - original.r;
|
||||
var diff_cr = current.r - original.r;
|
||||
var diff_g = final.g - original.g;
|
||||
var diff_cg = current.g - original.g;
|
||||
var diff_b = final.b - original.b;
|
||||
var diff_cb = current.b - original.b;
|
||||
var sign_r = diff_r === Math.abs(diff_r) ? 1 : -1;
|
||||
var sign_g = diff_g === Math.abs(diff_g) ? 1 : -1;
|
||||
var sign_b = diff_b === Math.abs(diff_b) ? 1 : -1;
|
||||
log.debug(`${diff_r} ${sign_r} ${diff_g} ${sign_g} ${diff_b} ${sign_b}`);
|
||||
var interval_r = sign_r * Math.ceil(Math.abs(diff_r) / fade_ticks);
|
||||
var interval_g = sign_g * Math.ceil(Math.abs(diff_g) / fade_ticks);
|
||||
var interval_b = sign_b * Math.ceil(Math.abs(diff_b) / fade_ticks);
|
||||
log.debug(
|
||||
`r${Math.abs(diff_r) / fade_ticks} ${Math.ceil(
|
||||
Math.abs(diff_r) / fade_ticks
|
||||
)}` +
|
||||
`g${Math.abs(diff_g) / fade_ticks} ${Math.ceil(
|
||||
Math.abs(diff_g) / fade_ticks
|
||||
)}` +
|
||||
`b${Math.abs(diff_b) / fade_ticks} ${Math.ceil(
|
||||
Math.abs(diff_b) / fade_ticks
|
||||
)}`
|
||||
);
|
||||
|
||||
var current_tick_r = Math.floor(Math.abs(diff_cr / diff_r) * fade_ticks);
|
||||
var current_tick_g = Math.floor(Math.abs(diff_cg / diff_g) * fade_ticks);
|
||||
var current_tick_b = Math.floor(Math.abs(diff_cb / diff_b) * fade_ticks);
|
||||
if (
|
||||
diff_r == 0 ||
|
||||
(sign_r == 1 && current.r + interval_r >= final.r) ||
|
||||
(sign_r == -1 && current.r + interval_r <= final.r) ||
|
||||
current_tick_r + 1 >= fade_ticks
|
||||
) {
|
||||
current.r = final.r;
|
||||
interval_r = 0;
|
||||
current_tick_r = fade_ticks;
|
||||
}
|
||||
if (
|
||||
diff_g == 0 ||
|
||||
(sign_g == 1 && current.g + interval_g >= final.g) ||
|
||||
(sign_g == -1 && current.g + interval_g <= final.g) ||
|
||||
current_tick_g + 1 >= fade_ticks
|
||||
) {
|
||||
current.g = final.g;
|
||||
interval_g = 0;
|
||||
current_tick_g = fade_ticks;
|
||||
}
|
||||
if (
|
||||
diff_b == 0 ||
|
||||
(sign_b == 1 && current.b + interval_b >= final.b) ||
|
||||
(sign_b == -1 && current.b + interval_b <= final.b) ||
|
||||
current_tick_b + 1 >= fade_ticks
|
||||
) {
|
||||
current.b = final.b;
|
||||
interval_b = 0;
|
||||
current_tick_b = fade_ticks;
|
||||
}
|
||||
|
||||
if (
|
||||
current_tick_r + 1 >= fade_ticks &&
|
||||
current_tick_g + 1 >= fade_ticks &&
|
||||
current_tick_b + 1 >= fade_ticks
|
||||
) {
|
||||
log.debug("FINISHED");
|
||||
pixel_cache[index] = next_pattern[index];
|
||||
} else {
|
||||
pixels[index] = rgb_to_int(
|
||||
current.r + interval_r,
|
||||
current.g + interval_g,
|
||||
current.b + interval_b
|
||||
);
|
||||
let prev = int_to_rgb(pixel_cache[index]);
|
||||
log.debug(
|
||||
`${current_tick_r} ${current_tick_g} ${current_tick_b}: ` +
|
||||
`CURRENT COLOR: ${current.r} ${current.g} ${current.b} NEW COLOR: ${
|
||||
current.r + interval_r
|
||||
} ${current.g + interval_g} ${current.b + interval_b} ` +
|
||||
`FINAL: ${final.r} ${final.g} ${final.b} ` +
|
||||
`\nINTERVAL: ${interval_r} ${interval_g} ${interval_b} ` +
|
||||
`PREVIOUS: ${prev.r} ${prev.g} ${prev.b}`
|
||||
);
|
||||
}
|
||||
}
|
||||
51
logger.js
51
logger.js
|
|
@ -1,51 +0,0 @@
|
|||
export const levels = {
|
||||
DEBUG: 4,
|
||||
INFO: 3,
|
||||
WARN: 2,
|
||||
ERROR: 1,
|
||||
PANIC: 0,
|
||||
};
|
||||
|
||||
export default class Logger {
|
||||
constructor(name, level) {
|
||||
console.log(`created new logger for ${name} with level ${level}`);
|
||||
this.sn(name);
|
||||
this.s(level);
|
||||
}
|
||||
n = 'DEFAULT';
|
||||
l = 0;
|
||||
sn(n) {
|
||||
this.n = n;
|
||||
}
|
||||
s(l) {
|
||||
if (l && l.constructor === Number) {
|
||||
this.l = l;
|
||||
} else {
|
||||
this.l = levels[l];
|
||||
}
|
||||
}
|
||||
|
||||
lo(l, m) {
|
||||
if (l <= this.l) {
|
||||
let level = Object.keys(levels).find((key) => levels[key] === l);
|
||||
let ms = typeof m == 'object' ? JSON.stringify(m) : m;
|
||||
console.log(`${level} [${this.n}]: ${ms}`);
|
||||
}
|
||||
}
|
||||
|
||||
debug(msg) {
|
||||
this.lo(levels.DEBUG, msg);
|
||||
}
|
||||
info(msg) {
|
||||
this.lo(levels.INFO, msg);
|
||||
}
|
||||
warn(msg) {
|
||||
this.lo(levels.WARN, msg);
|
||||
}
|
||||
error(msg) {
|
||||
this.lo(levels.ERROR, msg);
|
||||
}
|
||||
panic(msg) {
|
||||
this.lo(levels.PANIC, msg);
|
||||
}
|
||||
}
|
||||
10
logger.py
10
logger.py
|
|
@ -1,10 +0,0 @@
|
|||
debug_statements = False
|
||||
|
||||
|
||||
def debug(msg):
|
||||
if debug_statements:
|
||||
print(msg)
|
||||
|
||||
|
||||
def info(msg):
|
||||
print(msg)
|
||||
20
package.json
20
package.json
|
|
@ -1,20 +0,0 @@
|
|||
{
|
||||
"type": "module",
|
||||
"name": "leds",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1",
|
||||
"start": "node index.js"
|
||||
},
|
||||
"repository": {
|
||||
"type": "git",
|
||||
"url": "git@ssh.gitdab.com:jane/leds"
|
||||
},
|
||||
"author": "jane@j4.pm",
|
||||
"license": "UNLICENSED",
|
||||
"dependencies": {
|
||||
"rpi-ws281x": "^1.0.36"
|
||||
}
|
||||
}
|
||||
50
parse.js
50
parse.js
|
|
@ -1,50 +0,0 @@
|
|||
import * as fs from 'fs';
|
||||
import Logger, { levels } from './logger.js';
|
||||
import { functions } from './lights.js';
|
||||
|
||||
const cfg = JSON.parse(fs.readFileSync('./config.json'));
|
||||
const log = new Logger("server", cfg.log_level ? levels[cfg.log_level] : levels.INFO);
|
||||
|
||||
|
||||
export default function parse(data) {
|
||||
let parsed = []
|
||||
let errors = []
|
||||
log.info(data);
|
||||
// errors.push("not yet implemented");
|
||||
data = JSON.parse(data);
|
||||
let line = data.split("\n");
|
||||
for (let lineNumber in line) {
|
||||
let currentLine = line[lineNumber];
|
||||
let split = currentLine.split(" ");
|
||||
let command = split[0];
|
||||
let arg1 = split[1];
|
||||
let arg2 = split[2];
|
||||
|
||||
let match = functions[command];
|
||||
if (match != undefined) {
|
||||
if (
|
||||
(match.options["requires_arg1"] && arg1 == undefined) ||
|
||||
(match.options["requires_arg2"] && arg2 == undefined)
|
||||
) {
|
||||
errors.push(`error parsing line ${lineNumber}, invalid number of args`);
|
||||
}
|
||||
else if (!match.options["convert_args"] && parseInt(arg1)) {
|
||||
errors.push(`error parsing line ${lineNumber}, argument ${arg1} cannot be a number`);
|
||||
}
|
||||
else {
|
||||
parsed.push(
|
||||
{
|
||||
command: command,
|
||||
arg1: arg1 || undefined,
|
||||
arg2: arg2 || undefined
|
||||
}
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
return {
|
||||
parsed: parsed,
|
||||
data: data,
|
||||
errors: errors
|
||||
}
|
||||
}
|
||||
189
pattern.py
189
pattern.py
|
|
@ -1,189 +0,0 @@
|
|||
import sys
|
||||
import json
|
||||
import random
|
||||
import logger
|
||||
|
||||
this = sys.modules[__name__]
|
||||
|
||||
this.encoded = None
|
||||
this.pattern = None
|
||||
this.values = {
|
||||
"stack": 0,
|
||||
"stack2": 0,
|
||||
"stack3": 0,
|
||||
"stack4": 0,
|
||||
"stack5": 0,
|
||||
"stack6": 0,
|
||||
"stackr": 0,
|
||||
"stackg": 0,
|
||||
"stackb": 0,
|
||||
"r": 0,
|
||||
"g": 0,
|
||||
"b": 0,
|
||||
"tick": 0,
|
||||
"index": 0,
|
||||
"fadeval": 0,
|
||||
"fadeinc": True
|
||||
}
|
||||
|
||||
|
||||
def constant(target, arg, index):
|
||||
return (arg, index)
|
||||
|
||||
|
||||
def add(target, arg, index):
|
||||
return (target + arg, index)
|
||||
|
||||
|
||||
def sub(target, arg, index):
|
||||
return (target - arg, index)
|
||||
|
||||
|
||||
def mult(target, arg, index):
|
||||
return (target * arg, index)
|
||||
|
||||
|
||||
def div(target, arg, index):
|
||||
return (target / arg, index)
|
||||
|
||||
|
||||
def mod(target, arg, index):
|
||||
if arg <= 0:
|
||||
return target
|
||||
return (target % arg, index)
|
||||
|
||||
|
||||
def fade(target, arg, index):
|
||||
value = this.values['fadeval']
|
||||
if this.values['fadeinc']:
|
||||
value += 1
|
||||
if value >= arg:
|
||||
this.values['fadeinc'] = False
|
||||
else:
|
||||
value -= 1
|
||||
if value <= 0:
|
||||
this.values['fadeinc'] = True
|
||||
this.values['fadeval'] = value
|
||||
return (value, index)
|
||||
|
||||
|
||||
def rand(target, arg, index):
|
||||
return (random.randrange(0, 255), index)
|
||||
|
||||
|
||||
def jmp(target, arg, index):
|
||||
return (target, target)
|
||||
|
||||
|
||||
def jnz(target, arg, index):
|
||||
if target != 0:
|
||||
return (target, arg)
|
||||
else:
|
||||
return (target, index)
|
||||
|
||||
|
||||
def jez(target, arg, index):
|
||||
if target == 0:
|
||||
return (target, arg)
|
||||
else:
|
||||
return (target, index)
|
||||
|
||||
|
||||
def _apply(index, target, arg, func):
|
||||
if type(arg) is int:
|
||||
logger.debug("ran: {} {} {} {}".format(index, func.__name__, target, arg))
|
||||
return func(target, arg, index)
|
||||
elif type(arg) is str and arg in this.values:
|
||||
logger.debug("ran: {} {} {} {}".format(
|
||||
index, func.__name__, target, this.values[arg]))
|
||||
return func(target, this.values[arg], index)
|
||||
|
||||
|
||||
def apply(index, targets, args, func):
|
||||
j = index
|
||||
for target in range(len(targets)):
|
||||
if this.values[targets[target]['channel']] != None:
|
||||
logger.debug("target: {}".format(targets[target]['channel']))
|
||||
if target < len(args):
|
||||
val, jump = _apply(
|
||||
index, this.values[targets[target]['channel']], args[target], func)
|
||||
if val != this.values[targets[target]['channel']]:
|
||||
this.values[targets[target]['channel']] = val
|
||||
j = jump
|
||||
else:
|
||||
val, jump = _apply(
|
||||
index, this.values[targets[target]['channel']], 0, func)
|
||||
if val != this.values[targets[target]['channel']]:
|
||||
this.values[targets[target]['channel']] = val
|
||||
j = jump
|
||||
return j
|
||||
|
||||
|
||||
this.instructions = {
|
||||
"CONSTANT": constant,
|
||||
"ADD": add,
|
||||
"SUBTRACT": sub,
|
||||
"MULTIPLY": mult,
|
||||
"DIVIDE": div,
|
||||
"MODULO": mod,
|
||||
"FADE": fade,
|
||||
"RANDOM": rand,
|
||||
"JMP": jmp,
|
||||
"JNZ": jnz,
|
||||
"JEZ": jez
|
||||
}
|
||||
|
||||
|
||||
def default(index, tick):
|
||||
return (((index + tick) * 5) % 255, (tick * 42) % 255, (tick * 50) % 255)
|
||||
|
||||
|
||||
def pat(index, tick, previous_values):
|
||||
this.values['tick'] = tick
|
||||
this.values['index'] = index
|
||||
if this.pattern != None:
|
||||
i = 0
|
||||
while i < len(this.pattern):
|
||||
if i < len(this.pattern):
|
||||
name = this.pattern[i]['instruction']['name']
|
||||
targets = this.pattern[i]['instruction']['targets']
|
||||
args = []
|
||||
if 'args' in this.pattern[i]['instruction']:
|
||||
args = this.pattern[i]['instruction']['args']
|
||||
if this.instructions[name] != None:
|
||||
jump = apply(i, targets, args, this.instructions[name])
|
||||
logger.debug("{} {} {} {} {}".format(jump, i, len(
|
||||
this.pattern), jump != i, jump <= len(this.pattern)))
|
||||
if jump != i and jump <= len(this.pattern):
|
||||
logger.debug("jumping to {}".format(jump - 1))
|
||||
i = jump - 1
|
||||
i += 1
|
||||
r = this.values["r"]
|
||||
g = this.values["g"]
|
||||
b = this.values["b"]
|
||||
this.values["r"] = 0
|
||||
this.values["g"] = 0
|
||||
this.values["b"] = 0
|
||||
this.values["stack"] = 0
|
||||
if r > 255:
|
||||
r = 255
|
||||
elif r < 0:
|
||||
r = 0
|
||||
if g > 255:
|
||||
g = 255
|
||||
elif g < 0:
|
||||
g = 0
|
||||
if b > 255:
|
||||
b = 255
|
||||
elif b < 0:
|
||||
b = 0
|
||||
logger.debug("final color: {}".format((r, g, b)))
|
||||
return (r, g, b)
|
||||
else:
|
||||
return default(index, tick)
|
||||
|
||||
|
||||
def parse(str):
|
||||
this.encoded = str
|
||||
logger.debug(this.encoded)
|
||||
this.pattern = json.loads(this.encoded)
|
||||
|
|
@ -1,20 +0,0 @@
|
|||
lockfileVersion: 5.3
|
||||
|
||||
specifiers:
|
||||
rpi-ws281x: ^1.0.36
|
||||
|
||||
dependencies:
|
||||
rpi-ws281x: 1.0.36
|
||||
|
||||
packages:
|
||||
|
||||
/nan/2.14.2:
|
||||
resolution: {integrity: sha512-M2ufzIiINKCuDfBSAUr1vWQ+vuVcA9kqx8JJUsbQi6yf1uGRyb7HfpdfUr5qLXf3B/t8dPvcjhKMmlfnP47EzQ==}
|
||||
dev: false
|
||||
|
||||
/rpi-ws281x/1.0.36:
|
||||
resolution: {integrity: sha512-iKmc4lKA0/V83q7rdYmFJV3nsQTXaJ8wqyYqdamUn6krDPRevkOhkty9Zj0ZcsYeXBVzxWKzd3VdenDYDQKAGg==}
|
||||
requiresBuild: true
|
||||
dependencies:
|
||||
nan: 2.14.2
|
||||
dev: false
|
||||
|
|
@ -1,2 +0,0 @@
|
|||
rpi_ws281x==4.2.5
|
||||
adafruit-circuitpython-neopixel==6.0.0
|
||||
2
run.sh
2
run.sh
|
|
@ -1,2 +0,0 @@
|
|||
git pull
|
||||
node index.js
|
||||
62
server.js
62
server.js
|
|
@ -1,62 +0,0 @@
|
|||
import * as net from 'net';
|
||||
import * as fs from 'fs';
|
||||
import Logger, { levels } from './logger.js';
|
||||
import parse from './parse.js'
|
||||
|
||||
const cfg = JSON.parse(fs.readFileSync('./config.json'));
|
||||
const log = new Logger("server", cfg.log_level ? levels[cfg.log_level] : levels.INFO);
|
||||
|
||||
|
||||
const hostname = '0.0.0.0';
|
||||
const port = 29999;
|
||||
|
||||
export function recv(callback, errorCallback) {
|
||||
let server = new net.Server();
|
||||
server.listen(port, hostname, () => {
|
||||
server.on('connection', (con) => {
|
||||
console.log('connection recieved: ' +
|
||||
con.remoteAddress + ":" + con.remotePort);
|
||||
// let data = [];
|
||||
// for (let key of Object.keys(functions)) {
|
||||
// data.push({
|
||||
// n: key.toUpperCase(),
|
||||
// a: reqs[key.toLowerCase()] != undefined ? reqs[key.toLowerCase()] : true
|
||||
// });
|
||||
// }
|
||||
// let functions_str = JSON.stringify(data);
|
||||
// con.write(functions_str);
|
||||
// log.debug(`sending ${functions_str}`);
|
||||
con.on('data', (data) => {
|
||||
let parsed_data = parse(String(data));
|
||||
|
||||
if (parsed_data.errors != undefined && parsed_data.errors.length > 0) {
|
||||
con.write(`error ..\n${JSON.stringify(parsed_data)}`);
|
||||
errorCallback(JSON.stringify(parsed_data));
|
||||
}
|
||||
else {
|
||||
con.write(`success ..\n${JSON.stringify(parsed_data)}`);
|
||||
callback(JSON.stringify(parsed_data));
|
||||
}
|
||||
});
|
||||
con.on('close', () => {
|
||||
console.log('recieved close for ' +
|
||||
con.remoteAddress + ":" + con.remotePort);
|
||||
con.destroy();
|
||||
});
|
||||
|
||||
server.getConnections((err, cons) => {
|
||||
if (err) {
|
||||
console.error(err);
|
||||
}
|
||||
else {
|
||||
console.log(`connections: ${cons}`);
|
||||
}
|
||||
})
|
||||
})
|
||||
|
||||
server.on('error', (e) => {
|
||||
server.close();
|
||||
errorCallback(e);
|
||||
});
|
||||
});
|
||||
}
|
||||
14
shell.nix
Normal file
14
shell.nix
Normal file
|
|
@ -0,0 +1,14 @@
|
|||
let
|
||||
pkgs = import <nixpkgs> {};
|
||||
in
|
||||
with pkgs;
|
||||
mkShell {
|
||||
buildInputs = [
|
||||
pkgs.cargo
|
||||
pkgs.rustc
|
||||
pkgs.rustfmt
|
||||
pkgs.rls
|
||||
];
|
||||
|
||||
RUST_SRC_PATH= "${pkgs.rust.packages.stable.rustPlatform.rustLibSrc}";
|
||||
}
|
||||
30
src/main.rs
Normal file
30
src/main.rs
Normal file
|
|
@ -0,0 +1,30 @@
|
|||
pub mod util;
|
||||
|
||||
use util::lights::*;
|
||||
use std::sync::RwLock;
|
||||
use std::thread;
|
||||
|
||||
|
||||
pub const LED_SIZE: usize = 450;
|
||||
|
||||
fn main() {
|
||||
let lock = RwLock::new([Color {r: 0, g: 0, b: 0}; LED_SIZE]);
|
||||
thread::spawn(move || loop {
|
||||
let lights = lock.read().unwrap();
|
||||
run_lights(&lights);
|
||||
});
|
||||
let mut x: u8 = 0;
|
||||
loop {
|
||||
if x == 255 {
|
||||
x = 0;
|
||||
}
|
||||
let color = Color {
|
||||
r: x,
|
||||
g: x,
|
||||
b: x
|
||||
};
|
||||
let mut lights = lock.write().unwrap();
|
||||
lights[0] = color;
|
||||
x += 1;
|
||||
}
|
||||
}
|
||||
3
src/util.rs
Normal file
3
src/util.rs
Normal file
|
|
@ -0,0 +1,3 @@
|
|||
pub mod lights;
|
||||
pub mod parser;
|
||||
pub mod webserver;
|
||||
5
src/util/lights.rs
Normal file
5
src/util/lights.rs
Normal file
|
|
@ -0,0 +1,5 @@
|
|||
use candela::Pixel;
|
||||
|
||||
pub fn run_lights(strip: &[Pixel; crate::LED_SIZE]) {
|
||||
println!("Value: {:?}", strip[0]);
|
||||
}
|
||||
0
src/util/parser.rs
Normal file
0
src/util/parser.rs
Normal file
0
src/util/webserver.rs
Normal file
0
src/util/webserver.rs
Normal file
Loading…
Reference in a new issue