Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 5 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,17 +1,18 @@
# Go DDP Server
# Go DDP

DDP server and client implemented with go.

## Example
## Server Example

```go
package main

import (
"github.com/meteorhacks/goddp/server"
"github.com/meteorhacks/goddp"
)

func main() {
server := server.New()
server := goddp.NewServer()
server.Method("hello", methodHandler)
server.Listen(":1337")
}
Expand Down
3 changes: 3 additions & 0 deletions client/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
# Go DDP Client

DDP client implemented with go.
8 changes: 8 additions & 0 deletions client/client.go
Original file line number Diff line number Diff line change
@@ -1 +1,9 @@
package client

type Client struct {
}

func New() Client {
client := Client{}
return client
}
14 changes: 14 additions & 0 deletions goddp.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
package goddp

import (
"github.com/meteorhacks/goddp/client"
"github.com/meteorhacks/goddp/server"
)

func NewClient() client.Client {
return client.New()
}

func NewServer() server.Server {
return server.New()
}
23 changes: 23 additions & 0 deletions server/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
# Go DDP Server

DDP server implemented with go.

## Example

```go
package main

import (
"github.com/meteorhacks/goddp/server"
)

func main() {
server := server.New()
server.Method("hello", methodHandler)
server.Listen(":1337")
}

func methodHandler(p []interface{}) (interface{}, error) {
return "result", nil
}
```
5 changes: 2 additions & 3 deletions server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,12 +31,11 @@ func (s *Server) Method(n string, h MethodHandler) {
}

func (s *Server) Listen(ipPort string) {
http.HandleFunc("/websocket", s.handler)
http.HandleFunc("/websocket", s.Handler)
http.ListenAndServe(ipPort, nil)
}

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

if err != nil {
Expand Down