4nk/ihm_client
5
0
Fork 0
Code Issues 6 Pull Requests Actions Packages Projects Releases Wiki Activity

Add logs for handleCreatePairing
All checks were successful
Build and Push to Registry / build-and-push (push) Successful in 2m35s
Details

Browse Source
This commit is contained in:
NicolasCantu 2025-10-10 11:33:40 +02:00
parent 412c855777
commit 79633ed923
1 changed files with 49 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
src/router.ts
View File

@ -234,47 +234,78 @@ export async function registerAllListeners() {
if (event.data.type !== MessageType.CREATE_PAIRING) { if (event.data.type !== MessageType.CREATE_PAIRING) {
return; return;
} }
console.log("📨 [Router] Received CREATE_PAIRING request");
if (services.isPaired()) { if (services.isPaired()) {
const errorMsg = 'Device already paired'; const errorMsg = "⚠️ Device already paired — ignoring CREATE_PAIRING request";
console.warn(errorMsg);
errorResponse(errorMsg, event.origin, event.data.messageId); errorResponse(errorMsg, event.origin, event.data.messageId);
return; return;
} }
try { try {
const { accessToken } = event.data; const { accessToken } = event.data;
if (!accessToken || !(await tokenService.validateToken(accessToken, event.origin))) { console.log("🔐 Checking access token validity...");
throw new Error('Invalid or expired session token'); const validToken = accessToken && (await tokenService.validateToken(accessToken, event.origin));
if (!validToken) {
throw new Error("❌ Invalid or expired session token");
} }
console.log('🚀 Starting pairing process'); console.log("✅ Token validated successfully");
console.log("🚀 Starting pairing process");
const myAddress = services.getDeviceAddress(); const myAddress = services.getDeviceAddress();
const createPairingProcessReturn = await services.createPairingProcess('', [myAddress]); console.log("📍 Device address:", myAddress);
console.log("🧱 Creating pairing process...");
const createPairingProcessReturn = await services.createPairingProcess("", [myAddress]);
console.log("🧾 Pairing process created:", createPairingProcessReturn);
const pairingId = createPairingProcessReturn.updated_process?.process_id; const pairingId = createPairingProcessReturn.updated_process?.process_id;
const stateId = createPairingProcessReturn.updated_process?.current_process?.states[0]?.state_id as string; const stateId = createPairingProcessReturn.updated_process?.current_process?.states[0]?.state_id as string;
console.log("🔗 Pairing ID:", pairingId);
console.log("🧩 State ID:", stateId);
console.log("🔒 Registering device as paired...");
services.pairDevice(pairingId, [myAddress]); services.pairDevice(pairingId, [myAddress]);
console.log("🧠 Handling API return for createPairingProcess...");
await services.handleApiReturn(createPairingProcessReturn); await services.handleApiReturn(createPairingProcessReturn);
console.log("🧰 Creating PRD update...");
const createPrdUpdateReturn = await services.createPrdUpdate(pairingId, stateId); const createPrdUpdateReturn = await services.createPrdUpdate(pairingId, stateId);
console.log("🧾 PRD update result:", createPrdUpdateReturn);
await services.handleApiReturn(createPrdUpdateReturn); await services.handleApiReturn(createPrdUpdateReturn);
console.log("✅ Approving change...");
const approveChangeReturn = await services.approveChange(pairingId, stateId); const approveChangeReturn = await services.approveChange(pairingId, stateId);
console.log("📜 Approve change result:", approveChangeReturn);
await services.handleApiReturn(approveChangeReturn); await services.handleApiReturn(approveChangeReturn);
console.log("🔁 Confirming pairing...");
await services.confirmPairing(); await services.confirmPairing();
// Send success response console.log("🎉 Pairing successfully completed!");
// ✅ Send success response to frontend
const successMsg = { const successMsg = {
type: MessageType.PAIRING_CREATED, type: MessageType.PAIRING_CREATED,
pairingId, pairingId,
messageId: event.data.messageId messageId: event.data.messageId
}; };
console.log("📤 Sending PAIRING_CREATED message to UI:", successMsg);
window.parent.postMessage(successMsg, event.origin); window.parent.postMessage(successMsg, event.origin);
} catch (e) { } catch (e) {
const errorMsg = `Failed to create pairing process: ${e}`; const errorMsg = `❌ Failed to create pairing process: ${e}`;
console.error(errorMsg);
errorResponse(errorMsg, event.origin, event.data.messageId); errorResponse(errorMsg, event.origin, event.data.messageId);
} }
} };
const handleGetMyProcesses = async (event: MessageEvent) => { const handleGetMyProcesses = async (event: MessageEvent) => {
if (event.data.type !== MessageType.GET_MY_PROCESSES) { if (event.data.type !== MessageType.GET_MY_PROCESSES) {
@ -875,6 +906,9 @@ export async function registerAllListeners() {
case MessageType.CREATE_PROCESS: case MessageType.CREATE_PROCESS:
await handleCreateProcess(event); await handleCreateProcess(event);
break; break;
case MessageType.CREATE_CONVERSATION:
await handleCreateConversationProcess(event);
break;
case MessageType.NOTIFY_UPDATE: case MessageType.NOTIFY_UPDATE:
await handleNotifyUpdate(event); await handleNotifyUpdate(event);
break; break;