/*
Copyright 2011 Google Inc.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package server
import (
"encoding/json"
"fmt"
"log"
"net/http"
"os"
"sort"
"sync"
"time"
"camlistore.org/pkg/auth"
"camlistore.org/pkg/blobserver"
"camlistore.org/pkg/buildinfo"
"camlistore.org/pkg/images"
"camlistore.org/pkg/jsonconfig"
"camlistore.org/pkg/osutil"
"camlistore.org/pkg/search"
)
// RootHandler handles serving the about/splash page.
type RootHandler struct {
// Stealth determines whether we hide from non-authenticated
// clients.
Stealth bool
OwnerName string // for display purposes only.
Username string // default user for mobile setup.
// URL prefixes (path or full URL) to the primary blob and
// search root.
BlobRoot string
SearchRoot string
statusRoot string
Prefix string // root handler's prefix
Storage blobserver.Storage // of BlobRoot, or nil
searchInitOnce sync.Once // runs searchInit, which populates searchHandler
searchInit func()
searchHandler *search.Handler // of SearchRoot, or nil
ui *UIHandler // or nil, if none configured
sync []*SyncHandler // list of configured sync handlers, for discovery.
}
func (rh *RootHandler) SearchHandler() (h *search.Handler, ok bool) {
rh.searchInitOnce.Do(rh.searchInit)
return rh.searchHandler, rh.searchHandler != nil
}
func init() {
blobserver.RegisterHandlerConstructor("root", newRootFromConfig)
}
func newRootFromConfig(ld blobserver.Loader, conf jsonconfig.Obj) (h http.Handler, err error) {
username, err := getUserName()
if err != nil {
return
}
root := &RootHandler{
BlobRoot: conf.OptionalString("blobRoot", ""),
SearchRoot: conf.OptionalString("searchRoot", ""),
OwnerName: conf.OptionalString("ownerName", username),
Username: osutil.Username(),
Prefix: ld.MyPrefix(),
}
root.Stealth = conf.OptionalBool("stealth", false)
root.statusRoot = conf.OptionalString("statusRoot", "")
if err = conf.Validate(); err != nil {
return
}
if root.BlobRoot != "" {
bs, err := ld.GetStorage(root.BlobRoot)
if err != nil {
return nil, fmt.Errorf("Root handler's blobRoot of %q error: %v", root.BlobRoot, err)
}
root.Storage = bs
}
root.searchInit = func() {}
if root.SearchRoot != "" {
prefix := root.SearchRoot
if t := ld.GetHandlerType(prefix); t != "search" {
if t == "" {
return nil, fmt.Errorf("root handler's searchRoot of %q is invalid and doesn't refer to a declared handler", prefix)
}
return nil, fmt.Errorf("root handler's searchRoot of %q is of type %q, not %q", prefix, t, "search")
}
root.searchInit = func() {
h, err := ld.GetHandler(prefix)
if err != nil {
log.Fatalf("Error fetching SearchRoot at %q: %v", prefix, err)
}
root.searchHandler = h.(*search.Handler)
root.searchInit = nil
}
}
return root, nil
}
func (rh *RootHandler) registerUIHandler(h *UIHandler) {
rh.ui = h
}
func (rh *RootHandler) registerSyncHandler(h *SyncHandler) {
rh.sync = append(rh.sync, h)
sort.Sort(byFromTo(rh.sync))
}
func (rh *RootHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
if wantsDiscovery(req) {
if auth.Allowed(req, auth.OpDiscovery) {
rh.serveDiscovery(rw, req)
return
}
if !rh.Stealth {
http.Error(rw, "Unauthorized", http.StatusUnauthorized)
}
return
}
if rh.Stealth {
return
}
if req.URL.Path == "/favicon.ico" {
serveStaticFile(rw, req, Files, "favicon.ico")
return
}
f := func(p string, a ...interface{}) {
fmt.Fprintf(rw, p, a...)
}
f("This is camlistored (%s), a "+
"Camlistore server.
", buildinfo.Version())
if auth.IsLocalhost(req) && !isDevServer() {
f("If you're coming from localhost, configure your Camlistore server at /setup.
")
}
if rh.ui != nil {
f("To manage your content, access the %s.
", rh.ui.prefix, rh.ui.prefix)
}
if rh.statusRoot != "" {
f("To view status, see %s", rh.statusRoot, rh.statusRoot)
}
fmt.Fprintf(rw, "")
}
func isDevServer() bool {
return os.Getenv("CAMLI_DEV_CAMLI_ROOT") != ""
}
type byFromTo []*SyncHandler
func (b byFromTo) Len() int { return len(b) }
func (b byFromTo) Swap(i, j int) { b[i], b[j] = b[j], b[i] }
func (b byFromTo) Less(i, j int) bool {
if b[i].fromName < b[j].fromName {
return true
}
return b[i].fromName == b[j].fromName && b[i].toName < b[j].toName
}
func (rh *RootHandler) serveDiscovery(rw http.ResponseWriter, req *http.Request) {
m := map[string]interface{}{
"blobRoot": rh.BlobRoot,
"searchRoot": rh.SearchRoot,
"ownerName": rh.OwnerName,
"username": rh.Username,
"statusRoot": rh.statusRoot,
"wsAuthToken": auth.ProcessRandom(),
"thumbVersion": images.ThumbnailVersion(),
}
if gener, ok := rh.Storage.(blobserver.Generationer); ok {
initTime, gen, err := gener.StorageGeneration()
if err != nil {
m["storageGenerationError"] = err.Error()
} else {
m["storageInitTime"] = initTime.UTC().Format(time.RFC3339)
m["storageGeneration"] = gen
}
} else {
log.Printf("Storage type %T is not a blobserver.Generationer; not sending storageGeneration", rh.Storage)
}
if rh.ui != nil {
rh.ui.populateDiscoveryMap(m)
}
if len(rh.sync) > 0 {
var syncHandlers []map[string]interface{}
for _, sh := range rh.sync {
syncHandlers = append(syncHandlers, sh.discoveryMap())
}
m["syncHandlers"] = syncHandlers
}
discoveryHelper(rw, req, m)
}
func discoveryHelper(rw http.ResponseWriter, req *http.Request, m map[string]interface{}) {
rw.Header().Set("Content-Type", "text/javascript")
if cb := req.FormValue("cb"); identOrDotPattern.MatchString(cb) {
fmt.Fprintf(rw, "%s(", cb)
defer rw.Write([]byte(");\n"))
} else if v := req.FormValue("var"); identOrDotPattern.MatchString(v) {
fmt.Fprintf(rw, "%s = ", v)
defer rw.Write([]byte(";\n"))
}
bytes, _ := json.MarshalIndent(m, "", " ")
rw.Write(bytes)
}