Skip to content

Commit 6f78c00

Browse files
committed
Revert "Add support websocket return response"
This reverts commit 7ee1944.
1 parent 0cf843f commit 6f78c00

File tree

2 files changed

+0
-13
lines changed

2 files changed

+0
-13
lines changed

aws/api_gateway_websocket.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -166,14 +166,6 @@ func WebsocketResponse(w *WebsocketResponseWriter, multiValue bool) (r *events.A
166166
r.Headers = utils.SemicolonSeparatedHeaderMap(w.Header())
167167
}
168168

169-
if 0 < w.buf.Len() {
170-
if r.IsBase64Encoded {
171-
r.Body = base64.StdEncoding.EncodeToString(w.buf.Bytes())
172-
} else {
173-
r.Body = w.buf.String()
174-
}
175-
}
176-
177169
w.Done()
178170
return
179171
}

aws/websocket_response_writer.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package aws
22

33
import (
4-
"bytes"
54
"context"
65
"github.com/aws/aws-lambda-go/events"
76
"net/http"
@@ -15,7 +14,6 @@ type WebsocketResponseWriter struct {
1514
headers http.Header
1615
wroteHeader bool
1716
closeCh chan bool
18-
buf *bytes.Buffer
1917
}
2018

2119
func NewWebsocketResponseWriter(ctx context.Context, client APIGatewayManagementAPI, request *events.APIGatewayWebsocketProxyRequest) *WebsocketResponseWriter {
@@ -25,7 +23,6 @@ func NewWebsocketResponseWriter(ctx context.Context, client APIGatewayManagement
2523
req: request,
2624
headers: map[string][]string{},
2725
closeCh: make(chan bool, 1),
28-
buf: bytes.NewBuffer(nil),
2926
}
3027
}
3128

@@ -38,8 +35,6 @@ func (w *WebsocketResponseWriter) Write(i []byte) (int, error) {
3835
w.WriteHeader(http.StatusOK)
3936
}
4037

41-
w.buf.Write(i)
42-
4338
err := w.client.PostToConnection(w.ctx, w.req.RequestContext.ConnectionID, i)
4439
if err != nil {
4540
return 0, err

0 commit comments

Comments
 (0)