feat: Use CF

## Description
<!-- Briefly describe the purpose and scope of your changes -->


<!-- This is an auto-generated comment: release notes by coderabbit.ai
-->
## Summary by CodeRabbit

- **New Features**
- Introduced a retry and dead-letter queue system for more robust event
processing.
- Added a retry handler for processing failed Lambda invocations with
exponential backoff.
- Enhanced event handling to support retry logic and improved error
management.

- **Refactor**
- Replaced SQS-based library event processing with an event bus-based
approach.
- Updated event names and structure for improved clarity and
consistency.
  - Removed legacy library queue and related infrastructure.

- **Chores**
  - Updated dependencies to include the AWS Lambda client.
  - Cleaned up unused code and removed deprecated event handling logic.
<!-- end of auto-generated comment: release notes by coderabbit.ai -->

apps/blog/.gitignore

@@ -1,24 +0,0 @@
-# build output
-dist/
-# generated types
-.astro/
-
-# dependencies
-node_modules/
-
-# logs
-npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
-pnpm-debug.log*
-
-
-# environment variables
-.env
-.env.production
-
-# macOS-specific files
-.DS_Store
-
-# jetbrains setting folder
-.idea/

apps/blog/.vscode/extensions.json

@@ -1,4 +0,0 @@
-{
-  "recommendations": ["astro-build.astro-vscode", "unifiedjs.vscode-mdx"],
-  "unwantedRecommendations": []
-}

apps/blog/.vscode/launch.json

@@ -1,11 +0,0 @@
-{
-  "version": "0.2.0",
-  "configurations": [
-    {
-      "command": "./node_modules/.bin/astro dev",
-      "name": "Development server",
-      "request": "launch",
-      "type": "node-terminal"
-    }
-  ]
-}

apps/blog/README.md

