FM / neon

/opt/canhelp/node_modules/drizzle-orm/neon/

/opt/canhelp/node_modules/drizzle-orm/neon

Name	Size	Mode	Actions
index.cjs	1211	0644	edit dl rm
index.cjs.map	221	0644	edit dl rm
index.d.cts	64	0644	edit dl rm
index.d.ts	62	0644	edit dl rm
index.js	95	0644	edit dl rm
index.js.map	182	0644	edit dl rm
neon-identity.cjs	1661	0644	edit dl rm
neon-identity.cjs.map	1153	0644	edit dl rm
neon-identity.d.cts	3848	0644	edit dl rm
neon-identity.d.ts	3848	0644	edit dl rm
neon-identity.js	507	0644	edit dl rm
neon-identity.js.map	1123	0644	edit dl rm
rls.cjs	3327	0644	edit dl rm
rls.cjs.map	4755	0644	edit dl rm
rls.d.cts	1510	0644	edit dl rm
rls.d.ts	1507	0644	edit dl rm
rls.js	1956	0644	edit dl rm
rls.js.map	4707	0644	edit dl rm

Edit: /opt/canhelp/node_modules/drizzle-orm/neon/rls.js (1956B)

import { is } from "../entity.js";
import { pgPolicy } from "../pg-core/index.js";
import { PgRole, pgRole } from "../pg-core/roles.js";
import { sql } from "../sql/sql.js";
const crudPolicy = (options) => {
  if (options.read === void 0) {
    throw new Error("crudPolicy requires a read policy");
  }
  if (options.modify === void 0) {
    throw new Error("crudPolicy requires a modify policy");
  }
  let read;
  if (options.read === true) {
    read = sql`true`;
  } else if (options.read === false) {
    read = sql`false`;
  } else if (options.read !== null) {
    read = options.read;
  }
  let modify;
  if (options.modify === true) {
    modify = sql`true`;
  } else if (options.modify === false) {
    modify = sql`false`;
  } else if (options.modify !== null) {
    modify = options.modify;
  }
  let rolesName = "";
  if (Array.isArray(options.role)) {
    rolesName = options.role.map((it) => {
      return is(it, PgRole) ? it.name : it;
    }).join("-");
  } else {
    rolesName = is(options.role, PgRole) ? options.role.name : options.role;
  }
  return [
    read && pgPolicy(`crud-${rolesName}-policy-select`, {
      for: "select",
      to: options.role,
      using: read
    }),
    modify && pgPolicy(`crud-${rolesName}-policy-insert`, {
      for: "insert",
      to: options.role,
      withCheck: modify
    }),
    modify && pgPolicy(`crud-${rolesName}-policy-update`, {
      for: "update",
      to: options.role,
      using: modify,
      withCheck: modify
    }),
    modify && pgPolicy(`crud-${rolesName}-policy-delete`, {
      for: "delete",
      to: options.role,
      using: modify
    })
  ].filter(Boolean);
};
const authenticatedRole = pgRole("authenticated").existing();
const anonymousRole = pgRole("anonymous").existing();
const authUid = (userIdColumn) => sql`(select auth.user_id() = ${userIdColumn})`;
export {
  anonymousRole,
  authUid,
  authenticatedRole,
  crudPolicy
};
//# sourceMappingURL=rls.js.map

import { is } from "../entity.js"; import { pgPolicy } from "../pg-core/index.js"; import { PgRole, pgRole } from "../pg-core/roles.js"; import { sql } from "../sql/sql.js"; const crudPolicy = (options) => { if (options.read === void 0) { throw new Error("crudPolicy requires a read policy"); } if (options.modify === void 0) { throw new Error("crudPolicy requires a modify policy"); } let read; if (options.read === true) { read = sql`true`; } else if (options.read === false) { read = sql`false`; } else if (options.read !== null) { read = options.read; } let modify; if (options.modify === true) { modify = sql`true`; } else if (options.modify === false) { modify = sql`false`; } else if (options.modify !== null) { modify = options.modify; } let rolesName = ""; if (Array.isArray(options.role)) { rolesName = options.role.map((it) => { return is(it, PgRole) ? it.name : it; }).join("-"); } else { rolesName = is(options.role, PgRole) ? options.role.name : options.role; } return [ read && pgPolicy(`crud-${rolesName}-policy-select`, { for: "select", to: options.role, using: read }), modify && pgPolicy(`crud-${rolesName}-policy-insert`, { for: "insert", to: options.role, withCheck: modify }), modify && pgPolicy(`crud-${rolesName}-policy-update`, { for: "update", to: options.role, using: modify, withCheck: modify }), modify && pgPolicy(`crud-${rolesName}-policy-delete`, { for: "delete", to: options.role, using: modify }) ].filter(Boolean); }; const authenticatedRole = pgRole("authenticated").existing(); const anonymousRole = pgRole("anonymous").existing(); const authUid = (userIdColumn) => sql`(select auth.user_id() = ${userIdColumn})`; export { anonymousRole, authUid, authenticatedRole, crudPolicy }; //# sourceMappingURL=rls.js.map