Use niceId

This commit is contained in:
Owen Schwartz 2024-10-14 22:26:32 -04:00
parent ff47ba0b77
commit c47d7fb1ff
No known key found for this signature in database
GPG key ID: 8271FDFFD9E0CCBD
15 changed files with 62 additions and 55 deletions

View file

@ -12,7 +12,7 @@ export const names = JSON.parse(readFileSync(file, 'utf-8'));
export function getUniqueName(): string {
return (
names.animals[Math.floor(Math.random() * names.animals.length)] +
names.descriptor[Math.floor(Math.random() * names.descriptor.length)]
).toLowerCase();
names.descriptors[Math.floor(Math.random() * names.descriptors.length)] + "-" +
names.animals[Math.floor(Math.random() * names.animals.length)]
).toLowerCase().replace(/\s/g, '-');
}

View file

@ -44,10 +44,12 @@ authenticated.delete("/org/:orgId", verifyOrgAccess, org.deleteOrg);
authenticated.put("/org/:orgId/site", verifyOrgAccess, site.createSite);
authenticated.get("/org/:orgId/sites", verifyOrgAccess, site.listSites);
authenticated.get("/site/:siteId", verifySiteAccess, site.getSite);
authenticated.get("/site/:siteId/roles", verifySiteAccess, site.listSiteRoles);
authenticated.post("/site/:siteId", verifySiteAccess, site.updateSite);
authenticated.delete("/site/:siteId", verifySiteAccess, site.deleteSite);
authenticated.get("/org/:orgId/site/:niceId", verifyOrgAccess, site.getSite);
authenticated.get("/site/siteId/:siteId", verifySiteAccess, site.getSite);
authenticated.get("/site/siteId/:siteId/roles", verifySiteAccess, site.listSiteRoles);
authenticated.post("/site/siteId/:siteId", verifySiteAccess, site.updateSite);
authenticated.delete("/site/siteId/:siteId", verifySiteAccess, site.deleteSite);
authenticated.put(
"/org/:orgId/site/:siteId/resource",

View file

@ -82,7 +82,6 @@ export async function createSite(req: Request, res: Response, next: NextFunction
orgId,
name,
niceId,
subdomain,
pubKey,
subnet,
}).returning();
@ -129,7 +128,7 @@ export async function createSite(req: Request, res: Response, next: NextFunction
status: HttpCode.CREATED,
});
} catch (error) {
logger.error(error);
throw error;
return next(createHttpError(HttpCode.INTERNAL_SERVER_ERROR, "An error occurred..."));
}
}

View file

@ -2,7 +2,7 @@ import { Request, Response, NextFunction } from 'express';
import { z } from 'zod';
import { db } from '@server/db';
import { sites } from '@server/db/schema';
import { eq } from 'drizzle-orm';
import { eq, and } from 'drizzle-orm';
import response from "@server/utils/response";
import HttpCode from '@server/types/HttpCode';
import createHttpError from 'http-errors';
@ -11,7 +11,9 @@ import logger from '@server/logger';
// Define Zod schema for request parameters validation
const getSiteSchema = z.object({
siteId: z.string().transform(Number).pipe(z.number().int().positive())
siteId: z.string().transform(Number).pipe(z.number().int().positive()).optional(),
niceId: z.string().optional(),
orgId: z.string().optional(),
});
export type GetSiteResponse = {
@ -34,7 +36,7 @@ export async function getSite(req: Request, res: Response, next: NextFunction):
);
}
const { siteId } = parsedParams.data;
const { siteId, niceId, orgId } = parsedParams.data;
// Check if the user has permission to list sites
const hasPermission = await checkUserActionPermission(ActionsEnum.updateSite, req);
@ -42,11 +44,23 @@ export async function getSite(req: Request, res: Response, next: NextFunction):
return next(createHttpError(HttpCode.FORBIDDEN, 'User does not have permission to perform this action'));
}
let site;
// Fetch the site from the database
const site = await db.select()
.from(sites)
.where(eq(sites.siteId, siteId))
.limit(1);
if (siteId) {
site = await db.select()
.from(sites)
.where(eq(sites.siteId, siteId))
.limit(1);
} else if (niceId && orgId) {
site = await db.select()
.from(sites)
.where(and(eq(sites.niceId, niceId), eq(sites.orgId, orgId)))
.limit(1);
}
if (!site) {
return next(createHttpError(HttpCode.NOT_FOUND, 'Site not found'));
}
if (site.length === 0) {
return next(
@ -60,8 +74,8 @@ export async function getSite(req: Request, res: Response, next: NextFunction):
return response(res, {
data: {
siteId: site[0].siteId,
niceId: site[0].niceId,
name: site[0].name,
subdomain: site[0].subdomain,
subnet: site[0].subnet,
},
success: true,
@ -70,7 +84,7 @@ export async function getSite(req: Request, res: Response, next: NextFunction):
status: HttpCode.OK,
});
} catch (error) {
logger.error(error);
logger.error("Error from getSite: ", error);
return next(createHttpError(HttpCode.INTERNAL_SERVER_ERROR, "An error occurred..."));
}
}

View file

@ -32,6 +32,7 @@ function querySites(orgId: string, accessibleSiteIds: number[]) {
return db
.select({
siteId: sites.siteId,
niceId: sites.niceId,
name: sites.name,
pubKey: sites.pubKey,
subnet: sites.subnet,