pkgs/cloudflare-workers
pkgs/cloudflare-workers
1
0
Fork 0
mirror of https://github.com/syumai/workers.git synced 2025-03-11 09:49:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix examples

Browse Source
This commit is contained in:
syumai 2023-02-11 12:37:38 +09:00
parent 9e87698fac
commit 0fe54fad27
12 changed files with 116 additions and 166 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
examples/basic-auth-proxy/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

2
examples/env/main.go vendored
View File

@ -10,7 +10,7 @@ import (
func main() {
handler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
fmt.Fprintf(w, "MY_ENV: %s", cloudflare.Getenv("MY_ENV"))
fmt.Fprintf(w, "MY_ENV: %s", cloudflare.Getenv(req.Context(), "MY_ENV"))
})
workers.Serve(handler)
}

23
examples/env/worker.mjs vendored
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

23
examples/hello/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

48
examples/kv-counter/main.go
View File

@ -7,9 +7,8 @@ import (
"os"
"strconv"
"github.com/syumai/workers/cloudflare"
"github.com/syumai/workers"
"github.com/syumai/workers/cloudflare"
)
// counterNamespace is a bounded KV namespace for storing counter.
@ -25,35 +24,25 @@ func handleErr(w http.ResponseWriter, msg string, err error) {
}
func main() {
// initialize KV namespace instance
kv, err := cloudflare.NewKVNamespace(counterNamespace)
if err != nil {
fmt.Fprintf(os.Stderr, "failed to init KV: %v", err)
os.Exit(1)
}
http.HandleFunc("/", func(w http.ResponseWriter, req *http.Request) {
if req.URL.Path != "/" {
w.WriteHeader(http.StatusNotFound)
return
}
// initialize KV namespace instance
kv, err := cloudflare.NewKVNamespace(req.Context(), counterNamespace)
if err != nil {
fmt.Fprintf(os.Stderr, "failed to init KV: %v", err)
os.Exit(1)
}
countStr, err := kv.GetString(countKey, nil)
if err != nil {
handleErr(w, "failed to get current count\n", err)
return
}
/*
countReader, err := kv.GetReader(countKey, nil)
if err != nil {
handleErr(w, "failed to get current count\n", err)
return
}
b, _ := io.ReadAll(countReader)
countStr := string(b)
*/
// ignore err and treat count value as 0
count, _ := strconv.Atoi(countStr)
@ -65,28 +54,7 @@ func main() {
return
}
/*
err = kv.PutReader(countKey, strings.NewReader(nextCountStr), nil)
if err != nil {
handleErr(w, "failed to put next count\n", err)
return
}
*/
w.Header().Set("Content-Type", "text/plain")
/*
// List returns only `count` as the keys in this namespace.
v, err := kv.List(nil)
if err != nil {
handleErr(w, "failed to list\n", err)
return
}
for i, key := range v.Keys {
fmt.Fprintf(w, "%d: %s\n", i, key.Name)
}
*/
w.Write([]byte(nextCountStr))
})

23
examples/kv-counter/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

44
examples/r2-image-server/main.go
View File

@ -1,11 +1,11 @@
package main
import (
"context"
"fmt"
"io"
"log"
"net/http"
"os"
"strings"
"github.com/syumai/workers"
@ -22,20 +22,19 @@ func handleErr(w http.ResponseWriter, msg string, err error) {
w.Write([]byte(msg))
}
type server struct {
bucket *cloudflare.R2Bucket
}
type server struct{}
func newServer() (*server, error) {
bucket, err := cloudflare.NewR2Bucket(bucketName)
if err != nil {
return nil, err
}
return &server{bucket: bucket}, nil
func (s *server) bucket(ctx context.Context) (*cloudflare.R2Bucket, error) {
return cloudflare.NewR2Bucket(ctx, bucketName)
}
func (s *server) post(w http.ResponseWriter, req *http.Request, key string) {
objects, err := s.bucket.List()
bucket, err := s.bucket(req.Context())
if err != nil {
handleErr(w, "failed to initialize R2Bucket\n", err)
return
}
objects, err := bucket.List()
if err != nil {
handleErr(w, "failed to list R2Objects\n", err)
return
@ -47,7 +46,7 @@ func (s *server) post(w http.ResponseWriter, req *http.Request, key string) {
return
}
}
_, err = s.bucket.Put(key, req.Body, &cloudflare.R2PutOptions{
_, err = bucket.Put(key, req.Body, &cloudflare.R2PutOptions{
HTTPMetadata: cloudflare.R2HTTPMetadata{
ContentType: req.Header.Get("Content-Type"),
},
@ -64,7 +63,12 @@ func (s *server) post(w http.ResponseWriter, req *http.Request, key string) {
func (s *server) get(w http.ResponseWriter, req *http.Request, key string) {
// get image object from R2
imgObj, err := s.bucket.Get(key)
bucket, err := s.bucket(req.Context())
if err != nil {
handleErr(w, "failed to initialize R2Bucket\n", err)
return
}
imgObj, err := bucket.Get(key)
if err != nil {
handleErr(w, "failed to get R2Object\n", err)
return
@ -86,7 +90,12 @@ func (s *server) get(w http.ResponseWriter, req *http.Request, key string) {
func (s *server) delete(w http.ResponseWriter, req *http.Request, key string) {
// delete image object from R2
if err := s.bucket.Delete(key); err != nil {
bucket, err := s.bucket(req.Context())
if err != nil {
handleErr(w, "failed to initialize R2Bucket\n", err)
return
}
if err := bucket.Delete(key); err != nil {
handleErr(w, "failed to delete R2Object\n", err)
return
}
@ -114,10 +123,5 @@ func (s *server) ServeHTTP(w http.ResponseWriter, req *http.Request) {
}
func main() {
s, err := newServer()
if err != nil {
fmt.Fprintf(os.Stderr, "failed to start server: %v", err)
os.Exit(1)
}
workers.Serve(s)
workers.Serve(&server{})
}

23
examples/r2-image-server/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

2
examples/r2-image-viewer/main.go
View File

@ -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 := cloudflare.NewR2Bucket(req.Context(), bucketName)
if err != nil {
handleErr(w, "failed to get R2Bucket\n", err)
return

23
examples/r2-image-viewer/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})

25
examples/simple-json-server/app/app_easyjson.go
View File

@ -4,7 +4,6 @@ package app
import (
json "encoding/json"
easyjson "github.com/mailru/easyjson"
jlexer "github.com/mailru/easyjson/jlexer"
jwriter "github.com/mailru/easyjson/jwriter"
@ -18,7 +17,7 @@ var (
_ easyjson.Marshaler
)
func easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp(in *jlexer.Lexer, out *HelloResponse) {
func easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(in *jlexer.Lexer, out *HelloResponse) {
isTopLevel := in.IsStart()
if in.IsNull() {
if isTopLevel {
@ -49,7 +48,7 @@ func easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp(in *jlexer.Le
in.Consumed()
}
}
func easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp(out *jwriter.Writer, in HelloResponse) {
func easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(out *jwriter.Writer, in HelloResponse) {
out.RawByte('{')
first := true
_ = first
@ -64,27 +63,27 @@ func easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp(out *jwriter.
// MarshalJSON supports json.Marshaler interface
func (v HelloResponse) MarshalJSON() ([]byte, error) {
w := jwriter.Writer{}
easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp(&w, v)
easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(&w, v)
return w.Buffer.BuildBytes(), w.Error
}
// MarshalEasyJSON supports easyjson.Marshaler interface
func (v HelloResponse) MarshalEasyJSON(w *jwriter.Writer) {
easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp(w, v)
easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(w, v)
}
// UnmarshalJSON supports json.Unmarshaler interface
func (v *HelloResponse) UnmarshalJSON(data []byte) error {
r := jlexer.Lexer{Data: data}
easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp(&r, v)
easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(&r, v)
return r.Error()
}
// UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (v *HelloResponse) UnmarshalEasyJSON(l *jlexer.Lexer) {
easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp(l, v)
easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp(l, v)
}
func easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp1(in *jlexer.Lexer, out *HelloRequest) {
func easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(in *jlexer.Lexer, out *HelloRequest) {
isTopLevel := in.IsStart()
if in.IsNull() {
if isTopLevel {
@ -115,7 +114,7 @@ func easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp1(in *jlexer.L
in.Consumed()
}
}
func easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp1(out *jwriter.Writer, in HelloRequest) {
func easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(out *jwriter.Writer, in HelloRequest) {
out.RawByte('{')
first := true
_ = first
@ -130,23 +129,23 @@ func easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp1(out *jwriter
// MarshalJSON supports json.Marshaler interface
func (v HelloRequest) MarshalJSON() ([]byte, error) {
w := jwriter.Writer{}
easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp1(&w, v)
easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(&w, v)
return w.Buffer.BuildBytes(), w.Error
}
// MarshalEasyJSON supports easyjson.Marshaler interface
func (v HelloRequest) MarshalEasyJSON(w *jwriter.Writer) {
easyjsonD2c14bEncodeGithubComSyumaiWorkersPlaygroundTinygoApp1(w, v)
easyjsonD2c14bEncodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(w, v)
}
// UnmarshalJSON supports json.Unmarshaler interface
func (v *HelloRequest) UnmarshalJSON(data []byte) error {
r := jlexer.Lexer{Data: data}
easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp1(&r, v)
easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(&r, v)
return r.Error()
}
// UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (v *HelloRequest) UnmarshalEasyJSON(l *jlexer.Lexer) {
easyjsonD2c14bDecodeGithubComSyumaiWorkersPlaygroundTinygoApp1(l, v)
easyjsonD2c14bDecodeGithubComSyumaiWorkersExamplesSimpleJsonServerApp1(l, v)
}

23
examples/simple-json-server/worker.mjs
View File

@ -4,22 +4,19 @@ import mod from "./dist/app.wasm";
const go = new Go();
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
const load = WebAssembly.instantiate(mod, go.importObject).then((instance) => {
go.run(instance);
return instance;
});
const readyPromise = new Promise((resolve) => {
globalThis.ready = resolve;
});
async function processRequest(event) {
const req = event.request;
await load;
await readyPromise;
return handleRequest(req);
export default {
async fetch(req, env, ctx) {
await load;
await readyPromise;
return handleRequest(req, { env, ctx });
}
}
addEventListener("fetch", (event) => {
event.respondWith(processRequest(event));
})