pkgs/cloudflare-workers
pkgs/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

small refactor

Browse Source
This commit is contained in:
a 2023-06-26 03:39:10 -05:00
parent 432419f4bd
commit 3d7f6acdd9
No known key found for this signature in database
GPG Key ID: 374BC539FE795AF0
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
_examples/tcp/node_modules/.mf/cf.json generated vendored Normal file
View File

@ -0,0 +1 @@
{"clientTcpRtt":4,"longitude":"-87.63830","latitude":"41.90320","tlsCipher":"AEAD-AES256-GCM-SHA384","continent":"NA","asn":6079,"clientAcceptEncoding":"br, gzip, deflate","country":"US","tlsClientAuth":{"certIssuerDNLegacy":"","certIssuerSKI":"","certSubjectDNRFC2253":"","certSubjectDNLegacy":"","certFingerprintSHA256":"","certNotBefore":"","certSKI":"","certSerial":"","certIssuerDN":"","certVerified":"NONE","certNotAfter":"","certSubjectDN":"","certPresented":"0","certRevoked":"0","certIssuerSerial":"","certIssuerDNRFC2253":"","certFingerprintSHA1":""},"tlsExportedAuthenticator":{"clientFinished":"6e17d4f96eca419c75c86d5a6beedcac3a1f0875c7c2d29054eca3e9c09210983f8e5786cc6a749a9b4d045787c0f55b","clientHandshake":"15735c095eaf758b59290283e2a625c70218b96312ef4a105664187187b7fcda9bb9f16d68ebe9ae7e2591ea3cdd5399","serverHandshake":"af89a947c9949945b1b4f01ca88573f4c6015cd5b0eda73f13c225a442af0c23b2e46afce3d04d7879a29f887b05be2d","serverFinished":"42abe67a58a7cb1215fb1dc9e0e9c143603879b2f2210f9cfa0005e2e2d06062a16ac6e03d2867e20f5d07e992404101"},"tlsVersion":"TLSv1.3","colo":"ORD","timezone":"America/Chicago","city":"Chicago","httpProtocol":"HTTP/1.1","edgeRequestKeepAliveStatus":1,"requestPriority":"","botManagement":{"corporateProxy":false,"verifiedBot":false,"ja3Hash":"0cce74b0d9b7f8528fb2181588d23793","staticResource":false,"detectionIds":{},"score":4},"clientTrustScore":4,"region":"Illinois","regionCode":"IL","asOrganization":"Astound Broadband","metroCode":"602","postalCode":"60610"}

20
cloudflare/socket.go
View File

@ -49,14 +49,17 @@ func (d *Dialer) Dial(ctx context.Context, network, addr string) (net.Conn, erro
} }
sock := &TCPSocket{} sock := &TCPSocket{}
sock.socket = d.connect.Invoke(addr, optionsObj) sock.socket = d.connect.Invoke(addr, optionsObj)
sock.options = d.opts
sock.ctx, sock.cn = context.WithCancel(ctx)
sock.init(d.ctx)
return sock, nil
}
func (sock *TCPSocket) init(ctx context.Context) {
sock.writer = sock.socket.Get("writable").Call("getWriter") sock.writer = sock.socket.Get("writable").Call("getWriter")
sock.reader = sock.socket.Get("readable").Call("getReader") sock.reader = sock.socket.Get("readable").Call("getReader")
sock.options = d.opts
sock.rd = jsutil.ConvertReadableStreamToReader(sock.reader) sock.rd = jsutil.ConvertReadableStreamToReader(sock.reader)
return
sock.ctx, sock.cn = context.WithCancel(d.ctx)
return sock, nil
} }
type TCPSocket struct { type TCPSocket struct {
@ -123,9 +126,10 @@ func (t *TCPSocket) Write(b []byte) (n int, err error) {
} }
// StartTls will call startTls on the socket // StartTls will call startTls on the socket
func (t *TCPSocket) StartTls() error { func (t *TCPSocket) StartTls() *TCPSocket {
t.socket.Call("startTls") t.socket = t.socket.Call("startTls")
return nil t.init(t.ctx)
return t
} }
// Close closes the connection. // Close closes the connection.