Fixed pixels/links collect.
This commit is contained in:
@@ -82,6 +82,8 @@ export async function POST(request: Request) {
|
|||||||
id,
|
id,
|
||||||
} = payload;
|
} = payload;
|
||||||
|
|
||||||
|
const sourceId = websiteId || pixelId || linkId;
|
||||||
|
|
||||||
// Cache check
|
// Cache check
|
||||||
let cache: Cache | null = null;
|
let cache: Cache | null = null;
|
||||||
|
|
||||||
@@ -128,13 +130,13 @@ export async function POST(request: Request) {
|
|||||||
const sessionSalt = hash(startOfMonth(createdAt).toUTCString());
|
const sessionSalt = hash(startOfMonth(createdAt).toUTCString());
|
||||||
const visitSalt = hash(startOfHour(createdAt).toUTCString());
|
const visitSalt = hash(startOfHour(createdAt).toUTCString());
|
||||||
|
|
||||||
const sessionId = id ? uuid(websiteId, id) : uuid(websiteId, ip, userAgent, sessionSalt);
|
const sessionId = id ? uuid(sourceId, id) : uuid(sourceId, ip, userAgent, sessionSalt);
|
||||||
|
|
||||||
// Create a session if not found
|
// Create a session if not found
|
||||||
if (!clickhouse.enabled && !cache?.sessionId) {
|
if (!clickhouse.enabled && !cache?.sessionId) {
|
||||||
await createSession({
|
await createSession({
|
||||||
id: sessionId,
|
id: sessionId,
|
||||||
websiteId,
|
websiteId: sourceId,
|
||||||
browser,
|
browser,
|
||||||
os,
|
os,
|
||||||
device,
|
device,
|
||||||
@@ -206,7 +208,7 @@ export async function POST(request: Request) {
|
|||||||
: EVENT_TYPE.pageView;
|
: EVENT_TYPE.pageView;
|
||||||
|
|
||||||
await saveEvent({
|
await saveEvent({
|
||||||
websiteId: websiteId || linkId || pixelId,
|
websiteId: sourceId,
|
||||||
sessionId,
|
sessionId,
|
||||||
visitId,
|
visitId,
|
||||||
eventType,
|
eventType,
|
||||||
@@ -270,6 +272,9 @@ export async function POST(request: Request) {
|
|||||||
} catch (e) {
|
} catch (e) {
|
||||||
const error = serializeError(e);
|
const error = serializeError(e);
|
||||||
|
|
||||||
|
// eslint-disable-next-line no-console
|
||||||
|
console.log(error);
|
||||||
|
|
||||||
return serverError({ errorObject: error });
|
return serverError({ errorObject: error });
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user