Merge pull request #66 from mutablelogic/v4

Added middleware

Author: djthorpe

cmd/nginx-server/main.go

@@ -62,6 +62,7 @@ func main() {
 	auth, err := auth.Config{
 		TokenJar:   jar.(auth.TokenJar),
 		TokenBytes: 8,
+		Bearer:     true, // Use bearer token in requests for authorization
 	}.New()
 	if err != nil {
 		log.Fatal(err)
@@ -77,12 +78,14 @@ func main() {
 				Service: n.(server.ServiceEndpoints),
 				Middleware: []server.Middleware{
 					logger.(server.Middleware),
+					auth.(server.Middleware),
 				},
 			},
 			"auth": { // /api/auth/...
 				Service: auth.(server.ServiceEndpoints),
 				Middleware: []server.Middleware{
 					logger.(server.Middleware),
+					auth.(server.Middleware),
 				},
 			},
 		},

pkg/handler/auth/config.go

@@ -11,6 +11,7 @@ import (
 type Config struct {
 	TokenJar   TokenJar `hcl:"token_jar" description:"Persistent storage for tokens"`
 	TokenBytes int      `hcl:"token_bytes" description:"Number of bytes in a token"`
+	Bearer     bool     `hcl:"bearer" description:"Use bearer token for authorization"`
 }
 
 // Check interfaces are satisfied

pkg/handler/auth/endpoints.go

@@ -15,6 +15,12 @@ import (
 	types "github.com/mutablelogic/go-server/pkg/types"
 )
 
+///////////////////////////////////////////////////////////////////////////////
+// TYPES
+
+// Check interfaces are satisfied
+var _ server.ServiceEndpoints = (*auth)(nil)
+
 ///////////////////////////////////////////////////////////////////////////////
 // GLOBALS
 

pkg/handler/auth/middleware.go

@@ -0,0 +1,27 @@
+package auth
+
+import (
+	"context"
+	"net/http"
+
+	// Packages
+	"github.com/mutablelogic/go-server"
+	"github.com/mutablelogic/go-server/pkg/provider"
+)
+
+///////////////////////////////////////////////////////////////////////////////
+// TYPES
+
+// Check interfaces are satisfied
+var _ server.Middleware = (*auth)(nil)
+
+///////////////////////////////////////////////////////////////////////////////
+// PUBLIC METHODS
+
+func (middleware *auth) Wrap(ctx context.Context, next http.HandlerFunc) http.HandlerFunc {
+	logger := provider.Logger(ctx)
+	return func(w http.ResponseWriter, r *http.Request) {
+		logger.Printf(ctx, "TODO Auth: %v", r.URL)
+		next(w, r)
+	}
+}

pkg/handler/auth/task.go

@@ -21,7 +21,6 @@ type auth struct {
 
 // Check interfaces are satisfied
 var _ server.Task = (*auth)(nil)
-var _ server.ServiceEndpoints = (*auth)(nil)
 
 ///////////////////////////////////////////////////////////////////////////////
 // LIFECYCLE

pkg/handler/tokenjar/task.go

@@ -33,7 +33,7 @@ func (jar *tokenjar) Run(ctx context.Context) error {
 				if err := jar.Write(); err != nil {
 					logger.Print(ctx, err)
 				} else {
-					logger.Print(ctx, "Sync %q", filepath.Base(jar.filename))
+					logger.Printf(ctx, "Sync %q", filepath.Base(jar.filename))
 				}
 			}
 		case <-ctx.Done():