synchroapi

type Config struct {
	// DB is the database connection pool (required). Must be connected to a
	// PostgreSQL database with the synchro_pg extension installed.
	DB *sql.DB

	// UserIDResolver resolves the canonical internal user ID from a trusted
	// upstream-authenticated request. Mutually exclusive with JWTSecret and
	// JWKSURL.
	UserIDResolver UserIDResolver

	// JWTSecret is the HS256 shared secret for token validation.
	// Mutually exclusive with JWKSURL and UserIDResolver.
	JWTSecret []byte

	// JWKSURL is the RS256/ES256 JWKS endpoint for token validation.
	// Mutually exclusive with JWTSecret and UserIDResolver.
	JWKSURL string

	// JWKSContext controls the JWKS refresh lifecycle. It is required when
	// JWKSURL is set. Cancel it when the handler is no longer in use.
	JWKSContext context.Context

	// JWTUserClaim is the JWT claim containing the user ID (default: "sub").
	JWTUserClaim string

	// MinClientVersion is the minimum client version allowed (semver).
	// When set, authenticated sync requests must send exactly one
	// X-Client-Version or X-App-Version header at or above this version.
	// Leave empty to skip version checking.
	MinClientVersion string

	// DatabaseQueryTimeout bounds one canonical extension call. A zero value uses
	// DefaultDatabaseQueryTimeout. A negative value is invalid.
	DatabaseQueryTimeout time.Duration
}

type ConnectRequest struct {
	ClientID string `json:"client_id"`
}

type ExtensionContractInfo struct {
	ExtensionVersion          string `json:"extension_version"`
	SQLContractVersion        int    `json:"sql_contract_version"`
	ProtocolVersion           int    `json:"protocol_version"`
	LibraryBuildFingerprint   string `json:"library_build_fingerprint"`
	InstalledBuildFingerprint string `json:"installed_build_fingerprint"`
	ExtensionObjectsCurrent   bool   `json:"extension_objects_current"`
}

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

type PullRequest struct {
	ClientID string `json:"client_id"`
}

type PushRequest struct {
	ClientID string `json:"client_id"`
}

type RebuildRequest struct {
	ClientID string `json:"client_id"`
	Scope    string `json:"scope"`
}

type UserIDResolver func(*http.Request) (string, error)