all repos — litestore @ 6f31d732255c509351909aaf0ca81116392d7da4

A minimalist nosql document store.

Merge branch 'master' of https://github.com/h3rald/litestore
h3rald h3rald@h3rald.com
Tue, 18 Feb 2020 14:01:54 +0100
commit

6f31d732255c509351909aaf0ca81116392d7da4

parent

1a2f0f9e9e90e59584197a66e9e88a5ffa2d22d8

A src/litestorepkg/examples/config.json

@@ -0,0 +1,24 @@

+{ + "settings": { + "mount": true, + "directory": "admin" + }, + "resources": { + "/info": { + "GET": { "auth": ["admin:server"] } + }, + "/docs/*": { + "POST": { "auth": ["admin:server"] }, + "PATCH": { "auth": ["admin:server"] }, + "PUT": { "auth": ["admin:server"] }, + "DELETE": { "auth": ["admin:server"] } + }, + "/docs/wiki/*": { + "POST": { "auth": ["admin:wiki"] }, + "PUT": { "auth": ["admin:wiki"] }, + "PATCH": { "auth": ["admin:wiki"] }, + "DELETE": { "auth": ["admin:wiki"] } + } + }, + "signature": "\n-----BEGIN CERTIFICATE-----\n<certificate text goes here>\n-----END CERTIFICATE-----\n" +}
M src/litestorepkg/lib/cli.nimsrc/litestorepkg/lib/cli.nim

@@ -17,22 +17,25 @@ readonly = false

logLevel = "warn" mount = false auth = newJNull() - exOperation:string = "" - exFile:string = "" - exBody:string = "" - exType:string = "" - exUri:string = "" + configuration = newJNull() + authFile = "" + configFile = "" + exOperation = "" + exFile = "" + exBody = "" + exType = "" + exUri = "" + cliSettings = newJObject() let usage* = appname & " v" & pkgVersion & " - Lightweight REST Document Store" & """ -(c) 2015-2018 Fabio Cevasco +(c) 2015-2020 Fabio Cevasco Usage: litestore [command] [option1 option2 ...] Commands: - run Start LiteStore server (default if no command specified). delete Delete a previously-imported specified directory (requires -d). execute Execute an operation on data stored in the datastore (requires -o, -u, and in certain cases -f or -b and -t). import Import the specified directory into the datastore (requires -d).

@@ -45,6 +48,7 @@ -a, --address Specify server address (default: 127.0.0.1).

--auth Specify an authentication/authorization configuration file. -b, --body Specify a string containing input data for an operation to be executed. -d, --directory Specify a directory to serve, import, export, delete, or mount. + -c, --config Specify a configuration file. -f, --file Specify a file containing input data for an operation to be executed. -h, --help Display this message. -l, --log Specify the log level: debug, info, warn, error, none (default: info)

@@ -84,12 +88,15 @@ of "address", "a":

if val == "": fail(100, "Address not specified.") address = val + cliSettings["address"] = %address of "port", "p": if val == "": fail(101, "Port not specified.") port = val.parseInt + cliSettings["port"] = %port of "store", "s": file = val + cliSettings["store"] = %file of "log", "l": if val == "": fail(102, "Log level not specified.")

@@ -107,10 +114,12 @@ LOG.level = lvNone

else: fail(103, "Invalid log level '$1'" % val) loglevel = val + cliSettings["log"] = %logLevel of "directory", "d": if val == "": fail(104, "Directory not specified.") directory = val + cliSettings["directory"] = %directory of "operation", "o": if val == "": fail(106, "Operation not specified.")

@@ -134,9 +143,15 @@ exType = val

of "auth": if val == "": fail(114, "Authentication/Authorization configuration file not specified.") - auth = val.parseFile + authFile = val + of "config", "c": + if val == "": + fail(115, "Configuration file not specified.") + configuration = val.parseFile + configFile = val of "mount", "m": mount = true + cliSettings["mounnt"] = %mount of "version", "v": echo pkgVersion quit(0)

@@ -145,11 +160,39 @@ echo usage

quit(0) of "readonly", "r": readonly = true + cliSettings["readonly"] = %readonly else: discard else: discard +# Process auth configuration if present + +if auth == newJNull() and configuration != newJNull() and configuration.hasKey("signature"): + auth = newJObject(); + auth["access"] = newJObject(); + auth["signature"] = configuration["signature"] + for k, v in configuration["resources"].pairs: + if v.hasKey("auth"): + auth["access"][k] = v["auth"] + +# Process config settings if present and if no cli settings are set + +if configuration != newJNull() and configuration.hasKey("settings"): + let settings = configuration["settings"] + if not cliSettings.hasKey("address") and settings.hasKey("address"): + address = settings["address"].getStr + if not cliSettings.hasKey("port") and settings.hasKey("port"): + port = settings["port"].getInt + if not cliSettings.hasKey("store") and settings.hasKey("store"): + file = settings["store"].getStr + if not cliSettings.hasKey("directory") and settings.hasKey("directory"): + directory = settings["directory"].getStr + if not cliSettings.hasKey("mount") and settings.hasKey("mount"): + mount = settings["mount"].getBool + if not cliSettings.hasKey("readonly") and settings.hasKey("readonly"): + readonly = settings["readonly"].getBool + # Validation if directory == "" and (operation in [opDelete, opImport, opExport] or mount):

@@ -164,6 +207,8 @@

if exOperation == "" and operation == opExecute: fail(111, "--operation option not specified") + + LS.operation = operation LS.address = address LS.port = port

@@ -173,6 +218,9 @@ LS.readonly = readonly

LS.favicon = favicon LS.loglevel = loglevel LS.auth = auth +LS.authFile = authFile +LS.config = configuration +LS.configFile = configFile LS.mount = mount LS.execution.file = exFile LS.execution.body = exBody
M src/litestorepkg/lib/server.nimsrc/litestorepkg/lib/server.nim

@@ -216,6 +216,16 @@ let res = req.process(LS)

let areq = asynchttpserver.Request(req) await areq.respond(res.code, res.content, res.headers) echo(LS.appname & " v" & LS.appversion & " started on " & LS.address & ":" & $LS.port & ".") + if LS.configFile != "": + echo "- Configuration File: " & LS.configFile + if LS.authFile != "": + echo "- Auth File: " & LS.authFile if LS.mount: - echo("Mirroring datastore changes to: " & LS.directory) + echo "- Mirroring datastore changes to: " & LS.directory + if LS.readonly: + echo "- Read-only mode" + echo "- Log Level: " & LS.loglevel + echo "- Store: " & LS.file + if LS.auth != newJNull(): + echo "- Authorization configured" asyncCheck server.serve(LS.port.Port, handleHttpRequest, LS.address)
M src/litestorepkg/lib/types.nimsrc/litestorepkg/lib/types.nim

@@ -15,6 +15,9 @@ EDirectoryNotFound* = object of Exception

EFileNotFound* = object of Exception EFileExists* = object of Exception EInvalidRequest* = object of Exception + ConfigFiles* = object + auth*: string + config*: string ExecutionData* = object operation*: string file*: string

@@ -69,6 +72,8 @@ execution*: ExecutionData

address*: string port*: int operation*: Operation + config*: JsonNode + configFile*: string directory*: string file*: string mount*: bool

@@ -76,6 +81,7 @@ readonly*: bool

appname*: string appversion*: string auth*: JsonNode + authFile*: string favicon*:string loglevel*:string LSRequest* = asynchttpserver.Request