/*
 * Copyright 2018 Dialog LLC <info@dlg.im>
 */

import Long from 'long';
import { google } from '@dlghq/dialog-api';

interface ProtoValue<T> {
  value?: null | T;
}

export function getOpt<T, R>(
  value: undefined | null | ProtoValue<T>,
  defaultValue: R,
) {
  return value ? (value.value ? value.value : defaultValue) : defaultValue;
}

export function mapOpt<T, R>(
  value: undefined | null | ProtoValue<T>,
  mapper: (value: T) => R,
  defaultValue: R,
) {
  return value
    ? value.value
      ? mapper(value.value)
      : defaultValue
    : defaultValue;
}

export function dateFromLong(time?: Long): Date {
  if (!time) {
    return new Date(0);
  }

  return new Date(parseInt(time.toString(), 10));
}

export function dateFromTimestamp(ts?: google.protobuf.Timestamp | null): Date {
  if (!ts || !ts.seconds || !ts.nanos) {
    return new Date(0);
  }
  const secondsMs = parseInt(ts.seconds.toString(), 10) * 1000;
  const nanosMs = ts.nanos / 1e6;

  return new Date(secondsMs + nanosMs);
}

export function longFromDate(date?: Date | null): Long {
  if (!date) {
    return Long.ZERO;
  }

  return Long.fromNumber(date.getTime());
}

export function sleep(ms: number) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

export function TryCatchWrapper(
  target: any,
  propertyKey: string,
  descriptor: any,
) {
  const fn = descriptor.value!;
  descriptor.value = async function DescriptorValue(...args: any[]) {
    let retries = 0;
    while (this.retryOptions) {
      try {
        return await fn.apply(this, args);
      } catch (error) {
        if (retries <= this.retryOptions.maxRetries) {
          console.log(error);
          let delay = Math.min(
            this.retryOptions.minDelay *
              Math.pow(this.retryOptions.delayFactor, retries),
            this.retryOptions.maxDelay,
          );
          console.log(delay);
          await sleep(delay * 1000);
        }
        if (retries == this.retryOptions.maxRetries) {
          console.log('Max retries exceeded.');
          throw error;
        }
        retries++;
      }
    }
    return await fn.apply(this, args);
  };
  return descriptor;
}