//
// Copyright © 2025 Hardcore Engineering Inc.
//
// Licensed under the Eclipse Public License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License. You may
// obtain a copy of the License at https://www.eclipse.org/legal/epl-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//
// See the License for the specific language governing permissions and
// limitations under the License.
//

import {
  MessageQueryParams,
  NotificationContextQueryOptions,
  NotificationQueryParams,
  MessageQueryOptions,
  QueryOptions
} from '@hcengineering/communication-query'
import type { PagedQueryCallback, QueryCallback } from '@hcengineering/communication-sdk-types'
import {
  type FindLabelsParams,
  type FindNotificationContextParams,
  type Label,
  type Message,
  type NotificationContext,
  type Notification,
  FindCollaboratorsParams,
  Collaborator
} from '@hcengineering/communication-types'
import { deepEqual } from 'fast-equals'
import { getLiveQueries, getOnDestroy } from './init'

class BaseQuery<P extends Record<string, any>, C extends (r: any) => void, O extends QueryOptions = QueryOptions> {
  private oldParams: P | undefined
  private oldOptions: O | undefined
  private oldCallback: C | undefined

  constructor (dontDestroy?: boolean) {
    if (dontDestroy !== true) {
      const destroyFn = getOnDestroy()
      destroyFn(() => {
        this.unsubscribe()
      })
    }
  }

  private _unsubscribe: (isUpdate: boolean) => void = () => {}

  public unsubscribe (): void {
    this._unsubscribe(false)
  }

  query (params: P, callback: C, options?: O): boolean {
    if (!this.needUpdate(params, callback, options)) {
      return false
    }
    this.doQuery(params, callback, options)
    return true
  }

  private doQuery (params: P, callback: C, options?: O): void {
    const isUpdate = this.oldParams !== undefined
    this._unsubscribe(isUpdate)
    this.oldCallback = callback
    this.oldParams = params
    this.oldOptions = options

    const { unsubscribe } = this.createQuery(params, callback, options)
    this._unsubscribe = (isUpdate) => {
      unsubscribe(isUpdate)
      this.oldCallback = undefined
      this.oldParams = undefined
      this.oldOptions = undefined
      this._unsubscribe = () => {}
    }
  }

  // eslint-disable-next-line @typescript-eslint/no-unused-vars
  createQuery (params: P, callback: C, options?: O): { unsubscribe: (isUpdate: boolean) => void } {
    return {
      unsubscribe: () => {}
    }
  }

  private needUpdate (params: P, callback: C, options?: O): boolean {
    if (!deepEqual(params, this.oldParams)) return true
    if (!deepEqual(options, this.oldOptions)) return true
    if (!deepEqual(callback.toString(), this.oldCallback?.toString())) return true
    return false
  }
}

export class MessagesQuery extends BaseQuery<MessageQueryParams, PagedQueryCallback<Message>, MessageQueryOptions> {
  override createQuery (
    params: MessageQueryParams,
    callback: PagedQueryCallback<Message>,
    options?: MessageQueryOptions
  ): { unsubscribe: (isUpdate: boolean) => void } {
    return getLiveQueries().queryMessages(params, callback, options)
  }
}

export class NotificationsQuery extends BaseQuery<NotificationQueryParams, PagedQueryCallback<Notification>> {
  override createQuery (
    params: NotificationQueryParams,
    callback: PagedQueryCallback<Notification>
  ): {
      unsubscribe: (isUpdate: boolean) => void
    } {
    return getLiveQueries().queryNotifications(params, callback)
  }
}

export class NotificationContextsQuery extends BaseQuery<
FindNotificationContextParams,
PagedQueryCallback<NotificationContext>,
NotificationContextQueryOptions
> {
  override createQuery (
    params: FindNotificationContextParams,
    callback: PagedQueryCallback<NotificationContext>,
    options?: NotificationContextQueryOptions
  ): {
      unsubscribe: (isUpdate: boolean) => void
    } {
    return getLiveQueries().queryNotificationContexts(params, callback, options)
  }
}

export class LabelsQuery extends BaseQuery<FindLabelsParams, QueryCallback<Label>> {
  override createQuery (
    params: FindLabelsParams,
    callback: QueryCallback<Label>
  ): {
      unsubscribe: (isUpdate: boolean) => void
    } {
    return getLiveQueries().queryLabels(params, callback)
  }
}

export class CollaboratorsQuery extends BaseQuery<FindCollaboratorsParams, QueryCallback<Collaborator>> {
  override createQuery (
    params: FindCollaboratorsParams,
    callback: QueryCallback<Collaborator>
  ): {
      unsubscribe: (isUpdate: boolean) => void
    } {
    return getLiveQueries().queryCollaborators(params, callback)
  }
}