feat(database): add api_tokens and inbox_items tables for OpenSheets Companion

- Add api_tokens table to store device authentication tokens
  - Includes token hash, prefix, expiration, and usage tracking
  - Cascades on user deletion

- Add inbox_items table to store notifications from companion app
  - Stores original notification data and parsed transaction info
  - Tracks processing status (pending, processed, discarded)
  - Links to created lancamento when processed

- Add TypeScript types: ApiToken, NewApiToken, InboxItem, NewInboxItem
- Add inbox Zod schemas for input validation
This commit is contained in:
Felipe Coutinho
2026-01-23 12:10:05 +00:00
parent c2527df191
commit 29a457ad36
2 changed files with 142 additions and 0 deletions

View File

@@ -423,6 +423,97 @@ export const savedInsights = pgTable(
}), }),
); );
// ===================== OPENSHEETS COMPANION =====================
export const apiTokens = pgTable(
"api_tokens",
{
id: uuid("id")
.primaryKey()
.default(sql`gen_random_uuid()`),
userId: text("user_id")
.notNull()
.references(() => user.id, { onDelete: "cascade" }),
name: text("name").notNull(), // Ex: "Meu Samsung Galaxy"
tokenHash: text("token_hash").notNull(), // SHA-256 do token
tokenPrefix: text("token_prefix").notNull(), // Primeiros 8 chars (display)
lastUsedAt: timestamp("last_used_at", { mode: "date", withTimezone: true }),
lastUsedIp: text("last_used_ip"),
expiresAt: timestamp("expires_at", { mode: "date", withTimezone: true }),
revokedAt: timestamp("revoked_at", { mode: "date", withTimezone: true }),
createdAt: timestamp("created_at", { mode: "date", withTimezone: true })
.notNull()
.defaultNow(),
},
(table) => ({
userIdIdx: index("api_tokens_user_id_idx").on(table.userId),
tokenHashIdx: uniqueIndex("api_tokens_token_hash_idx").on(table.tokenHash),
}),
);
export const inboxItems = pgTable(
"inbox_items",
{
id: uuid("id")
.primaryKey()
.default(sql`gen_random_uuid()`),
userId: text("user_id")
.notNull()
.references(() => user.id, { onDelete: "cascade" }),
// Informações da fonte
sourceApp: text("source_app").notNull(), // Ex: "com.nu.production"
sourceAppName: text("source_app_name"), // Ex: "Nubank"
deviceId: text("device_id"), // Identificador do dispositivo
// Dados originais da notificação
originalTitle: text("original_title"),
originalText: text("original_text").notNull(),
notificationTimestamp: timestamp("notification_timestamp", {
mode: "date",
withTimezone: true,
}).notNull(),
// Dados parseados (editáveis pelo usuário antes de processar)
parsedName: text("parsed_name"), // Nome do estabelecimento
parsedAmount: numeric("parsed_amount", { precision: 12, scale: 2 }),
parsedDate: date("parsed_date", { mode: "date" }),
parsedCardLastDigits: text("parsed_card_last_digits"), // Ex: "1234"
parsedTransactionType: text("parsed_transaction_type"), // Despesa, Receita
// Status de processamento
status: text("status").notNull().default("pending"), // pending, processed, discarded
// Referência ao lançamento criado (se processado)
lancamentoId: uuid("lancamento_id").references(() => lancamentos.id, {
onDelete: "set null",
}),
// Metadados de processamento
processedAt: timestamp("processed_at", { mode: "date", withTimezone: true }),
discardedAt: timestamp("discarded_at", { mode: "date", withTimezone: true }),
discardReason: text("discard_reason"),
// Timestamps
createdAt: timestamp("created_at", { mode: "date", withTimezone: true })
.notNull()
.defaultNow(),
updatedAt: timestamp("updated_at", { mode: "date", withTimezone: true })
.notNull()
.defaultNow(),
},
(table) => ({
userIdStatusIdx: index("inbox_items_user_id_status_idx").on(
table.userId,
table.status,
),
userIdCreatedAtIdx: index("inbox_items_user_id_created_at_idx").on(
table.userId,
table.createdAt,
),
}),
);
export const installmentAnticipations = pgTable( export const installmentAnticipations = pgTable(
"installment_anticipations", "installment_anticipations",
{ {
@@ -562,6 +653,8 @@ export const userRelations = relations(user, ({ many, one }) => ({
orcamentos: many(orcamentos), orcamentos: many(orcamentos),
pagadores: many(pagadores), pagadores: many(pagadores),
installmentAnticipations: many(installmentAnticipations), installmentAnticipations: many(installmentAnticipations),
apiTokens: many(apiTokens),
inboxItems: many(inboxItems),
})); }));
export const accountRelations = relations(account, ({ one }) => ({ export const accountRelations = relations(account, ({ one }) => ({
@@ -669,6 +762,24 @@ export const savedInsightsRelations = relations(savedInsights, ({ one }) => ({
}), }),
})); }));
export const apiTokensRelations = relations(apiTokens, ({ one }) => ({
user: one(user, {
fields: [apiTokens.userId],
references: [user.id],
}),
}));
export const inboxItemsRelations = relations(inboxItems, ({ one }) => ({
user: one(user, {
fields: [inboxItems.userId],
references: [user.id],
}),
lancamento: one(lancamentos, {
fields: [inboxItems.lancamentoId],
references: [lancamentos.id],
}),
}));
export const lancamentosRelations = relations(lancamentos, ({ one }) => ({ export const lancamentosRelations = relations(lancamentos, ({ one }) => ({
user: one(user, { user: one(user, {
fields: [lancamentos.userId], fields: [lancamentos.userId],
@@ -736,3 +847,7 @@ export type SavedInsight = typeof savedInsights.$inferSelect;
export type Lancamento = typeof lancamentos.$inferSelect; export type Lancamento = typeof lancamentos.$inferSelect;
export type InstallmentAnticipation = export type InstallmentAnticipation =
typeof installmentAnticipations.$inferSelect; typeof installmentAnticipations.$inferSelect;
export type ApiToken = typeof apiTokens.$inferSelect;
export type NewApiToken = typeof apiTokens.$inferInsert;
export type InboxItem = typeof inboxItems.$inferSelect;
export type NewInboxItem = typeof inboxItems.$inferInsert;

27
lib/schemas/inbox.ts Normal file
View File

@@ -0,0 +1,27 @@
/**
* Zod schemas for inbox items (OpenSheets Companion)
*/
import { z } from "zod";
export const inboxItemSchema = z.object({
sourceApp: z.string().min(1, "sourceApp é obrigatório"),
sourceAppName: z.string().optional(),
deviceId: z.string().optional(),
originalTitle: z.string().optional(),
originalText: z.string().min(1, "originalText é obrigatório"),
notificationTimestamp: z.string().transform((val) => new Date(val)),
parsedName: z.string().optional(),
parsedAmount: z.coerce.number().optional(),
parsedDate: z.string().optional().transform((val) => (val ? new Date(val) : undefined)),
parsedCardLastDigits: z.string().length(4).optional(),
parsedTransactionType: z.enum(["Despesa", "Receita"]).optional(),
clientId: z.string().optional(), // ID local do app para rastreamento
});
export const inboxBatchSchema = z.object({
items: z.array(inboxItemSchema).min(1).max(50),
});
export type InboxItemInput = z.infer<typeof inboxItemSchema>;
export type InboxBatchInput = z.infer<typeof inboxBatchSchema>;