1
0
mirror of https://github.com/astaxie/beego.git synced 2024-11-26 07:51:30 +00:00

delete old static file code

This commit is contained in:
JessonChan 2015-11-11 16:21:04 +08:00
parent e4c6e5d2e1
commit 15b0b9b66d
2 changed files with 0 additions and 270 deletions

View File

@ -1,190 +0,0 @@
// Copyright 2014 beego Author. All Rights Reserved.
//
// 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 beego
import (
"bytes"
"errors"
"io"
"io/ioutil"
"os"
"sync"
"time"
"github.com/astaxie/beego/acceptencoder"
)
var (
menFileInfoMap = make(map[string]*memFileInfo)
lock sync.RWMutex
)
// openMemZipFile returns MemFile object with a compressed static file.
// it's used for serve static file if gzip enable.
func openMemZipFile(path string, zip string) (*memFile, error) {
osFile, e := os.Open(path)
if e != nil {
return nil, e
}
defer osFile.Close()
osFileInfo, e := osFile.Stat()
if e != nil {
return nil, e
}
modTime := osFileInfo.ModTime()
fileSize := osFileInfo.Size()
mapKey := zip + ":" + path
lock.RLock()
cfi, ok := menFileInfoMap[mapKey]
lock.RUnlock()
if !(ok && cfi.ModTime() == modTime && cfi.fileSize == fileSize) {
lock.Lock()
defer lock.Unlock()
if cfi, ok = menFileInfoMap[mapKey]; !ok {
cfi, e = newMenFileInfo(osFile, osFileInfo, zip)
if e != nil {
return nil, e
}
menFileInfoMap[mapKey] = cfi
}
}
return &memFile{fi: cfi, offset: 0}, nil
}
// memFileInfo contains a compressed file bytes and file information.
// it implements os.FileInfo interface.
type memFileInfo struct {
os.FileInfo
modTime time.Time
content []byte
contentSize int64
fileSize int64
}
// newMenFileInfo return a memFileInfo from file by zip type
func newMenFileInfo(file *os.File, fileInfo os.FileInfo, zip string) (*memFileInfo, error) {
var content []byte
var zipBuf bytes.Buffer
var err error
_, _, err = acceptencoder.WriteFile(zip, &zipBuf, file)
if err != nil {
return nil, err
}
content, err = ioutil.ReadAll(&zipBuf)
if err != nil {
return nil, err
}
return &memFileInfo{
FileInfo: fileInfo,
modTime: fileInfo.ModTime(),
content: content,
contentSize: int64(len(content)),
fileSize: fileInfo.Size(),
}, nil
}
// Name returns the compressed filename.
func (fi *memFileInfo) Name() string {
return fi.Name()
}
// Size returns the raw file content size, not compressed size.
func (fi *memFileInfo) Size() int64 {
return fi.contentSize
}
// Mode returns file mode.
func (fi *memFileInfo) Mode() os.FileMode {
return fi.Mode()
}
// ModTime returns the last modified time of raw file.
func (fi *memFileInfo) ModTime() time.Time {
return fi.modTime
}
// IsDir returns the compressing file is a directory or not.
func (fi *memFileInfo) IsDir() bool {
return fi.IsDir()
}
// return nil. implement the os.FileInfo interface method.
func (fi *memFileInfo) Sys() interface{} {
return nil
}
// memFile contains MemFileInfo and bytes offset when reading.
// it implements io.Reader,io.ReadCloser and io.Seeker.
type memFile struct {
fi *memFileInfo
offset int64
}
// Close memfile.
func (f *memFile) Close() error {
return nil
}
// Get os.FileInfo of memfile.
func (f *memFile) Stat() (os.FileInfo, error) {
return f.fi, nil
}
// read os.FileInfo of files in directory of memfile.
// it returns empty slice.
func (f *memFile) Readdir(count int) ([]os.FileInfo, error) {
infos := []os.FileInfo{}
return infos, nil
}
// Read bytes from the compressed file bytes.
func (f *memFile) Read(p []byte) (n int, err error) {
if len(f.fi.content)-int(f.offset) >= len(p) {
n = len(p)
} else {
n = len(f.fi.content) - int(f.offset)
err = io.EOF
}
copy(p, f.fi.content[f.offset:f.offset+int64(n)])
f.offset += int64(n)
return
}
var errWhence = errors.New("Seek: invalid whence")
var errOffset = errors.New("Seek: invalid offset")
// Read bytes from the compressed file bytes by seeker.
func (f *memFile) Seek(offset int64, whence int) (ret int64, err error) {
switch whence {
default:
return 0, errWhence
case os.SEEK_SET:
case os.SEEK_CUR:
offset += f.offset
case os.SEEK_END:
offset += int64(len(f.fi.content))
}
if offset < 0 || int(offset) > len(f.fi.content) {
return 0, errOffset
}
f.offset = offset
return f.offset, nil
}

View File

@ -1,80 +0,0 @@
// Copyright 2015 beego Author. All Rights Reserved.
//
// 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 beego
import (
"bytes"
"compress/flate"
"compress/gzip"
"io"
"io/ioutil"
"os"
"testing"
)
const licenseFile = "./LICENSE"
func TestOpenMemZipFile_1(t *testing.T) {
mf, err := openMemZipFile(licenseFile, "")
if err != nil {
t.Fail()
}
file, _ := os.Open(licenseFile)
content, _ := ioutil.ReadAll(file)
assetMenFileAndContent(mf, content, t)
}
func assetMenFileAndContent(mf *memFile, content []byte, t *testing.T) {
if mf.fi.contentSize != int64(len(content)) {
t.Log("content size not same")
t.Fail()
}
for i, v := range content {
if v != mf.fi.content[i] {
t.Log("content not same")
t.Fail()
}
}
if len(menFileInfoMap) == 0 {
t.Log("men map is empty")
t.Fail()
}
}
func TestOpenMemZipFile_2(t *testing.T) {
mf, err := openMemZipFile(licenseFile, "gzip")
if err != nil {
t.Fail()
}
file, _ := os.Open(licenseFile)
var zipBuf bytes.Buffer
fileWriter, _ := gzip.NewWriterLevel(&zipBuf, gzip.BestCompression)
io.Copy(fileWriter, file)
fileWriter.Close()
content, _ := ioutil.ReadAll(&zipBuf)
assetMenFileAndContent(mf, content, t)
}
func TestOpenMemZipFile_3(t *testing.T) {
mf, err := openMemZipFile(licenseFile, "deflate")
if err != nil {
t.Fail()
}
file, _ := os.Open(licenseFile)
var zipBuf bytes.Buffer
fileWriter, _ := flate.NewWriter(&zipBuf, flate.BestCompression)
io.Copy(fileWriter, file)
fileWriter.Close()
content, _ := ioutil.ReadAll(&zipBuf)
assetMenFileAndContent(mf, content, t)
}