ESP32 регистрация и архив тестового удаления PDA

This commit is contained in:
AidarKC
2026-06-23 20:31:05 +04:00
parent d2f45ff67a
commit 23e61cc182
3 changed files with 91 additions and 18 deletions
@@ -2206,20 +2206,20 @@ static std::vector<uint8_t> buildEd25519InstructionData(const uint8_t signature[
}
static bool getLatestBlockhashBytes(uint8_t out[32], String &blockhashB58, String &messageOut) {
String payload;
if (!rpcCallSolana("getLatestBlockhash", "[{\"commitment\":\"confirmed\"}]", payload)) {
messageOut = "RPC did not return blockhash";
return false;
for (int attempt = 0; attempt < 3; ++attempt) {
String payload;
if (rpcCallSolana("getLatestBlockhash", "[{\"commitment\":\"confirmed\"}]", payload)
&& jsonStringField(payload, "blockhash", blockhashB58)
&& !blockhashB58.isEmpty()
&& base58ToFixed32(blockhashB58, out)) {
return true;
}
if (attempt < 2) {
delay(120);
}
}
if (!jsonStringField(payload, "blockhash", blockhashB58) || blockhashB58.isEmpty()) {
messageOut = "Blockhash missing in response";
return false;
}
if (!base58ToFixed32(blockhashB58, out)) {
messageOut = "Invalid blockhash";
return false;
}
return true;
messageOut = "RPC did not return blockhash";
return false;
}
static bool pdaAlreadyExists(const String &login, String &pdaAddress, String &messageOut) {
@@ -3215,6 +3215,10 @@ static bool updateHomeserverSessionOnSolana(bool requireExisting, String &messag
}
diagDetails += String("wifi=connected:") + WiFi.localIP().toString() + "\n";
Serial.println("HOMESERVER_UPDATE_WIFI_OK");
if (gShineAuthenticated || gShineWs.connected) {
Serial.println("HOMESERVER_UPDATE_CLOSE_SHINE_SESSION");
clearShineSessionState(false);
}
ShinePdaUserState currentState;
String stateError;
@@ -3224,6 +3228,7 @@ static bool updateHomeserverSessionOnSolana(bool requireExisting, String &messag
usedCachedPda = true;
diagDetails += "read_pda_source=cache\n";
} else {
Serial.println("HOMESERVER_UPDATE_READ_PDA_CALL");
if (!readShineUserPda(cleanLogin, currentState, stateError)) {
diagDetails += String("read_pda_error=") + stateError + "\n";
return failWithDiag(stateError.isEmpty() ? "Failed to read user PDA" : stateError);
@@ -3715,6 +3720,7 @@ static bool readShineUserPda(const String &login, ShinePdaUserState &outState, S
}
String pdaB58 = base58From32(userPda);
Serial.println(String("READ_PDA_RPC_START: ") + pdaB58);
int code = -1;
String payload;
String req = "{\"jsonrpc\":\"2.0\",\"id\":1,\"method\":\"getAccountInfo\",\"params\":[\"" + pdaB58 + "\",{\"encoding\":\"base64\",\"commitment\":\"confirmed\"}]}";
@@ -3722,6 +3728,7 @@ static bool readShineUserPda(const String &login, ShinePdaUserState &outState, S
errorOut = "Solana RPC unavailable";
return false;
}
Serial.println(String("READ_PDA_RPC_DONE_CODE: ") + String(code));
if (payload.indexOf("\"value\":null") >= 0) {
outState.found = false;
return true;
@@ -3777,6 +3784,10 @@ static void refreshAccountPdaStatus() {
return;
}
gCachedAccountPdaState = pdaState;
gCachedAccountPdaLogin = normalizeLoginValue(gLoginValue);
gCachedAccountPdaValid = true;
uint8_t recoveryPub[32] = {};
uint8_t rootPub[32] = {};
uint8_t clientPub[32] = {};
@@ -3845,9 +3856,6 @@ static void refreshAccountPdaStatus() {
return;
}
gCachedAccountPdaState = pdaState;
gCachedAccountPdaLogin = normalizeLoginValue(gLoginValue);
gCachedAccountPdaValid = true;
gAccountPdaStatus = ACCOUNT_PDA_OK;
gAccountPdaStatusMessage = "ok";
}
@@ -5691,24 +5699,30 @@ static void actionButtonCb(lv_event_t *event) {
showScreen(SCREEN_HOMESERVER_PDA_CONFIRM);
break;
case ACTION_HOMESERVER_PDA_ADD_EXECUTE: {
Serial.println("HOMESERVER_ADD_BUTTON_CLICK");
gRegisterTriggerSource = "manual-homeserver-add";
String updateMessage;
Serial.println("HOMESERVER_ADD_CALL_BEGIN");
if (!updateHomeserverSessionOnSolana(false, updateMessage)) {
gHomeserverPdaResultSuccess = false;
gHomeserverPdaResultMessage = updateMessage;
gHomeserverPdaResultDetails = "";
}
Serial.println(String("HOMESERVER_ADD_CALL_END: ") + updateMessage);
showScreen(SCREEN_HOMESERVER_PDA_RESULT);
break;
}
case ACTION_HOMESERVER_PDA_FIX_EXECUTE: {
Serial.println("HOMESERVER_FIX_BUTTON_CLICK");
gRegisterTriggerSource = "manual-homeserver-fix";
String updateMessage;
Serial.println("HOMESERVER_FIX_CALL_BEGIN");
if (!updateHomeserverSessionOnSolana(true, updateMessage)) {
gHomeserverPdaResultSuccess = false;
gHomeserverPdaResultMessage = updateMessage;
gHomeserverPdaResultDetails = "";
}
Serial.println(String("HOMESERVER_FIX_CALL_END: ") + updateMessage);
showScreen(SCREEN_HOMESERVER_PDA_RESULT);
break;
}