Method storeMetadata

internal/auditlog/codec/binary/encode.go:76–105

(
	msg message.Message,
	storage storage.Writer,
	startTime int64,
	ip string,
	country string,
	username *string,
)

}

func (e *encoder) storeMetadata(
	msg message.Message,
	storage storage.Writer,
	startTime int64,
	ip string,
	country string,
	username *string,
) (string, string, *string) {
	switch msg.MessageType {
	case message.TypeConnect:
		remoteAddr := msg.Payload.(message.PayloadConnect).RemoteAddr
		ip = remoteAddr
		country := e.geoIPProvider.Lookup(net.ParseIP(ip))
		storage.SetMetadata(startTime/1000000000, ip, country, username)
	case message.TypeAuthPasswordSuccessful:
		u := msg.Payload.(message.PayloadAuthPassword).Username
		username = &u
		storage.SetMetadata(startTime/1000000000, ip, country, username)
	case message.TypeAuthPubKeySuccessful:
		payload := msg.Payload.(message.PayloadAuthPubKey)
		username = &payload.Username
		storage.SetMetadata(startTime/1000000000, ip, country, username)
	case message.TypeHandshakeSuccessful:
		payload := msg.Payload.(message.PayloadHandshakeSuccessful)
		username = &payload.Username
		storage.SetMetadata(startTime/1000000000, ip, country, username)
	}

	return ip, country, username
}