renamed instance to client
This commit is contained in:
parent
2b2f1648c1
commit
cfc682a36f
@ -6,11 +6,11 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (i *Instance) Dispatch(cmd string) (io.ReadCloser, error) {
|
func (i *Client) Dispatch(cmd string) (io.ReadCloser, error) {
|
||||||
return readSocketRaw(i.SocketPath(), strings.NewReader(fmt.Sprintf("dispatch %s", cmd)))
|
return readSocketRaw(i.SocketPath(), strings.NewReader(fmt.Sprintf("dispatch %s", cmd)))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) DispatchExpectOK(cmd string) error {
|
func (i *Client) DispatchExpectOK(cmd string) error {
|
||||||
str, err := readSocketString(i.SocketPath(), strings.NewReader(fmt.Sprintf("dispatch %s", cmd)))
|
str, err := readSocketString(i.SocketPath(), strings.NewReader(fmt.Sprintf("dispatch %s", cmd)))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -12,7 +12,7 @@ import (
|
|||||||
"git.milar.in/milarin/slices"
|
"git.milar.in/milarin/slices"
|
||||||
)
|
)
|
||||||
|
|
||||||
func GetInstance(signature string) (*Instance, error) {
|
func GetClient(signature string) (*Client, error) {
|
||||||
lockFilePath := fmt.Sprintf("/tmp/hypr/%s.lock", signature)
|
lockFilePath := fmt.Sprintf("/tmp/hypr/%s.lock", signature)
|
||||||
|
|
||||||
file, err := os.Open(lockFilePath)
|
file, err := os.Open(lockFilePath)
|
||||||
@ -33,38 +33,38 @@ func GetInstance(signature string) (*Instance, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return &Instance{
|
return &Client{
|
||||||
Signature: signature,
|
Signature: signature,
|
||||||
PID: pid,
|
PID: pid,
|
||||||
WaylandSocket: lines[1],
|
WaylandSocket: lines[1],
|
||||||
}, nil
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetDefaultInstance() (*Instance, error) {
|
func GetDefaultClient() (*Client, error) {
|
||||||
signature, ok := os.LookupEnv("HYPRLAND_INSTANCE_SIGNATURE")
|
signature, ok := os.LookupEnv("HYPRLAND_INSTANCE_SIGNATURE")
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, errors.New("default instance not found because HYPRLAND_INSTANCE_SIGNATURE is not set")
|
return nil, errors.New("default instance not found because HYPRLAND_INSTANCE_SIGNATURE is not set")
|
||||||
}
|
}
|
||||||
|
|
||||||
return GetInstance(signature)
|
return GetClient(signature)
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetInstances() ([]*Instance, error) {
|
func GetClients() ([]*Client, error) {
|
||||||
entries, err := os.ReadDir("/tmp/hypr")
|
entries, err := os.ReadDir("/tmp/hypr")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
entries = slices.Filter(entries, fs.DirEntry.IsDir)
|
entries = slices.Filter(entries, fs.DirEntry.IsDir)
|
||||||
instances := make([]*Instance, 0, len(entries))
|
clients := make([]*Client, 0, len(entries))
|
||||||
for _, entry := range entries {
|
for _, entry := range entries {
|
||||||
instance, err := GetInstance(entry.Name())
|
client, err := GetClient(entry.Name())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println(err)
|
fmt.Println(err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
instances = append(instances, instance)
|
clients = append(clients, client)
|
||||||
}
|
}
|
||||||
|
|
||||||
return instances, nil
|
return clients, nil
|
||||||
}
|
}
|
14
getters.go
14
getters.go
@ -4,30 +4,30 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (i *Instance) GetActiveWindow() (*Window, error) {
|
func (i *Client) GetActiveWindow() (*Window, error) {
|
||||||
return readSocket[*Window](i.SocketPath(), strings.NewReader("j/activewindow"))
|
return readSocket[*Window](i.SocketPath(), strings.NewReader("j/activewindow"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetActiveWorkspace() (*Workspace, error) {
|
func (i *Client) GetActiveWorkspace() (*Workspace, error) {
|
||||||
return readSocket[*Workspace](i.SocketPath(), strings.NewReader("j/activeworkspace"))
|
return readSocket[*Workspace](i.SocketPath(), strings.NewReader("j/activeworkspace"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetBinds() ([]*Bind, error) {
|
func (i *Client) GetBinds() ([]*Bind, error) {
|
||||||
return readSocket[[]*Bind](i.SocketPath(), strings.NewReader("j/binds"))
|
return readSocket[[]*Bind](i.SocketPath(), strings.NewReader("j/binds"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetWindows() ([]*Window, error) {
|
func (i *Client) GetWindows() ([]*Window, error) {
|
||||||
return readSocket[[]*Window](i.SocketPath(), strings.NewReader("j/clients"))
|
return readSocket[[]*Window](i.SocketPath(), strings.NewReader("j/clients"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetCursorPos() (Point, error) {
|
func (i *Client) GetCursorPos() (Point, error) {
|
||||||
return readSocket[Point](i.SocketPath(), strings.NewReader("j/cursorpos"))
|
return readSocket[Point](i.SocketPath(), strings.NewReader("j/cursorpos"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetMonitors() ([]*Monitor, error) {
|
func (i *Client) GetMonitors() ([]*Monitor, error) {
|
||||||
return readSocket[[]*Monitor](i.SocketPath(), strings.NewReader("j/monitors"))
|
return readSocket[[]*Monitor](i.SocketPath(), strings.NewReader("j/monitors"))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i *Instance) GetWorkspaces() ([]*Workspace, error) {
|
func (i *Client) GetWorkspaces() ([]*Workspace, error) {
|
||||||
return readSocket[[]*Workspace](i.SocketPath(), strings.NewReader("j/workspaces"))
|
return readSocket[[]*Workspace](i.SocketPath(), strings.NewReader("j/workspaces"))
|
||||||
}
|
}
|
||||||
|
@ -5,21 +5,21 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
)
|
)
|
||||||
|
|
||||||
type Instance struct {
|
type Client struct {
|
||||||
Signature string `json:"instance"`
|
Signature string `json:"instance"`
|
||||||
PID int `json:"pid"`
|
PID int `json:"pid"`
|
||||||
WaylandSocket string `json:"wl_socket"`
|
WaylandSocket string `json:"wl_socket"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i Instance) String() string {
|
func (c Client) String() string {
|
||||||
data, _ := json.MarshalIndent(i, "", "\t")
|
data, _ := json.MarshalIndent(c, "", "\t")
|
||||||
return string(data)
|
return string(data)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i Instance) SocketPath() string {
|
func (c Client) SocketPath() string {
|
||||||
return fmt.Sprintf("/tmp/hypr/%s/.socket.sock", i.Signature)
|
return fmt.Sprintf("/tmp/hypr/%s/.socket.sock", c.Signature)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (i Instance) EventSocketPath() string {
|
func (c Client) EventSocketPath() string {
|
||||||
return fmt.Sprintf("/tmp/hypr/%s/.socket2.sock", i.Signature)
|
return fmt.Sprintf("/tmp/hypr/%s/.socket2.sock", c.Signature)
|
||||||
}
|
}
|
||||||
|
@ -8,7 +8,7 @@ import (
|
|||||||
"git.milar.in/milarin/slices"
|
"git.milar.in/milarin/slices"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (i *Instance) Subscribe(ctx context.Context, events ...EventType) (<-chan Event, error) {
|
func (i *Client) Subscribe(ctx context.Context, events ...EventType) (<-chan Event, error) {
|
||||||
r, err := readSocketRaw(i.EventSocketPath(), strings.NewReader(""))
|
r, err := readSocketRaw(i.EventSocketPath(), strings.NewReader(""))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
Loading…
Reference in New Issue
Block a user