Feature/integrate xp api: GetXpUserMeta

.vscode/settings.json

@@ -57,12 +57,14 @@
     "editor.insertSpaces": true,
     "editor.tabSize": 4,
     "editor.detectIndentation": false,
+    "javascript.preferences.importModuleSpecifier": "relative",
     "javascript.preferences.quoteStyle": "single",
     "typescript.preferences.quoteStyle": "single",
     "workbench.colorCustomizations": {},
     "deno.enable": false,
     "jest.autoEnable": false,
     "typescript.tsdk": "node_modules\\typescript\\lib",
     "typescript.tsserver.maxTsServerMemory": 8192,
-    "jest.autoRun": "off"
+    "jest.autoRun": "off",
+    "cSpell.words": ["KASP"]
 }

docker/conf/redis.conf

@@ -0,0 +1,2 @@
+bind 0.0.0.0 ::
+protected-mode no

docker/docker-compose.dev.yml

@@ -37,7 +37,9 @@ services:
             - '6379:6379'
         networks:
             - enable_ipv6
-        command: ['redis-server', '--bind', '0.0.0.0', '::']
+        volumes:
+            - ./conf/redis.conf:/etc/redis.conf
+        command: ['redis-server', '/etc/redis.conf']
     livekit:
         image: livekit/livekit-server:v1.8.0
         restart: always

jakefile.js

@@ -78,7 +78,7 @@ task('generate-stub-projects', [], async function () {
     const { existsSync, writeFileSync, mkdirSync } = await import('fs');
 
     const projects = [
-        path.resolve(__dirname, 'xpexchange', 'xp-api', 'tsconfig.json'),
+        path.resolve(__dirname, 'xpexchange', 'tsconfig.json'),
         path.resolve(
             __dirname,
             'extensions',

src/aux-records/MemoryStore.ts

@@ -1,5 +1,5 @@
 import { cloneDeep, orderBy, sortBy } from 'lodash';
-import { RegexRule } from './Utils';
+import { cloneDeepNull, RegexRule } from './Utils';
 import {
     AddressType,
     AuthInvoice,
@@ -149,6 +149,15 @@ import {
 } from './SystemNotificationMessenger';
 import { ModerationConfiguration } from './ModerationConfiguration';
 import { uniq } from 'lodash';
+import {
+    XpAccount,
+    XpAccountEntry,
+    XpContract,
+    XpInvoice,
+    XpStore,
+    XpUser,
+} from './XpStore';
+import { SuccessResult } from './TypeUtils';
 
 export interface MemoryConfiguration {
     subscriptions: SubscriptionConfiguration;
@@ -168,7 +177,8 @@ export class MemoryStore
         ConfigurationStore,
         InstRecordsStore,
         ModerationStore,
-        SystemNotificationMessenger
+        SystemNotificationMessenger,
+        XpStore
 {
     private _users: AuthUser[] = [];
     private _userAuthenticators: AuthUserAuthenticator[] = [];
@@ -213,6 +223,13 @@ export class MemoryStore
     private _studioLoomConfigs: Map<string, LoomConfig> = new Map();
     private _studioHumeConfigs: Map<string, HumeConfig> = new Map();
 
+    private _xpUsers: Map<XpUser['id'], XpUser> = new Map();
+    private _xpAccounts: Map<XpAccount['id'], XpAccount> = new Map();
+    private _xpContracts: Map<XpContract['id'], XpContract> = new Map();
+    private _xpInvoices: Map<XpInvoice['id'], XpInvoice> = new Map();
+    private _xpAccountEntries: Map<XpAccountEntry['id'], XpAccountEntry> =
+        new Map();
+
     // TODO: Support global permissions
     // private _globalPermissionAssignments: GlobalPermissionAssignment[] = [];
 
@@ -351,6 +368,69 @@ export class MemoryStore
         this.roleAssignments = {};
     }
 
+    async saveXpAccount(
+        associationId: XpUser['id'] | XpContract['id'],
+        account: XpAccount
+    ): Promise<SuccessResult> {
+        this._xpAccounts.set(associationId, account);
+        return {
+            success: true,
+        };
+    }
+
+    async saveXpUserWithAccount(user: XpUser, account: XpAccount) {
+        this._xpUsers.set(user.id, user);
+        this._xpAccounts.set(account.id, account);
+    }
+
+    async saveXpUser(id: XpUser['id'], user: XpUser): Promise<SuccessResult> {
+        this._xpUsers.set(id, user);
+        return {
+            success: true,
+        };
+    }
+
+    async saveXpContract(
+        contract: XpContract,
+        account: XpAccount | null
+    ): Promise<void> {
+        this._xpContracts.set(contract.id, contract);
+        if (account !== null) {
+            this._xpAccounts.set(account.id, account);
+        }
+    }
+
+    async getXpUserByAuthId(id: AuthUser['id']): Promise<XpUser> {
+        const user = Array.from(this._xpUsers.values()).find(
+            (u: XpUser) => u.userId === id
+        );
+        return cloneDeepNull(user ?? undefined);
+    }
+
+    async getXpUserById(id: XpUser['id']): Promise<XpUser> {
+        return cloneDeep(this._xpUsers.get(id) ?? undefined);
+    }
+
+    async getXpAccount(
+        associationId: XpUser['id'] | XpContract['id']
+    ): Promise<XpAccount> {
+        return cloneDeepNull(this._xpAccounts.get(associationId) ?? undefined);
+    }
+
+    async getXpAccountEntry(
+        entryId: XpAccountEntry['id']
+    ): Promise<XpAccountEntry> {
+        return cloneDeepNull(this._xpAccountEntries.get(entryId) ?? undefined);
+    }
+
+    async getXpContract(contractId: XpContract['id']): Promise<XpContract> {
+        return cloneDeepNull(this._xpContracts.get(contractId) ?? undefined);
+    }
+
+    async getXpInvoice(invoiceId: XpInvoice['id']): Promise<XpInvoice> {
+        return cloneDeepNull(this._xpInvoices.get(invoiceId) ?? undefined);
+    }
+
     init?(): Promise<void>;
 
     /**