Add healthcheck and update node version

.env.example

@@ -1,12 +1,13 @@
 TZ=UTC
 PORT=3333
-HOST=localhost
+HOST=0.0.0.0
 LOG_LEVEL=info
-APP_KEY=
+APP_KEY=sMoYEqixvC3sgJO4WM9ej9ctlcVtAdCE
 NODE_ENV=development
 SESSION_DRIVER=cookie
+PG_USER=postgres
 PG_PORT=5432
-PG_HOST=localhost
+PG_HOST=db
 PG_PASSWORD=password
 SENTRY_TOKEN=
 SENTRY_ORG=

Dockerfile

@@ -1,4 +1,6 @@
-FROM node:22-alpine AS base
+FROM node:lts-alpine3.22 AS base
+HEALTHCHECK --interval=5s --timeout=10s --start-period=5s --retries=5 \
+  CMD sh -c 'wget --no-verbose --tries=1 --spider http://127.0.0.1:3333 || exit 1'
 
 # All deps stage
 FROM base AS deps
@@ -32,4 +34,5 @@ WORKDIR /app
 COPY --from=production-deps /app/node_modules /app/node_modules
 COPY --from=build /app/build /app
 EXPOSE 8080
+
 CMD ["node", "./bin/server.js"]

app/controllers/replays_controller.ts

@@ -5,8 +5,19 @@ const SENTRY_ORG = env.get('SENTRY_ORG')
 import redis from '@adonisjs/redis/services/main'
 import { fetchBatch } from '../Helpers/Replays.js'
 import { sendDataToWebhook } from '../Helpers/Webhook.js'
