feat(mfi-notifications): liquidation notifications

api.Dockerfile

@@ -0,0 +1,14 @@
+FROM node:lts-bullseye
+
+# WORKDIR /workspace 
+# Create and change to the app directory.
+WORKDIR /app
+
+COPY . .
+
+RUN yarn install
+RUN yarn build
+
+WORKDIR /app/apps/marginfi-api
+
+CMD "./scripts/start.sh"

apps/marginfi-api/.eslintrc.json

@@ -0,0 +1,3 @@
+{
+  "extends": "next/core-web-vitals"
+}

apps/marginfi-api/.gitignore

@@ -0,0 +1,36 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.js
+.yarn/install-state.gz
+
+# testing
+/coverage
+
+# next.js
+/.next/
+/out/
+
+# production
+/build
+
+# misc
+.DS_Store
+*.pem
+
+# debug
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# local env files
+.env*.local
+
+# vercel
+.vercel
+
+# typescript
+*.tsbuildinfo
+next-env.d.ts

apps/marginfi-api/README.md

@@ -0,0 +1,36 @@
+This is a [Next.js](https://nextjs.org/) project bootstrapped with [`create-next-app`](https://github.com/vercel/next.js/tree/canary/packages/create-next-app).
+
+## Getting Started
+
+First, run the development server:
+
+```bash
+npm run dev
+# or
+yarn dev
+# or
+pnpm dev
+# or
+bun dev
+```
+
+Open [http://localhost:3000](http://localhost:3000) with your browser to see the result.
+
+You can start editing the page by modifying `app/page.tsx`. The page auto-updates as you edit the file.
+
+This project uses [`next/font`](https://nextjs.org/docs/basic-features/font-optimization) to automatically optimize and load Inter, a custom Google Font.
+
+## Learn More
+
+To learn more about Next.js, take a look at the following resources:
+
+- [Next.js Documentation](https://nextjs.org/docs) - learn about Next.js features and API.
+- [Learn Next.js](https://nextjs.org/learn) - an interactive Next.js tutorial.
+
+You can check out [the Next.js GitHub repository](https://github.com/vercel/next.js/) - your feedback and contributions are welcome!
+
+## Deploy on Vercel
+
+The easiest way to deploy your Next.js app is to use the [Vercel Platform](https://vercel.com/new?utm_medium=default-template&filter=next.js&utm_source=create-next-app&utm_campaign=create-next-app-readme) from the creators of Next.js.
+
+Check out our [Next.js deployment documentation](https://nextjs.org/docs/deployment) for more details.

apps/marginfi-api/next.config.mjs

@@ -0,0 +1,4 @@
+/** @type {import('next').NextConfig} */
+const nextConfig = {};
+
+export default nextConfig;

apps/marginfi-api/package.json

@@ -0,0 +1,26 @@
+{
+  "name": "@mrgnlabs/marginfi-api",
+  "version": "0.1.0",
+  "private": true,
+  "scripts": {
+    "dev": "next dev",
+    "build": "next build",
+    "start": "next start",
+    "lint": "next lint"
+  },
+  "dependencies": {
+    "next": "14.1.1",
+    "pg": "^8.11.3",
+    "react": "18.2.0",
+    "react-dom": "18.2.0"
+  },
+  "devDependencies": {
+    "@mrgnlabs/eslint-config-custom": "*",
+    "@mrgnlabs/tsconfig": "*",
+    "@types/node": "18.11.18",
+    "@types/react": "^18.2.61",
+    "@types/react-dom": "^18.2.19",
+    "eslint": "8.30.0",
+    "typescript": "4.9.4"
+  }
+}

apps/marginfi-api/scripts/pm2.config.js

@@ -0,0 +1,16 @@
+const path = require("path");
+
+module.exports = [
+  {
+    name: "fetcher",
+    script: path.join(__dirname, "../dist/rpcFetcher.js"),
+    instances: 1,
+    exec_mode: "fork",
+  },
+  {
+    name: "api",
+    script: path.join(__dirname, "../.next/index.js"),
+    wait_ready: false,
+    listen_timeout: 5000,
+  },
+];

apps/marginfi-api/scripts/start.sh

@@ -0,0 +1,4 @@
+while true; do
+    yarn start
+    sleep 1  # Sleep for 1 second before restarting, adjust as needed
+done

apps/marginfi-api/src/app/notifications/route.ts

@@ -0,0 +1,129 @@
+import { NextResponse } from "next/server";
+
+import db from "~/lib/pg";
+
+export const dynamic = "force-dynamic";
+
+export async function GET(request: Request) {
+  const { searchParams } = new URL(request.url);
+  const wallet = searchParams.get("wallet_address");
+  const apiKey = request.headers.get("X-API-KEY");
+
+  if (!apiKey || apiKey !== process.env.MARGINFI_API_KEY) {
+    console.error("Invalid or missing API key");
+    return NextResponse.json(
+      { error: "Invalid or missing API key" },
+      {
+        status: 401,
+      }
+    );
+  }
+
+  if (!wallet) {
+    console.error("Missing wallet address parameter");
+    return NextResponse.json(
+      { error: "Missing wallet address parameter" },
+      {
+        status: 400,
+      }
+    );
+  }
+
+  try {
+    const queryText = "SELECT * FROM notification_settings WHERE wallet_address = $1";
+    const { rows } = await db.query(queryText, [wallet]);
+
+    if (rows.length === 0) {
+      console.error("Notification settings not found");
+      return NextResponse.json(
+        { error: "Notification settings not found" },
+        {
+          status: 404,
+        }
+      );
+    }
+
+    return NextResponse.json(rows[0], {
+      status: 200,
+    });
+  } catch (error) {
+    console.error("Database error:", error);
+    return NextResponse.json(
+      { error: "Internal server error" },
+      {
+        status: 500,
+      }
+    );
+  }
+}
+
+export async function POST(request: Request) {
+  const data = await request.json();
+  const apiKey = request.headers.get("X-API-KEY");
+
+  if (!apiKey || apiKey !== process.env.MARGINFI_API_KEY) {
+    return NextResponse.json({ error: "Invalid or missing API key" }, { status: 401 });
+  }
+
+  if (!data.wallet_address) {
+    return NextResponse.json({ error: "Missing wallet address parameter" }, { status: 400 });
+  }
+
+  // Start constructing the query dynamically
+  let fields: string[] = ["wallet_address"];
+  let values: string[] = [data.wallet_address];
+  let params: string[] = ["$1"];
+  let updateSets: string[] = [];
+  let counter: number = 2;
+
+  // Dynamically add fields that are present
+  ["email", "account_health", "ybx_updates", "last_notification"].forEach((field) => {
+    if (data.hasOwnProperty(field)) {
+      fields.push(field);
+      values.push(data[field]);
+      params.push(`$${counter}`);
+      updateSets.push(`${field} = EXCLUDED.${field}`);
+      counter++;
+    }
+  });
+
+  const queryText = `
+    INSERT INTO notification_settings (${fields.join(", ")})
+    VALUES (${params.join(", ")})
+    ON CONFLICT (wallet_address)
+    DO UPDATE SET ${updateSets.join(", ")};
+  `;
+
+  try {
+    await db.query(queryText, values);
+    return NextResponse.json({ success: true }, { status: 200 });
+  } catch (error) {
+    console.error("Database error:", error);
+    return NextResponse.json({ error: "Internal server error" }, { status: 500 });
+  }
+}
+
+export async function DELETE(request: Request) {
+  const { searchParams } = new URL(request.url);
+  const wallet = searchParams.get("wallet_address");
+  const apiKey = request.headers.get("X-API-KEY");
+
+  if (!apiKey || apiKey !== process.env.MARGINFI_API_KEY) {
+    return NextResponse.json({ error: "Invalid or missing API key" }, { status: 401 });
+  }
+
+  if (!wallet) {
+    return NextResponse.json({ error: "Missing wallet address parameter" }, { status: 400 });
+  }
+
+  const queryText = `DELETE FROM notification_settings WHERE wallet_address = '${wallet}'`;
+
+  try {
+    const res = await db.query(queryText);
+    console.log(res);
+    return NextResponse.json({ success: true }, { status: 200 });
+  } catch (error) {
+    console.error("Database error:", error);
+    return NextResponse.json({ error: "Internal server error" }, { status: 500 });
+  }
+}

apps/marginfi-api/src/lib/pg.ts

@@ -0,0 +1,11 @@
+import { Pool } from "pg";
+
+const pool = new Pool({
+  host: process.env.PG_HOST,
+  database: process.env.PG_DATABASE,
+  user: process.env.PG_USER,
+  password: process.env.PG_PASSWORD,
+  port: parseInt(process.env.PG_PORT || "5432"),
+});
+
+export default pool;

apps/marginfi-api/tsconfig.json

@@ -0,0 +1,28 @@
+{
+  "extends": "@mrgnlabs/tsconfig/nextjs.json",
+  "compilerOptions": {
+    "jsx": "preserve",
+    "allowSyntheticDefaultImports": true,
+    "esModuleInterop": true,
+    "downlevelIteration": true,
+    "paths": {
+      "~/*": [
+        "./src/*"
+      ]
+    },
+    "plugins": [
+      {
+        "name": "next"
+      }
+    ]
+  },
+  "include": [
+    "next-env.d.ts",
+    "**/*.ts",
+    "**/*.tsx",
+    ".next/types/**/*.ts"
+  ],
+  "exclude": [
+    "node_modules"
+  ]
+}

apps/marginfi-notifications/.env.example

@@ -0,0 +1,35 @@
+# Solana Configuration
+WALLET_KEYPAIR=~/.config/solana/id.json
+RPC_ENDPOINT=https://api.mainnet-beta.solana.com
+
+# Marginfi Configuration
+MRGN_ENV=production
+MARGINFI_ACCOUNT_WHITELIST=
+MARGINFI_ACCOUNT_BLACKLIST=
+HEALTH_FACTOR_THRESHOLD=0.95
+SLEEP_INTERVAL_SECONDS=5
+WS_RESET_INTERVAL_SECONDS=300
+
+# API Configuration
+MARGINFI_API_URL=https://yourapi.example.com
+MARGINFI_API_KEY=your_api_key_here
+
+# PostgreSQL Database Configuration
+PG_USER=postgres_user
+PG_PASSWORD=postgres_password
+PG_HOST=localhost
+PG_PORT=5432
+PG_DATABASE=postgres_db
+
+# Resend Configuration
+RESEND_API_KEY=
+
+# Marginfi API key
+MARGINFI_API_KEY=
+
+# Sentry Configuration (Optional)
+SENTRY=false
+SENTRY_DSN=
+
+# WebSocket Endpoint (Optional)
+WS_ENDPOINT=wss://api.example.com

apps/marginfi-notifications/.gitignore

@@ -0,0 +1,5 @@
+node_modules
+dist
+.env
+!.env.example
+dump.rdb

apps/marginfi-notifications/README.md

@@ -0,0 +1 @@
+# marginfi notifications