Compare commits
1 Commits
920eb49941
...
2cb658c723
Author | SHA1 | Date |
---|---|---|
Martin | 2cb658c723 |
|
@ -16,13 +16,6 @@ type Config* = object
|
||||||
mountcwd*: Option[bool]
|
mountcwd*: Option[bool]
|
||||||
privileged*: Option[bool]
|
privileged*: Option[bool]
|
||||||
sethostname*: Option[bool]
|
sethostname*: Option[bool]
|
||||||
allowdri*: Option[bool]
|
|
||||||
dbus*: Option[bool]
|
|
||||||
dbussee*: Option[seq[string]]
|
|
||||||
dbustalk*: Option[seq[string]]
|
|
||||||
dbusown*: Option[seq[string]]
|
|
||||||
dbuscall*: Option[seq[string]]
|
|
||||||
dbusbroadcast*: Option[seq[string]]
|
|
||||||
|
|
||||||
proc applyConfig*(call: var BwrapCall, config: Config) =
|
proc applyConfig*(call: var BwrapCall, config: Config) =
|
||||||
for mount in config.mount.get(@[]):
|
for mount in config.mount.get(@[]):
|
||||||
|
@ -46,19 +39,10 @@ proc extendConfig*(config: var Config): Config {.discardable.} =
|
||||||
var eConf = loadConfig(getProfilePath(config.extends.unsafeGet))
|
var eConf = loadConfig(getProfilePath(config.extends.unsafeGet))
|
||||||
eConf.extendConfig()
|
eConf.extendConfig()
|
||||||
|
|
||||||
# todo: replace using macro / templates
|
|
||||||
config.mount = some(config.mount.get(@[]).concat(eConf.mount.get(@[])))
|
config.mount = some(config.mount.get(@[]).concat(eConf.mount.get(@[])))
|
||||||
config.romount = some(config.romount.get(@[]).concat(eConf.romount.get(@[])))
|
config.romount = some(config.romount.get(@[]).concat(eConf.romount.get(@[])))
|
||||||
config.symlinks = some(config.symlinks.get(@[]).concat(eConf.symlinks.get(@[])))
|
config.symlinks = some(config.symlinks.get(@[]).concat(eConf.symlinks.get(@[])))
|
||||||
config.mountcwd = some(config.mountcwd.get(eConf.mountcwd.get(false)))
|
config.mountcwd = some(config.mountcwd.get(eConf.mountcwd.get(false)))
|
||||||
config.sethostname = some(config.sethostname.get(eConf.sethostname.get(false)))
|
config.sethostname = some(config.sethostname.get(eConf.sethostname.get(false)))
|
||||||
config.allowdri = some(config.allowdri.get(eConf.allowdri.get(false)))
|
|
||||||
|
|
||||||
config.dbus = some(config.dbus.get(eConf.dbus.get(false)))
|
|
||||||
config.dbussee = some(config.dbussee.get(@[]).concat(eConf.dbussee.get(@[])))
|
|
||||||
config.dbustalk = some(config.dbustalk.get(@[]).concat(eConf.dbustalk.get(@[])))
|
|
||||||
config.dbusown = some(config.dbusown.get(@[]).concat(eConf.dbusown.get(@[])))
|
|
||||||
config.dbuscall = some(config.dbuscall.get(@[]).concat(eConf.dbuscall.get(@[])))
|
|
||||||
config.dbusbroadcast = some(config.dbusbroadcast.get(@[]).concat(eConf.dbusbroadcast.get(@[])))
|
|
||||||
|
|
||||||
return config
|
return config
|
||||||
|
|
81
lib/dbus.nim
81
lib/dbus.nim
|
@ -1,54 +1,43 @@
|
||||||
import strformat
|
import strformat
|
||||||
import options
|
|
||||||
import config
|
|
||||||
import osproc
|
import osproc
|
||||||
import random
|
|
||||||
import os
|
|
||||||
|
|
||||||
type DbusProxy* = object
|
type DbusProxy* = object
|
||||||
process*: Process
|
|
||||||
socket*: string
|
|
||||||
args: seq[string]
|
args: seq[string]
|
||||||
|
|
||||||
proc exec*(proxy: var DbusProxy) =
|
proc addSee*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"--see={name}")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc addTalk*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"--talk={name}")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc addOwn*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"--own={name}")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc addCall*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"--call={name}")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc addBroadcast*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"--broadcast={name}")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc paths*(proxy: var DbusProxy, systembus: string, filterbus: string): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add(&"unix:path={systembus}")
|
||||||
|
proxy.args.add(filterbus)
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc log*(proxy: var DbusProxy): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add("--log")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc filter*(proxy: var DbusProxy): var DbusProxy {.discardable.} =
|
||||||
|
proxy.args.add("--filter")
|
||||||
|
proxy
|
||||||
|
|
||||||
|
proc exec*(proxy: DbusProxy): Process {.discardable.} =
|
||||||
# todo: start dbus proxy in bwrap
|
# todo: start dbus proxy in bwrap
|
||||||
# todo: pass arguments as fd
|
# todo: pass arguments as fd
|
||||||
proxy.process = startProcess("xdg-dbus-proxy", args = proxy.args,
|
startProcess("xdg-dbus-proxy", args = proxy.args, options = {poEchoCmd, poParentStreams, poUsePath})
|
||||||
options = {poEchoCmd, poParentStreams, poUsePath})
|
|
||||||
|
|
||||||
proc startDBusProxy*(config: Config, hostname: string): DbusProxy =
|
|
||||||
let busPath = getEnv("DBUS_SESSION_BUS_ADDRESS")
|
|
||||||
let runtimeDir = getEnv("XDG_RUNTIME_DIR")
|
|
||||||
|
|
||||||
if busPath == "" or runtimeDir == "":
|
|
||||||
raise newException(IOError, "DBUS_SESSION_BUS_ADDRESS and XDG_RUNTIME_DIR are required")
|
|
||||||
|
|
||||||
let id = rand(1000)
|
|
||||||
let filterName = &"dbus-proxy-{hostname}-{id}"
|
|
||||||
|
|
||||||
var proxy = DbusProxy()
|
|
||||||
proxy.socket = &"{runtimeDir}/{filterName}"
|
|
||||||
|
|
||||||
proxy.args.add(busPath)
|
|
||||||
proxy.args.add(proxy.socket)
|
|
||||||
|
|
||||||
for name in config.dbussee.get(@[]):
|
|
||||||
proxy.args.add(&"--see={name}")
|
|
||||||
|
|
||||||
for name in config.dbustalk.get(@[]):
|
|
||||||
proxy.args.add(&"--talk={name}")
|
|
||||||
|
|
||||||
for name in config.dbuscall.get(@[]):
|
|
||||||
proxy.args.add(&"--call={name}")
|
|
||||||
|
|
||||||
for name in config.dbusown.get(@[]):
|
|
||||||
proxy.args.add(&"--own={name}")
|
|
||||||
|
|
||||||
for name in config.dbusbroadcast.get(@[]):
|
|
||||||
proxy.args.add(&"--broadcast={name}")
|
|
||||||
|
|
||||||
proxy.args.add("--filter")
|
|
||||||
proxy.args.add("--log")
|
|
||||||
proxy.exec()
|
|
||||||
|
|
||||||
proxy
|
|
|
@ -1,12 +1,11 @@
|
||||||
import strutils
|
import os
|
||||||
import options
|
|
||||||
import config
|
|
||||||
import utils
|
|
||||||
import bwrap
|
|
||||||
import args
|
import args
|
||||||
import json
|
import json
|
||||||
import dbus
|
import dbus
|
||||||
import os
|
import utils
|
||||||
|
import bwrap
|
||||||
|
import config
|
||||||
|
import options
|
||||||
|
|
||||||
proc sandboxExec*(args: Args) =
|
proc sandboxExec*(args: Args) =
|
||||||
var call = BwrapCall()
|
var call = BwrapCall()
|
||||||
|
@ -35,10 +34,28 @@ proc sandboxExec*(args: Args) =
|
||||||
var config = loadConfig(configPath.unsafeGet)
|
var config = loadConfig(configPath.unsafeGet)
|
||||||
config.extendConfig()
|
config.extendConfig()
|
||||||
|
|
||||||
|
var proxy = DbusProxy()
|
||||||
|
|
||||||
|
proxy
|
||||||
|
.paths("/run/user/1000/bus", "/run/user/1000/.bus-sandboxed/test2")
|
||||||
|
.addCall("org.freedesktop.Notifications.*=@/org/freedesktop/Notifications")
|
||||||
|
.addCall("org.freedesktop.portal.*=*")
|
||||||
|
.addBroadcast("org.freedesktop.portal.*=@/org/freedesktop/portal/*")
|
||||||
|
.addOwn("org.mpris.MediaPlayer2.spotify")
|
||||||
|
.filter()
|
||||||
|
.log()
|
||||||
|
.exec()
|
||||||
|
|
||||||
call
|
call
|
||||||
.addArg("--dev", "/dev")
|
.addArg("--dev", "/dev")
|
||||||
|
# https://github.com/flatpak/flatpak/blob/1bdbb80ac57df437e46fce2cdd63e4ff7704718b/common/flatpak-run.c#L1496
|
||||||
|
.addMount("--dev-bind", "/dev/dri")
|
||||||
|
.addMount("--dev-bind", "/dev/nvidiactl")
|
||||||
|
.addMount("--dev-bind", "/dev/nvidia-modeset")
|
||||||
|
.addMount("--dev-bind", "/dev/nvidia0")
|
||||||
.addMount("--dev-bind", "/dev/random")
|
.addMount("--dev-bind", "/dev/random")
|
||||||
.addMount("--dev-bind", "/dev/urandom")
|
.addMount("--dev-bind", "/dev/urandom")
|
||||||
|
.addArg("--ro-bind", "/run/user/1000/.bus-sandboxed/test2", "/run/user/1000/bus")
|
||||||
.addArg("--tmpfs", "/tmp")
|
.addArg("--tmpfs", "/tmp")
|
||||||
.addArg("--tmpfs", "/dev/shm")
|
.addArg("--tmpfs", "/dev/shm")
|
||||||
.addArg("--proc", "/proc")
|
.addArg("--proc", "/proc")
|
||||||
|
@ -48,18 +65,6 @@ proc sandboxExec*(args: Args) =
|
||||||
.addArg("--setenv", "BWSANDBOX", "1")
|
.addArg("--setenv", "BWSANDBOX", "1")
|
||||||
.applyConfig(config)
|
.applyConfig(config)
|
||||||
|
|
||||||
if config.dbus.get(false):
|
|
||||||
# todo: handle process and cleanup later
|
|
||||||
let proxy = startDBusProxy(config, hostname)
|
|
||||||
call.addArg("--ro-bind", proxy.socket,
|
|
||||||
getEnv("DBUS_SESSION_BUS_ADDRESS").split('=')[1])
|
|
||||||
|
|
||||||
# todo: use fd signaling instead of this
|
|
||||||
sleep(100)
|
|
||||||
|
|
||||||
if config.allowdri.get(false):
|
|
||||||
enableDri(call)
|
|
||||||
|
|
||||||
if config.mountcwd.get(false):
|
if config.mountcwd.get(false):
|
||||||
call
|
call
|
||||||
.addMount("--bind", getCurrentDir())
|
.addMount("--bind", getCurrentDir())
|
||||||
|
|
|
@ -1,8 +1,5 @@
|
||||||
import strformat
|
|
||||||
import posix
|
|
||||||
import bwrap
|
|
||||||
import args
|
|
||||||
import os
|
import os
|
||||||
|
import args
|
||||||
|
|
||||||
const APP_NAME = "bwsandbox"
|
const APP_NAME = "bwsandbox"
|
||||||
|
|
||||||
|
@ -25,27 +22,4 @@ proc getProfilePath*(args: Args): string =
|
||||||
proc getSandboxPath*(name: string): string =
|
proc getSandboxPath*(name: string): string =
|
||||||
getDataDir()
|
getDataDir()
|
||||||
.joinPath(APP_NAME)
|
.joinPath(APP_NAME)
|
||||||
.joinPath(name)
|
.joinPath(name)
|
||||||
|
|
||||||
proc deviceExists(path: string): bool =
|
|
||||||
var res: Stat
|
|
||||||
return stat(path, res) >= 0 and S_ISCHR(res.st_mode)
|
|
||||||
|
|
||||||
# https://github.com/flatpak/flatpak/blob/1bdbb80ac57df437e46fce2cdd63e4ff7704718b/common/flatpak-run.c#L1496
|
|
||||||
proc enableDri*(call: var BwrapCall) =
|
|
||||||
const mounts = [
|
|
||||||
"/dev/dri", # general
|
|
||||||
"/dev/mali", "/dev/mali0", "/dev/umplock", # mali
|
|
||||||
"/dev/nvidiactl", "/dev/nvidia-modeset", # nvidia
|
|
||||||
"/dev/nvidia-uvm", "/dev/nvidia-uvm-tools" # nvidia OpenCl/CUDA
|
|
||||||
]
|
|
||||||
|
|
||||||
for mount in mounts:
|
|
||||||
if deviceExists(mount):
|
|
||||||
call.addMount("--dev-bind", mount)
|
|
||||||
|
|
||||||
for i in 0..20:
|
|
||||||
let device = &"/dev/nvidia{i}"
|
|
||||||
|
|
||||||
if deviceExists(device):
|
|
||||||
call.addMount("--dev-bind", device)
|
|
2
main.nim
2
main.nim
|
@ -1,7 +1,6 @@
|
||||||
import lib/sandbox
|
import lib/sandbox
|
||||||
import lib/args
|
import lib/args
|
||||||
import options
|
import options
|
||||||
import random
|
|
||||||
|
|
||||||
proc main(): int =
|
proc main(): int =
|
||||||
let args = parseArgs()
|
let args = parseArgs()
|
||||||
|
@ -10,7 +9,6 @@ proc main(): int =
|
||||||
echo "Usage: bwshell --command=cmd --profile=profile <sandbox_name>"
|
echo "Usage: bwshell --command=cmd --profile=profile <sandbox_name>"
|
||||||
return 1
|
return 1
|
||||||
else:
|
else:
|
||||||
randomize()
|
|
||||||
sandboxExec(args.unsafeGet)
|
sandboxExec(args.unsafeGet)
|
||||||
|
|
||||||
quit(main())
|
quit(main())
|
||||||
|
|
Loading…
Reference in New Issue