go/cloudflare-workers
go/cloudflare-workers
1
0
Fork 0
mirror of https://github.com/syumai/workers.git synced 2025-03-10 17:29:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

update R2 examples

Browse Source
This commit is contained in:
syumai 2025-01-12 22:54:47 +09:00
parent c30f8b601c
commit f11ec6530f
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
_examples/r2-image-server/main.go
View File

@ -8,7 +8,7 @@ import (
"strings"
"github.com/syumai/workers"
"github.com/syumai/workers/cloudflare"
"github.com/syumai/workers/cloudflare/r2"
)
// bucketName is R2 bucket name defined in wrangler.toml.
@ -23,8 +23,8 @@ func handleErr(w http.ResponseWriter, msg string, err error) {
type server struct{}
func (s *server) bucket() (*cloudflare.R2Bucket, error) {
return cloudflare.NewR2Bucket(bucketName)
func (s *server) bucket() (*r2.Bucket, error) {
return r2.NewBucket(bucketName)
}
func (s *server) post(w http.ResponseWriter, req *http.Request, key string) {
@ -45,8 +45,8 @@ func (s *server) post(w http.ResponseWriter, req *http.Request, key string) {
return
}
}
_, err = bucket.Put(key, req.Body, &cloudflare.R2PutOptions{
HTTPMetadata: cloudflare.R2HTTPMetadata{
_, err = bucket.Put(key, req.Body, &r2.PutOptions{
HTTPMetadata: r2.HTTPMetadata{
ContentType: req.Header.Get("Content-Type"),
},
CustomMetadata: map[string]string{"custom-key": "custom-value"},

4
_examples/r2-image-viewer/main.go
View File

@ -8,7 +8,7 @@ import (
"strings"
"github.com/syumai/workers"
"github.com/syumai/workers/cloudflare"
"github.com/syumai/workers/cloudflare/r2"
)
// bucketName is R2 bucket name defined in wrangler.toml.
@ -23,7 +23,7 @@ func handleErr(w http.ResponseWriter, msg string, err error) {
// This example is based on implementation in syumai/workers-playground
// - https://github.com/syumai/workers-playground/blob/e32881648ccc055e3690a0d9c750a834261c333e/r2-image-viewer/src/index.ts#L30
func handler(w http.ResponseWriter, req *http.Request) {
bucket, err := cloudflare.NewR2Bucket(bucketName)
bucket, err := r2.NewBucket(bucketName)
if err != nil {
handleErr(w, "failed to get R2Bucket\n", err)
return