Something went wrong. Try again.
leaflet fork for copy edit / bug fixes forked from leaflet.pub/leaflet
Something went wrong. Try again.
2.2 kB · 70 lines
TypeScript
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071"use server";
import { eq, and } from "drizzle-orm";import { drizzle } from "drizzle-orm/node-postgres";import { permission_token_rights, permission_tokens } from "drizzle/schema";import { pool } from "supabase/pool";export async function getShareLink( token: { id: string; entity_set: string }, rootEntity: string,) { const client = await pool.connect(); const db = drizzle(client); let link = await db.transaction(async (tx) => { // This will likely error out when if we have multiple permission // token rights associated with a single token let [tokenW] = await tx .select() .from(permission_tokens) .leftJoin( permission_token_rights, eq(permission_token_rights.token, permission_tokens.id), ) .where(eq(permission_tokens.id, token.id)); if ( !tokenW.permission_token_rights || tokenW.permission_token_rights.create_token !== true || tokenW.permission_tokens.root_entity !== rootEntity || tokenW.permission_token_rights.entity_set !== token.entity_set ) { return null; }
let [existingToken] = await tx .select() .from(permission_tokens) .rightJoin( permission_token_rights, eq(permission_token_rights.token, permission_tokens.id), ) .where( and( eq(permission_token_rights.read, true), eq(permission_token_rights.write, false), eq(permission_token_rights.create_token, false), eq(permission_token_rights.change_entity_set, false), eq(permission_token_rights.entity_set, token.entity_set), eq(permission_tokens.root_entity, rootEntity), ), ); if (existingToken) { return existingToken.permission_tokens; } let [newToken] = await tx .insert(permission_tokens) .values({ root_entity: rootEntity }) .returning(); await tx.insert(permission_token_rights).values({ entity_set: token.entity_set, token: newToken.id, read: true, write: false, create_token: false, change_entity_set: false, }); return newToken; });
client.release(); return link;}