Method executeChunks

internal/bridge/module_download.go:176–209

(ctx ModuleContext, sessionID string, taskID uint32, shellTool string, sess *sessions.Session, chunks []sessions.DownloadChunk, ch <-chan *sessions.CommandResult)

}

func (m *DownloadModule) executeChunks(ctx ModuleContext, sessionID string, taskID uint32, shellTool string, sess *sessions.Session, chunks []sessions.DownloadChunk, ch <-chan *sessions.CommandResult) {
	var assembled []byte

	for i, chunk := range chunks {
		args := sessions.BuildCommandArguments(sess, shellTool, chunk.Command)
		if _, ok := enqueueToolAction(ctx, sessionID, taskID, shellTool, args); !ok {
			return
		}
		log.Infof("[bridge] enqueued download chunk %d/%d for session %s", i+1, len(chunks), sessionID)

		// Wait for chunk result.
		result, ok := awaitTaskResult(ch, taskID)
		if !ok {
			log.Errorf("[bridge] download chunk %d/%d failed for session %s", i+1, len(chunks), sessionID)
			ctx.Tasks.Fail(sessionID, taskID, "chunk failed")
			return
		}

		decoded, err := sessions.DecodeBase64Output(result.Output)
		if err != nil {
			log.Errorf("[bridge] failed to decode download chunk %d/%d for session %s: %v", i+1, len(chunks), sessionID, err)
			ctx.Tasks.Fail(sessionID, taskID, "decode failed")
			return
		}

		assembled = append(assembled, decoded...)
		log.Infof("[bridge] download chunk %d/%d decoded: %d bytes (total: %d) for session %s",
			i+1, len(chunks), len(decoded), len(assembled), sessionID)
	}

	log.Infof("[bridge] all %d download chunks assembled: %d bytes for session %s", len(chunks), len(assembled), sessionID)
	sendDownloadResp(ctx, sessionID, taskID, assembled)
	ctx.Tasks.Complete(sessionID, taskID)
}

// sendDownloadResp sends a DownloadResponse via ModuleContext.
func sendDownloadResp(ctx ModuleContext, sessionID string, taskID uint32, content []byte) {