+import { faker } from '@faker-js/faker'
 
 export default class ReplaysController {
+  public async faker({ request, response }: HttpContext) {
+    const { page } = await request.qs()
+    const sessions = Array.from({ length: 100 }, generateFakeSession)
+    const nextPage = +page + 1
+    await response.safeHeader(
+      'link',
+      `<http://localhost:3333/faker/?page=${page}>; rel="previous"; results="true"; cursor="0:1100:1", <http://localhost:3333/faker/?page=${nextPage}>; rel="next"; results="${page == 10 ? 'false' : 'true'}"; cursor="0:${page * 100}:0"`
+    )
+    return { data: sessions, count: sessions.length, page: page }
+  }
   public async stats({ request, response }: HttpContext) {
     const { sendToWebhook } = request.qs()
     const latestVersion = await redis.get(`replays:stats:latest_version`)
@@ -77,9 +88,12 @@ export default class ReplaysController {
       queryString = `?start=${start}&end=${end}`
     }
     const queryFilter = env.get('QUERY_FILTER')
-    await fetchBatch(
-      `https://sentry.io/api/0/organizations/${SENTRY_ORG}/replays/${queryString}&field=id&field=user&field=duration&field=started_at&field=finished_at&query=${encodeURIComponent(queryFilter)}`
-    )
+    const baseUrl =
+      env.get('NODE_ENV') == 'production'
+        ? `https://sentry.io/api/0/organizations/${SENTRY_ORG}/replays/${queryString}&field=id&field=user&field=duration&field=started_at&field=finished_at&query=${encodeURIComponent(queryFilter)}`
+        : 'http://localhost:3333/faker?page=1'
+    console.log('base', baseUrl)
+    await fetchBatch(baseUrl)
 
     let queryResults = await Replay.updateReplayStats()
 
@@ -119,3 +133,63 @@ function buildPaginationLinks(meta: {
 
   return links
 }
+
+function generateFakeSession() {
+  const uuid = faker.string.uuid()
+  const browserName = faker.helpers.arrayElement(['Chrome', 'Firefox', 'Safari', 'Edge', 'Brave'])
+  const deviceBrand = faker.helpers.arrayElement(['Apple', 'Samsung', 'Google'])
+  const osName = faker.helpers.arrayElement(['iOS', 'Android', 'Windows', 'macOS'])
+  const platform = faker.helpers.arrayElement(['Sentry', 'Datadog', 'New Relic', 'Rollbar'])
+  const finishedAt = new Date(Date.now() - faker.number.int({ min: 0, max: 60 * 60 * 1000 }))
+  const displayName = faker.internet.email()
+  return {
+    activity: faker.number.int({ min: 1, max: 10 }),
+    browser: {
+      name: browserName,
+      version: faker.system.semver(),
+    },
+    count_dead_clicks: faker.number.int({ min: 0, max: 10 }),
+    count_rage_clicks: faker.number.int({ min: 0, max: 5 }),
+    count_errors: faker.number.int({ min: 0, max: 5 }),
+    count_segments: faker.number.int({ min: 0, max: 3 }),
+    count_urls: faker.number.int({ min: 1, max: 3 }),
+    device: {
+      brand: deviceBrand,
+      family: deviceBrand === 'Apple' ? 'iPhone' : deviceBrand,
+      model: faker.string.numeric({ length: 2 }),
+      name: `${deviceBrand} ${faker.string.alphanumeric({ length: 3 })}`,
+    },
+    dist: null,
+    duration: faker.number.int({ min: 100, max: 1000 }),
+    environment: faker.helpers.arrayElement(['production', 'staging', 'development']),
+    error_ids: [uuid],
+    finished_at: faker.date.between({ from: finishedAt, to: new Date() }).toISOString(),
+    has_viewed: faker.datatype.boolean(),
+    id: uuid,
+    is_archived: faker.datatype.boolean() ? null : false,
+    os: {
+      name: osName,
+      version: `${faker.number.int({ min: 10, max: 17 })}.${faker.number.int({ min: 0, max: 5 })}`,
+    },
+    platform: platform,
+    project_id: faker.string.numeric({ length: 6 }),
+    releases: [`version@${faker.system.semver()}`],
+    sdk: {
+      name: faker.hacker.noun(),
+      version: faker.system.semver(),
+    },
+    started_at: faker.date.recent().toISOString(),
+    tags: {
+      hello: ['world', faker.person.fullName()],
+    },
+    trace_ids: [uuid],
+    urls: [faker.internet.url()],
+    user: {
+      display_name: displayName,
+      email: displayName,
+      id: faker.string.numeric({ length: 8 }),
+      ip: faker.internet.ip(),
+      username: faker.internet.username(),
+    },
+  }
+}

app/models/replay.ts

@@ -14,7 +14,9 @@ export default class Replay extends BaseModel {
               u.average_session_time_readable,
               u.average_time_seconds,
               r.id AS last_session_id,
-              r.finished_at AS last_session_time
+              r.finished_at AS last_session_time,
+              o.id AS oldest_session_id,
+              o.finished_at AS oldest_session_time
 
             FROM (
               -- Aggregate sessions in the last 30 days
@@ -38,6 +40,8 @@ export default class Replay extends BaseModel {
               WHERE
                 finished_at >= NOW() - INTERVAL '30 days'
                 AND "user" ->> 'display_name' LIKE '%@%'
+                AND "user" ->> 'display_name' !~ 'e2etesting|@paragontruss.com'
+                
               GROUP BY
                 "user" ->> 'display_name'
             ) u
@@ -47,14 +51,29 @@ export default class Replay extends BaseModel {
               SELECT id, finished_at
               FROM replays
               WHERE "user" ->> 'display_name' = u.display_name
+                AND "user" ->> 'display_name' LIKE '%@%'
+                AND "user" ->> 'display_name' !~ 'e2etesting|@paragontruss.com'
               ORDER BY
                 CASE WHEN finished_at >= NOW() - INTERVAL '30 days' THEN 0 ELSE 1 END,
                 finished_at DESC
               LIMIT 1
             ) r ON true
 
+              -- LATERAL JOIN to get the oldest session
+              JOIN LATERAL (
+                SELECT id, finished_at
+                FROM replays
+                WHERE "user" ->> 'display_name' = u.display_name
+                  AND "user" ->> 'display_name' LIKE '%@%'
+                  AND "user" ->> 'display_name' !~ 'e2etesting|@paragontruss.com'
+                ORDER BY finished_at ASC
+                LIMIT 1
+              ) o ON true
+
             ORDER BY
-              u.total_time_seconds DESC;`)
+              u.total_time_seconds DESC;
+              
+ `)
     const updatedVersion = await redis.incr('replays:stats:latest_version')
     results.version = updatedVersion
     results.updatedAt = Date.now()

package-lock.json

@@ -34,6 +34,7 @@
         "@adonisjs/eslint-config": "^2.0.0",
         "@adonisjs/prettier-config": "^1.4.4",
         "@adonisjs/tsconfig": "^1.4.0",
+        "@faker-js/faker": "^9.8.0",
         "@japa/assert": "^4.0.1",
         "@japa/plugin-adonisjs": "^4.0.0",
         "@japa/runner": "^4.2.0",

package.json

@@ -36,6 +36,7 @@
     "@adonisjs/eslint-config": "^2.0.0",
     "@adonisjs/prettier-config": "^1.4.4",
     "@adonisjs/tsconfig": "^1.4.0",
+    "@faker-js/faker": "^9.8.0",
     "@japa/assert": "^4.0.1",
     "@japa/plugin-adonisjs": "^4.0.0",
     "@japa/runner": "^4.2.0",

start/env.ts

@@ -34,7 +34,7 @@ export default await Env.create(new URL('../', import.meta.url), {
   PG_USER: Env.schema.string(),
   PG_PASSWORD: Env.schema.string(),
 
-  WEBHOOK_URL: Env.schema.string(),
+  WEBHOOK_URL: Env.schema.string.optional(),
 
   QUERY_FILTER: Env.schema.string(),
 })

start/routes.ts

@@ -12,3 +12,4 @@ import router from '@adonisjs/core/services/router'
 router.get('/', [ReplaysController, 'home'])
 router.get('/replays', [ReplaysController, 'index'])
 router.get('/stats', [ReplaysController, 'stats'])
+router.get('/faker', [ReplaysController, 'faker'])