Compare commits
29 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 243a41fa7a | |||
| 7cce11dc66 | |||
| fc808a6c28 | |||
| c6b3f65b35 | |||
| 427a872811 | |||
| 1e5527f629 | |||
| 6d5404337e | |||
| 8c06248c32 | |||
| 7d5b41a7f7 | |||
| 302136c28b | |||
| 4b4e1968b3 | |||
| 8272352d64 | |||
| f2ee812bc5 | |||
| edf33e2afd | |||
| 9d9285df23 | |||
| c46f5ee492 | |||
| 4d82414fdd | |||
| 2aa73f581f | |||
| 3a29ffad57 | |||
| 7fd48da51e | |||
| 05c7bb3291 | |||
| 13cf05bf99 | |||
| 06901c72c0 | |||
| 037fdc2778 | |||
| 8819b3fa0d | |||
| 22ceac1a9b | |||
| d504f8cd5d | |||
| 89ccd5ff02 | |||
| bc728f479d |
30
.github/workflows/build.yml
vendored
30
.github/workflows/build.yml
vendored
@@ -1,30 +0,0 @@
|
||||
name: Build randopix
|
||||
# This workflow is triggered on pushes to the repository.
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- master
|
||||
|
||||
jobs:
|
||||
build:
|
||||
name: Build x86
|
||||
# This job runs on Linux
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- name: Install GTK packages
|
||||
run: sudo apt install --ignore-missing gnome-devel
|
||||
- uses: actions/checkout@master
|
||||
- name: Cache choosenim
|
||||
id: cache-choosenim
|
||||
uses: actions/cache@v1
|
||||
with:
|
||||
path: ~/.choosenim
|
||||
key: ${{ runner.os }}-choosenim-stable
|
||||
- name: Cache nimble
|
||||
id: cache-nimble
|
||||
uses: actions/cache@v1
|
||||
with:
|
||||
path: ~/.nimble
|
||||
key: ${{ runner.os }}-nimble-stable
|
||||
- uses: jiro4989/setup-nim-action@v1.0.2
|
||||
- run: nimble build -Y
|
||||
10
.gitignore
vendored
10
.gitignore
vendored
@@ -1,12 +1,4 @@
|
||||
# Ignore all
|
||||
*
|
||||
|
||||
# Unignore all with extensions
|
||||
!*.*
|
||||
|
||||
# Unignore all dirs
|
||||
!*/
|
||||
|
||||
### Above combination will ignore all files without extension ###
|
||||
bin/
|
||||
.vscode/
|
||||
pixctrl.js
|
||||
9
examples/randopix.service
Normal file
9
examples/randopix.service
Normal file
@@ -0,0 +1,9 @@
|
||||
[Unit]
|
||||
Description=randopix image display
|
||||
|
||||
[Service]
|
||||
Environment=DISPLAY=:0
|
||||
ExecStart=randopix -d /mnt/pix -m file
|
||||
|
||||
[Install]
|
||||
WantedBy=default.target
|
||||
@@ -1,18 +1,31 @@
|
||||
import strformat
|
||||
# Package
|
||||
|
||||
version = "0.1.0"
|
||||
version = "1.1.0"
|
||||
author = "luxick"
|
||||
description = "Play an image slide show from different sources"
|
||||
license = "GPL-2.0"
|
||||
srcDir = "src"
|
||||
binDir = "bin"
|
||||
bin = @["randopix", "pixctrl"]
|
||||
|
||||
# Dependencies
|
||||
requires "nim >= 1.0.0", "gintro >= 0.5.5", "argparse >=0.10.1"
|
||||
requires "nim >= 1.0.0", "gintro", "argparse", "jester", "ajax"
|
||||
# Not on nimble yet
|
||||
requires "https://github.com/luxick/op.git >= 1.0.0"
|
||||
|
||||
proc genJS =
|
||||
echo "Generating JS Client"
|
||||
exec("nim js -o:src/resources/www/pixctrl.js src/pixctrl.nim")
|
||||
|
||||
task genJS, "Generate the Javascript client":
|
||||
genJS()
|
||||
|
||||
task buildAll, "Generate JS and run build":
|
||||
genJS()
|
||||
exec "nimble build"
|
||||
|
||||
task debug, "Compile debug version":
|
||||
exec "nim c -d:debug --debugger:native --out:randopix src/randopix.nim"
|
||||
exec "nim c -d:debug --debugger:native -o:bin/randopix src/randopix.nim"
|
||||
|
||||
task release, "Compile release version":
|
||||
exec fmt"nim c -d:release --out:randopix-{version} src/randopix.nim"
|
||||
before install:
|
||||
genJS()
|
||||
@@ -1,8 +1,5 @@
|
||||
import json
|
||||
|
||||
const
|
||||
defaultPort* = 5555 ## Default port at which the control server will run
|
||||
|
||||
type
|
||||
OpResult* = object of RootObj ## Result object for signalling failure state across proc calls
|
||||
success*: bool ## Indicating if the opration was successfull
|
||||
@@ -24,18 +21,18 @@ type
|
||||
command*: Command ## Command that the application should execute
|
||||
parameter*: string ## Optional parameter for the command
|
||||
|
||||
proc `$`(cMsg: CommandMessage): string =
|
||||
$(%cMsg)
|
||||
|
||||
proc newOpResult*(): OpResult =
|
||||
OpResult(success: true)
|
||||
|
||||
proc newOpResult*(msg: string): OpResult =
|
||||
OpResult(success: false, errorMsg: msg)
|
||||
|
||||
proc newCommand*(c: Command, p: string = ""): CommandMessage =
|
||||
proc newCommandMessage*(c: Command, p: string = ""): CommandMessage =
|
||||
CommandMessage(command: c, parameter: p)
|
||||
|
||||
proc wrap*(msg: CommandMessage): string =
|
||||
$(%msg) & "\r\L"
|
||||
|
||||
proc enumToStrings*(en: typedesc): seq[string] =
|
||||
for x in en:
|
||||
result.add $x
|
||||
@@ -1,52 +1,94 @@
|
||||
import strutils, net
|
||||
import argparse
|
||||
import strutils, json
|
||||
import common
|
||||
|
||||
const modeHelp = "Change the display mode. Possible values: [$1]" % Mode.enumToStrings().join(", ")
|
||||
when defined(js):
|
||||
import ajax, jsconsole, dom
|
||||
else:
|
||||
import httpClient, strformat
|
||||
import argparse
|
||||
var randopixServer* {.exportc.}: string ## URL for the randopix server
|
||||
|
||||
var socket = newSocket()
|
||||
proc sendCommand(msg: CommandMessage) =
|
||||
when defined(js):
|
||||
console.log("Sending:", $msg, "to URL:", document.URL)
|
||||
var req = newXMLHttpRequest()
|
||||
|
||||
proc sendCommand*(server, port: string, msg: CommandMessage) =
|
||||
socket.connect(server, Port(port.parseInt))
|
||||
if not socket.trySend(msg.wrap):
|
||||
echo "Cannot send command: ", msg
|
||||
socket.close()
|
||||
proc processSend(e:Event) =
|
||||
if req.readyState == rsDONE:
|
||||
if req.status != 200:
|
||||
console.log("There was a problem with the request.")
|
||||
console.log($req.status, req.statusText)
|
||||
|
||||
proc switchMode*(server, port: string, mode: string) =
|
||||
req.onreadystatechange = processSend
|
||||
req.open("POST", document.URL)
|
||||
req.send(cstring($(%*msg)))
|
||||
else:
|
||||
let client = newHttpClient()
|
||||
let resp = client.post(randopixServer, $(%msg))
|
||||
if not resp.status.contains("200"):
|
||||
echo "Error while sending command: ", resp.status
|
||||
|
||||
proc sendCommand(cmd: Command) =
|
||||
sendCommand(newCommandMessage(cmd))
|
||||
|
||||
proc switchMode*(mode: string) =
|
||||
## Update the display mode
|
||||
try:
|
||||
discard parseEnum[Mode](mode)
|
||||
except ValueError:
|
||||
echo "Invalid mode: ", mode
|
||||
echo "Possible values: [$1]" % Mode.enumToStrings().join(", ")
|
||||
return
|
||||
let c = newCommand(cMode, mode)
|
||||
sendCommand(server, port, c)
|
||||
sendCommand(newCommandMessage(cMode, mode))
|
||||
|
||||
proc refresh*() {.exportc.} =
|
||||
## Force refresh of the current image
|
||||
sendCommand(cRefresh)
|
||||
|
||||
proc setTimeout*(seconds: string) =
|
||||
## Set the image timeout to this value
|
||||
sendCommand(newCommandMessage(cTimeout, seconds))
|
||||
|
||||
when defined(js):
|
||||
proc getModes(): seq[cstring] {.exportc.} =
|
||||
for mode in enumToStrings(Mode):
|
||||
result.add cstring(mode)
|
||||
proc switchMode*(mode: cstring) {.exportc.} =
|
||||
switchMode($mode)
|
||||
proc setTimeout*(seconds: cstring) {.exportc.} =
|
||||
setTimeout($seconds)
|
||||
else:
|
||||
when isMainModule:
|
||||
const modeHelp = "Change the display mode. Possible values: [$1]" % Mode.enumToStrings().join(", ")
|
||||
var p = newParser("pixctrl"):
|
||||
help("Control utilitiy for randopix")
|
||||
option("-s", "--server", help="Host running the randopix server", default="127.0.0.1")
|
||||
option("-p", "--port", help="Port to connect to the randopix server", default = $defaultPort)
|
||||
option("-s", "--server", help="Host running the randopix server", default="http://localhost:8080/")
|
||||
run:
|
||||
if opts.server.startsWith("http://"):
|
||||
randopixServer = opts.server
|
||||
else:
|
||||
randopixServer = fmt"http://{opts.server}"
|
||||
|
||||
command($cRefresh):
|
||||
## Force refresh command
|
||||
help("Force image refresh now")
|
||||
run:
|
||||
let c = newCommand(cRefresh)
|
||||
sendCommand(opts.parentOpts.server, opts.parentOpts.port, c)
|
||||
refresh()
|
||||
|
||||
command($cTimeout):
|
||||
## Timeout Command
|
||||
help("Set timeout in seconds before a new image is displayed")
|
||||
arg("seconds", default = "300")
|
||||
run:
|
||||
let c = newCommand(cTimeout, opts.seconds)
|
||||
sendCommand(opts.parentOpts.server, opts.parentOpts.port, c)
|
||||
setTimeout(opts.seconds)
|
||||
|
||||
command($cMode):
|
||||
## Mode switch command
|
||||
help(modeHelp)
|
||||
arg("mode")
|
||||
run:
|
||||
switchMode(opts.parentOpts.server, opts.parentOpts.port, opts.mode)
|
||||
switchMode(opts.mode)
|
||||
try:
|
||||
p.run(commandLineParams())
|
||||
except:
|
||||
echo p.help
|
||||
echo getCurrentExceptionMsg()
|
||||
@@ -1,34 +1,33 @@
|
||||
import os, sets, random, httpClient, json, strformat, options
|
||||
import gintro/[gdkpixbuf, gobject]
|
||||
import os, sets, random, httpClient, json, strutils, strformat, options, deques, times
|
||||
from lenientops import `*`
|
||||
import op, gintro/[gdkpixbuf, gobject]
|
||||
import common
|
||||
|
||||
const
|
||||
supportedExts = @[".png", ".jpg", ".jpeg"]
|
||||
placeholderImg = slurp("resources/blank.png")
|
||||
foxesUrl = "https://randomfox.ca/floof/"
|
||||
inspiroUrl = "http://inspirobot.me/api?generate=true"
|
||||
tmpFile = "/tmp/randopix_tmp.png"
|
||||
|
||||
type
|
||||
FileOpResult* = object of OpResult
|
||||
file*: string
|
||||
|
||||
ImageProvider* = ref object of RootObj
|
||||
## Manages images that should be displayed
|
||||
verbose: bool ## Additional logging for the image provider
|
||||
mode* : Mode ## Selects the API that is used to get images
|
||||
path*: Option[string] ## Path on the local file syetem that will be used in `file` mode
|
||||
exts: HashSet[string] ## Allowed extensions that the `file` mode will display
|
||||
files: seq[string] ## Currently loaded list of images in `file` mode
|
||||
|
||||
var
|
||||
client = newHttpClient() ## For loading images from the web
|
||||
tmpDir = getTempDir() / "randopix"
|
||||
tmpFile = tmpDir / "tmp.png"
|
||||
fileList = initDeque[string]()
|
||||
|
||||
########################
|
||||
# Constructors
|
||||
########################
|
||||
|
||||
proc newImageProvider(verbose: bool, mode: Mode, path: Option[string]): ImageProvider =
|
||||
randomize()
|
||||
ImageProvider(verbose: verbose, mode: mode, path: path, exts: supportedExts.toHashSet)
|
||||
|
||||
proc newImageProvider*(verbose: bool): ImageProvider =
|
||||
@@ -43,24 +42,39 @@ proc newImageProvider*(verbose: bool, mode: Mode): ImageProvider =
|
||||
proc newImageProvider*(verbose: bool, mode: Mode, path: string): ImageProvider =
|
||||
newImageProvider(verbose, mode, some(path))
|
||||
|
||||
proc newFileOpResultError(msg: string): FileOpResult =
|
||||
FileOpResult(success: false, errorMsg: msg)
|
||||
|
||||
proc newFileOpResult(file: string): FileOpResult =
|
||||
FileOpResult(success: true, file: file)
|
||||
|
||||
########################
|
||||
# Utilities
|
||||
########################
|
||||
|
||||
proc log(ip: ImageProvider, msg: string) =
|
||||
if ip.verbose: echo msg
|
||||
proc log(ip: ImageProvider, things: varargs[string, `$`]) =
|
||||
if ip.verbose:
|
||||
echo things.join()
|
||||
|
||||
func calcImageSize(maxWidth, maxHeight, imgWidth, imgHeight: int): tuple[width: int, height: int] =
|
||||
## Calculate the best fit for an image on the give screen size.
|
||||
## This should keep the image aspect ratio
|
||||
let
|
||||
ratioMax = maxWidth / maxHeight
|
||||
ratioImg = imgWidth / imgHeight
|
||||
if (ratioMax > ratioImg):
|
||||
result.width = (imgWidth * (maxHeight / imgHeight)).toInt
|
||||
result.height = maxHeight
|
||||
else:
|
||||
result.width = maxWidth
|
||||
result.height = (imgHeight * (maxWidth / imgWidth)).toInt
|
||||
|
||||
########################
|
||||
# Image Provider procs
|
||||
########################
|
||||
|
||||
proc getFox(ip: ImageProvider): FileOpResult =
|
||||
proc getPlaceHolder(ip: ImageProvider): OP[string] =
|
||||
## Provide the placeholder image.
|
||||
## This is used when no mode is active
|
||||
let f = fmt"{tmpFile}.blank"
|
||||
writeFile(f, placeholderImg)
|
||||
ok f
|
||||
|
||||
proc getFox(ip: ImageProvider): OP[string] =
|
||||
## Download image from the fox API
|
||||
try:
|
||||
let urlData = client.getContent(foxesUrl)
|
||||
@@ -68,15 +82,15 @@ proc getFox(ip: ImageProvider): FileOpResult =
|
||||
let imageData = client.getContent(info["image"].getStr)
|
||||
let dlFile = fmt"{tmpFile}.download"
|
||||
writeFile(dlFile, imageData)
|
||||
return newFileOpResult(dlFile)
|
||||
ok dlFile
|
||||
except JsonParsingError:
|
||||
ip.log fmt"Error while fetching from fox API: {getCurrentExceptionMsg()}"
|
||||
return newFileOpResultError("Json parsing error")
|
||||
fail[string] "Json parsing error"
|
||||
except KeyError:
|
||||
ip.log fmt"No image in downloaded data: {getCurrentExceptionMsg()}"
|
||||
return newFileOpResultError("No image from API")
|
||||
fail[string] "No image from API"
|
||||
|
||||
proc getInspiro(ip: ImageProvider): FileOpResult =
|
||||
proc getInspiro(ip: ImageProvider): OP[string] =
|
||||
## Download and save image from the inspiro API
|
||||
try:
|
||||
let imageUrl = client.getContent(inspiroUrl)
|
||||
@@ -84,74 +98,77 @@ proc getInspiro(ip: ImageProvider): FileOpResult =
|
||||
let imageData = client.getContent(imageUrl)
|
||||
let dlFile = fmt"{tmpFile}.download"
|
||||
writeFile(dlFile,imageData)
|
||||
return newFileOpResult(dlFile)
|
||||
ok dlFile
|
||||
except:
|
||||
ip.log fmt"Unexpected error while downloading: {getCurrentExceptionMsg()}"
|
||||
return newFileOpResultError(getCurrentExceptionMsg())
|
||||
fail[string] getCurrentExceptionMsg()
|
||||
|
||||
proc getLocalFile(ip: var ImageProvider): FileOpResult =
|
||||
proc getLocalFile(ip: var ImageProvider): OP[string] =
|
||||
## Provide an image from a local folder
|
||||
|
||||
# First, check if there are still images left to be loaded.
|
||||
# If not reread all files from the path
|
||||
if ip.files.len < 1:
|
||||
if ip.path.isNone:
|
||||
return newFileOpResultError("No path for image loading")
|
||||
ip.log "Reloading file list..."
|
||||
if fileList.len == 0:
|
||||
var tmp: seq[string]
|
||||
var split: tuple[dir, name, ext: string]
|
||||
for file in walkDirRec(ip.path.get):
|
||||
let split = splitFile(file)
|
||||
split = splitFile(file)
|
||||
if ip.exts.contains(split.ext):
|
||||
ip.files.add(file)
|
||||
ip.log fmt"Loaded {ip.files.len} files"
|
||||
shuffle(ip.files)
|
||||
tmp.add($file)
|
||||
|
||||
ip.log fmt"Loaded {tmp.len} files"
|
||||
shuffle(tmp)
|
||||
for file in tmp:
|
||||
fileList.addLast(file)
|
||||
if fileList.len == 0:
|
||||
return fail[string] "No files found"
|
||||
|
||||
let next = fileList.popFirst()
|
||||
# Remove the current file after
|
||||
result = newFileOpResult(ip.files[0])
|
||||
ip.files.delete(0)
|
||||
ok next
|
||||
|
||||
proc getFileName(ip: var ImageProvider): FileOpResult =
|
||||
proc getFileName(ip: var ImageProvider): OP[string] =
|
||||
## Get the temporary file name of the next file to display
|
||||
case ip.mode
|
||||
of Mode.None:
|
||||
return ip.getPlaceHolder()
|
||||
of Mode.File:
|
||||
return ip.getLocalFile()
|
||||
of Mode.Foxes:
|
||||
return ip.getFox()
|
||||
of Mode.Inspiro:
|
||||
return ip.getInspiro()
|
||||
else:
|
||||
return newFileOpResultError("Not implemented")
|
||||
|
||||
########################
|
||||
# Exported procs
|
||||
########################
|
||||
|
||||
proc next*(ip: var ImageProvider, width, height: int): FileOpResult =
|
||||
proc next*(ip: var ImageProvider, maxWidth, maxHeight: int): OP[string] =
|
||||
## Uses the image provider to get a new image ready to display.
|
||||
## `width` and `height` should be the size of the window.
|
||||
if ip.mode == Mode.None:
|
||||
return newFileOpResultError("No mode active")
|
||||
|
||||
let op = ip.getFileName()
|
||||
if not op.success: return op
|
||||
let r = ip.getFileName()
|
||||
if not r.isOk: return r
|
||||
|
||||
var rawPixbuf = newPixbufFromFile(op.file)
|
||||
# resize the pixbuf to best fit on screen
|
||||
var w, h: int
|
||||
if (width > height):
|
||||
h = height
|
||||
w = ((rawPixbuf.width * h) / rawPixbuf.height).toInt
|
||||
else:
|
||||
w = width
|
||||
h = ((rawPixbuf.height * w) / rawPixbuf.width).toInt
|
||||
var pixbuf = rawPixbuf.scaleSimple(w, h, InterpType.bilinear)
|
||||
var rawPixbuf = newPixbufFromFile(r.val)
|
||||
# Resize the pixbuf to best fit on screen
|
||||
let size = calcImageSize(maxWidth, maxHeight, rawPixbuf.width, rawPixbuf.height)
|
||||
ip.log "Scale image to: ", size
|
||||
let then = now()
|
||||
var pixbuf = rawPixbuf.scaleSimple(size.width, size.height, InterpType.nearest)
|
||||
let now = now()
|
||||
ip.log "Image scaled. Time: ", (now - then).inMilliseconds, "ms"
|
||||
# The pixbuf is written to disk and loaded again once because
|
||||
# directly setting the image from a pixbuf will leak memory
|
||||
let saved = pixbuf.savev(tmpFile, "png", @[])
|
||||
if not saved:
|
||||
return newFileOpResultError("Error while saving temporary image")
|
||||
return result.fail "Error while saving temporary image"
|
||||
|
||||
# GTK pixbuf leaks memory when not manually decreasing reference count
|
||||
pixbuf.genericGObjectUnref()
|
||||
rawPixbuf.genericGObjectUnref()
|
||||
pixbuf.unref()
|
||||
rawPixbuf.unref()
|
||||
|
||||
newFileOpResult(tmpFile)
|
||||
ok tmpFile
|
||||
|
||||
createDir(tmpDir)
|
||||
randomize()
|
||||
148
src/randopix.nim
148
src/randopix.nim
@@ -1,26 +1,35 @@
|
||||
import os, options, strformat
|
||||
import op
|
||||
import gintro/[glib, gobject, gtk, gio]
|
||||
import gintro/gdk except Window
|
||||
import argparse except run
|
||||
import providers, server, common
|
||||
|
||||
const
|
||||
css = slurp("app.css")
|
||||
version = "0.1"
|
||||
css = slurp("resources/app.css")
|
||||
version = slurp("version")
|
||||
helpString = [
|
||||
"ESC\tClose program",
|
||||
"H\tShow/Hide this help",
|
||||
"F\tToggle fullscreen",
|
||||
"U\tForce refresh"
|
||||
].join("\n")
|
||||
|
||||
type
|
||||
Args = ref object
|
||||
fullscreen: bool ## Applicaion is show in fullscreen mode
|
||||
verbose: bool ## More debug information in notification label
|
||||
timeout: int ## Milliseconds between image refreshes
|
||||
port: int ## Port to host the control server
|
||||
|
||||
var
|
||||
imageProvider: ImageProvider ## Gets images from the chosen source
|
||||
args: Args ## The parsed command line args
|
||||
updateTimeout: int ## ID of the timeout that updates the images
|
||||
updateTimeout, serverTimeout: int ## ID of the timeouts for image updating and server checking
|
||||
# Widgets
|
||||
window: ApplicationWindow
|
||||
label: Label
|
||||
box: Box
|
||||
# Server vor recieving commands from external tools
|
||||
serverWorker: system.Thread[ServerArgs]
|
||||
|
||||
@@ -28,21 +37,22 @@ proc log(things: varargs[string, `$`]) =
|
||||
if args.verbose:
|
||||
echo things.join()
|
||||
|
||||
proc notify(label: Label, message: string = "") =
|
||||
proc notify(label: Label, things: varargs[string, `$`]) =
|
||||
## Shows the notification box in the lower left corner.
|
||||
## If no message is passed, the box will be hidden
|
||||
label.text = message
|
||||
if (message == ""):
|
||||
label.hide
|
||||
label.text = things.join()
|
||||
if (label.text == ""):
|
||||
box.hide
|
||||
else:
|
||||
label.show
|
||||
box.show
|
||||
|
||||
proc newArgs(): Option[Args] =
|
||||
let p = newParser("randopix"):
|
||||
help(fmt"Version {version} - Display random images from different sources")
|
||||
option("-m", "--mode", help="The image source mode.", choices=enumToStrings(Mode))
|
||||
option("-p", "--path", help="Path to a directory with images for the 'file' mode")
|
||||
option("-d", "--directoy", help="Path to a directory with images for the 'file' mode")
|
||||
option("-t", "--timeout", help="Seconds before the image is refreshed", default="300")
|
||||
option("-p", "--port", help="Port over which the control server should be accessible", default="8080")
|
||||
flag("-w", "--windowed", help="Do not start in fullscreen mode")
|
||||
flag("-v", "--verbose", help="Show more information")
|
||||
|
||||
@@ -61,8 +71,8 @@ proc newArgs(): Option[Args] =
|
||||
startMode = Mode.None
|
||||
|
||||
# Create the image provider
|
||||
if opts.path != "":
|
||||
imageProvider = newImageProvider(opts.verbose, startMode, opts.path)
|
||||
if opts.directoy != "":
|
||||
imageProvider = newImageProvider(opts.verbose, startMode, opts.directoy)
|
||||
else:
|
||||
imageProvider = newImageProvider(opts.verbose, startMode)
|
||||
|
||||
@@ -76,7 +86,8 @@ proc newArgs(): Option[Args] =
|
||||
return some(Args(
|
||||
fullscreen: not opts.windowed,
|
||||
verbose: opts.verbose,
|
||||
timeout: timeout))
|
||||
timeout: timeout,
|
||||
port: opts.port.parseInt))
|
||||
except:
|
||||
echo p.help
|
||||
|
||||
@@ -88,35 +99,37 @@ proc updateImage(image: Image): bool =
|
||||
if imageProvider.mode == Mode.None:
|
||||
log "No display mode"
|
||||
label.notify "No mode selected"
|
||||
return true
|
||||
|
||||
var wWidth, wHeight: int
|
||||
window.getSize(wWidth, wHeight)
|
||||
|
||||
let op = imageProvider.next(wWidth, wHeight)
|
||||
result = op.success
|
||||
if not op.success:
|
||||
label.notify op.errorMsg
|
||||
let r = imageProvider.next(wWidth, wHeight)
|
||||
result = r.isOk
|
||||
if not r.isOk:
|
||||
label.notify r.error
|
||||
return
|
||||
|
||||
image.setFromFile(op.file)
|
||||
image.setFromFile(r.val)
|
||||
if imageProvider.mode != Mode.None:
|
||||
label.notify
|
||||
except:
|
||||
let
|
||||
e = getCurrentException()
|
||||
msg = getCurrentExceptionMsg()
|
||||
log "Got exception ", repr(e), " with message ", msg
|
||||
label.notify "Error while refreshing image, retrying..."
|
||||
label.notify "Error while refreshing, retrying..."
|
||||
return false
|
||||
|
||||
proc timedUpdate(image: Image): bool =
|
||||
discard updateImage(image);
|
||||
discard updateImage(image)
|
||||
# Force garbage collection now. Otherwise the RAM will fill up until the GC is triggered.
|
||||
GC_fullCollect()
|
||||
updateTimeout = int(timeoutAdd(uint32(args.timeout), timedUpdate, image))
|
||||
return false
|
||||
|
||||
proc forceUpdate(action: SimpleAction; parameter: Variant; image: Image): void =
|
||||
log "Refreshing image..."
|
||||
label.notify "Refreshing image..."
|
||||
log "Refreshing..."
|
||||
label.notify "Refreshing..."
|
||||
if updateTimeout > 0:
|
||||
discard updateTimeout.remove
|
||||
updateTimeout = int(timeoutAdd(500, timedUpdate, image))
|
||||
@@ -137,21 +150,22 @@ proc checkServerChannel(image: Image): bool =
|
||||
let val = msg.parameter.parseInt * 1000
|
||||
log "Setting timeout to ", val
|
||||
args.timeout = val
|
||||
if updateTimeout > 0:
|
||||
discard updateTimeout.remove
|
||||
updateTimeout = int(timeoutAdd(uint32(args.timeout), timedUpdate, image))
|
||||
|
||||
of cMode:
|
||||
try:
|
||||
let mode = parseEnum[Mode](msg.parameter)
|
||||
log "Switching mode: ", mode
|
||||
imageProvider.mode = mode
|
||||
forceUpdate(nil, nil, image)
|
||||
log "Switching mode: ", mode
|
||||
label.notify fmt"Switch Mode: {msg.parameter.capitalizeAscii()}"
|
||||
except ValueError:
|
||||
log "Invalid mode: ", msg.parameter
|
||||
|
||||
else:
|
||||
log "Command ignored: ", msg.command
|
||||
|
||||
sleep(100)
|
||||
result = true
|
||||
|
||||
proc toggleFullscreen(action: SimpleAction; parameter: Variant; window: ApplicationWindow) =
|
||||
@@ -162,19 +176,34 @@ proc toggleFullscreen(action: SimpleAction; parameter: Variant; window: Applicat
|
||||
window.fullscreen
|
||||
args.fullscreen = not args.fullscreen
|
||||
|
||||
proc toggleHelp(action: SimpleAction; parameter: Variant; box: Box) =
|
||||
if box.visible:
|
||||
box.hide
|
||||
else:
|
||||
box.show
|
||||
|
||||
proc cleanUp(w: ApplicationWindow, app: Application) =
|
||||
## Stop the control server and exit the GTK application
|
||||
log "Stopping control server..."
|
||||
closeServer()
|
||||
serverWorker.joinThread()
|
||||
chan.close()
|
||||
log "Server stopped."
|
||||
log "Server channel closed."
|
||||
app.quit()
|
||||
|
||||
proc quit(action: SimpleAction; parameter: Variant; app: Application) =
|
||||
## Application quit event
|
||||
cleanUp(window, app)
|
||||
|
||||
proc realizeWindow(window: ApplicationWindow, image: Image): void =
|
||||
## Hides the mouse pointer for the application.
|
||||
if args.fullscreen:
|
||||
window.fullscreen
|
||||
let cur = window.getDisplay().newCursorForDisplay(CursorType.blankCursor)
|
||||
let win = window.getWindow()
|
||||
win.setCursor(cur)
|
||||
|
||||
# Setting the inital image
|
||||
# Fix 1 second timeout to make sure all other initialization has finished
|
||||
updateTimeout = int(timeoutAdd(1000, timedUpdate, image))
|
||||
|
||||
proc appActivate(app: Application) =
|
||||
# Parse arguments from the command line
|
||||
let parsed = newArgs()
|
||||
@@ -194,51 +223,68 @@ proc appActivate(app: Application) =
|
||||
addProviderForScreen(getDefaultScreen(), provider, STYLE_PROVIDER_PRIORITY_USER)
|
||||
|
||||
# Create all windgets we are gonna use
|
||||
label = newLabel("Starting...")
|
||||
label.halign = Align.`end`
|
||||
label.valign = Align.`end`
|
||||
label = newLabel(fmt"Starting ('H' for help)...")
|
||||
|
||||
let spinner = newSpinner()
|
||||
spinner.start()
|
||||
|
||||
box = newBox(Orientation.horizontal, 2)
|
||||
box.halign = Align.`end`
|
||||
box.valign = Align.`end`
|
||||
box.packStart(spinner, true, true, 10)
|
||||
box.packStart(label, true, true, 0)
|
||||
|
||||
let helpText = newLabel(helpString)
|
||||
let helpBox = newBox(Orientation.vertical, 0)
|
||||
helpBox.packStart(helpText, true, true, 0)
|
||||
helpBox.halign = Align.start
|
||||
helpBox.valign = Align.start
|
||||
|
||||
let container = newOverlay()
|
||||
container.addOverlay(label)
|
||||
container.addOverlay(box)
|
||||
container.addOverlay(helpBox)
|
||||
window.add(container)
|
||||
|
||||
let image = newImage()
|
||||
container.add(image)
|
||||
|
||||
if args.fullscreen:
|
||||
window.fullscreen
|
||||
|
||||
## Connect the GTK signals to the procs
|
||||
let fullscreenAction = newSimpleAction("fullscreen")
|
||||
discard fullscreenAction.connect("activate", toggleFullscreen, window)
|
||||
var action: SimpleAction
|
||||
|
||||
action = newSimpleAction("fullscreen")
|
||||
discard action.connect("activate", toggleFullscreen, window)
|
||||
app.setAccelsForAction("win.fullscreen", "F")
|
||||
window.actionMap.addAction(fullscreenAction)
|
||||
window.actionMap.addAction(action)
|
||||
|
||||
let quitAction = newSimpleAction("quit")
|
||||
discard quitAction.connect("activate", quit, app)
|
||||
action = newSimpleAction("quit")
|
||||
discard action.connect("activate", quit, app)
|
||||
app.setAccelsForAction("win.quit", "Escape")
|
||||
window.actionMap.addAction(quitAction)
|
||||
window.actionMap.addAction(action)
|
||||
|
||||
let updateImageAction = newSimpleAction("update")
|
||||
discard updateImageAction.connect("activate", forceUpdate, image)
|
||||
action = newSimpleAction("update")
|
||||
discard action.connect("activate", forceUpdate, image)
|
||||
app.setAccelsForAction("win.update", "U")
|
||||
window.actionMap.addAction(updateImageAction)
|
||||
window.actionMap.addAction(action)
|
||||
|
||||
action = newSimpleAction("help")
|
||||
discard action.connect("activate", toggleHelp, helpBox)
|
||||
app.setAccelsForAction("win.help", "H")
|
||||
window.actionMap.addAction(action)
|
||||
|
||||
window.connect("destroy", cleanUp, app)
|
||||
window.connect("realize", realizeWindow, image)
|
||||
|
||||
window.showAll
|
||||
|
||||
# Setting the inital image
|
||||
# Fix 1 second timeout to make sure all other initialization has finished
|
||||
updateTimeout = int(timeoutAdd(1000, timedUpdate, image))
|
||||
# Help is only shown on demand
|
||||
helpBox.hide
|
||||
|
||||
## open communication channel from the control server
|
||||
chan.open()
|
||||
|
||||
## Start the server for handling incoming commands
|
||||
let serverArgs = newServerArgs(args.verbose)
|
||||
let serverArgs = ServerArgs(verbose: args.verbose, port: args.port)
|
||||
createThread(serverWorker, runServer, serverArgs)
|
||||
discard idleAdd(checkServerChannel, image)
|
||||
serverTimeout = int(timeoutAdd(100, checkServerChannel, image))
|
||||
|
||||
when isMainModule:
|
||||
let app = newApplication("org.luxick.randopix")
|
||||
|
||||
@@ -1,3 +1,3 @@
|
||||
threads:on
|
||||
d:ssl
|
||||
gc:arc
|
||||
# gc:arc
|
||||
@@ -2,8 +2,8 @@ window {
|
||||
background: black;
|
||||
font-size: 30px;
|
||||
}
|
||||
label {
|
||||
background-color: #fff;
|
||||
box {
|
||||
background-color: rgba(255, 255, 255, .75);
|
||||
border: 2px solid gray;
|
||||
border-radius: 5px;
|
||||
margin: 10px;
|
||||
BIN
src/resources/blank.png
Normal file
BIN
src/resources/blank.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 10 KiB |
BIN
src/resources/www/favicon.ico
Normal file
BIN
src/resources/www/favicon.ico
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 1.1 KiB |
BIN
src/resources/www/github.png
Normal file
BIN
src/resources/www/github.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 1.5 KiB |
53
src/resources/www/index.html
Normal file
53
src/resources/www/index.html
Normal file
@@ -0,0 +1,53 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="en">
|
||||
<head>
|
||||
<meta charset="utf-8" />
|
||||
<meta http-equiv="x-ua-compatible" content="ie=edge" />
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1" />
|
||||
|
||||
<title>randopix</title>
|
||||
|
||||
<link rel="stylesheet" type="text/css" href="/site.css">
|
||||
|
||||
<script src="/pixctrl.js" type="text/javascript"></script>
|
||||
<script src="/script.js" type="text/javascript"></script>
|
||||
</head>
|
||||
|
||||
<body class="star-bg">
|
||||
<main>
|
||||
<h1 class="center">Randopix Remote</h1>
|
||||
|
||||
<p>Control the image that is shown on this randopix.</p>
|
||||
|
||||
<div class="control">
|
||||
<div class="control-info">Load the next image</div>
|
||||
<div class="control-body">
|
||||
<button type="button" class="btn" onclick="refresh()">Refresh Image Now!</button>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="control">
|
||||
<div class="control-info">Switch the image mode</div>
|
||||
<div class="control-body">
|
||||
<select id="modeselect"></select>
|
||||
<button type="button" class="btn" onclick="js_setMode()">Set Mode</button>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="control">
|
||||
<div class="control-info">Adjust timespan between images</div>
|
||||
<div class="control-body">
|
||||
<input id="timeout" type="number">
|
||||
<button type="button" class="btn" onclick="js_setTimeout()">Set Timeout</button>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="social">
|
||||
<a class="btn btn-mini" href="https://github.com/luxick/randopix">
|
||||
<img src="/github.png"></img>
|
||||
Source code and usage
|
||||
</a>
|
||||
</div>
|
||||
</main>
|
||||
</body>
|
||||
</html>
|
||||
BIN
src/resources/www/microfab.gif
Normal file
BIN
src/resources/www/microfab.gif
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 18 KiB |
BIN
src/resources/www/not-comic-sans.woff
Normal file
BIN
src/resources/www/not-comic-sans.woff
Normal file
Binary file not shown.
30
src/resources/www/script.js
Normal file
30
src/resources/www/script.js
Normal file
@@ -0,0 +1,30 @@
|
||||
function capitalize(string) {
|
||||
return string.charAt(0).toUpperCase() + string.slice(1);
|
||||
}
|
||||
|
||||
window.onload = () => {
|
||||
const modes = getModes();
|
||||
const modeselect = document.getElementById("modeselect");
|
||||
modes.forEach(mode => {
|
||||
let opt = document.createElement('option');
|
||||
opt.value = mode;
|
||||
opt.innerHTML = capitalize(mode)
|
||||
modeselect.appendChild(opt);
|
||||
});
|
||||
}
|
||||
|
||||
function js_setTimeout() {
|
||||
const elem = document.getElementById("timeout");
|
||||
const timeout = parseInt(elem.value);
|
||||
if (timeout < 1) {
|
||||
console.error("timeout must be positive");
|
||||
return;
|
||||
}
|
||||
setTimeout(timeout.toString());
|
||||
elem.value = null;
|
||||
}
|
||||
|
||||
function js_setMode() {
|
||||
const modeselect = document.getElementById("modeselect");
|
||||
switchMode(modeselect.value)
|
||||
}
|
||||
157
src/resources/www/site.css
Normal file
157
src/resources/www/site.css
Normal file
@@ -0,0 +1,157 @@
|
||||
@charset "utf-8";
|
||||
/* CSS Document */
|
||||
|
||||
@font-face {
|
||||
font-family: notcomicsans;
|
||||
src: url("/not-comic-sans.woff") format('truetype');
|
||||
font-weight: normal;
|
||||
font-style: normal;
|
||||
}
|
||||
|
||||
.star-bg {
|
||||
background-color: #1c1d1b;
|
||||
background-image: url("/stars.gif")
|
||||
}
|
||||
|
||||
/* Chrome, Safari, Opera */
|
||||
@-webkit-keyframes rainbow {
|
||||
0%{color: orange;}
|
||||
10%{color: purple;}
|
||||
20%{color: red;}
|
||||
30%{color: CadetBlue;}
|
||||
40%{color: yellow;}
|
||||
50%{color: coral;}
|
||||
60%{color: green;}
|
||||
70%{color: cyan;}
|
||||
80%{color: DeepPink;}
|
||||
90%{color: DodgerBlue;}
|
||||
100%{color: orange;}
|
||||
}
|
||||
|
||||
/* Internet Explorer */
|
||||
@-ms-keyframes rainbow {
|
||||
0%{color: orange;}
|
||||
10%{color: purple;}
|
||||
20%{color: red;}
|
||||
30%{color: CadetBlue;}
|
||||
40%{color: yellow;}
|
||||
50%{color: coral;}
|
||||
60%{color: green;}
|
||||
70%{color: cyan;}
|
||||
80%{color: DeepPink;}
|
||||
90%{color: DodgerBlue;}
|
||||
100%{color: orange;}
|
||||
}
|
||||
|
||||
/* Standard Syntax */
|
||||
@keyframes rainbow {
|
||||
0%{color: orange;}
|
||||
10%{color: purple;}
|
||||
20%{color: red;}
|
||||
30%{color: CadetBlue;}
|
||||
40%{color: yellow;}
|
||||
50%{color: coral;}
|
||||
60%{color: green;}
|
||||
70%{color: cyan;}
|
||||
80%{color: DeepPink;}
|
||||
90%{color: DodgerBlue;}
|
||||
100%{color: orange;}
|
||||
}
|
||||
|
||||
body {
|
||||
font-family: notcomicsans;
|
||||
color:#FFFF00;
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
align-items: stretch;
|
||||
font-size: 1.2rem;
|
||||
}
|
||||
|
||||
main {
|
||||
max-width: 900px;
|
||||
align-self: center;
|
||||
border: 1px solid gray;
|
||||
border-radius: 5px;
|
||||
background-image: url("/microfab.gif");
|
||||
padding: 15px;
|
||||
}
|
||||
|
||||
.control {
|
||||
padding-bottom: 20px;
|
||||
}
|
||||
|
||||
.control-info {
|
||||
padding-bottom: 5px;
|
||||
}
|
||||
|
||||
.control-body {
|
||||
display: flex;
|
||||
justify-content: space-around;
|
||||
align-items: center;
|
||||
}
|
||||
.control-body > * {
|
||||
margin-left: 5px;
|
||||
margin-right: 5px;
|
||||
}
|
||||
|
||||
h1 {
|
||||
/* Chrome, Safari, Opera */
|
||||
-webkit-animation: rainbow 5s infinite;
|
||||
/* Internet Explorer */
|
||||
-ms-animation: rainbow 5s infinite;
|
||||
/* Standar Syntax */
|
||||
animation: rainbow 5s infinite;
|
||||
margin-top: 0;
|
||||
}
|
||||
|
||||
button {
|
||||
padding: 0;
|
||||
border: none;
|
||||
font: inherit;
|
||||
color: inherit;
|
||||
background-color: transparent;
|
||||
/* show a hand cursor on hover; some argue that we
|
||||
should keep the default arrow cursor for buttons */
|
||||
cursor: pointer;
|
||||
}
|
||||
|
||||
a:visited {
|
||||
color: #ff0;
|
||||
}
|
||||
|
||||
.btn {
|
||||
text-align: center;
|
||||
font-size: 1.3rem;
|
||||
text-decoration: none;
|
||||
display: block;
|
||||
border: 2px solid darkgray;
|
||||
border-radius: 5px;
|
||||
padding: 0px 10px;
|
||||
background-color: #1c1d1b;
|
||||
}
|
||||
.btn:hover {
|
||||
color: #ff0;
|
||||
fill: #ff0;
|
||||
background-color: #0b0c0b;
|
||||
}
|
||||
|
||||
.btn-mini {
|
||||
font-size: 0.75rem;
|
||||
border: 1px solid darkgray;
|
||||
padding: 3px;
|
||||
display: flex;
|
||||
align-items: center;
|
||||
}
|
||||
.btn-mini > img {
|
||||
width: 0.75rem;
|
||||
height: 0.75rem;
|
||||
margin-right: 5px;
|
||||
}
|
||||
|
||||
.social {
|
||||
margin-top: 20px;
|
||||
display: inline-block;
|
||||
}
|
||||
.center {
|
||||
text-align: center;
|
||||
}
|
||||
BIN
src/resources/www/stars.gif
Normal file
BIN
src/resources/www/stars.gif
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 11 KiB |
115
src/server.nim
115
src/server.nim
@@ -1,60 +1,87 @@
|
||||
import net, json, strutils
|
||||
import asyncdispatch, strutils, json, logging, os
|
||||
import jester
|
||||
import common
|
||||
|
||||
when defined(release):
|
||||
proc slurpResources(): Table[string, string] {.compileTime.} =
|
||||
## Include everything from the www dir into the binary.
|
||||
## This way the final executable will not need an static web folder.
|
||||
for item in walkDir("src/resources/www/", true):
|
||||
if item.kind == pcFile:
|
||||
result[item.path] = slurp("resources/www/" & item.path)
|
||||
|
||||
const resources = slurpResources()
|
||||
|
||||
const
|
||||
contentTypes = {
|
||||
".js": "text/javascript",
|
||||
".css": "text/css"
|
||||
}.toTable
|
||||
|
||||
type
|
||||
ServerArgs* = object of RootObj
|
||||
verbose: bool
|
||||
verbose*: bool
|
||||
port*: int
|
||||
|
||||
var
|
||||
chan*: Channel[CommandMessage]
|
||||
verbose: bool
|
||||
|
||||
proc newServerArgs*(verbose: bool): ServerArgs =
|
||||
ServerArgs(verbose: verbose)
|
||||
|
||||
proc log(things: varargs[string, `$`]) =
|
||||
if verbose:
|
||||
echo things.join()
|
||||
|
||||
proc closeServer*() =
|
||||
## Sends a "Close" command to the server
|
||||
var socket = newSocket()
|
||||
socket.connect("127.0.0.1", Port(defaultPort))
|
||||
let c = newCommand(cClose)
|
||||
socket.send(c.wrap)
|
||||
socket.close()
|
||||
when defined(release):
|
||||
## When in release mode, use resources includes in the binary.
|
||||
## When developing use the files directly.
|
||||
router getRouter:
|
||||
get "/":
|
||||
resp resources["index.html"]
|
||||
|
||||
get "/@resource":
|
||||
try:
|
||||
var cType: string
|
||||
if contentTypes.hasKey(@"resource".splitFile.ext):
|
||||
cType = contentTypes[@"resource".splitFile.ext]
|
||||
resp resources[@"resource"], contentType=cType
|
||||
except KeyError:
|
||||
log "Resource not found: ", @"resource"
|
||||
resp Http404
|
||||
else:
|
||||
router getRouter:
|
||||
get "/":
|
||||
resp readFile("src/resources/www/index.html")
|
||||
get "/@resource":
|
||||
try:
|
||||
var cType: string
|
||||
if contentTypes.hasKey(@"resource".splitFile.ext):
|
||||
cType = contentTypes[@"resource".splitFile.ext]
|
||||
resp readFile("src/resources/www/" & @"resource"), contentType=cType
|
||||
except KeyError:
|
||||
log "Resource not found: ", @"resource"
|
||||
resp Http404
|
||||
|
||||
router postRouter:
|
||||
post "/":
|
||||
try:
|
||||
log "Command from ", request.ip
|
||||
let json = request.body.parseJson
|
||||
let msg = json.to(CommandMessage)
|
||||
log "Got message: ", $msg
|
||||
# Pass command from client to main applicaiton
|
||||
chan.send(msg)
|
||||
resp Http200
|
||||
except:
|
||||
log "Error: ", getCurrentExceptionMsg()
|
||||
|
||||
router randopixRouter:
|
||||
extend postRouter, ""
|
||||
extend getRouter, ""
|
||||
|
||||
proc runServer*[ServerArgs](arg: ServerArgs) {.thread, nimcall.} =
|
||||
verbose = arg.verbose
|
||||
var server = net.newSocket()
|
||||
server.bindAddr(Port(defaultPort))
|
||||
server.listen()
|
||||
log "Control server is listening"
|
||||
|
||||
while true:
|
||||
# Process client requests
|
||||
var client = net.newSocket()
|
||||
server.accept(client)
|
||||
log "Client connected"
|
||||
try:
|
||||
var line = client.recvLine()
|
||||
if line == "":
|
||||
log "No data from client"
|
||||
continue
|
||||
|
||||
var jsonData = parseJson(line)
|
||||
let msg = jsonData.to(CommandMessage)
|
||||
case msg.command
|
||||
of cClose:
|
||||
log "Server recieved termination command. Exiting."
|
||||
break
|
||||
else:
|
||||
# Pass command from client to main applicaiton
|
||||
chan.send(msg)
|
||||
|
||||
except OSError:
|
||||
log "Server error: ", getCurrentExceptionMsg()
|
||||
except:
|
||||
log "Invalid command from client: ", getCurrentExceptionMsg()
|
||||
log repr(getCurrentException())
|
||||
server.close()
|
||||
logging.setLogFilter(lvlInfo)
|
||||
let port = Port(arg.port)
|
||||
let settings = newSettings(port=port)
|
||||
var server = initJester(randopixRouter, settings=settings)
|
||||
server.serve()
|
||||
1
src/version
Normal file
1
src/version
Normal file
@@ -0,0 +1 @@
|
||||
1.1.0
|
||||
Reference in New Issue
Block a user