fix(profile-editor): rebuild backend W3DS-native — read from AaaS, write to eVault

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}

infrastructure/web3-adapter/src/index.ts

@@ -8,6 +8,13 @@ import { logger } from "./logging";
 import { fromGlobal, toGlobal } from "./mapper/mapper";
 import type { IMapping } from "./mapper/mapper.types";
 
+export { EVaultClient } from "./evault/evault";
+export type {
+	MetaEnvelope,
+	UploadFileInput,
+	UploadFileResult,
+} from "./evault/evault";
+
 /**
  * Standalone function to spin up an eVault
  * @param registryUrl - URL of the registry service

platforms/profile-editor/api/nodemon.json

@@ -0,0 +1,6 @@
+{
+	"watch": ["src"],
+	"ext": "ts,json",
+	"ignore": ["src/**/*.spec.ts"],
+	"exec": "ts-node src/index.ts"
+}

platforms/profile-editor/api/package.json

@@ -1,42 +1,31 @@
 {
 	"name": "profile-editor-api",
 	"version": "1.0.0",
-	"description": "Profile Editor API for the w3ds ecosystem",
+	"description": "W3DS-native Profile Editor API: reads from AaaS, writes to eVault",
 	"main": "src/index.ts",
 	"scripts": {
  "start": "ts-node src/index.ts",
  "dev": "nodemon --exec ts-node src/index.ts",
- "build": "tsc && cp -r src/web3adapter/mappings dist/web3adapter/",
- "typeorm": "typeorm-ts-node-commonjs",
- "migration:generate": "bash -c 'read -p \"Migration name: \" name && npx typeorm-ts-node-commonjs migration:generate src/database/migrations/$name -d src/database/data-source.ts'",
- "migration:run": "npm run typeorm migration:run -- -d src/database/data-source.ts",
- "migration:revert": "npm run typeorm migration:revert -- -d src/database/data-source.ts"
+ "build": "tsc"
 	},
 	"dependencies": {
  "@metastate-foundation/auth": "workspace:*",
  "axios": "^1.6.7",
  "cors": "^2.8.5",
  "dotenv": "^16.4.5",
  "express": "^4.18.2",
- "form-data": "^4.0.5",
- "graphql-request": "^6.1.0",
+ "form-data": "^4.0.0",
  "jsonwebtoken": "^9.0.3",
  "multer": "^2.1.1",
- "pg": "^8.20.0",
- "reflect-metadata": "^0.2.2",
- "signature-validator": "workspace:*",
  "web3-adapter": "workspace:*",
- "typeorm": "^0.3.28",
- "uuid": "^9.0.1"
+ "zod": "^3.23.8"
 	},
 	"devDependencies": {
  "@types/cors": "^2.8.17",
  "@types/express": "^4.17.21",
  "@types/jsonwebtoken": "^9.0.10",
  "@types/multer": "^2.1.0",
  "@types/node": "^20.11.24",
- "@types/pg": "^8.18.0",
- "@types/uuid": "^9.0.8",
  "nodemon": "^3.0.3",
  "ts-node": "^10.9.2",
  "typescript": "^5.3.3"

platforms/profile-editor/api/src/aaas.ts

@@ -0,0 +1,121 @@
+import axios from "axios";
+import { env } from "./env";
+import {
+ type Payload,
+ PROFESSIONAL_PROFILE_ONTOLOGY,
+ USER_ONTOLOGY,
+} from "./ontology";
+
+/** A single packet as returned by AaaS `GET /api/packets`. */
+export interface Packet {
+ id: string;
+ ontology: string;
+ w3id: string | null;
+ data: Payload | null;
+ receivedAt: string;
+}
+
+interface PacketsResponse {
+ packets: Packet[];
+ hasMore: boolean;
+ nextCursor: string | null;
+}
+
+/** The current envelope (id + payload) for one ontology. */
+export interface EnvelopeState {
+ id: string;
+ data: Payload;
+}
+
+/**
+ * Read side of the W3DS-native profile editor: everything is pulled from
+ * Awareness-as-a-Service. Each MetaEnvelope maps to exactly one packet (AaaS
+ * upserts by envelope id), so filtering by eVault + ontology yields the current
+ * state.
+ */
+export class AaasClient {
+ private base = env.awarenessServiceUrl.replace(/\/$/, "");
+ private headers = { Authorization: `Bearer ${env.awarenessApiKey}` };
+
+ /** One page of packets for the given filters. */
+ private async page(
+ params: Record<string, string | number>,
+ cursor?: string | null,
+ ): Promise<PacketsResponse> {
+ const { data } = await axios.get<PacketsResponse>(
+ `${this.base}/api/packets`,
+ {
+ headers: this.headers,
+ params: { limit: 200, ...params, ...(cursor ? { cursor } : {}) },
+ timeout: 15000,
+ },
+ );
+ return data;
+ }
+
+ /** Every packet matching the filters, paged to exhaustion (newest last). */
+ private async all(
+ params: Record<string, string | number>,
+ ): Promise<Packet[]> {
+ const out: Packet[] = [];
+ let cursor: string | null | undefined;
+ do {
+ const res = await this.page(params, cursor);
+ out.push(...(res.packets ?? []));
+ cursor = res.hasMore ? res.nextCursor : null;
+ } while (cursor);
+ return out;
+ }
+
+ /** Latest envelope state per ontology for a single eVault (by eName). */
+ async getProfileEnvelopes(ename: string): Promise<{
+ user: EnvelopeState | null;
+ professional: EnvelopeState | null;
+ }> {
+ const packets = await this.all({
+ evault: ename,
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ // Packets are ordered oldest→newest, so the last write wins.
+ let user: EnvelopeState | null = null;
+ let professional: EnvelopeState | null = null;
+ for (const p of packets) {
+ if (!p.data) continue;
+ if (p.ontology === USER_ONTOLOGY) {
+ user = { id: p.id, data: p.data };
+ } else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ professional = { id: p.id, data: p.data };
+ }
+ }
+ return { user, professional };
+ }
+
+ /**
+ * All User + Professional-Profile envelopes across every eVault, keyed by
+ * eName — the cross-user source for discovery (no single eVault has them).
+ */
+ async listAllProfiles(): Promise<
+ Map<string, { user: Payload | null; professional: Payload | null }>
+ > {
+ const packets = await this.all({
+ ontology: `${USER_ONTOLOGY},${PROFESSIONAL_PROFILE_ONTOLOGY}`,
+ });
+
+ const byEname = new Map<
+ string,
+ { user: Payload | null; professional: Payload | null }
+ >();
+ for (const p of packets) {
+ const ename = p.w3id ?? (p.data?.ename as string | undefined);
+ if (!ename || !p.data) continue;
+ const entry = byEname.get(ename) ?? { user: null, professional: null };
+ if (p.ontology === USER_ONTOLOGY) entry.user = p.data;
+ else if (p.ontology === PROFESSIONAL_PROFILE_ONTOLOGY) {
+ entry.professional = p.data;
+ }
+ byEname.set(ename, entry);
+ }
+ return byEname;
+ }
+}