Lithium/main.go

package main

import (
	"encoding/json"
	"net/http"

	"github.com/geplauder/lithium/auth"
	"github.com/geplauder/lithium/pipelines"
	"github.com/geplauder/lithium/settings"
	"github.com/geplauder/lithium/storage"
	"github.com/gorilla/mux"
	"github.com/spf13/afero"
)

const Name string = "Lithium"
const Version string = "0.1.0"

type Metadata struct {
	Name    string `json:"name"`
	Version string `json:"version"`
}

func PipelineHandler(pipeline pipelines.IPipeline, storageProvider storage.IStorageProvider, w http.ResponseWriter, r *http.Request) {
	w.Header().Set("Content-Type", "application/json")
	err := json.NewEncoder(w).Encode(pipeline)
	if err != nil {
		w.WriteHeader(http.StatusInternalServerError)
	}
}

func IndexHandler(w http.ResponseWriter, r *http.Request) {
	w.Header().Set("Content-Type", "application/json")
	err := json.NewEncoder(w).Encode(Metadata{Name, Version})
	if err != nil {
		w.WriteHeader(http.StatusInternalServerError)
	}
}

func RegisterRoutes(r *mux.Router, pipelines []pipelines.IPipeline, storageProvider storage.IStorageProvider) {
	r.HandleFunc("/", IndexHandler)
	r.HandleFunc("/pipelines/{pipeline}", func(w http.ResponseWriter, r *http.Request) {
		for _, pipeline := range pipelines {
			if pipeline.GetSlug() == mux.Vars(r)["pipeline"] {
				PipelineHandler(pipeline, storageProvider, w, r)
				return
			}
		}

		w.WriteHeader(404)
	})
}

func main() {
	appSettings, err := settings.LoadSettings(afero.NewOsFs())
	if err != nil {
		panic(err)
	}

	var storageProvider storage.IStorageProvider

	if appSettings.StorageProvider.Type == 0 {
		storageProvider = storage.GetFileSystemStorageProvider(appSettings.StorageProvider.BasePath, "")
	} else {
		panic("Invalid file system provided!")
	}

	pipes := pipelines.LoadPipelines()

	authMiddleware := auth.CreateAuthenticationMiddleware(appSettings.Token)

	r := mux.NewRouter()
	r.Use(authMiddleware.Middleware)

	RegisterRoutes(r, pipes, storageProvider)

	err = http.ListenAndServe(appSettings.Endpoint, r)
	if err != nil {
		panic(err)
	}
}