107 lines
3.1 KiB
JavaScript
107 lines
3.1 KiB
JavaScript
/**
|
|
* GitHub OAuth Bridge (main process)
|
|
*
|
|
* Renderer fetches to `github.com/login/*` are blocked by CORS.
|
|
* This bridge proxies GitHub Device Flow endpoints via the main process.
|
|
*/
|
|
|
|
const GITHUB_CLIENT_ID = process.env.VITE_SYNC_GITHUB_CLIENT_ID || "";
|
|
const GITHUB_DEVICE_CODE_URL = "https://github.com/login/device/code";
|
|
const GITHUB_ACCESS_TOKEN_URL = "https://github.com/login/oauth/access_token";
|
|
const pendingPollControllers = new Map();
|
|
|
|
/**
|
|
* @param {Electron.IpcMain} ipcMain
|
|
*/
|
|
function registerHandlers(ipcMain) {
|
|
ipcMain.handle("netcatty:github:deviceFlow:start", async (_event, payload) => {
|
|
const clientId = payload?.clientId || GITHUB_CLIENT_ID;
|
|
const scope = payload?.scope || "gist read:user";
|
|
|
|
const res = await fetch(GITHUB_DEVICE_CODE_URL, {
|
|
method: "POST",
|
|
headers: {
|
|
Accept: "application/json",
|
|
"Content-Type": "application/x-www-form-urlencoded",
|
|
},
|
|
body: new URLSearchParams({
|
|
client_id: clientId,
|
|
scope,
|
|
}).toString(),
|
|
});
|
|
|
|
const text = await res.text();
|
|
if (!res.ok) {
|
|
throw new Error(`GitHub device flow failed: ${res.status} - ${text}`);
|
|
}
|
|
|
|
let data;
|
|
try {
|
|
data = JSON.parse(text);
|
|
} catch {
|
|
throw new Error(`GitHub device flow invalid JSON: ${text.slice(0, 200)}`);
|
|
}
|
|
|
|
return {
|
|
deviceCode: data.device_code,
|
|
userCode: data.user_code,
|
|
verificationUri: data.verification_uri,
|
|
expiresAt: Date.now() + (data.expires_in || 0) * 1000,
|
|
interval: data.interval || 5,
|
|
};
|
|
});
|
|
|
|
ipcMain.handle("netcatty:github:deviceFlow:poll", async (_event, payload) => {
|
|
const clientId = payload?.clientId || GITHUB_CLIENT_ID;
|
|
const deviceCode = payload?.deviceCode;
|
|
const pollId = payload?.pollId;
|
|
if (!deviceCode) throw new Error("Missing deviceCode");
|
|
|
|
const controller = new AbortController();
|
|
if (pollId) {
|
|
pendingPollControllers.set(pollId, controller);
|
|
}
|
|
|
|
try {
|
|
const res = await fetch(GITHUB_ACCESS_TOKEN_URL, {
|
|
method: "POST",
|
|
signal: controller.signal,
|
|
headers: {
|
|
Accept: "application/json",
|
|
"Content-Type": "application/x-www-form-urlencoded",
|
|
},
|
|
body: new URLSearchParams({
|
|
client_id: clientId,
|
|
device_code: deviceCode,
|
|
grant_type: "urn:ietf:params:oauth:grant-type:device_code",
|
|
}).toString(),
|
|
});
|
|
|
|
const text = await res.text();
|
|
if (!res.ok) {
|
|
throw new Error(`GitHub token polling failed: ${res.status} - ${text}`);
|
|
}
|
|
|
|
try {
|
|
return JSON.parse(text);
|
|
} catch {
|
|
throw new Error(`GitHub token polling invalid JSON: ${text.slice(0, 200)}`);
|
|
}
|
|
} finally {
|
|
if (pollId) {
|
|
pendingPollControllers.delete(pollId);
|
|
}
|
|
}
|
|
});
|
|
|
|
ipcMain.handle("netcatty:github:deviceFlow:cancelPoll", async (_event, pollId) => {
|
|
if (!pollId) return;
|
|
const controller = pendingPollControllers.get(pollId);
|
|
if (!controller) return;
|
|
pendingPollControllers.delete(pollId);
|
|
controller.abort();
|
|
});
|
|
}
|
|
|
|
module.exports = { registerHandlers };
|