import { StreamEvent } from '@/types/events';
import { Paginated, PaginationOptions } from '@/types/pagination';

/// StreamRef is the simplified stream info.
/// Full stream info shall be obtained from chain data. StreamRef is a brief for immutable stream
/// config info.
export interface StreamRef {
  groupId: string;
  streamId: string;
  sender: string;
  recipient: string;
  coinType: string;
  createDate: string;
}

/// IBackend interface for supporting Stream registry query and history events.
export interface IBackend {
  getStreamGroupByGroupId(groupId: string): Promise<{
    groupId: string;
    streamIds: string[];
  }>;
  getIncomingStreams(recipient: string, options?: BackendIncomingStreamFilterOptions): Promise<StreamRef[]>;
  getOutgoingStreams(sender: string, options?: BackendOutgoingStreamFilterOptions): Promise<StreamRef[]>;
  getAllCoinTypes(address: string): Promise<string[]>;
  getAllRecipients(sender: string, options?: StreamFilterStatus): Promise<string[]>;
  getAllSenders(recipient: string, options?: StreamFilterStatus): Promise<string[]>;

  getStreamHistory(query: {
    streamId?: string;
    groupId?: string;
    pagination?: PaginationOptions;
  }): Promise<Paginated<StreamEvent>>;
}

//   streaming: !canceled && streamed != 100
//   streamed: !canceled && streamed === 100 && claimable !== 0
//   canceled: canceled && claimable !== 0

//   completed: !canceled && streamed === 100 && claimable === 0
//   settled: canceled && claimable === 0

// StreamFilterStatus only applies for active / inactive status.
// SDK will do the filtering for streams.
// active - 'streamed', 'canceled', 'streaming' - RawStatus.status === OPEN | CANCELED
// inactive - 'settled', 'completed' === COMPLETED | CANCELED_COMPLETED
export type StreamFilterStatus = 'active' | 'inactive' | 'all';

/// BackendIncomingStreamFilterOptions Options for querying Incoming StreamRefs from backend.
/// Note that the pagination is currently not supported since the stream number
/// to displayed on frontend requires more complicated computation.
/// Shall add later.
export interface BackendIncomingStreamFilterOptions {
  status?: StreamFilterStatus;

  // One or more coin types
  coinType?: string | string[];

  sender?: string | string[];
}

/// BackedOutgoingStreamFilterOptions Options for querying Outgoing StreamRefs from backend.
export interface BackendOutgoingStreamFilterOptions {
  status?: StreamFilterStatus;

  coinType?: string | string[];

  recipient?: string | string[];
}

export type StreamEventDto = {
  streamId: string;
  createdAt: Date;
  sender: string;
  txDigest: string;
  data: StreamEventDataDto;
};

export type StreamEventDataDto =
  | CreateStreamEventDataDto
  | CancelStreamEventDataDto
  | ClaimEventDataDto
  | AutoClaimEventDataDto
  | SetAutoClaimEventDataDto;

export interface CreateStreamEventDataDto {
  type: 'create_stream';
  coinType: string;
  balance: string;
}

export interface CancelStreamEventDataDto {
  type: 'cancel_stream';
  coinType: string;
  withdrawAmount: string;
}

export interface ClaimEventDataDto {
  type: 'claim';
  coinType: string;
  claimAmount: string;
}

export interface AutoClaimEventDataDto {
  type: 'auto_claim';
  coinType: string;
  claimAmount: string;
}

export interface SetAutoClaimEventDataDto {
  type: 'set_auto_claim';
  enabled: boolean;
}