Merge branch 'xml-api' into 'master' HEADmaster

add initial server with ping.view endpoint

Issue #1 

See merge request !1

4 files changed, 179 insertions, 1 deletions

diff --git a/README.md b/README.md
index b82d4d4..2bf167b 100644
--- a/README.md
+++ b/README.md
@@ -1 +1,9 @@
-Implementation details can be found here: http://www.subsonic.org/pages/api.jsp
\ No newline at end of file
+Implementation details can be found here: http://www.subsonic.org/pages/api.jsp
+
+To start dev clone this repo into $GOPATH/src/codesaloon.com/torpedo
+
+and start the server with:
+
+cd cmd
+go build -o serve
+./serve
\ No newline at end of file
diff --git a/cmd/main.go b/cmd/main.go
new file mode 100644
index 0000000..074a4f3
--- /dev/null
+++ b/cmd/main.go
@@ -0,0 +1,51 @@
+package main
+
+import (
+        "bytes"
+        "codesaloon.com/torpedo"
+        "encoding/xml"
+        "flag"
+        "fmt"
+        "net/url"
+)
+
+type subsonicresponse struct {
+        XMLName xml.Name `xml:"subsonic-response"`
+        Xmlns   string   `xml:"xmlns,attr"`
+        Status  string   `xml:"status,attr"`
+        Version string   `xml:"version,attr"`
+}
+
+type ping struct {
+        torpedo.PostNotSupported
+        torpedo.PutNotSupported
+        torpedo.DeleteNotSupported
+}
+
+func (ping) Get(values url.Values) (int, string) {
+
+        data := &subsonicresponse{Version: "1.1.1", Status: "ok", Xmlns: "http://subsonic.org/restapi"}
+
+        buf := new(bytes.Buffer)
+        enc := xml.NewEncoder(buf)
+
+        if err := enc.Encode(data); err != nil {
+                fmt.Printf("error: %v\n", err)
+        } else {
+                fmt.Println(buf.String())
+        }
+
+        return 200, buf.String()
+}
+
+func main() {
+        var port = flag.Int("port", 8000, "Port number to listen on")
+        flag.Parse()
+
+        ping := new(ping)
+
+        var api = new(torpedo.API)
+        api.AddResource(ping, "/rest/ping.view")
+        api.Start(*port)
+
+}
diff --git a/cmd/ping.go b/cmd/ping.go
new file mode 100644
index 0000000..a046cb0
--- /dev/null
+++ b/cmd/ping.go
@@ -0,0 +1,31 @@
+package main
+
+import (
+        "bytes"
+        "codesaloon.com/torpedo"
+        "encoding/xml"
+        "fmt"
+        "net/url"
+)
+
+type ping struct {
+        torpedo.PostNotSupported
+        torpedo.PutNotSupported
+        torpedo.DeleteNotSupported
+}
+
+func (ping) Get(values url.Values) (int, string) {
+
+        data := &subsonicresponse{Version: "1.1.1", Status: "ok", Xmlns: "http://subsonic.org/restapi"}
+
+        buf := new(bytes.Buffer)
+        enc := xml.NewEncoder(buf)
+
+        if err := enc.Encode(data); err != nil {
+                fmt.Printf("error: %v\n", err)
+        } else {
+                fmt.Println(buf.String())
+        }
+
+        return 200, buf.String()
+}
diff --git a/torpedo.go b/torpedo.go
new file mode 100644
index 0000000..e0c1b99
--- /dev/null
+++ b/torpedo.go
@@ -0,0 +1,88 @@
+package torpedo
+
+import (
+        "fmt"
+        "net/http"
+        "net/url"
+)
+
+const (
+        GET    = "GET"
+        POST   = "POST"
+        PUT    = "PUT"
+        DELETE = "DELETE"
+)
+
+type Resource interface {
+        Get(values url.Values) (int, string)
+        Post(values url.Values) (int, string)
+        Put(values url.Values) (int, string)
+        Delete(values url.Values) (int, string)
+}
+
+type (
+        GetNotSupported    struct{}
+        PostNotSupported   struct{}
+        PutNotSupported    struct{}
+        DeleteNotSupported struct{}
+)
+
+func (GetNotSupported) Get(values url.Values) (int, string) {
+        return 405, ""
+}
+
+func (PostNotSupported) Post(values url.Values) (int, string) {
+        return 405, ""
+}
+
+func (PutNotSupported) Put(values url.Values) (int, string) {
+        return 405, ""
+}
+
+func (DeleteNotSupported) Delete(values url.Values) (int, string) {
+        return 405, ""
+}
+
+type API struct{}
+
+func (api *API) Abort(rw http.ResponseWriter, statusCode int) {
+        rw.WriteHeader(statusCode)
+}
+
+func (api *API) requestHandler(resource Resource) http.HandlerFunc {
+        return func(rw http.ResponseWriter, request *http.Request) {
+
+                var data string
+                var code int
+
+                request.ParseForm()
+                method := request.Method
+                values := request.Form
+
+                switch method {
+                case GET:
+                        code, data = resource.Get(values)
+                case POST:
+                        code, data = resource.Post(values)
+                case PUT:
+                        code, data = resource.Put(values)
+                case DELETE:
+                        code, data = resource.Delete(values)
+                default:
+                        api.Abort(rw, 405)
+                        return
+                }
+
+                rw.WriteHeader(code)
+                rw.Write([]byte(data))
+        }
+}
+
+func (api *API) AddResource(resource Resource, path string) {
+        http.HandleFunc(path, api.requestHandler(resource))
+}
+
+func (api *API) Start(port int) {
+        portString := fmt.Sprintf(":%d", port)
+        http.ListenAndServe(portString, nil)
+}