add: view duration releated constants

Author: marek629

CHANGELOG.md

@@ -6,6 +6,10 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+### Added
+
+- Page view duration limit and interval is configurable now at system level, could be changed via API and Settings panel
+
 ### Changed
 
 - The official Docker image is now based on Node.js 22 (#343)

dist/index.css

@@ -61,6 +61,7 @@
   "devDependencies": {
     "@apollo/client": "^3.7.2",
     "@electerious/eslint-config": "^3.5.0",
+    "@types/sinon": "^17.0.3",
     "ava": "5.1.0",
     "classnames": "^2.3.1",
     "coveralls": "^3.1.1",
@@ -73,6 +74,7 @@
     "normalize.css": "^8.0.1",
     "nyc": "^15.1.0",
     "prop-types": "^15.8.1",
+    "ramda": "^0.30.1",
     "react": "^18.1.0",
     "react-apollo-network-status": "^5.0.1",
     "react-dom": "^18.1.0",
@@ -83,6 +85,7 @@
     "rosid-handler-sass": "^8.0.0",
     "s-ago": "^2.2.0",
     "shortid": "^2.2.16",
+    "sinon": "^19.0.2",
     "test-listen": "^1.1.0",
     "url-pattern": "^1.0.3"
   },

dist/index.js

@@ -1,6 +1,6 @@
 'use strict'
 
-const { DURATIONS_LIMIT, DURATIONS_INTERVAL } = require('../constants/durations')
+const constants = require('../constants/durations')
 const matchDomains = require('../stages/matchDomains')
 
 module.exports = (ids, dateDetails) => {
@@ -19,10 +19,10 @@ module.exports = (ids, dateDetails) => {
 	}
 
 	// Ignore users that are on the page for too long
-	aggregation[0].$match.created = { $gte: dateDetails.lastMilliseconds(DURATIONS_LIMIT) }
+	aggregation[0].$match.created = { $gte: dateDetails.lastMilliseconds(constants.DURATIONS_LIMIT) }
 
 	// Ignore users that aren't active anymore
-	aggregation[0].$match.updated = { $gte: dateDetails.lastMilliseconds(DURATIONS_INTERVAL * 2) }
+	aggregation[0].$match.updated = { $gte: dateDetails.lastMilliseconds(constants.DURATIONS_INTERVAL * 2) }
 
 	return aggregation
 }

package.json

@@ -1,11 +1,15 @@
 'use strict'
 
-const { hour } = require('../utils/times')
+const { customise } = require('../utils/constants')
+const { hour, second } = require('../utils/times')
 
-const DURATIONS_INTERVAL = 15000
+const DURATIONS_INTERVAL = 15 * second
 const DURATIONS_LIMIT = hour / 2
 
-module.exports = {
+module.exports = customise({
 	DURATIONS_INTERVAL,
 	DURATIONS_LIMIT,
-}
+}, [
+	'DURATIONS_INTERVAL',
+	'DURATIONS_LIMIT',
+])

src/aggregations/aggregateActiveVisitors.js

@@ -0,0 +1,40 @@
+'use strict'
+
+const Constant = require('../models/Constant')
+
+const response = (entry) => ({
+	id: entry.id,
+	name: entry.name,
+	value: entry.value,
+	unit: entry.unit,
+	created: entry.created,
+	updated: entry.updated,
+})
+
+const enhance = (entry) => {
+	return entry == null ? entry : response(entry)
+}
+
+const get = async (name) => enhance(
+	await Constant.findOne({ name }),
+)
+
+const update = async (name, value, unit) => enhance(
+	await Constant.findOneAndUpdate({
+		name,
+	}, {
+		$set: {
+			updated: Date.now(),
+			value,
+			unit,
+		},
+	}, {
+		new: true,
+		upsert: true,
+	}),
+)
+
+module.exports = {
+	get,
+	update,
+}

src/constants/durations.js

@@ -0,0 +1,38 @@
+'use strict'
+
+const mongoose = require('mongoose')
+const uuid = require('crypto').randomUUID
+
+const schema = new mongoose.Schema({
+	id: {
+		type: String,
+		required: true,
+		unique: true,
+		default: () => uuid(),
+	},
+	created: {
+		type: Date,
+		required: true,
+		default: Date.now,
+	},
+	updated: {
+		type: Date,
+		required: true,
+		default: Date.now,
+	},
+	name: {
+		type: String,
+		required: true,
+		unique: true,
+	},
+	value: {
+		type: Number,
+		required: true,
+	},
+	unit: {
+		type: String,
+		required: true,
+	},
+})
+
+module.exports = mongoose.model('Constant', schema)

src/database/constants.js

@@ -0,0 +1,53 @@
+const { DURATIONS_INTERVAL, DURATIONS_LIMIT } = require('../constants/durations')
+const constants = require('../database/constants')
+const requireAuth = require('../middlewares/requireAuth')
+const pipe = require('../utils/pipe')
+
+const response = (entry) => ({
+	created: entry.created,
+	updated: entry.updated,
+	id: entry.name,
+	value: entry.value,
+	unit: entry.unit,
+})
+
+const toApi = ({ name, ...data }) => ({
+	...data,
+	id: name,
+})
+const interval = async () => {
+	const name = 'DURATIONS_INTERVAL'
+	return toApi(await constants.get(name) || {
+		name,
+		value: DURATIONS_INTERVAL,
+		unit: 'seconds',
+	})
+}
+const limit = async () => {
+	const name = 'DURATIONS_LIMIT'
+	return toApi(await constants.get(name) || {
+		name,
+		value: DURATIONS_LIMIT,
+		unit: 'minutes',
+	})
+}
+
+module.exports = {
+	Query: {
+		constants: pipe(requireAuth, async () => ({
+			durationsInterval: await interval(),
+			durationsLimit: await limit(),
+		})),
+	},
+	Mutation: {
+		setConstant: pipe(requireAuth, async (parent, { input }) => {
+			const { id, value, unit } = input
+
+			const entry = await constants.update(id, value, unit)
+			return {
+				success: true,
+				payload: response(entry),
+			}
+		}),
+	},
+}

src/models/Constant.js

@@ -5,6 +5,7 @@ const { mergeResolvers } = require('@graphql-tools/merge')
 module.exports = mergeResolvers([
 	require('./tokens'),
 	require('./permanentTokens'),
+	require('./contants'),
 	require('./records'),
 	require('./domains'),
 	require('./events'),