chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
coodos merged 8 commits into from
Jun 2, 2025
+8,819 −6,444
Merged

chore: change from nomad to k8s #179

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
d3276cb
chore: change from nomad to k8s
coodos Jun 2, 2025
bd73cc5
Update infrastructure/eid-wallet/src/routes/+layout.svelte
coodos Jun 2, 2025
1c41f4d
feat: uri extraction
coodos Jun 2, 2025
e24b745
feat: regitry stuff
coodos Jun 2, 2025
c817701
feat: registry using local db
coodos Jun 2, 2025
6d6a0cf
📝 Add docstrings to `feat/switch-to-k8s` (#181)
coderabbitai[bot] Jun 2, 2025
f29d510
chore: format
coodos Jun 2, 2025
518d2ef
Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…
coodos Jun 2, 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
4 changes: 2 additions & 2 deletions infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
CODE_SIGN_IDENTITY = "iPhone Developer";
DEVELOPMENT_TEAM = 7F2T2WK6DR;
DEVELOPMENT_TEAM = 3FS4B734X5;
ENABLE_BITCODE = NO;
"EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
"EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
CODE_SIGN_IDENTITY = "iPhone Developer";
DEVELOPMENT_TEAM = 7F2T2WK6DR;
DEVELOPMENT_TEAM = 3FS4B734X5;
ENABLE_BITCODE = NO;
"EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
"EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down
46 changes: 39 additions & 7 deletions infrastructure/eid-wallet/src/routes/+layout.svelte
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
showSplashScreen = false;
});

const safeAreaTop = $derived.by(
() =>
Number.parseFloat(
getComputedStyle(document.documentElement).getPropertyValue(
"--safe-top",
),
) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
<SplashScreen />
{:else}
<div class="bg-white h-[100dvh] overflow-scroll">
{@render children?.()}
</div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
{#if showSplashScreen}
<SplashScreen />
{:else}
<div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
{@render children?.()}
</div>
{/if}
</main>

<style>
:root {
--safe-bottom: env(safe-area-inset-bottom);
--safe-top: env(safe-area-inset-top);
}

:global(body), * {
-webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
scrollbar-width: none; /* Firefox */
-ms-overflow-style: none; /* IE 10+ */
}

/* Hide scrollbar for WebKit (Chrome, Safari) */
:global(body::-webkit-scrollbar),
*::-webkit-scrollbar {
display: none;
}
</style>
159 changes: 84 additions & 75 deletions infrastructure/evault-core/src/evault.ts
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
FastifyInstance,
FastifyRequest,
FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
server: FastifyInstance;
graphqlServer: GraphQLServer;
logService: LogService;
driver: Driver;

constructor() {
const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
const user = process.env.NEO4J_USER || "neo4j";
const password = process.env.NEO4J_PASSWORD || "neo4j";

if (
!process.env.NEO4J_URI ||
!process.env.NEO4J_USER ||
!process.env.NEO4J_PASSWORD
) {
console.warn(
"Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
);
server: FastifyInstance;
graphqlServer: GraphQLServer;
logService: LogService;
driver: Driver;

constructor() {
const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
const user = process.env.NEO4J_USER || "neo4j";
const password = process.env.NEO4J_PASSWORD || "neo4j";

if (
!process.env.NEO4J_URI ||
!process.env.NEO4J_USER ||
!process.env.NEO4J_PASSWORD
) {
console.warn(
"Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
);
}

this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

const dbService = new DbService(this.driver);
this.logService = new LogService(this.driver);
this.graphqlServer = new GraphQLServer(dbService);

this.server = fastify({
logger: true,
});
}

this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

const dbService = new DbService(this.driver);
this.logService = new LogService(this.driver);
this.graphqlServer = new GraphQLServer(dbService);

this.server = fastify({
logger: true,
});
}

async initialize() {
await registerHttpRoutes(this.server);

const w3id = await W3ID.get({
id: process.env.W3ID as string,
driver: this.driver,
password: process.env.ENCRYPTION_PASSWORD,
});

const yoga = this.graphqlServer.init();

this.server.route({
// Bind to the Yoga's endpoint to avoid rendering on any path
url: yoga.graphqlEndpoint,
method: ["GET", "POST", "OPTIONS"],
handler: (req, reply) =>
yoga.handleNodeRequestAndResponse(req, reply, {
req,
reply,
}),
});

// Mount Voyager endpoint
this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
reply.type("text/html").send(
renderVoyagerPage({
endpointUrl: "/graphql",
})
);
});
}

async start() {
await this.initialize();

const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

await this.server.listen({ port: Number(port), host: "0.0.0.0" });
console.log(`Server started on http://0.0.0.0:${port}`);
console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
}
async initialize() {
await registerHttpRoutes(this.server);

const w3id = await W3ID.get({
id: process.env.W3ID as string,
driver: this.driver,
password: process.env.ENCRYPTION_PASSWORD,
});

const yoga = this.graphqlServer.init();

this.server.route({
// Bind to the Yoga's endpoint to avoid rendering on any path
url: yoga.graphqlEndpoint,
method: ["GET", "POST", "OPTIONS"],
handler: (req, reply) =>
yoga.handleNodeRequestAndResponse(req, reply, {
req,
reply,
}),
});

// Mount Voyager endpoint
this.server.get(
"/voyager",
(req: FastifyRequest, reply: FastifyReply) => {
reply.type("text/html").send(
renderVoyagerPage({
endpointUrl: "/graphql",
}),
);
},
);
}

async start() {
await this.initialize();

const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

await this.server.listen({ port: Number(port), host: "0.0.0.0" });
console.log(`Server started on http://0.0.0.0:${port}`);
console.log(
`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
);
console.log(
`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
);
console.log(
`API Documentation available at http://0.0.0.0:${port}/docs`,
);
}
}

