Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Sign in / Register
Toggle navigation
Y
ygopro-proxy
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Locked Files
Issues
0
Issues
0
List
Boards
Labels
Service Desk
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Security & Compliance
Security & Compliance
Dependency List
License Compliance
Packages
Packages
List
Container Registry
Analytics
Analytics
CI / CD
Code Review
Insights
Issues
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
MyCard
ygopro-proxy
Commits
d42a6762
Commit
d42a6762
authored
Aug 13, 2022
by
Chunchi Che
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
update log
parent
675e9b70
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
6 additions
and
6 deletions
+6
-6
proxy.go
proxy.go
+6
-6
No files found.
proxy.go
View file @
d42a6762
...
@@ -35,7 +35,7 @@ func ygoEndpoint(w http.ResponseWriter, r *http.Request) {
...
@@ -35,7 +35,7 @@ func ygoEndpoint(w http.ResponseWriter, r *http.Request) {
tcp
,
err
:=
net
.
Dial
(
"tcp"
,
"127.0.0.1"
+
PROXY_PORT
)
tcp
,
err
:=
net
.
Dial
(
"tcp"
,
"127.0.0.1"
+
PROXY_PORT
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Fatal
(
err
)
log
.
Fatal
(
"connect tcp server error"
,
err
)
}
}
defer
tcp
.
Close
()
defer
tcp
.
Close
()
...
@@ -49,7 +49,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
...
@@ -49,7 +49,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
for
{
for
{
messageType
,
buf
,
err
:=
ws
.
ReadMessage
()
messageType
,
buf
,
err
:=
ws
.
ReadMessage
()
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Fatal
(
err
)
log
.
Fatal
(
"websocket read message error"
,
err
)
break
break
}
}
...
@@ -65,7 +65,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
...
@@ -65,7 +65,7 @@ func wsProxy(ws *websocket.Conn, tcp *net.Conn, wg *sync.WaitGroup) {
_
,
err
=
writer
.
Write
(
buffer
)
_
,
err
=
writer
.
Write
(
buffer
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Fatal
(
err
)
log
.
Fatal
(
"websocket send message error"
,
err
)
break
break
}
}
}
}
...
@@ -80,15 +80,15 @@ func tcpProxy(tcp *net.Conn, ws *websocket.Conn, wg *sync.WaitGroup) {
...
@@ -80,15 +80,15 @@ func tcpProxy(tcp *net.Conn, ws *websocket.Conn, wg *sync.WaitGroup) {
_
,
err
:=
reader
.
Read
(
buffer
)
_
,
err
:=
reader
.
Read
(
buffer
)
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Fatal
(
err
)
log
.
Fatal
(
"tcp read message error"
,
err
)
break
break
}
}
log
.
Println
(
"tcp to websocket: "
+
string
(
buffer
))
log
.
Println
(
"tcp to websocket: "
+
string
(
buffer
))
err
=
ws
.
WriteMessage
(
websocket
.
TextMessage
,
buffer
)
// temporary TextMessage, should be BinaryMessage in ygopro
err
=
ws
.
WriteMessage
(
websocket
.
TextMessage
,
buffer
)
// temporary TextMessage, should be BinaryMessage in ygopro
if
err
!=
nil
{
if
err
!=
nil
{
log
.
Fatal
(
err
)
log
.
Fatal
(
"tcp send message error"
,
err
)
break
break
}
}
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment