-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathmain.go
119 lines (95 loc) · 2.21 KB
/
main.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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package main
import (
"log"
"net"
"net/http"
"net/rpc"
)
// Item struct
type Item struct {
Title string
Body string
}
var database []Item
// API object
type API int
// GetByName get the item for the database and return Item
func (a *API) GetByName(title string, reply *Item) error {
var getItem Item
for _, val := range database {
if val.Title == title {
getItem = val
}
}
*reply = getItem
return nil
}
// AddItem return void
func (a *API) AddItem(item Item, reply *Item) error {
database = append(database, item)
*reply = item
return nil
}
// EditItem return Item
func (*API) EditItem(edit Item, reply *Item) error {
var changed Item
for idx, val := range database {
if val.Title == edit.Title {
database[idx] = Item{edit.Title, edit.Body}
changed = edit
}
}
*reply = changed
return nil
}
// DeleteItem return item
func (*API) DeleteItem(item Item, reply *Item) error {
var del Item
for idx, val := range database {
if val.Title == item.Title && val.Body == item.Body {
database = append(database[:idx], database[idx+1:]...)
del = item
break
}
}
*reply = del
return nil
}
// GetDB return a database wraped
func (a *API) GetDB(title string, reply *[]Item) error {
*reply = database
return nil
}
// main return void
func main() {
var api = new(API)
err := rpc.Register(api)
if err != nil {
log.Fatal("error registering API to RPC", err)
}
rpc.HandleHTTP()
listener, err := net.Listen("tcp", ":4040")
if err != nil {
log.Fatal("Listener error ", err)
}
log.Printf("serving rpc on por %d", 4040)
err = http.Serve(listener, nil)
if err != nil {
log.Fatal("error serving: ", err)
}
// fmt.Println("Initial database: ", database)
// a := Item{"first", "This is the first item on the db"}
// b := Item{"second", "This is the second item on the db"}
// c := Item{"third", "This is the third item on the db"}
// api.AddItem(a, reply)
// AddItem(b)
// AddItem(c)
// fmt.Println("Second database is: ", database)
// DeleteItem(b)
// fmt.Println("Third database is: ", database)
// EditItem("third", Item{"third new", "The new Item"})
// fmt.Println("fourth database is: ", database)
// x := GetByName("first")
// y := GetByName("third")
// fmt.Println(x, y)
}