feat: Non-entity tables can be queies with global ambits

packages/data/src/schema.ts

@@ -1,6 +1,5 @@
 // Core
 import * as action from './schema/action.ts';
-import * as amit from './schema/ambit.ts';
 import * as dispatch from './schema/dispatch.ts';
 import * as mutate from './schema/mutate.ts';
 import * as session from './schema/session.ts';
@@ -59,7 +58,6 @@ export function schemaFlatten<G extends Record<string, { table: unknown; relates
 
 export const schema = schemaFlatten({
   action,
-  amit,
   dispatch,
   mutate,
   session,
@@ -84,7 +82,6 @@ export const schema = schemaFlatten({
 
 export {
   action,
-  amit,
   dispatch,
   mutate,
   session,
@@ -137,7 +134,6 @@ export type SchemaSelect = {
  */
 export const core = {
   action,
-  amit,
   dispatch,
   mutate,
   session,

packages/data/src/transaction/query.ts

@@ -1,5 +1,5 @@
 import type { Transaction } from './transaction.types';
-import { sql, SQL, type TableConfig } from 'drizzle-orm';
+import { getTableName, sql, SQL, type TableConfig } from 'drizzle-orm';
 import type { PgTableWithColumns } from 'drizzle-orm/pg-core';
 import { scope } from '@do-ob/data/scope';
 import { type Input } from '@do-ob/core';
@@ -36,7 +36,15 @@ export function query<
       throw new Error('Unauthorized. No subject provided for the query operation.');
     }
 
-    const result = await tx.select().from(table).fullJoin(schema.entity, dataFilter.eq(table.$id, schema.entity.$id)).limit(limit).offset(offset)
+    const tableName = getTableName(table);
+
+    const builder = tx.select().from(table);
+
+    if(tableName.startsWith('entity_')) {
+      builder.leftJoin(schema.entity, dataFilter.eq(table.$id, schema.entity.$id));
+    }
+
+    const result = await builder.limit(limit).offset(offset)
       .orderBy(...order({ table, entity: schema.entity }, dataOrder))
       .where(dataFilter.and(
         scope($subject, ambit),