F: add cache API example

examples/cache/.gitignore

@@ -0,0 +1 @@
+dist

examples/cache/Makefile

@@ -0,0 +1,13 @@
+.PHONY: dev
+dev:
+	wrangler dev
+
+.PHONY: build
+build:
+	mkdir -p dist
+	#tinygo build -o ./dist/app.wasm -target wasm ./...
+	tinygo build -o ./dist/app.wasm -target wasm -no-debug ./...
+
+.PHONY: publish
+publish:
+	wrangler publish

examples/cache/README.md

@@ -0,0 +1,20 @@
+# [Cache](https://developers.cloudflare.com/workers/runtime-apis/cache/)
+
+The Cache API allows fine grained control of reading and writing from the Cloudflare global network.
+
+### Development
+
+#### Requirements
+
+This project requires these tools to be installed globally.
+
+* wrangler
+* tinygo
+
+#### Commands
+
+```
+make dev     # run dev server
+make build   # build Go Wasm binary
+make publish # publish worker
+```

examples/cache/go.mod

@@ -0,0 +1,9 @@
+module github.com/syumai/cache
+
+go 1.18
+
+require github.com/syumai/workers v0.0.0
+
+require github.com/go-chi/chi/v5 v5.0.8 // indirect
+
+replace github.com/syumai/workers => ../../

examples/cache/go.sum

@@ -0,0 +1,4 @@
+github.com/go-chi/chi/v5 v5.0.8 h1:lD+NLqFcAi1ovnVZpsnObHGW4xb4J8lNmoYVfECH1Y0=
+github.com/go-chi/chi/v5 v5.0.8/go.mod h1:DslCQbL2OYiznFReuXYUmQ2hGd1aDpCnlMNITLSKoi8=
+github.com/syumai/workers v0.1.0 h1:z5QfQR2X+PCKzom7RodpI5J4D5YF7NT7Qwzb9AM9dgY=
+github.com/syumai/workers v0.1.0/go.mod h1:alXIDhTyeTwSzh0ZgQ3cb9HQPyyYfIejupE4Z3efr14=

examples/cache/main.go

@@ -0,0 +1,77 @@
+package main
+
+import (
+	"bytes"
+	"fmt"
+	"io"
+	"net/http"
+	"time"
+
+	"github.com/syumai/workers"
+	"github.com/syumai/workers/cloudflare"
+	"github.com/syumai/workers/cloudflare/cache"
+)
+
+type responseWriter struct {
+	http.ResponseWriter
+	StatusCode int
+	Body       []byte
+}
+
+func (rw *responseWriter) WriteHeader(statusCode int) {
+	rw.StatusCode = statusCode
+	rw.ResponseWriter.WriteHeader(statusCode)
+}
+
+func (rw *responseWriter) Write(data []byte) (int, error) {
+	rw.Body = append(rw.Body, data...)
+	return rw.ResponseWriter.Write(data)
+}
+
+func (rw *responseWriter) ToHTTPResponse() *http.Response {
+	return &http.Response{
+		StatusCode: rw.StatusCode,
+		Header:     rw.Header(),
+		Body:       io.NopCloser(bytes.NewReader(rw.Body)),
+	}
+}
+
+func handler(w http.ResponseWriter, req *http.Request) {
+	ctx := req.Context()
+	rw := responseWriter{ResponseWriter: w}
+	c := cache.New()
+
+	// Find cache
+	res, _ := c.Match(req, nil)
+	if res != nil {
+		// Set the response status code
+		rw.WriteHeader(res.StatusCode)
+		// Set the response headers
+		for key, values := range res.Header {
+			for _, value := range values {
+				rw.Header().Add(key, value)
+			}
+		}
+		rw.Header().Add("X-Message", "cache from worker")
+		// Set the response body
+		io.Copy(rw.ResponseWriter, res.Body)
+		return
+	}
+
+	// Responding
+	text := fmt.Sprintf("time:%v\n", time.Now().UnixMilli())
+	rw.Header().Set("Cache-Control", "max-age=15")
+	rw.Write([]byte(text))
+
+	// Create cache
+	cloudflare.WaitUntil(ctx, func() {
+		err := c.Put(req, rw.ToHTTPResponse())
+		if err != nil {
+			fmt.Println(err)
+		}
+	})
+}
+
+func main() {
+	workers.Serve(http.HandlerFunc(handler))
+}

examples/cache/worker.mjs

@@ -0,0 +1,22 @@
+import "../assets/polyfill_performance.js";
+import "../assets/wasm_exec.js";
+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;
+});
+
+export default {
+  async fetch(req, env, ctx) {
+    await load;
+    await readyPromise;
+    return handleRequest(req, { env, ctx });
+  }
+}

examples/cache/wrangler.toml

@@ -0,0 +1,6 @@
+name = "cache"
+main = "./worker.mjs"
+compatibility_date = "2023-02-24"
+
+[build]
+command = "make build"