mem0 MCP Server
by sadiuysal
action-matcher.js•9.94 kB
var __values = (this && this.__values) || function(o) {
var s = typeof Symbol === "function" && Symbol.iterator, m = s && o[s], i = 0;
if (m) return m.call(o);
if (o && typeof o.length === "number") return {
next: function () {
if (o && i >= o.length) o = void 0;
return { value: o && o[i++], done: !o };
}
};
throw new TypeError(s ? "Object is not iterable." : "Symbol.iterator is not defined.");
};
import { SimpleEventEmitter } from '../../utils/simple-event-emitter';
import { isUndefined } from '../../utils/type-utils';
import { window } from '../../utils/globals';
import { isMatchingRegex } from '../../utils/regex-utils';
var ActionMatcher = /** @class */ (function () {
function ActionMatcher(instance) {
var _this = this;
this._debugEventEmitter = new SimpleEventEmitter();
this.checkStep = function (event, step) {
return _this.checkStepEvent(event, step) && _this.checkStepUrl(event, step) && _this.checkStepElement(event, step);
};
this.checkStepEvent = function (event, step) {
// CHECK CONDITIONS, OTHERWISE SKIPPED
if ((step === null || step === void 0 ? void 0 : step.event) && (event === null || event === void 0 ? void 0 : event.event) !== (step === null || step === void 0 ? void 0 : step.event)) {
return false; // EVENT NAME IS A MISMATCH
}
return true;
};
this.instance = instance;
this.actionEvents = new Set();
this.actionRegistry = new Set();
}
ActionMatcher.prototype.init = function () {
var _this = this;
var _a, _b;
if (!isUndefined((_a = this.instance) === null || _a === void 0 ? void 0 : _a._addCaptureHook)) {
var matchEventToAction = function (eventName, eventPayload) {
_this.on(eventName, eventPayload);
};
(_b = this.instance) === null || _b === void 0 ? void 0 : _b._addCaptureHook(matchEventToAction);
}
};
ActionMatcher.prototype.register = function (actions) {
var _this = this;
var _a, _b, _c;
if (isUndefined((_a = this.instance) === null || _a === void 0 ? void 0 : _a._addCaptureHook)) {
return;
}
actions.forEach(function (action) {
var _a, _b;
(_a = _this.actionRegistry) === null || _a === void 0 ? void 0 : _a.add(action);
(_b = action.steps) === null || _b === void 0 ? void 0 : _b.forEach(function (step) {
var _a;
(_a = _this.actionEvents) === null || _a === void 0 ? void 0 : _a.add((step === null || step === void 0 ? void 0 : step.event) || '');
});
});
if ((_b = this.instance) === null || _b === void 0 ? void 0 : _b.autocapture) {
var selectorsToWatch_1 = new Set();
actions.forEach(function (action) {
var _a;
(_a = action.steps) === null || _a === void 0 ? void 0 : _a.forEach(function (step) {
if (step === null || step === void 0 ? void 0 : step.selector) {
selectorsToWatch_1.add(step === null || step === void 0 ? void 0 : step.selector);
}
});
});
(_c = this.instance) === null || _c === void 0 ? void 0 : _c.autocapture.setElementSelectors(selectorsToWatch_1);
}
};
ActionMatcher.prototype.on = function (eventName, eventPayload) {
var _this = this;
var _a;
if (eventPayload == null || eventName.length == 0) {
return;
}
if (!this.actionEvents.has(eventName) && !this.actionEvents.has(eventPayload === null || eventPayload === void 0 ? void 0 : eventPayload.event)) {
return;
}
if (this.actionRegistry && ((_a = this.actionRegistry) === null || _a === void 0 ? void 0 : _a.size) > 0) {
this.actionRegistry.forEach(function (action) {
if (_this.checkAction(eventPayload, action)) {
_this._debugEventEmitter.emit('actionCaptured', action.name);
}
});
}
};
ActionMatcher.prototype._addActionHook = function (callback) {
this.onAction('actionCaptured', function (data) { return callback(data); });
};
ActionMatcher.prototype.checkAction = function (event, action) {
var e_1, _a;
if ((action === null || action === void 0 ? void 0 : action.steps) == null) {
return false;
}
try {
for (var _b = __values(action.steps), _c = _b.next(); !_c.done; _c = _b.next()) {
var step = _c.value;
if (this.checkStep(event, step)) {
return true;
}
}
}
catch (e_1_1) { e_1 = { error: e_1_1 }; }
finally {
try {
if (_c && !_c.done && (_a = _b.return)) _a.call(_b);
}
finally { if (e_1) throw e_1.error; }
}
return false;
};
ActionMatcher.prototype.onAction = function (event, cb) {
return this._debugEventEmitter.on(event, cb);
};
ActionMatcher.prototype.checkStepUrl = function (event, step) {
var _a;
// CHECK CONDITIONS, OTHERWISE SKIPPED
if (step === null || step === void 0 ? void 0 : step.url) {
var eventUrl = (_a = event === null || event === void 0 ? void 0 : event.properties) === null || _a === void 0 ? void 0 : _a.$current_url;
if (!eventUrl || typeof eventUrl !== 'string') {
return false; // URL IS UNKNOWN
}
if (!ActionMatcher.matchString(eventUrl, step === null || step === void 0 ? void 0 : step.url, (step === null || step === void 0 ? void 0 : step.url_matching) || 'contains')) {
return false; // URL IS A MISMATCH
}
}
return true;
};
ActionMatcher.matchString = function (url, pattern, matching) {
switch (matching) {
case 'regex':
return !!window && isMatchingRegex(url, pattern);
case 'exact':
return pattern === url;
case 'contains':
// Simulating SQL LIKE behavior (_ = any single character, % = any zero or more characters)
// eslint-disable-next-line no-case-declarations
var adjustedRegExpStringPattern = ActionMatcher.escapeStringRegexp(pattern)
.replace(/_/g, '.')
.replace(/%/g, '.*');
return isMatchingRegex(url, adjustedRegExpStringPattern);
default:
return false;
}
};
ActionMatcher.escapeStringRegexp = function (pattern) {
// Escape characters with special meaning either inside or outside character sets.
// Use a simple backslash escape when it’s always valid, and a `\xnn` escape when the simpler form would be disallowed by Unicode patterns’ stricter grammar.
return pattern.replace(/[|\\{}()[\]^$+*?.]/g, '\\$&').replace(/-/g, '\\x2d');
};
ActionMatcher.prototype.checkStepElement = function (event, step) {
var _a;
// CHECK CONDITIONS, OTHERWISE SKIPPED
if ((step === null || step === void 0 ? void 0 : step.href) || (step === null || step === void 0 ? void 0 : step.tag_name) || (step === null || step === void 0 ? void 0 : step.text)) {
var elements = this.getElementsList(event);
if (!elements.some(function (element) {
if ((step === null || step === void 0 ? void 0 : step.href) &&
!ActionMatcher.matchString(element.href || '', step === null || step === void 0 ? void 0 : step.href, (step === null || step === void 0 ? void 0 : step.href_matching) || 'exact')) {
return false; // ELEMENT HREF IS A MISMATCH
}
if ((step === null || step === void 0 ? void 0 : step.tag_name) && element.tag_name !== (step === null || step === void 0 ? void 0 : step.tag_name)) {
return false; // ELEMENT TAG NAME IS A MISMATCH
}
if ((step === null || step === void 0 ? void 0 : step.text) &&
!(ActionMatcher.matchString(element.text || '', step === null || step === void 0 ? void 0 : step.text, (step === null || step === void 0 ? void 0 : step.text_matching) || 'exact') ||
ActionMatcher.matchString(element.$el_text || '', step === null || step === void 0 ? void 0 : step.text, (step === null || step === void 0 ? void 0 : step.text_matching) || 'exact'))) {
return false; // ELEMENT TEXT IS A MISMATCH
}
return true;
})) {
// AT LEAST ONE ELEMENT MUST BE A SUBMATCH
return false;
}
}
if (step === null || step === void 0 ? void 0 : step.selector) {
var elementSelectors = (_a = event === null || event === void 0 ? void 0 : event.properties) === null || _a === void 0 ? void 0 : _a.$element_selectors;
if (!elementSelectors) {
return false; // SELECTOR IS A MISMATCH
}
if (!elementSelectors.includes(step === null || step === void 0 ? void 0 : step.selector)) {
return false; // SELECTOR IS A MISMATCH
}
}
return true;
};
ActionMatcher.prototype.getElementsList = function (event) {
if ((event === null || event === void 0 ? void 0 : event.properties.$elements) == null) {
return [];
}
return event === null || event === void 0 ? void 0 : event.properties.$elements;
};
return ActionMatcher;
}());
export { ActionMatcher };
//# sourceMappingURL=action-matcher.js.map
Latest Blog Posts
- MCP Moves to the Linux Foundation: Neutral Stewardship for Agentic InfrastructureBy Om-Shree-0709 on .mcpanthropicLinux Foundation
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/sadiuysal/mem0-mcp-server-ts'
If you have feedback or need assistance with the MCP directory API, please join our Discord server