LLKennedy/httpgrpc

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func _App_Fibonacci_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(FibonacciRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func _ExposedApp_PostUploadPhoto_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(UploadPhotoRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func _App_Random_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(RandomRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func _ExposedApp_GetRandom_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(RandomRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

func _App_UploadPhoto_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
    in := new(UploadPhotoRequest)
    if err := dec(in); err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        newConn.addEventListener("close", async ev => {
            let event = ev;
            try {
                await this.mutex.Run(() => {
                    this.closeHandler(event);

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        newConn.addEventListener("error", async ev => {
            let event = ev;
            try {
                await this.mutex.Run(() => {
                    this.errorHandler(event);

• Read up
  Read up

MercuryWebSocket has 22 functions (exceeds 20 allowed). Consider refactoring.

Open

export class MercuryWebSocket<ReqT extends ProtoJSONCompatible, ResT = any> {
    //#region properties
    /** The logger used for all logs from this class */
    public readonly logger: Logger = console;
    /** The name of this websocket */

Method Server.handleClientStream has 73 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Server) handleClientStream(ctx context.Context, procType reflect.Type, caller reflect.Value, srv httpapi.ExposedService_ProxyStreamServer) (err error) {
    defer func() {
        r := recover()
        if r != nil {
            err = status.Errorf(codes.Internal, "caught panic for client stream: %v", r)

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *appClient) Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (App_BroadcastClient, error) {
    stream, err := c.cc.NewStream(ctx, &_App_serviceDesc.Streams[1], "/service.App/Broadcast", opts...)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (c *exposedAppClient) GetBroadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (ExposedApp_GetBroadcastClient, error) {
    stream, err := c.cc.NewStream(ctx, &_ExposedApp_serviceDesc.Streams[1], "/service.ExposedApp/GetBroadcast", opts...)
    if err != nil {
        return nil, err
    }

• Read up
  Read up

Function makeMockedWebsocket has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function makeMockedWebsocket(sandbox: sinon.SinonSandbox): Promise<mockedWebsocket> {
    let fake = new FakeWebsocket();
    let evStub = sandbox.stub(fake, "addEventListener");
    let done: ((a: any) => any)[] = [];
    let wait: [Promise<(ev: CloseEvent) => void>, Promise<(ev: Event) => void>, Promise<(ev: MessageEvent) => void>, Promise<(ev: Event) => void>] = [

Method Server.handleServerStream has 63 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (s *Server) handleServerStream(ctx context.Context, procType reflect.Type, caller reflect.Value, srv httpapi.ExposedService_ProxyStreamServer) (err error) {
    defer func() {
        r := recover()
        if r != nil {
            err = status.Errorf(codes.Internal, "caught panic for server stream: %v", r)

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    addEventListener<K extends keyof WebSocketEventMap>(type: K, listener: (this: WebSocket, ev: WebSocketEventMap[K]) => any, options?: boolean | AddEventListenerOptions): void

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    addEventListener<K extends keyof WebSocketEventMap>(type: K, listener: (this: WebSocket, ev: WebSocketEventMap[K]) => any, options?: boolean | AddEventListenerOptions): void

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func isOutStream(in reflect.Type) bool {
    sendMethod, exists := in.MethodByName("Send")
    if !exists {
        return false
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func isInStream(in reflect.Type) bool {
    recvMethod, exists := in.MethodByName("Recv")
    if !exists {
        return false
    }

• Read up
  Read up

Method stream.Serve has 61 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (h stream) Serve(c *websocket.Conn) {
    errWriter := errorWriter{
        c:       c,
        loggers: h.loggers,
        txid:    h.txid,

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            try {
                await job2;
                assert.fail("Not supposed to succeed")
            } catch (err) {
                assert.instanceOf(err, Error)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

            try {
                await job4;
                assert.fail("Not supposed to succeed")
            } catch (err) {
                assert.instanceOf(err, Error)

• Read up
  Read up