Compare commits
1 Commits
2cb658c723
...
920eb49941
Author | SHA1 | Date |
---|---|---|
Martin | 920eb49941 |
|
@ -16,6 +16,13 @@ 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(@[]):
|
||||||
|
@ -39,10 +46,19 @@ 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,43 +1,54 @@
|
||||||
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 addSee*(proxy: var DbusProxy, name: string): var DbusProxy {.discardable.} =
|
proc exec*(proxy: var DbusProxy) =
|
||||||
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
|
||||||
startProcess("xdg-dbus-proxy", args = proxy.args, options = {poEchoCmd, poParentStreams, poUsePath})
|
proxy.process = startProcess("xdg-dbus-proxy", args = proxy.args,
|
||||||
|
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,11 +1,12 @@
|
||||||
import os
|
import strutils
|
||||||
|
import options
|
||||||
|
import config
|
||||||
|
import utils
|
||||||
|
import bwrap
|
||||||
import args
|
import args
|
||||||
import json
|
import json
|
||||||
import dbus
|
import dbus
|
||||||
import utils
|
import os
|
||||||
import bwrap
|
|
||||||
import config
|
|
||||||
import options
|
|
||||||
|
|
||||||
proc sandboxExec*(args: Args) =
|
proc sandboxExec*(args: Args) =
|
||||||
var call = BwrapCall()
|
var call = BwrapCall()
|
||||||
|
@ -34,28 +35,10 @@ 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")
|
||||||
|
@ -65,6 +48,18 @@ 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,5 +1,8 @@
|
||||||
import os
|
import strformat
|
||||||
|
import posix
|
||||||
|
import bwrap
|
||||||
import args
|
import args
|
||||||
|
import os
|
||||||
|
|
||||||
const APP_NAME = "bwsandbox"
|
const APP_NAME = "bwsandbox"
|
||||||
|
|
||||||
|
@ -22,4 +25,27 @@ 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,6 +1,7 @@
|
||||||
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()
|
||||||
|
@ -9,6 +10,7 @@ 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