#2329 : SipgateSyncService.kt

Structure du code

Annotations : param, micromata, Service, author, Autowired

Classes : SipgateSyncService

Fonctions (4) : getStorage, readStorage, readFromFileOrGetFromRemote, remoteRead

Propriétés (8) : sipgateService, privateStorage, ps, newStorage, newStorage, userDevices, devices, storageFile

Importations : 8 paquetages

Paquetage : org.projectforge.rest.sipgate

Code source (abrégé)

package org.projectforge.rest.sipgate

import mu.KotlinLogging
import org.projectforge.business.sipgate.SipgateUserDevices
import org.projectforge.framework.configuration.ConfigXml
import org.projectforge.framework.json.JsonUtils
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.stereotype.Service
import java.io.File
import kotlin.concurrent.thread

private val log = KotlinLogging.logger {}

/**
 * Lit les numéros, appareils, utilisateurs, etc. depuis le serveur Sipgate distant.
 * @author K. Reinhard (k.reinhard@micromata.de)
 */
@Service
open class SipgateSyncService {
  @Autowired
  internal lateinit var sipgateService: SipgateService

  private var privateStorage: SipgateDataStorage? = null

  /**
   * Obtient le stockage, s'il existe. Sinon, le stockage est lu depuis le serveur Sipgate distant.
   * Si le stockage existant est présent mais obsolète, le stockage obsolète est retourné, mais
   * une tâche asynchrone est lancée pour obtenir les nouvelles données de stockage.
   */
  open fun getStorage(): SipgateDataStorage {
    privateStorage?.let {
      thread(start = true) {
        readStorage() // Relecture si obsolète.
      }
      return it
    }
    return readStorage()
  }

  /**
   * Obtient les données du serveur Sipgate distant. Seront mises en cache sous forme de fichier (work/sipgateStorage.json). Les données seront
   * relues automatiquement après un jour.
   * @param Si forceSync est défini sur true, la configuration sera obtenue depuis le serveur Sipgate distant. La valeur par défaut est false.
   */
  open fun readStorage(forceSync: Boolean = false): SipgateDataStorage {
    val ps = privateStorage
    if (forceSync || ps == null || !ps.uptodate) {
      if (forceSync) {
        log.info { "La lecture de la configuration Sipgate est forcée." }
      } else if (ps == null) {
        log.info { "La configuration Sipgate n'existe pas encore.." }
      } else {
        log.info { "Configuration Sipgate obsolète." }
      }
      readFromFileOrGetFromRemote(forceSync)
    }
    return privateStorage!!
  }

  private fun readFromFileOrGetFromRemote(forceSync: Boolean = false) {
    synchronized(this) {
      try {
        if (!forceSync && storageFile.canRead()) {
          val json = storageFile.readText()
          log.info { "Lecture des données Sipgate depuis '${storageFile.absolutePath}'..." }
          val newStorage = JsonUtils.fromJson(json, SipgateDataStorage::class.java)
          if (newStorage?.uptodate == true) {
            privateStorage = newStorage
            return
          }
          log.info { "Le stockage Sipgate est obsolète (plus d'un jour), relecture..." }
        }
      } catch (ex: Exception) {
        log.error("Erreur lors de l'analyse du stockage sipgate depuis '${storageFile.absolutePath}' : ${ex.message}", ex)
      }
      remoteRead()
    }
  }

  private fun remoteRead() {
    log.info { "Lecture des données Sipgate (utilisateurs, appareils, etc.)..." }
    val newStorage = SipgateDataStorage()
    newStorage.users = sipgateService.getUsers()
    try {
      newStorage.numbers = sipgateService.getNumbers()
    } catch (ex: Exception) {
      log.error("Impossible de lire les numéros (peut-être pas d'accès) : ${ex.message}", ex)
    }
    val userDevices = mutableListOf<SipgateUserDevices>()
    newStorage.users?.forEach { user ->
      val devices = sipgateService.getDevices(user)
      if (devices.isNotEmpty()) {
        devices.forEach { it.deleteSecrets() }
        userDevices.add(SipgateUserDevices(user.id, devices))
      }
    }
    newStorage.userDevices = userDevices
    newStorage.addresses = sipgateService.getAddresses()
    privateStorage = newStorage
    log.info { "Écriture des données Sipgate vers '${storageFile.absolutePath}'..." }
    storageFile.writeText(privateStorage.toString())
  }

  companion object {
    private val storageFile by lazy {
      File(ConfigXml.getInstance().workingDirectory, "sipgateStorage.json")
    }
  }
}

Historique Git

868d6abb7 2025 -> 2026
63081666f En-têtes des fichiers source : 2024 -> 2025.
5bafe7941 @Repository -> @Service. Annotations @Transactional supprimées.
b6092df09 Copyright 2023 -> 2024
031eb26c3 WIP : appels téléphoniques pour Sipgate