(tempFile: string, externalId: string)
| 140 | } |
| 141 | |
| 142 | private async fullImportFile(tempFile: string, externalId: string): Promise<ImportResult> { |
| 143 | this.logger.info(`[Pull] First import via streamImport (externalId=${externalId})`) |
| 144 | const result = await worker.streamImport(tempFile, undefined, undefined, externalId) |
| 145 | if (result.success) { |
| 146 | const msgCount = result.diagnostics?.messagesWritten ?? 0 |
| 147 | this.logger.info(`[Pull] streamImport OK: session=${result.sessionId}, messages=${msgCount}`) |
| 148 | return { success: true, newMessageCount: msgCount, sessionId: result.sessionId } |
| 149 | } |
| 150 | this.logger.error(`[Pull] streamImport failed: ${result.error}`) |
| 151 | return { success: false, newMessageCount: 0, error: result.error } |
| 152 | } |
| 153 | } |
| 154 | |
| 155 | // ==================== BrowserWindowNotifier ==================== |
no test coverage detected