kick off the dav things

This commit is contained in:
zicla 2019-04-12 18:01:35 +08:00
parent 73076c3a54
commit 8edb7833a8
4 changed files with 42 additions and 13 deletions

View File

@ -148,7 +148,8 @@ func (this *Context) registerBeans() {
this.registerBean(new(UserService)) this.registerBean(new(UserService))
//webdav //webdav
this.registerBean(new(WebdavController)) this.registerBean(new(DavController))
this.registerBean(new(DavService))
} }

View File

@ -3,7 +3,7 @@
// license that can be found in the LICENSE file. // license that can be found in the LICENSE file.
// Package webdav provides a WebDAV server implementation. // Package webdav provides a WebDAV server implementation.
package dav // import "golang.org/x/net/webdav" package dav
import ( import (
"errors" "errors"
@ -70,6 +70,7 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
} }
} }
// status = 0 表示没有问题
if status != 0 { if status != 0 {
w.WriteHeader(status) w.WriteHeader(status)
if status != http.StatusNoContent { if status != http.StatusNoContent {

View File

@ -1,9 +1,9 @@
package rest package rest
import ( import (
"golang.org/x/net/webdav"
"net/http" "net/http"
"regexp" "regexp"
"tank/rest/dav"
) )
/** /**
@ -12,7 +12,7 @@ import (
* https://tools.ietf.org/html/rfc4918 * https://tools.ietf.org/html/rfc4918
* *
*/ */
type WebdavController struct { type DavController struct {
BaseController BaseController
uploadTokenDao *UploadTokenDao uploadTokenDao *UploadTokenDao
downloadTokenDao *DownloadTokenDao downloadTokenDao *DownloadTokenDao
@ -20,10 +20,11 @@ type WebdavController struct {
matterService *MatterService matterService *MatterService
imageCacheDao *ImageCacheDao imageCacheDao *ImageCacheDao
imageCacheService *ImageCacheService imageCacheService *ImageCacheService
davService *DavService
} }
//初始化方法 //初始化方法
func (this *WebdavController) Init() { func (this *DavController) Init() {
this.BaseController.Init() this.BaseController.Init()
//手动装填本实例的Bean. //手动装填本实例的Bean.
@ -56,10 +57,15 @@ func (this *WebdavController) Init() {
if c, ok := b.(*ImageCacheService); ok { if c, ok := b.(*ImageCacheService); ok {
this.imageCacheService = c this.imageCacheService = c
} }
b = CONTEXT.GetBean(this.davService)
if c, ok := b.(*DavService); ok {
this.davService = c
}
} }
//注册自己的路由。 //注册自己的路由。
func (this *WebdavController) RegisterRoutes() map[string]func(writer http.ResponseWriter, request *http.Request) { func (this *DavController) RegisterRoutes() map[string]func(writer http.ResponseWriter, request *http.Request) {
routeMap := make(map[string]func(writer http.ResponseWriter, request *http.Request)) routeMap := make(map[string]func(writer http.ResponseWriter, request *http.Request))
@ -67,12 +73,12 @@ func (this *WebdavController) RegisterRoutes() map[string]func(writer http.Respo
} }
//处理一些特殊的接口,比如参数包含在路径中,一般情况下controller不将参数放在url路径中 //处理一些特殊的接口,比如参数包含在路径中,一般情况下controller不将参数放在url路径中
func (this *WebdavController) HandleRoutes(writer http.ResponseWriter, request *http.Request) (func(writer http.ResponseWriter, request *http.Request), bool) { func (this *DavController) HandleRoutes(writer http.ResponseWriter, request *http.Request) (func(writer http.ResponseWriter, request *http.Request), bool) {
path := request.URL.Path path := request.URL.Path
//匹配 /api/webdav{subPath} //匹配 /api/webdav{subPath}
reg := regexp.MustCompile(`^/api/webdav(.*)$`) reg := regexp.MustCompile(`^/api/dav(.*)$`)
strs := reg.FindStringSubmatch(path) strs := reg.FindStringSubmatch(path)
if len(strs) == 2 { if len(strs) == 2 {
var f = func(writer http.ResponseWriter, request *http.Request) { var f = func(writer http.ResponseWriter, request *http.Request) {
@ -85,16 +91,15 @@ func (this *WebdavController) HandleRoutes(writer http.ResponseWriter, request *
} }
//完成系统安装 //完成系统安装
func (this *WebdavController) Index(writer http.ResponseWriter, request *http.Request, subPath string) { func (this *DavController) Index(writer http.ResponseWriter, request *http.Request, subPath string) {
this.logger.Info("请求访问来了:%s %s", request.RequestURI, subPath) this.logger.Info("请求访问来了:%s %s", request.RequestURI, subPath)
handler := &webdav.Handler{ handler := &dav.Handler{
FileSystem: webdav.Dir("/Users/fusu/d/group/golang/src/tank/tmp/webdav"), FileSystem: dav.Dir("/Users/fusu/d/group/golang/src/tank/tmp/dav"),
LockSystem: webdav.NewMemLS(), LockSystem: dav.NewMemLS(),
} }
handler.ServeHTTP(writer, request) handler.ServeHTTP(writer, request)
} }

22
rest/dav_service.go Normal file
View File

@ -0,0 +1,22 @@
package rest
//@Service
type DavService struct {
Bean
matterDao *MatterDao
}
//初始化方法
func (this *DavService) Init() {
this.Bean.Init()
//手动装填本实例的Bean. 这里必须要用中间变量方可。
b := CONTEXT.GetBean(this.matterDao)
if b, ok := b.(*MatterDao); ok {
this.matterDao = b
}
}