-
Notifications
You must be signed in to change notification settings - Fork 0
/
jsonrpc.go
87 lines (73 loc) · 1.71 KB
/
jsonrpc.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package jsonrpc
import (
"fmt"
"log"
"net/rpc"
"os"
)
// get RPC client by dialing at `rpc.DefaultRPCPath` endpoint
var client, _ = rpc.DialHTTP("tcp", "localhost:9000")
type Query struct {
Base string
Args []interface{}
}
type WatchedDirsState struct {
Id int
Path string
State string
}
type FileProperties struct {
Path_to_file string
Fname string
Size int
Mtime_ns int
IsDir bool
}
func isValidDir(path string) bool {
if info, err := os.Stat(path); err != nil {
return false
} else {
return info.IsDir()
}
}
func AddDir(toAdd []string) []string {
for _, path := range toAdd {
if !isValidDir(path) {
log.Fatalf("ERROR: The directory provided '%s' is not valid", path)
}
}
var added []string
if err := client.Call("RemoteCall.Add", toAdd, &added); err != nil {
log.Fatal("RemoteCall.Add -> Error:", err)
}
return added
}
func RmDir(toRm []int) []int {
var removed []int
if err := client.Call("RemoteCall.Remove", toRm, &removed); err != nil {
log.Fatal("RemoteCall.Remove -> Error:", err)
}
return removed
}
func Search(s string) []FileProperties {
var rows []FileProperties
if err := client.Call("RemoteCall.Search", s, &rows); err != nil {
log.Fatal("RemoteCall.Search -> Error:", err)
}
return rows
}
func StopDaemon() {
var signal struct{}
if err := client.Call("RemoteCall.StopDaemon", signal, &signal); err != nil {
log.Fatal("RemoteCall.StopDaemon -> Error:", err)
} else {
fmt.Println("daemon stopped successfully")
}
}
func WatchedDirs() []WatchedDirsState {
var rows []WatchedDirsState
if err := client.Call("RemoteCall.WatchedDirs", struct{}{}, &rows); err != nil {
log.Fatal("RemoteCall.WatchedDirs -> Error:", err)
}
return rows
}