a8e12dd75a
Implement proxy lifecycle ownership model distinguishing visible from health-only events based on socket role and origin; add configGeneration for FakeTLS budget state independent of activation lifecycle; introduce resume grace period masking for stale phases during app foreground transitions. Centralize proxy link parsing into ProxyLinkHelper with clipboard extraction; add clipboard proxy alert on app resume. Expand plugin infrastructure with text formatting, structured settings, Android/client utilities, and UI bridge for settings screens. Introduce EditableForwardDraft for caption editing and album/separate-post grouping modes in message forwarding. Add video frame capture feature for PhotoViewer and PeerStoriesView with gallery save support. Increase socket role tracking through proxy connection event pipeline for distinguishing control/media/background traffic in diagnostics. Update proxy check guards and runtime log verifiers to enforce lifecycle ownership boundaries and new architectural constraints.
95 lines
3.7 KiB
C++
95 lines
3.7 KiB
C++
/*
|
|
* This is the source code of tgnet library v. 1.1
|
|
* It is licensed under GNU GPL v. 2 or later.
|
|
*/
|
|
|
|
#ifndef MTPROXYPROBECOORDINATOR_H
|
|
#define MTPROXYPROBECOORDINATOR_H
|
|
|
|
#include <stdint.h>
|
|
#include <string>
|
|
#include "MtProxyAdaptivePolicy.h"
|
|
|
|
class MtProxyProbeCoordinator {
|
|
public:
|
|
enum class DecisionKind : uint8_t {
|
|
StartOwner,
|
|
JoinExisting,
|
|
UseWorkingRecipe,
|
|
ProfilesExhaustedBackoff,
|
|
HandshakeBudgetBackoff,
|
|
};
|
|
|
|
struct ProbeKey {
|
|
std::string key;
|
|
std::string endpointKey;
|
|
std::string networkEndpointKey;
|
|
uint32_t allowedSniVariants = 0;
|
|
uint32_t configGeneration = 0;
|
|
};
|
|
|
|
struct GreaseProbeResult {
|
|
bool useGrease = false;
|
|
bool probe = false;
|
|
bool supported = false;
|
|
bool rejected = false;
|
|
};
|
|
|
|
struct Decision {
|
|
DecisionKind kind = DecisionKind::StartOwner;
|
|
uint32_t generation = 0;
|
|
uint32_t waitMs = 0;
|
|
uint64_t ownerToken = 0;
|
|
MtProxyAdaptivePolicy::RecipeCursor cursor;
|
|
MtProxyAdaptivePolicy::RecipeCursor workingCursor;
|
|
MtProxyAdaptivePolicy::CompatibilityRecipe workingRecipe;
|
|
std::string lastRecipeDiagnostic;
|
|
std::string terminalPhase;
|
|
GreaseProbeResult greaseProbe;
|
|
};
|
|
|
|
struct FailureResult {
|
|
bool recorded = false;
|
|
bool recipeExhausted = false;
|
|
bool terminalBudgetExhausted = false;
|
|
uint32_t generation = 0;
|
|
uint32_t budgetAttempts = 0;
|
|
int64_t budgetElapsedMs = 0;
|
|
uint64_t responseSignature = 0;
|
|
MtProxyAdaptivePolicy::RecipeCursor cursor;
|
|
MtProxyAdaptivePolicy::RecipeCursor cachedCursor;
|
|
std::string lastRecipeDiagnostic;
|
|
std::string terminalPhase;
|
|
};
|
|
|
|
static Decision beginOrJoin(const ProbeKey &probeKey, uint64_t callerToken, int64_t now);
|
|
static FailureResult completeFailure(const ProbeKey &probeKey,
|
|
uint64_t callerToken,
|
|
const std::string &diagnostic,
|
|
uint64_t responseSignature,
|
|
bool recipeUsesGrease,
|
|
bool recipeIsGreaseProbe,
|
|
bool classicFallbackAllowed,
|
|
bool advanceRecipe,
|
|
int64_t now);
|
|
static void completeSuccess(const ProbeKey &probeKey,
|
|
uint64_t callerToken,
|
|
const char *reason,
|
|
bool recipeUsesGrease,
|
|
const MtProxyAdaptivePolicy::CompatibilityRecipe &recipe,
|
|
int64_t now);
|
|
static void completeProfilesExhausted(const ProbeKey &probeKey, uint64_t callerToken, int64_t now);
|
|
static void cancelOwner(const ProbeKey &probeKey, uint64_t token);
|
|
static void touchOwner(const ProbeKey &probeKey, uint64_t token, int64_t now);
|
|
static void reapExpired(int64_t now);
|
|
|
|
static bool failureNeedsRecipe(const std::string &diagnostic);
|
|
static bool failureCountsTowardHandshakeBudget(const std::string &diagnostic, uint64_t responseSignature);
|
|
static MtProxyAdaptivePolicy::RecipeCursor recipeCursorForProbe(const std::string &probeKey);
|
|
static MtProxyAdaptivePolicy::RecipeCursor workingRecipeCursorForProbe(const std::string &probeKey);
|
|
static MtProxyAdaptivePolicy::CompatibilityRecipe workingRecipeForProbe(const std::string &probeKey);
|
|
static std::string lastRecipeDiagnosticForProbe(const std::string &probeKey);
|
|
static GreaseProbeResult readGreaseProbeState(const std::string &probeKey);
|
|
};
|
|
|
|
#endif
|