Anapher/Strive

Function selectAvailableInputDevicesFactory has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   createSelector(selectLocalDevices, selectEquipmentConnections, getSource, (devices, equipment, source) => {
      const result = new Array<DeviceGroup>();

      if (devices) {
         const localDevices = devices

Function transportProduce has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   public async transportProduce(
      { transportId, appData, kind, ...producerOptions }: TransportProduceRequest,
      connectionId: string,
   ): Promise<SuccessOrError<TransportProduceResponse>> {
      const connection = this.connections.get(connectionId);

Method Handle has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public async Task<Unit> Handle(UpdateSubscriptionsRequest request, CancellationToken cancellationToken)
        {
            var participant = request.Participant;

            _logger.LogDebug("Update subscriptions for {participant}", participant);

Method Handle has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public async Task<Unit> Handle(TalkingStickEnqueueRequest request, CancellationToken cancellationToken)
        {
            var (participant, remove) = request;

            var rooms = await _mediator.FetchSynchronizedObject<SynchronizedRooms>(participant.ConferenceId,

Method Handle has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public async Task<SuccessOrError<Unit>> Handle(OpenBreakoutRoomsRequest request,
            CancellationToken cancellationToken)
        {
            var (_, _, _, assignedRooms, conferenceId) = request;

Method BuildCluster has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public IEnumerable<ClusterBucket<T>> BuildCluster<T, TValue>(IEnumerable<T> data, Func<T, TValue> valueSelector,
            IDistanceAlgorithm<TValue> distanceAlgorithm, double threshold)
        {
            var clusterBuckets = data.Select(x => new ClusterBucket<T>(new List<T> {x})).ToArray();
            var entriesMatrix = new double?[clusterBuckets.Length, clusterBuckets.Length];

Method DisposeAsync_ThreadSafety has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        [Fact]
        public async Task DisposeAsync_ThreadSafety()
        {
            // arrange
            var readerWriterLock = new AsyncReaderWriterLock();

Method GlobalUndo_IsAvailable_ExecuteUndo has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        [Fact]
        public async Task GlobalUndo_IsAvailable_ExecuteUndo()
        {
            // arrange
            var useCase = Create();

Method GlobalRedo_IsAvailable_ExecuteRedo has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        [Fact]
        public async Task GlobalRedo_IsAvailable_ExecuteRedo()
        {
            // arrange
            var useCase = Create();

Method BuildLoginViewModelAsync has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        private async Task<LoginViewModel> BuildLoginViewModelAsync(string returnUrl)
        {
            var context = await _interaction.GetAuthorizationContextAsync(returnUrl);
            if (context?.IdP != null && await _schemeProvider.GetSchemeAsync(context.IdP) != null)
            {

Method Send has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public async Task<SuccessOrError<TResponse>> Send()
        {
            var token = _context.Hub.Context.ConnectionAborted;

            foreach (var middleware in _middlewares)

Method PatchConferenceLink has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        [HttpPatch("{conferenceId}")]
        [Authorize]
        public async Task<ActionResult> PatchConferenceLink(string conferenceId,
            JsonPatchDocument<ChangeConferenceLinkStarDto> patch, [FromServices] IConferenceLinkRepo repo,
            [FromServices] IOptions<ConcurrencyOptions> options)

Method Handle has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        public async Task<SuccessOrError<Unit>> Handle(SetTemporaryPermissionRequest request,
            CancellationToken cancellationToken)
        {
            var (participant, permissionKey, value) = request;

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

Open

            await conn.SyncObjects.AssertSyncObject(SynchronizedWhiteboards.SyncObjId(RoomOptions.DEFAULT_ROOM_ID),
                (SynchronizedWhiteboards whiteboards) =>
                {
                    var whiteboard = whiteboards.Whiteboards[whiteboardId];
                    Assert.True(whiteboard.ParticipantStates[conn.User.Sub].CanRedo);

• Read up
  Read up

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

Open

            await conn.SyncObjects.AssertSyncObject(SynchronizedWhiteboards.SyncObjId(RoomOptions.DEFAULT_ROOM_ID),
                (SynchronizedWhiteboards whiteboards) =>
                {
                    var whiteboard = whiteboards.Whiteboards[whiteboardId];
                    Assert.True(whiteboard.ParticipantStates[conn.User.Sub].CanUndo);

• Read up
  Read up

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

Open

export const onReconnecting = createAction(`${DEFAULT_PREFIX}::ON_RECONNECTING`, (appData: any, error?: Error) => ({
   payload: { appData, error },
}));

• Read up
  Read up

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

Open

const useStyles = makeStyles((theme) => ({
   errorChip: {
      backgroundColor: theme.palette.error.main,
      color: theme.palette.error.contrastText,
   },

• Read up
  Read up

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

Open

const useStyles = makeStyles((theme) => ({
   toast: {
      backgroundColor: theme.palette.background.paper,
      color: theme.palette.text.primary,
   },

• Read up
  Read up

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

Open

export const onReconnected = createAction(`${DEFAULT_PREFIX}::ON_RECONNECTED`, (appData: any, error?: Error) => ({
   payload: { appData, error },
}));

• Read up
  Read up

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

Open

export const onConnectionClosed = createAction(
   `${DEFAULT_PREFIX}::ON_CONNECTION_CLOSED`,
   (appData?: any, error?: Error) => ({
      payload: { appData, error },
   }),

• Read up
  Read up