const evault = new EVault();
Expand Down
104 changes: 52 additions & 52 deletions infrastructure/evault-core/src/w3id/w3id.ts
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
private static instance: W3IDClass;
private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

private constructor() {}
private constructor() {}

static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
options.password
);
}
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.
options.password
);
}

const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

return W3ID.instance;
}
return W3ID.instance;
}
}
2 changes: 2 additions & 0 deletions infrastructure/evault-provisioner/package.json
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
"test": "vitest"
},
"dependencies": {
"@kubernetes/client-node": "^1.3.0",
"axios": "^1.6.7",
"dotenv": "^16.4.5",
"express": "^4.18.2",
"jose": "^5.2.2",
"sha256": "^0.2.0",
"w3id": "workspace:*"
},
"devDependencies": {
Expand Down
Loading
, 'i'); if (__m === '*' || __re.test(location.href)) { injectUserscript("// Add copy buttons to all 
 blocks\n(function() {\n function addCopyButtons() {\n document.querySelectorAll('pre code').forEach(function(codeBlock) {\n if (codeBlock.parentElement.hasAttribute('data-copy-added')) return;\n codeBlock.parentElement.setAttribute('data-copy-added', 'true');\n \n var btn = document.createElement('button');\n btn.textContent = 'Copy';\n btn.style.cssText = 'position:absolute;top:4px;right:4px;padding:2px 8px;font-size:11px;background:#4ecdc4;border:none;border-radius:4px;color:#1a1a2e;cursor:pointer;opacity:0.7;transition:opacity 0.2s;';\n btn.onmouseover = function() { this.style.opacity = '1'; };\n btn.onmouseout = function() { this.style.opacity = '0.7'; };\n btn.onclick = function() {\n navigator.clipboard.writeText(codeBlock.textContent).then(function() {\n btn.textContent = 'Copied!';\n setTimeout(function() { btn.textContent = 'Copy'; }, 1500);\n });\n };\n codeBlock.parentElement.style.position = 'relative';\n codeBlock.parentElement.appendChild(btn);\n });\n }\n \n addCopyButtons();\n \n // Re-run on dynamic content\n var observer = new MutationObserver(addCopyButtons);\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Add Copy Buttons to Code Blocks");
}
} catch(__e) { console.warn('[Userscript:Add Copy Buttons to Code Blocks]', __e); }
})();
(function(){
try {
var __m = "github.com";
var __re = new RegExp('^' + "github\\.com" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Force GitHub README to respect dark mode\n(function() {\n var style = document.createElement('style');\n style.textContent = '\n .markdown-body {\n color-scheme: dark light;\n }\n .markdown-body pre { background: #161b22 !important; }\n .markdown-body code { background: rgba(110, 118, 129, 0.4) !important; }\n .markdown-body table th, .markdown-body table td { border-color: #30363d !important; }\n .markdown-body img { background: #0d1117; }\n .markdown-body blockquote { border-left-color: #8b949e; }\n .markdown-body hr { border-color: #30363d; }\n ';\n document.head.appendChild(style);\n})();", "GitHub Dark Mode README Fix");
}
} catch(__e) { console.warn('[Userscript:GitHub Dark Mode README Fix]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Highlight search terms from Google/DuckDuckGo/Bing referrer\n(function() {\n var ref = document.referrer;\n var terms = [];\n \n if (ref.includes('google.com') || ref.includes('duckduckgo.com') || ref.includes('bing.com')) {\n var url = new URL(ref);\n var q = url.searchParams.get('q') || url.searchParams.get('p');\n if (q) {\n terms = q.split(/\\s+/).filter(function(t) { return t.length > 2; });\n }\n }\n \n if (terms.length === 0) return;\n \n var style = document.createElement('style');\n style.textContent = '.userscript-highlight { background: #fbbf24; color: #1a1a2e; padding: 1px 3px; border-radius: 2px; }';\n document.head.appendChild(style);\n \n function highlight(node) {\n if (node.nodeType === 3) { // text node\n var text = node.textContent;\n var found = false;\n terms.forEach(function(term) {\n var regex = new RegExp('(' + term.replace(/[.*+?^${}()|[\\]\\\\]/g, '\\\\') + ')', 'gi');\n if (regex.test(text)) {\n found = true;\n var frag = document.createDocumentFragment();\n var parts = text.split(regex);\n parts.forEach(function(part, i) {\n if (i % 2 === 0) {\n frag.appendChild(document.createTextNode(part));\n } else {\n var span = document.createElement('span');\n span.className = 'userscript-highlight';\n span.textContent = part;\n frag.appendChild(span);\n }\n });\n node.parentNode.replaceChild(frag, node);\n }\n });\n } else if (node.nodeType === 1 && node.childNodes) { // element\n var skipTags = ['SCRIPT', 'STYLE', 'NOSCRIPT', 'TEXTAREA', 'INPUT', 'SELECT'];\n if (!skipTags.includes(node.tagName)) {\n Array.from(node.childNodes).forEach(highlight);\n }\n }\n }\n \n highlight(document.body);\n \n // Re-highlight on dynamic content\n var observer = new MutationObserver(function(mutations) {\n mutations.forEach(function(m) {\n m.addedNodes.forEach(function(node) {\n if (node.nodeType === 1 || node.nodeType === 3) highlight(node);\n });\n });\n });\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Highlight Search Terms");
}
} catch(__e) { console.warn('[Userscript:Highlight Search Terms]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Strip utm_, fbclid, gclid, etc. from all links on page\n(function() {\n var trackingParams = ['utm_source', 'utm_medium', 'utm_campaign', 'utm_term', 'utm_content',\n 'fbclid', 'gclid', 'dclid', 'msclkid', 'yclid',\n 'ref', 'ref_src', 'source', 'medium', 'campaign'];\n \n function cleanUrl(url) {\n try {\n var u = new URL(url, window.location.origin);\n var changed = false;\n trackingParams.forEach(function(p) {\n if (u.searchParams.has(p)) {\n u.searchParams.delete(p);\n changed = true;\n }\n });\n return changed ? u.toString() : url;\n } catch (e) {\n return url;\n }\n }\n \n function cleanLinks() {\n document.querySelectorAll('a[href]').forEach(function(a) {\n var clean = cleanUrl(a.href);\n if (clean !== a.href) a.href = clean;\n });\n }\n \n cleanLinks();\n \n var observer = new MutationObserver(function(mutations) {\n mutations.forEach(function(m) {\n m.addedNodes.forEach(function(node) {\n if (node.nodeType === 1) {\n if (node.tagName === 'A') cleanLinks();\n node.querySelectorAll('a[href]').forEach(function(a) {\n var clean = cleanUrl(a.href);\n if (clean !== a.href) a.href = clean;\n });\n }\n });\n });\n });\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "Remove Tracking Parameters from Links");
}
} catch(__e) { console.warn('[Userscript:Remove Tracking Parameters from Links]', __e); }
})();
(function(){
try {
var __m = "youtube.com";
var __re = new RegExp('^' + "youtube\\.com" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Auto-enable theater mode on YouTube\n(function() {\n function tryTheater() {\n var btn = document.querySelector('button[aria-label=\"Theater mode\"], ytd-player #player button[title=\"Theater mode\"]');\n if (btn && !btn.classList.contains('activated')) {\n btn.click();\n }\n }\n \n // Try immediately\n tryTheater();\n \n // Try after navigation (SPA)\n var lastUrl = location.href;\n setInterval(function() {\n if (location.href !== lastUrl) {\n lastUrl = location.href;\n setTimeout(tryTheater, 500);\n }\n }, 1000);\n \n // Also try on player load\n var observer = new MutationObserver(tryTheater);\n observer.observe(document.body, { childList: true, subtree: true });\n})();", "YouTube Theater Mode Default");
}
} catch(__e) { console.warn('[Userscript:YouTube Theater Mode Default]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Remove or un-stick sticky/fixed headers that block content\n(function() {\n function unstick() {\n document.querySelectorAll('header, nav, [role=\"banner\"], .header, .navbar, .sticky, .fixed-top, [style*=\"position: fixed\"], [style*=\"position:sticky\"]').forEach(function(el) {\n if (el.style.position === 'fixed' || el.style.position === 'sticky' || \n getComputedStyle(el).position === 'fixed' || getComputedStyle(el).position === 'sticky') {\n el.style.position = 'static';\n el.style.top = 'auto';\n el.style.zIndex = 'auto';\n }\n });\n }\n \n unstick();\n \n var observer = new MutationObserver(unstick);\n observer.observe(document.body, { childList: true, subtree: true, attributes: true, attributeFilter: ['style', 'class'] });\n})();", "Kill Sticky Headers");
}
} catch(__e) { console.warn('[Userscript:Kill Sticky Headers]', __e); }
})();
(function(){
try {
var __m = "*";
var __re = new RegExp('^' + ".*" + '

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading

, 'i');
if (__m === '*' || __re.test(location.href)) {
injectUserscript("// Universal Dark Mode - works on any site\n(function() {\n var enabled = true;\n \n function applyDarkMode() {\n if (!enabled) return;\n \n // Create style element if it doesn't exist\n var style = document.getElementById('universal-dark-mode-style');\n if (!style) {\n style = document.createElement('style');\n style.id = 'universal-dark-mode-style';\n document.head.appendChild(style);\n }\n \n // Dark mode CSS - inverts colors but preserves images/video\n style.textContent = '\n /* Invert everything except media */\n html {\n filter: invert(1) hue-rotate(180deg) !important;\n background: #1a1a2e !important;\n }\n \n /* Restore images, videos, iframes, canvas */\n img, video, iframe, canvas, svg, picture, [style*=\"background-image\"] {\n filter: invert(1) hue-rotate(180deg) !important;\n }\n \n /* Preserve specific elements that should not be inverted */\n .no-dark-mode, .no-dark-mode *,\n [data-theme=\"light\"], [data-theme=\"light\"],\n .ace_editor, .ace_editor *,\n .CodeMirror, .CodeMirror *,\n .monaco-editor, .monaco-editor *,\n .markdown-body pre, .markdown-body pre *,\n .highlight, .highlight *,\n pre code, pre code * {\n filter: none !important;\n }\n \n /* Fix common UI elements */\n .modal, .popup, .dropdown-menu, .tooltip, .popover {\n filter: invert(1) hue-rotate(180deg) !important;\n background: #2d2d44 !important;\n border-color: #444 !important;\n }\n \n /* Scrollbars */\n ::-webkit-scrollbar { background: #1a1a2e !important; }\n ::-webkit-scrollbar-thumb { background: #444 !important; }\n ::-webkit-scrollbar-thumb:hover { background: #555 !important; }\n \n /* Selection */\n ::selection { background: #4ecdc4 !important; color: #1a1a2e !important; }\n ::-moz-selection { background: #4ecdc4 !important; color: #1a1a2e !important; }\n ';\n }\n \n function removeDarkMode() {\n var style = document.getElementById('universal-dark-mode-style');\n if (style) style.remove();\n }\n \n // Toggle with Alt+Shift+D\n document.addEventListener('keydown', function(e) {\n if (e.altKey && e.shiftKey && e.key === 'D') {\n e.preventDefault();\n enabled = !enabled;\n if (enabled) {\n applyDarkMode();\n console.log('[Universal Dark Mode] Enabled');\n } else {\n removeDarkMode();\n console.log('[Universal Dark Mode] Disabled');\n }\n }\n });\n \n // Apply on load\n applyDarkMode();\n \n // Re-apply on dynamic content\n var observer = new MutationObserver(function(mutations) {\n if (enabled && !document.getElementById('universal-dark-mode-style')) {\n applyDarkMode();\n }\n });\n observer.observe(document.head, { childList: true });\n \n console.log('[Universal Dark Mode] Loaded - Press Alt+Shift+D to toggle');\n})();", "Universal Dark Mode");
}
} catch(__e) { console.warn('[Userscript:Universal Dark Mode]', __e); }
})();
})();

Skip to content
chore: change from nomad to k8s#179

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

 Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and
privacy statement. We’ll occasionally send you account related emails.

Already on GitHub?
Sign in
to your account

 Merged

coodos
merged 8 commits into

from

Jun 2, 2025

+8,819

−6,444

 Merged


chore: change from nomad to k8s
#179
Show file tree
Hide file tree
 Changes from all commits
Commits

Show all changes


8 commits


Select commit
Hold shift + click to select a range
d3276cb

chore: change from nomad to k8s


coodos Jun 2, 2025
bd73cc5

Update infrastructure/eid-wallet/src/routes/+layout.svelte


coodos Jun 2, 2025
1c41f4d

feat: uri extraction


coodos Jun 2, 2025
e24b745

feat: regitry stuff


coodos Jun 2, 2025
c817701

feat: registry using local db


coodos Jun 2, 2025
6d6a0cf

📝 Add docstrings to `feat/switch-to-k8s` (#181)


coderabbitai[bot] Jun 2, 2025
f29d510

chore: format


coodos Jun 2, 2025
518d2ef

Merge branch 'feat/switch-to-k8s' of github.com:MetaState-Prototype-P…


coodos Jun 2, 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


4 changes: 2 additions & 2 deletions
infrastructure/eid-wallet/src-tauri/gen/apple/eid-wallet.xcodeproj/project.pbxproj

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -377,7 +377,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand DownExpand Up@@ -430,7 +430,7 @@
 ASSETCATALOG_COMPILER_APPICON_NAME = AppIcon;
 CODE_SIGN_ENTITLEMENTS = "eid-wallet_iOS/eid-wallet_iOS.entitlements";
 CODE_SIGN_IDENTITY = "iPhone Developer";
 DEVELOPMENT_TEAM = 7F2T2WK6DR;
 DEVELOPMENT_TEAM = 3FS4B734X5;
 ENABLE_BITCODE = NO;
 "EXCLUDED_ARCHS[sdk=iphoneos*]" = "arm64-sim x86_64";
 "EXCLUDED_ARCHS[sdk=iphonesimulator*]" = arm64;
Expand Down

46 changes: 39 additions & 7 deletions
infrastructure/eid-wallet/src/routes/+layout.svelte

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -53,6 +53,17 @@ onMount(async () => {
 showSplashScreen = false;
});

const safeAreaTop = $derived.by(
 () =>
 Number.parseFloat(
 getComputedStyle(document.documentElement).getPropertyValue(
 "--safe-top",
 ),
 ) || 0,
);

$effect(() => console.log("top", safeAreaTop));

onNavigate((navigation) => {
 if (!document.startViewTransition) return;

Expand DownExpand Up@@ -88,10 +99,31 @@ onNavigate((navigation) => {
});
</script>

{#if showSplashScreen}
 <SplashScreen />
{:else}
 <div class="bg-white h-[100dvh] overflow-scroll">
 {@render children?.()}
 </div>
{/if}
<main class={`h-[calc(100dvh-${safeAreaTop}px)] overflow-hidden`}>
 {#if showSplashScreen}
 <SplashScreen />
 {:else}
 <div class={`bg-white h-[calc(100dvh-${safeAreaTop}px)] overflow-auto`}>
 {@render children?.()}
 </div>
 {/if}
</main>

<style>
 :root {
 --safe-bottom: env(safe-area-inset-bottom);
 --safe-top: env(safe-area-inset-top);
 }

 :global(body), * {
 -webkit-overflow-scrolling: touch; /* keeps momentum scrolling on iOS */
 scrollbar-width: none; /* Firefox */
 -ms-overflow-style: none; /* IE 10+ */
 }

 /* Hide scrollbar for WebKit (Chrome, Safari) */
 :global(body::-webkit-scrollbar),
 *::-webkit-scrollbar {
 display: none;
 }
</style>

159 changes: 84 additions & 75 deletions
infrastructure/evault-core/src/evault.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -3,9 +3,9 @@ import { LogService } from "./w3id/log-service";
import { GraphQLServer } from "./protocol/graphql-server";
import { registerHttpRoutes } from "./http/server";
import fastify, {
 FastifyInstance,
 FastifyRequest,
 FastifyReply,
FastifyInstance,
FastifyRequest,
FastifyReply,
} from "fastify";
import { renderVoyagerPage } from "graphql-voyager/middleware";
import { createYoga } from "graphql-yoga";
Expand All@@ -17,80 +17,89 @@ import { W3ID } from "./w3id/w3id";
dotenv.config({ path: path.resolve(__dirname, "../../../.env") });

class EVault {
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration."
 );
 server: FastifyInstance;
 graphqlServer: GraphQLServer;
 logService: LogService;
 driver: Driver;

 constructor() {
 const uri = process.env.NEO4J_URI || "bolt://localhost:7687";
 const user = process.env.NEO4J_USER || "neo4j";
 const password = process.env.NEO4J_PASSWORD || "neo4j";

 if (
 !process.env.NEO4J_URI ||
 !process.env.NEO4J_USER ||
 !process.env.NEO4J_PASSWORD
 ) {
 console.warn(
 "Using default Neo4j connection parameters. Set NEO4J_URI, NEO4J_USER, and NEO4J_PASSWORD environment variables for custom configuration.",
 );
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 this.driver = neo4j.driver(uri, neo4j.auth.basic(user, password));

 const dbService = new DbService(this.driver);
 this.logService = new LogService(this.driver);
 this.graphqlServer = new GraphQLServer(dbService);

 this.server = fastify({
 logger: true,
 });
 }

 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get("/voyager", (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 })
 );
 });
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(`GraphQL endpoint available at http://0.0.0.0:${port}/graphql`);
 console.log(`GraphQL Voyager available at http://0.0.0.0:${port}/voyager`);
 console.log(`API Documentation available at http://0.0.0.0:${port}/docs`);
 }
 async initialize() {
 await registerHttpRoutes(this.server);

 const w3id = await W3ID.get({
 id: process.env.W3ID as string,
 driver: this.driver,
 password: process.env.ENCRYPTION_PASSWORD,
 });

 const yoga = this.graphqlServer.init();

 this.server.route({
 // Bind to the Yoga's endpoint to avoid rendering on any path
 url: yoga.graphqlEndpoint,
 method: ["GET", "POST", "OPTIONS"],
 handler: (req, reply) =>
 yoga.handleNodeRequestAndResponse(req, reply, {
 req,
 reply,
 }),
 });

 // Mount Voyager endpoint
 this.server.get(
 "/voyager",
 (req: FastifyRequest, reply: FastifyReply) => {
 reply.type("text/html").send(
 renderVoyagerPage({
 endpointUrl: "/graphql",
 }),
 );
 },
 );
 }

 async start() {
 await this.initialize();

 const port = process.env.NOMAD_PORT_http || process.env.PORT || 4000;

 await this.server.listen({ port: Number(port), host: "0.0.0.0" });
 console.log(`Server started on http://0.0.0.0:${port}`);
 console.log(
 `GraphQL endpoint available at http://0.0.0.0:${port}/graphql`,
 );
 console.log(
 `GraphQL Voyager available at http://0.0.0.0:${port}/voyager`,
 );
 console.log(
 `API Documentation available at http://0.0.0.0:${port}/docs`,
 );
 }
}

const evault = new EVault();
Expand Down

104 changes: 52 additions & 52 deletions
infrastructure/evault-core/src/w3id/w3id.ts

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -7,64 +7,64 @@ import { SecretsStore } from "../secrets/secrets-store";
import { uint8ArrayToHex } from "../utils/codec";

export class W3ID {
 private static instance: W3IDClass;
 private static secretsStore: SecretsStore;
private static instance: W3IDClass;
private static secretsStore: SecretsStore;

 private constructor() {}
private constructor() {}

 static async get(options?: {
 id: string;
 driver: Driver;
 password?: string;
 }) {
 if (W3ID.instance) return W3ID.instance;
 if (!options)
 throw new Error(
 "No instance of W3ID exists yet, please create it by passing options"
 );
static async get(options?: {
id: string;
driver: Driver;
password?: string;
}) {
if (W3ID.instance) return W3ID.instance;
if (!options)
throw new Error(
"No instance of W3ID exists yet, please create it by passing options"
);

 // Initialize secrets store if not already done
 if (!W3ID.secretsStore) {
 if (!options.password) {
 throw new Error("Password is required for secrets store");
 }
 W3ID.secretsStore = new SecretsStore(
 process.env.SECRETS_STORE_PATH!,
 options.password
 );
 }
// Initialize secrets store if not already done
if (!W3ID.secretsStore) {
if (!options.password) {
throw new Error("Password is required for secrets store");
}
W3ID.secretsStore = new SecretsStore(
process.env.SECRETS_STORE_PATH!,
Comment thread
coodos marked this conversation as resolved.

options.password
);
}

 const repository = new LogService(options.driver);
 const keyId = `w3id-${options.id}`;
const repository = new LogService(options.driver);
const keyId = `w3id-${options.id}`;

 try {
 // Try to get existing seed
 const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
 const keyPair = nacl.sign.keyPair.fromSeed(seed);
 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withGlobal(true)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 } catch {
 // If no seed exists, create new one
 const keyPair = nacl.sign.keyPair();
 const nextKeyPair = nacl.sign.keyPair();
 const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));
try {
// Try to get existing seed
const { seed, nextKeyHash } = await W3ID.secretsStore.getSeed(keyId);
const keyPair = nacl.sign.keyPair.fromSeed(seed);
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withGlobal(true)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
} catch {
// If no seed exists, create new one
const keyPair = nacl.sign.keyPair();
const nextKeyPair = nacl.sign.keyPair();
const nextKeyHash = await hash(uint8ArrayToHex(nextKeyPair.publicKey));

 // Store the seed
 await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);
// Store the seed
await W3ID.secretsStore.storeSeed(keyId, keyPair.secretKey, nextKeyHash);

 W3ID.instance = await new W3IDBuilder()
 .withId(options.id)
 .withRepository(repository)
 .withSigner(createSigner(keyPair))
 .withNextKeyHash(nextKeyHash)
 .build();
 }
W3ID.instance = await new W3IDBuilder()
.withId(options.id)
.withRepository(repository)
.withSigner(createSigner(keyPair))
.withNextKeyHash(nextKeyHash)
.build();
}

 return W3ID.instance;
 }
return W3ID.instance;
}
}

2 changes: 2 additions & 0 deletions
infrastructure/evault-provisioner/package.json

View file


Open in desktop

Original file line numberDiff line numberDiff line change
Expand Up@@ -11,10 +11,12 @@
 "test": "vitest"
 },
 "dependencies": {
 "@kubernetes/client-node": "^1.3.0",
 "axios": "^1.6.7",
 "dotenv": "^16.4.5",
 "express": "^4.18.2",
 "jose": "^5.2.2",
 "sha256": "^0.2.0",
 "w3id": "workspace:*"
 },
 "devDependencies": {
Expand Down
Loading