Method Decode

decoder/stream/irc/irc_data.go:67–134

Decode extracts file from IRC DCC DATA channel

()

// Decode extracts file from IRC DCC DATA channel
func (i *ircDCCDataReader) Decode() {
	// Check if this connection matches a tracked DCC connection
	keys := []string{
		fmt.Sprintf("%s:%d", i.conversation.ServerIP, i.conversation.ServerPort),
		fmt.Sprintf("%s:%d", i.conversation.ClientIP, i.conversation.ClientPort),
	}

	var connInfo *IRCDCCConnection
	var found bool
	var matchedKey string

	for _, key := range keys {
		connInfo, found = CheckDCCConnection(key)
		if found {
			matchedKey = key
			break
		}
	}

	if !found {
		// Not a tracked DCC connection
		return
	}

	ircLog.Info("Processing IRC DCC DATA channel",
		zap.String("filename", connInfo.Filename),
		zap.String("type", connInfo.Type),
		zap.Int64("expectedSize", connInfo.Filesize),
		zap.String("ident", i.conversation.Ident),
	)

	// DCC SEND: sender connects to receiver
	// Data flows from sender (collect all data, typically from one direction)
	var fileData []byte

	// Extract all data from the connection
	// DCC transfers are typically unidirectional
	for _, fragment := range i.conversation.Data {
		fileData = append(fileData, fragment.Raw()...)
	}

	if len(fileData) == 0 {
		ircLog.Warn("No data in IRC DCC channel",
			zap.String("ident", i.conversation.Ident),
		)
		RemoveDCCConnection(matchedKey)
		return
	}

	ircLog.Info("Extracting IRC DCC file",
		zap.String("filename", connInfo.Filename),
		zap.Int("dataSize", len(fileData)),
		zap.Int64("expectedSize", connInfo.Filesize),
		zap.String("ident", i.conversation.Ident),
	)

	// Extract file
	err := ExtractDCCDataChannel(i.conversation, fileData, connInfo)