Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
50 commits
Select commit Hold shift + click to select a range
979bbf8
adds support to handle out of order events arriving in the RSP Engine.
argahsuknesib Jul 1, 2024
c97999b
feat: Add max_delay configuration to log_config.json and use it in RS…
argahsuknesib Jul 1, 2024
d7d2ce6
printing the size of the window.
argahsuknesib Jul 2, 2024
f9bce4e
reusing windows.
argahsuknesib Jul 2, 2024
f348263
added watermarking and support for OnContentChange report strategy
argahsuknesib Jul 3, 2024
5ff3119
checking if the window data is defined or not.
argahsuknesib Jul 3, 2024
b403676
removing window emit from check_watermark function.
argahsuknesib Jul 3, 2024
94b6f53
trying a fix to remove multiple window triggers.
argahsuknesib Jul 3, 2024
8a619b8
This reverts commit b4036767f4a3da14d36595f2b524866ce79ebea3 and adds…
argahsuknesib Jul 4, 2024
c9026a3
adds watermarking with a failing test for triggering the window.
argahsuknesib Jul 4, 2024
0993670
fixed the bug related to triggering of the window and added tests.
argahsuknesib Jul 5, 2024
c7c7f4a
adds 2 more tests in rsp.test.js for OOO.
argahsuknesib Jul 5, 2024
eb79221
feat: Add CSPARQLWindow to log_config.json and IntervalManager class
argahsuknesib Jul 9, 2024
a45b097
refactor: Improve CSPARQLWindow class and add watermarking support
argahsuknesib Jul 9, 2024
ab20f38
refactor: Improve CSPARQLWindow class and add lazy loading support
argahsuknesib Jul 9, 2024
5542b69
refactor: Improve CSPARQLWindow class and add support for max delay a…
argahsuknesib Jul 9, 2024
d1e592f
refactor: Improve CSPARQLWindow class and add support for max delay a…
argahsuknesib Jul 9, 2024
8920599
refactor: Improve CSPARQLWindow class and add support for max delay a…
argahsuknesib Jul 9, 2024
dfaf984
refactor: Improve CSPARQLWindow class and add support for max delay a…
argahsuknesib Jul 10, 2024
19834d7
added logging of the triggering window to show the length of the quad…
argahsuknesib Jul 10, 2024
aeb6c82
refactor: Add conditional check for content length before triggering …
argahsuknesib Jul 10, 2024
cdb9517
refactor: Add conditional check for content length before triggering …
argahsuknesib Jul 10, 2024
18889e5
refactor: Add conditional check for content length before triggering …
argahsuknesib Jul 12, 2024
8a0060e
```text
argahsuknesib Aug 20, 2024
d0c5516
refactor: Add conditional check for content length before triggering …
argahsuknesib Aug 20, 2024
8b0ec87
refactor: Remove unused test files and dependencies
argahsuknesib Aug 26, 2024
5c28a38
refactor: Add conditional check for content length before triggering …
argahsuknesib Aug 26, 2024
ba857fc
refactor: Add event counter and throughput logging to CSPARQLWindow c…
argahsuknesib Aug 28, 2024
6ac26cd
refactor: Add computeWindowIfAbsent function to CSPARQLWindow class
argahsuknesib Aug 29, 2024
ccf1c49
refactor: Add conditional check for content length before triggering …
argahsuknesib Sep 2, 2024
245f430
refactor: Add conditional check for content length before triggering …
argahsuknesib Sep 3, 2024
26a0188
fixed the tests
argahsuknesib Sep 3, 2024
28afbe0
refactor: Add conditional check for content length before triggering …
argahsuknesib Sep 3, 2024
4da86a2
refactor: Add conditional check for content length before triggering …
argahsuknesib Sep 3, 2024
c18f54a
Refactor logger messages in RSPEngine and CSPARQLWindow classes
argahsuknesib Sep 10, 2024
1d1a8ac
Refactor the Logger Class.
argahsuknesib Oct 4, 2024
4fab907
added few extra tests to confirm the experimental behaviour is rsp-js…
argahsuknesib Oct 8, 2024
9ca9fee
fixed the conditional bug for adding the in order events with timesta…
argahsuknesib Oct 8, 2024
bb1d692
updated the package.json's version
argahsuknesib Oct 8, 2024
4847d56
Refactor logger messages in RSPEngine and CSPARQLWindow classes
argahsuknesib Oct 21, 2024
acad00c
edited the logger and added logging to each bounds
argahsuknesib Oct 30, 2024
8179f05
edited the package.json
argahsuknesib Oct 30, 2024
83f5a66
added an extra log for the window trigger
argahsuknesib Oct 31, 2024
e2f5efe
Add log_enabled option to RSPEngine constructor
argahsuknesib Nov 13, 2024
22f1602
Bump version to 2.3.0 in package.json
argahsuknesib Nov 13, 2024
25e0c4e
Bump version to 2.4.0 and enable logging by default in RSPEngine
argahsuknesib Nov 13, 2024
cca6622
removed the logger in the rsp.js constructor
argahsuknesib Nov 20, 2024
d43c7e0
fixed the window delete logic
argahsuknesib Nov 20, 2024
15e4c02
added trigger boolean logic
argahsuknesib Nov 25, 2024
5dac00c
Enhance R2ROperator with logging capabilities and refactor scope calc…
argahsuknesib Jul 31, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
73 changes: 73 additions & 0 deletions .eslintrc.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
module.exports = {
root: true,
env: {node: true, es2020: true, jest: true},
extends: [
'eslint:recommended'
],
ignorePatterns: ['dist', '.eslintrc.cjs', 'tests'],
parserOptions: {ecmaVersion: 'latest', sourceType: 'module'},
parser: '@typescript-eslint/parser',
plugins: ['jsdoc', 'jest'],
rules: {
'prefer-const': ['error', {
'destructuring': 'any',
'ignoreReadBeforeAssign': false
}],
// 'no-multiple-empty-lines': ['error',
// {'max': 1, 'maxEOF': 0}
// ],
// 'indent': ['error', 2],
// 'semi': ['error', 'always'],
// 'camelcase': 'error',
// 'quotes': ['error', 'single', { 'avoidEscape': true }],
'jsdoc/check-access': 1, // Recommended
'jsdoc/check-alignment': 1, // Recommended
// 'jsdoc/check-examples': 1,
// 'jsdoc/check-indentation': 1,
// 'jsdoc/check-line-alignment': 1,
'jsdoc/check-param-names': 1, // Recommended
'jsdoc/check-property-names': 1, // Recommended
// 'jsdoc/check-syntax': 1,
'jsdoc/check-tag-names': 1, // Recommended
'jsdoc/check-types': 1, // Recommended
'jsdoc/check-values': 1, // Recommended
'jsdoc/empty-tags': 1, // Recommended
'jsdoc/implements-on-classes': 1, // Recommended
// 'jsdoc/informative-docs': 1,
// 'jsdoc/match-description': 1,
'jsdoc/multiline-blocks': 1, // Recommended
// 'jsdoc/no-bad-blocks': 1,
// 'jsdoc/no-blank-block-descriptions': 1,
// 'jsdoc/no-defaults': 1,
// 'jsdoc/no-missing-syntax': 1,
'jsdoc/no-multi-asterisks': 1, // Recommended
// 'jsdoc/no-restricted-syntax': 1,
// 'jsdoc/no-types': 1,
'jsdoc/no-undefined-types': 1, // Recommended
// 'jsdoc/require-asterisk-prefix': 1,
'jsdoc/require-description': 1,
'jsdoc/require-description-complete-sentence': 1,
// 'jsdoc/require-example': 1,
// 'jsdoc/require-file-overview': 1,
'jsdoc/require-hyphen-before-param-description': 1,
'jsdoc/require-jsdoc': [1, { contexts: ['ClassDeclaration', 'ClassProperty', 'FunctionDeclaration', 'MethodDefinition'] }],
'jsdoc/require-param': 1, // Recommended
'jsdoc/require-param-description': 1, // Recommended
'jsdoc/require-param-name': 1, // Recommended
'jsdoc/require-param-type': 1, // Recommended
'jsdoc/require-property': 1, // Recommended
'jsdoc/require-property-description': 1, // Recommended
'jsdoc/require-property-name': 1, // Recommended
'jsdoc/require-property-type': 1, // Recommended
'jsdoc/require-returns': 1, // Recommended
'jsdoc/require-returns-check': 1, // Recommended
'jsdoc/require-returns-description': 1, // Recommended
'jsdoc/require-returns-type': 1, // Recommended
// 'jsdoc/require-throws': 1,
'jsdoc/require-yields': 1, // Recommended
'jsdoc/require-yields-check': 1, // Recommended
// 'jsdoc/sort-tags': 1,
'jsdoc/tag-lines': 1, // Recommended
'jsdoc/valid-types': 1 // Recommended
},
}
2 changes: 2 additions & 0 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -104,3 +104,5 @@ typings/

# TernJS port file
.tern-port

# Removing the build directory
49 changes: 49 additions & 0 deletions config.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
{
"@context": "https://linkedsoftwaredependencies.org/bundles/npm/@solid/community-server/^7.0.0/components/context.jsonld",
"import": [
"css:config/app/init/static-root.json",
"css:config/app/main/default.json",
"css:config/app/variables/default.json",
"css:config/http/handler/default.json",
"css:config/http/middleware/default.json",
"css:config/http/notifications/webhooks.json",
"css:config/http/server-factory/http.json",
"css:config/http/static/default.json",
"css:config/identity/access/public.json",
"css:config/identity/email/default.json",
"css:config/identity/handler/default.json",
"css:config/identity/oidc/default.json",
"css:config/identity/ownership/token.json",
"css:config/identity/pod/static.json",
"css:config/ldp/authentication/dpop-bearer.json",
"css:config/ldp/authorization/allow-all.json",
"css:config/ldp/handler/default.json",
"css:config/ldp/metadata-parser/default.json",
"css:config/ldp/metadata-writer/default.json",
"css:config/ldp/modes/default.json",
"css:config/storage/backend/file.json",
"css:config/storage/key-value/resource-store.json",
"css:config/storage/location/pod.json",
"css:config/storage/middleware/default.json",
"css:config/util/auxiliary/empty.json",
"css:config/util/identifiers/suffix.json",
"css:config/util/index/default.json",
"css:config/util/logging/winston.json",
"css:config/util/representation-conversion/default.json",
"css:config/util/resource-locker/redis.json",
"css:config/util/variables/default.json"
],
"@graph": [
{
"comment": "The new expiration time for inactive locks, in milliseconds.",
"@type": "Override",
"overrideInstance": {
"@id": "urn:solid-server:default:ResourceLocker"
},
"overrideParameters": {
"@type": "WrappedExpiringReadWriteLocker",
"expiration": 180000
}
}
]
}
4 changes: 0 additions & 4 deletions dist/index.d.ts

This file was deleted.

22 changes: 0 additions & 22 deletions dist/index.js

This file was deleted.

9 changes: 0 additions & 9 deletions dist/operators/r2r.d.ts

This file was deleted.

41 changes: 0 additions & 41 deletions dist/operators/r2r.js

This file was deleted.

1 change: 0 additions & 1 deletion dist/operators/r2r.test.d.ts

This file was deleted.

36 changes: 0 additions & 36 deletions dist/operators/r2r.test.js

This file was deleted.

46 changes: 0 additions & 46 deletions dist/operators/s2r.d.ts

This file was deleted.

Loading
Loading