proxy

type Broker struct {
	// contains filtered or unexported fields
}

type Deps struct {
	Store   *store.Store
	Records *record.Store
	/*
	 * RecordMinFree, altına inildiğinde YENİ oturumun reddedildiği boş
	 * alan. 0 kapalı. Gerekçesi Open'daki kullanım yerinde.
	 */
	RecordMinFree uint64
	Authority     *ca.CA
	Logger        *slog.Logger
	RecordInput   bool

	// Requests, oturum kanalı request'lerinin süzgeci (requests.go).
	// Sıfır değeri kullanılabilir: env whitelist'i varsayılana düşer,
	// tip listeleri zaten sabit.
	Requests RequestPolicy

	// IdleTimeout, iki yönde de bayt akmayan oturumun kapatılma süresi.
	// 0 = kapalı (bkz. config.SessionConfig.IdleTimeout).
	IdleTimeout time.Duration

	// MaxLifetime, oturumun mutlak ömrü. 0 = kapalı.
	MaxLifetime time.Duration

	// Probe, hedefte KOMUT ÇALIŞTIRARAK tanıma. Sıfır değeri KAPALI —
	// yani bu oturum yolu hedefte kullanıcının oturumu dışında bir şey
	// çalıştırmaz. (Panelin yönetim bağlantısı ayrı bir yol ve ayrı bir
	// ayar: config.ManageConfig.)
	Probe ProbePolicy

	/*
	 * FreshenRoles, oturum AÇILIRKEN kullanıcının rollerini aktif kimlik
	 * kaynağından tazeler. nil ise tazeleme yapılmaz.
	 *
	 * ⚠️ NEDEN BURADA: iki kapı (SSH kanalı ve web terminali) tek
	 * fonksiyondan geçiyor, yani kural ikisine birden uygulanıyor —
	 * "iki kapı, tek gerçek". Kimlik doğrulama geri çağrısında değil,
	 * çünkü orası el sıkışmanın içi: bir handshake'te birden çok kez
	 * çağrılıyor ve orada ağ isteği yapmak, kimliği doğrulanmamış bir
	 * bağlantıyı dizine karşı bir yükseltici hâline getirirdi.
	 *
	 * ErrDirectoryRefused dönerse oturum REDDEDİLİR; başka bir hata
	 * yalnızca loglanır ve saklanan rollerle devam edilir (dizin arızası
	 * yetki yokluğu değildir).
	 */
	FreshenRoles func(ctx context.Context, username string) error

	// Events, canlı izleme akışı. nil ise olay yayınlanmaz.
	//
	// ⚠️ Publish BLOKLAMAZ (bkz. events.Bus): burası bir oturumun açılış
	// ve kapanış yolu ve izleyen bir panel, izlediği oturumu
	// bekletemez.
	Events events.Publisher

	// Live, akan oturumların defteri: yöneticinin kesme düğmesi buradan
	// çalışıyor. nil olabilir — o zaman kayıt tutulmuyor ve hiçbir
	// oturum kesilemiyor (Live'ın bütün metotları nil-güvenli).
	Live *Live
}

type ExecRequest struct {
	Command string
}

type Live struct {
	// contains filtered or unexported fields
}

type OwnWriter interface {
	WriteOwn(p []byte) (int, error)
	WriteOwnStderr(p []byte) (int, error)
}

type ProbePolicy struct {
	Enabled bool
	Refresh time.Duration
	Timeout time.Duration
}

type PtyRequest struct {
	Term          string
	Columns, Rows uint32
	Width, Height uint32 // piksel cinsinden; genelde 0
	Modes         string // opaque terminal modes — parse etme, olduğu gibi ilet (Ek C.4)
}

type Request struct {
	// Username, DOĞRULANMIŞ postern kullanıcı adıdır — istemcinin iddia
	// ettiği değil. SSH tarafında Permissions'tan, web tarafında oturum
	// kaydından gelir; ikisi de kimliği kendi kapısında doğrulamış olur.
	Username string

	/*
	 * AccountID, bağlantının bağlı olduğu users.id.
	 *
	 * ⚠️ AD DEĞİL KİMLİK, VE BOŞ GEÇİLEMİYOR. Ad yeniden
	 * kullanılabiliyor (purge onu serbest bırakıyor), kimlik kalıcı.
	 * Bunu kapıda çözüp buraya taşımak, kanal açılırken "bu bağlantı
	 * HÂLÂ o kişiye mi ait" sorusunun sorulabilmesinin tek yolu.
	 */
	AccountID string

	TargetName string
	SrcIP      string
}

type RequestPolicy struct {
	// AcceptEnv, geçmesine izin verilen ortam değişkeni adları.
	// Sondaki * joker: "LC_*" tüm LC_ ile başlayanları kapsar.
	//
	// nil = varsayılan (defaultAcceptEnv). BOŞ DİLİM = hiçbiri; ikisi
	// farklı şeyler ve YAML bu ikisini ayırt edebiliyor.
	AcceptEnv []string

	/*
	 * AllowSFTP, `subsystem sftp` kanalını açar.
	 *
	 * ⚠️ VARSAYILAN KAPALI ve öyle kalmalı. Açık geldiğinde, yükseltme
	 * yapan bir operatör hiçbir şey yapmadan yeni bir veri çıkış yolu
	 * kazanmış olurdu — üstelik farkında olmadan.
	 *
	 * Açıkken bile SFTP yalnızca dosya olayları denetlenerek geçiyor
	 * (sftp.go). Denetim kurulamıyorsa kanal AÇILMIYOR: bu bayrağın
	 * anlamı "sftp serbest" değil, "denetimli sftp serbest".
	 */
	AllowSFTP bool
}

type SFTPSink interface {
	Emit(sftpaudit.Event)
}

type Session struct {
	// ID, denetim satırının ve .cast dosyasının ortak anahtarı.
	ID string

	// OSUser, policy'nin verdiği karar — çağıran log'a yazsın diye açık.
	OSUser string

	// Log, oturumun alanları bağlanmış logger'ı (user, target, session_id,
	// record_path). Çağıran kendi olaylarını bununla yazsın ki satırlar
	// aynı oturumda birleşsin.
	Log *slog.Logger
	// contains filtered or unexported fields
}

type SubsystemRequest struct {
	Name string
}

type WindowChangeRequest struct {
	Columns, Rows uint32
	Width, Height uint32
}