mirror of
https://github.com/golang/go
synced 2024-11-19 00:04:40 -07:00
ff3f684ce0
This is not intended to be a user friendly package, just the rawest correct implemenation of the protocol as a building block Change-Id: Ib672b7f1e2fd8284be422dc7964f1876e94c9578 Reviewed-on: https://go-review.googlesource.com/136676 Reviewed-by: Alan Donovan <adonovan@google.com> Reviewed-by: Rebecca Stambler <rstambler@golang.org>
35 lines
1.1 KiB
Go
35 lines
1.1 KiB
Go
// Copyright 2018 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package protocol
|
|
|
|
import (
|
|
"context"
|
|
|
|
"golang.org/x/tools/internal/jsonrpc2"
|
|
)
|
|
|
|
func canceller(ctx context.Context, conn *jsonrpc2.Conn, req *jsonrpc2.Request) {
|
|
conn.Notify(context.Background(), "$/cancelRequest", &CancelParams{ID: *req.ID})
|
|
}
|
|
|
|
func RunClient(ctx context.Context, stream jsonrpc2.Stream, client Client, opts ...interface{}) (*jsonrpc2.Conn, Server) {
|
|
opts = append([]interface{}{clientHandler(client), canceller}, opts...)
|
|
conn := jsonrpc2.NewConn(ctx, stream, opts...)
|
|
return conn, &serverDispatcher{Conn: conn}
|
|
}
|
|
|
|
func RunServer(ctx context.Context, stream jsonrpc2.Stream, server Server, opts ...interface{}) (*jsonrpc2.Conn, Client) {
|
|
opts = append([]interface{}{serverHandler(server), canceller}, opts...)
|
|
conn := jsonrpc2.NewConn(ctx, stream, opts...)
|
|
return conn, &clientDispatcher{Conn: conn}
|
|
}
|
|
|
|
func toJSONError(err error) *jsonrpc2.Error {
|
|
if jsonError, ok := err.(*jsonrpc2.Error); ok {
|
|
return jsonError
|
|
}
|
|
return jsonrpc2.NewErrorf(jsonrpc2.CodeParseError, "%v", err)
|
|
}
|