cloudflare-workers/_examples/sockets/main.go

package main

import (
	"bufio"
	"net/http"
	"time"

	"github.com/syumai/workers"
	"github.com/syumai/workers/cloudflare/sockets"
)

func main() {
	handler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
		conn, err := sockets.Connect(req.Context(), "tcpbin.com:4242", nil)
		if err != nil {
			http.Error(w, err.Error(), http.StatusInternalServerError)
			return
		}
		defer conn.Close()
		conn.SetDeadline(time.Now().Add(1 * time.Hour))
		_, err = conn.Write([]byte("hello.\n"))
		if err != nil {
			http.Error(w, err.Error(), http.StatusInternalServerError)
			return
		}
		rd := bufio.NewReader(conn)
		bts, err := rd.ReadBytes('.')
		if err != nil {
			http.Error(w, err.Error(), http.StatusInternalServerError)
			return
		}
		w.Write(bts)
	})
	workers.Serve(handler)
}