@ai- matrx/ 数据

评论家AI Matrx 数据层: /db 等级——来之不易的Supabase原始人 每个 Matrx 客户端在平台数据库中使用 – /net 一级—— 恢复力三重奏,每一次外出呼叫和事件流的行驶——以及 /files 等级 - 马特克斯文件通信客户端。 每一个原始的存在,因为一个真正的生产 事件伪造了它;文件头带故事.

npm install @ai-matrx/data

@ai-matrx/data/db

门——与数据库交谈的一种方式

每个应用程序通过门对数据库进行比标 本地生成 从 一个数据库描述。 本包件内的描述船(Adescription/一个被咬了 ,所以不需要数据库或数据库访问.

# in your app (package.json: "db:generate": "matrx-data generate --out src/db/generated --schemas workbench,chat")
npx matrx-data generate --out src/db/generated --schemas workbench          # one file per schema
npx matrx-data generate --out src/db/generated --schemas workbench --check  # CI: fail when stale
npx matrx-data generate --out src/db/generated --flags-index                # + per-schema flags for tableByName
# fresher than this package version? With the direct-DB variables (SUPABASE_MATRIX_*):
npx matrx-data emit --out db-contract && npx matrx-data generate --from db-contract --out src/db/generated

import { createDb, listAll, read, insert, update, remove, call } from "@ai-matrx/data/db";
import { noteFolders, notes, noteFolderGetOrCreate } from "./db/generated/workbench";

const db = createDb({ client: supabase, organization: () => activeOrgId }); // wraps YOUR client
const pinned = await listAll(db, notes, (q) => q.eq("is_pinned", true));       // complete; typed filter; live rows
const row = await read(db, notes, id, { columns: ["id", "label"] });           // typed to those columns
await insert(db, notes, { folder_id, label });         // child: the folder's organization, never the active one
await update(db, notes, id, { label }, { expectedVersion: row.version });      // or { overwrite: true }
await remove(db, notes, id, { expectedVersion: v });   // soft delete; archive-only tables refuse
await call(db, noteFolderGetOrCreate, { p_name: "Clients" });
// @ai-matrx/api: pass db.credentials as its `credentials` option — one sign-in feeds both lanes

规则来自描述(活桌注册),从不使用呼叫网站: 访问阶梯; 读取从不由活动组织过滤并排除软删除行, 除非 includeDeleted· ; listAll 由完整的主密钥完成并订购; 版本上的每个字 表格是看守的; 门沿登记类型; createServiceDb 只有服务器.

@ai-matrx/api/net

接线:没有注射. 该等级具有零依赖性和零接合性—— fetch 和计时器来自环境(节点20+,浏览器,React Industrial/Hermes), 它从不触及Supabase, org上下文, 或API道。 自己传 AbortSignal 改为 resilientFetch编号 :withRetry 还有你自己的 AbortController 改为 monitorStream 这样 监视超时也会取消基本请求 。 这里的一切也是 从根再出口 @ai-matrx/data 进入点.

@ai-matrx/data/next

Next.js的应用程序有五个地方必须构建一个Supabase客户端,每个地方 它们必须通过 SAME 认证- cookie 选项, 否则它不能看到其他的会话 写作。 一个工厂拥有所有五个。 宿主只注射身份识别.

// One module in your app — everything else imports from here.
import { createNextSupabase } from "@ai-matrx/data/next";
import type { Database } from "@/types/database.types";

export const supabaseNext = createNextSupabase<Database>({
  // STATIC member accesses: Next only inlines NEXT_PUBLIC_* for those.
  supabaseUrl: process.env.NEXT_PUBLIC_SUPABASE_URL,
  publishableKey: process.env.NEXT_PUBLIC_SUPABASE_PUBLISHABLE_KEY,
  apexDomain: "example.com",
  cookieName: "sb-example-auth-v2",
  legacyCookieName: "sb-example-auth", // optional: migrate + clear an old key
});

middlewareSession 是整个认证通过在一个呼叫和返回中 { user, client, response, redirect(url), splitCookieJar, ambiguousAuthCookies, authUnavailable }。它拥有: 遗产- 关键迁移( 仅缺席, 所以现场会议永远不会 覆盖),"没有什么可以运行在 createServerClient 和身份决心" 规则是结构化的,持续在当前键下迁移的会话,清除 此主机发布范围取代密钥, 无存储响应标题 带饼干的响应, 饼干结转到方向。 丢弃其中任何一种 随机对用户进行记录——每个用户都是这样找到的.

身份决定是 getClaims()永远 getUser(),它是被弹出. getUser() 向 Auth 服务器发送每个 JWT 的请求; getClaims() 核查 使用 WebCrypto 本地的、通常没有网络的 JWKS 访问令牌 和信任一样,因为签名被检查。 它需要一个 不对称 在项目上签名密钥(ECC/RSA);带有对称密钥可降解为 getUser()- 每一个呼叫的形状请求,仍然正确,但是没有节省。 一个2.5s 身份预算——每个请求一个截止日期 /auth/v1/user,一个符号刷新和 JWKS 抓取, 之后 Auth- js 以不可重试的 408 来回答, 所以它的 30 s 刷新 备份不能运行 (0. 18. 0) —— 意味着一个停滞的认证服务器成本 在Vercel上 16个强制通过 进入一个有硬任务盖的节点Lambda, 无限制版本返回 504 MIDDLEWARE_INVOCATION_TIMEOUT 对真实的人.

🚨 authUnavailable 是消费者的义务. 意思是当局不可能 完成,未"签出": user 实值 null但是没有写 auth cookie, 过期或愈合,被替换的密钥没有清除. 在治疗前读一下 user === null 已签出 ——宿主回弹 /login 无效用户必须跳过 或一个2.5s的网络闪烁 显示人们离开会场. 一个呼叫站点需要 created_at, (中文(简体) ), identities, (中文(简体) ), last_sign_in_at, (中文(简体) ), factors 或者说 *_confirmed_at 必须保留 getUser() 其他地方:JWT没有携带任何武器. 全额合同: common-docs/systems/platform/auth/proxy-identity/FEATURE.md。 。 。 .

没有 next/* 导入软件包中的活性. cookies() 财务报告和审定财务报表 NextResponse 到达通过 结构接合createResponse: () => NextResponse.next({ request })),这样 /next 在"Next"之外建立和测试,从不将框架拖入另一个消费者的图表. 身份丢弃 MissingSupabaseIdentityError 命名变量,而不是 密码 undefined.trim() 类型错误 process.env.X! 产自Supabase内部.

@ai-matrx/data/react

三个钩子,每个钩子都是由MEASURED的重复消费者所建造的——而不是数据比对框架. 这里没有缓存、 商店和查询客户端 : 这些编曲 下级 您的 Redux 或 密码 重复查询,他们不会与之竞争。 他们拥有的是每份手卷拷贝 错了.

const { data, loading, error, refresh, realtimeStatus } = useRealtimeQuery({
  client: supabaseNext.browserClient(),
  topic: `jobs:${fileId}`,
  watch: [{ schema: "docproc", table: "jobs", filter: `file_id=eq.${fileId}` }],
  load: ({ signal }) => listJobsForFile(fileId, signal),
  deps: [fileId],
}, { enabled: fileId !== null });

Supabase客户端类型是结构化的——包从不导入 @supabase/supabase-js。一个真正的客户端通过形状满足它,有一个编译时间 在包件本身的测试中证明这一点(在测试过程中,包件的签名太窄) 软件包的构建,这正是一个主机否则会撞到的失败.

@ai-matrx/data/knobs, (中文(简体) ), /app-config, (中文(简体) ), /config-attestation, (中文(简体) ), /config-types

配置没有代码默认值, 每个读数都计算在内 :

import { createKnobStore, defineKnobFeature, knob, parse } from "@ai-matrx/data/knobs";
import { createAppConfigReader } from "@ai-matrx/data/app-config";
import { createConfigReadRecorder } from "@ai-matrx/data/config-attestation";

const CHAT = defineKnobFeature("desktop.confidential_chat", {
  recentlyDeletedDays: knob("recently_deleted_days", parse.int(0, 3650)),
});
const chat = createKnobStore({ feature: CHAT, client, address, bundled, cache, log, name: "confidential_chat", recorder });
chat.load();
await chat.refresh();
chat.get("recentlyDeletedDays"); // live DB → last-seen cache → build snapshot; throws KnobUnavailableError if none

createAppConfigReader 读取应用程序 public.app_config 同样的行( PostgREST 为 Accept-Profile: public然后,与携带者一起做爱. forDisplay() 其中一个是冷冻的拷贝 从不计数. createConfigReadRecorder 批次读入间隔桶 platform.config_reads_report· ; buildConfigManifest 从输入的登记册中建立释放表.

@ai-matrx/data/access

由网站出入口功能移动. 纯( 无反应 ) : fetchAccessDeniedContext, (中文(简体) ), deriveStatus, (中文(简体) ), classifyDataError, (中文(简体) ), readServerRefusal 编号 : readTypedRefusal, (中文(简体) ), createAccessRequest 编号 : createDeleteRequest 编号 : createSettingAccessRequest 编号 : decideAccessRequest 编号 : withdrawAccessRequest 编号 : listAccessRequests, (中文(简体) ), fetchRemovalRights 编号 : hideForMe 编号 : unhideForMe 编号 : listHiddenItems,则 requestAccess 路由助手, actionAuthority, (中文(简体) ), archivedWords, (中文(简体) ), decideServerReadRecheck, (中文(简体) ), isGovernedActionDenial类型 (单位:千美元)AccessDeniedContext, (中文(简体) ), AccessGateStatus(中文(简体) ).

这个 configureAccess 合同. 软件包没有从应用程序中进口任何东西。 打电话 configureAccess({ getClient, ... }) 启动时一次; 之前使用的任何服务都会丢出一个错误命名 configureAccess域(除 getClient 具有可选性,并且只根据使用它们的特性需要:

resetAccessEnv() 清除注射(测试)。 反应屏幕在 @ai-matrx/sharing/access/react (数据没有UI).

@ai-matrx/data (核心数)

结构类型(PostgrestLikeError, (中文(简体) ), MaybeSingleResponse, (中文(简体) ), Json和 pgErrorToError - PostgREST 错误是普通对象,不是 Errors; 此折叠为 描述性真实错误。 这个 /net 三重奏也在这里再出口.

设计

• 零运行时间依赖关系. 所有Supabase打字都是结构性的——一个真正的supabase-js 客户端满足了形状;没有导入任何形状。 工作在节点20+,浏览器, 和反应土著/赫姆斯.
• 注射主机,有观点的行为. 价值和客户端通过参数输入 (单位:千美元)apexDomain, (中文(简体) ), auth• 行为——CAS合同,拒绝部分归还 列表,单因重试——是故意的不可配置的. 意见是 产品.
• 双载具. 无害环境管理和共同JS条件与相应的申报,证明: 每一次放出都装满了焦油丸.

麻省理工学院