+ );
+}
+
+export default PriceAlertsPage;
diff --git a/apps/webapp/app/alerts/priceAlertService.js b/apps/webapp/app/alerts/priceAlertService.js
new file mode 100644
index 00000000..43a542a2
--- /dev/null
+++ b/apps/webapp/app/alerts/priceAlertService.js
@@ -0,0 +1,18 @@
+import axios from 'axios';
+
+export async function getAlerts() {
+ const res = await axios.get('/api/alerts');
+ return res.data;
+}
+
+export async function createAlert(alert) {
+ await axios.post('/api/alerts', alert);
+}
+
+export async function updateAlert(id, alert) {
+ await axios.put(`/api/alerts/${id}`, alert);
+}
+
+export async function deleteAlert(id) {
+ await axios.delete(`/api/alerts/${id}`);
+}
diff --git a/apps/webapp/app/alerts/price_alerts_controller.js b/apps/webapp/app/alerts/price_alerts_controller.js
new file mode 100644
index 00000000..18354df9
--- /dev/null
+++ b/apps/webapp/app/alerts/price_alerts_controller.js
@@ -0,0 +1,24 @@
+const express = require('express');
+const router = express.Router();
+const service = require('../services/price_alerts_service');
+
+router.get('/api/alerts', async (req, res) => {
+ res.json(await service.listAlerts(req.user.id));
+});
+
+router.post('/api/alerts', async (req, res) => {
+ await service.createAlert(req.user.id, req.body);
+ res.json({ success: true });
+});
+
+router.put('/api/alerts/:id', async (req, res) => {
+ await service.updateAlert(req.user.id, req.params.id, req.body);
+ res.json({ success: true });
+});
+
+router.delete('/api/alerts/:id', async (req, res) => {
+ await service.deleteAlert(req.user.id, req.params.id);
+ res.json({ success: true });
+});
+
+module.exports = router;
diff --git a/apps/webapp/app/alerts/price_alerts_service.js b/apps/webapp/app/alerts/price_alerts_service.js
new file mode 100644
index 00000000..1cb977cb
--- /dev/null
+++ b/apps/webapp/app/alerts/price_alerts_service.js
@@ -0,0 +1,26 @@
+const db = require('../db');
+
+async function listAlerts(userId) {
+ const res = await db.query('SELECT * FROM price_alerts WHERE user_id=$1', [userId]);
+ return res.rows;
+}
+
+async function createAlert(userId, { asset, targetPrice, direction }) {
+ await db.query(
+ 'INSERT INTO price_alerts (id, user_id, asset, target_price, direction, created_at) VALUES (gen_random_uuid(), $1, $2, $3, $4, NOW())',
+ [userId, asset, targetPrice, direction]
+ );
+}
+
+async function updateAlert(userId, id, { targetPrice, direction }) {
+ await db.query(
+ 'UPDATE price_alerts SET target_price=$1, direction=$2 WHERE id=$3 AND user_id=$4',
+ [targetPrice, direction, id, userId]
+ );
+}
+
+async function deleteAlert(userId, id) {
+ await db.query('DELETE FROM price_alerts WHERE id=$1 AND user_id=$2', [id, userId]);
+}
+
+module.exports = { listAlerts, createAlert, updateAlert, deleteAlert };
diff --git a/apps/webapp/app/alerts/price_alerts_tests.js b/apps/webapp/app/alerts/price_alerts_tests.js
new file mode 100644
index 00000000..82915dc1
--- /dev/null
+++ b/apps/webapp/app/alerts/price_alerts_tests.js
@@ -0,0 +1,25 @@
+const service = require('../src/services/price_alerts_service');
+
+describe('Price Alerts Service', () => {
+ it('creates a new alert', async () => {
+ await service.createAlert('user1', { asset: 'XLM', targetPrice: 0.5, direction: 'above' });
+ const alerts = await service.listAlerts('user1');
+ expect(alerts.some(a => a.asset === 'XLM')).toBe(true);
+ });
+
+ it('updates an alert', async () => {
+ const alerts = await service.listAlerts('user1');
+ const id = alerts[0].id;
+ await service.updateAlert('user1', id, { targetPrice: 0.6, direction: 'below' });
+ const updated = await service.listAlerts('user1');
+ expect(updated.find(a => a.id === id).target_price).toBe(0.6);
+ });
+
+ it('deletes an alert', async () => {
+ const alerts = await service.listAlerts('user1');
+ const id = alerts[0].id;
+ await service.deleteAlert('user1', id);
+ const updated = await service.listAlerts('user1');
+ expect(updated.find(a => a.id === id)).toBeUndefined();
+ });
+});
diff --git a/apps/webapp/components/stellar/TransactionFeed.test.tsx b/apps/webapp/components/stellar/TransactionFeed.test.tsx
new file mode 100644
index 00000000..0a4191e0
--- /dev/null
+++ b/apps/webapp/components/stellar/TransactionFeed.test.tsx
@@ -0,0 +1,9 @@
+import { render, screen } from "@testing-library/react";
+import { TransactionFeed } from "./TransactionFeed";
+
+describe("TransactionFeed", () => {
+ it("renders loading state", () => {
+ render(