Method handlePublicKey

ssh_server.go:144–184

(ctx ssh.Context, incomingKey ssh.PublicKey)

}

func (serv *Server) handlePublicKey(ctx ssh.Context, incomingKey ssh.PublicKey) bool {
	slog := CtxLogger(ctx).With().
		Str("remote_user", ctx.User()).
		Str("remote_addr", ctx.RemoteAddr().String()).Logger()

	remoteUser := ctx.User()

	config := serv.GetAdminConfig()

	pk := models.PublicKey{PublicKey: incomingKey}

	/*
		if strings.HasPrefix(remoteUser, settings.Options.InvitePrefix) {
			invite := remoteUser[len(settings.Options.InvitePrefix):]

			// Try to accept the invite. If this fails, bail out. Otherwise,
			// continue looking up the user as normal.
			if ok := serv.AcceptInvite(invite, models.PublicKey{incomingKey, ""}); !ok {
				return false
			}

			// If it succeeded, we actually need to pull the refreshed admin config
			// so the new user shows up.
			settings = serv.GetAdminConfig()
		}
	*/

	user, err := config.LookupUserFromKey(pk, remoteUser)
	if err != nil {
		slog.Warn().Err(err).Msg("User not found")
		return false
	}

	// Update the context with what we discovered
	CtxSetUser(ctx, user)
	CtxSetConfig(ctx, config)
	CtxSetLogger(ctx, &slog)
	CtxSetPublicKey(ctx, &pk)

	return true
}

func (serv *Server) handleSession(s ssh.Session) {
	var ctx context.Context = s.Context()