Anapher/Strive

Method WaitForEventInternal has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        private async Task WaitForEventInternal(Func<bool> testCondition, TimeSpan timeout)
        {
            var timeoutTimestamp = DateTimeOffset.UtcNow.Add(timeout);
            var autoResetEvent = new AsyncAutoResetEvent(false);

Method RemoveParticipant has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        private async Task RemoveParticipant(Participant participant, string? connectionId,
            CancellationToken cancellationToken)
        {
            _logger.LogDebug("RemoveParticipant() | {participant}, connectionId:{connectionId}", participant,
                connectionId);

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

Open

         <Box mt={4}>
            <ErrorWrapper
               failed={webrtcState !== 'connected'}
               error={t('conference.settings.webrtc_not_connected_error')}
            >

• Read up
  Read up

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

Open

         <Box mt={4}>
            <ErrorWrapper
               failed={webrtcState !== 'connected'}
               error={t('conference.settings.webrtc_not_connected_error')}
            >

• Read up
  Read up

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

Open

   if (health.connection.sendTransport.transportState !== 'connected') {
      return t(`${webRtcNamespace}.transport_${health.connection.sendTransport.transportState}.message`, {
         transport: 'send-transport',
      });
   }

• Read up
  Read up

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

Open

   if (health.connection.receiveTransport.transportState !== 'connected') {
      return t(`${webRtcNamespace}.transport_${health.connection.receiveTransport.transportState}.message`, {
         transport: 'receive-transport',
      });
   }

• Read up
  Read up

Function ChatBar has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default function ChatBar() {
   const classes = useStyles();
   const participants = useSelector(selectParticipantList);
   const connected = useSelector((state: RootState) => state.signalr.isConnected);
   const channels = useSelector(selectChannels);

Function getChannel has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   public async getChannel(): Promise<RabbitChannel> {
      if (this.cachedChannel) return this.cachedChannel;

      try {
         this.cachedChannel = await retry(

Function changeStream has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   public async changeStream({ id, type, action }: ChangeStreamRequest, connectionId: string): Promise<SuccessOrError> {
      const connection = this.connections.get(connectionId);
      if (!connection) {
         return { success: false, error: errors.connectionNotFound(connectionId) };
      }

Function MainRoute has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default function MainRoute() {
   const classes = useStyles();
   const dispatch = useDispatch();
   const { t } = useTranslation();

Function MultipleChoiceInstructionForm has 33 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export default function MultipleChoiceInstructionForm(props: InstructionFormProps) {
   const { t } = useTranslation();
   const {
      form: {
         register,

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

Open

        [Fact]
        public void CreatePatch_ValueChanged_CallPatchValue()
        {
            // arrange
            var original = JToken.FromObject(new TestObj {Value = 5});

• Read up
  Read up

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

Open

        [Fact]
        public void CreatePatch_PropertyNull_CallPatchValueSetNull()
        {
            // arrange
            var original = JToken.FromObject(new TestObj2 {Value = "hello"});

• Read up
  Read up

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

Open

        [Fact]
        public void CreatePatch_PropertyWasNull_CallPatchValue()
        {
            // arrange
            var original = JToken.FromObject(new TestObj2 {Value = null});

• Read up
  Read up

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

Open

            {connection.receiveTransport.transportState === 'new' &&
               connection.sendTransport.transportState === 'new' && (
                  <Typography>{t(`${webRtcNamespace}.transport_new.desc`)}</Typography>
               )}

• Read up
  Read up

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

Open

            {connection.receiveTransport.transportState === 'connecting' &&
               connection.sendTransport.transportState === 'connecting' && (
                  <Typography>{t(`${webRtcNamespace}.transport_connecting.desc`)}</Typography>
               )}

• Read up
  Read up

Function updateParticipant has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

   public async updateParticipant(participant: Participant): Promise<void> {
      await this.lock.acquire(participant.participantId, async () => {
         // loopback is independent from the room
         await this.loopbackManager.updateParticipant(participant);

Function useWebRtcConnectionHealth has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function useWebRtcConnectionHealth(): SfuConnectionHealth | undefined {
   const connection = useWebRtc();
   const [health, setHealth] = useState<SfuConnectionHealth | undefined>();

   useEffect(() => {

Method Aggregate_CaseInsensitive_BuildCloud has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        [Fact]
        public async Task Aggregate_CaseInsensitive_BuildCloud()
        {
            // arrange
            var aggregator = new TagCloudAggregator();

Function synchronizeObjectState has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function synchronizeObjectState<TS = any>(
   requests: SynchronizeProperty | SynchronizeProperty[],
   syncObjDeletedCallback?: (state: TS, syncObjId: string) => void,
) {
   if (!Array.isArray(requests)) {