diff --git a/lib/db.js b/lib/db.js
index 8725f88c..57518b18 100644
--- a/lib/db.js
+++ b/lib/db.js
@@ -5,6 +5,7 @@ const prisma = new PrismaClient();
export async function runQuery(query) {
return query
.catch(e => {
+ console.error(e);
throw e;
})
.finally(async () => {
@@ -69,9 +70,9 @@ export async function savePageView(website_id, session_id, url, referrer) {
);
}
-export async function saveEvent(website_id, session_id, url, eventType, eventValue) {
+export async function saveEvent(website_id, session_id, url, event_type, event_value) {
return runQuery(
- prisma.pageview.create({
+ prisma.event.create({
data: {
website: {
connect: {
@@ -84,8 +85,8 @@ export async function saveEvent(website_id, session_id, url, eventType, eventVal
},
},
url,
- eventType,
- eventValue,
+ event_type,
+ event_value,
},
}),
);
diff --git a/lib/utils.js b/lib/utils.js
index c2730f70..52f76160 100644
--- a/lib/utils.js
+++ b/lib/utils.js
@@ -91,8 +91,8 @@ export function parseCollectRequest(req) {
const {
url,
referrer,
- eventType,
- eventValue,
+ event_type,
+ event_value,
session: { website_id, session_id, time, hash: validationHash },
} = payload;
@@ -109,8 +109,8 @@ export function parseCollectRequest(req) {
session_id,
url,
referrer,
- eventType,
- eventValue,
+ event_type,
+ event_value,
};
}
}
diff --git a/pages/api/collect.js b/pages/api/collect.js
index 724191f8..b1573673 100644
--- a/pages/api/collect.js
+++ b/pages/api/collect.js
@@ -8,14 +8,14 @@ export default async (req, res) => {
const values = parseCollectRequest(req);
if (values.success) {
- const { type, website_id, session_id, url, referrer, eventType, eventValue } = values;
+ const { type, website_id, session_id, url, referrer, event_type, event_value } = values;
if (type === 'pageview') {
await savePageView(website_id, session_id, url, referrer).catch(() => {
values.success = 0;
});
} else if (type === 'event') {
- await saveEvent(website_id, session_id, url, eventType, eventValue).catch(() => {
+ await saveEvent(website_id, session_id, url, event_type, event_value).catch(() => {
values.success = 0;
});
}
diff --git a/pages/index.js b/pages/index.js
index 0bd3d0ac..e8681e22 100644
--- a/pages/index.js
+++ b/pages/index.js
@@ -15,7 +15,7 @@ export default function Home() {
123
-