amal
8480cec6ae
Deskripsi: - upload surat ke seafile - update struktur db - notif wa kirim link download surat - api download surat No Issues;
273 lines
9.3 KiB
TypeScript
273 lines
9.3 KiB
TypeScript
#!/usr/bin/env bun
|
|
import { promises as fs } from 'fs';
|
|
import * as os from 'os';
|
|
import * as path from 'path';
|
|
|
|
// --- Constants ---
|
|
const CONFIG_FILE = path.join(os.homedir(), '.note.conf');
|
|
|
|
// --- Types ---
|
|
interface Config {
|
|
TOKEN?: string;
|
|
REPO?: string;
|
|
URL?: string;
|
|
}
|
|
|
|
export const defaultConfigSF: Config = {
|
|
TOKEN: process.env.SF_TOKEN,
|
|
REPO: process.env.SF_REPO,
|
|
URL: process.env.SF_URL,
|
|
}
|
|
|
|
// --- Config Management ---
|
|
// async function createDefaultConfig(): Promise<void> {
|
|
// const defaultConfig = `TOKEN=fa49bf1774cad2ec89d2882ae2c6ac1f5d7df445
|
|
// REPO=repos/e23626dc-cc18-4bb8-8fbc-d103b7d33bc8
|
|
// URL=https://cld-dkr-makuro-seafile.wibudev.com/api2
|
|
// `;
|
|
// await fs.writeFile(CONFIG_FILE, defaultConfig, 'utf8');
|
|
// }
|
|
|
|
// async function editConfig(): Promise<void> {
|
|
// if (!(await fs.stat(CONFIG_FILE)).isFile()) {
|
|
// createDefaultConfig();
|
|
// }
|
|
// const editor = process.env.EDITOR || 'vim';
|
|
// try {
|
|
// execSync(`${editor} "${CONFIG_FILE}"`, { stdio: 'inherit' });
|
|
// } catch {
|
|
// console.error('❌ Failed to open editor');
|
|
// process.exit(1);
|
|
// }
|
|
// }
|
|
|
|
export async function loadConfig(): Promise<Config> {
|
|
if (!(await fs.stat(CONFIG_FILE)).isFile()) {
|
|
console.error(`⚠️ Config file not found at ${CONFIG_FILE}`);
|
|
console.error('Run: bun note.ts config to create/edit it.');
|
|
process.exit(1);
|
|
}
|
|
|
|
const configContent = await fs.readFile(CONFIG_FILE, 'utf8');
|
|
const config: Config = {};
|
|
|
|
configContent.split('\n').forEach((line) => {
|
|
const trimmed = line.trim();
|
|
if (!trimmed || trimmed.startsWith('#')) return;
|
|
|
|
const [key, ...valueParts] = trimmed.split('=');
|
|
if (key && valueParts.length > 0) {
|
|
let value = valueParts.join('=').trim();
|
|
if (
|
|
(value.startsWith('"') && value.endsWith('"')) ||
|
|
(value.startsWith("'") && value.endsWith("'"))
|
|
) {
|
|
value = value.slice(1, -1);
|
|
}
|
|
config[key as keyof Config] = value;
|
|
}
|
|
});
|
|
|
|
if (!config.TOKEN || !config.REPO || !config.URL) {
|
|
console.error(`❌ Config invalid. Please set TOKEN, REPO, and URL inside ${CONFIG_FILE}`);
|
|
process.exit(1);
|
|
}
|
|
return config;
|
|
}
|
|
|
|
// --- HTTP Helpers ---
|
|
export async function fetchWithAuth(config: Config, url: string, options: RequestInit = {}): Promise<Response> {
|
|
const headers = {
|
|
Authorization: `Token ${config.TOKEN}`,
|
|
...options.headers,
|
|
};
|
|
|
|
const response = await fetch(url, { ...options, headers });
|
|
if (!response.ok) {
|
|
console.error(`❌ Request failed: ${response.status} ${response.statusText}`);
|
|
console.error(`🔍 URL: ${url}`);
|
|
console.error(`🔍 Headers:`, headers);
|
|
|
|
try {
|
|
const errorText = await response.text();
|
|
console.error(`🔍 Response body: ${errorText}`);
|
|
} catch {
|
|
console.error('🔍 Could not read response body');
|
|
}
|
|
}
|
|
return response;
|
|
}
|
|
|
|
// --- Commands ---
|
|
export async function testConnection(config: Config): Promise<string> {
|
|
try {
|
|
const response = await fetchWithAuth(config, `${config.URL}/ping/`);
|
|
return `✅ API connection successful: ${await response.text()}`
|
|
} catch {
|
|
// return '⚠️ API ping failed, trying repo access...'
|
|
try {
|
|
await fetchWithAuth(config, `${config.URL}/${config.REPO}/`);
|
|
return `✅ Repo access successful`
|
|
} catch {
|
|
return '❌ Both API ping and repo access failed'
|
|
}
|
|
}
|
|
}
|
|
|
|
export async function listFiles(config: Config): Promise<{ name: string }[]> {
|
|
const url = `${config.URL}/${config.REPO}/dir/?p=/`;
|
|
const response = await fetchWithAuth(config, url);
|
|
|
|
try {
|
|
const files = (await response.json()) as { name: string }[];
|
|
return files
|
|
} catch {
|
|
console.error('❌ Failed to parse response');
|
|
process.exit(1);
|
|
}
|
|
}
|
|
|
|
export async function catFile(config: Config, folder: string, fileName: string): Promise<ArrayBuffer> {
|
|
const downloadUrlResponse = await fetchWithAuth(config, `${config.URL}/${config.REPO}/file/?p=/${folder}/${fileName}`);
|
|
const downloadUrl = (await downloadUrlResponse.text()).replace(/"/g, '');
|
|
|
|
// Download file sebagai binary, BUKAN text
|
|
const fileResponse = await fetchWithAuth(config, downloadUrl);
|
|
const buffer = await fileResponse.arrayBuffer();
|
|
|
|
return buffer;
|
|
}
|
|
|
|
export async function uploadFile(config: Config, file: File, folder: string): Promise<string> {
|
|
const remoteName = path.basename(file.name);
|
|
|
|
// 1. Dapatkan upload link (pakai Authorization)
|
|
const uploadUrlResponse = await fetchWithAuth(
|
|
config,
|
|
`${config.URL}/${config.REPO}/upload-link/`
|
|
);
|
|
const uploadUrl = (await uploadUrlResponse.text()).replace(/"/g, "");
|
|
|
|
// 2. Siapkan form-data
|
|
const formData = new FormData();
|
|
formData.append("parent_dir", "/");
|
|
formData.append("relative_path", folder); // tanpa slash di akhir
|
|
formData.append("file", file, remoteName); // file langsung, jangan pakai Blob
|
|
|
|
// 3. Upload file TANPA Authorization header, token di query param
|
|
const res = await fetch(`${uploadUrl}?token=${config.TOKEN}`, {
|
|
method: "POST",
|
|
body: formData,
|
|
});
|
|
|
|
const text = await res.text();
|
|
|
|
if (!res.ok) return 'gagal'
|
|
return `✅ Uploaded ${file.name} successfully`;
|
|
}
|
|
|
|
export async function uploadFileBase64(config: Config, base64File: { name: string; data: string; }): Promise<string> {
|
|
const remoteName = path.basename(base64File.name);
|
|
|
|
// 1. Dapatkan upload link (pakai Authorization)
|
|
const uploadUrlResponse = await fetchWithAuth(
|
|
config,
|
|
`${config.URL}/${config.REPO}/upload-link/`
|
|
);
|
|
const uploadUrl = (await uploadUrlResponse.text()).replace(/"/g, "");
|
|
|
|
// 2. Konversi base64 ke Blob
|
|
const binary = Buffer.from(base64File.data, "base64");
|
|
const blob = new Blob([binary]);
|
|
|
|
// 3. Siapkan form-data
|
|
const formData = new FormData();
|
|
formData.append("parent_dir", "/");
|
|
formData.append("relative_path", "syarat-dokumen"); // tanpa slash di akhir
|
|
formData.append("file", blob, remoteName);
|
|
|
|
// 4. Upload file TANPA Authorization header, token di query param
|
|
const res = await fetch(`${uploadUrl}?token=${config.TOKEN}`, {
|
|
method: "POST",
|
|
body: formData,
|
|
});
|
|
|
|
const text = await res.text();
|
|
|
|
if (!res.ok) throw new Error(`Upload failed: ${text}`);
|
|
return `✅ Uploaded ${base64File.name} successfully`;
|
|
}
|
|
|
|
export async function uploadFileToFolder(config: Config, base64File: { name: string; data: string; }, folder: 'syarat-dokumen' | 'pengaduan'): Promise<string> {
|
|
const remoteName = path.basename(base64File.name);
|
|
|
|
// 1. Dapatkan upload link (pakai Authorization)
|
|
const uploadUrlResponse = await fetchWithAuth(
|
|
config,
|
|
`${config.URL}/${config.REPO}/upload-link/`
|
|
);
|
|
const uploadUrl = (await uploadUrlResponse.text()).replace(/"/g, "");
|
|
|
|
// 2. Konversi base64 ke Blob
|
|
const binary = Buffer.from(base64File.data, "base64");
|
|
const blob = new Blob([binary]);
|
|
|
|
// 3. Siapkan form-data
|
|
const formData = new FormData();
|
|
formData.append("parent_dir", "/");
|
|
formData.append("relative_path", folder); // tanpa slash di akhir
|
|
formData.append("file", blob, remoteName);
|
|
|
|
// 4. Upload file TANPA Authorization header, token di query param
|
|
const res = await fetch(`${uploadUrl}?token=${config.TOKEN}`, {
|
|
method: "POST",
|
|
body: formData,
|
|
});
|
|
|
|
const text = await res.text();
|
|
|
|
if (!res.ok) throw new Error(`Upload failed: ${text}`);
|
|
return `✅ Uploaded ${base64File.name} successfully`;
|
|
}
|
|
|
|
|
|
export async function removeFile(config: Config, fileName: string, folder: string): Promise<string> {
|
|
const res = await fetchWithAuth(config, `${config.URL}/${config.REPO}/file/?p=/${folder}/${fileName}`, { method: 'DELETE' });
|
|
|
|
if (!res.ok) return 'gagal menghapus file';
|
|
return `🗑️ Removed ${fileName}`
|
|
}
|
|
|
|
export async function moveFile(config: Config, oldName: string, newName: string): Promise<string> {
|
|
const url = `${config.URL}/${config.REPO}/file/?p=/${oldName}`;
|
|
const formData = new FormData();
|
|
formData.append('operation', 'rename');
|
|
formData.append('newname', newName);
|
|
|
|
await fetchWithAuth(config, url, { method: 'POST', body: formData });
|
|
return `✏️ Renamed ${oldName} → ${newName}`
|
|
}
|
|
|
|
export async function downloadFile(config: Config, fileName: string, folder: string, localFile?: string): Promise<string> {
|
|
const localName = localFile || fileName;
|
|
// 🔹 gabungkan path folder + file
|
|
const filePath = `/${folder}/${fileName}`.replace(/\/+/g, "/");
|
|
|
|
// 🔹 encode path agar aman (spasi, dll)
|
|
const params = new URLSearchParams({
|
|
p: filePath,
|
|
});
|
|
|
|
const downloadUrlResponse = await fetchWithAuth(config, `${config.URL}/${config.REPO}/file/?${params.toString()}`);
|
|
if(!downloadUrlResponse.ok)
|
|
return 'gagal'
|
|
const downloadUrl = (await downloadUrlResponse.text()).replace(/"/g, '');
|
|
const buffer = Buffer.from(await (await fetchWithAuth(config, downloadUrl)).arrayBuffer());
|
|
await fs.writeFile(localName, buffer);
|
|
return `⬇️ Downloaded ${fileName} → ${localName}`
|
|
}
|
|
|
|
export async function getFileLink(config: Config, fileName: string): Promise<string> {
|
|
const downloadUrlResponse = await fetchWithAuth(config, `${config.URL}/${config.REPO}/file/?p=/${fileName}`);
|
|
return `🔗 Link for ${fileName}:\n${(await downloadUrlResponse.text()).replace(/"/g, '')}`
|
|
} |