Added session data display.

This commit is contained in:
Mike Cao 2024-07-30 21:22:19 -07:00
parent f32bf0a2e0
commit b3e6e52473
23 changed files with 239 additions and 34 deletions

View File

@ -0,0 +1,5 @@
.link {
display: flex;
align-items: center;
gap: 20px;
}

View File

@ -1,21 +1,27 @@
import Link from 'next/link'; import Link from 'next/link';
import { GridColumn, GridTable, useBreakpoint } from 'react-basics'; import { GridColumn, GridTable, useBreakpoint } from 'react-basics';
import { useFormat, useMessages } from 'components/hooks'; import { useFormat, useLocale, useMessages } from 'components/hooks';
import Profile from 'components/common/Profile'; import Profile from 'components/common/Profile';
import styles from './SessionsTable.module.css';
import { formatDate } from 'lib/date';
export function SessionsTable({ data = [] }: { data: any[]; showDomain?: boolean }) { export function SessionsTable({ data = [] }: { data: any[]; showDomain?: boolean }) {
const { locale } = useLocale();
const { formatMessage, labels } = useMessages(); const { formatMessage, labels } = useMessages();
const breakpoint = useBreakpoint(); const breakpoint = useBreakpoint();
const { formatValue } = useFormat(); const { formatValue } = useFormat();
return ( return (
<GridTable data={data} cardMode={['xs', 'sm', 'md'].includes(breakpoint)}> <GridTable data={data} cardMode={['xs', 'sm', 'md'].includes(breakpoint)}>
<GridColumn name="pic" label="" width="90px"> <GridColumn name="id" label="ID" width="300px">
{row => <Profile key={row.id} seed={row.id} size={64} />} {row => (
</GridColumn> <Link href={`sessions/${row.id}`} className={styles.link}>
<GridColumn name="id" label="ID"> <Profile key={row.id} seed={row.id} size={64} />
{row => <Link href={`sessions/${row.id}`}>{row.id}</Link>} {row.id}
</Link>
)}
</GridColumn> </GridColumn>
<GridColumn name="visits" label={formatMessage(labels.visits)} width="100px" />
<GridColumn name="country" label={formatMessage(labels.country)}> <GridColumn name="country" label={formatMessage(labels.country)}>
{row => formatValue(row.country, 'country')} {row => formatValue(row.country, 'country')}
</GridColumn> </GridColumn>
@ -28,7 +34,7 @@ export function SessionsTable({ data = [] }: { data: any[]; showDomain?: boolean
{row => formatValue(row.device, 'device')} {row => formatValue(row.device, 'device')}
</GridColumn> </GridColumn>
<GridColumn name="lastAt" label={formatMessage(labels.lastSeen)}> <GridColumn name="lastAt" label={formatMessage(labels.lastSeen)}>
{row => row.lastAt} {row => formatDate(new Date(row.lastAt), 'PPPpp', locale)}
</GridColumn> </GridColumn>
</GridTable> </GridTable>
); );

View File

@ -23,7 +23,6 @@ export function SessionActivity({
return ( return (
<div className={styles.timeline}> <div className={styles.timeline}>
<h1>Activity log</h1>
{data.map(({ eventId, createdAt, urlPath, eventName, visitId }) => { {data.map(({ eventId, createdAt, urlPath, eventName, visitId }) => {
const showHeader = !lastDay || !isSameDay(new Date(lastDay), new Date(createdAt)); const showHeader = !lastDay || !isSameDay(new Date(lastDay), new Date(createdAt));
lastDay = createdAt; lastDay = createdAt;

View File

@ -0,0 +1,39 @@
.data {
display: flex;
flex-direction: column;
gap: 20px;
width: 200px;
position: relative;
}
.header {
font-weight: bold;
}
.empty {
color: var(--font-color300);
text-align: center;
}
.label {
display: flex;
align-items: center;
justify-content: space-between;
}
.type {
font-size: 10px;
text-transform: uppercase;
padding: 0 6px;
border-radius: 4px;
border: 1px solid var(--base300);
}
.name {
color: var(--font-color200);
font-weight: bold;
}
.value {
margin: 5px 0;
}

View File

@ -0,0 +1,34 @@
import { Loading, TextOverflow } from 'react-basics';
import { useMessages, useSessionData } from 'components/hooks';
import Empty from 'components/common/Empty';
import styles from './SessionData.module.css';
import { DATA_TYPES } from 'lib/constants';
export function SessionData({ websiteId, sessionId }: { websiteId: string; sessionId: string }) {
const { formatMessage, labels } = useMessages();
const { data, isLoading } = useSessionData(websiteId, sessionId);
if (isLoading) {
return <Loading icon="dots" size="sm" />;
}
return (
<div className={styles.data}>
<div className={styles.header}>{formatMessage(labels.properties)}</div>
{!data?.length && <Empty className={styles.empty} />}
{data?.map(({ dataKey, dataType, stringValue }) => {
return (
<div key={dataKey}>
<div className={styles.label}>
<div className={styles.name}>
<TextOverflow>{dataKey}</TextOverflow>
</div>
<div className={styles.type}>{DATA_TYPES[dataType]}</div>
</div>
<div className={styles.value}>{stringValue}</div>
</div>
);
})}
</div>
);
}

View File

@ -2,6 +2,7 @@
display: grid; display: grid;
grid-template-columns: 300px 1fr max-content; grid-template-columns: 300px 1fr max-content;
margin-bottom: 40px; margin-bottom: 40px;
position: relative;
} }
.sidebar { .sidebar {
@ -12,16 +13,32 @@
gap: 20px; gap: 20px;
padding-right: 20px; padding-right: 20px;
border-right: 1px solid var(--base300); border-right: 1px solid var(--base300);
position: relative;
} }
.content { .content {
padding: 0 20px;
}
.stats {
display: flex; display: flex;
flex-direction: column; flex-direction: column;
gap: 20px; gap: 30px;
padding: 0 20px;
position: relative;
}
.data {
border-left: 1px solid var(--base300); border-left: 1px solid var(--base300);
padding-left: 20px; padding-left: 20px;
position: relative;
transition: width 200ms ease-in-out;
}
@media screen and (max-width: 992px) {
.page {
grid-template-columns: 1fr;
gap: 30px;
}
.sidebar,
.data {
border: 0;
}
} }

View File

@ -4,9 +4,10 @@ import SessionInfo from './SessionInfo';
import { useWebsiteSession } from 'components/hooks'; import { useWebsiteSession } from 'components/hooks';
import { Loading } from 'react-basics'; import { Loading } from 'react-basics';
import Profile from 'components/common/Profile'; import Profile from 'components/common/Profile';
import styles from './SessionDetailsPage.module.css';
import { SessionActivity } from './SessionActivity'; import { SessionActivity } from './SessionActivity';
import SessionStats from './SessionStats'; import { SessionStats } from './SessionStats';
import { SessionData } from './SessionData';
import styles from './SessionDetailsPage.module.css';
export default function SessionDetailsPage({ export default function SessionDetailsPage({
websiteId, websiteId,
@ -30,10 +31,11 @@ export default function SessionDetailsPage({
<SessionInfo data={data} /> <SessionInfo data={data} />
</div> </div>
<div className={styles.content}> <div className={styles.content}>
<SessionStats data={data} />
<SessionActivity websiteId={websiteId} sessionId={sessionId} /> <SessionActivity websiteId={websiteId} sessionId={sessionId} />
</div> </div>
<div className={styles.stats}> <div className={styles.data}>
<SessionStats data={data} /> <SessionData websiteId={websiteId} sessionId={sessionId} />
</div> </div>
</div> </div>
</> </>

View File

@ -1,14 +1,15 @@
import MetricCard from 'components/metrics/MetricCard'; import MetricCard from 'components/metrics/MetricCard';
import { useMessages } from 'components/hooks'; import { useMessages } from 'components/hooks';
import MetricsBar from 'components/metrics/MetricsBar';
export default function SessionStats({ data }) { export function SessionStats({ data }) {
const { formatMessage, labels } = useMessages(); const { formatMessage, labels } = useMessages();
return ( return (
<> <MetricsBar isFetched={true}>
<MetricCard label={formatMessage(labels.visits)} value={data?.visits} /> <MetricCard label={formatMessage(labels.visits)} value={data?.visits} />
<MetricCard label={formatMessage(labels.views)} value={data?.views} /> <MetricCard label={formatMessage(labels.views)} value={data?.views} />
<MetricCard label={formatMessage(labels.events)} value={data?.events} /> <MetricCard label={formatMessage(labels.events)} value={data?.events} />
</> </MetricsBar>
); );
} }

View File

@ -10,9 +10,9 @@ function convertToPastel(hexColor: string, pastelFactor: number = 0.5) {
hexColor = hexColor.replace(/^#/, ''); hexColor = hexColor.replace(/^#/, '');
// Convert hex to RGB // Convert hex to RGB
let r = parseInt(hexColor.substr(0, 2), 16); let r = parseInt(hexColor.substring(0, 2), 16);
let g = parseInt(hexColor.substr(2, 2), 16); let g = parseInt(hexColor.substring(2, 4), 16);
let b = parseInt(hexColor.substr(4, 2), 16); let b = parseInt(hexColor.substring(4, 6), 16);
// Calculate pastel version (mix with white) // Calculate pastel version (mix with white)
//const pastelFactor = 0.5; // Adjust this value to control pastel intensity //const pastelFactor = 0.5; // Adjust this value to control pastel intensity

View File

@ -6,6 +6,7 @@ export * from './queries/useRealtime';
export * from './queries/useReport'; export * from './queries/useReport';
export * from './queries/useReports'; export * from './queries/useReports';
export * from './queries/useSessionActivity'; export * from './queries/useSessionActivity';
export * from './queries/useSessionData';
export * from './queries/useWebsiteSession'; export * from './queries/useWebsiteSession';
export * from './queries/useWebsiteSessions'; export * from './queries/useWebsiteSessions';
export * from './queries/useShareToken'; export * from './queries/useShareToken';

View File

@ -0,0 +1,12 @@
import { useApi } from './useApi';
export function useSessionData(websiteId: string, sessionId: string) {
const { get, useQuery } = useApi();
return useQuery({
queryKey: ['session:data', { websiteId, sessionId }],
queryFn: () => {
return get(`/sessions/${sessionId}/data`, { websiteId });
},
});
}

View File

@ -274,6 +274,7 @@ export const labels = defineMessages({
previousYear: { id: 'label.previous-year', defaultMessage: 'Previous year' }, previousYear: { id: 'label.previous-year', defaultMessage: 'Previous year' },
lastSeen: { id: 'label.last-seen', defaultMessage: 'Last seen' }, lastSeen: { id: 'label.last-seen', defaultMessage: 'Last seen' },
firstSeen: { id: 'label.first-seen', defaultMessage: 'First seen' }, firstSeen: { id: 'label.first-seen', defaultMessage: 'First seen' },
properties: { id: 'label.properties', defaultMessage: 'Properties' },
}); });
export const messages = defineMessages({ export const messages = defineMessages({

View File

@ -0,0 +1,42 @@
import { canViewWebsite } from 'lib/auth';
import { useAuth, useCors, useValidate } from 'lib/middleware';
import { NextApiRequestQueryBody } from 'lib/types';
import { NextApiResponse } from 'next';
import { methodNotAllowed, ok, unauthorized } from 'next-basics';
import { getSessionData } from 'queries';
import * as yup from 'yup';
export interface SessionDataRequestQuery {
sessionId: string;
websiteId: string;
}
const schema = {
GET: yup.object().shape({
sessionId: yup.string().uuid().required(),
websiteId: yup.string().uuid().required(),
}),
};
export default async (
req: NextApiRequestQueryBody<SessionDataRequestQuery, any>,
res: NextApiResponse<any>,
) => {
await useCors(req, res);
await useAuth(req, res);
await useValidate(schema, req, res);
if (req.method === 'GET') {
const { websiteId, sessionId } = req.query;
if (!(await canViewWebsite(req.auth, websiteId))) {
return unauthorized(res);
}
const data = await getSessionData(websiteId, sessionId);
return ok(res, data);
}
return methodNotAllowed(res);
};

View File

@ -4,7 +4,7 @@ import clickhouse from 'lib/clickhouse';
import kafka from 'lib/kafka'; import kafka from 'lib/kafka';
import prisma from 'lib/prisma'; import prisma from 'lib/prisma';
import { uuid } from 'lib/crypto'; import { uuid } from 'lib/crypto';
import { saveEventData } from 'queries/analytics/eventData/saveEventData'; import { saveEventData } from './saveEventData';
export async function saveEvent(args: { export async function saveEvent(args: {
websiteId: string; websiteId: string;

View File

@ -0,0 +1,41 @@
import prisma from 'lib/prisma';
import clickhouse from 'lib/clickhouse';
import { runQuery, PRISMA, CLICKHOUSE } from 'lib/db';
export async function getSessionData(...args: [websiteId: string, sessionId: string]) {
return runQuery({
[PRISMA]: () => relationalQuery(...args),
[CLICKHOUSE]: () => clickhouseQuery(...args),
});
}
async function relationalQuery(websiteId: string, sessionId: string) {
return prisma.client.sessionData.findMany({
where: {
id: sessionId,
websiteId,
},
});
}
async function clickhouseQuery(websiteId: string, sessionId: string) {
const { rawQuery } = clickhouse;
return rawQuery(
`
select
website_id as websiteId,
session_id as sessionId,
data_key as dataKey,
data_type as dataType,
string_value as stringValue,
number_value as numberValue,
date_value as dateValue,
created_at as createdAt
from session_data
where website_id = {websiteId:UUID}
and session_id = {sessionId:UUID}
`,
{ websiteId, sessionId },
);
}

View File

@ -37,9 +37,9 @@ async function clickhouseQuery(websiteId: string, sessionId: string) {
city, city,
min(created_at) as firstAt, min(created_at) as firstAt,
max(created_at) as lastAt, max(created_at) as lastAt,
uniq(visit_id) as "visits", uniq(visit_id) as visits,
sumIf(1, event_type = 1) as "views", sumIf(1, event_type = 1) as views,
sumIf(1, event_type = 2) as "events" sumIf(1, event_type = 2) as events
from website_event from website_event
where website_id = {websiteId:UUID} where website_id = {websiteId:UUID}
and session_id = {sessionId:UUID} and session_id = {sessionId:UUID}

View File

@ -42,7 +42,8 @@ async function clickhouseQuery(websiteId: string, filters: QueryFilters, pagePar
subdivision1, subdivision1,
city, city,
min(created_at) as firstAt, min(created_at) as firstAt,
max(created_at) as lastAt max(created_at) as lastAt,
uniq(visit_id) as visits
from website_event from website_event
where website_id = {websiteId:UUID} where website_id = {websiteId:UUID}
${dateQuery} ${dateQuery}
@ -52,5 +53,8 @@ async function clickhouseQuery(websiteId: string, filters: QueryFilters, pagePar
`, `,
params, params,
pageParams, pageParams,
); ).then((result: any) => ({
...result,
visits: Number(result.visits),
}));
} }

View File

@ -3,13 +3,13 @@ export * from 'queries/prisma/team';
export * from 'queries/prisma/teamUser'; export * from 'queries/prisma/teamUser';
export * from 'queries/prisma/user'; export * from 'queries/prisma/user';
export * from 'queries/prisma/website'; export * from 'queries/prisma/website';
export * from './analytics/events/getEventDataEvents';
export * from './analytics/events/getEventDataFields';
export * from './analytics/events/getEventDataStats';
export * from './analytics/events/getEventDataUsage';
export * from './analytics/events/getEventMetrics'; export * from './analytics/events/getEventMetrics';
export * from './analytics/events/getEventUsage';
export * from './analytics/events/getEvents'; export * from './analytics/events/getEvents';
export * from './analytics/eventData/getEventDataEvents'; export * from './analytics/events/getEventUsage';
export * from './analytics/eventData/getEventDataFields';
export * from './analytics/eventData/getEventDataStats';
export * from './analytics/eventData/getEventDataUsage';
export * from './analytics/events/saveEvent'; export * from './analytics/events/saveEvent';
export * from './analytics/reports/getFunnel'; export * from './analytics/reports/getFunnel';
export * from './analytics/reports/getJourney'; export * from './analytics/reports/getJourney';
@ -20,6 +20,7 @@ export * from './analytics/pageviews/getPageviewMetrics';
export * from './analytics/pageviews/getPageviewStats'; export * from './analytics/pageviews/getPageviewStats';
export * from './analytics/sessions/createSession'; export * from './analytics/sessions/createSession';
export * from './analytics/sessions/getWebsiteSession'; export * from './analytics/sessions/getWebsiteSession';
export * from './analytics/sessions/getSessionData';
export * from './analytics/sessions/getSessionMetrics'; export * from './analytics/sessions/getSessionMetrics';
export * from './analytics/sessions/getWebsiteSessions'; export * from './analytics/sessions/getWebsiteSessions';
export * from './analytics/sessions/getSessionActivity'; export * from './analytics/sessions/getSessionActivity';