xuejiahao/kintone-customize-manager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
薛家豪
2026-03-13 15:25:44 +08:00
parent 4ec09661cd
commit 8ff555f9e4
11 changed files with 393 additions and 371 deletions
Download Patch File Download Diff File Expand all files Collapse all files

483
src/main/ipc-handlers.ts
View File

@@ -16,7 +16,7 @@ import {
saveDownload,
saveBackup,
} from "./storage";
import { SelfKintoneClient, createKintoneClient } from "./kintone-api";
import { KintoneClient, createKintoneClient } from "./kintone-api";
import type { Result } from "@shared/types/ipc";
import type {
CreateDomainParams,
@@ -32,21 +32,27 @@ import type {
GetVersionsParams,
RollbackParams,
} from "@shared/types/ipc";
import type { Domain, DomainWithStatus, DomainWithPassword } from "@shared/types/domain";
import type {
Domain,
DomainWithStatus,
DomainWithPassword,
} from "@shared/types/domain";
import type {
Version,
DownloadMetadata,
BackupMetadata,
DownloadFile,
} from "@shared/types/version";
import type { AppCustomizeResponse } from "@shared/types/kintone";
import type { AppCustomizeParameter, AppDetail } from "@shared/types/kintone";
import { getDisplayName, getFileKey } from "@shared/utils/fileDisplay";
// Cache for Kintone clients
const clientCache = new Map<string, SelfKintoneClient>();
const clientCache = new Map<string, KintoneClient>();
/**
* Get or create a Kintone client for a domain
*/
async function getClient(domainId: string): Promise<SelfKintoneClient> {
async function getClient(domainId: string): Promise<KintoneClient> {
if (clientCache.has(domainId)) {
return clientCache.get(domainId)!;
}
@@ -64,28 +70,15 @@ async function getClient(domainId: string): Promise<SelfKintoneClient> {
/**
* Helper to wrap IPC handlers with error handling
*/
function handle<T>(channel: string, handler: () => Promise<T>): void {
ipcMain.handle(channel, async (): Promise<Result<T>> => {
try {
const data = await handler();
return { success: true, data };
} catch (error) {
const message = error instanceof Error ? error.message : "Unknown error";
return { success: false, error: message };
}
});
}
/**
* Helper to wrap IPC handlers with parameters
*/
function handleWithParams<P, T>(
function handle<P = void, T = unknown>(
channel: string,
handler: (params: P) => Promise<T>,
): void {
ipcMain.handle(channel, async (_event, params: P): Promise<Result<T>> => {
try {
const data = await handler(params);
// For handlers without params (P=void), params will be undefined but handler ignores it
// For handlers with params, params will be the typed value
const data = await handler(params as P);
return { success: true, data };
} catch (error) {
const message = error instanceof Error ? error.message : "Unknown error";
@@ -110,89 +103,83 @@ function registerGetDomains(): void {
* Deduplication: Check if domain+username already exists
*/
function registerCreateDomain(): void {
handleWithParams<CreateDomainParams, Domain>(
"createDomain",
async (params) => {
// Check for duplicate domain+username
const existingDomains = await listDomains();
const duplicate = existingDomains.find(
(d) =>
d.domain.toLowerCase() === params.domain.toLowerCase() &&
d.username.toLowerCase() === params.username.toLowerCase()
handle<CreateDomainParams, Domain>("createDomain", async (params) => {
// Check for duplicate domain+username
const existingDomains = await listDomains();
const duplicate = existingDomains.find(
(d) =>
d.domain.toLowerCase() === params.domain.toLowerCase() &&
d.username.toLowerCase() === params.username.toLowerCase(),
);
if (duplicate) {
throw new Error(
`Domain "${params.domain}" with user "${params.username}" already exists. Please edit the existing domain instead.`,
);
}
if (duplicate) {
throw new Error(
`Domain "${params.domain}" with user "${params.username}" already exists. Please edit the existing domain instead.`
);
}
const now = new Date().toISOString();
const domain: Domain = {
id: uuidv4(),
name: params.name,
domain: params.domain,
username: params.username,
authType: params.authType,
apiToken: params.apiToken,
createdAt: now,
updatedAt: now,
};
const now = new Date().toISOString();
const domain: Domain = {
id: uuidv4(),
name: params.name,
domain: params.domain,
username: params.username,
authType: params.authType,
apiToken: params.apiToken,
createdAt: now,
updatedAt: now,
};
await saveDomain(domain, params.password);
return domain;
},
);
await saveDomain(domain, params.password);
return domain;
});
}
/**
* Update an existing domain
*/
function registerUpdateDomain(): void {
handleWithParams<UpdateDomainParams, Domain>(
"updateDomain",
async (params) => {
const domains = await listDomains();
const existing = domains.find((d) => d.id === params.id);
handle<UpdateDomainParams, Domain>("updateDomain", async (params) => {
const domains = await listDomains();
const existing = domains.find((d) => d.id === params.id);
if (!existing) {
throw new Error(`Domain not found: ${params.id}`);
if (!existing) {
throw new Error(`Domain not found: ${params.id}`);
}
const updated: Domain = {
...existing,
name: params.name ?? existing.name,
domain: params.domain ?? existing.domain,
username: params.username ?? existing.username,
authType: params.authType ?? existing.authType,
apiToken: params.apiToken ?? existing.apiToken,
updatedAt: new Date().toISOString(),
};
// If password is provided, update it
if (params.password) {
await saveDomain(updated, params.password);
} else {
// Get existing password and re-save
const existingWithPassword = await getDomain(params.id);
if (existingWithPassword) {
await saveDomain(updated, existingWithPassword.password);
}
}
const updated: Domain = {
...existing,
name: params.name ?? existing.name,
domain: params.domain ?? existing.domain,
username: params.username ?? existing.username,
authType: params.authType ?? existing.authType,
apiToken: params.apiToken ?? existing.apiToken,
updatedAt: new Date().toISOString(),
};
// Clear cached client
clientCache.delete(params.id);
// If password is provided, update it
if (params.password) {
await saveDomain(updated, params.password);
} else {
// Get existing password and re-save
const existingWithPassword = await getDomain(params.id);
if (existingWithPassword) {
await saveDomain(updated, existingWithPassword.password);
}
}
// Clear cached client
clientCache.delete(params.id);
return updated;
},
);
return updated;
});
}
/**
* Delete a domain
*/
function registerDeleteDomain(): void {
handleWithParams<string, void>("deleteDomain", async (id) => {
handle<string, void>("deleteDomain", async (id) => {
await deleteDomain(id);
clientCache.delete(id);
});
@@ -202,7 +189,7 @@ function registerDeleteDomain(): void {
* Test domain connection
*/
function registerTestConnection(): void {
handleWithParams<string, DomainWithStatus>("testConnection", async (id) => {
handle<string, DomainWithStatus>("testConnection", async (id) => {
const domainWithPassword = await getDomain(id);
if (!domainWithPassword) {
throw new Error(`Domain not found: ${id}`);
@@ -223,7 +210,7 @@ function registerTestConnection(): void {
* Test domain connection with temporary credentials
*/
function registerTestDomainConnection(): void {
handleWithParams<TestDomainConnectionParams, boolean>(
handle<TestDomainConnectionParams, boolean>(
"testDomainConnection",
async (params) => {
const tempDomain: DomainWithPassword = {
@@ -256,27 +243,25 @@ function registerTestDomainConnection(): void {
* Get apps
*/
function registerGetApps(): void {
handleWithParams<
GetAppsParams,
Awaited<ReturnType<SelfKintoneClient["getApps"]>>
>("getApps", async (params) => {
const client = await getClient(params.domainId);
return client.getApps({
limit: params.limit,
offset: params.offset,
});
});
handle<GetAppsParams, Awaited<ReturnType<KintoneClient["getApps"]>>>(
"getApps",
async (params) => {
const client = await getClient(params.domainId);
return client.getApps({
limit: params.limit,
offset: params.offset,
});
},
);
}
/**
* Get app detail
*/
function registerGetAppDetail(): void {
handleWithParams<
handle<
GetAppDetailParams,
Awaited<ReturnType<SelfKintoneClient["getAppDetail"]>>
Awaited<ReturnType<KintoneClient["getAppDetail"]>>
>("getAppDetail", async (params) => {
const client = await getClient(params.domainId);
return client.getAppDetail(params.appId);
@@ -287,9 +272,9 @@ function registerGetAppDetail(): void {
* Get file content
*/
function registerGetFileContent(): void {
handleWithParams<
handle<
GetFileContentParams,
Awaited<ReturnType<SelfKintoneClient["getFileContent"]>>
Awaited<ReturnType<KintoneClient["getFileContent"]>>
>("getFileContent", async (params) => {
const client = await getClient(params.domainId);
return client.getFileContent(params.fileKey);
@@ -298,11 +283,45 @@ function registerGetFileContent(): void {
// ==================== Deploy IPC Handlers ====================
/**
* Add files to backup for a specific platform and file type
*/
async function addFilesToBackup(
platform: "desktop" | "mobile",
fileType: "js" | "css",
client: KintoneClient,
appDetail: AppDetail,
backupFiles: Map<string, Buffer>,
backupFileList: DownloadFile[]
): Promise<void> {
const files = appDetail.customization?.[platform]?.[fileType] || [];
for (const [index, file] of files.entries()) {
const fileKey = getFileKey(file);
if (fileKey) {
const fileContent = await client.getFileContent(fileKey);
const content = Buffer.from(fileContent.content || "", "base64");
const fileName = getDisplayName(file, fileType, index);
const type = platform === "desktop" ? "pc" : "mobile";
backupFiles.set(`${type}/${fileName}`, content);
backupFileList.push({
type,
fileType,
fileName,
fileKey,
size: content.length,
path: `${type}/${fileName}`,
});
}
}
}
/**
* Deploy files to Kintone
*/
function registerDeploy(): void {
handleWithParams<DeployParams, DeployResult>("deploy", async (params) => {
handle<DeployParams, DeployResult>("deploy", async (params) => {
const client = await getClient(params.domainId);
const domainWithPassword = await getDomain(params.domainId);
@@ -317,39 +336,14 @@ function registerDeploy(): void {
const backupFiles = new Map<string, Buffer>();
const backupFileList: BackupMetadata["files"] = [];
// Add JS files to backup
for (const js of appDetail.customization?.desktop?.js || []) {
if (js.file?.fileKey) {
const fileContent = await client.getFileContent(js.file.fileKey);
const content = Buffer.from(fileContent.content || "", "base64");
backupFiles.set(`pc/${js.file.name || js.file.fileKey}.js`, content);
backupFileList.push({
type: "pc",
fileType: "js",
fileName: js.file.name || js.file.fileKey,
fileKey: js.file.fileKey,
size: content.length,
path: `pc/${js.file.name || js.file.fileKey}.js`,
});
}
}
// Add desktop files to backup
await addFilesToBackup("desktop", "js", client, appDetail, backupFiles, backupFileList);
await addFilesToBackup("desktop", "css", client, appDetail, backupFiles, backupFileList);
// Add mobile files to backup
await addFilesToBackup("mobile", "js", client, appDetail, backupFiles, backupFileList);
await addFilesToBackup("mobile", "css", client, appDetail, backupFiles, backupFileList);
// Add CSS files to backup
for (const css of appDetail.customization?.desktop?.css || []) {
if (css.file?.fileKey) {
const fileContent = await client.getFileContent(css.file.fileKey);
const content = Buffer.from(fileContent.content || "", "base64");
backupFiles.set(`pc/${css.file.name || css.file.fileKey}.css`, content);
backupFileList.push({
type: "pc",
fileType: "css",
fileName: css.file.name || css.file.fileKey,
fileKey: css.file.fileKey,
size: content.length,
path: `pc/${css.file.name || css.file.fileKey}.css`,
});
}
}
// Save backup
const backupMetadata: BackupMetadata = {
backedUpAt: new Date().toISOString(),
@@ -363,59 +357,42 @@ function registerDeploy(): void {
const backupPath = await saveBackup(backupMetadata, backupFiles);
// Upload new files
const uploadedFiles: Array<{
type: "js" | "css";
position: string;
fileKey: string;
}> = [];
// Upload new files and build customization config directly
const newConfig: AppCustomizeParameter = {
app: params.appId,
scope: "ALL",
desktop: {
js: [],
css: [],
},
mobile: {
js: [],
css: [],
},
};
for (const file of params.files) {
const fileKey = await client.uploadFile(file.content, file.fileName);
const fileEntry = { type: "FILE" as const, file: { fileKey: fileKey.fileKey } };
uploadedFiles.push({
type: file.fileType,
position: file.position,
fileKey: fileKey.fileKey,
});
// Add to corresponding field based on file type and position
if (file.fileType === "js") {
if (file.position.startsWith("pc_")) {
newConfig.desktop!.js!.push(fileEntry);
} else if (file.position.startsWith("mobile_")) {
newConfig.mobile!.js!.push(fileEntry);
}
} else if (file.fileType === "css") {
if (file.position === "pc_css") {
newConfig.desktop!.css!.push(fileEntry);
} else if (file.position === "mobile_css") {
newConfig.mobile!.css!.push(fileEntry);
}
}
}
// Build new customization config
// Note: This is simplified - real implementation would merge with existing config
const newConfig: AppCustomizeResponse = {
desktop: {
js: uploadedFiles
.filter((f) => f.type === "js" && f.position.startsWith("pc_"))
.map((f) => ({
type: "FILE" as const,
file: { fileKey: f.fileKey },
})),
css: uploadedFiles
.filter((f) => f.type === "css" && f.position === "pc_css")
.map((f) => ({
type: "FILE" as const,
file: { fileKey: f.fileKey },
})),
},
mobile: {
js: uploadedFiles
.filter((f) => f.type === "js" && f.position.startsWith("mobile_"))
.map((f) => ({
type: "FILE" as const,
file: { fileKey: f.fileKey },
})),
css: uploadedFiles
.filter((f) => f.type === "css" && f.position === "mobile_css")
.map((f) => ({
type: "FILE" as const,
file: { fileKey: f.fileKey },
})),
},
scope: "ALL",
revision: "-1",
};
// Update app customization
await client.updateAppCustomize(params.appId, newConfig);
// Deploy the changes
await client.deployApp(params.appId);
@@ -434,81 +411,79 @@ function registerDeploy(): void {
* Download files from Kintone
*/
function registerDownload(): void {
handleWithParams<DownloadParams, DownloadResult>(
"download",
async (params) => {
const client = await getClient(params.domainId);
const domainWithPassword = await getDomain(params.domainId);
handle<DownloadParams, DownloadResult>("download", async (params) => {
const client = await getClient(params.domainId);
const domainWithPassword = await getDomain(params.domainId);
if (!domainWithPassword) {
throw new Error(`Domain not found: ${params.domainId}`);
}
if (!domainWithPassword) {
throw new Error(`Domain not found: ${params.domainId}`);
}
const appDetail = await client.getAppDetail(params.appId);
const downloadFiles = new Map<string, Buffer>();
const downloadFileList: DownloadMetadata["files"] = [];
const appDetail = await client.getAppDetail(params.appId);
const downloadFiles = new Map<string, Buffer>();
const downloadFileList: DownloadMetadata["files"] = [];
// Download based on requested file types
const fileTypes = params.fileTypes || [
"pc_js",
"pc_css",
"mobile_js",
"mobile_css",
];
// Download based on requested file types
const fileTypes = params.fileTypes || [
"pc_js",
"pc_css",
"mobile_js",
"mobile_css",
];
for (const fileType of fileTypes) {
const files =
fileType === "pc_js"
? appDetail.customization?.desktop?.js
: fileType === "pc_css"
? appDetail.customization?.desktop?.css
: fileType === "mobile_js"
? appDetail.customization?.mobile?.js
: appDetail.customization?.mobile?.css;
for (const fileType of fileTypes) {
const files =
fileType === "pc_js"
? appDetail.customization?.desktop?.js
: fileType === "pc_css"
? appDetail.customization?.desktop?.css
: fileType === "mobile_js"
? appDetail.customization?.mobile?.js
: appDetail.customization?.mobile?.css;
for (const file of files || []) {
if (file.file?.fileKey) {
const content = await client.getFileContent(file.file.fileKey);
const buffer = Buffer.from(content.content || "", "base64");
const fileName = file.file.name || file.file.fileKey;
const type = fileType.includes("mobile") ? "mobile" : "pc";
const ext = fileType.includes("js") ? "js" : "css";
for (const [index, file] of (files || []).entries()) {
const fileKey = getFileKey(file);
if (fileKey) {
const content = await client.getFileContent(fileKey);
const buffer = Buffer.from(content.content || "", "base64");
const ext = fileType.includes("js") ? "js" : "css";
const fileName = getDisplayName(file, ext, index);
const type = fileType.includes("mobile") ? "mobile" : "pc";
downloadFiles.set(`${type}/${fileName}`, buffer);
downloadFileList.push({
type,
fileType: ext,
fileName,
fileKey: file.file.fileKey,
size: buffer.length,
path: `${type}/${fileName}`,
});
}
downloadFiles.set(`${type}/${fileName}`, buffer);
downloadFileList.push({
type,
fileType: ext,
fileName,
fileKey,
size: buffer.length,
path: `${type}/${fileName}`,
});
}
}
}
// Save download metadata
const metadata: DownloadMetadata = {
downloadedAt: new Date().toISOString(),
domain: domainWithPassword.domain,
domainId: params.domainId,
appId: params.appId,
appName: appDetail.name,
spaceId: appDetail.spaceId || "",
spaceName: "", // Would need to fetch from space API
files: downloadFileList,
source: "kintone",
};
// Save download metadata
const metadata: DownloadMetadata = {
downloadedAt: new Date().toISOString(),
domain: domainWithPassword.domain,
domainId: params.domainId,
appId: params.appId,
appName: appDetail.name,
spaceId: appDetail.spaceId || "",
spaceName: "", // Would need to fetch from space API
files: downloadFileList,
source: "kintone",
};
const path = await saveDownload(metadata, downloadFiles);
const path = await saveDownload(metadata, downloadFiles);
return {
success: true,
path,
metadata,
};
},
);
return {
success: true,
path,
metadata,
};
});
}
// ==================== Version IPC Handlers ====================
@@ -517,19 +492,16 @@ function registerDownload(): void {
* Get versions for an app
*/
function registerGetVersions(): void {
handleWithParams<GetVersionsParams, Version[]>(
"getVersions",
async (params) => {
return listVersions(params.domainId, params.appId);
},
);
handle<GetVersionsParams, Version[]>("getVersions", async (params) => {
return listVersions(params.domainId, params.appId);
});
}
/**
* Delete a version
*/
function registerDeleteVersion(): void {
handleWithParams<string, void>("deleteVersion", async (id) => {
handle<string, void>("deleteVersion", async (id) => {
return deleteVersion(id);
});
}
@@ -538,7 +510,7 @@ function registerDeleteVersion(): void {
* Rollback to a previous version
*/
function registerRollback(): void {
handleWithParams<RollbackParams, DeployResult>("rollback", async (_params) => {
handle<RollbackParams, DeployResult>("rollback", async (_params) => {
// This would read the version file and redeploy
// Simplified implementation - would need full implementation
throw new Error("Rollback not yet implemented");
@@ -577,3 +549,4 @@ export function registerIpcHandlers(): void {
console.log("IPC handlers registered");
}