aboutsummaryrefslogtreecommitdiffhomepage
path: root/cmd/fshim/ipc
diff options
context:
space:
mode:
authorOphestra <cat@gensokyo.uk>2025-01-17 23:43:32 +0900
committerOphestra <cat@gensokyo.uk>2025-01-17 23:43:32 +0900
commitea8f228af36b2c9ae9918f7760c3af4f1e21cfa2 (patch)
tree1f9b43cd1a0f83217f20e76924b8ae48e182cf0c /cmd/fshim/ipc
parent16db3dabe2060d5a66948101e16709697bfb374a (diff)
proc/priv/shim: merge shim into main program
Signed-off-by: Ophestra <cat@gensokyo.uk>
Diffstat (limited to 'cmd/fshim/ipc')
-rw-r--r--cmd/fshim/ipc/payload.go23
-rw-r--r--cmd/fshim/ipc/shim/shim.go142
2 files changed, 0 insertions, 165 deletions
diff --git a/cmd/fshim/ipc/payload.go b/cmd/fshim/ipc/payload.go
deleted file mode 100644
index 92e51e8c..00000000
--- a/cmd/fshim/ipc/payload.go
+++ /dev/null
@@ -1,23 +0,0 @@
-package shim0
-
-import (
- "git.gensokyo.uk/security/fortify/helper/bwrap"
-)
-
-const Env = "FORTIFY_SHIM"
-
-type Payload struct {
- // child full argv
- Argv []string
- // bwrap, target full exec path
- Exec [2]string
- // bwrap config
- Bwrap *bwrap.Config
- // path to outer home directory
- Home string
- // sync fd
- Sync *uintptr
-
- // verbosity pass through
- Verbose bool
-}
diff --git a/cmd/fshim/ipc/shim/shim.go b/cmd/fshim/ipc/shim/shim.go
deleted file mode 100644
index 4f60531b..00000000
--- a/cmd/fshim/ipc/shim/shim.go
+++ /dev/null
@@ -1,142 +0,0 @@
-package shim
-
-import (
- "context"
- "encoding/gob"
- "errors"
- "os"
- "os/exec"
- "strconv"
- "strings"
- "time"
-
- shim0 "git.gensokyo.uk/security/fortify/cmd/fshim/ipc"
- "git.gensokyo.uk/security/fortify/internal"
- "git.gensokyo.uk/security/fortify/internal/fmsg"
- "git.gensokyo.uk/security/fortify/internal/proc"
-)
-
-// used by the parent process
-
-type Shim struct {
- // user switcher process
- cmd *exec.Cmd
- // uid of shim target user
- uid uint32
- // string representation of application id
- aid string
- // string representation of supplementary group ids
- supp []string
- // fallback exit notifier with error returned killing the process
- killFallback chan error
- // shim setup payload
- payload *shim0.Payload
- // monitor to shim encoder
- encoder *gob.Encoder
-}
-
-func New(uid uint32, aid string, supp []string, payload *shim0.Payload) *Shim {
- return &Shim{uid: uid, aid: aid, supp: supp, payload: payload}
-}
-
-func (s *Shim) String() string {
- if s.cmd == nil {
- return "(unused shim manager)"
- }
- return s.cmd.String()
-}
-
-func (s *Shim) Unwrap() *exec.Cmd {
- return s.cmd
-}
-
-func (s *Shim) WaitFallback() chan error {
- return s.killFallback
-}
-
-func (s *Shim) Start() (*time.Time, error) {
- // prepare user switcher invocation
- var fsu string
- if p, ok := internal.Check(internal.Fsu); !ok {
- fmsg.Fatal("invalid fsu path, this copy of fshim is not compiled correctly")
- panic("unreachable")
- } else {
- fsu = p
- }
- s.cmd = exec.Command(fsu)
-
- // pass shim setup pipe
- if fd, e, err := proc.Setup(&s.cmd.ExtraFiles); err != nil {
- return nil, fmsg.WrapErrorSuffix(err,
- "cannot create shim setup pipe:")
- } else {
- s.encoder = e
- s.cmd.Env = []string{
- shim0.Env + "=" + strconv.Itoa(fd),
- "FORTIFY_APP_ID=" + s.aid,
- }
- }
-
- // format fsu supplementary groups
- if len(s.supp) > 0 {
- fmsg.VPrintf("attaching supplementary group ids %s", s.supp)
- s.cmd.Env = append(s.cmd.Env, "FORTIFY_GROUPS="+strings.Join(s.supp, " "))
- }
- s.cmd.Stdin, s.cmd.Stdout, s.cmd.Stderr = os.Stdin, os.Stdout, os.Stderr
- s.cmd.Dir = "/"
-
- // pass sync fd if set
- if s.payload.Bwrap.Sync() != nil {
- fd := proc.ExtraFile(s.cmd, s.payload.Bwrap.Sync())
- s.payload.Sync = &fd
- }
-
- fmsg.VPrintln("starting shim via fsu:", s.cmd)
- // withhold messages to stderr
- fmsg.Suspend()
- if err := s.cmd.Start(); err != nil {
- return nil, fmsg.WrapErrorSuffix(err,
- "cannot start fsu:")
- }
- startTime := time.Now().UTC()
- return &startTime, nil
-}
-
-func (s *Shim) Serve(ctx context.Context) error {
- // kill shim if something goes wrong and an error is returned
- s.killFallback = make(chan error, 1)
- killShim := func() {
- if err := s.cmd.Process.Signal(os.Interrupt); err != nil {
- s.killFallback <- err
- }
- }
- defer func() { killShim() }()
-
- encodeErr := make(chan error)
- go func() { encodeErr <- s.encoder.Encode(s.payload) }()
-
- select {
- // encode return indicates setup completion
- case err := <-encodeErr:
- if err != nil {
- return fmsg.WrapErrorSuffix(err,
- "cannot transmit shim config:")
- }
- killShim = func() {}
- return nil
-
- // setup canceled before payload was accepted
- case <-ctx.Done():
- err := ctx.Err()
- if errors.Is(err, context.Canceled) {
- return fmsg.WrapError(errors.New("shim setup canceled"),
- "shim setup canceled")
- }
- if errors.Is(err, context.DeadlineExceeded) {
- return fmsg.WrapError(errors.New("deadline exceeded waiting for shim"),
- "deadline exceeded waiting for shim")
- }
- // unreachable
- return err
- }
-}