Function decodePacket

pkg/agent/proxy/integrations/mysql/wire/decode.go:129–434

(ctx context.Context, logger *zap.Logger, packet mysql.Packet, clientConn net.Conn, lastOp byte, decodeCtx *DecodeContext)

}

func decodePacket(ctx context.Context, logger *zap.Logger, packet mysql.Packet, clientConn net.Conn, lastOp byte, decodeCtx *DecodeContext) (*mysql.PacketBundle, error) {
	//Get the Header & payload of the packet
	header := packet.Header
	payload := packet.Payload

	parsedPacket := &mysql.PacketBundle{
		Header: &mysql.PacketInfo{
			Header: &header,
		},
	}

	payloadType := payload[0]

	var sg *mysql.HandshakeV10Packet
	var ok bool
	// No need to find the server greetings in the map if the payload is HandshakeV10 because it is the first packet and going to be stored in the map
	if payloadType != mysql.HandshakeV10 {
		sg, ok = decodeCtx.ServerGreetings.Load(clientConn)
		if !ok {
			return parsedPacket, fmt.Errorf("server Greetings not found")
		}
	}

	logger.Debug("payload info", zap.Any("last operation", lastOp), zap.Any("payload type", payloadType))

	// Handle handshakeResponse41 separately, because its status is not defined and can be changed with the client capabilities.
	if lastOp == mysql.HandshakeV10 {
		logger.Debug("HandshakeResponse41/SSL Request packet", zap.Any("Type", payloadType))
		pkt, err := connection.DecodeHandshakeResponse(ctx, logger, payload)
		if err != nil {
			return parsedPacket, fmt.Errorf("failed to decode HandshakeResponse41 packet: %w", err)
		}

		var pktType string
		switch pkt := pkt.(type) {
		case *mysql.HandshakeResponse41Packet:
			// Store the client capabilities to use it later
			decodeCtx.ClientCapabilities = pkt.CapabilityFlags

			pktType = mysql.HandshakeResponse41
			lastOp = payloadType
		case *mysql.SSLRequestPacket:
			// Store the client capabilities to use it later
			decodeCtx.ClientCapabilities = pkt.CapabilityFlags

			pktType = mysql.SSLRequest
			decodeCtx.UseSSL = true
			logger.Debug("SSL Request packet detected")
			// Don't change the last operation if the packet is an SSL Request
		}

		setPacketInfo(ctx, parsedPacket, pkt, pktType, clientConn, lastOp, decodeCtx)

		logger.Debug("HandshakeResponse41/SSL Request decoded", zap.Any("parsed packet", parsedPacket))

		return parsedPacket, nil
	}