@@ -1,68 +0,0 @@
-# Astro Starter Kit: Blog
-
-```sh
-bun create astro@latest -- --template blog
-```
-
-[![Open in StackBlitz](https://developer.stackblitz.com/img/open_in_stackblitz.svg)](https://stackblitz.com/github/withastro/astro/tree/latest/examples/blog)
-[![Open with CodeSandbox](https://assets.codesandbox.io/github/button-edit-lime.svg)](https://codesandbox.io/p/sandbox/github/withastro/astro/tree/latest/examples/blog)
-[![Open in GitHub Codespaces](https://github.com/codespaces/badge.svg)](https://codespaces.new/withastro/astro?devcontainer_path=.devcontainer/blog/devcontainer.json)
-
-> 🧑‍🚀 **Seasoned astronaut?** Delete this file. Have fun!
-
-![blog](https://github.com/withastro/astro/assets/2244813/ff10799f-a816-4703-b967-c78997e8323d)
-
-Features:
-
-- ✅ Minimal styling (make it your own!)
-- ✅ 100/100 Lighthouse performance
-- ✅ SEO-friendly with canonical URLs and OpenGraph data
-- ✅ Sitemap support
-- ✅ RSS Feed support
-- ✅ Markdown & MDX support
-
-## 🚀 Project Structure
-
-Inside of your Astro project, you'll see the following folders and files:
-
-```text
-├── public/
-├── src/
-│   ├── components/
-│   ├── content/
-│   ├── layouts/
-│   └── pages/
-├── astro.config.mjs
-├── README.md
-├── package.json
-└── tsconfig.json
-```
-
-Astro looks for `.astro` or `.md` files in the `src/pages/` directory. Each page is exposed as a route based on its file name.
-
-There's nothing special about `src/components/`, but that's where we like to put any Astro/React/Vue/Svelte/Preact components.
-
-The `src/content/` directory contains "collections" of related Markdown and MDX documents. Use `getCollection()` to retrieve posts from `src/content/blog/`, and type-check your frontmatter using an optional schema. See [Astro's Content Collections docs](https://docs.astro.build/en/guides/content-collections/) to learn more.
-
-Any static assets, like images, can be placed in the `public/` directory.
-
-## 🧞 Commands
-
-All commands are run from the root of the project, from a terminal:
-
-| Command                   | Action                                           |
-| :------------------------ | :----------------------------------------------- |
-| `bun install`             | Installs dependencies                            |
-| `bun dev`             | Starts local dev server at `localhost:4321`      |
-| `bun build`           | Build your production site to `./dist/`          |
-| `bun preview`         | Preview your build locally, before deploying     |
-| `bun astro ...`       | Run CLI commands like `astro add`, `astro check` |
-| `bun astro -- --help` | Get help using the Astro CLI                     |
-
-## 👀 Want to learn more?
-
-Check out [our documentation](https://docs.astro.build) or jump into our [Discord server](https://astro.build/chat).
-
-## Credit
-
-This theme is based off of the lovely [Bear Blog](https://github.com/HermanMartinus/bearblog/).

apps/blog/astro.config.mjs

@@ -1,18 +0,0 @@
-// @ts-check
-import { defineConfig } from 'astro/config';
-import mdx from '@astrojs/mdx';
-import sitemap from '@astrojs/sitemap';
-
-import solidJs from '@astrojs/solid-js';
-
-import tailwindcss from '@tailwindcss/vite';
-
-// https://astro.build/config
-export default defineConfig({
-  site: 'https://example.com',
-  integrations: [mdx(), sitemap(), solidJs()],
-
-  vite: {
-    plugins: [tailwindcss()],
-  },
-});

apps/blog/package.json

@@ -1,21 +0,0 @@
-{
-  "name": "",
-  "type": "module",
-  "version": "0.0.1",
-  "scripts": {
-    "dev": "astro dev",
-    "build": "astro build",
-    "preview": "astro preview",
-    "astro": "astro"
-  },
-  "dependencies": {
-    "@astrojs/mdx": "^4.2.6",
-    "@astrojs/rss": "^4.0.11",
-    "@astrojs/sitemap": "^3.4.0",
-    "@astrojs/solid-js": "^5.0.10",
-    "@tailwindcss/vite": "^4.1.7",
-    "astro": "^5.7.13",
-    "solid-js": "^1.9.7",
-    "tailwindcss": "^4.1.7"
-  }
-}

apps/blog/public/favicon.svg

@@ -1,9 +0,0 @@
-<svg xmlns="http://www.w3.org/2000/svg" fill="none" viewBox="0 0 128 128">
-    <path d="M50.4 78.5a75.1 75.1 0 0 0-28.5 6.9l24.2-65.7c.7-2 1.9-3.2 3.4-3.2h29c1.5 0 2.7 1.2 3.4 3.2l24.2 65.7s-11.6-7-28.5-7L67 45.5c-.4-1.7-1.6-2.8-2.9-2.8-1.3 0-2.5 1.1-2.9 2.7L50.4 78.5Zm-1.1 28.2Zm-4.2-20.2c-2 6.6-.6 15.8 4.2 20.2a17.5 17.5 0 0 1 .2-.7 5.5 5.5 0 0 1 5.7-4.5c2.8.1 4.3 1.5 4.7 4.7.2 1.1.2 2.3.2 3.5v.4c0 2.7.7 5.2 2.2 7.4a13 13 0 0 0 5.7 4.9v-.3l-.2-.3c-1.8-5.6-.5-9.5 4.4-12.8l1.5-1a73 73 0 0 0 3.2-2.2 16 16 0 0 0 6.8-11.4c.3-2 .1-4-.6-6l-.8.6-1.6 1a37 37 0 0 1-22.4 2.7c-5-.7-9.7-2-13.2-6.2Z" />
-    <style>
-        path { fill: #000; }
-        @media (prefers-color-scheme: dark) {
-            path { fill: #FFF; }
-        }
-    </style>
-</svg>

apps/blog/src/components/BaseHead.astro

@@ -1,55 +0,0 @@
----
-// Import the global.css file here so that it is included on
-// all pages through the use of the <BaseHead /> component.
-import '../styles/global.css';
-import { SITE_TITLE } from '../consts';
-
-interface Props {
-	title: string;
-	description: string;
-	image?: string;
-}
-
-const canonicalURL = new URL(Astro.url.pathname, Astro.site);
-
-const { title, description, image = '/blog-placeholder-1.jpg' } = Astro.props;
----
-
-<!-- Global Metadata -->
-<meta charset="utf-8" />
-<meta name="viewport" content="width=device-width,initial-scale=1" />
-<link rel="icon" type="image/svg+xml" href="/favicon.svg" />
-<link rel="sitemap" href="/sitemap-index.xml" />
-<link
-	rel="alternate"
-	type="application/rss+xml"
-	title={SITE_TITLE}
-	href={new URL('rss.xml', Astro.site)}
-/>
-<meta name="generator" content={Astro.generator} />
-
-<!-- Font preloads -->
-<link rel="preload" href="/fonts/atkinson-regular.woff" as="font" type="font/woff" crossorigin />
-<link rel="preload" href="/fonts/atkinson-bold.woff" as="font" type="font/woff" crossorigin />
-
-<!-- Canonical URL -->
-<link rel="canonical" href={canonicalURL} />
-
-<!-- Primary Meta Tags -->
-<title>{title}</title>
-<meta name="title" content={title} />
-<meta name="description" content={description} />
-
-<!-- Open Graph / Facebook -->
-<meta property="og:type" content="website" />
-<meta property="og:url" content={Astro.url} />
-<meta property="og:title" content={title} />
-<meta property="og:description" content={description} />
-<meta property="og:image" content={new URL(image, Astro.url)} />
-
-<!-- Twitter -->
-<meta property="twitter:card" content="summary_large_image" />
-<meta property="twitter:url" content={Astro.url} />
-<meta property="twitter:title" content={title} />
-<meta property="twitter:description" content={description} />
-<meta property="twitter:image" content={new URL(image, Astro.url)} />

apps/blog/src/components/Footer.astro

@@ -1,53 +0,0 @@
----
-import "../styles/global.css"
-const today = new Date();
----
-
-<footer>
-	<div class="mt-6 flex w-full items-center justify-center gap-2 text-xs sm:text-sm font-medium text-neutral-600 dark:text-neutral-400">
-		<span class="hover:text-primary-500 transition-colors duration-200">
-			<a rel="noreferrer" href="https://nestri.io/terms" >Terms of Service</a></span>
-		<span class="text-gray-400 dark:text-gray-600">•</span>
-		<span class="hover:text-primary-500 transition-colors duration-200">
-			<a href="https://nestri.io/privacy">Privacy Policy</a>
-		</span>
-	</div>
-	<div class="mt-6 w-full justify-center flex items-center space-x-4">
-		<a href="https://discord.gg/6um5K6jrYj" target="_blank">
-			<span class="sr-only">Join our Discord Server</span>
-			<svg width="59" height="44" viewBox="0 0 59 44"  aria-hidden="true" astro-icon="social/discord" style="height:28px">
-				<path d="M37.1937 0C36.6265 1.0071 36.1172 2.04893 35.6541 3.11392C31.2553 2.45409 26.7754 2.45409 22.365 3.11392C21.9136 2.04893 21.3926 1.0071 20.8254 0C16.6928 0.70613 12.6644 1.94475 8.84436 3.69271C1.27372 14.9098 -0.775214 25.8374 0.243466 36.6146C4.67704 39.8906 9.6431 42.391 14.9333 43.9884C16.1256 42.391 17.179 40.6893 18.0819 38.9182C16.3687 38.2815 14.7133 37.4828 13.1274 36.5567C13.5442 36.2557 13.9493 35.9432 14.3429 35.6422C23.6384 40.0179 34.4039 40.0179 43.711 35.6422C44.1046 35.9663 44.5097 36.2789 44.9264 36.5567C43.3405 37.4943 41.6852 38.2815 39.9604 38.9298C40.8633 40.7009 41.9167 42.4025 43.109 44C48.3992 42.4025 53.3653 39.9137 57.7988 36.6377C59.0027 24.1358 55.7383 13.3007 49.1748 3.70429C45.3663 1.95633 41.3379 0.717706 37.2053 0.0231518L37.1937 0ZM19.3784 29.9816C16.5192 29.9816 14.1461 27.3886 14.1461 24.1821C14.1461 20.9755 16.4266 18.371 19.3669 18.371C22.3071 18.371 24.6455 20.9871 24.5992 24.1821C24.5529 27.377 22.2956 29.9816 19.3784 29.9816ZM38.6639 29.9816C35.7931 29.9816 33.4431 27.3886 33.4431 24.1821C33.4431 20.9755 35.7236 18.371 38.6639 18.371C41.6042 18.371 43.9309 20.9871 43.8846 24.1821C43.8383 27.377 41.581 29.9816 38.6639 29.9816Z" fill="white"/>
-			</svg>
-		</a>
-		<a href="https://github.com/nestrilabs/nestri/" target="_blank">
-			<span class="sr-only">Go to Nestri's GitHub repo</span>
-			<svg viewBox="0 0 16 16" aria-hidden="true" width="32" height="32" astro-icon="social/github"
-				><path
-					fill="currentColor"
-					d="M8 0C3.58 0 0 3.58 0 8c0 3.54 2.29 6.53 5.47 7.59.4.07.55-.17.55-.38 0-.19-.01-.82-.01-1.49-2.01.37-2.53-.49-2.69-.94-.09-.23-.48-.94-.82-1.13-.28-.15-.68-.52-.01-.53.63-.01 1.08.58 1.23.82.72 1.21 1.87.87 2.33.66.07-.52.28-.87.51-1.07-1.78-.2-3.64-.89-3.64-3.95 0-.87.31-1.59.82-2.15-.08-.2-.36-1.02.08-2.12 0 0 .67-.21 2.2.82.64-.18 1.32-.27 2-.27.68 0 1.36.09 2 .27 1.53-1.04 2.2-.82 2.2-.82.44 1.1.16 1.92.08 2.12.51.56.82 1.27.82 2.15 0 3.07-1.87 3.75-3.65 3.95.29.25.54.73.54 1.48 0 1.07-.01 1.93-.01 2.2 0 .21.15.46.55.38A8.012 8.012 0 0 0 16 8c0-4.42-3.58-8-8-8z"
-				/>
-			</svg>
-		</a>
-	</div>
-</footer>
-<style>
-	footer {
-		padding: 2em 1em 6em 1em;
-		background: linear-gradient(var(--gray-gradient)) no-repeat;
-		color: rgb(var(--gray));
-		text-align: center;
-	}
-	.social-links {
-		display: flex;
-		justify-content: center;
-		gap: 1em;
-		margin-top: 1em;
-	}
-	.social-links a {
-		text-decoration: none;
-		color: rgb(var(--gray));
-	}
-	.social-links a:hover {
-		color: rgb(var(--gray-dark));
-	}
-</style>

apps/blog/src/components/FormattedDate.astro

@@ -1,17 +0,0 @@
----
-interface Props {
-	date: Date;
-}
-
-const { date } = Astro.props;
----
-
-<time datetime={date.toISOString()}>
-	{
-		date.toLocaleDateString('en-us', {
-			year: 'numeric',
-			month: 'short',
-			day: 'numeric',
-		})
-	}
-</time>

apps/blog/src/components/Header.astro

@@ -1,57 +0,0 @@
----
-import HeaderLink from './HeaderLink.astro';
-import { SITE_TITLE } from '../consts';
-import "../styles/global.css";
----
-
-<header>
-	<nav>
-		<h2><a href="/">{SITE_TITLE}</a></h2>
-		<div class="internal-links">
-			<HeaderLink href="https://nestri.io/">Nestri Home</HeaderLink>
-			<HeaderLink href="/blog">Blog</HeaderLink>
-			<HeaderLink href="https://nestri.io/about">About us</HeaderLink>
-		</div>
-	</nav>
-</header>
-<style>
-	header {
-		margin: 0;
-		padding: 0 1em;
-		border-bottom: solid;
-		box-: 0 2px 8px rgba(var(--black), 5%);
-	}
-	h2 {
-		margin: 0;
-		font-size: 1em;
-	}
-
-	h2 a,
-	h2 a.active {
-		text-decoration: none;
-	}
-	nav {
-		display: flex;
-		align-items: center;
-		justify-content: space-between;
-	}
-	nav a {
-		padding: 1em 0.5em;
-		color: var(--black);
-		border-bottom: 4px solid transparent;
-		text-decoration: none;
-	}
-	nav a.active {
-		text-decoration: none;
-		border-bottom-color: var(--accent);
-	}
-	.social-links,
-	.social-links a {
-		display: flex;
-	}
-	@media (max-width: 720px) {
-		.social-links {
-			display: none;
-		}
-	}
-</style>

apps/blog/src/components/HeaderLink.astro

@@ -1,24 +0,0 @@
----
-import type { HTMLAttributes } from 'astro/types';
-
-type Props = HTMLAttributes<'a'>;
-
-const { href, class: className, ...props } = Astro.props;
-const pathname = Astro.url.pathname.replace(import.meta.env.BASE_URL, '');
-const subpath = pathname.match(/[^\/]+/g);
-const isActive = href === pathname || href === '/' + (subpath?.[0] || '');
----
-
-<a href={href} class:list={[className, { active: isActive }]} {...props}>
-	<slot />
-</a>
-<style>
-	a {
-		display: inline-block;
-		text-decoration: none;
-	}
-	a.active {
-		font-weight: bolder;
-		text-decoration: underline;
-	}
-</style>

apps/blog/src/consts.ts

@@ -1,5 +0,0 @@
-// Place any global data in this file.
-// You can import this data from anywhere in your site by using the `import` keyword.
-
-export const SITE_TITLE = 'Nestri Blog';
-export const SITE_DESCRIPTION = 'Welcome to Nestri\'s Blog - This Blog is about the current status of and about intresting facts about Nestri';

apps/blog/src/content.config.ts

@@ -1,18 +0,0 @@
-import { glob } from 'astro/loaders';
-import { defineCollection, z } from 'astro:content';
-
-const blog = defineCollection({
-	// Load Markdown and MDX files in the `src/content/blog/` directory.
-	loader: glob({ base: './src/content/blog', pattern: '**/*.{md,mdx}' }),
-	// Type-check frontmatter using a schema
-	schema: z.object({
-		title: z.string(),
-		description: z.string(),
-		// Transform string to Date object
-		pubDate: z.coerce.date(),
-		updatedDate: z.coerce.date().optional(),
-		heroImage: z.string().optional(),
-	}),
-});
-
-export const collections = { blog };

apps/blog/src/content/blog/first-post.md

@@ -1,16 +0,0 @@
----
-title: 'First post'
-description: 'Lorem ipsum dolor sit amet'
-pubDate: 'Jul 08 2022'
-heroImage: '/blog-placeholder-3.jpg'
----
-
-Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Vitae ultricies leo integer malesuada nunc vel risus commodo viverra. Adipiscing enim eu turpis egestas pretium. Euismod elementum nisi quis eleifend quam adipiscing. In hac habitasse platea dictumst vestibulum. Sagittis purus sit amet volutpat. Netus et malesuada fames ac turpis egestas. Eget magna fermentum iaculis eu non diam phasellus vestibulum lorem. Varius sit amet mattis vulputate enim. Habitasse platea dictumst quisque sagittis. Integer quis auctor elit sed vulputate mi. Dictumst quisque sagittis purus sit amet.
-
-Morbi tristique senectus et netus. Id semper risus in hendrerit gravida rutrum quisque non tellus. Habitasse platea dictumst quisque sagittis purus sit amet. Tellus molestie nunc non blandit massa. Cursus vitae congue mauris rhoncus. Accumsan tortor posuere ac ut. Fringilla urna porttitor rhoncus dolor. Elit ullamcorper dignissim cras tincidunt lobortis. In cursus turpis massa tincidunt dui ut ornare lectus. Integer feugiat scelerisque varius morbi enim nunc. Bibendum neque egestas congue quisque egestas diam. Cras ornare arcu dui vivamus arcu felis bibendum. Dignissim suspendisse in est ante in nibh mauris. Sed tempus urna et pharetra pharetra massa massa ultricies mi.
-
-Mollis nunc sed id semper risus in. Convallis a cras semper auctor neque. Diam sit amet nisl suscipit. Lacus viverra vitae congue eu consequat ac felis donec. Egestas integer eget aliquet nibh praesent tristique magna sit amet. Eget magna fermentum iaculis eu non diam. In vitae turpis massa sed elementum. Tristique et egestas quis ipsum suspendisse ultrices. Eget lorem dolor sed viverra ipsum. Vel turpis nunc eget lorem dolor sed viverra. Posuere ac ut consequat semper viverra nam. Laoreet suspendisse interdum consectetur libero id faucibus. Diam phasellus vestibulum lorem sed risus ultricies tristique. Rhoncus dolor purus non enim praesent elementum facilisis. Ultrices tincidunt arcu non sodales neque. Tempus egestas sed sed risus pretium quam vulputate. Viverra suspendisse potenti nullam ac tortor vitae purus faucibus ornare. Fringilla urna porttitor rhoncus dolor purus non. Amet dictum sit amet justo donec enim.
-
-Mattis ullamcorper velit sed ullamcorper morbi tincidunt. Tortor posuere ac ut consequat semper viverra. Tellus mauris a diam maecenas sed enim ut sem viverra. Venenatis urna cursus eget nunc scelerisque viverra mauris in. Arcu ac tortor dignissim convallis aenean et tortor at. Curabitur gravida arcu ac tortor dignissim convallis aenean et tortor. Egestas tellus rutrum tellus pellentesque eu. Fusce ut placerat orci nulla pellentesque dignissim enim sit amet. Ut enim blandit volutpat maecenas volutpat blandit aliquam etiam. Id donec ultrices tincidunt arcu. Id cursus metus aliquam eleifend mi.
-
-Tempus quam pellentesque nec nam aliquam sem. Risus at ultrices mi tempus imperdiet. Id porta nibh venenatis cras sed felis eget velit. Ipsum a arcu cursus vitae. Facilisis magna etiam tempor orci eu lobortis elementum. Tincidunt dui ut ornare lectus sit. Quisque non tellus orci ac. Blandit libero volutpat sed cras. Nec tincidunt praesent semper feugiat nibh sed pulvinar proin gravida. Egestas integer eget aliquet nibh praesent tristique magna.

apps/blog/src/content/blog/latency-deep-dive.md

@@ -1,65 +0,0 @@
----
-title: 'Technical Deep Dive into Latency'
-description: "Why It's High and How to Reduce It"
-pubDate: 'May 18 2025'
-heroImage: '/pexels-brett-sayles-2881224.jpg'
----
-
-### Why It's High and How to Reduce It
-
-First, let's start with the basics of the Internet.
-
-The Internet connects clients and servers. Webpages primarily use the Application Layer protocol HTTP(S) to communicate with servers. HTTP is widely adopted for various applications, including mobile apps and other services requiring server communication.
-
-There are also other client protocols like WebRTC (Web Real-Time Communication), which mainly powers streaming services needing a back channel. Nestri utilizes WebRTC, and we'll delve deeper into that later.
-
-Imagine using a client protocol like WebRTC to send messages. Common formats for these messages include XML, HTML, or JSON.
-
-While HTML contains significant duplicate symbols (e.g., `<a href="example.com">Some Link</a> <a href="example.com/subpage">Some nested Link</a>`), the modern web employs techniques to reduce its size. For instance, using modern zipping algorithms like gzip, this data can be compressed, resulting in a smaller size for transmission over the HTTP protocol.
-
-In computer science, the more dense the information in a message (achieved through compression, for example), the higher its message entropy. Therefore, sending messages with high entropy is beneficial as it allows for the transfer of more information in a smaller package. Pure HTTP has relatively low entropy, similar to XML. JSON offers higher entropy, which can be further increased by removing whitespace and shortening attribute names. However, in modern client-server applications, JSON is often compressed.
-
-So, we compress JSON traffic for efficiency. Have you ever compressed a large file? Modern systems make this process incredibly fast! But this requires computing power on both the client and server sides, which directly influences latency.
-
-"Well, if I have a fiber connection, I don't need to worry about that..."
-
-While a fiber connection offers significant bandwidth, this statement is somewhat misleading.
-
-Latency also depends on your local network. A modern and stable Wi-Fi connection might seem sufficient, but the physical layer of the internet also contributes to latency. Wireless protocols, in particular, operate on a shared medium – the air. This medium is utilized by various devices, commonly on frequencies around 2.4 or 5 GHz. This spectrum is divided among all these devices. Mechanisms like scheduling and signal modulation are used to manage this shared resource. In essence, to avoid a deeper dive into wireless communication, a wired connection is generally superior to a wireless connection due to the absence of a shared physical medium.
-
-Okay, but what about Ethernet or fiber cables? Aren't we sharing those as well, with multiple applications or other internet users?
-
-Yes, this also impacts latency. If many users in your local area are utilizing the same uplinks to a backbone (a high-speed part of the internet), you'll have to share that bandwidth. While fiber optic cables have substantial capacity due to advanced modulation techniques, consider the journey these data packets undertake across the internet.
-
-Sometimes, if a data center is located nearby, your connection will involve fewer routers (fewer hops) between you and the server. Fewer hops generally translate to lower latency. Each router needs to queue your messages and determine the next destination. Modern routing protocols facilitate this process. However, even routers have to process messages in their queues. Thus, higher message entropy means fewer or smaller packets need to be sent.
-
-What happens when your messages are too large for transmission? They are split into multiple parts and sent using protocols like TCP. TCP ensures reliable packet exchange by retransmitting any packets that are likely lost during internet transit. Packet loss can occur if a router's queue overflows, forcing it to drop packets, potentially prioritizing other traffic. This retransmission significantly increases latency as a packet might need to be sent multiple times.
-
-UDP offers a different approach: it sends all packets without the overhead of retransmission. In this case, the application protocol is responsible for handling any lost packets. Fortunately, there's an application protocol that manages this quite effectively: WebRTC.
-
-WebRTC is an open-source project providing APIs for real-time communication of audio, video, and generic data between peers via a browser. It leverages protocols like ICE, STUN, and TURN to handle NAT traversal and establish peer-to-peer connections, enabling low-latency media streaming and data exchange directly within web applications.
-
-Sending raw video streams over WebRTC is inefficient; they require compression using modern codecs. A GPU is the optimal choice for this task because it has dedicated hardware (hardware encoder) to accelerate video encoding, significantly speeding up the process compared to software encoding on a CPU. Therefore, your GPU also plays a crucial role in reducing latency during video encoding and decoding.
-
-So, why is all this relevant to Nestri?
-
-We aim to deliver a cutting-edge, low-latency cloud gaming experience. Here's what we've implemented to combat bad latency:
-
-**1. Reducing Mouse and Keyboard Latency**
-   1. Reduce package size by using the Protobuf protocol instead of JSON.
-   2. Avoid wasting compute power by not compressing these already optimized messages.
-   3. Minimize message flooding by bundling multiple mouse events into fewer messages through aggregation.
-   4. Implement all of this within WebRTC for a super lightweight communication over UDP.
-
-**2. Reducing Video Latency**
-   1. Utilize cutting-edge encoder-decoders on a GPU instead of a CPU.
-
-**3. Reducing Network Latency in the Backbone**
-   1. Bring servers closer to users to reduce the hop count.
-
-Here's a glimpse of the results of these improvements, comparing the experience before and after implementation:
-
-![[nestri footage video](/nestri-footage-latency.png)](https://fs.dathorse.com/w/ad2bee7e322b942491044fcffcccc899)
-**Latency Test and comparison to the old Nestri**
-
-Did you enjoy this blog post? Join our Discord and share your thoughts!

apps/blog/src/content/blog/markdown-style-guide.md

@@ -1,214 +0,0 @@
----
-title: 'Markdown Style Guide'
-description: 'Here is a sample of some basic Markdown syntax that can be used when writing Markdown content in Astro.'
-pubDate: 'Jun 19 2024'
-heroImage: '/blog-placeholder-1.jpg'
----
-
-Here is a sample of some basic Markdown syntax that can be used when writing Markdown content in Astro.
-
-## Headings
-
-The following HTML `<h1>`—`<h6>` elements represent six levels of section headings. `<h1>` is the highest section level while `<h6>` is the lowest.
-
-# H1
-
-## H2
-
-### H3
-
-#### H4
-
-##### H5
-
-###### H6
-
-## Paragraph
-
-Xerum, quo qui aut unt expliquam qui dolut labo. Aque venitatiusda cum, voluptionse latur sitiae dolessi aut parist aut dollo enim qui voluptate ma dolestendit peritin re plis aut quas inctum laceat est volestemque commosa as cus endigna tectur, offic to cor sequas etum rerum idem sintibus eiur? Quianimin porecus evelectur, cum que nis nust voloribus ratem aut omnimi, sitatur? Quiatem. Nam, omnis sum am facea corem alique molestrunt et eos evelece arcillit ut aut eos eos nus, sin conecerem erum fuga. Ri oditatquam, ad quibus unda veliamenimin cusam et facea ipsamus es exerum sitate dolores editium rerore eost, temped molorro ratiae volorro te reribus dolorer sperchicium faceata tiustia prat.
-
-Itatur? Quiatae cullecum rem ent aut odis in re eossequodi nonsequ idebis ne sapicia is sinveli squiatum, core et que aut hariosam ex eat.
-
-## Images
-
-### Syntax
-
-```markdown
-![Alt text](./full/or/relative/path/of/image)
-```
-
-### Output
-
-![blog placeholder](/blog-placeholder-about.jpg)
-
-## Blockquotes
-
-The blockquote element represents content that is quoted from another source, optionally with a citation which must be within a `footer` or `cite` element, and optionally with in-line changes such as annotations and abbreviations.
-
-### Blockquote without attribution
-
-#### Syntax
-
-```markdown
-> Tiam, ad mint andaepu dandae nostion secatur sequo quae.  
-> **Note** that you can use _Markdown syntax_ within a blockquote.
-```
-
-#### Output
-
-> Tiam, ad mint andaepu dandae nostion secatur sequo quae.  
-> **Note** that you can use _Markdown syntax_ within a blockquote.
-
-### Blockquote with attribution
-
-#### Syntax
-
-```markdown
-> Don't communicate by sharing memory, share memory by communicating.<br>
-> — <cite>Rob Pike[^1]</cite>
-```
-
-#### Output
-
-> Don't communicate by sharing memory, share memory by communicating.<br>
-> — <cite>Rob Pike[^1]</cite>
-
-[^1]: The above quote is excerpted from Rob Pike's [talk](https://www.youtube.com/watch?v=PAAkCSZUG1c) during Gopherfest, November 18, 2015.
-
-## Tables
-
-### Syntax
-
-```markdown
-| Italics   | Bold     | Code   |
-| --------- | -------- | ------ |
-| _italics_ | **bold** | `code` |
-```
-
-### Output
-
-| Italics   | Bold     | Code   |
-| --------- | -------- | ------ |
-| _italics_ | **bold** | `code` |
-
-## Code Blocks
-
-### Syntax
-
-we can use 3 backticks ``` in new line and write snippet and close with 3 backticks on new line and to highlight language specific syntax, write one word of language name after first 3 backticks, for eg. html, javascript, css, markdown, typescript, txt, bash
-
-````markdown
-```html
-<!doctype html>
-<html lang="en">
-  <head>
-    <meta charset="utf-8" />
-    <title>Example HTML5 Document</title>
-  </head>
-  <body>
-    <p>Test</p>
-  </body>
-</html>
-```
-````
-
-### Output
-
-```html
-<!doctype html>
-<html lang="en">
-  <head>
-    <meta charset="utf-8" />
-    <title>Example HTML5 Document</title>
-  </head>
-  <body>
-    <p>Test</p>
-  </body>
-</html>
-```
-
-## List Types
-
-### Ordered List
-
-#### Syntax
-
-```markdown
-1. First item
-2. Second item
-3. Third item
-```
-
-#### Output
-
-1. First item
-2. Second item
-3. Third item
-
-### Unordered List
-
-#### Syntax
-
-```markdown
-- List item
-- Another item
-- And another item
-```
-
-#### Output
-
-- List item
-- Another item
-- And another item
-
-### Nested list
-
-#### Syntax
-
-```markdown
-- Fruit
-  - Apple
-  - Orange
-  - Banana
-- Dairy
-  - Milk
-  - Cheese
-```
-
-#### Output
-
-- Fruit
-  - Apple
-  - Orange
-  - Banana
-- Dairy
-  - Milk
-  - Cheese
-
-## Other Elements — abbr, sub, sup, kbd, mark
-
-### Syntax
-
-```markdown
-<abbr title="Graphics Interchange Format">GIF</abbr> is a bitmap image format.
-
-H<sub>2</sub>O
-
-X<sup>n</sup> + Y<sup>n</sup> = Z<sup>n</sup>
-
-Press <kbd>CTRL</kbd> + <kbd>ALT</kbd> + <kbd>Delete</kbd> to end the session.
-
-Most <mark>salamanders</mark> are nocturnal, and hunt for insects, worms, and other small creatures.
-```
-
-### Output
-
-<abbr title="Graphics Interchange Format">GIF</abbr> is a bitmap image format.
-
-H<sub>2</sub>O
-
-X<sup>n</sup> + Y<sup>n</sup> = Z<sup>n</sup>
-
-Press <kbd>CTRL</kbd> + <kbd>ALT</kbd> + <kbd>Delete</kbd> to end the session.
-
-Most <mark>salamanders</mark> are nocturnal, and hunt for insects, worms, and other small creatures.

apps/blog/src/content/blog/second-post.md

@@ -1,16 +0,0 @@
----
-title: 'Second post'
-description: 'Lorem ipsum dolor sit amet'
-pubDate: 'Jul 15 2022'
-heroImage: '/blog-placeholder-4.jpg'
----
-
-Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Vitae ultricies leo integer malesuada nunc vel risus commodo viverra. Adipiscing enim eu turpis egestas pretium. Euismod elementum nisi quis eleifend quam adipiscing. In hac habitasse platea dictumst vestibulum. Sagittis purus sit amet volutpat. Netus et malesuada fames ac turpis egestas. Eget magna fermentum iaculis eu non diam phasellus vestibulum lorem. Varius sit amet mattis vulputate enim. Habitasse platea dictumst quisque sagittis. Integer quis auctor elit sed vulputate mi. Dictumst quisque sagittis purus sit amet.
-
-Morbi tristique senectus et netus. Id semper risus in hendrerit gravida rutrum quisque non tellus. Habitasse platea dictumst quisque sagittis purus sit amet. Tellus molestie nunc non blandit massa. Cursus vitae congue mauris rhoncus. Accumsan tortor posuere ac ut. Fringilla urna porttitor rhoncus dolor. Elit ullamcorper dignissim cras tincidunt lobortis. In cursus turpis massa tincidunt dui ut ornare lectus. Integer feugiat scelerisque varius morbi enim nunc. Bibendum neque egestas congue quisque egestas diam. Cras ornare arcu dui vivamus arcu felis bibendum. Dignissim suspendisse in est ante in nibh mauris. Sed tempus urna et pharetra pharetra massa massa ultricies mi.
-
-Mollis nunc sed id semper risus in. Convallis a cras semper auctor neque. Diam sit amet nisl suscipit. Lacus viverra vitae congue eu consequat ac felis donec. Egestas integer eget aliquet nibh praesent tristique magna sit amet. Eget magna fermentum iaculis eu non diam. In vitae turpis massa sed elementum. Tristique et egestas quis ipsum suspendisse ultrices. Eget lorem dolor sed viverra ipsum. Vel turpis nunc eget lorem dolor sed viverra. Posuere ac ut consequat semper viverra nam. Laoreet suspendisse interdum consectetur libero id faucibus. Diam phasellus vestibulum lorem sed risus ultricies tristique. Rhoncus dolor purus non enim praesent elementum facilisis. Ultrices tincidunt arcu non sodales neque. Tempus egestas sed sed risus pretium quam vulputate. Viverra suspendisse potenti nullam ac tortor vitae purus faucibus ornare. Fringilla urna porttitor rhoncus dolor purus non. Amet dictum sit amet justo donec enim.
-
-Mattis ullamcorper velit sed ullamcorper morbi tincidunt. Tortor posuere ac ut consequat semper viverra. Tellus mauris a diam maecenas sed enim ut sem viverra. Venenatis urna cursus eget nunc scelerisque viverra mauris in. Arcu ac tortor dignissim convallis aenean et tortor at. Curabitur gravida arcu ac tortor dignissim convallis aenean et tortor. Egestas tellus rutrum tellus pellentesque eu. Fusce ut placerat orci nulla pellentesque dignissim enim sit amet. Ut enim blandit volutpat maecenas volutpat blandit aliquam etiam. Id donec ultrices tincidunt arcu. Id cursus metus aliquam eleifend mi.
-
-Tempus quam pellentesque nec nam aliquam sem. Risus at ultrices mi tempus imperdiet. Id porta nibh venenatis cras sed felis eget velit. Ipsum a arcu cursus vitae. Facilisis magna etiam tempor orci eu lobortis elementum. Tincidunt dui ut ornare lectus sit. Quisque non tellus orci ac. Blandit libero volutpat sed cras. Nec tincidunt praesent semper feugiat nibh sed pulvinar proin gravida. Egestas integer eget aliquet nibh praesent tristique magna.

apps/blog/src/content/blog/third-post.md

@@ -1,16 +0,0 @@
----
-title: 'Third post'
-description: 'Lorem ipsum dolor sit amet'
-pubDate: 'Jul 22 2022'
-heroImage: '/blog-placeholder-2.jpg'
----
-
-Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Vitae ultricies leo integer malesuada nunc vel risus commodo viverra. Adipiscing enim eu turpis egestas pretium. Euismod elementum nisi quis eleifend quam adipiscing. In hac habitasse platea dictumst vestibulum. Sagittis purus sit amet volutpat. Netus et malesuada fames ac turpis egestas. Eget magna fermentum iaculis eu non diam phasellus vestibulum lorem. Varius sit amet mattis vulputate enim. Habitasse platea dictumst quisque sagittis. Integer quis auctor elit sed vulputate mi. Dictumst quisque sagittis purus sit amet.
-
-Morbi tristique senectus et netus. Id semper risus in hendrerit gravida rutrum quisque non tellus. Habitasse platea dictumst quisque sagittis purus sit amet. Tellus molestie nunc non blandit massa. Cursus vitae congue mauris rhoncus. Accumsan tortor posuere ac ut. Fringilla urna porttitor rhoncus dolor. Elit ullamcorper dignissim cras tincidunt lobortis. In cursus turpis massa tincidunt dui ut ornare lectus. Integer feugiat scelerisque varius morbi enim nunc. Bibendum neque egestas congue quisque egestas diam. Cras ornare arcu dui vivamus arcu felis bibendum. Dignissim suspendisse in est ante in nibh mauris. Sed tempus urna et pharetra pharetra massa massa ultricies mi.
-
-Mollis nunc sed id semper risus in. Convallis a cras semper auctor neque. Diam sit amet nisl suscipit. Lacus viverra vitae congue eu consequat ac felis donec. Egestas integer eget aliquet nibh praesent tristique magna sit amet. Eget magna fermentum iaculis eu non diam. In vitae turpis massa sed elementum. Tristique et egestas quis ipsum suspendisse ultrices. Eget lorem dolor sed viverra ipsum. Vel turpis nunc eget lorem dolor sed viverra. Posuere ac ut consequat semper viverra nam. Laoreet suspendisse interdum consectetur libero id faucibus. Diam phasellus vestibulum lorem sed risus ultricies tristique. Rhoncus dolor purus non enim praesent elementum facilisis. Ultrices tincidunt arcu non sodales neque. Tempus egestas sed sed risus pretium quam vulputate. Viverra suspendisse potenti nullam ac tortor vitae purus faucibus ornare. Fringilla urna porttitor rhoncus dolor purus non. Amet dictum sit amet justo donec enim.
-
-Mattis ullamcorper velit sed ullamcorper morbi tincidunt. Tortor posuere ac ut consequat semper viverra. Tellus mauris a diam maecenas sed enim ut sem viverra. Venenatis urna cursus eget nunc scelerisque viverra mauris in. Arcu ac tortor dignissim convallis aenean et tortor at. Curabitur gravida arcu ac tortor dignissim convallis aenean et tortor. Egestas tellus rutrum tellus pellentesque eu. Fusce ut placerat orci nulla pellentesque dignissim enim sit amet. Ut enim blandit volutpat maecenas volutpat blandit aliquam etiam. Id donec ultrices tincidunt arcu. Id cursus metus aliquam eleifend mi.
-
-Tempus quam pellentesque nec nam aliquam sem. Risus at ultrices mi tempus imperdiet. Id porta nibh venenatis cras sed felis eget velit. Ipsum a arcu cursus vitae. Facilisis magna etiam tempor orci eu lobortis elementum. Tincidunt dui ut ornare lectus sit. Quisque non tellus orci ac. Blandit libero volutpat sed cras. Nec tincidunt praesent semper feugiat nibh sed pulvinar proin gravida. Egestas integer eget aliquet nibh praesent tristique magna.

apps/blog/src/content/blog/using-mdx.mdx

@@ -1,31 +0,0 @@
----
-title: 'Using MDX'
-description: 'Lorem ipsum dolor sit amet'
-pubDate: 'Jun 01 2024'
-heroImage: '/blog-placeholder-5.jpg'
----
-
-This theme comes with the [@astrojs/mdx](https://docs.astro.build/en/guides/integrations-guide/mdx/) integration installed and configured in your `astro.config.mjs` config file. If you prefer not to use MDX, you can disable support by removing the integration from your config file.
-
-## Why MDX?
-
-MDX is a special flavor of Markdown that supports embedded JavaScript & JSX syntax. This unlocks the ability to [mix JavaScript and UI Components into your Markdown content](https://docs.astro.build/en/guides/markdown-content/#mdx-features) for things like interactive charts or alerts.
-
-If you have existing content authored in MDX, this integration will hopefully make migrating to Astro a breeze.
-
-## Example
-
-Here is how you import and use a UI component inside of MDX.  
-When you open this page in the browser, you should see the clickable button below.
-
-import HeaderLink from '../../components/HeaderLink.astro';
-
-<HeaderLink href="#" onclick="alert('clicked!')">
-	Embedded component in MDX
-</HeaderLink>
-
-## More Links
-
-- [MDX Syntax Documentation](https://mdxjs.com/docs/what-is-mdx)
-- [Astro Usage Documentation](https://docs.astro.build/en/guides/markdown-content/#markdown-and-mdx-pages)
-- **Note:** [Client Directives](https://docs.astro.build/en/reference/directives-reference/#client-directives) are still required to create interactive components. Otherwise, all components in your MDX will render as static HTML (no JavaScript) by default.

apps/blog/src/layouts/BlogPost.astro

@@ -1,92 +0,0 @@
----
-import type { CollectionEntry } from 'astro:content';
-import BaseHead from '../components/BaseHead.astro';
-import Header from '../components/Header.astro';
-import Footer from '../components/Footer.astro';
-import FormattedDate from '../components/FormattedDate.astro';
-import "../styles/global.css"
-
-type Props = CollectionEntry<'blog'>['data'];
-
-const { title, description, pubDate, updatedDate, heroImage } = Astro.props;
----
-
-<html lang="en">
-	<head>
-		<BaseHead title={title} description={description} />
-		<style>
-			main {
-				width: calc(100% - 2em);
-				max-width: 100%;
-				margin: 0;
-			}
-			.hero-image {
-				width: 100%;
-			}
-			.hero-image img {
-				display: block;
-				margin: 0 auto;
-				border-radius: 12px;
-			}
-			.prose {
-				width: 720px;
-				max-width: calc(100% - 2em);
-				margin: auto;
-				padding: 1em;
-				color: rgb(var(--gray-dark));
-			}
-			.title {
-				margin-bottom: 1em;
-				padding: 1em 0;
-				text-align: center;
-				line-height: 1;
-			}
-			.title h1 {
-				margin: 0 0 0.5em 0;
-			}
-			.date {
-				margin-bottom: 0.5em;
-				color: rgb(var(--gray));
-			}
-			.last-updated-on {
-				font-style: italic;
-			}
-		</style>
-	</head>
-
-	<body>
-		<Header />
-		<main>
-			<article>
-
-				<div class="grid gap-8 items-start justify-center">
-					<div class="relative group">
-						<div class="absolute -inset-0.5 bg-radial-gradient opacity-40 group-hover:opacity-80 transition duration-1000 group-hover:duration-200 animate-tilt" />
-							<div class="relative bg-black rounded-lg leading-none flex items-center divide-x divide-gray-600">
-								{heroImage && <img width={1020} height={510} src={heroImage} alt="" />}
-							</div>
-						</div>
-					</div>
-				</div>
-				<div class="prose">
-					<div class="title">
-						<div class="date">
-							<FormattedDate date={pubDate} />
-							{
-								updatedDate && (
-									<div class="last-updated-on">
-										Last updated on <FormattedDate date={updatedDate} />
-									</div>
-								)
-							}
-						</div>
-						<h1>{title}</h1>
-						<hr />
-					</div>
-					<slot />
-				</div>
-			</article>
-		</main>
-		<Footer />
-	</body>
-</html>

apps/blog/src/pages/about.astro

@@ -1,62 +0,0 @@
----
-import Layout from '../layouts/BlogPost.astro';
----
-
-<Layout
-	title="About Me"
-	description="Lorem ipsum dolor sit amet"
-	pubDate={new Date('August 08 2021')}
-	heroImage="/blog-placeholder-about.jpg"
->
-	<p>
-		Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut
-		labore et dolore magna aliqua. Vitae ultricies leo integer malesuada nunc vel risus commodo
-		viverra. Adipiscing enim eu turpis egestas pretium. Euismod elementum nisi quis eleifend quam
-		adipiscing. In hac habitasse platea dictumst vestibulum. Sagittis purus sit amet volutpat. Netus
-		et malesuada fames ac turpis egestas. Eget magna fermentum iaculis eu non diam phasellus
-		vestibulum lorem. Varius sit amet mattis vulputate enim. Habitasse platea dictumst quisque
-		sagittis. Integer quis auctor elit sed vulputate mi. Dictumst quisque sagittis purus sit amet.
-	</p>
-
-	<p>
-		Morbi tristique senectus et netus. Id semper risus in hendrerit gravida rutrum quisque non
-		tellus. Habitasse platea dictumst quisque sagittis purus sit amet. Tellus molestie nunc non
-		blandit massa. Cursus vitae congue mauris rhoncus. Accumsan tortor posuere ac ut. Fringilla urna
-		porttitor rhoncus dolor. Elit ullamcorper dignissim cras tincidunt lobortis. In cursus turpis
-		massa tincidunt dui ut ornare lectus. Integer feugiat scelerisque varius morbi enim nunc.
-		Bibendum neque egestas congue quisque egestas diam. Cras ornare arcu dui vivamus arcu felis
-		bibendum. Dignissim suspendisse in est ante in nibh mauris. Sed tempus urna et pharetra pharetra
-		massa massa ultricies mi.
-	</p>
-
-	<p>
-		Mollis nunc sed id semper risus in. Convallis a cras semper auctor neque. Diam sit amet nisl
-		suscipit. Lacus viverra vitae congue eu consequat ac felis donec. Egestas integer eget aliquet
-		nibh praesent tristique magna sit amet. Eget magna fermentum iaculis eu non diam. In vitae
-		turpis massa sed elementum. Tristique et egestas quis ipsum suspendisse ultrices. Eget lorem
-		dolor sed viverra ipsum. Vel turpis nunc eget lorem dolor sed viverra. Posuere ac ut consequat
-		semper viverra nam. Laoreet suspendisse interdum consectetur libero id faucibus. Diam phasellus
-		vestibulum lorem sed risus ultricies tristique. Rhoncus dolor purus non enim praesent elementum
-		facilisis. Ultrices tincidunt arcu non sodales neque. Tempus egestas sed sed risus pretium quam
-		vulputate. Viverra suspendisse potenti nullam ac tortor vitae purus faucibus ornare. Fringilla
-		urna porttitor rhoncus dolor purus non. Amet dictum sit amet justo donec enim.
-	</p>
-
-	<p>
-		Mattis ullamcorper velit sed ullamcorper morbi tincidunt. Tortor posuere ac ut consequat semper
-		viverra. Tellus mauris a diam maecenas sed enim ut sem viverra. Venenatis urna cursus eget nunc
-		scelerisque viverra mauris in. Arcu ac tortor dignissim convallis aenean et tortor at. Curabitur
-		gravida arcu ac tortor dignissim convallis aenean et tortor. Egestas tellus rutrum tellus
-		pellentesque eu. Fusce ut placerat orci nulla pellentesque dignissim enim sit amet. Ut enim
-		blandit volutpat maecenas volutpat blandit aliquam etiam. Id donec ultrices tincidunt arcu. Id
-		cursus metus aliquam eleifend mi.
-	</p>
-
-	<p>
-		Tempus quam pellentesque nec nam aliquam sem. Risus at ultrices mi tempus imperdiet. Id porta
-		nibh venenatis cras sed felis eget velit. Ipsum a arcu cursus vitae. Facilisis magna etiam
-		tempor orci eu lobortis elementum. Tincidunt dui ut ornare lectus sit. Quisque non tellus orci
-		ac. Blandit libero volutpat sed cras. Nec tincidunt praesent semper feugiat nibh sed pulvinar
-		proin gravida. Egestas integer eget aliquet nibh praesent tristique magna.
-	</p>
-</Layout>

apps/blog/src/pages/blog/[...slug].astro

@@ -1,21 +0,0 @@
----
-import { type CollectionEntry, getCollection } from 'astro:content';
-import BlogPost from '../../layouts/BlogPost.astro';
-import { render } from 'astro:content';
-
-export async function getStaticPaths() {
-	const posts = await getCollection('blog');
-	return posts.map((post) => ({
-		params: { slug: post.id },
-		props: post,
-	}));
-}
-type Props = CollectionEntry<'blog'>;
-
-const post = Astro.props;
-const { Content } = await render(post);
----
-
-<BlogPost {...post.data}>
-	<Content />
-</BlogPost>

apps/blog/src/pages/blog/index.astro

@@ -1,120 +0,0 @@
----
-import BaseHead from '../../components/BaseHead.astro';
-import Header from '../../components/Header.astro';
-import Footer from '../../components/Footer.astro';
-import { SITE_TITLE, SITE_DESCRIPTION } from '../../consts';
-import { getCollection } from 'astro:content';
-import FormattedDate from '../../components/FormattedDate.astro';
-import "../../styles/global.css"
-
-const posts = (await getCollection('blog')).sort(
-	(a, b) => b.data.pubDate.valueOf() - a.data.pubDate.valueOf(),
-);
----
-
-<!doctype html>
-<html lang="en">
-	<head>
-		<BaseHead title={SITE_TITLE} description={SITE_DESCRIPTION} />
-		<style>
-			main {
-				width: 960px;
-			}
-			ul {
-				display: flex;
-				flex-wrap: wrap;
-				gap: 2rem;
-				list-style-type: none;
-				margin: 0;
-				padding: 0;
-			}
-			ul li {
-				width: calc(50% - 1rem);
-			}
-			ul li * {
-				text-decoration: none;
-				transition: 0.2s ease;
-			}
-			ul li:first-child {
-				width: 100%;
-				margin-bottom: 1rem;
-				text-align: center;
-			}
-			ul li:first-child img {
-				width: 100%;
-			}
-			ul li:first-child .title {
-				font-size: 2.369rem;
-			}
-			ul li img {
-				
-			}
-			ul li a {
-				display: block;
-			}
-			.title {
-				margin: 0;
-				color: #d9d9d9;
-				line-height: 1;
-			}
-			.date {
-				margin: 0;
-				color: #c0c0c0;
-			}
-			ul li a:hover h4,
-			ul li a:hover .date {
-				color: #f2f2f2;
-			}
-			ul a:hover img {
-				box-shadow: var(--box-shadow);
-			}
-			@media (max-width: 720px) {
-				ul {
-					gap: 0.5em;
-				}
-				ul li {
-					width: 100%;
-					text-align: center;
-				}
-				ul li:first-child {
-					margin-bottom: 0;
-				}
-				ul li:first-child .title {
-					font-size: 1.563em;
-				}
-			}
-		</style>
-	</head>
-	<body>
-		<Header />
-		<main>
-			<section>
-				<ul>							
-					{
-						posts.map((post) => (
-							<li>
-								<a href={`/blog/${post.id}/`}>
-									
-									<div class="grid gap-8 items-start justify-center">
-										<div class="relative group">
-											<div class="absolute -inset-0.5 bg-radial-gradient opacity-0 group-hover:opacity-80 transition duration-1000 group-hover:duration-200 animate-tilt" />
-												<div class="relative bg-black rounded-lg leading-none flex items-center divide-x divide-gray-600">
-													<img width={720} height={360} src={post.data.heroImage} alt="" />
-												</div>
-											</div>
-										</div>
-									</div>
-									<h4 class="title py-4">{post.data.title}</h4>
-									<p class="date">
-										<FormattedDate date={post.data.pubDate} />
-									</p>
-								</a>
-							</li>
-						))
-					}
-				</ul>
-			</section>
-		</main>
-		<Footer />
-	</body>
-</html>

apps/blog/src/pages/index.astro

@@ -1,49 +0,0 @@
----
-import BaseHead from '../components/BaseHead.astro';
-import Header from '../components/Header.astro';
-import Footer from '../components/Footer.astro';
-import { SITE_TITLE, SITE_DESCRIPTION } from '../consts';
----
-
-<!doctype html>
-<html lang="en">
-	<head>
-		<BaseHead title={SITE_TITLE} description={SITE_DESCRIPTION} />
-	</head>
-	<body>
-		<Header />
-		<main>
-			<h1>🧑‍🚀 Hello, Astronaut!</h1>
-			<p>
-				Welcome to the official <a href="https://astro.build/">Astro</a> blog starter template. This
-				template serves as a lightweight, minimally-styled starting point for anyone looking to build
-				a personal website, blog, or portfolio with Astro.
-			</p>
-			<p>
-				This template comes with a few integrations already configured in your
-				<code>astro.config.mjs</code> file. You can customize your setup with
-				<a href="https://astro.build/integrations">Astro Integrations</a> to add tools like Tailwind,
-				React, or Vue to your project.
-			</p>
-			<p>Here are a few ideas on how to get started with the template:</p>
-			<ul>
-				<li>Edit this page in <code>src/pages/index.astro</code></li>
-				<li>Edit the site header items in <code>src/components/Header.astro</code></li>
-				<li>Add your name to the footer in <code>src/components/Footer.astro</code></li>
-				<li>Check out the included blog posts in <code>src/content/blog/</code></li>
-				<li>Customize the blog post page layout in <code>src/layouts/BlogPost.astro</code></li>
-			</ul>
-			<p>
-				Have fun! If you get stuck, remember to
-				<a href="https://docs.astro.build/">read the docs</a>
-				or <a href="https://astro.build/chat">join us on Discord</a> to ask questions.
-			</p>
-			<p>
-				Looking for a blog template with a bit more personality? Check out
-				<a href="https://github.com/Charca/astro-blog-template">astro-blog-template</a>
-				by <a href="https://twitter.com/Charca">Maxi Ferreira</a>.
-			</p>
-		</main>
-		<Footer />
-	</body>
-</html>

apps/blog/src/pages/rss.xml.js

@@ -1,16 +0,0 @@
-import rss from '@astrojs/rss';
-import { getCollection } from 'astro:content';
-import { SITE_TITLE, SITE_DESCRIPTION } from '../consts';
-
-export async function GET(context) {
-	const posts = await getCollection('blog');
-	return rss({
-		title: SITE_TITLE,
-		description: SITE_DESCRIPTION,
-		site: context.site,
-		items: posts.map((post) => ({
-			...post.data,
-			link: `/blog/${post.id}/`,
-		})),
-	});
-}

apps/blog/src/styles/global.css

@@ -1,178 +0,0 @@
-/*
-  The CSS in this style tag is based off of Bear Blog's default CSS.
-  https://github.com/HermanMartinus/bearblog/blob/297026a877bc2ab2b3bdfbd6b9f7961c350917dd/templates/styles/blog/default.css
-  License MIT: https://github.com/HermanMartinus/bearblog/blob/master/LICENSE.md
- */
-@import "tailwindcss";
-
-
-:root {
-	/*--accent: rgb(255, 79, 1);*/
-	/*--accent-dark: #fafafa;*/
-	/*--black: 15, 18, 25;*/
-	/*--gray: 96, 1, 159;*/
-	/*--gray-light: 82, 82, 82;*/
-	--gray-dark: 250, 250, 250;
-	--gray-gradient: rgba(var(--gray-light), 50%), #fff;
-	--box-shadow:
-		0 2px 6px rgba(var(--gray), 25%), 0 8px 24px rgba(var(--gray), 33%),
-		0 16px 32px rgba(var(--gray), 33%);
-}
-@font-face {
-	font-family: 'Atkinson';
-	src: url('/fonts/atkinson-regular.woff') format('woff');
-	font-weight: 400;
-	font-style: normal;
-	font-display: swap;
-}
-@font-face {
-	font-family: 'Atkinson';
-	src: url('/fonts/atkinson-bold.woff') format('woff');
-	font-weight: 700;
-	font-style: normal;
-	font-display: swap;
-}
-
-body {
-	font-family: 'Atkinson', sans-serif;
-	margin: 0;
-	padding: 0;
-	text-align: left;
-	background: linear-gradient(var(--gray-gradient)) no-repeat;
-	background-color: #171717;
-	background-size: 100% 600px;
-	word-wrap: break-word;
-	overflow-wrap: break-word;
-	color: rgb(var(--gray-dark));
-	font-size: 20px;
-	line-height: 1.7;
-}
-main {
-	width: 720px;
-	max-width: calc(100% - 2em);
-	margin: auto;
-	padding: 3em 1em;
-}
-h1,
-h2,
-h3,
-h4,
-h5,
-h6 {
-	margin: 0 0 0.5rem 0;
-	color: rgb(var(--black));
-	line-height: 1.2;
-}
-h1 {
-	font-size: 3.052em;
-}
-h2 {
-	font-size: 2.441em;
-}
-h3 {
-	font-size: 1.953em;
-}
-h4 {
-	font-size: 1.563em;
-}
-h5 {
-	font-size: 1.25em;
-}
-strong,
-b {
-	font-weight: 700;
-}
-a {
-	color: var(--accent);
-}
-a:hover {
-	color: var(--accent);
-}
-p {
-	margin-bottom: 1em;
-}
-.prose p {
-	margin-bottom: 2em;
-}
-textarea {
-	width: 100%;
-	font-size: 16px;
-}
-input {
-	font-size: 16px;
-}
-table {
-	width: 100%;
-}
-img {
-	max-width: 100%;
-	height: auto;
-	border-radius: 8px;
-}
-code {
-	padding: 2px 5px;
-	background-color: rgb(var(--gray-light));
-	border-radius: 2px;
-}
-pre {
-	padding: 1.5em;
-	border-radius: 8px;
-}
-pre > code {
-	all: unset;
-}
-blockquote {
-	border-left: 4px solid var(--accent);
-	padding: 0 0 0 20px;
-	margin: 0px;
-	font-size: 1.333em;
-}
-hr {
-	border: none;
-	border-top: 1px solid rgb(var(--gray-light));
-}
-@media (max-width: 720px) {
-	body {
-		font-size: 18px;
-	}
-	main {
-		padding: 1em;
-	}
-}
-
-.sr-only {
-	border: 0;
-	padding: 0;
-	margin: 0;
-	position: absolute !important;
-	height: 1px;
-	width: 1px;
-	overflow: hidden;
-	/* IE6, IE7 - a 0 height clip, off to the bottom right of the visible 1px box */
-	clip: rect(1px 1px 1px 1px);
-	/* maybe deprecated but we need to support legacy browsers */
-	clip: rect(1px, 1px, 1px, 1px);
-	/* modern browsers, clip-path works inwards from each corner */
-	clip-path: inset(50%);
-	/* added line to stop words getting smushed together (as they go onto separate lines and some screen readers do not understand line feeds as a space */
-	white-space: nowrap;
-}
-
-.bg-radial-gradient {
-  filter: blur(32px);
-  background-image: linear-gradient(
-    90deg,
-    rgb(239, 118, 70),
-    rgb(251, 91, 88),
-    rgb(255, 61, 116),
-    rgb(249, 33, 149),
-    rgb(227, 34, 188),
-    rgb(181, 94, 230),
-    rgb(118, 128, 252),
-    rgb(0, 150, 255),
-    rgb(0, 183, 255),
-    rgb(0, 208, 242),
-    rgb(0, 227, 184),
-    rgb(70, 239, 111)
-  );
-}

apps/blog/tsconfig.json

@@ -1,15 +0,0 @@
-{
-  "extends": "astro/tsconfigs/strict",
-  "include": [
-    ".astro/types.d.ts",
-    "**/*"
-  ],
-  "exclude": [
-    "dist"
-  ],
-  "compilerOptions": {
-    "strictNullChecks": true,
-    "jsx": "preserve",
-    "jsxImportSource": "solid-js"
-  }
-}

containers/runner.Containerfile

@@ -168,8 +168,7 @@ ENV USER="nestri" \
     USER_PWD="nestri1234" \
     XDG_RUNTIME_DIR=/run/user/1000 \
     HOME=/home/nestri \
-    NVIDIA_DRIVER_CAPABILITIES=all \
-    NVIDIA_VISIBLE_DEVICES=all
+    NVIDIA_DRIVER_CAPABILITIES=all
 
 RUN mkdir -p /home/${USER} && \
     groupadd -g ${GID} ${USER} && \

infra/api.ts

@@ -1,10 +1,9 @@
 import { bus } from "./bus";
 import { auth } from "./auth";
 import { domain } from "./dns";
+import { secret } from "./secret";
 import { cluster } from "./cluster";
 import { postgres } from "./postgres";
-import { LibraryQueue } from "./steam";
-import { secret, steamEncryptionKey } from "./secret";
 
 export const apiService = new sst.aws.Service("Api", {
     cluster,
@@ -14,8 +13,7 @@ export const apiService = new sst.aws.Service("Api", {
         bus,
         auth,
         postgres,
-        LibraryQueue,
-        steamEncryptionKey,
+        secret.SteamApiKey,
         secret.PolarSecret,
         secret.PolarWebhookSecret,
         secret.NestriFamilyMonthly,
@@ -52,7 +50,7 @@ export const apiService = new sst.aws.Service("Api", {
     transform: {
         taskDefinition: (args) => {
             const volumes = $output(args.volumes).apply(v => {
-                const next = [...v, {
+                const next = [...(v || []), {
                     name: "shared-tmp",
                     dockerVolumeConfiguration: {
                         scope: "shared",

infra/auth.ts

@@ -1,8 +1,8 @@
 import { bus } from "./bus";
 import { domain } from "./dns";
+import { secret } from "./secret";
 import { cluster } from "./cluster";
 import { postgres } from "./postgres";
-import { secret, steamEncryptionKey } from "./secret";
 
 export const authService = new sst.aws.Service("Auth", {
     cluster,
@@ -13,7 +13,6 @@ export const authService = new sst.aws.Service("Auth", {
         bus,
         postgres,
         secret.PolarSecret,
-        steamEncryptionKey,
         secret.GithubClientID,
         secret.DiscordClientID,
         secret.GithubClientSecret,
@@ -56,7 +55,7 @@ export const authService = new sst.aws.Service("Auth", {
     transform: {
         taskDefinition: (args) => {
             const volumes = $output(args.volumes).apply(v => {
-                const next = [...v, {
+                const next = [...(v || []), {
                     name: "shared-tmp",
                     dockerVolumeConfiguration: {
                         scope: "shared",

infra/bus.ts

@@ -1,26 +1,70 @@
 import { vpc } from "./vpc";
+import { secret } from "./secret";
 import { storage } from "./storage";
-// import { email } from "./email";
 import { postgres } from "./postgres";
-import { steamEncryptionKey } from "./secret";
+
+export const dlq = new sst.aws.Queue("Dlq");
+
+export const retryQueue = new sst.aws.Queue("RetryQueue");
 
 export const bus = new sst.aws.Bus("Bus");
 
-bus.subscribe("Event", {
+export const eventSub = bus.subscribe("Event", {
   vpc,
   handler: "packages/functions/src/events/index.handler",
   link: [
     // email,
-    postgres,
+    bus,
     storage,
-    steamEncryptionKey
+    postgres,
+    retryQueue,
+    secret.PolarSecret,
+    secret.SteamApiKey
   ],
-  timeout: "10 minutes",
+  environment: {
+    RETRIES: "2",
+  },
   memory: "3002 MB",// For faster processing of large(r) images
+  timeout: "10 minutes",
+});
+
+new aws.lambda.FunctionEventInvokeConfig("EventConfig", {
+  functionName: $resolve([eventSub.nodes.function.name]).apply(
+    ([name]) => name,
+  ),
+  maximumRetryAttempts: 1,
+  destinationConfig: {
+    onFailure: {
+      destination: retryQueue.arn,
+    },
+  },
+});
+
+retryQueue.subscribe({
+  vpc,
+  handler: "packages/functions/src/queues/retry.handler",
+  timeout: "30 seconds",
+  environment: {
+    RETRIER_QUEUE_URL: retryQueue.url,
+  },
+  link: [
+    dlq,
+    retryQueue,
+    eventSub.nodes.function,
+  ],
   permissions: [
     {
-      actions: ["ses:SendEmail"],
-      resources: ["*"],
+      actions: ["lambda:GetFunction", "lambda:InvokeFunction"],
+      resources: [
+        $interpolate`arn:aws:lambda:${aws.getRegionOutput().name}:${aws.getCallerIdentityOutput().accountId}:function:*`,
+      ],
     },
   ],
+  transform: {
+    function: {
+      deadLetterConfig: {
+        targetArn: dlq.arn,
+      },
+    },
+  },
 });

infra/images.ts

@@ -0,0 +1,57 @@
+import { domain } from "./dns";
+import { storage } from "./storage";
+
+sst.Linkable.wrap(aws.iam.AccessKey, (resource) => ({
+    properties: {
+        key: resource.id,
+        secret: resource.secret,
+    },
+}))
+
+const cache = new sst.cloudflare.Kv("ImageCache");
+
+const bucket = new sst.cloudflare.Bucket("ImageBucket");
+
+const lambdaInvokerUser = new aws.iam.User("ImageIAMUser", {
+    name: `${$app.name}-${$app.stage}-ImageIAMUser`,
+    forceDestroy: true
+});
+
+const imageProcessorFunction = new sst.aws.Function("ImageProcessor",
+    {
+        memory: "1024 MB",
+        link: [storage],
+        timeout: "30 seconds",
+        nodejs: { install: ["sharp"] },
+        handler: "packages/functions/src/images/processor.handler",
+    },
+);
+
+new aws.iam.UserPolicy("InvokeLambdaPolicy", {
+    user: lambdaInvokerUser.name,
+    policy: $output({
+        Version: "2012-10-17",
+        Statement: [
+            {
+                Effect: "Allow",
+                Action: ["lambda:InvokeFunction"],
+                Resource: imageProcessorFunction.arn,
+            },
+        ],
+    }).apply(JSON.stringify),
+});
+
+const accessKey = new aws.iam.AccessKey("ImageInvokerAccessKey", {
+    user: lambdaInvokerUser.name,
+});
+
+export const imageCdn = new sst.cloudflare.Worker("ImageCDN", {
+    url: true,
+    domain: "cdn." + domain,
+    link: [bucket, cache, imageProcessorFunction, accessKey],
+    handler: "packages/functions/src/images/index.ts",
+});
+
+export const outputs = {
+    cdn: imageCdn.url
+}

infra/postgres.ts

@@ -1,17 +1,12 @@
 import { vpc } from "./vpc";
-import { isPermanentStage } from "./stage";
-import { steamEncryptionKey } from "./secret";
 
-// TODO: Add a dev db to use, this will help with running zero locally... and testing it
 export const postgres = new sst.aws.Aurora("Database", {
   vpc,
   engine: "postgres",
-  scaling: isPermanentStage
-    ? undefined
-    : {
-      min: "0 ACU",
-      max: "1 ACU",
-    },
+  scaling: {
+    min: "0 ACU",
+    max: "1 ACU",
+  },
   transform: {
     clusterParameterGroup: {
       parameters: [
@@ -42,7 +37,7 @@ export const postgres = new sst.aws.Aurora("Database", {
 
 
 new sst.x.DevCommand("Studio", {
-  link: [postgres, steamEncryptionKey],
+  link: [postgres],
   dev: {
     command: "bun db:dev studio",
     directory: "packages/core",

infra/secret.ts

@@ -1,5 +1,6 @@
 export const secret = {
     PolarSecret: new sst.Secret("PolarSecret", process.env.POLAR_API_KEY),
+    SteamApiKey: new sst.Secret("SteamApiKey"),
     GithubClientID: new sst.Secret("GithubClientID"),
     DiscordClientID: new sst.Secret("DiscordClientID"),
     PolarWebhookSecret: new sst.Secret("PolarWebhookSecret"),
@@ -14,17 +15,4 @@ export const secret = {
     NestriFamilyYearly: new sst.Secret("NestriFamilyYearly"),
 };
 
-export const allSecrets = Object.values(secret);
-
-sst.Linkable.wrap(random.RandomString, (resource) => ({
-    properties: {
-        value: resource.result,
-    },
-}));
-
-export const steamEncryptionKey = new random.RandomString(
-    "SteamEncryptionKey",
-    {
-        length: 32,
-    },
-);
+export const allSecrets = Object.values(secret);

infra/steam.ts

@@ -1,19 +0,0 @@
-import { vpc } from "./vpc";
-import { postgres } from "./postgres";
-import { steamEncryptionKey } from "./secret";
-
-export const LibraryQueue = new sst.aws.Queue("LibraryQueue", {
-    fifo: true,
-    visibilityTimeout: "10 minutes",
-});
-
-LibraryQueue.subscribe({
-    vpc,
-    timeout: "10 minutes",
-    memory: "3002 MB",
-    handler: "packages/functions/src/queues/library.handler",
-    link: [
-        postgres,
-        steamEncryptionKey
-    ],
-});

infra/zero.ts

@@ -28,6 +28,7 @@ const zeroEnv = {
     ZERO_LITESTREAM_RESTORE_PARALLELISM: "64",
     ZERO_APP_ID: $app.stage,
     ZERO_AUTH_JWKS_URL: $interpolate`${auth.url}/.well-known/jwks.json`,
+    ZERO_INITIAL_SYNC_ROW_BATCH_SIZE: "30000",
     NODE_OPTIONS: "--max-old-space-size=8192",
     ...($dev
         ? {
@@ -145,9 +146,9 @@ export const zero = new sst.aws.Service("Zero", {
                 ZERO_NUM_SYNC_WORKERS: "1",
             }
             : {
-                ZERO_CHANGE_STREAMER_URI: replicationManager.url.apply((val) =>
+                ZERO_CHANGE_STREAMER_URI: replicationManager?.url.apply((val) =>
                     val.replace("http://", "ws://"),
-                ),
+                ) ?? "",
                 ZERO_UPSTREAM_MAX_CONNS: "15",
                 ZERO_CVR_MAX_CONNS: "160",
             }),

package.json

@@ -3,6 +3,7 @@
   "devDependencies": {
     "@cloudflare/workers-types": "4.20240821.1",
     "@pulumi/pulumi": "^3.134.0",
+    "@tsconfig/node22": "^22.0.1",
     "@types/aws-lambda": "8.10.147",
     "prettier": "^3.2.5",
     "typescript": "^5.4.5"
@@ -18,7 +19,6 @@
   },
   "overrides": {
     "@openauthjs/openauth": "0.4.3",
-    "@rocicorp/zero": "0.20.2025050901",
     "steam-session": "1.9.3"
   },
   "patchedDependencies": {
@@ -30,7 +30,6 @@
     "core-js-pure",
     "esbuild",
     "protobufjs",
-    "@rocicorp/zero-sqlite3",
     "workerd"
   ],
   "workspaces": [
@@ -38,6 +37,7 @@
     "packages/*"
   ],
   "dependencies": {
+    "sharp": "^0.34.2",
     "sst": "^3.11.21"
   }
-}
+}

packages/core/migrations/0020_vengeful_wallop.sql

@@ -0,0 +1,23 @@
+ALTER TABLE "steam_account_credentials" DISABLE ROW LEVEL SECURITY;--> statement-breakpoint
+DROP TABLE "steam_account_credentials" CASCADE;--> statement-breakpoint
+ALTER TABLE "game_libraries" RENAME COLUMN "owner_id" TO "owner_steam_id";--> statement-breakpoint
+ALTER TABLE "teams" RENAME COLUMN "owner_id" TO "owner_steam_id";--> statement-breakpoint
+ALTER TABLE "steam_accounts" DROP CONSTRAINT "idx_steam_username";--> statement-breakpoint
+ALTER TABLE "game_libraries" DROP CONSTRAINT "game_libraries_owner_id_steam_accounts_id_fk";
+--> statement-breakpoint
+ALTER TABLE "teams" DROP CONSTRAINT "teams_owner_id_users_id_fk";
+--> statement-breakpoint
+ALTER TABLE "teams" DROP CONSTRAINT "teams_slug_steam_accounts_username_fk";
+--> statement-breakpoint
+DROP INDEX "idx_team_slug";--> statement-breakpoint
+DROP INDEX "idx_game_libraries_owner_id";--> statement-breakpoint
+ALTER TABLE "game_libraries" DROP CONSTRAINT "game_libraries_base_game_id_owner_id_pk";--> statement-breakpoint
+ALTER TABLE "game_libraries" ALTER COLUMN "last_played" DROP NOT NULL;--> statement-breakpoint
+ALTER TABLE "game_libraries" ADD CONSTRAINT "game_libraries_base_game_id_owner_steam_id_pk" PRIMARY KEY("base_game_id","owner_steam_id");--> statement-breakpoint
+ALTER TABLE "game_libraries" ADD CONSTRAINT "game_libraries_owner_steam_id_steam_accounts_id_fk" FOREIGN KEY ("owner_steam_id") REFERENCES "public"."steam_accounts"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
+ALTER TABLE "teams" ADD CONSTRAINT "teams_owner_steam_id_steam_accounts_id_fk" FOREIGN KEY ("owner_steam_id") REFERENCES "public"."steam_accounts"("id") ON DELETE cascade ON UPDATE no action;--> statement-breakpoint
+CREATE INDEX "idx_game_libraries_owner_id" ON "game_libraries" USING btree ("owner_steam_id");--> statement-breakpoint
+ALTER TABLE "game_libraries" DROP COLUMN "time_acquired";--> statement-breakpoint
+ALTER TABLE "game_libraries" DROP COLUMN "is_family_shared";--> statement-breakpoint
+ALTER TABLE "steam_accounts" DROP COLUMN "username";--> statement-breakpoint
+ALTER TABLE "teams" DROP COLUMN "slug";

packages/core/migrations/0021_real_skreet.sql

@@ -0,0 +1,2 @@
+ALTER TYPE "public"."category_type" ADD VALUE 'category';--> statement-breakpoint
+ALTER TYPE "public"."category_type" ADD VALUE 'franchise';

packages/core/migrations/0022_clean_living_lightning.sql

@@ -0,0 +1,6 @@
+ALTER TABLE "public"."categories" ALTER COLUMN "type" SET DATA TYPE text;--> statement-breakpoint
+ALTER TABLE "public"."games" ALTER COLUMN "type" SET DATA TYPE text;--> statement-breakpoint
+DROP TYPE "public"."category_type";--> statement-breakpoint
+CREATE TYPE "public"."category_type" AS ENUM('tag', 'genre', 'publisher', 'developer', 'categorie', 'franchise');--> statement-breakpoint
+ALTER TABLE "public"."categories" ALTER COLUMN "type" SET DATA TYPE "public"."category_type" USING "type"::"public"."category_type";--> statement-breakpoint
+ALTER TABLE "public"."games" ALTER COLUMN "type" SET DATA TYPE "public"."category_type" USING "type"::"public"."category_type";

packages/core/migrations/0023_flawless_steel_serpent.sql

@@ -0,0 +1,2 @@
+ALTER TABLE "base_games" ALTER COLUMN "description" DROP NOT NULL;--> statement-breakpoint
+ALTER TABLE "base_games" ADD COLUMN "links" text[];

packages/core/migrations/0024_damp_cerise.sql

@@ -0,0 +1 @@
+ALTER TABLE "base_games" ALTER COLUMN "links" SET DATA TYPE json;

packages/core/migrations/0025_bitter_jack_flag.sql

@@ -0,0 +1,3 @@
+DROP TABLE "members" CASCADE;--> statement-breakpoint
+DROP TABLE "teams" CASCADE;--> statement-breakpoint
+DROP TYPE "public"."member_role";

packages/core/migrations/meta/0025_snapshot.json

@@ -0,0 +1,930 @@
+{
+  "id": "735d315b-40e1-46c1-814d-0fd3619b65de",
+  "prevId": "d35aa09b-5739-46a5-86f3-3050913dc2f7",
+  "version": "7",
+  "dialect": "postgresql",
+  "tables": {
+    "public.base_games": {
+      "name": "base_games",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "id": {
+          "name": "id",
+          "type": "varchar(255)",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "links": {
+          "name": "links",
+          "type": "json",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "slug": {
+          "name": "slug",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "description": {
+          "name": "description",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "release_date": {
+          "name": "release_date",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "size": {
+          "name": "size",
+          "type": "json",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "primary_genre": {
+          "name": "primary_genre",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "controller_support": {
+          "name": "controller_support",
+          "type": "controller_support",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "compatibility": {
+          "name": "compatibility",
+          "type": "compatibility",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "'unknown'"
+        },
+        "score": {
+          "name": "score",
+          "type": "numeric(2, 1)",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "idx_base_games_slug": {
+          "name": "idx_base_games_slug",
+          "nullsNotDistinct": false,
+          "columns": [
+            "slug"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.categories": {
+      "name": "categories",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "slug": {
+          "name": "slug",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "type": {
+          "name": "type",
+          "type": "category_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "idx_categories_type": {
+          "name": "idx_categories_type",
+          "columns": [
+            {
+              "expression": "type",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {},
+      "compositePrimaryKeys": {
+        "categories_slug_type_pk": {
+          "name": "categories_slug_type_pk",
+          "columns": [
+            "slug",
+            "type"
+          ]
+        }
+      },
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.friends_list": {
+      "name": "friends_list",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "steam_id": {
+          "name": "steam_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "friend_steam_id": {
+          "name": "friend_steam_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "idx_friends_list_friend_steam_id": {
+          "name": "idx_friends_list_friend_steam_id",
+          "columns": [
+            {
+              "expression": "friend_steam_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "friends_list_steam_id_steam_accounts_id_fk": {
+          "name": "friends_list_steam_id_steam_accounts_id_fk",
+          "tableFrom": "friends_list",
+          "tableTo": "steam_accounts",
+          "columnsFrom": [
+            "steam_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "friends_list_friend_steam_id_steam_accounts_id_fk": {
+          "name": "friends_list_friend_steam_id_steam_accounts_id_fk",
+          "tableFrom": "friends_list",
+          "tableTo": "steam_accounts",
+          "columnsFrom": [
+            "friend_steam_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {
+        "friends_list_steam_id_friend_steam_id_pk": {
+          "name": "friends_list_steam_id_friend_steam_id_pk",
+          "columns": [
+            "steam_id",
+            "friend_steam_id"
+          ]
+        }
+      },
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.games": {
+      "name": "games",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "base_game_id": {
+          "name": "base_game_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "category_slug": {
+          "name": "category_slug",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "type": {
+          "name": "type",
+          "type": "category_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "idx_games_category_slug": {
+          "name": "idx_games_category_slug",
+          "columns": [
+            {
+              "expression": "category_slug",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "idx_games_category_type": {
+          "name": "idx_games_category_type",
+          "columns": [
+            {
+              "expression": "type",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "idx_games_category_slug_type": {
+          "name": "idx_games_category_slug_type",
+          "columns": [
+            {
+              "expression": "category_slug",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            },
+            {
+              "expression": "type",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "games_base_game_id_base_games_id_fk": {
+          "name": "games_base_game_id_base_games_id_fk",
+          "tableFrom": "games",
+          "tableTo": "base_games",
+          "columnsFrom": [
+            "base_game_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "games_categories_fkey": {
+          "name": "games_categories_fkey",
+          "tableFrom": "games",
+          "tableTo": "categories",
+          "columnsFrom": [
+            "category_slug",
+            "type"
+          ],
+          "columnsTo": [
+            "slug",
+            "type"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {
+        "games_base_game_id_category_slug_type_pk": {
+          "name": "games_base_game_id_category_slug_type_pk",
+          "columns": [
+            "base_game_id",
+            "category_slug",
+            "type"
+          ]
+        }
+      },
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.images": {
+      "name": "images",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "type": {
+          "name": "type",
+          "type": "image_type",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "image_hash": {
+          "name": "image_hash",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "base_game_id": {
+          "name": "base_game_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "source_url": {
+          "name": "source_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "position": {
+          "name": "position",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true,
+          "default": 0
+        },
+        "file_size": {
+          "name": "file_size",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "dimensions": {
+          "name": "dimensions",
+          "type": "json",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "extracted_color": {
+          "name": "extracted_color",
+          "type": "json",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "idx_images_type": {
+          "name": "idx_images_type",
+          "columns": [
+            {
+              "expression": "type",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        },
+        "idx_images_game_id": {
+          "name": "idx_images_game_id",
+          "columns": [
+            {
+              "expression": "base_game_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "images_base_game_id_base_games_id_fk": {
+          "name": "images_base_game_id_base_games_id_fk",
+          "tableFrom": "images",
+          "tableTo": "base_games",
+          "columnsFrom": [
+            "base_game_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {
+        "images_image_hash_type_base_game_id_position_pk": {
+          "name": "images_image_hash_type_base_game_id_position_pk",
+          "columns": [
+            "image_hash",
+            "type",
+            "base_game_id",
+            "position"
+          ]
+        }
+      },
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.game_libraries": {
+      "name": "game_libraries",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "base_game_id": {
+          "name": "base_game_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "owner_steam_id": {
+          "name": "owner_steam_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "last_played": {
+          "name": "last_played",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "total_playtime": {
+          "name": "total_playtime",
+          "type": "integer",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {
+        "idx_game_libraries_owner_id": {
+          "name": "idx_game_libraries_owner_id",
+          "columns": [
+            {
+              "expression": "owner_steam_id",
+              "isExpression": false,
+              "asc": true,
+              "nulls": "last"
+            }
+          ],
+          "isUnique": false,
+          "concurrently": false,
+          "method": "btree",
+          "with": {}
+        }
+      },
+      "foreignKeys": {
+        "game_libraries_base_game_id_base_games_id_fk": {
+          "name": "game_libraries_base_game_id_base_games_id_fk",
+          "tableFrom": "game_libraries",
+          "tableTo": "base_games",
+          "columnsFrom": [
+            "base_game_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        },
+        "game_libraries_owner_steam_id_steam_accounts_id_fk": {
+          "name": "game_libraries_owner_steam_id_steam_accounts_id_fk",
+          "tableFrom": "game_libraries",
+          "tableTo": "steam_accounts",
+          "columnsFrom": [
+            "owner_steam_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {
+        "game_libraries_base_game_id_owner_steam_id_pk": {
+          "name": "game_libraries_base_game_id_owner_steam_id_pk",
+          "columns": [
+            "base_game_id",
+            "owner_steam_id"
+          ]
+        }
+      },
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.steam_accounts": {
+      "name": "steam_accounts",
+      "schema": "",
+      "columns": {
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "id": {
+          "name": "id",
+          "type": "varchar(255)",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "user_id": {
+          "name": "user_id",
+          "type": "char(30)",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "status": {
+          "name": "status",
+          "type": "steam_status",
+          "typeSchema": "public",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "last_synced_at": {
+          "name": "last_synced_at",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "real_name": {
+          "name": "real_name",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "member_since": {
+          "name": "member_since",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "profile_url": {
+          "name": "profile_url",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "avatar_hash": {
+          "name": "avatar_hash",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "limitations": {
+          "name": "limitations",
+          "type": "json",
+          "primaryKey": false,
+          "notNull": true
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {
+        "steam_accounts_user_id_users_id_fk": {
+          "name": "steam_accounts_user_id_users_id_fk",
+          "tableFrom": "steam_accounts",
+          "tableTo": "users",
+          "columnsFrom": [
+            "user_id"
+          ],
+          "columnsTo": [
+            "id"
+          ],
+          "onDelete": "cascade",
+          "onUpdate": "no action"
+        }
+      },
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {},
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    },
+    "public.users": {
+      "name": "users",
+      "schema": "",
+      "columns": {
+        "id": {
+          "name": "id",
+          "type": "char(30)",
+          "primaryKey": true,
+          "notNull": true
+        },
+        "time_created": {
+          "name": "time_created",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_updated": {
+          "name": "time_updated",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true,
+          "default": "now()"
+        },
+        "time_deleted": {
+          "name": "time_deleted",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "email": {
+          "name": "email",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "avatar_url": {
+          "name": "avatar_url",
+          "type": "text",
+          "primaryKey": false,
+          "notNull": false
+        },
+        "last_login": {
+          "name": "last_login",
+          "type": "timestamp with time zone",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "name": {
+          "name": "name",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": true
+        },
+        "polar_customer_id": {
+          "name": "polar_customer_id",
+          "type": "varchar(255)",
+          "primaryKey": false,
+          "notNull": false
+        }
+      },
+      "indexes": {},
+      "foreignKeys": {},
+      "compositePrimaryKeys": {},
+      "uniqueConstraints": {
+        "idx_user_email": {
+          "name": "idx_user_email",
+          "nullsNotDistinct": false,
+          "columns": [
+            "email"
+          ]
+        }
+      },
+      "policies": {},
+      "checkConstraints": {},
+      "isRLSEnabled": false
+    }
+  },
+  "enums": {
+    "public.compatibility": {
+      "name": "compatibility",
+      "schema": "public",
+      "values": [
+        "high",
+        "mid",
+        "low",
+        "unknown"
+      ]
+    },
+    "public.controller_support": {
+      "name": "controller_support",
+      "schema": "public",
+      "values": [
+        "full",
+        "partial",
+        "unknown"
+      ]
+    },
+    "public.category_type": {
+      "name": "category_type",
+      "schema": "public",
+      "values": [
+        "tag",
+        "genre",
+        "publisher",
+        "developer",
+        "categorie",
+        "franchise"
+      ]
+    },
+    "public.image_type": {
+      "name": "image_type",
+      "schema": "public",
+      "values": [
+        "heroArt",
+        "icon",
+        "logo",
+        "banner",
+        "poster",
+        "boxArt",
+        "screenshot",
+        "backdrop"
+      ]
+    },
+    "public.steam_status": {
+      "name": "steam_status",
+      "schema": "public",
+      "values": [
+        "online",
+        "offline",
+        "dnd",
+        "playing"
+      ]
+    }
+  },
+  "schemas": {},
+  "sequences": {},
+  "roles": {},
+  "policies": {},
+  "views": {},
+  "_meta": {
+    "columns": {},
+    "schemas": {},
+    "tables": {}
+  }
+}

packages/core/migrations/meta/_journal.json

@@ -141,6 +141,48 @@
       "when": 1747202158003,
       "tag": "0019_charming_namorita",
       "breakpoints": true
+    },
+    {
+      "idx": 20,
+      "version": "7",
+      "when": 1747795508868,
+      "tag": "0020_vengeful_wallop",
+      "breakpoints": true
+    },
+    {
+      "idx": 21,
+      "version": "7",
+      "when": 1747975397543,
+      "tag": "0021_real_skreet",
+      "breakpoints": true
+    },
+    {
+      "idx": 22,
+      "version": "7",
+      "when": 1748099972605,
+      "tag": "0022_clean_living_lightning",
+      "breakpoints": true
+    },
+    {
+      "idx": 23,
+      "version": "7",
+      "when": 1748411845939,
+      "tag": "0023_flawless_steel_serpent",
+      "breakpoints": true
+    },
+    {
+      "idx": 24,
+      "version": "7",
+      "when": 1748414049463,
+      "tag": "0024_damp_cerise",
+      "breakpoints": true
+    },
+    {
+      "idx": 25,
+      "version": "7",
+      "when": 1748845818197,
+      "tag": "0025_bitter_jack_flag",
+      "breakpoints": true
     }
   ]
 }

packages/core/package.json

@@ -17,6 +17,7 @@
         "@tsconfig/node20": "^20.1.4",
         "@types/pngjs": "^6.0.5",
         "@types/sanitize-html": "^2.16.0",
+        "@types/xml2js": "^0.4.14",
         "aws-iot-device-sdk-v2": "^1.21.1",
         "aws4fetch": "^1.0.20",
         "mqtt": "^5.10.3",
@@ -42,6 +43,7 @@
         "postgres": "^3.4.5",
         "sanitize-html": "^2.16.0",
         "sharp": "^0.34.1",
-        "steam-session": "*"
+        "steam-session": "*",
+        "xml2js": "^0.6.2"
     }
 }

packages/core/src/account/index.ts

@@ -1,6 +1,6 @@
 import { z } from "zod"
 import { User } from "../user";
-import { Team } from "../team";
+import { Steam } from "../steam";
 import { Actor } from "../actor";
 import { Examples } from "../examples";
 import { ErrorCodes, VisibleError } from "../error";
@@ -9,26 +9,26 @@ export namespace Account {
     export const Info =
         User.Info
             .extend({
-                teams: Team.Info
+                profiles: Steam.Info
                     .array()
                     .openapi({
-                        description: "The teams that this user is part of",
-                        example: [Examples.Team]
+                        description: "The Steam accounts this user owns",
+                        example: [Examples.SteamAccount]
                     })
             })
             .openapi({
                 ref: "Account",
                 description: "Represents an account's information stored on Nestri",
-                example: { ...Examples.User, teams: [Examples.Team] },
+                example: { ...Examples.User, profiles: [Examples.SteamAccount] },
             });
 
     export type Info = z.infer<typeof Info>;
 
     export const list = async (): Promise<Info> => {
-        const [userResult, teamsResult] =
+        const [userResult, steamResult] =
             await Promise.allSettled([
                 User.fromID(Actor.userID()),
-                Team.list()
+                Steam.list()
             ])
 
         if (userResult.status === "rejected" || !userResult.value)
@@ -40,7 +40,7 @@ export namespace Account {
 
         return {
             ...userResult.value,
-            teams: teamsResult.status === "rejected" ? [] : teamsResult.value
+            profiles: steamResult.status === "rejected" ? [] : steamResult.value
         }
     }
 

packages/core/src/actor.ts

@@ -11,11 +11,11 @@ export namespace Actor {
       email: string;
     };
   }
-
-  export interface System {
-    type: "system";
+  
+  export interface Steam {
+    type: "steam";
     properties: {
-      teamID: string;
+      steamID: string;
     };
   }
 
@@ -32,7 +32,6 @@ export namespace Actor {
     properties: {
       userID: string;
       steamID: string;
-      teamID: string;
     };
   }
 
@@ -41,7 +40,7 @@ export namespace Actor {
     properties: {};
   }
 
-  export type Info = User | Public | Token | System | Machine;
+  export type Info = User | Public | Token | Machine | Steam;
 
   export const Context = createContext<Info>();
 

packages/core/src/base-game/base-game.sql.ts

@@ -3,15 +3,18 @@ import { timestamps, utc } from "../drizzle/types";
 import { json, numeric, pgEnum, pgTable, text, unique, varchar } from "drizzle-orm/pg-core";
 
 export const CompatibilityEnum = pgEnum("compatibility", ["high", "mid", "low", "unknown"])
-export const ControllerEnum = pgEnum("controller_support", ["full","partial", "unknown"])
+export const ControllerEnum = pgEnum("controller_support", ["full", "partial", "unknown"])
 
 export const Size =
     z.object({
         downloadSize: z.number().positive().int(),
         sizeOnDisk: z.number().positive().int()
-    })
+    });
 
-export type Size = z.infer<typeof Size>
+export const Links = z.string().array();
+
+export type Size = z.infer<typeof Size>;
+export type Links = z.infer<typeof Links>;
 
 export const baseGamesTable = pgTable(
     "base_games",
@@ -20,12 +23,13 @@ export const baseGamesTable = pgTable(
         id: varchar("id", { length: 255 })
             .primaryKey()
             .notNull(),
+        links: json("links").$type<Links>(),
         slug: varchar("slug", { length: 255 })
             .notNull(),
         name: text("name").notNull(),
+        description: text("description"),
         releaseDate: utc("release_date").notNull(),
         size: json("size").$type<Size>().notNull(),
-        description: text("description").notNull(),
         primaryGenre: text("primary_genre"),
         controllerSupport: ControllerEnum("controller_support").notNull(),
         compatibility: CompatibilityEnum("compatibility").notNull().default("unknown"),

packages/core/src/base-game/index.ts

@@ -1,13 +1,12 @@
 import { z } from "zod";
 import { fn } from "../utils";
-import { Resource } from "sst";
-import { bus } from "sst/aws/bus";
 import { Common } from "../common";
 import { Examples } from "../examples";
 import { createEvent } from "../event";
 import { eq, isNull, and } from "drizzle-orm";
-import { afterTx, createTransaction, useTransaction } from "../drizzle/transaction";
-import { CompatibilityEnum, baseGamesTable, Size, ControllerEnum } from "./base-game.sql";
+import { ImageTypeEnum } from "../images/images.sql";
+import { createTransaction, useTransaction } from "../drizzle/transaction";
+import { CompatibilityEnum, baseGamesTable, Size, ControllerEnum, Links } from "./base-game.sql";
 
 export namespace BaseGame {
     export const Info = z.object({
@@ -31,7 +30,7 @@ export namespace BaseGame {
             description: "The initial public release date of the game on Steam",
             example: Examples.BaseGame.releaseDate
         }),
-        description: z.string().openapi({
+        description: z.string().nullable().openapi({
             description: "A comprehensive overview of the game, including its features, storyline, and gameplay elements",
             example: Examples.BaseGame.description
         }),
@@ -39,6 +38,12 @@ export namespace BaseGame {
             description: "The aggregate user review score on Steam, represented as a percentage of positive reviews",
             example: Examples.BaseGame.score
         }),
+        links: Links
+            .nullable()
+            .openapi({
+                description: "The social links of this game",
+                example: Examples.BaseGame.links
+            }),
         primaryGenre: z.string().nullable().openapi({
             description: "The main category or genre that best represents the game's content and gameplay style",
             example: Examples.BaseGame.primaryGenre
@@ -50,7 +55,7 @@ export namespace BaseGame {
         compatibility: z.enum(CompatibilityEnum.enumValues).openapi({
             description: "Steam Deck/Proton compatibility rating indicating how well the game runs on Linux systems",
             example: Examples.BaseGame.compatibility
-        })
+        }),
     }).openapi({
         ref: "BaseGame",
         description: "Detailed information about a game available in the Nestri library, including technical specifications and metadata",
@@ -61,9 +66,27 @@ export namespace BaseGame {
 
     export const Events = {
         New: createEvent(
-            "new_game.added",
+            "new_image.save",
             z.object({
                 appID: Info.shape.id,
+                url: z.string().url(),
+                type: z.enum(ImageTypeEnum.enumValues)
+            }),
+        ),
+        NewBoxArt: createEvent(
+            "new_box_art_image.save",
+            z.object({
+                appID: Info.shape.id,
+                logoUrl: z.string().url(),
+                backgroundUrl: z.string().url(),
+            }),
+        ),
+        NewHeroArt: createEvent(
+            "new_hero_art_image.save",
+            z.object({
+                appID: Info.shape.id,
+                backdropUrl: z.string().url(),
+                screenshots: z.string().url().array(),
             }),
         ),
     };
@@ -72,6 +95,21 @@ export namespace BaseGame {
         Info,
         (input) =>
             createTransaction(async (tx) => {
+                const result = await tx
+                    .select()
+                    .from(baseGamesTable)
+                    .where(
+                        and(
+                            eq(baseGamesTable.id, input.id),
+                            isNull(baseGamesTable.timeDeleted)
+                        )
+                    )
+                    .limit(1)
+                    .execute()
+                    .then(rows => rows.at(0))
+
+                if (result) return result.id
+
                 await tx
                     .insert(baseGamesTable)
                     .values(input)
@@ -82,10 +120,6 @@ export namespace BaseGame {
                         }
                     })
 
-                await afterTx(async () => {
-                    await bus.publish(Resource.Bus, Events.New, { appID: input.id })
-                })
-
                 return input.id
             })
     )
@@ -116,6 +150,7 @@ export namespace BaseGame {
             name: input.name,
             slug: input.slug,
             size: input.size,
+            links: input.links,
             score: input.score,
             description: input.description,
             releaseDate: input.releaseDate,

packages/core/src/categories/categories.sql.ts

@@ -1,7 +1,8 @@
 import { timestamps } from "../drizzle/types";
 import { index, pgEnum, pgTable, primaryKey, text, varchar } from "drizzle-orm/pg-core";
 
-export const CategoryTypeEnum = pgEnum("category_type", ["tag", "genre", "publisher", "developer"])
+// Intentional grammatical error on category
+export const CategoryTypeEnum = pgEnum("category_type", ["tag", "genre", "publisher", "developer", "categorie", "franchise"])
 
 export const categoriesTable = pgTable(
     "categories",

packages/core/src/categories/index.ts

@@ -1,10 +1,10 @@
 import { z } from "zod";
 import { fn } from "../utils";
 import { Examples } from "../examples";
+import { eq, isNull, and } from "drizzle-orm";
 import { createSelectSchema } from "drizzle-zod";
 import { categoriesTable } from "./categories.sql";
 import { createTransaction, useTransaction } from "../drizzle/transaction";
-import { eq, isNull, and } from "drizzle-orm";
 
 export namespace Categories {
 
@@ -36,7 +36,16 @@ export namespace Categories {
             genres: Category.array().openapi({
                 description: "Primary classification categories that define the game's style and type of gameplay",
                 example: Examples.Categories.genres
-            })
+            }),
+            categories: Category.array().openapi({
+                description: "Primary classification categories that define the game's categorisation on Steam",
+                example: Examples.Categories.genres
+            }),
+            franchises: Category.array().openapi({
+                description: "The franchise this game belongs belongs to on Steam",
+                example: Examples.Categories.genres
+            }),
+
         }).openapi({
             ref: "Categories",
             description: "A comprehensive categorization system for games, including publishing details, development credits, and content classification",
@@ -111,7 +120,9 @@ export namespace Categories {
             tags: [],
             genres: [],
             publishers: [],
-            developers: []
+            developers: [],
+            categories: [],
+            franchises: []
         })
     }
 }

packages/core/src/client/index.ts

@@ -1,159 +1,172 @@
 import type {
+    Shot,
     AppInfo,
-    GameTagsResponse,
-    SteamApiResponse,
-    GameDetailsResponse,
-    SteamAppDataResponse,
     ImageInfo,
     ImageType,
-    Shot
+    SteamAccount,
+    GameTagsResponse,
+    GameDetailsResponse,
+    SteamAppDataResponse,
+    SteamOwnedGamesResponse,
+    SteamPlayerBansResponse,
+    SteamFriendsListResponse,
+    SteamPlayerSummaryResponse,
+    SteamStoreResponse,
 } from "./types";
 import { z } from "zod";
-import pLimit from 'p-limit';
-import SteamID from "steamid";
 import { fn } from "../utils";
+import { Resource } from "sst";
+import { Steam } from "./steam";
 import { Utils } from "./utils";
-import SteamCommunity from "steamcommunity";
-import { Credentials } from "../credentials";
-import type CSteamUser from "steamcommunity/classes/CSteamUser";
-
-const requestLimit = pLimit(10); // max concurrent requests
+import { ImageTypeEnum } from "../images/images.sql";
 
 export namespace Client {
     export const getUserLibrary = fn(
-        Credentials.Info.shape.accessToken,
-        async (accessToken) =>
-            await Utils.fetchApi<SteamApiResponse>(`https://api.steampowered.com/IFamilyGroupsService/GetSharedLibraryApps/v1/?access_token=${accessToken}&family_groupid=0&include_excluded=true&include_free=true&include_non_games=false&include_own=true`)
+        z.string(),
+        async (steamID) =>
+            await Utils.fetchApi<SteamOwnedGamesResponse>(`https://api.steampowered.com/IPlayerService/GetOwnedGames/v0001/?key=${Resource.SteamApiKey.value}&steamid=${steamID}&include_appinfo=1&format=json&include_played_free_games=1&skip_unvetted_apps=0`)
     )
 
     export const getFriendsList = fn(
-        Credentials.Info.shape.cookies,
-        async (cookies): Promise<CSteamUser[]> => {
-            const community = new SteamCommunity();
-            community.setCookies(cookies);
-
-            const allFriends = await new Promise<Record<string, any>>((resolve, reject) => {
-                community.getFriendsList((err, friends) => {
-                    if (err) {
-                        return reject(new Error(`Could not get friends list: ${err.message}`));
-                    }
-                    resolve(friends);
-                });
-            });
-
-            const friendIds = Object.keys(allFriends);
-
-            const userPromises: Promise<CSteamUser>[] = friendIds.map(id =>
-                requestLimit(() => new Promise<CSteamUser>((resolve, reject) => {
-                    const sid = new SteamID(id);
-                    community.getSteamUser(sid, (err, user) => {
-                        if (err) {
-                            return reject(new Error(`Could not get steam user info for ${id}: ${err.message}`));
-                        }
-                        resolve(user);
-                    });
-                }))
-            );
-
-            const settled = await Promise.allSettled(userPromises)
-
-            settled
-                .filter(r => r.status === "rejected")
-                .forEach(r => console.warn("[getFriendsList] failed:", (r as PromiseRejectedResult).reason));
-
-            return settled.filter(s => s.status === "fulfilled").map(r => (r as PromiseFulfilledResult<CSteamUser>).value);
-        }
+        z.string(),
+        async (steamID) =>
+            await Utils.fetchApi<SteamFriendsListResponse>(`https://api.steampowered.com/ISteamUser/GetFriendList/v0001/?key=${Resource.SteamApiKey.value}&steamid=${steamID}&relationship=friend`)
     );
 
     export const getUserInfo = fn(
-        Credentials.Info.pick({ cookies: true, steamID: true }),
-        async (input) =>
-            new Promise((resolve, reject) => {
-                const community = new SteamCommunity()
-                community.setCookies(input.cookies);
-                const steamID = new SteamID(input.steamID);
-                community.getSteamUser(steamID, async (err, user) => {
-                    if (err) {
-                        reject(`Could not get steam user info: ${err.message}`)
+        z.string().array(),
+        async (steamIDs) => {
+            const [userInfo, banInfo, profileInfo] = await Promise.all([
+                Utils.fetchApi<SteamPlayerSummaryResponse>(`https://api.steampowered.com/ISteamUser/GetPlayerSummaries/v0002/?key=${Resource.SteamApiKey.value}&steamids=${steamIDs.join(",")}`),
+                Utils.fetchApi<SteamPlayerBansResponse>(`https://api.steampowered.com/ISteamUser/GetPlayerBans/v1/?key=${Resource.SteamApiKey.value}&steamids=${steamIDs.join(",")}`),
+                Utils.fetchProfilesInfo(steamIDs)
+            ])
+
+            // Create a map of bans by steamID for fast lookup
+            const bansBySteamID = new Map(
+                banInfo.players.map((b) => [b.SteamId, b])
+            );
+
+            // Map userInfo.players to your desired output using Promise.allSettled 
+            // to prevent one error from closing down the whole pipeline
+            const steamAccounts = await Promise.allSettled(
+                userInfo.response.players.map(async (player) => {
+                    const ban = bansBySteamID.get(player.steamid);
+                    const info = profileInfo.get(player.steamid);
+
+                    if (!info) {
+                        throw new Error(`[userInfo] profile info missing for ${player.steamid}`)
+                    }
+
+                    if ('error' in info) {
+                        throw new Error(`error handling profile info for: ${player.steamid}:${info.error}`)
                     } else {
-                        resolve(user)
+                        return {
+                            id: player.steamid,
+                            name: player.personaname,
+                            realName: player.realname ?? null,
+                            steamMemberSince: new Date(player.timecreated * 1000),
+                            avatarHash: player.avatarhash,
+                            limitations: {
+                                isLimited: info.isLimited,
+                                privacyState: info.privacyState,
+                                isVacBanned: ban?.VACBanned ?? false,
+                                tradeBanState: ban?.EconomyBan ?? "none",
+                                visibilityState: player.communityvisibilitystate,
+                            },
+                            lastSyncedAt: new Date(),
+                            profileUrl: player.profileurl,
+                        };
                     }
                 })
-            }) as Promise<CSteamUser>
-    )
+            );
+
+            steamAccounts
+                .filter(result => result.status === 'rejected')
+                .forEach(result => console.warn('[userInfo] failed:', (result as PromiseRejectedResult).reason))
+
+            return steamAccounts.filter(result => result.status === "fulfilled").map(result => (result as PromiseFulfilledResult<SteamAccount>).value)
+        })
 
     export const getAppInfo = fn(
         z.string(),
         async (appid) => {
-            const [infoData, tagsData, details] = await Promise.all([
-                Utils.fetchApi<SteamAppDataResponse>(`https://api.steamcmd.net/v1/info/${appid}`),
-                Utils.fetchApi<GameTagsResponse>("https://store.steampowered.com/actions/ajaxgetstoretags"),
-                Utils.fetchApi<GameDetailsResponse>(
-                    `https://store.steampowered.com/apphover/${appid}?full=1&review_score_preference=1&pagev6=true&json=1`
-                ),
-            ]);
+            try {
+                const info = await Promise.all([
+                    Utils.fetchApi<SteamAppDataResponse>(`https://api.steamcmd.net/v1/info/${appid}`),
+                    Utils.fetchApi<SteamStoreResponse>(`https://api.steampowered.com/IStoreBrowseService/GetItems/v1/?key=${Resource.SteamApiKey.value}&input_json={"ids":[{"appid":"${appid}"}],"context":{"language":"english","country_code":"US","steam_realm":"1"},"data_request":{"include_assets":true,"include_release":true,"include_platforms":true,"include_all_purchase_options":true,"include_screenshots":true,"include_trailers":true,"include_ratings":true,"include_tag_count":"40","include_reviews":true,"include_basic_info":true,"include_supported_languages":true,"include_full_description":true,"include_included_items":true,"include_assets_without_overrides":true,"apply_user_filters":true,"include_links":true}}`),
+                ]);
 
-            const tags = tagsData.tags;
-            const game = infoData.data[appid];
-            // Guard against an empty string - When there are no genres, Steam returns an empty string
-            const genres = details.strGenres ? Utils.parseGenres(details.strGenres) : [];
+                const cmd = info[0].data[appid]
+                const store = info[1].response.store_items[0]
 
-            const controllerTag = game.common.controller_support ?
-                Utils.createTag(`${Utils.capitalise(game.common.controller_support)} Controller Support`) :
-                Utils.createTag(`Unknown Controller Support`)
+                if (!cmd) {
+                    throw new Error(`App data not found for appid: ${appid}`)
+                }
 
-            const compatibilityTag = Utils.createTag(`${Utils.capitalise(Utils.compatibilityType(game.common.steam_deck_compatibility?.category))} Compatibility`)
+                if (!store || store.success !== 1) {
+                    throw new Error(`Could not get store information or appid: ${appid}`)
+                }
 
-            const controller = (game.common.controller_support === "partial" || game.common.controller_support === "full") ? game.common.controller_support : "unknown";
-            const appInfo: AppInfo = {
-                genres,
-                gameid: game.appid,
-                name: game.common.name.trim(),
-                size: Utils.getPublicDepotSizes(game.depots!),
-                slug: Utils.createSlug(game.common.name.trim()),
-                description: Utils.cleanDescription(details.strDescription),
-                controllerSupport: controller,
-                releaseDate: new Date(Number(game.common.steam_release_date) * 1000),
-                primaryGenre: (!!game?.common.genres && !!details.strGenres) ? Utils.getPrimaryGenre(
-                    genres,
-                    game.common.genres!,
-                    game.common.primary_genre!
-                ) : null,
-                developers: game.common.associations ?
-                    Array.from(
-                        Utils.getAssociationsByTypeWithSlug(
-                            game.common.associations!,
-                            "developer"
-                        )
-                    ) : [],
-                publishers: game.common.associations ?
-                    Array.from(
-                        Utils.getAssociationsByTypeWithSlug(
-                            game.common.associations!,
-                            "publisher"
-                        )
-                    ) : [],
-                compatibility: Utils.compatibilityType(game.common.steam_deck_compatibility?.category),
-                tags: [
-                    ...(game?.common.store_tags ?
-                        Utils.mapGameTags(
-                            tags,
-                            game.common.store_tags!,
-                        ) : []),
-                    controllerTag,
-                    compatibilityTag
-                ],
-                score: Utils.getRating(
-                    details.ReviewSummary.cRecommendationsPositive,
-                    details.ReviewSummary.cRecommendationsNegative
-                ),
-            };
+                const tags = store.tagids
+                    .map(id => Steam.tags[id.toString() as keyof typeof Steam.tags])
+                    .filter((name): name is string => typeof name === 'string')
 
-            return appInfo
+                const publishers = store.basic_info.publishers
+                    .map(i => i.name)
+
+                const developers = store.basic_info.developers
+                    .map(i => i.name)
+
+                const franchises = store.basic_info.franchises
+                    ?.map(i => i.name)
+
+                const genres = cmd?.common.genres &&
+                    Object.keys(cmd?.common.genres)
+                        .map(id => Steam.genres[id.toString() as keyof typeof Steam.genres])
+                        .filter((name): name is string => typeof name === 'string')
+
+                const categories = [
+                    ...(store.categories?.controller_categoryids?.map(i => Steam.categories[i.toString() as keyof typeof Steam.categories]) ?? []),
+                    ...(store.categories?.supported_player_categoryids?.map(i => Steam.categories[i.toString() as keyof typeof Steam.categories]) ?? [])
+                ].filter((name): name is string => typeof name === 'string')
+
+                const assetUrls = Utils.getAssetUrls(cmd?.common.library_assets_full, appid, cmd?.common.header_image.english);
+
+                const screenshots = store.screenshots.all_ages_screenshots?.map(i => `https://shared.cloudflare.steamstatic.com/store_item_assets/${i.filename}`) ?? [];
+
+                const icon = `https://cdn.cloudflare.steamstatic.com/steamcommunity/public/images/apps/${appid}/${cmd?.common.icon}.jpg`;
+
+                const data: AppInfo = {
+                    id: appid,
+                    name: cmd?.common.name.trim(),
+                    tags: Utils.createType(tags, "tag"),
+                    images: { screenshots, icon, ...assetUrls },
+                    size: Utils.getPublicDepotSizes(cmd?.depots!),
+                    slug: Utils.createSlug(cmd?.common.name.trim()),
+                    publishers: Utils.createType(publishers, "publisher"),
+                    developers: Utils.createType(developers, "developer"),
+                    categories: Utils.createType(categories, "categorie"),
+                    links: store.links ? store.links.map(i => i.url) : null,
+                    genres: genres ? Utils.createType(genres, "genre") : [],
+                    franchises: franchises ? Utils.createType(franchises, "franchise") : [],
+                    description: store.basic_info.short_description ? Utils.cleanDescription(store.basic_info.short_description) : null,
+                    controllerSupport: cmd?.common.controller_support ?? "unknown" as any,
+                    releaseDate: new Date(Number(cmd?.common.steam_release_date) * 1000),
+                    primaryGenre: !!cmd?.common.primary_genre && Steam.genres[cmd?.common.primary_genre as keyof typeof Steam.genres] ? Steam.genres[cmd?.common.primary_genre as keyof typeof Steam.genres] : null,
+                    compatibility: store?.platforms.steam_os_compat_category ? Utils.compatibilityType(store?.platforms.steam_os_compat_category.toString() as any).toLowerCase() : "unknown" as any,
+                    score: Utils.estimateRatingFromSummary(store.reviews.summary_filtered.review_count, store.reviews.summary_filtered.percent_positive)
+                }
+
+                return data
+            } catch (err) {
+                console.log(`Error handling: ${appid}`)
+                throw err
+            }
         }
     )
 
-    export const getImages = fn(
+    export const getImageUrls = fn(
         z.string(),
         async (appid) => {
             const [appData, details] = await Promise.all([
@@ -167,18 +180,49 @@ export namespace Client {
             if (!game) throw new Error('Game info missing');
 
             // 2. Prepare URLs
-            const screenshotUrls = Utils.getScreenshotUrls(details.rgScreenshots || []);
+            const screenshots = Utils.getScreenshotUrls(details.rgScreenshots || []);
             const assetUrls = Utils.getAssetUrls(game.library_assets_full, appid, game.header_image.english);
-            const iconUrl = `https://cdn.cloudflare.steamstatic.com/steamcommunity/public/images/apps/${appid}/${game.icon}.jpg`;
+            const icon = `https://cdn.cloudflare.steamstatic.com/steamcommunity/public/images/apps/${appid}/${game.icon}.jpg`;
 
-            //2.5 Get the backdrop buffer and use it to get the best screenshot
-            const baselineBuffer = await Utils.fetchBuffer(assetUrls.backdrop);
+            return { screenshots, icon, ...assetUrls }
+        }
+    )
 
-            // 3. Download screenshot buffers in parallel
+    export const getImageInfo = fn(
+        z.object({
+            type: z.enum(ImageTypeEnum.enumValues),
+            url: z.string()
+        }),
+        async (input) =>
+            Utils.fetchBuffer(input.url)
+                .then(buf => Utils.getImageMetadata(buf))
+                .then(meta => ({ ...meta, position: 0, sourceUrl: input.url, type: input.type } as ImageInfo))
+    )
+
+    export const createBoxArt = fn(
+        z.object({
+            backgroundUrl: z.string(),
+            logoUrl: z.string(),
+        }),
+        async (input) =>
+            Utils.createBoxArtBuffer(input.logoUrl, input.backgroundUrl)
+                .then(buf => Utils.getImageMetadata(buf))
+                .then(meta => ({ ...meta, position: 0, sourceUrl: null, type: 'boxArt' as const }) as ImageInfo)
+    )
+
+    export const createHeroArt = fn(
+        z.object({
+            screenshots: z.string().array(),
+            backdropUrl: z.string()
+        }),
+        async (input) => {
+            // Download screenshot buffers in parallel
             const shots: Shot[] = await Promise.all(
-                screenshotUrls.map(async url => ({ url, buffer: await Utils.fetchBuffer(url) }))
+                input.screenshots.map(async url => ({ url, buffer: await Utils.fetchBuffer(url) }))
             );
 
+            const baselineBuffer = await Utils.fetchBuffer(input.backdropUrl);
+
             // 4. Score screenshots (or pick single)
             const scores =
                 shots.length === 1
@@ -204,37 +248,69 @@ export namespace Client {
                 );
             }
 
-            // 5b. Asset images
-            for (const [type, url] of Object.entries({ ...assetUrls, icon: iconUrl })) {
-                if (!url || type === "backdrop") continue;
-                tasks.push(
-                    Utils.fetchBuffer(url)
-                        .then(buf => Utils.getImageMetadata(buf))
-                        .then(meta => ({ ...meta, position: 0, sourceUrl: url, type: type as ImageType } as ImageInfo))
-                );
-            }
-
-            // 5c. Backdrop
-            tasks.push(
-                Utils.getImageMetadata(baselineBuffer)
-                    .then(meta => ({ ...meta, position: 0, sourceUrl: assetUrls.backdrop, type: "backdrop" as const } as ImageInfo))
-            )
-
-            // 5d. Box art
-            tasks.push(
-                Utils.createBoxArtBuffer(game.library_assets_full, appid)
-                    .then(buf => Utils.getImageMetadata(buf))
-                    .then(meta => ({ ...meta, position: 0, sourceUrl: null, type: 'boxArt' as const }) as ImageInfo)
-            );
-
-            const settled = await Promise.allSettled(tasks)
+            const settled = await Promise.allSettled(tasks);
 
             settled
                 .filter(r => r.status === "rejected")
-                .forEach(r => console.warn("[getImages] failed:", (r as PromiseRejectedResult).reason));
+                .forEach(r => console.warn("[getHeroArt] failed:", (r as PromiseRejectedResult).reason));
 
-            // 6. Await all and return
+            // Await all and return
             return settled.filter(s => s.status === "fulfilled").map(r => (r as PromiseFulfilledResult<ImageInfo>).value)
         }
     )
+
+    /**
+     * Verifies a Steam OpenID response by sending a request back to Steam
+     * with mode=check_authentication
+     */
+    export async function verifyOpenIDResponse(params: URLSearchParams): Promise<string | null> {
+        try {
+            // Create a new URLSearchParams with all the original parameters
+            const verificationParams = new URLSearchParams();
+
+            // Copy all parameters from the original request
+            for (const [key, value] of params.entries()) {
+                verificationParams.append(key, value);
+            }
+
+            // Change mode to check_authentication for verification
+            verificationParams.set('openid.mode', 'check_authentication');
+
+            // Send verification request to Steam
+            const verificationResponse = await fetch('https://steamcommunity.com/openid/login', {
+                method: 'POST',
+                headers: {
+                    'Content-Type': 'application/x-www-form-urlencoded'
+                },
+                body: verificationParams.toString()
+            });
+
+            const responseText = await verificationResponse.text();
+
+            // Check if verification was successful
+            if (!responseText.includes('is_valid:true')) {
+                console.error('OpenID verification failed: Invalid response from Steam', responseText);
+                return null;
+            }
+
+            // Extract steamID from the claimed_id
+            const claimedId = params.get('openid.claimed_id');
+            if (!claimedId) {
+                console.error('OpenID verification failed: Missing claimed_id');
+                return null;
+            }
+
+            // Extract the Steam ID from the claimed_id
+            const steamID = claimedId.split('/').pop();
+            if (!steamID || !/^\d+$/.test(steamID)) {
+                console.error('OpenID verification failed: Invalid steamID format', steamID);
+                return null;
+            }
+
+            return steamID;
+        } catch (error) {
+            console.error('OpenID verification error:', error);
+            return null;
+        }
+    }
 }

packages/core/src/client/steam.ts

@@ -0,0 +1,544 @@
+export namespace Steam {
+    //Source: https://github.com/woctezuma/steam-api/blob/master/data/genres.json
+    export const genres = {
+        "1": "Action",
+        "2": "Strategy",
+        "3": "RPG",
+        "4": "Casual",
+        "9": "Racing",
+        "18": "Sports",
+        "23": "Indie",
+        "25": "Adventure",
+        "28": "Simulation",
+        "29": "Massively Multiplayer",
+        "37": "Free to Play",
+        "50": "Accounting",
+        "51": "Animation & Modeling",
+        "52": "Audio Production",
+        "53": "Design & Illustration",
+        "54": "Education",
+        "55": "Photo Editing",
+        "56": "Software Training",
+        "57": "Utilities",
+        "58": "Video Production",
+        "59": "Web Publishing",
+        "60": "Game Development",
+        "70": "Early Access",
+        "71": "Sexual Content",
+        "72": "Nudity",
+        "73": "Violent",
+        "74": "Gore",
+        "80": "Movie",
+        "81": "Documentary",
+        "82": "Episodic",
+        "83": "Short",
+        "84": "Tutorial",
+        "85": "360 Video"
+    }
+
+    //Source: https://github.com/woctezuma/steam-api/blob/master/data/categories.json
+    export const categories = {
+        "1": "Multi-player",
+        "2": "Single-player",
+        "6": "Mods (require HL2)",
+        "7": "Mods (require HL1)",
+        "8": "Valve Anti-Cheat enabled",
+        "9": "Co-op",
+        "10": "Demos",
+        "12": "HDR available",
+        "13": "Captions available",
+        "14": "Commentary available",
+        "15": "Stats",
+        "16": "Includes Source SDK",
+        "17": "Includes level editor",
+        "18": "Partial Controller Support",
+        "19": "Mods",
+        "20": "MMO",
+        "21": "Downloadable Content",
+        "22": "Steam Achievements",
+        "23": "Steam Cloud",
+        "24": "Shared/Split Screen",
+        "25": "Steam Leaderboards",
+        "27": "Cross-Platform Multiplayer",
+        "28": "Full controller support",
+        "29": "Steam Trading Cards",
+        "30": "Steam Workshop",
+        "31": "VR Support",
+        "32": "Steam Turn Notifications",
+        "33": "Native Steam Controller",
+        "35": "In-App Purchases",
+        "36": "Online PvP",
+        "37": "Shared/Split Screen PvP",
+        "38": "Online Co-op",
+        "39": "Shared/Split Screen Co-op",
+        "40": "SteamVR Collectibles",
+        "41": "Remote Play on Phone",
+        "42": "Remote Play on Tablet",
+        "43": "Remote Play on TV",
+        "44": "Remote Play Together",
+        "45": "Cloud Gaming",
+        "46": "Cloud Gaming (NVIDIA)",
+        "47": "LAN PvP",
+        "48": "LAN Co-op",
+        "49": "PvP",
+        "50": "Additional High-Quality Audio",
+        "51": "Steam Workshop",
+        "52": "Tracked Controller Support",
+        "53": "VR Supported",
+        "54": "VR Only"
+    }
+
+    // Source: https://files.catbox.moe/96bty7.json
+    export const tags = {
+        "9": "Strategy",
+        "19": "Action",
+        "21": "Adventure",
+        "84": "Design & Illustration",
+        "87": "Utilities",
+        "113": "Free to Play",
+        "122": "RPG",
+        "128": "Massively Multiplayer",
+        "492": "Indie",
+        "493": "Early Access",
+        "597": "Casual",
+        "599": "Simulation",
+        "699": "Racing",
+        "701": "Sports",
+        "784": "Video Production",
+        "809": "Photo Editing",
+        "872": "Animation & Modeling",
+        "1027": "Audio Production",
+        "1036": "Education",
+        "1038": "Web Publishing",
+        "1445": "Software Training",
+        "1616": "Trains",
+        "1621": "Music",
+        "1625": "Platformer",
+        "1628": "Metroidvania",
+        "1638": "Dog",
+        "1643": "Building",
+        "1644": "Driving",
+        "1645": "Tower Defense",
+        "1646": "Hack and Slash",
+        "1647": "Western",
+        "1649": "GameMaker",
+        "1651": "Satire",
+        "1654": "Relaxing",
+        "1659": "Zombies",
+        "1662": "Survival",
+        "1663": "FPS",
+        "1664": "Puzzle",
+        "1665": "Match 3",
+        "1666": "Card Game",
+        "1667": "Horror",
+        "1669": "Moddable",
+        "1670": "4X",
+        "1671": "Superhero",
+        "1673": "Aliens",
+        "1674": "Typing",
+        "1676": "RTS",
+        "1677": "Turn-Based",
+        "1678": "War",
+        "1680": "Heist",
+        "1681": "Pirates",
+        "1684": "Fantasy",
+        "1685": "Co-op",
+        "1687": "Stealth",
+        "1688": "Ninja",
+        "1693": "Classic",
+        "1695": "Open World",
+        "1697": "Third Person",
+        "1698": "Point & Click",
+        "1702": "Crafting",
+        "1708": "Tactical",
+        "1710": "Surreal",
+        "1714": "Psychedelic",
+        "1716": "Roguelike",
+        "1717": "Hex Grid",
+        "1718": "MOBA",
+        "1719": "Comedy",
+        "1720": "Dungeon Crawler",
+        "1721": "Psychological Horror",
+        "1723": "Action RTS",
+        "1730": "Sokoban",
+        "1732": "Voxel",
+        "1733": "Unforgiving",
+        "1734": "Fast-Paced",
+        "1736": "LEGO",
+        "1738": "Hidden Object",
+        "1741": "Turn-Based Strategy",
+        "1742": "Story Rich",
+        "1743": "Fighting",
+        "1746": "Basketball",
+        "1751": "Comic Book",
+        "1752": "Rhythm",
+        "1753": "Skateboarding",
+        "1754": "MMORPG",
+        "1755": "Space",
+        "1756": "Great Soundtrack",
+        "1759": "Perma Death",
+        "1770": "Board Game",
+        "1773": "Arcade",
+        "1774": "Shooter",
+        "1775": "PvP",
+        "1777": "Steampunk",
+        "3796": "Based On A Novel",
+        "3798": "Side Scroller",
+        "3799": "Visual Novel",
+        "3810": "Sandbox",
+        "3813": "Real Time Tactics",
+        "3814": "Third-Person Shooter",
+        "3834": "Exploration",
+        "3835": "Post-apocalyptic",
+        "3839": "First-Person",
+        "3841": "Local Co-Op",
+        "3843": "Online Co-Op",
+        "3854": "Lore-Rich",
+        "3859": "Multiplayer",
+        "3871": "2D",
+        "3877": "Precision Platformer",
+        "3878": "Competitive",
+        "3916": "Old School",
+        "3920": "Cooking",
+        "3934": "Immersive",
+        "3942": "Sci-fi",
+        "3952": "Gothic",
+        "3955": "Character Action Game",
+        "3959": "Roguelite",
+        "3964": "Pixel Graphics",
+        "3965": "Epic",
+        "3968": "Physics",
+        "3978": "Survival Horror",
+        "3987": "Historical",
+        "3993": "Combat",
+        "4004": "Retro",
+        "4018": "Vampire",
+        "4026": "Difficult",
+        "4036": "Parkour",
+        "4046": "Dragons",
+        "4057": "Magic",
+        "4064": "Thriller",
+        "4085": "Anime",
+        "4094": "Minimalist",
+        "4102": "Combat Racing",
+        "4106": "Action-Adventure",
+        "4115": "Cyberpunk",
+        "4136": "Funny",
+        "4137": "Transhumanism",
+        "4145": "Cinematic",
+        "4150": "World War II",
+        "4155": "Class-Based",
+        "4158": "Beat 'em up",
+        "4161": "Real-Time",
+        "4166": "Atmospheric",
+        "4168": "Military",
+        "4172": "Medieval",
+        "4175": "Realistic",
+        "4182": "Singleplayer",
+        "4184": "Chess",
+        "4190": "Addictive",
+        "4191": "3D",
+        "4195": "Cartoony",
+        "4202": "Trading",
+        "4231": "Action RPG",
+        "4234": "Short",
+        "4236": "Loot",
+        "4242": "Episodic",
+        "4252": "Stylized",
+        "4255": "Shoot 'Em Up",
+        "4291": "Spaceships",
+        "4295": "Futuristic",
+        "4305": "Colorful",
+        "4325": "Turn-Based Combat",
+        "4328": "City Builder",
+        "4342": "Dark",
+        "4345": "Gore",
+        "4364": "Grand Strategy",
+        "4376": "Assassin",
+        "4400": "Abstract",
+        "4434": "JRPG",
+        "4474": "CRPG",
+        "4486": "Choose Your Own Adventure",
+        "4508": "Co-op Campaign",
+        "4520": "Farming",
+        "4559": "Quick-Time Events",
+        "4562": "Cartoon",
+        "4598": "Alternate History",
+        "4604": "Dark Fantasy",
+        "4608": "Swordplay",
+        "4637": "Top-Down Shooter",
+        "4667": "Violent",
+        "4684": "Wargame",
+        "4695": "Economy",
+        "4700": "Movie",
+        "4711": "Replay Value",
+        "4726": "Cute",
+        "4736": "2D Fighter",
+        "4747": "Character Customization",
+        "4754": "Politics",
+        "4758": "Twin Stick Shooter",
+        "4777": "Spectacle fighter",
+        "4791": "Top-Down",
+        "4821": "Mechs",
+        "4835": "6DOF",
+        "4840": "4 Player Local",
+        "4845": "Capitalism",
+        "4853": "Political",
+        "4878": "Parody",
+        "4885": "Bullet Hell",
+        "4947": "Romance",
+        "4975": "2.5D",
+        "4994": "Naval Combat",
+        "5030": "Dystopian",
+        "5055": "eSports",
+        "5094": "Narration",
+        "5125": "Procedural Generation",
+        "5153": "Kickstarter",
+        "5154": "Score Attack",
+        "5160": "Dinosaurs",
+        "5179": "Cold War",
+        "5186": "Psychological",
+        "5228": "Blood",
+        "5230": "Sequel",
+        "5300": "God Game",
+        "5310": "Games Workshop",
+        "5348": "Mod",
+        "5350": "Family Friendly",
+        "5363": "Destruction",
+        "5372": "Conspiracy",
+        "5379": "2D Platformer",
+        "5382": "World War I",
+        "5390": "Time Attack",
+        "5395": "3D Platformer",
+        "5407": "Benchmark",
+        "5411": "Beautiful",
+        "5432": "Programming",
+        "5502": "Hacking",
+        "5537": "Puzzle Platformer",
+        "5547": "Arena Shooter",
+        "5577": "RPGMaker",
+        "5608": "Emotional",
+        "5611": "Mature",
+        "5613": "Detective",
+        "5652": "Collectathon",
+        "5673": "Modern",
+        "5708": "Remake",
+        "5711": "Team-Based",
+        "5716": "Mystery",
+        "5727": "Baseball",
+        "5752": "Robots",
+        "5765": "Gun Customization",
+        "5794": "Science",
+        "5796": "Bullet Time",
+        "5851": "Isometric",
+        "5900": "Walking Simulator",
+        "5914": "Tennis",
+        "5923": "Dark Humor",
+        "5941": "Reboot",
+        "5981": "Mining",
+        "5984": "Drama",
+        "6041": "Horses",
+        "6052": "Noir",
+        "6129": "Logic",
+        "6214": "Birds",
+        "6276": "Inventory Management",
+        "6310": "Diplomacy",
+        "6378": "Crime",
+        "6426": "Choices Matter",
+        "6506": "3D Fighter",
+        "6621": "Pinball",
+        "6625": "Time Manipulation",
+        "6650": "Nudity",
+        "6691": "1990's",
+        "6702": "Mars",
+        "6730": "PvE",
+        "6815": "Hand-drawn",
+        "6869": "Nonlinear",
+        "6910": "Naval",
+        "6915": "Martial Arts",
+        "6948": "Rome",
+        "6971": "Multiple Endings",
+        "7038": "Golf",
+        "7107": "Real-Time with Pause",
+        "7108": "Party",
+        "7113": "Crowdfunded",
+        "7178": "Party Game",
+        "7208": "Female Protagonist",
+        "7250": "Linear",
+        "7309": "Skiing",
+        "7328": "Bowling",
+        "7332": "Base Building",
+        "7368": "Local Multiplayer",
+        "7423": "Sniper",
+        "7432": "Lovecraftian",
+        "7478": "Illuminati",
+        "7481": "Controller",
+        "7556": "Dice",
+        "7569": "Grid-Based Movement",
+        "7622": "Offroad",
+        "7702": "Narrative",
+        "7743": "1980s",
+        "7782": "Cult Classic",
+        "7918": "Dwarf",
+        "7926": "Artificial Intelligence",
+        "7948": "Soundtrack",
+        "8013": "Software",
+        "8075": "TrackIR",
+        "8093": "Minigames",
+        "8122": "Level Editor",
+        "8253": "Music-Based Procedural Generation",
+        "8369": "Investigation",
+        "8461": "Well-Written",
+        "8666": "Runner",
+        "8945": "Resource Management",
+        "9130": "Hentai",
+        "9157": "Underwater",
+        "9204": "Immersive Sim",
+        "9271": "Trading Card Game",
+        "9541": "Demons",
+        "9551": "Dating Sim",
+        "9564": "Hunting",
+        "9592": "Dynamic Narration",
+        "9803": "Snow",
+        "9994": "Experience",
+        "10235": "Life Sim",
+        "10383": "Transportation",
+        "10397": "Memes",
+        "10437": "Trivia",
+        "10679": "Time Travel",
+        "10695": "Party-Based RPG",
+        "10808": "Supernatural",
+        "10816": "Split Screen",
+        "11014": "Interactive Fiction",
+        "11095": "Boss Rush",
+        "11104": "Vehicular Combat",
+        "11123": "Mouse only",
+        "11333": "Villain Protagonist",
+        "11634": "Vikings",
+        "12057": "Tutorial",
+        "12095": "Sexual Content",
+        "12190": "Boxing",
+        "12286": "Warhammer 40K",
+        "12472": "Management",
+        "13070": "Solitaire",
+        "13190": "America",
+        "13276": "Tanks",
+        "13382": "Archery",
+        "13577": "Sailing",
+        "13782": "Experimental",
+        "13906": "Game Development",
+        "14139": "Turn-Based Tactics",
+        "14153": "Dungeons & Dragons",
+        "14720": "Nostalgia",
+        "14906": "Intentionally Awkward Controls",
+        "15045": "Flight",
+        "15172": "Conversation",
+        "15277": "Philosophical",
+        "15339": "Documentary",
+        "15564": "Fishing",
+        "15868": "Motocross",
+        "15954": "Silent Protagonist",
+        "16094": "Mythology",
+        "16250": "Gambling",
+        "16598": "Space Sim",
+        "16689": "Time Management",
+        "17015": "Werewolves",
+        "17305": "Strategy RPG",
+        "17337": "Lemmings",
+        "17389": "Tabletop",
+        "17770": "Asynchronous Multiplayer",
+        "17894": "Cats",
+        "17927": "Pool",
+        "18594": "FMV",
+        "19568": "Cycling",
+        "19780": "Submarine",
+        "19995": "Dark Comedy",
+        "21006": "Underground",
+        "21491": "Demo Available",
+        "21725": "Tactical RPG",
+        "21978": "VR",
+        "22602": "Agriculture",
+        "22955": "Mini Golf",
+        "24003": "Word Game",
+        "24904": "NSFW",
+        "25085": "Touch-Friendly",
+        "26921": "Political Sim",
+        "27758": "Voice Control",
+        "28444": "Snowboarding",
+        "29363": "3D Vision",
+        "29482": "Souls-like",
+        "29855": "Ambient",
+        "30358": "Nature",
+        "30927": "Fox",
+        "31275": "Text-Based",
+        "31579": "Otome",
+        "32322": "Deckbuilding",
+        "33572": "Mahjong",
+        "35079": "Job Simulator",
+        "42089": "Jump Scare",
+        "42329": "Coding",
+        "42804": "Action Roguelike",
+        "44868": "LGBTQ+",
+        "47827": "Wrestling",
+        "49213": "Rugby",
+        "51306": "Foreign",
+        "56690": "On-Rails Shooter",
+        "61357": "Electronic Music",
+        "65443": "Adult Content",
+        "71389": "Spelling",
+        "87918": "Farming Sim",
+        "91114": "Shop Keeper",
+        "92092": "Jet",
+        "96359": "Skating",
+        "97376": "Cozy",
+        "102530": "Elf",
+        "117648": "8-bit Music",
+        "123332": "Bikes",
+        "129761": "ATV",
+        "143739": "Electronic",
+        "150626": "Gaming",
+        "158638": "Cricket",
+        "176981": "Battle Royale",
+        "180368": "Faith",
+        "189941": "Instrumental Music",
+        "198631": "Mystery Dungeon",
+        "198913": "Motorbike",
+        "220585": "Colony Sim",
+        "233824": "Feature Film",
+        "252854": "BMX",
+        "255534": "Automation",
+        "323922": "Musou",
+        "324176": "Hockey",
+        "337964": "Rock Music",
+        "348922": "Steam Machine",
+        "353880": "Looter Shooter",
+        "363767": "Snooker",
+        "379975": "Clicker",
+        "454187": "Traditional Roguelike",
+        "552282": "Wholesome",
+        "603297": "Hardware",
+        "615955": "Idler",
+        "620519": "Hero Shooter",
+        "745697": "Social Deduction",
+        "769306": "Escape Room",
+        "776177": "360 Video",
+        "791774": "Card Battler",
+        "847164": "Volleyball",
+        "856791": "Asymmetric VR",
+        "916648": "Creature Collector",
+        "922563": "Roguevania",
+        "1003823": "Profile Features Limited",
+        "1023537": "Boomer Shooter",
+        "1084988": "Auto Battler",
+        "1091588": "Roguelike Deckbuilder",
+        "1100686": "Outbreak Sim",
+        "1100687": "Automobile Sim",
+        "1100688": "Medical Sim",
+        "1100689": "Open World Survival Craft",
+        "1199779": "Extraction Shooter",
+        "1220528": "Hobby Sim",
+        "1254546": "Football (Soccer)",
+        "1254552": "Football (American)",
+        "1368160": "AI Content Disclosed",
+    }
+}

packages/core/src/client/types.ts

@@ -160,9 +160,9 @@ export interface AppConfig {
 export interface AppDepots {
     branches: AppDepotBranches;
     privatebranches: Record<string, AppDepotBranches>;
-    [depotId: string]: DepotEntry 
-        | AppDepotBranches 
-        | Record<string, AppDepotBranches>;
+    [depotId: string]: DepotEntry
+    | AppDepotBranches
+    | Record<string, AppDepotBranches>;
 }
 
 
@@ -284,16 +284,27 @@ export type GenreType = {
 export interface AppInfo {
     name: string;
     slug: string;
+    images: {
+        logo: string;
+        backdrop: string;
+        poster: string;
+        banner: string;
+        screenshots: string[];
+        icon: string;
+    }
+    links: string[] | null;
     score: number;
-    gameid: string;
+    id: string;
     releaseDate: Date;
-    description: string;
+    description: string | null;
     compatibility: "low" | "mid" | "high" | "unknown";
     controllerSupport: "partial" | "full" | "unknown";
     primaryGenre: string | null;
     size: { downloadSize: number; sizeOnDisk: number };
     tags: Array<{ name: string; slug: string; type: "tag" }>;
     genres: Array<{ type: "genre"; name: string; slug: string }>;
+    categories: Array<{ name: string; slug: string; type: "categorie" }>;
+    franchises: Array<{ name: string; slug: string; type: "franchise" }>;
     developers: Array<{ name: string; slug: string; type: "developer" }>;
     publishers: Array<{ name: string; slug: string; type: "publisher" }>;
 }
@@ -341,4 +352,249 @@ export interface Shot {
 export interface RankedShot {
     url: string;
     score: number;
-}
+}
+
+export interface SteamPlayerSummaryResponse {
+    response: {
+        players: SteamPlayerSummary[];
+    };
+}
+
+export interface SteamPlayerSummary {
+    steamid: string;
+    communityvisibilitystate: number;
+    profilestate?: number;
+    personaname: string;
+    profileurl: string;
+    avatar: string;
+    avatarmedium: string;
+    avatarfull: string;
+    avatarhash: string;
+    lastlogoff?: number;
+    personastate: number;
+    realname?: string;
+    primaryclanid?: string;
+    timecreated: number;
+    personastateflags?: number;
+    loccountrycode?: string;
+}
+
+export interface SteamPlayerBansResponse {
+    players: SteamPlayerBan[];
+}
+
+export interface SteamPlayerBan {
+    SteamId: string;
+    CommunityBanned: boolean;
+    VACBanned: boolean;
+    NumberOfVACBans: number;
+    DaysSinceLastBan: number;
+    NumberOfGameBans: number;
+    EconomyBan: 'none' | 'probation' | 'banned'; // Enum based on known possible values
+}
+
+export type SteamAccount = {
+    id: string;
+    name: string;
+    realName: string | null;
+    steamMemberSince: Date;
+    avatarHash: string;
+    limitations: {
+        isLimited: boolean;
+        tradeBanState: 'none' | 'probation' | 'banned';
+        isVacBanned: boolean;
+        visibilityState: number;
+        privacyState: 'public' | 'private' | 'friendsonly';
+    };
+    profileUrl: string;
+    lastSyncedAt: Date;
+};
+
+export interface SteamFriendsListResponse {
+    friendslist: {
+        friends: SteamFriend[];
+    };
+}
+
+export interface SteamFriend {
+    steamid: string;
+    relationship: 'friend'; // could expand this if Steam ever adds more types
+    friend_since: number; // Unix timestamp (seconds)
+}
+
+export interface SteamOwnedGamesResponse {
+    response: {
+        game_count: number;
+        games: SteamOwnedGame[];
+    };
+}
+
+export interface SteamOwnedGame {
+    appid: number;
+    name: string;
+    playtime_forever: number;
+    img_icon_url: string;
+
+    playtime_windows_forever?: number;
+    playtime_mac_forever?: number;
+    playtime_linux_forever?: number;
+    playtime_deck_forever?: number;
+
+    rtime_last_played?: number; // Unix timestamp
+    content_descriptorids?: number[];
+    playtime_disconnected?: number;
+    has_community_visible_stats?: boolean;
+}
+
+/**
+ * The shape of the parsed Steam profile information.
+ */
+export interface ProfileInfo {
+    steamID64: string;
+    isLimited: boolean;
+    privacyState: 'public' | 'private' | 'friendsonly' | string;
+    visibility: string;
+}
+
+export interface SteamStoreResponse {
+    response: {
+        store_items: SteamStoreItem[];
+    };
+}
+
+export interface SteamStoreItem {
+    item_type: number;
+    id: number;
+    success: number;
+    visible: boolean;
+    name: string;
+    store_url_path: string;
+    appid: number;
+    type: number;
+    tagids: number[];
+    categories: {
+        supported_player_categoryids?: number[];
+        feature_categoryids?: number[];
+        controller_categoryids?: number[];
+    };
+    reviews: {
+        summary_filtered: {
+            review_count: number;
+            percent_positive: number;
+            review_score: number;
+            review_score_label: string;
+        };
+    };
+    basic_info: {
+        short_description?: string;
+        publishers: SteamCreator[];
+        developers: SteamCreator[];
+        franchises?: SteamCreator[];
+    };
+    tags: {
+        tagid: number;
+        weight: number;
+    }[];
+    assets: SteamAssets;
+    assets_without_overrides: SteamAssets;
+    release: {
+        steam_release_date: number;
+    };
+    platforms: {
+        windows: boolean;
+        mac: boolean;
+        steamos_linux: boolean;
+        vr_support: Record<string, never>;
+        steam_deck_compat_category?: number;
+        steam_os_compat_category?: number;
+    };
+    best_purchase_option: PurchaseOption;
+    purchase_options: PurchaseOption[];
+    screenshots: {
+        all_ages_screenshots: {
+            filename: string;
+            ordinal: number;
+        }[];
+    };
+    trailers: {
+        highlights: Trailer[];
+    };
+    supported_languages: SupportedLanguage[];
+    full_description: string;
+    links?: {
+        link_type: number;
+        url: string;
+    }[];
+}
+
+export interface SteamCreator {
+    name: string;
+    creator_clan_account_id: number;
+}
+
+export interface SteamAssets {
+    asset_url_format: string;
+    main_capsule: string;
+    small_capsule: string;
+    header: string;
+    page_background: string;
+    hero_capsule: string;
+    hero_capsule_2x: string;
+    library_capsule: string;
+    library_capsule_2x: string;
+    library_hero: string;
+    library_hero_2x: string;
+    community_icon: string;
+    page_background_path: string;
+    raw_page_background: string;
+}
+
+export interface PurchaseOption {
+    packageid?: number;
+    bundleid?: number;
+    purchase_option_name: string;
+    final_price_in_cents: string;
+    original_price_in_cents: string;
+    formatted_final_price: string;
+    formatted_original_price: string;
+    discount_pct: number;
+    active_discounts: ActiveDiscount[];
+    user_can_purchase_as_gift: boolean;
+    hide_discount_pct_for_compliance: boolean;
+    included_game_count: number;
+    bundle_discount_pct?: number;
+    price_before_bundle_discount?: string;
+    formatted_price_before_bundle_discount?: string;
+}
+
+export interface ActiveDiscount {
+    discount_amount: string;
+    discount_description: string;
+    discount_end_date: number;
+}
+
+export interface Trailer {
+    trailer_name: string;
+    trailer_url_format: string;
+    trailer_category: number;
+    trailer_480p: TrailerFile[];
+    trailer_max: TrailerFile[];
+    microtrailer: TrailerFile[];
+    screenshot_medium: string;
+    screenshot_full: string;
+    trailer_base_id: number;
+    all_ages: boolean;
+}
+
+export interface TrailerFile {
+    filename: string;
+    type: string;
+}
+
+export interface SupportedLanguage {
+    elanguage: number;
+    eadditionallanguage: number;
+    supported: boolean;
+    full_audio: boolean;
+    subtitles: boolean;
+}

packages/core/src/client/utils.ts

@@ -9,6 +9,7 @@ import type {
     CompareResult,
     RankedShot,
     Shot,
+    ProfileInfo,
 } from "./types";
 import crypto from 'crypto';
 import pLimit from 'p-limit';
@@ -18,6 +19,7 @@ import { LRUCache } from 'lru-cache';
 import sanitizeHtml from 'sanitize-html';
 import { Agent as HttpAgent } from 'http';
 import { Agent as HttpsAgent } from 'https';
+import { parseStringPromise } from "xml2js";
 import sharp, { type Metadata } from 'sharp';
 import AbortController from 'abort-controller';
 import fetch, { RequestInit } from 'node-fetch';
@@ -90,29 +92,21 @@ export namespace Utils {
 
     // --- Optimized Box Art creation ---
     export async function createBoxArtBuffer(
-        assets: LibraryAssetsFull,
-        appid: number | string,
+        logoUrl: string,
+        backgroundUrl: string,
         logoPercent = 0.9
     ): Promise<Buffer> {
-        const base = `https://shared.cloudflare.steamstatic.com/store_item_assets/steam/apps/${appid}`;
-        const pick = (key: string) => {
-            const set = assets[key];
-            const path = set?.image2x?.english || set?.image?.english;
-            if (!path) throw new Error(`Missing asset for ${key}`);
-            return `${base}/${path}`;
-        };
-
         const [bgBuf, logoBuf] = await Promise.all([
             downloadLimit(() =>
-                fetchBuffer(pick('library_hero'))
+                fetchBuffer(backgroundUrl)
                     .catch(error => {
-                        console.error(`Failed to download hero image for ${appid}:`, error);
+                        console.error(`Failed to download hero image from ${backgroundUrl}:`, error);
                         throw new Error(`Failed to create box art: hero image unavailable`);
                     }),
             ),
-            downloadLimit(() => fetchBuffer(pick('library_logo'))
+            downloadLimit(() => fetchBuffer(logoUrl)
                 .catch(error => {
-                    console.error(`Failed to download logo image for ${appid}:`, error);
+                    console.error(`Failed to download logo image from ${logoUrl}:`, error);
                     throw new Error(`Failed to create box art: logo image unavailable`);
                 }),
             ),
@@ -182,9 +176,11 @@ export namespace Utils {
     export function createSlug(name: string): string {
         return name
             .toLowerCase()
-            .replace(/[^\w\s -]/g, "")
-            .replace(/\s+/g, "-")
-            .replace(/-+/g, "-")
+            .normalize("NFKD") // Normalize to decompose accented characters
+            .replace(/[^\p{L}\p{N}\s-]/gu, '') // Keep Unicode letters, numbers, spaces, and hyphens
+            .replace(/\s+/g, '-')              // Replace spaces with hyphens
+            .replace(/-+/g, '-')               // Collapse multiple hyphens
+            .replace(/^-+|-+$/g, '')           // Trim leading/trailing hyphens
             .trim();
     }
 
@@ -328,16 +324,26 @@ export namespace Utils {
     export function compatibilityType(type?: string): "low" | "mid" | "high" | "unknown" {
         switch (type) {
             case "1":
-                return "low";
+                return "high";
             case "2":
                 return "mid";
             case "3":
-                return "high";
+                return "low";
             default:
                 return "unknown";
         }
     }
 
+
+    export function estimateRatingFromSummary(
+        reviewCount: number,
+        percentPositive: number
+    ): number {
+        const positiveVotes = Math.round((percentPositive / 100) * reviewCount);
+        const negativeVotes = reviewCount - positiveVotes;
+        return getRating(positiveVotes, negativeVotes);
+    }
+
     export function mapGameTags<
         T extends string = "tag"
     >(
@@ -353,6 +359,20 @@ export namespace Utils {
         return result;
     }
 
+    export function createType<
+        T extends "developer" | "publisher" | "franchise" | "tag" | "categorie" | "genre"
+    >(
+        names: string[],
+        type: T
+    ) {
+        return names
+            .map(name => ({
+                type,
+                name: name.trim(),
+                slug: createSlug(name.trim())
+            }));
+    }
+
     /**
     * Create a tag object with name, slug, and type
     * @typeparam T Literal type of the `type` field (defaults to 'tag')
@@ -380,17 +400,39 @@ export namespace Utils {
                 .toLowerCase();
     }
 
+    function isDepotEntry(e: any): e is DepotEntry {
+        return (
+            e != null &&
+            typeof e === 'object' &&
+            'manifests' in e &&
+            e.manifests != null &&
+            typeof e.manifests.public?.download === 'string'
+        );
+    }
+
     export function getPublicDepotSizes(depots: AppDepots) {
-        const sum = { download: 0, size: 0 };
-        for (const key in depots) {
+        let download = 0;
+        let size = 0;
+
+        for (const key of Object.keys(depots)) {
             if (key === 'branches' || key === 'privatebranches') continue;
             const entry = depots[key] as DepotEntry;
-            if ('manifests' in entry && entry.manifests.public) {
-                sum.download += Number(entry.manifests.public.download);
-                sum.size += Number(entry.manifests.public.size);
+            if (!isDepotEntry(entry)) {
+                continue;
             }
+
+            const dl = Number(entry.manifests.public.download);
+            const sz = Number(entry.manifests.public.size);
+            if (!Number.isFinite(dl) || !Number.isFinite(sz)) {
+                console.warn(`[getPublicDepotSizes] non-numeric size for depot ${key}`);
+                continue;
+            }
+
+            download += dl;
+            size += sz;
         }
-        return { downloadSize: sum.download, sizeOnDisk: sum.size };
+
+        return { downloadSize: download, sizeOnDisk: size };
     }
 
     export function parseGenres(str: string): GenreType[] {
@@ -419,4 +461,64 @@ export namespace Utils {
 
         return cleaned.trim()
     }
+
+    /**
+     * Fetches and parses a single Steam community profile XML.
+     * @param steamIdOrVanity - The 64-bit SteamID or vanity name.
+     * @returns Promise resolving to ProfileInfo.
+     */
+    export async function fetchProfileInfo(
+        steamIdOrVanity: string
+    ): Promise<ProfileInfo> {
+        const isNumericId = /^\d+$/.test(steamIdOrVanity);
+        const path = isNumericId ? `profiles/${steamIdOrVanity}` : `id/${steamIdOrVanity}`;
+        const url = `https://steamcommunity.com/${path}/?xml=1`;
+
+        const response = await fetch(url);
+        if (!response.ok) {
+            throw new Error(`Failed to fetch ${steamIdOrVanity}: HTTP ${response.status}`);
+        }
+
+        const xml = await response.text();
+        const { profile } = await parseStringPromise(xml, {
+            explicitArray: false,
+            trim: true,
+            mergeAttrs: true
+        }) as { profile: any };
+
+        // Extract fields (fall back to limitedAccount tag if needed)
+        const limitedFlag = profile.isLimitedAccount ?? profile.limitedAccount;
+        const isLimited = limitedFlag === '1';
+
+        return {
+            isLimited,
+            steamID64: profile.steamID64,
+            privacyState: profile.privacyState,
+            visibility: profile.visibilityState
+        };
+    }
+
+    /**
+     * Batch-fetches multiple Steam profiles in parallel.
+     * @param idsOrVanities - Array of SteamID64 strings or vanity names.
+     * @returns Promise resolving to a record mapping each input to its ProfileInfo or an error.
+     */
+    export async function fetchProfilesInfo(
+        idsOrVanities: string[]
+    ): Promise<Map<string, ProfileInfo | { error: string }>> {
+        const results = await Promise.all(
+            idsOrVanities.map(async (input) => {
+                try {
+                    const info = await fetchProfileInfo(input);
+                    return { input, result: info };
+                } catch (err) {
+                    return { input, result: { error: (err as Error).message } };
+                }
+            })
+        );
+
+        return new Map(
+            results.map(({ input, result }) => [input, result] as [string, ProfileInfo | { error: string }])
+        );
+    }
 }

packages/core/src/common.ts

@@ -1,5 +1,5 @@
-import { sql } from "drizzle-orm";
 import "zod-openapi/extend";
+import { sql } from "drizzle-orm";
 
 export namespace Common {
   export const IdDescription = `Unique object identifier.

packages/core/src/credentials/credentials.sql.ts

@@ -1,25 +0,0 @@
-import { steamTable } from "../steam/steam.sql";
-import { pgTable, primaryKey, varchar } from "drizzle-orm/pg-core";
-import { encryptedText, ulid, timestamps, utc } from "../drizzle/types";
-
-export const steamCredentialsTable = pgTable(
-    "steam_account_credentials",
-    {
-        ...timestamps,
-        id: ulid("id").notNull(),
-        steamID: varchar("steam_id", { length: 255 })
-            .notNull()
-            .references(() => steamTable.id, {
-                onDelete: "cascade"
-            }),
-        refreshToken: encryptedText("refresh_token")
-            .notNull(),
-        expiry: utc("expiry").notNull(),
-        username: varchar("username", { length: 255 }).notNull(),
-    },
-    (table) => [
-        primaryKey({
-            columns: [table.steamID, table.id]
-        })
-    ]
-)

packages/core/src/credentials/index.ts

@@ -1,93 +0,0 @@
-import { z } from "zod";
-import { Resource } from "sst";
-import { bus } from "sst/aws/bus";
-import { createEvent } from "../event";
-import { createID, fn } from "../utils";
-import { eq, and, isNull, gt } from "drizzle-orm";
-import { createSelectSchema } from "drizzle-zod";
-import { steamCredentialsTable } from "./credentials.sql";
-import { afterTx, createTransaction, useTransaction } from "../drizzle/transaction";
-
-export namespace Credentials {
-    export const Info = createSelectSchema(steamCredentialsTable)
-        .omit({ timeCreated: true, timeDeleted: true, timeUpdated: true })
-        .extend({
-            accessToken: z.string(),
-            cookies: z.string().array()
-        })
-
-    export type Info = z.infer<typeof Info>;
-
-    export const Events = {
-        New: createEvent(
-            "new_credentials.added",
-            z.object({
-                steamID: Info.shape.steamID,
-            }),
-        ),
-    };
-
-    export const create = fn(
-        Info
-            .omit({ accessToken: true, cookies: true, expiry: true })
-            .partial({ id: true }),
-        (input) => {
-            const part = input.refreshToken.split('.')[1] as string
-
-            const payload = JSON.parse(Buffer.from(part, 'base64').toString());
-
-            return createTransaction(async (tx) => {
-                const id = input.id ?? createID("credentials")
-                await tx
-                    .insert(steamCredentialsTable)
-                    .values({
-                        id,
-                        steamID: input.steamID,
-                        username: input.username,
-                        refreshToken: input.refreshToken,
-                        expiry: new Date(payload.exp * 1000),
-                    })
-                await afterTx(async () =>
-                    await bus.publish(Resource.Bus, Events.New, { steamID: input.steamID })
-                );
-                return id
-            })
-        });
-
-    export const fromSteamID = fn(
-        Info.shape.steamID,
-        (steamID) =>
-            useTransaction(async (tx) => {
-                const now = new Date()
-
-                const credential = await tx
-                    .select()
-                    .from(steamCredentialsTable)
-                    .where(
-                        and(
-                            eq(steamCredentialsTable.steamID, steamID),
-                            isNull(steamCredentialsTable.timeDeleted),
-                            gt(steamCredentialsTable.expiry, now)
-                        )
-                    )
-                    .execute()
-                    .then(rows => rows.at(0));
-
-                if (!credential) return null;
-
-                return serialize(credential);
-            })
-    );
-
-    export function serialize(
-        input: typeof steamCredentialsTable.$inferSelect,
-    ) {
-        return {
-            id: input.id,
-            expiry: input.expiry,
-            steamID: input.steamID,
-            username: input.username,
-            refreshToken: input.refreshToken,
-        };
-    }
-}

packages/core/src/drizzle/types.ts

@@ -1,5 +1,4 @@
-import { Token } from "../utils";
-import { char, customType, timestamp as rawTs } from "drizzle-orm/pg-core";
+import { char, timestamp as rawTs } from "drizzle-orm/pg-core";
 
 export const ulid = (name: string) => char(name, { length: 26 + 4 });
 
@@ -33,19 +32,6 @@ export const utc = (name: string) =>
     // mode: "date"
   });
 
-export const encryptedText =
-  customType<{ data: string; driverData: string; }>({
-    dataType() {
-      return 'text';
-    },
-    fromDriver(val) {
-      return Token.decrypt(val);
-    },
-    toDriver(val) {
-      return Token.encrypt(val);
-    },
-  });
-
 export const timestamps = {
   timeCreated: utc("time_created").notNull().defaultNow(),
   timeUpdated: utc("time_updated").notNull().defaultNow(),

packages/core/src/examples.ts

@@ -34,7 +34,7 @@ export namespace Examples {
 
     export const SteamAccount = {
         status: "online" as const, //offline,dnd(do not disturb) or playing 
-        id: "74839300282033",// Primary key
+        id: "74839300282033",// Steam ID
         userID: User.id,// | null  FK to User (null if not linked)
         name: "JD The 65th",
         username: "jdoe",
@@ -55,11 +55,10 @@ export namespace Examples {
 
     export const Team = {
         id: Id("team"),// Primary key
-        name: "John's Console", // Team name (not null, unique)
-        ownerID: User.id, // FK to User who owns/created the team
-        slug: SteamAccount.profileUrl.toLowerCase(),
+        name: "John", // Team name (not null, unique)
         maxMembers: 3,
         inviteCode: "xwydjf",
+        ownerSteamID: SteamAccount.id, // FK to User who owns/created the team
         members: [SteamAccount]
     };
 
@@ -152,6 +151,9 @@ export namespace Examples {
         id: "1809540",
         slug: "nine-sols",
         name: "Nine Sols",
+        links:[
+            "https://example.com"
+        ],
         controllerSupport: "full" as const,
         releaseDate: new Date("2024-05-29T06:53:24.000Z"),
         compatibility: "high" as const,
@@ -205,6 +207,13 @@ export namespace Examples {
                 slug: "redcandlegames"
             }
         ],
+        franchises: [],
+        categories: [
+            {
+                name: "Partial Controller",
+                slug: "partial-controller"
+            }
+        ]
     }
 
     export const CommonImg = [

packages/core/src/friend/index.ts

@@ -8,9 +8,9 @@ import { friendTable } from "./friend.sql";
 import { userTable } from "../user/user.sql";
 import { steamTable } from "../steam/steam.sql";
 import { createSelectSchema } from "drizzle-zod";
+import { and, eq, isNull, sql } from "drizzle-orm";
 import { groupBy, map, pipe, values } from "remeda";
 import { ErrorCodes, VisibleError } from "../error";
-import { and, eq, isNull, sql } from "drizzle-orm";
 import { createTransaction, useTransaction } from "../drizzle/transaction";
 
 export namespace Friend {

packages/core/src/library/index.ts

@@ -19,24 +19,21 @@ export namespace Library {
     export type Info = z.infer<typeof Info>;
 
     export const Events = {
-        Queue: createEvent(
-            "library.queue",
+        Add: createEvent(
+            "library.add",
             z.object({
                 appID: z.number(),
-                lastPlayed: z.date(),
-                timeAcquired: z.date(),
+                lastPlayed: z.date().nullable(),
                 totalPlaytime: z.number(),
-                isFamilyShared: z.boolean(),
-                isFamilyShareable: z.boolean(),
-            }).array(),
+            }),
         ),
     };
 
     export const add = fn(
-        Info.partial({ ownerID: true }),
+        Info.partial({ ownerSteamID: true }),
         async (input) =>
             createTransaction(async (tx) => {
-                const ownerSteamID = input.ownerID ?? Actor.steamID()
+                const ownerSteamID = input.ownerSteamID ?? Actor.steamID()
                 const result =
                     await tx
                         .select()
@@ -44,7 +41,7 @@ export namespace Library {
                         .where(
                             and(
                                 eq(steamLibraryTable.baseGameID, input.baseGameID),
-                                eq(steamLibraryTable.ownerID, ownerSteamID),
+                                eq(steamLibraryTable.ownerSteamID, ownerSteamID),
                                 isNull(steamLibraryTable.timeDeleted)
                             )
                         )
@@ -57,21 +54,17 @@ export namespace Library {
                 await tx
                     .insert(steamLibraryTable)
                     .values({
-                        ownerID: ownerSteamID,
+                        ownerSteamID: ownerSteamID,
                         baseGameID: input.baseGameID,
                         lastPlayed: input.lastPlayed,
                         totalPlaytime: input.totalPlaytime,
-                        timeAcquired: input.timeAcquired,
-                        isFamilyShared: input.isFamilyShared
                     })
                     .onConflictDoUpdate({
-                        target: [steamLibraryTable.ownerID, steamLibraryTable.baseGameID],
+                        target: [steamLibraryTable.ownerSteamID, steamLibraryTable.baseGameID],
                         set: {
                             timeDeleted: null,
                             lastPlayed: input.lastPlayed,
-                            timeAcquired: input.timeAcquired,
                             totalPlaytime: input.totalPlaytime,
-                            isFamilyShared: input.isFamilyShared
                         }
                     })
 
@@ -87,7 +80,7 @@ export namespace Library {
                     .set({ timeDeleted: sql`now()` })
                     .where(
                         and(
-                            eq(steamLibraryTable.ownerID, input.ownerID),
+                            eq(steamLibraryTable.ownerSteamID, input.ownerSteamID),
                             eq(steamLibraryTable.baseGameID, input.baseGameID),
                         )
                     )
@@ -105,7 +98,7 @@ export namespace Library {
                 .from(steamLibraryTable)
                 .where(
                     and(
-                        eq(steamLibraryTable.ownerID, Actor.steamID()),
+                        eq(steamLibraryTable.ownerSteamID, Actor.steamID()),
                         isNull(steamLibraryTable.timeDeleted)
                     )
                 )

packages/core/src/library/library.sql.ts

@@ -1,7 +1,7 @@
-import { timestamps, utc, } from "../drizzle/types";
 import { steamTable } from "../steam/steam.sql";
+import { timestamps, utc, } from "../drizzle/types";
 import { baseGamesTable } from "../base-game/base-game.sql";
-import { boolean, index, integer, pgTable, primaryKey, varchar, } from "drizzle-orm/pg-core";
+import { index, integer, pgTable, primaryKey, varchar, } from "drizzle-orm/pg-core";
 
 export const steamLibraryTable = pgTable(
     "game_libraries",
@@ -12,20 +12,18 @@ export const steamLibraryTable = pgTable(
             .references(() => baseGamesTable.id, {
                 onDelete: "cascade"
             }),
-        ownerID: varchar("owner_id", { length: 255 })
+        ownerSteamID: varchar("owner_steam_id", { length: 255 })
             .notNull()
             .references(() => steamTable.id, {
                 onDelete: "cascade"
             }),
-        timeAcquired: utc("time_acquired").notNull(),
-        lastPlayed: utc("last_played").notNull(),
+        lastPlayed: utc("last_played"),
         totalPlaytime: integer("total_playtime").notNull(),
-        isFamilyShared: boolean("is_family_shared").notNull()
     },
     (table) => [
         primaryKey({
-            columns: [table.baseGameID, table.ownerID]
+            columns: [table.baseGameID, table.ownerSteamID]
         }),
-        index("idx_game_libraries_owner_id").on(table.ownerID),
+        index("idx_game_libraries_owner_id").on(table.ownerSteamID),
     ],
 );

packages/core/src/member/index.ts

@@ -1,122 +0,0 @@
-import { z } from "zod";
-import { Actor } from "../actor";
-import { Common } from "../common";
-import { Examples } from "../examples";
-import { createID, fn } from "../utils";
-import { and, eq, isNull } from "drizzle-orm"
-import { memberTable, RoleEnum } from "./member.sql";
-import { createTransaction, useTransaction } from "../drizzle/transaction";
-
-export namespace Member {
-    export const Info = z
-        .object({
-            id: z.string().openapi({
-                description: Common.IdDescription,
-                example: Examples.Member.id,
-            }),
-            teamID: z.string().openapi({
-                description: "Associated team identifier for this membership",
-                example: Examples.Member.teamID
-            }),
-            role: z.enum(RoleEnum.enumValues).openapi({
-                description: "Assigned permission role within the team",
-                example: Examples.Member.role
-            }),
-            steamID: z.string().openapi({
-                description: "Steam platform identifier for Steam account integration",
-                example: Examples.Member.steamID
-            }),
-            userID: z.string().nullable().openapi({
-                description: "Optional associated user account identifier",
-                example: Examples.Member.userID
-            }),
-        })
-        .openapi({
-            ref: "Member",
-            description: "Team membership entity defining user roles and platform connections",
-            example: Examples.Member,
-        });
-
-    export type Info = z.infer<typeof Info>;
-
-    export const create = fn(
-        Info
-            .partial({
-                id: true,
-                userID: true,
-                teamID: true
-            }),
-        (input) =>
-            createTransaction(async (tx) => {
-                const id = input.id ?? createID("member");
-                await tx.insert(memberTable).values({
-                    id,
-                    role: input.role,
-                    userID: input.userID,
-                    steamID: input.steamID,
-                    teamID: input.teamID ?? Actor.teamID(),
-                })
-
-                return id;
-            }),
-    );
-
-    export const fromTeamID = fn(
-        Info.shape.teamID,
-        (teamID) =>
-            useTransaction((tx) =>
-                tx
-                    .select()
-                    .from(memberTable)
-                    .where(
-                        and(
-                            eq(memberTable.userID, Actor.userID()),
-                            eq(memberTable.teamID, teamID),
-                            isNull(memberTable.timeDeleted)
-                        )
-                    )
-                    .execute()
-                    .then(rows => rows.map(serialize).at(0))
-            )
-
-    )
-    
-    export const fromUserID = fn(
-        z.string(),
-        (userID) =>
-            useTransaction((tx) =>
-                tx
-                    .select()
-                    .from(memberTable)
-                    .where(
-                        and(
-                            eq(memberTable.userID, userID),
-                            eq(memberTable.teamID, Actor.teamID()),
-                            isNull(memberTable.timeDeleted)
-                        )
-                    )
-                    .execute()
-                    .then(rows => rows.map(serialize).at(0))
-            )
-
-    )
-
-    /**
-     * Converts a raw member database row into a standardized {@link Member.Info} object.
-     *
-     * @param input - The database row representing a member.
-     * @returns The member information formatted as a {@link Member.Info} object.
-     */
-    export function serialize(
-        input: typeof memberTable.$inferSelect,
-    ): z.infer<typeof Info> {
-        return {
-            id: input.id,
-            role: input.role,
-            userID: input.userID,
-            teamID: input.teamID,
-            steamID: input.steamID
-        };
-    }
-
-}

packages/core/src/member/member.sql.ts

@@ -1,33 +0,0 @@
-import { isNotNull } from "drizzle-orm";
-import { userTable } from "../user/user.sql";
-import { steamTable } from "../steam/steam.sql";
-import { timestamps, teamID, ulid } from "../drizzle/types";
-import { bigint, pgEnum, pgTable, primaryKey, uniqueIndex, varchar } from "drizzle-orm/pg-core";
-
-export const RoleEnum = pgEnum("member_role", ["child", "adult"])
-
-export const memberTable = pgTable(
-    "members",
-    {
-        ...teamID,
-        ...timestamps,
-        userID: ulid("user_id")
-            .references(() => userTable.id, {
-                onDelete: "cascade"
-            }),
-        steamID: varchar("steam_id", { length: 255 })
-            .notNull()
-            .references(() => steamTable.id, {
-                onDelete: "cascade",
-                onUpdate: "restrict"
-            }),
-        role: RoleEnum("role").notNull(),
-    },
-    (table) => [
-        primaryKey({ columns: [table.id, table.teamID] }),
-        uniqueIndex("idx_member_steam_id").on(table.teamID, table.steamID),
-        uniqueIndex("idx_member_user_id")
-            .on(table.teamID, table.userID)
-            .where(isNotNull(table.userID))
-    ],
-);

packages/core/src/steam/index.ts

@@ -1,15 +1,12 @@
 import { z } from "zod";
 import { fn } from "../utils";
-import { Resource } from "sst";
 import { Actor } from "../actor";
-import { bus } from "sst/aws/bus";
 import { Common } from "../common";
-import { createEvent } from "../event";
 import { Examples } from "../examples";
+import { createEvent } from "../event";
 import { eq, and, isNull, desc } from "drizzle-orm";
 import { steamTable, StatusEnum, Limitations } from "./steam.sql";
-import { afterTx, createTransaction, useTransaction } from "../drizzle/transaction";
-import { teamTable } from "../team/team.sql";
+import { createTransaction, useTransaction } from "../drizzle/transaction";
 
 export namespace Steam {
     export const Info = z
@@ -34,14 +31,6 @@ export namespace Steam {
                 description: "The steam community url of this account",
                 example: Examples.SteamAccount.profileUrl
             }),
-            username: z.string()
-                .regex(/^[a-z0-9]{1,32}$/, "The Steam username is not slug friendly")
-                .nullable()
-                .openapi({
-                    description: "The unique username of this account",
-                    example: Examples.SteamAccount.username
-                })
-                .default("unknown"),
             realName: z.string().nullable().openapi({
                 description: "The real name behind of this Steam account",
                 example: Examples.SteamAccount.realName
@@ -76,7 +65,7 @@ export namespace Steam {
             "steam_account.created",
             z.object({
                 steamID: Info.shape.id,
-                userID: Info.shape.userID
+                userID: Info.shape.userID,
             }),
         ),
         Updated: createEvent(
@@ -94,9 +83,9 @@ export namespace Steam {
                 useUser: z.boolean(),
             })
             .partial({
-                useUser: true,
                 userID: true,
                 status: true,
+                useUser: true,
                 lastSyncedAt: true
             }),
         (input) =>
@@ -107,8 +96,8 @@ export namespace Steam {
                         .from(steamTable)
                         .where(
                             and(
-                                eq(steamTable.id, input.id),
-                                isNull(steamTable.timeDeleted)
+                                isNull(steamTable.timeDeleted),
+                                eq(steamTable.id, input.id)
                             )
                         )
                         .execute()
@@ -129,7 +118,6 @@ export namespace Steam {
                         avatarHash: input.avatarHash,
                         limitations: input.limitations,
                         status: input.status ?? "offline",
-                        username: input.username ?? "unknown",
                         steamMemberSince: input.steamMemberSince,
                         lastSyncedAt: input.lastSyncedAt ?? Common.utc(),
                     })
@@ -151,8 +139,8 @@ export namespace Steam {
             .partial({
                 userID: true
             }),
-        (input) =>
-            useTransaction(async (tx) => {
+        async (input) =>
+            createTransaction(async (tx) => {
                 const userID = input.userID ?? Actor.userID()
                 await tx
                     .update(steamTable)
@@ -160,6 +148,12 @@ export namespace Steam {
                         userID
                     })
                     .where(eq(steamTable.id, input.steamID));
+
+                // await afterTx(async () =>
+                //     bus.publish(Resource.Bus, Events.Updated, { userID, steamID: input.steamID })
+                // );
+
+                return input.steamID
             })
     )
 
@@ -177,6 +171,26 @@ export namespace Steam {
             )
     )
 
+    export const confirmOwnerShip = fn(
+        z.string().min(1),
+        (userID) =>
+            useTransaction((tx) =>
+                tx
+                    .select()
+                    .from(steamTable)
+                    .where(
+                        and(
+                            eq(steamTable.userID, userID),
+                            eq(steamTable.id, Actor.steamID()),
+                            isNull(steamTable.timeDeleted)
+                        )
+                    )
+                    .orderBy(desc(steamTable.timeCreated))
+                    .execute()
+                    .then((rows) => rows.map(serialize).at(0))
+            )
+    )
+
     export const fromSteamID = fn(
         z.string(),
         (steamID) =>
@@ -208,15 +222,14 @@ export namespace Steam {
         return {
             id: input.id,
             name: input.name,
-            userID: input.userID,
             status: input.status,
-            username: input.username,
+            userID: input.userID,
             realName: input.realName,
+            profileUrl: input.profileUrl,
             avatarHash: input.avatarHash,
             limitations: input.limitations,
             lastSyncedAt: input.lastSyncedAt,
             steamMemberSince: input.steamMemberSince,
-            profileUrl: input.profileUrl ? `https://steamcommunity.com/id/${input.profileUrl}` : null,
         };
     }
 

packages/core/src/steam/steam.sql.ts

@@ -1,6 +1,6 @@
 import { z } from "zod";
 import { userTable } from "../user/user.sql";
-import { timestamps, ulid, utc } from "../drizzle/types";
+import { id, timestamps, ulid, utc } from "../drizzle/types";
 import { pgTable, varchar, pgEnum, json, unique } from "drizzle-orm/pg-core";
 
 export const StatusEnum = pgEnum("steam_status", ["online", "offline", "dnd", "playing"])
@@ -32,11 +32,7 @@ export const steamTable = pgTable(
         steamMemberSince: utc("member_since").notNull(),
         name: varchar("name", { length: 255 }).notNull(),
         profileUrl: varchar("profile_url", { length: 255 }),
-        username: varchar("username", { length: 255 }).notNull(),
         avatarHash: varchar("avatar_hash", { length: 255 }).notNull(),
         limitations: json("limitations").$type<Limitations>().notNull(),
-    },
-    (table) => [
-        unique("idx_steam_username").on(table.username)
-    ]
+    }
 );

packages/core/src/team/index.ts

@@ -1,188 +0,0 @@
-import { z } from "zod";
-import { Steam } from "../steam";
-import { Actor } from "../actor";
-import { Common } from "../common";
-import { teamTable } from "./team.sql";
-import { Examples } from "../examples";
-import { and, eq, isNull } from "drizzle-orm";
-import { steamTable } from "../steam/steam.sql";
-import { createID, fn, Invite } from "../utils";
-import { memberTable } from "../member/member.sql";
-import { groupBy, pipe, values, map } from "remeda";
-import { createTransaction, useTransaction, type Transaction } from "../drizzle/transaction";
-
-export namespace Team {
-    export const Info = z
-        .object({
-            id: z.string().openapi({
-                description: Common.IdDescription,
-                example: Examples.Team.id,
-            }),
-            slug: z.string().regex(/^[a-z0-9-]{1,32}$/, "Use a URL friendly name.").openapi({
-                description: "URL-friendly unique username (lowercase alphanumeric with hyphens)",
-                example: Examples.Team.slug
-            }),
-            name: z.string().openapi({
-                description: "Display name of the team",
-                example: Examples.Team.name
-            }),
-            ownerID: z.string().openapi({
-                description: "Unique identifier of the team owner",
-                example: Examples.Team.ownerID
-            }),
-            maxMembers: z.number().openapi({
-                description: "Maximum allowed team members based on subscription tier",
-                example: Examples.Team.maxMembers
-            }),
-            inviteCode: z.string().openapi({
-                description: "Unique invitation code used for adding new team members",
-                example: Examples.Team.inviteCode
-            }),
-            members: Steam.Info.array().openapi({
-                description: "All the team members in this team",
-                example: Examples.Team.members
-            })
-        })
-        .openapi({
-            ref: "Team",
-            description: "Team entity containing core team information and settings",
-            example: Examples.Team,
-        });
-
-    export type Info = z.infer<typeof Info>;
-
-    /**
-     * Generates a unique team invite code
-     * @param length The length of the invite code
-     * @param maxAttempts Maximum number of attempts to generate a unique code
-     * @returns A promise resolving to a unique invite code
-     */
-    async function createUniqueTeamInviteCode(
-        tx: Transaction,
-        length: number = 8,
-        maxAttempts: number = 5
-    ): Promise<string> {
-        let attempts = 0;
-
-        while (attempts < maxAttempts) {
-            const code = Invite.generateCode(length);
-
-            const teams =
-                await tx
-                    .select()
-                    .from(teamTable)
-                    .where(eq(teamTable.inviteCode, code))
-                    .execute()
-
-            if (teams.length === 0) {
-                return code;
-            }
-
-            attempts++;
-        }
-
-        // If we've exceeded max attempts, add timestamp to ensure uniqueness
-        const timestampSuffix = Date.now().toString(36).slice(-4);
-        const baseCode = Invite.generateCode(length - 4);
-        return baseCode + timestampSuffix;
-    }
-
-    export const create = fn(
-        Info
-            .omit({ members: true })
-            .partial({
-                id: true,
-                inviteCode: true,
-                maxMembers: true,
-                ownerID: true
-            }),
-        async (input) =>
-            createTransaction(async (tx) => {
-                const inviteCode = await createUniqueTeamInviteCode(tx)
-                const id = input.id ?? createID("team");
-                await tx
-                    .insert(teamTable)
-                    .values({
-                        id,
-                        inviteCode,
-                        slug: input.slug,
-                        name: input.name,
-                        ownerID: input.ownerID ?? Actor.userID(),
-                        maxMembers: input.maxMembers ?? 1,
-                    })
-                    .onConflictDoUpdate({
-                        target: [teamTable.slug],
-                        set: {
-                            timeDeleted: null
-                        }
-                    })
-
-                return id;
-            })
-    )
-
-    export const list = () =>
-        useTransaction(async (tx) =>
-            tx
-                .select({
-                    steam_accounts: steamTable,
-                    teams: teamTable
-                })
-                .from(teamTable)
-                .innerJoin(memberTable, eq(memberTable.teamID, teamTable.id))
-                .innerJoin(steamTable, eq(memberTable.steamID, steamTable.id))
-                .where(
-                    and(
-                        eq(memberTable.userID, Actor.userID()),
-                        isNull(memberTable.timeDeleted),
-                        isNull(steamTable.timeDeleted),
-                        isNull(teamTable.timeDeleted),
-                    ),
-                )
-                .execute()
-                .then((rows) => serialize(rows))
-        )
-
-    export const fromSlug = fn(
-        Info.shape.slug,
-        (slug) =>
-            useTransaction((tx) =>
-                tx
-                    .select()
-                    .from(teamTable)
-                    .innerJoin(memberTable, eq(memberTable.teamID, teamTable.id))
-                    .innerJoin(steamTable, eq(memberTable.steamID, steamTable.id))
-                    .where(
-                        and(
-                            eq(memberTable.userID, Actor.userID()),
-                            isNull(memberTable.timeDeleted),
-                            isNull(steamTable.timeDeleted),
-                            isNull(teamTable.timeDeleted),
-                            eq(teamTable.slug, slug),
-                        )
-                    )
-                    .then((rows) => serialize(rows).at(0))
-            )
-    )
-
-    export function serialize(
-        input: { teams: typeof teamTable.$inferSelect; steam_accounts: typeof steamTable.$inferSelect | null }[]
-    ): z.infer<typeof Info>[] {
-        return pipe(
-            input,
-            groupBy((row) => row.teams.id),
-            values(),
-            map((group) => ({
-                id: group[0].teams.id,
-                slug: group[0].teams.slug,
-                name: group[0].teams.name,
-                ownerID: group[0].teams.ownerID,
-                maxMembers: group[0].teams.maxMembers,
-                inviteCode: group[0].teams.inviteCode,
-                members: group.map(i => i.steam_accounts)
-                    .filter((c): c is typeof steamTable.$inferSelect => Boolean(c))
-                    .map((item) => Steam.serialize(item))
-            })),
-        )
-    }
-}

packages/core/src/team/team.sql.ts

@@ -1,35 +0,0 @@
-import { timestamps, id, ulid } from "../drizzle/types";
-import {
-  varchar,
-  pgTable,
-  bigint,
-  unique,
-  uniqueIndex,
-} from "drizzle-orm/pg-core";
-import { userTable } from "../user/user.sql";
-import { steamTable } from "../steam/steam.sql";
-
-export const teamTable = pgTable(
-  "teams",
-  {
-    ...id,
-    ...timestamps,
-    name: varchar("name", { length: 255 }).notNull(),
-    ownerID: ulid("owner_id")
-      .notNull()
-      .references(() => userTable.id, {
-        onDelete: "cascade"
-      }),
-    inviteCode: varchar("invite_code", { length: 10 }).notNull(),
-    slug: varchar("slug", { length: 255 })
-      .notNull()
-      .references(() => steamTable.username, {
-        onDelete: "cascade"
-      }),
-    maxMembers: bigint("max_members", { mode: "number" }).notNull(),
-  },
-  (team) => [
-    uniqueIndex("idx_team_slug").on(team.slug),
-    unique("idx_team_invite_code").on(team.inviteCode)
-  ]
-);

packages/core/src/user/index.ts

@@ -1,15 +1,13 @@
 import { z } from "zod";
-import { Resource } from "sst";
-import { bus } from "sst/aws/bus";
 import { Common } from "../common";
 import { createEvent } from "../event";
 import { Polar } from "../polar/index";
 import { createID, fn } from "../utils";
 import { userTable } from "./user.sql";
 import { Examples } from "../examples";
-import { and, eq, isNull, asc} from "drizzle-orm";
+import { and, eq, isNull, asc } from "drizzle-orm";
 import { ErrorCodes, VisibleError } from "../error";
-import { afterTx, createTransaction, useTransaction } from "../drizzle/transaction";
+import { createTransaction, useTransaction } from "../drizzle/transaction";
 
 export namespace User {
     export const Info = z

packages/core/src/utils/index.ts

@@ -1,6 +1,5 @@
+export * from "./id"
 export * from "./fn"
 export * from "./log"
-export * from "./id"
 export * from "./invite"
-export * from "./token"
 export * from "./helper"

packages/core/src/utils/token.ts

@@ -1,58 +0,0 @@
-import { z } from 'zod';
-import { fn } from './fn';
-import crypto from 'crypto';
-import { Resource } from 'sst';
-
-// This is a 32-character random ASCII string
-const rawKey = Resource.SteamEncryptionKey.value;
-
-// Turn it into exactly 32 bytes via UTF-8
-const key = Buffer.from(rawKey, 'utf8');
-if (key.length !== 32) {
-    throw new Error(
-        `SteamEncryptionKey must be exactly 32 bytes; got ${key.length}`
-    );
-}
-
-const ENCRYPTION_IV_LENGTH = 12; // 96 bits for GCM
-
-export namespace Token {
-    export const encrypt = fn(
-        z.string().min(4),
-        (token) => {
-            const iv = crypto.randomBytes(ENCRYPTION_IV_LENGTH);
-            const cipher = crypto.createCipheriv('aes-256-gcm', key, iv);
-
-            const ciphertext = Buffer.concat([
-                cipher.update(token, 'utf8'),
-                cipher.final(),
-            ]);
-            const tag = cipher.getAuthTag();
-
-            return ['v1', iv.toString('hex'), tag.toString('hex'), ciphertext.toString('hex')].join(':');
-        });
-
-    export const decrypt = fn(
-        z.string().min(4),
-        (data) => {
-            const [version, ivHex, tagHex, ciphertextHex] = data.split(':');
-            if (version !== 'v1' || !ivHex || !tagHex || !ciphertextHex) {
-                throw new Error('Invalid token format');
-            }
-
-            const iv = Buffer.from(ivHex, 'hex');
-            const tag = Buffer.from(tagHex, 'hex');
-            const ciphertext = Buffer.from(ciphertextHex, 'hex');
-
-            const decipher = crypto.createDecipheriv('aes-256-gcm', key, iv);
-            decipher.setAuthTag(tag);
-
-            const plaintext = Buffer.concat([
-                decipher.update(ciphertext),
-                decipher.final(),
-            ]);
-
-            return plaintext.toString('utf8');
-        });
-        
-}

packages/functions/package.json

@@ -14,17 +14,19 @@
   "peerDependencies": {
     "typescript": "^5"
   },
+  "exports": {
+    "./*": "./src/*.ts"
+  },
   "dependencies": {
     "@actor-core/bun": "^0.8.0",
     "@actor-core/file-system": "^0.8.0",
+    "@aws-sdk/client-lambda": "^3.821.0",
     "@aws-sdk/client-s3": "^3.806.0",
     "@aws-sdk/client-sqs": "^3.806.0",
     "@nestri/core": "workspace:",
     "actor-core": "^0.8.0",
+    "aws4fetch": "^1.0.20",
     "hono": "^4.7.8",
-    "hono-openapi": "^0.4.8",
-    "steam-session": "*",
-    "steamcommunity": "^3.48.6",
-    "steamid": "^2.1.0"
+    "hono-openapi": "^0.4.8"
   }
-}
+}

packages/functions/src/api/account.ts

@@ -20,7 +20,7 @@ export namespace AccountApi {
                                 schema: Result(
                                     Account.Info.openapi({
                                         description: "User account information",
-                                        example: { ...Examples.User, teams: [Examples.Team] }
+                                        example: { ...Examples.User, profiles: [Examples.SteamAccount] }
                                     })
                                 ),
                             },

packages/functions/src/api/image.ts

@@ -0,0 +1,137 @@
+import { z } from "zod"
+import { Hono } from "hono";
+import {
+    S3Client,
+    GetObjectCommand,
+} from "@aws-sdk/client-s3";
+import Sharp from "sharp";
+import { Resource } from "sst";
+import { validator } from "hono-openapi/zod";
+import { HTTPException } from "hono/http-exception";
+
+const s3 = new S3Client();
+
+interface TimingMetrics {
+    download: number;
+    transform: number;
+    upload?: number;
+}
+
+const formatTimingHeader = (metrics: TimingMetrics): string => {
+    const timings = [
+        `img-download;dur=${Math.round(metrics.download)}`,
+        `img-transform;dur=${Math.round(metrics.transform)}`,
+    ];
+
+    if (metrics.upload !== undefined) {
+        timings.push(`img-upload;dur=${Math.round(metrics.upload)}`);
+    }
+
+    return timings.join(",");
+};
+
+
+export namespace ImageApi {
+    export const route = new Hono()
+        .post("/:hash",
+            validator("json",
+                z.object({
+                    dpr: z.number().optional(),
+                    width: z.number().optional(),
+                    height: z.number().optional(),
+                    quality: z.number().optional(),
+                    format: z.enum(["avif", "webp", "jpeg"]),
+                })
+            ),
+            // validator("header",
+            //     z.object({
+            //         secretKey: z.string(),
+            //     })
+            // ),
+            validator("param",
+                z.object({
+                    hash: z.string(),
+                })
+            ),
+            async (c) => {
+                const input = c.req.valid("json");
+                const { hash } = c.req.valid("param");
+                // const secret = c.req.valid("header").secretKey
+
+                const metrics: TimingMetrics = {
+                    download: 0,
+                    transform: 0,
+                };
+
+                const downloadStart = performance.now();
+                let originalImage: Buffer;
+                let contentType: string;
+                try {
+                    const getCommand = new GetObjectCommand({
+                        Bucket: Resource.Storage.name,
+                        Key: hash,
+                    });
+                    const response = await s3.send(getCommand);
+
+                    originalImage = Buffer.from(await response.Body!.transformToByteArray());
+                    contentType = response.ContentType || "image/jpeg";
+                    metrics.download = performance.now() - downloadStart;
+                } catch (error) {
+                    throw new HTTPException(500, { message: `Error downloading original image:${error}` });
+                }
+
+
+                const transformStart = performance.now();
+                let transformedImage: Buffer;
+
+                try {
+                    let sharpInstance = Sharp(originalImage, {
+                        failOn: "none",
+                        animated: true,
+                    });
+
+                    const metadata = await sharpInstance.metadata();
+
+                    // Apply transformations
+                    if (input.width || input.height) {
+                        sharpInstance = sharpInstance.resize({
+                            width: input.width,
+                            height: input.height,
+                        });
+                    }
+
+                    if (metadata.orientation) {
+                        sharpInstance = sharpInstance.rotate();
+                    }
+
+                    if (input.format) {
+                        const isLossy = ["jpeg", "webp", "avif"].includes(input.format);
+
+                        if (isLossy && input.quality) {
+                            sharpInstance = sharpInstance.toFormat(input.format, {
+                                quality: input.quality,
+                            });
+                        } else {
+                            sharpInstance = sharpInstance.toFormat(input.format);
+                        }
+                    }
+
+                    transformedImage = await sharpInstance.toBuffer();
+                    metrics.transform = performance.now() - transformStart;
+
+                    contentType = `image/${input.format}`;
+                } catch (error) {
+                    throw new HTTPException(500, { message: `Error transforming image:${error}` });
+                }
+
+                return c.newResponse(transformedImage,
+                    200,
+                    {
+                        "Content-Type": contentType,
+                        "Cache-Control": "max-age=31536000",
+                        "Server-Timing": formatTimingHeader(metrics),
+                    },
+                )
+            }
+        )
+}

packages/functions/src/api/index.ts

@@ -24,10 +24,10 @@ app
         return next();
     })
     .use(auth)
-
+    
 const routes = app
     .get("/", (c) => c.text("Hello World!"))
-    .route("/games",GameApi.route)
+    .route("/games", GameApi.route)
     .route("/steam", SteamApi.route)
     .route("/realtime", Realtime.route)
     .route("/friends", FriendApi.route)
@@ -77,15 +77,15 @@ app.get(
                         scheme: "bearer",
                         bearerFormat: "JWT",
                     },
-                    TeamID: {
+                    SteamID: {
                         type: "apiKey",
-                        description: "The team ID to use for this query",
+                        description: "The steam ID to use for this query",
                         in: "header",
-                        name: "x-nestri-team"
+                        name: "x-nestri-steam"
                     },
                 },
             },
-            security: [{ Bearer: [], TeamID: [] }],
+            security: [{ Bearer: [], SteamID: [] }],
             servers: [
                 { description: "Production", url: "https://api.nestri.io" },
                 { description: "Sandbox", url: "https://api.dev.nestri.io" },
@@ -98,7 +98,7 @@ export default {
     port: 3001,
     idleTimeout: 255,
     webSocketHandler: Realtime.webSocketHandler,
-    fetch: (req: Request,env: Env) =>
+    fetch: (req: Request, env: Env) =>
         app.fetch(req, env, {
             waitUntil: (fn) => fn,
             passThroughOnException: () => { },

packages/functions/src/api/steam.ts

@@ -1,24 +1,20 @@
 import { z } from "zod";
 import { Hono } from "hono";
-import crypto from 'crypto';
 import { Resource } from "sst";
-import { streamSSE } from "hono/streaming";
+import { bus } from "sst/aws/bus";
 import { Actor } from "@nestri/core/actor";
-import SteamCommunity from "steamcommunity";
 import { describeRoute } from "hono-openapi";
-import { Team } from "@nestri/core/team/index";
+import { User } from "@nestri/core/user/index";
 import { Examples } from "@nestri/core/examples";
 import { Steam } from "@nestri/core/steam/index";
-import { Member } from "@nestri/core/member/index";
+import { getCookie, setCookie } from "hono/cookie";
 import { Client } from "@nestri/core/client/index";
+import { Friend } from "@nestri/core/friend/index";
 import { Library } from "@nestri/core/library/index";
 import { chunkArray } from "@nestri/core/utils/helper";
-import { ErrorResponses, validator, Result } from "./utils";
-import { Credentials } from "@nestri/core/credentials/index";
-import { SendMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
-import { LoginSession, EAuthTokenPlatformType } from "steam-session";
+import { ErrorCodes, VisibleError } from "@nestri/core/error";
+import { ErrorResponses, validator, Result, notPublic } from "./utils";
 
-const sqs = new SQSClient({});
 
 export namespace SteamApi {
     export const route = new Hono()
@@ -45,273 +41,214 @@ export namespace SteamApi {
                     429: ErrorResponses[429],
                 }
             }),
+            notPublic,
             async (c) =>
                 c.json({
                     data: await Steam.list()
                 })
         )
-        .get("/login",
+        .get("/callback/:id",
+            validator(
+                "param",
+                z.object({
+                    id: z.string().openapi({
+                        description: "ID of the user to login",
+                        example: Examples.User.id,
+                    }),
+                }),
+            ),
+            async (c) => {
+                const cookieID = getCookie(c, "user_id");
+
+                const userID = c.req.valid("param").id;
+
+                if (!cookieID || cookieID !== userID) {
+                    throw new VisibleError(
+                        "authentication",
+                        ErrorCodes.Authentication.UNAUTHORIZED,
+                        "You should not be here"
+                    );
+                }
+
+                const currentUser = await User.fromID(userID);
+                if (!currentUser) {
+                    throw new VisibleError(
+                        "not_found",
+                        ErrorCodes.NotFound.RESOURCE_NOT_FOUND,
+                        `User ${userID} not found`
+                    )
+                }
+
+                const params = new URL(c.req.url).searchParams;
+
+                // Verify OpenID response and get steamID
+                const steamID = await Client.verifyOpenIDResponse(params);
+
+                // If verification failed, return error
+                if (!steamID) {
+                    throw new VisibleError(
+                        "authentication",
+                        ErrorCodes.Authentication.UNAUTHORIZED,
+                        "Invalid OpenID authentication response"
+                    );
+                }
+
+                const user = (await Client.getUserInfo([steamID]))[0];
+
+                if (!user) {
+                    throw new VisibleError(
+                        "internal",
+                        ErrorCodes.NotFound.RESOURCE_NOT_FOUND,
+                        "Steam user data is missing"
+                    );
+                }
+
+                const wasAdded = await Steam.create({ ...user, userID });
+
+                if (!wasAdded) {
+                    // Update the owner of the Steam account
+                    await Steam.updateOwner({ userID, steamID })
+                }
+
+                c.executionCtx.waitUntil((async () => {
+                    try {
+                        // Get friends info
+                        const friends = await Client.getFriendsList(steamID);
+
+                        const friendSteamIDs = friends.friendslist.friends.map(f => f.steamid);
+
+                        // Steam API has a limit of requesting 100 friends at a go
+                        const friendChunks = chunkArray(friendSteamIDs, 100);
+
+                        const settled = await Promise.allSettled(
+                            friendChunks.map(async (friendIDs) => {
+                                const friendsInfo = await Client.getUserInfo(friendIDs)
+
+                                return await Promise.all(
+                                    friendsInfo.map(async (friend) => {
+                                        const wasAdded = await Steam.create(friend);
+
+                                        if (!wasAdded) {
+                                            console.log(`Friend ${friend.id} already exists`)
+                                        }
+
+                                        await Friend.add({ friendSteamID: friend.id, steamID })
+
+                                        return friend.id
+                                    })
+                                )
+                            })
+                        )
+
+                        settled
+                            .filter(result => result.status === 'rejected')
+                            .forEach(result => console.warn('[putFriends] failed:', (result as PromiseRejectedResult).reason))
+
+                        const prod = (Resource.App.stage === "production" || Resource.App.stage === "dev")
+
+                        const friendIDs = [
+                            steamID,
+                            ...(prod ? settled
+                                .filter(result => result.status === "fulfilled")
+                                .map(f => f.value)
+                                .flat() : [])
+                        ]
+
+                        await Promise.all(
+                            friendIDs.map(async (currentSteamID) => {
+                                // Get user library
+                                const gameLibrary = await Client.getUserLibrary(currentSteamID);
+
+                                const queryLib = await Promise.allSettled(
+                                    gameLibrary.response.games.map(async (game) => {
+                                        await Actor.provide(
+                                            "steam",
+                                            {
+                                                steamID: currentSteamID,
+                                            },
+                                            async () => {
+
+                                               await bus.publish(
+                                                    Resource.Bus,
+                                                    Library.Events.Add,
+                                                    {
+                                                        appID: game.appid,
+                                                        totalPlaytime: game.playtime_forever,
+                                                        lastPlayed: game.rtime_last_played ? new Date(game.rtime_last_played * 1000) : null,
+                                                    }
+                                                )
+
+                                            }
+                                        )
+                                    })
+                                )
+
+                                queryLib
+                                    .filter(i => i.status === "rejected")
+                                    .forEach(e => console.warn(`[pushUserLib]: Failed to push user library to queue: ${e.reason}`))
+                            })
+                        )
+                    } catch (error: any) {
+                        console.error(`Failed to process Steam data for user ${userID}:`, error);
+                    }
+                })())
+
+                return c.html(
+                    `
+                    <script>
+                       window.location.href = "about:blank";
+                       window.close()
+                    </script>
+                    `
+                )
+            }
+        )
+        .get("/popup/:id",
             describeRoute({
                 tags: ["Steam"],
-                summary: "Login to Steam using QR code",
-                description: "Login to Steam using a QR code sent using Server Sent Events",
+                summary: "Login to Steam",
+                description: "Login to Steam in a popup",
                 responses: {
                     400: ErrorResponses[400],
                     429: ErrorResponses[429],
                 }
             }),
             validator(
-                "header",
+                "param",
                 z.object({
-                    "accept": z.string()
-                        .refine((v) =>
-                            v.toLowerCase()
-                                .includes("text/event-stream")
-                        )
-                        .openapi({
-                            description: "Client must accept Server Sent Events",
-                            example: "text/event-stream"
-                        })
-                })
+                    id: z.string().openapi({
+                        description: "ID of the user to login",
+                        example: Examples.User.id,
+                    }),
+                }),
             ),
-            (c) => {
-                const currentUser = Actor.user()
+            async (c) => {
+                const userID = c.req.valid("param").id;
 
-                return streamSSE(c, async (stream) => {
+                const user = await User.fromID(userID);
+                if (!user) {
+                    throw new VisibleError(
+                        "not_found",
+                        ErrorCodes.NotFound.RESOURCE_NOT_FOUND,
+                        `User ${userID} not found`
+                    )
+                }
 
-                    const session = new LoginSession(EAuthTokenPlatformType.MobileApp);
+                setCookie(c, "user_id", user.id);
 
-                    session.loginTimeout = 30000; //30 seconds is typically when the url expires
+                const returnUrl = `${new URL(c.req.url).origin}/steam/callback/${userID}`
 
-                    await stream.writeSSE({
-                        event: 'status',
-                        data: JSON.stringify({ message: "connected to steam" })
-                    })
+                const params = new URLSearchParams({
+                    'openid.ns': 'http://specs.openid.net/auth/2.0',
+                    'openid.mode': 'checkid_setup',
+                    'openid.return_to': returnUrl,
+                    'openid.realm': new URL(returnUrl).origin,
+                    'openid.identity': 'http://specs.openid.net/auth/2.0/identifier_select',
+                    'openid.claimed_id': 'http://specs.openid.net/auth/2.0/identifier_select',
+                    'user_id': user.id
+                });
 
-                    const challenge = await session.startWithQR();
-
-                    await stream.writeSSE({
-                        event: 'challenge_url',
-                        data: JSON.stringify({ url: challenge.qrChallengeUrl })
-                    })
-
-                    return new Promise((resolve, reject) => {
-                        session.on('remoteInteraction', async () => {
-                            await stream.writeSSE({
-                                event: 'remote_interaction',
-                                data: JSON.stringify({ message: "Looks like you've scanned the code! Now just approve the login." }),
-                            })
-
-                            await stream.writeSSE({
-                                event: 'status',
-                                data: JSON.stringify({ message: "Looks like you've scanned the code! Now just approve the login." }),
-                            })
-                        });
-
-                        session.on('timeout', async () => {
-                            console.log('This login attempt has timed out.');
-
-                            await stream.writeSSE({
-                                event: 'status',
-                                data: JSON.stringify({ message: "Your session timed out" }),
-                            })
-
-                            await stream.writeSSE({
-                                event: 'timed_out',
-                                data: JSON.stringify({ success: false }),
-                            })
-
-                            await stream.close()
-                            reject("Authentication timed out")
-                        });
-
-                        session.on('error', async (err) => {
-                            // This should ordinarily not happen. This only happens in case there's some kind of unexpected error while
-                            // polling, e.g. the network connection goes down or Steam chokes on something.
-                            await stream.writeSSE({
-                                event: 'status',
-                                data: JSON.stringify({ message: "Recieved an error while authenticating" }),
-                            })
-
-                            await stream.writeSSE({
-                                event: 'error',
-                                data: JSON.stringify({ message: err.message }),
-                            })
-
-                            await stream.close()
-                            reject(err.message)
-                        });
-
-
-                        session.on('authenticated', async () => {
-                            await stream.writeSSE({
-                                event: 'status',
-                                data: JSON.stringify({ message: "Login successful" })
-                            })
-
-                            await stream.writeSSE({
-                                event: 'login_success',
-                                data: JSON.stringify({ success: true, })
-                            })
-
-                            const username = session.accountName;
-                            const accessToken = session.accessToken;
-                            const refreshToken = session.refreshToken;
-                            const steamID = session.steamID.toString();
-                            const cookies = await session.getWebCookies();
-
-                            // Get user information
-                            const community = new SteamCommunity();
-                            community.setCookies(cookies);
-
-                            const user = await Client.getUserInfo({ steamID, cookies })
-
-                            const wasAdded =
-                                await Steam.create({
-                                    username,
-                                    id: steamID,
-                                    name: user.name,
-                                    realName: user.realName,
-                                    userID: currentUser.userID,
-                                    avatarHash: user.avatarHash,
-                                    steamMemberSince: user.memberSince,
-                                    profileUrl: user.customURL?.trim() || null,
-                                    limitations: {
-                                        isLimited: user.isLimitedAccount,
-                                        isVacBanned: user.vacBanned,
-                                        privacyState: user.privacyState as any,
-                                        visibilityState: Number(user.visibilityState),
-                                        tradeBanState: user.tradeBanState.toLowerCase() as any,
-                                    }
-                                })
-
-                            // Does not matter if the user is already there or has just been created, just store the credentials
-                            await Credentials.create({ refreshToken, steamID, username })
-
-                            let teamID: string | undefined
-
-                            if (wasAdded) {
-                                const rawFirst = (user.name ?? username).trim().split(/\s+/)[0] ?? username;
-
-                                const firstName = rawFirst
-                                    .charAt(0) // first character
-                                    .toUpperCase() // make it uppercase
-                                    + rawFirst
-                                        .slice(1) // rest of the string
-                                        .toLowerCase();
-
-                                // create a team
-                                teamID = await Team.create({
-                                    slug: username,
-                                    name: firstName,
-                                    ownerID: currentUser.userID,
-                                })
-
-                                // Add us as a member
-                                await Actor.provide(
-                                    "system",
-                                    { teamID },
-                                    async () =>
-                                        await Member.create({
-                                            role: "adult",
-                                            userID: currentUser.userID,
-                                            steamID
-                                        })
-                                )
-
-                            } else {
-                                // Update the owner of the Steam account
-                                await Steam.updateOwner({ userID: currentUser.userID, steamID })
-                                const t = await Actor.provide(
-                                    "user",
-                                    currentUser,
-                                    async () => {
-                                        // Get the team associated with this username
-                                        const team = await Team.fromSlug(username);
-                                        // This should never happen
-                                        if (!team) throw Error(`Is Nestri okay???, we could not find the team with this slug ${username}`)
-
-                                        teamID = team.id
-
-                                        return team.id
-                                    }
-                                )
-                                console.log("t",t)
-                                console.log("teamID",teamID)
-                            }
-
-                            await stream.writeSSE({
-                                event: 'team_slug',
-                                data: JSON.stringify({ username })
-                            })
-
-                            // Get game library in the background
-                            c.executionCtx.waitUntil((async () => {
-                                const games = await Client.getUserLibrary(accessToken);
-
-                                // Get a batch of 5 games each
-                                const apps = games?.response?.apps || [];
-                                if (apps.length === 0) {
-                                    console.info("[SteamApi] Is Steam okay? No games returned for user:", { steamID });
-                                    return
-                                }
-
-                                const chunkedGames = chunkArray(apps, 5);
-                                // Get the batches to the queue
-                                const processQueue = chunkedGames.map(async (chunk) => {
-                                    const myGames = chunk.map(i => {
-                                        return {
-                                            appID: i.appid,
-                                            totalPlaytime: i.rt_playtime,
-                                            isFamilyShareable: i.exclude_reason === 0,
-                                            lastPlayed: new Date(i.rt_last_played * 1000),
-                                            timeAcquired: new Date(i.rt_time_acquired * 1000),
-                                            isFamilyShared: !i.owner_steamids.includes(steamID) && i.exclude_reason === 0,
-                                        }
-                                    })
-
-                                    if (teamID) {
-                                        const deduplicationId = crypto
-                                            .createHash('md5')
-                                            .update(`${teamID}_${chunk.map(g => g.appid).join(',')}`)
-                                            .digest('hex');
-
-                                        await Actor.provide(
-                                            "member",
-                                            {
-                                                teamID,
-                                                steamID,
-                                                userID: currentUser.userID
-                                            },
-                                            async () => {
-                                                const payload = await Library.Events.Queue.create(myGames);
-
-                                                await sqs.send(
-                                                    new SendMessageCommand({
-                                                        MessageGroupId: teamID,
-                                                        QueueUrl: Resource.LibraryQueue.url,
-                                                        MessageBody: JSON.stringify(payload),
-                                                        MessageDeduplicationId: deduplicationId,
-                                                    })
-                                                )
-                                            }
-                                        )
-                                    }
-                                })
-
-                                const settled = await Promise.allSettled(processQueue)
-
-                                settled
-                                    .filter(r => r.status === "rejected")
-                                    .forEach(r => console.error("[LibraryQueue] enqueue failed:", (r as PromiseRejectedResult).reason));
-                            })())
-
-                            await stream.close();
-
-                            resolve();
-                        })
-                    })
-                })
+                return c.redirect(`https://steamcommunity.com/openid/login?${params.toString()}`, 302)
             }
         )
 }

packages/functions/src/api/team.ts

@@ -1,91 +0,0 @@
-import { z } from "zod"
-import { Hono } from "hono";
-import { describeRoute } from "hono-openapi";
-import { Team } from "@nestri/core/team/index";
-import { Examples } from "@nestri/core/examples";
-import { ErrorResponses, Result, validator } from "./utils";
-import { ErrorCodes, VisibleError } from "@nestri/core/error";
-
-export namespace TeamApi {
-    export const route = new Hono()
-        .get("/",
-            describeRoute({
-                tags: ["Team"],
-                summary: "List user teams",
-                description: "List the current user's team details",
-                responses: {
-                    200: {
-                        content: {
-                            "application/json": {
-                                schema: Result(
-                                    Team.Info.array().openapi({
-                                        description: "All team information",
-                                        example: [Examples.Team]
-                                    })
-                                ),
-                            },
-                        },
-                        description: "All team details"
-                    },
-                    400: ErrorResponses[400],
-                    404: ErrorResponses[404],
-                    429: ErrorResponses[429],
-                }
-            }),
-            async (c) =>
-                c.json({
-                    data: await Team.list()
-                })
-        )
-        .get("/:slug",
-            describeRoute({
-                tags: ["Team"],
-                summary: "Get team by slug",
-                description: "Get the current user's team details, by its slug",
-                responses: {
-                    200: {
-                        content: {
-                            "application/json": {
-                                schema: Result(
-                                    Team.Info.openapi({
-                                        description: "Team details",
-                                        example: Examples.Team
-                                    })
-                                ),
-                            },
-                        },
-                        description: "Team details"
-                    },
-                    400: ErrorResponses[400],
-                    404: ErrorResponses[404],
-                    429: ErrorResponses[429],
-                }
-            }),
-            validator(
-                "param",
-                z.object({
-                    slug: z.string().openapi({
-                        description: "SLug of the team to get",
-                        example: Examples.Team.slug,
-                    }),
-                }),
-            ),
-            async (c) => {
-                const teamSlug = c.req.valid("param").slug
-
-                const team = await Team.fromSlug(teamSlug)
-
-                if (!team) {
-                    throw new VisibleError(
-                        "not_found",
-                        ErrorCodes.NotFound.RESOURCE_NOT_FOUND,
-                        `Team ${teamSlug} not found`
-                    )
-                }
-
-                return c.json({
-                    data: team
-                })
-            }
-        )
-}

packages/functions/src/api/utils/auth.ts

@@ -2,9 +2,9 @@ import { Resource } from "sst";
 import { subjects } from "../../subjects";
 import { Actor } from "@nestri/core/actor";
 import { type MiddlewareHandler } from "hono";
+import { Steam } from "@nestri/core/steam/index";
 import { createClient } from "@openauthjs/openauth/client";
 import { ErrorCodes, VisibleError } from "@nestri/core/error";
-import { Member } from "@nestri/core/member/index";
 
 const client = createClient({
   clientID: "api",
@@ -44,19 +44,19 @@ export const auth: MiddlewareHandler = async (c, next) => {
   }
 
   if (result.subject.type === "user") {
-    const teamID = c.req.header("x-nestri-team");
-    if (!teamID) {
+    const steamID = c.req.header("x-nestri-steam");
+    if (!steamID) {
       return Actor.provide(result.subject.type, result.subject.properties, next);
     }
     const userID = result.subject.properties.userID
     return Actor.provide(
-      "system",
+      "steam",
       {
-        teamID
+        steamID
       },
       async () => {
-        const member = await Member.fromUserID(userID)
-        if (!member || !member.userID) {
+        const steamAcc = await Steam.confirmOwnerShip(userID)
+        if (!steamAcc) {
           throw new VisibleError(
             "authentication",
             ErrorCodes.Authentication.UNAUTHORIZED,
@@ -66,9 +66,8 @@ export const auth: MiddlewareHandler = async (c, next) => {
         return Actor.provide(
           "member",
           {
-            steamID: member.steamID,
-            userID: member.userID,
-            teamID: member.teamID
+            steamID,
+            userID,
           },
           next)
       });

packages/functions/src/events/index.ts

@@ -1,74 +1,123 @@
+import "zod-openapi/extend";
 import { Resource } from "sst";
 import { bus } from "sst/aws/bus";
+import { Actor } from "@nestri/core/actor";
+import { Game } from "@nestri/core/game/index";
 import { Steam } from "@nestri/core/steam/index";
 import { Client } from "@nestri/core/client/index";
 import { Images } from "@nestri/core/images/index";
-import { Friend } from "@nestri/core/friend/index";
+import { Library } from "@nestri/core/library/index";
 import { BaseGame } from "@nestri/core/base-game/index";
-import { Credentials } from "@nestri/core/credentials/index";
-import { EAuthTokenPlatformType, LoginSession } from "steam-session";
+import { Categories } from "@nestri/core/categories/index";
+import { ImageTypeEnum } from "@nestri/core/images/images.sql";
 import { PutObjectCommand, S3Client, HeadObjectCommand } from "@aws-sdk/client-s3";
 
 const s3 = new S3Client({});
 
 export const handler = bus.subscriber(
-  [Credentials.Events.New, BaseGame.Events.New],
+  [
+    Library.Events.Add,
+    BaseGame.Events.New,
+    Steam.Events.Updated,
+    Steam.Events.Created,
+    BaseGame.Events.NewBoxArt,
+    BaseGame.Events.NewHeroArt,
+  ],
   async (event) => {
     console.log(event.type, event.properties, event.metadata);
     switch (event.type) {
-      case "new_credentials.added": {
-        const input = event.properties
-        const credentials = await Credentials.fromSteamID(input.steamID)
-        if (credentials) {
-          const session = new LoginSession(EAuthTokenPlatformType.MobileApp);
+      case "new_image.save": {
+        const input = event.properties;
+        const image = await Client.getImageInfo({ url: input.url, type: input.type });
 
-          session.refreshToken = credentials.refreshToken;
+        await Images.create({
+          type: image.type,
+          imageHash: image.hash,
+          baseGameID: input.appID,
+          position: image.position,
+          fileSize: image.fileSize,
+          sourceUrl: image.sourceUrl,
+          dimensions: image.dimensions,
+          extractedColor: image.averageColor,
+        });
 
-          const cookies = await session.getWebCookies();
+        try {
+          //Check whether the image already exists
+          await s3.send(
+            new HeadObjectCommand({
+              Bucket: Resource.Storage.name,
+              Key: `images/${image.hash}`,
+            })
+          );
 
-          const friends = await Client.getFriendsList(cookies);
-
-          const putFriends = friends.map(async (user) => {
-            const wasAdded =
-              await Steam.create({
-                id: user.steamID.toString(),
-                name: user.name,
-                realName: user.realName,
-                avatarHash: user.avatarHash,
-                steamMemberSince: user.memberSince,
-                profileUrl: user.customURL?.trim() || null,
-                limitations: {
-                  isLimited: user.isLimitedAccount,
-                  isVacBanned: user.vacBanned,
-                  tradeBanState: user.tradeBanState.toLowerCase() as any,
-                  privacyState: user.privacyState as any,
-                  visibilityState: Number(user.visibilityState)
-                }
-              })
-
-            if (!wasAdded) {
-              console.log(`Steam user ${user.steamID.toString()} already exists`)
-            }
-
-            await Friend.add({ friendSteamID: user.steamID.toString(), steamID: input.steamID })
-          })
-
-          const settled = await Promise.allSettled(putFriends);
-
-          settled
-            .filter(result => result.status === 'rejected')
-            .forEach(result => console.warn('[putFriends] failed:', (result as PromiseRejectedResult).reason))
+        } catch (e) {
+          // Save to s3 because it doesn't already exist
+          await s3.send(
+            new PutObjectCommand({
+              Bucket: Resource.Storage.name,
+              Key: `images/${image.hash}`,
+              Body: image.buffer,
+              ...(image.format && { ContentType: `image/${image.format}` }),
+              Metadata: {
+                type: image.type,
+                appID: input.appID,
+              }
+            })
+          )
         }
+
         break;
       }
-      case "new_game.added": {
-        const input = event.properties
-        // Get images and save to s3
-        const images = await Client.getImages(input.appID);
+      case "new_box_art_image.save": {
+        const input = event.properties;
 
-        (await Promise.allSettled(
+        const image = await Client.createBoxArt(input);
+
+        await Images.create({
+          type: image.type,
+          imageHash: image.hash,
+          baseGameID: input.appID,
+          position: image.position,
+          fileSize: image.fileSize,
+          sourceUrl: image.sourceUrl,
+          dimensions: image.dimensions,
+          extractedColor: image.averageColor,
+        });
+
+        try {
+          //Check whether the image already exists
+          await s3.send(
+            new HeadObjectCommand({
+              Bucket: Resource.Storage.name,
+              Key: `images/${image.hash}`,
+            })
+          );
+
+        } catch (e) {
+          // Save to s3 because it doesn't already exist
+          await s3.send(
+            new PutObjectCommand({
+              Bucket: Resource.Storage.name,
+              Key: `images/${image.hash}`,
+              Body: image.buffer,
+              ...(image.format && { ContentType: `image/${image.format}` }),
+              Metadata: {
+                type: image.type,
+                appID: input.appID,
+              }
+            })
+          )
+        }
+
+        break;
+      }
+      case "new_hero_art_image.save": {
+        const input = event.properties;
+
+        const images = await Client.createHeroArt(input);
+
+        await Promise.all(
           images.map(async (image) => {
-            // Put the images into the db
             await Images.create({
               type: image.type,
               imageHash: image.hash,
@@ -104,14 +153,117 @@ export const handler = bus.subscriber(
                 })
               )
             }
-
           })
-        ))
-          .filter(i => i.status === "rejected")
-          .forEach(r => console.warn("[createImages] failed:", (r as PromiseRejectedResult).reason));
+        )
 
         break;
       }
+      case "library.add": {
+
+        await Actor.provide(
+          event.metadata.actor.type,
+          event.metadata.actor.properties,
+          async () => {
+            const game = event.properties
+            // First check whether the base_game exists, if not get it
+            const appID = game.appID.toString();
+            const exists = await BaseGame.fromID(appID);
+
+            if (!exists) {
+              const appInfo = await Client.getAppInfo(appID);
+
+              await BaseGame.create({
+                id: appID,
+                name: appInfo.name,
+                size: appInfo.size,
+                slug: appInfo.slug,
+                links: appInfo.links,
+                score: appInfo.score,
+                description: appInfo.description,
+                releaseDate: appInfo.releaseDate,
+                primaryGenre: appInfo.primaryGenre,
+                compatibility: appInfo.compatibility,
+                controllerSupport: appInfo.controllerSupport,
+              })
+
+              const allCategories = [...appInfo.tags, ...appInfo.genres, ...appInfo.publishers, ...appInfo.developers, ...appInfo.categories, ...appInfo.franchises]
+
+              const uniqueCategories = Array.from(
+                new Map(allCategories.map(c => [`${c.type}:${c.slug}`, c])).values()
+              );
+
+              await Promise.all(
+                uniqueCategories.map(async (cat) => {
+                  //Create category if it doesn't exist
+                  await Categories.create({
+                    type: cat.type, slug: cat.slug, name: cat.name
+                  })
+
+                  //Create game if it doesn't exist
+                  await Game.create({ baseGameID: appID, categorySlug: cat.slug, categoryType: cat.type })
+                })
+              )
+
+              const imageUrls = appInfo.images
+
+              await Promise.all(
+                ImageTypeEnum.enumValues.map(async (type) => {
+                  switch (type) {
+                    case "backdrop": {
+                      await bus.publish(Resource.Bus, BaseGame.Events.New, { appID, type: "backdrop", url: imageUrls.backdrop })
+                      break;
+                    }
+                    case "banner": {
+                      await bus.publish(Resource.Bus, BaseGame.Events.New, { appID, type: "banner", url: imageUrls.banner })
+                      break;
+                    }
+                    case "icon": {
+                      await bus.publish(Resource.Bus, BaseGame.Events.New, { appID, type: "icon", url: imageUrls.icon })
+                      break;
+                    }
+                    case "logo": {
+                      await bus.publish(Resource.Bus, BaseGame.Events.New, { appID, type: "logo", url: imageUrls.logo })
+                      break;
+                    }
+                    case "poster": {
+                      await bus.publish(
+                        Resource.Bus,
+                        BaseGame.Events.New,
+                        { appID, type: "poster", url: imageUrls.poster }
+                      )
+                      break;
+                    }
+                    case "heroArt": {
+                      await bus.publish(
+                        Resource.Bus,
+                        BaseGame.Events.NewHeroArt,
+                        { appID, backdropUrl: imageUrls.backdrop, screenshots: imageUrls.screenshots }
+                      )
+                      break;
+                    }
+                    case "boxArt": {
+                      await bus.publish(
+                        Resource.Bus,
+                        BaseGame.Events.NewBoxArt,
+                        { appID, logoUrl: imageUrls.logo, backgroundUrl: imageUrls.backdrop }
+                      )
+                      break;
+                    }
+                  }
+                })
+              )
+            }
+
+            // Add to user's library
+            await Library.add({
+              baseGameID: appID,
+              lastPlayed: game.lastPlayed ? new Date(game.lastPlayed) : null,
+              totalPlaytime: game.totalPlaytime,
+            })
+          })
+
+          break;
+      }
     }
   },
 );

packages/functions/src/images/image.ts

@@ -0,0 +1,91 @@
+import { Hono } from "hono";
+import { AwsClient } from 'aws4fetch'
+import { Resource } from "sst";
+import { HTTPException } from "hono/http-exception";
+
+
+export namespace ImageRoute {
+    export const route = new Hono()
+        .get(
+            "/:hashWithExt",
+            async (c) => {
+                // const { hashWithExt } = c.req.param();
+
+                const client = new AwsClient({
+                    accessKeyId: Resource.ImageInvokerAccessKey.key,
+                    secretAccessKey: Resource.ImageInvokerAccessKey.secret,
+                })
+
+                const LAMBDA_URL = `https://lambda.us-east-1.amazonaws.com/2015-03-31/functions/${Resource.ImageProcessor.name}/invocations`
+
+                const lambdaResponse = await client.fetch(LAMBDA_URL, {
+                    method: 'POST',
+                    headers: { 'Content-Type': 'application/json' },
+                    body: JSON.stringify({ world: "hello" }),
+                })
+
+                if (!lambdaResponse.ok) {
+                    console.error(await lambdaResponse.text())
+                    return c.json({ error: `Lambda API returned ${lambdaResponse.status}` }, { status: 500 })
+                }
+
+                console.log(await lambdaResponse.json())
+
+                // // Validate format
+                // // Split hash and extension
+                // const match = hashWithExt.match(/^([a-zA-Z0-9_-]+)\.(avif|webp)$/);
+                // if (!match) {
+                //     throw new HTTPException(400, { message: "Invalid image hash or format" });
+                // }
+
+                // const [, hash, format] = match;
+
+                // const query = c.req.query();
+                // // Parse dimensions
+                // const width = parseInt(query.w || query.width || "");
+                // const height = parseInt(query.h || query.height || "");
+                // const dpr = parseFloat(query.dpr || "1");
+
+                // if (isNaN(width) || width <= 0) {
+                //     throw new HTTPException(400, { message: "Invalid width" });
+                // }
+                // if (!isNaN(height) && height < 0) {
+                //     throw new HTTPException(400, { message: "Invalid height" });
+                // }
+                // if (dpr < 1 || dpr > 4) {
+                //     throw new HTTPException(400, { message: "Invalid dpr" });
+                // }
+
+                // console.log("url",Resource.Api.url)
+
+                // const imageBytes = await fetch(`${Resource.Api.url}/image/${hash}`,{
+                //     method:"POST",
+                //     body:JSON.stringify({   
+                //         dpr,
+                //         width,
+                //         height,
+                //         format
+                //     })
+                // })
+
+                // console.log("imahe",imageBytes.headers)
+
+                // // Normalize and build cache key
+                // // const cacheKey = `${hash}_${format}_w${width}${height ? `_h${height}` : ""}_dpr${dpr}`;
+
+                // // Add aggressive caching
+                // // c.header("Cache-Control", "public, max-age=315360000, immutable");
+
+                // // Placeholder image response (to be replaced by real logic)
+                // return c.newResponse(await imageBytes.arrayBuffer(),
+                //     // {
+                //     //     headers: {
+                //     //        ...imageBytes.headers
+                //     //     }
+                //     // }
+                // );
+
+                return c.text("success")
+            }
+        )
+}