Method importTempFile

packages/sync/src/pull-engine.ts:194–216

(
    baseUrl: string,
    sess: ImportSession,
    tempFile: string
  )

  }

  private async importTempFile(
    baseUrl: string,
    sess: ImportSession,
    tempFile: string
  ): Promise<{
    success: boolean
    newMessageCount: number
    sessionId?: string
    error?: string
    needFullResync?: boolean
  }> {
    let targetId = sess.targetSessionId
    if (!targetId) {
      const derived = deriveLocalSessionId(baseUrl, sess.remoteSessionId)
      if (this.importer.sessionExists(derived)) {
        targetId = derived
        this.logger.info(`[Pull] Reusing existing local session ${derived} for "${sess.name}"`)
      }
    }

    const externalId = deriveLocalSessionId(baseUrl, sess.remoteSessionId)
    return this.importer.importFile(tempFile, targetId || undefined, externalId)
  }

  async executePullSession(sourceId: string, ds: DataSource, sess: ImportSession): Promise<PullSessionResult> {
    const currentDs = this.dsManager.get(sourceId)