remove arquivos desnecessarios
This commit is contained in:
@@ -123,9 +123,9 @@ export const criarOuBuscarConversaIndividual = mutation({
|
||||
handler: async (ctx, args) => {
|
||||
// TENTAR BETTER AUTH PRIMEIRO
|
||||
const identity = await ctx.auth.getUserIdentity();
|
||||
|
||||
|
||||
let usuarioAtual = null;
|
||||
|
||||
|
||||
if (identity && identity.email) {
|
||||
// Buscar por email (Better Auth)
|
||||
usuarioAtual = await ctx.db
|
||||
@@ -133,7 +133,7 @@ export const criarOuBuscarConversaIndividual = mutation({
|
||||
.withIndex("by_email", (q) => q.eq("email", identity.email!))
|
||||
.first();
|
||||
}
|
||||
|
||||
|
||||
// SE NÃO ENCONTROU, BUSCAR POR SESSÃO ATIVA (Sistema customizado)
|
||||
if (!usuarioAtual) {
|
||||
const sessaoAtiva = await ctx.db
|
||||
@@ -141,7 +141,7 @@ export const criarOuBuscarConversaIndividual = mutation({
|
||||
.filter((q) => q.eq(q.field("ativo"), true))
|
||||
.order("desc")
|
||||
.first();
|
||||
|
||||
|
||||
if (sessaoAtiva) {
|
||||
usuarioAtual = await ctx.db.get(sessaoAtiva.usuarioId);
|
||||
}
|
||||
@@ -184,7 +184,11 @@ export const enviarMensagem = mutation({
|
||||
args: {
|
||||
conversaId: v.id("conversas"),
|
||||
conteudo: v.string(),
|
||||
tipo: v.union(v.literal("texto"), v.literal("arquivo"), v.literal("imagem")),
|
||||
tipo: v.union(
|
||||
v.literal("texto"),
|
||||
v.literal("arquivo"),
|
||||
v.literal("imagem")
|
||||
),
|
||||
arquivoId: v.optional(v.id("_storage")),
|
||||
arquivoNome: v.optional(v.string()),
|
||||
arquivoTamanho: v.optional(v.number()),
|
||||
@@ -362,7 +366,10 @@ export const reagirMensagem = mutation({
|
||||
} else {
|
||||
// Adicionar reação
|
||||
await ctx.db.patch(args.mensagemId, {
|
||||
reagiuPor: [...reacoes, { usuarioId: usuarioAtual._id, emoji: args.emoji }],
|
||||
reagiuPor: [
|
||||
...reacoes,
|
||||
{ usuarioId: usuarioAtual._id, emoji: args.emoji },
|
||||
],
|
||||
});
|
||||
}
|
||||
|
||||
@@ -659,7 +666,9 @@ export const listarConversas = query({
|
||||
m.remetenteId !== usuarioAtual._id
|
||||
).length;
|
||||
} else {
|
||||
naoLidas = mensagens.filter((m) => m.remetenteId !== usuarioAtual._id).length;
|
||||
naoLidas = mensagens.filter(
|
||||
(m) => m.remetenteId !== usuarioAtual._id
|
||||
).length;
|
||||
}
|
||||
|
||||
return {
|
||||
@@ -757,10 +766,15 @@ export const obterMensagensAgendadas = query({
|
||||
|
||||
// Filtrar apenas as do usuário atual
|
||||
const minhasMensagensAgendadas = mensagens.filter(
|
||||
(m) => m.remetenteId === usuarioAtual._id && m.agendadaPara && m.agendadaPara > Date.now()
|
||||
(m) =>
|
||||
m.remetenteId === usuarioAtual._id &&
|
||||
m.agendadaPara &&
|
||||
m.agendadaPara > Date.now()
|
||||
);
|
||||
|
||||
return minhasMensagensAgendadas.sort((a, b) => (a.agendadaPara || 0) - (b.agendadaPara || 0));
|
||||
return minhasMensagensAgendadas.sort(
|
||||
(a, b) => (a.agendadaPara || 0) - (b.agendadaPara || 0)
|
||||
);
|
||||
},
|
||||
});
|
||||
|
||||
@@ -784,9 +798,7 @@ export const obterNotificacoes = query({
|
||||
|
||||
let query = ctx.db
|
||||
.query("notificacoes")
|
||||
.withIndex("by_usuario", (q) =>
|
||||
q.eq("usuarioId", usuarioAtual._id)
|
||||
);
|
||||
.withIndex("by_usuario", (q) => q.eq("usuarioId", usuarioAtual._id));
|
||||
|
||||
if (args.apenasPendentes) {
|
||||
query = ctx.db
|
||||
@@ -935,11 +947,11 @@ export const buscarMensagens = query({
|
||||
|
||||
let mensagens: any[] = [];
|
||||
|
||||
if (args.conversaId) {
|
||||
if (args.conversaId !== undefined) {
|
||||
// Buscar em conversa específica
|
||||
const mensagensConversa = await ctx.db
|
||||
.query("mensagens")
|
||||
.withIndex("by_conversa", (q) => q.eq("conversaId", args.conversaId))
|
||||
.withIndex("by_conversa", (q) => q.eq("conversaId", args.conversaId!))
|
||||
.collect();
|
||||
mensagens = mensagensConversa;
|
||||
} else {
|
||||
@@ -1008,7 +1020,9 @@ export const obterDigitando = query({
|
||||
.collect();
|
||||
|
||||
// Filtrar usuário atual e buscar informações
|
||||
const digitandoFiltrado = digitando.filter((d) => d.usuarioId !== usuarioAtual._id);
|
||||
const digitandoFiltrado = digitando.filter(
|
||||
(d) => d.usuarioId !== usuarioAtual._id
|
||||
);
|
||||
|
||||
const usuarios = await Promise.all(
|
||||
digitandoFiltrado.map(async (d) => {
|
||||
@@ -1054,7 +1068,9 @@ export const contarNaoLidas = query({
|
||||
|
||||
if (leitura) {
|
||||
return mensagens.filter(
|
||||
(m) => m.enviadaEm > (leitura.lidaEm || 0) && m.remetenteId !== usuarioAtual._id
|
||||
(m) =>
|
||||
m.enviadaEm > (leitura.lidaEm || 0) &&
|
||||
m.remetenteId !== usuarioAtual._id
|
||||
).length;
|
||||
}
|
||||
|
||||
@@ -1143,4 +1159,3 @@ export const limparIndicadoresDigitacao = internalMutation({
|
||||
return indicadoresAntigos.length;
|
||||
},
|
||||
});
|
||||
|
||||
|
||||
Reference in New Issue
Block a user