zias/stats
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(buffer): do not update created_at for profiles since its our partition key

Browse Source
This commit is contained in:
Carl-Gerhard Lindesvärd
2025-03-06 11:07:09 +01:00
parent 164a18e931
commit 08b07e42fb
2 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/api/src/routes/track.router.ts
View File

@@ -4,7 +4,7 @@ import type { FastifyPluginCallback } from 'fastify';
import { clientHook } from '@/hooks/client.hook'; import { clientHook } from '@/hooks/client.hook';
import { isBotHook } from '@/hooks/is-bot.hook'; import { isBotHook } from '@/hooks/is-bot.hook';
const trackRouter: FastifyPluginCallback = (fastify) => { const trackRouter: FastifyPluginCallback = async (fastify) => {
fastify.addHook('preHandler', clientHook); fastify.addHook('preHandler', clientHook);
fastify.addHook('preHandler', isBotHook); fastify.addHook('preHandler', isBotHook);

11
packages/db/src/buffers/profile-buffer-redis.ts
View File

@@ -69,18 +69,11 @@ export class ProfileBuffer extends BaseBuffer {
const existingProfile = await this.fetchProfile(profile, logger); const existingProfile = await this.fetchProfile(profile, logger);
const mergedProfile: IClickhouseProfile = existingProfile const mergedProfile: IClickhouseProfile = existingProfile
? deepMergeObjects(existingProfile, profile) ? deepMergeObjects(existingProfile, omit(['created_at'], profile))
: profile; : profile;
// Avoid unnecessary updates: if (profile && existingProfile) {
// If the profile is less than X minutes old
// and the profiles are the same
if (profile.created_at && existingProfile?.created_at) {
const a = new Date(profile.created_at);
const b = new Date(existingProfile.created_at);
const diffTime = Math.abs(a.getTime() - b.getTime());
if ( if (
diffTime < 1000 * 60 * 10 &&
shallowEqual( shallowEqual(
omit(['created_at'], existingProfile), omit(['created_at'], existingProfile),
omit(['created_at'], mergedProfile), omit(['created_at'], mergedProfile),