Skip to content

Commit daf9c95

Browse files
committed
Merge pull request #2 from meteorhacks/add-goddp-package
Create goddp package
2 parents dff8f2e + 6723f50 commit daf9c95

File tree

6 files changed

+55
-7
lines changed

6 files changed

+55
-7
lines changed

README.md

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,18 @@
1-
# Go DDP Server
1+
# Go DDP
22

3+
DDP server and client implemented with go.
34

4-
## Example
5+
## Server Example
56

67
```go
78
package main
89

910
import (
10-
"github.com/meteorhacks/goddp/server"
11+
"github.com/meteorhacks/goddp"
1112
)
1213

1314
func main() {
14-
server := server.New()
15+
server := goddp.NewServer()
1516
server.Method("hello", methodHandler)
1617
server.Listen(":1337")
1718
}

client/README.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
# Go DDP Client
2+
3+
DDP client implemented with go.

client/client.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1 +1,9 @@
11
package client
2+
3+
type Client struct {
4+
}
5+
6+
func New() Client {
7+
client := Client{}
8+
return client
9+
}

goddp.go

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
package goddp
2+
3+
import (
4+
"github.com/meteorhacks/goddp/client"
5+
"github.com/meteorhacks/goddp/server"
6+
)
7+
8+
func NewClient() client.Client {
9+
return client.New()
10+
}
11+
12+
func NewServer() server.Server {
13+
return server.New()
14+
}

server/README.md

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
# Go DDP Server
2+
3+
DDP server implemented with go.
4+
5+
## Example
6+
7+
```go
8+
package main
9+
10+
import (
11+
"github.com/meteorhacks/goddp/server"
12+
)
13+
14+
func main() {
15+
server := server.New()
16+
server.Method("hello", methodHandler)
17+
server.Listen(":1337")
18+
}
19+
20+
func methodHandler(p []interface{}) (interface{}, error) {
21+
return "result", nil
22+
}
23+
```

server/server.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,12 +31,11 @@ func (s *Server) Method(n string, h MethodHandler) {
3131
}
3232

3333
func (s *Server) Listen(ipPort string) {
34-
http.HandleFunc("/websocket", s.handler)
34+
http.HandleFunc("/websocket", s.Handler)
3535
http.ListenAndServe(ipPort, nil)
3636
}
3737

38-
// create websocket connection from http handler and runs the websocket handler
39-
func (s *Server) handler(w http.ResponseWriter, r *http.Request) {
38+
func (s *Server) Handler(w http.ResponseWriter, r *http.Request) {
4039
ws, err := s.upgrader.Upgrade(w, r, nil)
4140

4241
if err != nil {

0 commit comments

Comments
 (0)