作者：rilloma
项目：gcs-with-blob-issu
func getImageUrl(c appengine.Context, key appengine.BlobKey) (*url.URL, error) {
// get image url only if it was specified
option := image.ServingURLOptions{
Secure: true, // serve on https
}
return image.ServingURL(c, key, &option)
}
作者：shaundunca
项目：goplacecreatur
func (c Creature) CropImage(width, height, max int, ctx appengine.Context) (image.Image, error) {
url, _ := aeimg.ServingURL(ctx, c.BlobKey, &aeimg.ServingURLOptions{Size: max, Crop: true})
client := urlfetch.Client(ctx)
resp, _ := client.Get(url.String())
// Just in case
if resp.StatusCode != 200 {
return nil, errors.New("Blob not found")
}
// Do we need further cropping?
if width == height {
return jpeg.Decode(resp.Body)
}
src, err := jpeg.Decode(resp.Body)
dest := image.NewRGBA(image.Rect(0, 0, width, height))
if err != nil {
return nil, err
}
graphics.Thumbnail(dest, src)
return dest, nil
}
作者：gregworle
项目：appEngineStor
func handleConfirmItemEntry(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
q := datastore.NewQuery("lighting").Order("-CreationTime").Limit(1)
confirm := &ResultRead{}
//set up an infinite loop - it will break when "Done"
for t := q.Run(c); ; {
var x ResultData
_, err := t.Next(&x)
if err == datastore.Done {
break
}
if err != nil {
serveError(c, w, err)
return
}
//Do something with the iterator
url, err := image.ServingURL(c, x.MainPhoto, nil)
if err != nil {
serveError(c, w, err)
return
}
confirm.Manufacturer = x.Manufacturer
confirm.URL = template.HTML(url.String())
}
w.Header().Set("Content-Type", "text/html")
err := confirmItemEntryTemplate.Execute(w, confirm)
if err != nil {
serveError(c, w, err)
return
}
}
作者：gregworle
项目：appEngineStor
func handleLast10(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
q := datastore.NewQuery("lighting").Order("-CreationTime").Limit(10)
confirm := &ResultRead{}
b := make(map[int]ResultRead)
for t, i := q.Run(c), 0; ; i++ {
var x ResultData
_, err := t.Next(&x)
if err == datastore.Done {
break
}
if err != nil {
serveError(c, w, err)
return
}
url, err := image.ServingURL(c, x.MainPhoto, nil)
if err != nil {
serveError(c, w, err)
return
}
confirm.Manufacturer = x.Manufacturer
confirm.URL = template.HTML(url.String())
b[i] = *confirm
}
w.Header().Set("Content-Type", "text/html")
err := last10Template.Execute(w, b)
if err != nil {
serveError(c, w, err)
return
}
}
作者：omairraza
项目：bap
func (fi *FileInfo) CreateUrls(r *http.Request, c appengine.Context) {
u := &url.URL{
Scheme: r.URL.Scheme,
Host: appengine.DefaultVersionHostname(c),
Path: "/",
}
uString := u.String()
fi.Url = uString + escape(string(fi.Key)) + "/" +
escape(string(fi.Name))
fi.DeleteUrl = fi.Url + "?delete=true"
fi.DeleteType = "DELETE"
if imageTypes.MatchString(fi.Type) {
servingUrl, err := image.ServingURL(
c,
fi.Key,
&image.ServingURLOptions{
Secure: strings.HasSuffix(u.Scheme, "s"),
Size: 0,
Crop: false,
},
)
check(err)
fi.ThumbnailUrl = servingUrl.String() + THUMBNAIL_PARAM
}
}
作者：Raner
项目：gorea
func loadImage(c appengine.Context, f *Feed) string {
s := f.Link
if s == "" {
s = f.Url
}
u, err := url.Parse(s)
if err != nil {
return ""
}
u.Path = "/favicon.ico"
u.RawQuery = ""
u.Fragment = ""
g := goon.FromContext(c)
i := &Image{Id: u.String()}
if err := g.Get(i); err == nil {
return i.Url
}
client := urlfetch.Client(c)
r, err := client.Get(u.String())
if err != nil || r.StatusCode != http.StatusOK || r.ContentLength == 0 {
return ""
}
b, err := ioutil.ReadAll(r.Body)
r.Body.Close()
if err != nil {
return ""
}
buf := bytes.NewBuffer(b)
_, t, err := image.DecodeConfig(buf)
if err != nil {
t = "application/octet-stream"
} else {
t = "image/" + t
}
w, err := blobstore.Create(c, t)
if err != nil {
return ""
}
if _, err := w.Write(b); err != nil {
return ""
}
if w.Close() != nil {
return ""
}
i.Blob, _ = w.Key()
su, err := aimage.ServingURL(c, i.Blob, &aimage.ServingURLOptions{Size: 16})
if err != nil {
if err = blobstore.Delete(c, i.Blob); err != nil {
c.Errorf("blob delete err: %v", err)
}
return ""
}
i.Url = su.String()
g.Put(i)
return i.Url
}
作者：clicker36
项目：ebfmex-pu
func UpdateServingLogoUrl(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
const batch = 50
page, _ := strconv.Atoi(r.FormValue("pg"))
if page < 1 {
page = 1
}
offset := batch * (page - 1)
q := datastore.NewQuery("EmpLogo").Offset(offset).Order("IdEmp").Limit(batch)
n, _ := q.Count(c)
for i := q.Run(c); ; {
var e model.Image
key, err := i.Next(&e)
if err == datastore.Done {
break
}
// Se crea la URL para servir la oferta desde el CDN, si no se puede
// se deja en blanco
var imgprops image.ServingURLOptions
imgprops.Secure = true
imgprops.Size = 180
imgprops.Crop = false
if e.Sp4 == "" && e.IdEmp != "" {
var blobkey appengine.BlobKey
blob, err := blobstore.Create(c, "image/jpeg")
if err != nil {
c.Errorf("blobstore Create: %v", e.IdEmp)
}
_, err = blob.Write(e.Data)
if err != nil {
c.Errorf("blobstore Write: %v", e.IdEmp)
}
err = blob.Close()
if err != nil {
c.Errorf("blobstore Close: %v", e.IdEmp)
}
blobkey, err = blob.Key()
if err != nil {
c.Errorf("blobstore Key Gen: %v", e.IdEmp)
}
if url, err := image.ServingURL(c, blobkey, &imgprops); err != nil {
c.Errorf("Cannot construct EmpLogo ServingURL : %v", e.IdEmp)
} else {
e.Sp3 = string(blobkey)
e.Sp4 = url.String()
}
_, err = datastore.Put(c, key, &e)
if err != nil {
c.Errorf("PutEmpLogo(); Error al intentar actualizar Emplogo : %v", e.IdEmp)
}
}
}
c.Infof("UpdateServingLogoUrl() Pagina: %d, actualizados: %d, del %d al %d", page, n, offset, offset+n)
return
}
作者：clicker36
项目：ebfmex-pu
func handleServeImg(w http.ResponseWriter, r *http.Request) {
if r.FormValue("id") != "none" {
c := appengine.NewContext(r)
var imgprops image.ServingURLOptions
imgprops.Secure = true
imgprops.Size = 400
imgprops.Crop = false
url, _ := image.ServingURL(c, appengine.BlobKey(r.FormValue("id")), &imgprops)
http.Redirect(w, r, url.String(), http.StatusFound)
}
return
}
作者：mehulsbhat
项目：tools-ol
func serveThumb(c appengine.Context, w http.ResponseWriter, r *http.Request) {
// c := appengine.NewContext(r)
k := appengine.BlobKey(r.FormValue("blobkey"))
var o image.ServingURLOptions = *new(image.ServingURLOptions)
o.Size = 200
o.Crop = true
url, err := image.ServingURL(c, k, &o)
util_err.Err_http(w, r, err, false)
http.Redirect(w, r, url.String(), http.StatusFound)
}
作者：knights
项目：sandbo
// GCSに保存された画像の公開URLを取得します。
func GetServingURL(c appengine.Context, filename string) (servingURL *url.URL, err error) {
blobKey, err := blobstore.BlobKeyForFile(c, filename)
if err != nil {
c.Errorf("serve.go:14: %s", err.Error())
return nil, err
}
opts := &image.ServingURLOptions{Secure: true}
servingURL, err = image.ServingURL(c, blobKey, opts)
if err != nil {
c.Errorf("serve.go:25: %s", err.Error())
return nil, err
}
return servingURL, nil
}
作者：vidos
项目：goinbo
func (m *Message) images2urls(c appengine.Context) {
urlc := make(chan string)
for _, im := range m.images {
go func(img *img_attachment) {
w, err := blobstore.Create(c, img.Type)
if err != nil {
urlc <- err.Error()
return
}
_, err = w.Write(img.Data)
if err != nil {
urlc <- err.Error()
return
}
err = w.Close()
if err != nil {
urlc <- err.Error()
return
}
key, err := w.Key()
if err != nil {
urlc <- err.Error()
return
}
url, err := image.ServingURL(c, key, &image.ServingURLOptions{Secure: false, Size: 0, Crop: false})
if err != nil {
urlc <- err.Error()
return
}
urlc <- url.String()
}(&im)
}
imagescnt := len(m.images)
m.ImageUrls = make([]string, 0, imagescnt)
for i := 0; i < imagescnt; i++ {
u := <-urlc
if strings.HasPrefix(u, "http") {
m.ImageUrls = append(m.ImageUrls, u)
} else {
c.Errorf("Error converting image to url: %v", u)
}
}
return
}
作者：janjis
项目：go_meetu
func fetch(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
imageUrl := r.FormValue("image")
c.Infof("THIS IS IMAGE URL %v", imageUrl)
client := urlfetch.Client(c)
resp, err := client.Get(imageUrl)
if error3(err, c, w) {
return
}
blob, err := blobstore.Create(c, resp.Header.Get("Content-Type"))
if error3(err, c, w) {
return
}
written, err := io.Copy(blob, resp.Body)
if error3(err, c, w) {
return
}
if written < 100 {
c.Infof("image is too small %v", written)
return
}
err = blob.Close()
if error3(err, c, w) {
return
}
blobkey, err := blob.Key()
if error3(err, c, w) {
return
}
thumbnailUrl, err := image.ServingURL(c, blobkey, &image.ServingURLOptions{Size: 100})
if error3(err, c, w) {
return
}
t := thumbnailUrl.String()
errr := channel.Send(c, "qwerty", t)
if error3(errr, c, w) {
return
}
// c.Infof("THIS IS IMAGE URL %v", t)
}
作者：robinwasse
项目：go-cloud-storage-app-engine-exampl
// Get the image link for an object.
func api_imageLinkObject(w http.ResponseWriter, r *http.Request) {
// We use the blob store + images to generate a serving url for the file
c := appengine.NewContext(r)
vars := mux.Vars(r)
bk, err := blobstore.BlobKeyForFile(c, "/gs/"+bucketName+"/"+vars["key"])
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if imageUrl, err := image.ServingURL(c, bk, nil); err == nil {
fmt.Fprint(w, imageUrl)
} else {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
}
作者：clicker36
项目：ebfmex-pu
func UpdateServingUrl(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
const batch = 300
page, _ := strconv.Atoi(r.FormValue("pg"))
if page < 1 {
page = 1
}
offset := batch * (page - 1)
q := datastore.NewQuery("Oferta").Offset(offset).Order("-FechaHora").Limit(batch)
n, _ := q.Count(c)
for i := q.Run(c); ; {
var e model.Oferta
key, err := i.Next(&e)
if err == datastore.Done {
break
}
// Se crea la URL para servir la oferta desde el CDN, si no se puede
// se deja en blanco
var imgprops image.ServingURLOptions
imgprops.Secure = true
imgprops.Size = 400
imgprops.Crop = false
if e.BlobKey != "none" && e.Codigo == "" {
if url, err := image.ServingURL(c, e.BlobKey, &imgprops); err != nil {
c.Errorf("Cannot construct ServingURL : %v", e.IdOft)
e.Codigo = ""
} else {
e.Codigo = url.String()
}
//c.Errorf("Get Cta Key; Error al intentar leer key.Parent() de Empresa : %v", e.IdEmp)
_, err = datastore.Put(c, key, &e)
if err != nil {
c.Errorf("PutEmpresa(); Error al intentar actualizar empresa : %v", e.IdEmp)
}
}
}
c.Infof("UpdateServingUrl() Pagina: %d, actualizados: %d, del %d al %d", page, n, offset, offset+n)
return
}
作者：gregworle
项目：appEngineStor
func handleUpload(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
blobs, other, err := blobstore.ParseUpload(r)
if err != nil {
serveError(c, w, err)
return
}
mainPhoto := blobs["mainPhoto"][0].BlobKey
creationTime := blobs["mainPhoto"][0].CreationTime
result := ResultData{
Manufacturer: other["manufacturer"][0],
MainPhoto: mainPhoto,
CreationTime: creationTime,
}
key, err := datastore.Put(c, datastore.NewIncompleteKey(c, "lighting", nil), &result)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
var result2 ResultData
if err = datastore.Get(c, key, &result2); err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
w.Header().Set("Content-Type", "text/html")
url, err := image.ServingURL(c, result2.MainPhoto, nil)
if err != nil {
serveError(c, w, err)
return
}
toPass := &ResultRead2{result2, template.HTML(url.String())}
w.Header().Set("Content-Type", "text/html")
err = uploadTemplate.Execute(w, toPass)
if err != nil {
serveError(c, w, err)
return
}
}
作者：clicker36
项目：ebfmex-pu
func handleServeImgById(w http.ResponseWriter, r *http.Request) {
if r.FormValue("id") != "none" {
c := appengine.NewContext(r)
oft, _ := model.GetOferta(c, r.FormValue("id"))
if oft.BlobKey != "none" {
var imgprops image.ServingURLOptions
imgprops.Secure = true
imgprops.Size = 400
imgprops.Crop = false
if url, err := image.ServingURL(c, oft.BlobKey, &imgprops); err != nil {
c.Infof("Cannot construct ServingURL : %v", r.FormValue("id"))
blobstore.Send(w, oft.BlobKey)
} else {
http.Redirect(w, r, url.String(), http.StatusFound)
}
} else {
w.WriteHeader(http.StatusNotFound)
//w.Header().Set("Content-Type", "text/plain; charset=utf-8")
//io.WriteString(w, "404 - Not Found")
}
}
return
}
作者：jiacontreras
项目：gorea
func loadImage(c appengine.Context, f *Feed) {
if f.ImageDate.After(time.Now()) {
return
}
f.ImageDate = time.Now().Add(time.Hour * 24 * 7)
s := f.Link
if s == "" {
s = f.Url
}
u, err := url.Parse(s)
if err != nil {
return
}
u.RawQuery = ""
u.Fragment = ""
p := "/favicon.ico"
client := urlfetch.Client(c)
if r, err := client.Get(u.String()); err == nil {
b, err := ioutil.ReadAll(r.Body)
r.Body.Close()
if err == nil {
i, err := FindIcon(b)
if err == nil {
p = i
}
}
}
u, err = u.Parse(p)
if err != nil {
return
}
r, err := client.Get(u.String())
if err != nil || r.StatusCode != http.StatusOK || r.ContentLength == 0 {
return
}
b, err := ioutil.ReadAll(r.Body)
r.Body.Close()
if err != nil {
return
}
buf := bytes.NewBuffer(b)
_, t, err := image.DecodeConfig(buf)
if err != nil {
t = "application/octet-stream"
} else {
t = "image/" + t
}
w, err := blobstore.Create(c, t)
if err != nil {
return
}
if _, err := w.Write(b); err != nil {
return
}
if w.Close() != nil {
return
}
g := goon.FromContext(c)
i := &Image{Id: u.String()}
if err := g.Get(i); err == nil {
blobstore.Delete(c, i.Blob)
}
i.Blob, _ = w.Key()
su, err := aimage.ServingURL(c, i.Blob, &aimage.ServingURLOptions{Size: 16})
if err != nil {
if err = blobstore.Delete(c, i.Blob); err != nil {
c.Errorf("blob delete err: %v", err)
}
return
}
i.Url = su.String()
g.Put(i)
f.Image = i.Url
}
作者：verticalpalett
项目：danduboi
func save(c appengine.Context, p *painting.Painting) error {
if p.Image.URL != "" {
// Fetch the image.
res, err := urlfetch.Client(c).Get(p.Image.URL)
if err != nil {
logger.Error(c, err)
return err
}
defer res.Body.Close()
// Save what we read to decode the image config,
// so we can save the whole image to the blobstore.
buf := &bytes.Buffer{}
t := io.TeeReader(res.Body, buf)
// Decode the config to get the size and content type.
conf, ext, err := image.DecodeConfig(t)
if err != nil {
logger.Error(c, err)
return err
}
p.Image.Width = conf.Width
p.Image.Height = conf.Height
// Create a new blob.
b, err := blobstore.Create(c, "image/"+ext)
if err != nil {
logger.Error(c, err)
return err
}
// Copy the image into it.
// Prepend what we read to decode the image config.
r := io.MultiReader(buf, res.Body)
_, err = io.Copy(b, r)
if err != nil {
logger.Error(c, err)
return err
}
err = b.Close()
if err != nil {
logger.Error(c, err)
return err
}
// Add the image to the painting.
p.Image.BlobKey, err = b.Key()
if err != nil {
logger.Error(c, err)
return err
}
u, err := aeimage.ServingURL(c, p.Image.BlobKey, nil)
if err != nil {
logger.Error(c, err)
return err
}
p.Image.URL = u.String()
}
return p.Save(c)
}
作者：nvcnv
项目：imgid
func (i *ImageIndex) FetchImage(info imageInfo, pageID string) {
i.wg.Add(1)
_, err := i.s.Conn.Storage("Image").NewQuery().KeysOnly().
Filter("Location", model.EQ, info.src).GetFirst(nil)
if err != model.ErrNotFound {
i.s.Log("Error: %s\n", "galleyes: indexed image")
i.wg.Done()
return
}
resp, err := i.s.Client.Get(info.src)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
mime := resp.Header.Get("Content-Type")
if mime != "image/png" && mime != "image/jpeg" && mime != "image/gif" {
i.s.Log("Error: %s - %s - %s\n", "galleyes: not supported image format", mime, info.src)
i.wg.Done()
return
}
data, err := ioutil.ReadAll(resp.Body)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
// caculate PHash
var buff bytes.Buffer
_, err = buff.Write(data)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
m, _, err := tipimage.Decode(&buff)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
hash, part := PHash(m)
// caculate md5 checksum
h := md5.New()
_, err = h.Write(data)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
checksum := h.Sum(nil)
// save the original image
w, err := blobstore.Create(i.s.Context, mime)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
w.Write(data)
_, err = w.Write(data)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
err = w.Close()
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
key, err := w.Key()
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
link, err := imgs.ServingURL(i.s.Context, key, nil)
if err != nil {
i.s.Log("Error: %s\n", err.Error())
i.wg.Done()
return
}
// assign value
img := Image{}
img.PageID = pageID
img.SavedID = string(key)
img.SavedLocation = link.String()
img.Location = info.src
img.Description = info.alt
img.CheckSum = base64.URLEncoding.EncodeToString(checksum)
img.PHash = hash
img.Part0 = part[0]
img.Part1 = part[1]
img.Part2 = part[2]
img.Part3 = part[3]
//.........这里部分代码省略.........
作者：clicker36
项目：ebfmex-pu
// upload is the HTTP handler for uploading images; it handles "/".
func upload(w http.ResponseWriter, r *http.Request) {
c := appengine.NewContext(r)
var imgprops appimage.ServingURLOptions
imgprops.Secure = true
imgprops.Size = 180
imgprops.Crop = false
if s, ok := sess.IsSess(w, r, c); ok {
u, _ := model.GetCta(c, s.User)
emp, err := u.GetEmpresa(c, r.FormValue("IdEmp"))
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
imgo := model.GetLogo(c, r.FormValue("IdEmp"))
if imgo == nil {
imgo = new(model.Image)
imgo.IdEmp = emp.IdEmp
}
fd := imgToForm(*imgo)
tc := make(map[string]interface{})
tc["Sess"] = s
tc["Empresa"] = emp
tc["FormData"] = fd
if r.Method != "POST" {
// No upload; show the upload form.
micrositio(w, r)
return
}
idemp := r.FormValue("IdEmp")
sp1 := r.FormValue("Sp1")
sp2 := r.FormValue("Sp2")
f, _, err := r.FormFile("image")
model.Check(err)
defer f.Close()
// Grab the image data
var buf bytes.Buffer
io.Copy(&buf, f)
i, _, err := image.Decode(&buf)
if err != nil {
if r.FormValue("tipo") == "async" {
//w.Header().Set("Content-Type", "application/json")
fmt.Fprintf(w, "<p>'%s'</p>", "No se actualizó el logotipo, formato no aceptado")
} else {
tc["Error"] = struct{ Badformat string }{"badformat"}
micrositioTpl.Execute(w, tc)
}
return
}
const max = 600
// We aim for less than max pixels in any dimension.
if b := i.Bounds(); b.Dx() > max || b.Dy() > max {
// If it's gigantic, it's more efficient to downsample first
// and then resize; resizing will smooth out the roughness.
if b.Dx() > 2*max || b.Dy() > 2*max {
w, h := max*2, max*2
if b.Dx() > b.Dy() {
h = b.Dy() * h / b.Dx()
} else {
w = b.Dx() * w / b.Dy()
}
i = resize.Resample(i, i.Bounds(), w, h)
b = i.Bounds()
}
w, h := max, max
if b.Dx() > b.Dy() {
h = b.Dy() * h / b.Dx()
} else {
w = b.Dx() * w / b.Dy()
}
i = resize.Resize(i, i.Bounds(), w, h)
}
// Encode as a new JPEG image.
buf.Reset()
err = jpeg.Encode(&buf, i, nil)
if err != nil {
if r.FormValue("tipo") == "async" {
fmt.Fprintf(w, "<p>'%s'</p>", "No se actualizó el logotipo, formato no aceptado")
} else {
tc["Error"] = struct{ Badencode string }{"badencode"}
micrositioTpl.Execute(w, tc)
}
return
}
var blobkey appengine.BlobKey
blob, err := blobstore.Create(c, "image/jpeg")
if err != nil {
c.Errorf("blobstore Create: %v", idemp)
}
_, err = blob.Write(buf.Bytes())
if err != nil {
c.Errorf("blobstore Write: %v", idemp)
}
err = blob.Close()
if err != nil {
c.Errorf("blobstore Close: %v", idemp)
}
//.........这里部分代码省略.........
