return state;

}

async function persistState(state: DevicePairingStateFile, baseDir?: string) {

type DevicePairingPersistTarget = "pending" | "paired" | "both";

async function persistState(

state: DevicePairingStateFile,

baseDir: string | undefined,

target: DevicePairingPersistTarget,

) {

const { pendingPath, pairedPath } = resolvePairingPaths(baseDir, "devices");

if (target === "pending") {

await writeJsonAtomic(pendingPath, state.pendingById);

return;

}

if (target === "paired") {

await writeJsonAtomic(pairedPath, state.pairedByDeviceId);

return;

}

await Promise.all([

writeJsonAtomic(pendingPath, state.pendingById),

writeJsonAtomic(pairedPath, state.pairedByDeviceId),

},

});

},

persist: async () => await persistState(state, baseDir),

persist: async () => await persistState(state, baseDir, "pending"),

});

});

}

};

delete state.pendingById[requestId];

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, baseDir);

await persistState(state, baseDir, "both");

return { status: "approved", requestId, device };

});

}

};

delete state.pendingById[requestId];

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, baseDir);

await persistState(state, baseDir, "both");

return { status: "approved", requestId, device };

});

}

requestId,

idKey: "deviceId",

loadState: () => loadState(baseDir),

persistState: (state) => persistState(state, baseDir),

persistState: (state) => persistState(state, baseDir, "pending"),

getId: (pending: DevicePairingPendingRequest) => pending.deviceId,

});

});

delete state.pendingById[requestId];

}

}

await persistState(state, baseDir);

await persistState(state, baseDir, "both");

return { deviceId: normalized };

});

}

next.remoteIp = patch.remoteIp;

}

state.pairedByDeviceId[normalizedDeviceId] = next;

await persistState(state, baseDir);

await persistState(state, baseDir, "paired");

});

}

device.tokens ??= {};

device.tokens[role] = entry;

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, params.baseDir);

await persistState(state, params.baseDir, "paired");

return { ok: true };

});

}

tokens[role] = next;

device.tokens = tokens;

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, params.baseDir);

await persistState(state, params.baseDir, "paired");

return next;

});

}

tokens[role] = next;

device.tokens = tokens;

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, params.baseDir);

await persistState(state, params.baseDir, "paired");

return { ok: true, entry: next };

});

}

tokens[role] = entry;

device.tokens = tokens;

state.pairedByDeviceId[device.deviceId] = device;

await persistState(state, params.baseDir);

await persistState(state, params.baseDir, "paired");

return entry;

});

}

return false;

}

delete state.pairedByDeviceId[normalizedId];

await persistState(state, baseDir);

await persistState(state, baseDir, "paired");

return true;

});

}