#2329: SipgateSyncService.kt

Codestruktur

Annotationen: param, micromata, Service, author, Autowired

Klassen: SipgateSyncService

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

Eigenschaften (8): sipgateService, privateStorage, ps, newStorage, newStorage, userDevices, devices, storageFile

Importe: 8 Pakete

Paket: org.projectforge.rest.sipgate

Quellcode (gekürzt)

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 {}

/**
 * Liest Nummern, Geräte, Benutzer usw. vom entfernten Sipgate-Server.
 * @author K. Reinhard (k.reinhard@micromata.de)
 */
@Service
open class SipgateSyncService {
  @Autowired
  internal lateinit var sipgateService: SipgateService

  private var privateStorage: SipgateDataStorage? = null

  /**
   * Ruft den Speicher ab, falls vorhanden. Falls nicht, wird der Speicher vom entfernten Sipgate-Server gelesen.
   * Falls der vorhandene Speicher veraltet ist, wird der veraltete Speicher zurückgegeben, aber
   * ein asynchroner Job zum Abrufen neuer Speicherdaten gestartet.
   */
  open fun getStorage(): SipgateDataStorage {
    privateStorage?.let {
      thread(start = true) {
        readStorage() // Erneut lesen, falls veraltet.
      }
      return it
    }
    return readStorage()
  }

  /**
   * Ruft die Daten des entfernten Sipgate-Servers ab. Wird als Datei zwischengespeichert (work/sipgateStorage.json). Die Daten werden
   * nach einem Tag automatisch erneut gelesen.
   * @param forceSync Wenn auf true gesetzt, wird die Konfiguration vom entfernten Sipgate-Server abgerufen. Standard ist false.
   */
  open fun readStorage(forceSync: Boolean = false): SipgateDataStorage {
    val ps = privateStorage
    if (forceSync || ps == null || !ps.uptodate) {
      if (forceSync) {
        log.info { "Sipgate-Konfiguration wird erzwungen gelesen." }
      } else if (ps == null) {
        log.info { "Sipgate-Konfiguration existiert noch nicht.." }
      } else {
        log.info { "Sipgate-Konfiguration veraltet." }
      }
      readFromFileOrGetFromRemote(forceSync)
    }
    return privateStorage!!
  }

  private fun readFromFileOrGetFromRemote(forceSync: Boolean = false) {
    synchronized(this) {
      try {
        if (!forceSync && storageFile.canRead()) {
          val json = storageFile.readText()
          log.info { "Lese Sipgate-Daten von '${storageFile.absolutePath}'..." }
          val newStorage = JsonUtils.fromJson(json, SipgateDataStorage::class.java)
          if (newStorage?.uptodate == true) {
            privateStorage = newStorage
            return
          }
          log.info { "Sipgate-Speicher ist veraltet (älter als ein Tag), erneutes Lesen..." }
        }
      } catch (ex: Exception) {
        log.error("Fehler beim Parsen des Sipgate-Speichers von '${storageFile.absolutePath}': ${ex.message}", ex)
      }
      remoteRead()
    }
  }

  private fun remoteRead() {
    log.info { "Lese Sipgate-Daten (Benutzer, Geräte usw.)..." }
    val newStorage = SipgateDataStorage()
    newStorage.users = sipgateService.getUsers()
    try {
      newStorage.numbers = sipgateService.getNumbers()
    } catch (ex: Exception) {
      log.error("Nummern können nicht gelesen werden (möglicherweise kein Zugriff): ${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 { "Schreibe Sipgate-Daten nach '${storageFile.absolutePath}'..." }
    storageFile.writeText(privateStorage.toString())
  }

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

Git-Verlauf

868d6abb7 2025 -> 2026
63081666f Quellcode-Dateiköpfe: 2024 -> 2025.
5bafe7941 @Repository -> @Service. @Transactional-Annotationen entfernt.
b6092df09 Copyright 2023 -> 2024
031eb26c3 WIP: Telefonanrufe für Sipgate