refactor(cli): improve Turso database setup workflow

This commit is contained in:
Aman Varshney
2025-02-13 01:09:40 +05:30
parent efb669d13a
commit a06be85b50
2 changed files with 79 additions and 41 deletions

View File

@@ -0,0 +1,5 @@
---
"create-better-t-stack": patch
---
refactor(cli): improve Turso database setup workflow

View File

@@ -7,6 +7,11 @@ import ora, { type Ora } from "ora";
import { logger } from "../utils/logger"; import { logger } from "../utils/logger";
import { isTursoInstalled, isTursoLoggedIn } from "../utils/turso-cli"; import { isTursoInstalled, isTursoLoggedIn } from "../utils/turso-cli";
interface TursoConfig {
dbUrl: string;
authToken: string;
}
async function loginToTurso(spinner: Ora) { async function loginToTurso(spinner: Ora) {
try { try {
spinner.start("Logging in to Turso..."); spinner.start("Logging in to Turso...");
@@ -25,74 +30,74 @@ async function installTursoCLI(isMac: boolean, spinner: Ora) {
if (isMac) { if (isMac) {
await execa("brew", ["install", "tursodatabase/tap/turso"]); await execa("brew", ["install", "tursodatabase/tap/turso"]);
} else { } else {
const installScript = await execa("curl", [ const { stdout: installScript } = await execa("curl", [
"-sSfL", "-sSfL",
"https://get.tur.so/install.sh", "https://get.tur.so/install.sh",
]); ]);
await execa("bash", [], { input: installScript.stdout }); await execa("bash", [], { input: installScript });
} }
spinner.succeed("Turso CLI installed successfully!"); spinner.succeed("Turso CLI installed successfully!");
} catch (error) { } catch (error) {
if (error instanceof Error && error.message.includes("User force closed")) { if (error instanceof Error && error.message.includes("User force closed")) {
spinner.stop(); spinner.stop();
console.log("\n"); logger.warn("\nTurso CLI installation cancelled by user");
logger.warn("Turso CLI installation cancelled by user"); throw new Error("Installation cancelled");
throw error;
} }
spinner.fail("Failed to install Turso CLI"); spinner.fail("Failed to install Turso CLI");
throw error; throw error;
} }
} }
async function createTursoDatabase(projectDir: string, spinner: Ora) { async function createTursoDatabase(dbName: string): Promise<TursoConfig> {
try { try {
const defaultDbName = path.basename(projectDir);
const dbName = await input({
message: `Enter database name (default: ${defaultDbName}):`,
default: defaultDbName,
});
spinner.start(`Creating Turso database "${dbName}"...`);
await execa("turso", ["db", "create", dbName]); await execa("turso", ["db", "create", dbName]);
const { stdout: dbUrl } = await execa("turso", [
"db",
"show",
dbName,
"--url",
]);
const { stdout: authToken } = await execa("turso", [
"db",
"tokens",
"create",
dbName,
]);
const envPath = path.join(projectDir, "packages/server", ".env");
const envContent = `TURSO_DATABASE_URL="${dbUrl.trim()}"
TURSO_AUTH_TOKEN="${authToken.trim()}"`;
await fs.writeFile(envPath, envContent);
spinner.succeed("Turso database configured successfully!");
} catch (error) { } catch (error) {
spinner.fail("Failed to create Turso database"); if (error instanceof Error && error.message.includes("already exists")) {
throw new Error("DATABASE_EXISTS");
}
throw error; throw error;
} }
const { stdout: dbUrl } = await execa("turso", [
"db",
"show",
dbName,
"--url",
]);
const { stdout: authToken } = await execa("turso", [
"db",
"tokens",
"create",
dbName,
]);
return {
dbUrl: dbUrl.trim(),
authToken: authToken.trim(),
};
} }
async function setupManualConfig(projectDir: string) { async function writeEnvFile(projectDir: string, config?: TursoConfig) {
const envPath = path.join(projectDir, "packages/server", ".env"); const envPath = path.join(projectDir, "packages/server", ".env");
const envContent = `TURSO_DATABASE_URL= const envContent = config
? `TURSO_DATABASE_URL="${config.dbUrl}"
TURSO_AUTH_TOKEN="${config.authToken}"`
: `TURSO_DATABASE_URL=
TURSO_AUTH_TOKEN=`; TURSO_AUTH_TOKEN=`;
await fs.writeFile(envPath, envContent); await fs.writeFile(envPath, envContent);
}
function displayManualSetupInstructions() {
logger.info("\n📝 Manual Turso Setup Instructions:"); logger.info("\n📝 Manual Turso Setup Instructions:");
logger.info("1. Visit https://turso.tech and create an account"); logger.info("1. Visit https://turso.tech and create an account");
logger.info("2. Create a new database from the dashboard"); logger.info("2. Create a new database from the dashboard");
logger.info("3. Get your database URL and authentication token"); logger.info("3. Get your database URL and authentication token");
logger.info("4. Add these credentials to the .env file in your project root"); logger.info(
"4. Add these credentials to the .env file in packages/server/.env",
);
logger.info("\nThe .env file has been created with placeholder variables:"); logger.info("\nThe .env file has been created with placeholder variables:");
logger.info("TURSO_DATABASE_URL=your_database_url"); logger.info("TURSO_DATABASE_URL=your_database_url");
logger.info("TURSO_AUTH_TOKEN=your_auth_token"); logger.info("TURSO_AUTH_TOKEN=your_auth_token");
@@ -105,7 +110,8 @@ export async function setupTurso(projectDir: string) {
const canInstallCLI = platform !== "win32"; const canInstallCLI = platform !== "win32";
if (!canInstallCLI) { if (!canInstallCLI) {
await setupManualConfig(projectDir); await writeEnvFile(projectDir);
displayManualSetupInstructions();
return; return;
} }
@@ -119,7 +125,8 @@ export async function setupTurso(projectDir: string) {
}); });
if (!shouldInstall) { if (!shouldInstall) {
await setupManualConfig(projectDir); await writeEnvFile(projectDir);
displayManualSetupInstructions();
return; return;
} }
@@ -131,9 +138,35 @@ export async function setupTurso(projectDir: string) {
await loginToTurso(spinner); await loginToTurso(spinner);
} }
await createTursoDatabase(projectDir, spinner); const defaultDbName = path.basename(projectDir);
let dbName = await input({
message: `Enter database name (default: ${defaultDbName}):`,
default: defaultDbName,
});
let success = false;
while (!success) {
try {
spinner.start(`Creating Turso database "${dbName}"...`);
const config = await createTursoDatabase(dbName);
await writeEnvFile(projectDir, config);
spinner.succeed("Turso database configured successfully!");
success = true;
} catch (error) {
if (error instanceof Error && error.message === "DATABASE_EXISTS") {
spinner.warn(`Database "${dbName}" already exists`);
dbName = await input({
message: "Please enter a different database name:",
default: `${dbName}-${Math.floor(Math.random() * 1000)}`,
});
} else {
throw error;
}
}
}
} catch (error) { } catch (error) {
logger.error("Error during Turso setup:", error); logger.error("Error during Turso setup:", error);
await setupManualConfig(projectDir); await writeEnvFile(projectDir);
displayManualSetupInstructions();
} }
} }