Settings fetcher endpoint

Author: edshadi

pkg/api/settingfetcher/endpoint.go

@@ -0,0 +1,43 @@
+package settingfetcher
+
+import (
+	"context"
+	"encoding/json"
+	"strconv"
+
+	"github.com/gemsorg/assignment/pkg/apierror"
+	"github.com/gemsorg/assignment/pkg/authentication"
+	ds "github.com/gemsorg/assignment/pkg/datastore"
+	"github.com/gemsorg/assignment/pkg/service"
+	"github.com/go-kit/kit/endpoint"
+)
+
+func makeSettingFetcherEndpoint(svc service.AssignmentService) endpoint.Endpoint {
+	return func(ctx context.Context, request interface{}) (interface{}, error) {
+		data, _ := authentication.ParseAuthData(ctx)
+		svc.SetAuthData(data)
+		req := request.(SettingRequest)
+
+		jobID, err := strconv.ParseUint(req.JobID, 10, 64)
+		if err != nil {
+			return nil, errorResponse(err)
+		}
+
+		s, err := svc.GetSettings(jobID)
+		if _, ok := err.(ds.NoRowErr); ok {
+			return json.RawMessage("{}"), nil
+		}
+		if err != nil {
+			return nil, errorResponse(err)
+		}
+		return s, nil
+	}
+}
+
+func errorResponse(err error) *apierror.APIError {
+	return apierror.New(500, err.Error(), err)
+}
+
+type SettingRequest struct {
+	JobID string
+}

pkg/api/settingfetcher/transport.go

@@ -0,0 +1,35 @@
+package settingfetcher
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/gemsorg/assignment/pkg/service"
+	kithttp "github.com/go-kit/kit/transport/http"
+	"github.com/gorilla/mux"
+)
+
+func MakeHandler(s service.AssignmentService) http.Handler {
+	return kithttp.NewServer(
+		makeSettingFetcherEndpoint(s),
+		decodeSettingFetcherRequest,
+		encodeResponse,
+	)
+}
+
+func encodeResponse(ctx context.Context, w http.ResponseWriter, response interface{}) error {
+	w.Header().Set("Content-Type", "application/json; charset=utf-8")
+	return json.NewEncoder(w).Encode(response)
+}
+
+func decodeSettingFetcherRequest(_ context.Context, r *http.Request) (interface{}, error) {
+	vars := mux.Vars(r)
+	var ok bool
+	jobID, ok := vars["job_id"]
+	if !ok {
+		return nil, fmt.Errorf("missing job_id parameter")
+	}
+	return SettingRequest{JobID: jobID}, nil
+}

pkg/datastore/errors.go

@@ -20,5 +20,5 @@ func (err AssignmentNotFound) Error() string {
 type NoRowErr struct{}
 
 func (err NoRowErr) Error() string {
-	return "Query returned no rows"
+	return "No Records"
 }

pkg/server/server.go

@@ -7,6 +7,7 @@ import (
 	"github.com/gemsorg/assignment/pkg/api/assignmentdestroyer"
 	"github.com/gemsorg/assignment/pkg/api/assignmentfetcher"
 	"github.com/gemsorg/assignment/pkg/api/assignmentupdater"
+	"github.com/gemsorg/assignment/pkg/api/settingfetcher"
 
 	"github.com/gemsorg/assignment/pkg/authentication"
 
@@ -29,6 +30,7 @@ func New(
 	r.Handle("/assignments", assignmentcreator.MakeHandler(s)).Methods("POST")
 	r.Handle("/assignments", assignmentdestroyer.MakeHandler(s)).Methods("DELETE")
 	r.Handle("/assignments", assignmentupdater.MakeHandler(s)).Methods("PATCH")
+	r.Handle("/settings/{job_id}", settingfetcher.MakeHandler(s)).Methods("GET")
 	r.Use(authentication.AuthMiddleware)
 	return withHandlers(r)
 }