ref: e2ac43435940ad220871216999ef036dc64c915d
dir: /cmd/gojafs/main_unix.go/
//go:build !plan9
package main
import (
"9fans.net/go/plan9"
"9fans.net/go/plan9/client"
"fmt"
"github.com/knusbaum/go9p"
"github.com/psilva261/opossum/logger"
"io"
"os/user"
)
var fsys *client.Fsys
func Init() (err error) {
log.Infof("Init...")
if service == "" {
return
}
log.Infof("dial service...")
conn, err := client.DialService(service)
if err != nil {
log.Fatalf("dial: %v", err)
}
u, err := user.Current()
if err != nil {
return
}
un := u.Username
fsys, err = conn.Attach(nil, un, "")
if err != nil {
log.Fatalf("attach: %v", err)
}
if htm != "" || len(js) > 0 {
log.Infof("not loading htm/js from service")
return
}
log.Infof("open html...")
fid, err := fsys.Open("html", plan9.OREAD)
if err != nil {
return
}
defer fid.Close()
bs, err := io.ReadAll(fid)
if err != nil {
return
}
htm = string(bs)
log.Infof("htm: %v", htm)
log.Infof("open js...")
dfid, err := fsys.Open("js", plan9.OREAD)
if err != nil {
return
}
defer dfid.Close()
ds, err := dfid.Dirreadall()
if err != nil {
return
}
log.Infof("ds=%+v", ds)
for i := 0; i < len(ds); i++ {
fn := fmt.Sprintf("js/%v.js", i)
log.Infof("fn=%v", fn)
fid, err := fsys.Open(fn, plan9.OREAD)
if err != nil {
return fmt.Errorf("open: %w", err)
}
bs, err := io.ReadAll(fid)
if err != nil {
fid.Close()
return fmt.Errorf("read all: %w", err)
}
js = append(js, string(bs))
fid.Close()
}
return
}
func openQuery() (rwc io.ReadWriteCloser, err error) {
return fsys.Open("query", plan9.ORDWR)
}
func openXhr() (rwc io.ReadWriteCloser, err error) {
return fsys.Open("xhr", plan9.ORDWR)
}
func post(srv go9p.Srv) (err error) {
return go9p.PostSrv("goja", srv)
}