Реализация EventEmitter, Singleton через замыкание, Factory, и практический пример их совместного использования

// ===== EVENT EMITTER (Observer) =====
console.log('=== EventEmitter ===')

class EventEmitter {
  constructor() {
    this._events = {}
    this._onceWrappers = new WeakMap()  // для корректной отписки once
  }

  on(event, listener) {
    (this._events[event] ??= []).push(listener)
    return this
  }

  off(event, listener) {
    if (!this._events[event]) return this
    this._events[event] = this._events[event].filter(l => l !== listener)
    return this
  }

  once(event, listener) {
    const wrapper = (...args) => {
      listener(...args)
      this.off(event, wrapper)
    }
    this._onceWrappers.set(listener, wrapper)
    return this.on(event, wrapper)
  }

  emit(event, ...args) {
    const listeners = this._events[event]
    if (!listeners?.length) return false
    listeners.slice().forEach(l => l(...args))
    return true
  }

  listenerCount(event) {
    return this._events[event]?.length ?? 0
  }
}

// Пример: Store на основе EventEmitter
class Store extends EventEmitter {
  constructor(initialState) {
    super()
    this._state = initialState
  }

  getState() { return { ...this._state } }

  setState(updates) {
    const prevState = this._state
    this._state = { ...this._state, ...updates }
    this.emit('change', this._state, prevState)
  }
}

const store = new Store({ count: 0, user: null })

// Подписка на изменения
const unsubscribeLog = (newState) => {
  console.log('Изменение состояния:', newState)
}
store.on('change', unsubscribeLog)

// Подписка once — сработает только 1 раз
store.once('change', (state) => {
  console.log('Первое изменение (once):', state.count)
})

store.setState({ count: 1 })  // оба listener сработают
store.setState({ count: 2 })  // только unsubscribeLog

console.log('Listeners после двух изменений:', store.listenerCount('change'))  // 1

// ===== SINGLETON =====
console.log('\n=== Singleton ===')

const Logger = (() => {
  let instance = null
  let logCount = 0

  class LoggerClass {
    constructor(prefix) {
      if (instance) return instance  // возвращаем существующий
      this.prefix = prefix
      this.logs = []
      instance = this
    }

    log(level, message) {
      logCount++
      const entry = {
        id: logCount,
        level,
        message,
        prefix: this.prefix,
        timestamp: new Date().toISOString()
      }
      this.logs.push(entry)
      console.log(`[${this.prefix}][${level.toUpperCase()}] ${message}`)
    }

    info(msg)  { this.log('info', msg) }
    warn(msg)  { this.log('warn', msg) }
    error(msg) { this.log('error', msg) }

    getStats() {
      return {
        total: this.logs.length,
        byLevel: this.logs.reduce((acc, l) => {
          acc[l.level] = (acc[l.level] || 0) + 1
          return acc
        }, {})
      }
    }
  }

  return LoggerClass
})()

const logger1 = new Logger('APP')
const logger2 = new Logger('ДРУГОЙ')  // вернёт logger1!

logger1.info('Приложение запущено')
logger2.warn('Это пишет тот же экземпляр')
logger1.error('Ошибка подключения')

console.log('logger1 === logger2:', logger1 === logger2)  // true
console.log('Статистика:', logger1.getStats())

// ===== FACTORY =====
console.log('\n=== Factory ===')

function createNotification(type, data) {
  const base = {
    id: Math.random().toString(36).slice(2),
    createdAt: Date.now(),
    read: false,
    markRead() { this.read = true }
  }

  const templates = {
    success: {
      ...base,
      type: 'success',
      icon: 'check',
      title: data.title || 'Успешно',
      message: data.message,
      duration: data.duration || 3000
    },
    error: {
      ...base,
      type: 'error',
      icon: 'x',
      title: data.title || 'Ошибка',
      message: data.message,
      duration: data.duration || 0,  // ошибки не исчезают автоматически
      retry: data.retry || null
    },
    info: {
      ...base,
      type: 'info',
      icon: 'i',
      title: data.title || 'Информация',
      message: data.message,
      duration: data.duration || 5000
    }
  }

  if (!templates[type]) {
    throw new Error(`Неизвестный тип уведомления: ${type}`)
  }

  return templates[type]
}

const successNotification = createNotification('success', {
  message: 'Файл успешно загружен'
})
const errorNotification = createNotification('error', {
  title: 'Ошибка сети',
  message: 'Не удалось подключиться к серверу',
  retry: () => console.log('Повтор...')
})

console.log('Success:', successNotification.title, '-', successNotification.message)
console.log('Error:', errorNotification.title, '| duration:', errorNotification.duration)
console.log('Error id:', errorNotification.id)

// ===== ПАТТЕРНЫ ВМЕСТЕ: УВЕДОМЛЕНИЯ С EVENTЕМITTER =====
console.log('\n=== Объединяем: NotificationService ===')

class NotificationService extends EventEmitter {
  constructor() {
    super()
    this.notifications = []
  }

  add(type, data) {
    const notification = createNotification(type, data)
    this.notifications.push(notification)
    this.emit('added', notification)
    if (notification.duration > 0) {
      setTimeout(() => this.remove(notification.id), notification.duration)
    }
    return notification
  }

  remove(id) {
    const index = this.notifications.findIndex(n => n.id === id)
    if (index !== -1) {
      const [removed] = this.notifications.splice(index, 1)
      this.emit('removed', removed)
    }
  }

  getAll() { return [...this.notifications] }
}

// Singleton — один сервис уведомлений на всё приложение
const notificationSingleton = (() => {
  let service = null
  return {
    getInstance() {
      if (!service) service = new NotificationService()
      return service
    }
  }
})()

const ns = notificationSingleton.getInstance()
ns.on('added',   n => console.log('+ Уведомление добавлено:', n.type, '-', n.message))
ns.on('removed', n => console.log('- Уведомление удалено:', n.id))

ns.add('success', { message: 'Сохранено' })
ns.add('info',    { message: 'Новое сообщение от Алисы' })
ns.add('error',   { message: 'Ошибка загрузки' })

console.log('Всего уведомлений:', ns.getAll().length)