chore: Update frontend components and services for form submission ev…

frontend/package.json

@@ -26,6 +26,7 @@
  "@ng-icons/core": "^29.2.1",
  "@ng-icons/heroicons": "^29.2.1",
  "@ng-icons/remixicon": "^29.2.1",
+ "@stomp/stompjs": "^7.0.0",
  "date-fns": "^3.6.0",
  "rxjs": "~7.8.0",
  "tslib": "^2.3.0",

frontend/src/app/app.component.ts

@@ -1,6 +1,7 @@
-import { Component } from '@angular/core';
+import { Component, OnInit } from '@angular/core';
 import { RouterOutlet } from '@angular/router';
-import { ToastComponent } from "./shared/components/toast/toast.component";
+import { ToastComponent } from './shared/components/toast/toast.component';
+import { WebsocketService } from './core/services/websocket.service';
 
 @Component({
  selector: 'app-root',
@@ -9,6 +10,13 @@ import { ToastComponent } from "./shared/components/toast/toast.component";
  templateUrl: './app.component.html',
  styleUrl: './app.component.css',
 })
-export class AppComponent {
+export class AppComponent implements OnInit {
  title = 'frontend';
+
+ constructor(private websocketService: WebsocketService) {}
+
+ ngOnInit(): void {
+ console.log('Connecting to websocket');
+ this.websocketService.connect();
+ }
 }

frontend/src/app/core/services/order.service.ts

@@ -13,6 +13,7 @@ export class OrderService {
  return this.httpClient.post<OrderResponse>("/orders", data);
  }
 
- cancelOrder
- () {}
+ cancelOrder(orderId: number) {
+ return this.httpClient.delete(`/orders/${orderId}`);
+ }
 }

frontend/src/app/core/services/websocket.service.ts

@@ -0,0 +1,54 @@
+import { Injectable, OnInit, signal } from '@angular/core';
+import { Client } from '@stomp/stompjs';
+
+@Injectable({
+ providedIn: 'root',
+})
+export class WebsocketService implements OnInit {
+ constructor() {}
+
+ ngOnInit(): void {
+ console.log('Setting up client');
+ this.client.set(this.setupClient());
+ }
+
+ client = signal<Client | null>(null);
+ connected = signal(false);
+
+ setupClient() {
+ console.log('Setting up client');
+ const client = new Client({
+ brokerURL: 'ws://localhost:5002/api/v1/report/ws',
+ });
+
+ client.onConnect = (frame) => {
+ this.connected.set(true);
+ console.log('Connected: ' + client.connected + ' : ' + frame);
+ client.subscribe('/topic/greetings', (greeting) => {
+ console.log(greeting);
+ });
+ };
+
+ client.onWebSocketError = (error) => {
+ console.error('Error with websocket', error);
+ };
+
+ client.onStompError = (frame) => {
+ console.error('Broker reported error: ' + frame.headers['message']);
+ console.error('Additional details: ' + frame.body);
+ };
+
+ return client;
+ }
+
+ connect() {
+ console.log('Connecting');
+ this.client()?.activate();
+ }
+
+ disconnect() {
+ this.client()?.deactivate();
+ this.connected.set(false);
+ console.log('Disconnected');
+ }
+}

frontend/src/app/features/dashboard/dashboard.component.html

@@ -89,14 +89,14 @@
  </div>
 
  <div class="mt-4 flex space-x-5">
- <div class="w-3/4">
+ <div [class]="isAdmin() ? 'w-full' : 'w-3/4'">
  <canvasjs-chart
  [options]="stockChartOptions()"
  [styles]="{ width: '100%', height: '100%' }"
  ></canvasjs-chart>
  </div>
 
- <div class="w-1/4">
+ <div [class]="isAdmin() ? 'hidden' : 'w-1/4'">
  <app-order-form (formSubmit)="placeOrder($event)" />
  </div>
  </div>

frontend/src/app/features/dashboard/dashboard.component.ts

@@ -9,6 +9,8 @@ import { StockPriceCardComponent } from '../../shared/components/stock-price-car
 import { ToastService, ToastVariant } from '../../core/services/toast.service';
 import { Stock } from '../../shared/models/stock.model';
 import { OrderRequest } from '../../shared/models/order.model';
+import { AuthService } from '../../core/services/auth.service';
+import { AccountType } from '../../shared/models/user.model';
 
 @Component({
  selector: 'app-dashboard',
@@ -27,9 +29,12 @@ export class DashboardComponent {
  constructor(
  private themeService: ThemeService,
  private orderService: OrderService,
- private toastService: ToastService
+ private toastService: ToastService,
+ private authService: AuthService
  ) {}
 
+ isAdmin = computed(() => this.authService.role() == AccountType.ADMIN);
+
  stocks: Stock[] = [
  {
  name: 'Amazon',
@@ -90,7 +95,7 @@ export class DashboardComponent {
  ];
 
  placeOrder($event: OrderRequest) {
- console.log("placing order", $event);
+ console.log('placing order', $event);
  this.orderService.createOrder($event).subscribe({
  next: () => {
  this.toastService.initiate({

frontend/src/app/shared/components/order-form/order-form.component.html

@@ -16,9 +16,14 @@ <h2 class="card-title">Place Order</h2>
  <option [value]="portfolio.id">{{ portfolio.name }}</option>
  }
  </select>
- @if (orderForm.get('portfolio')?.touched && orderForm.get('portfolio')?.invalid) {
+ @if (orderForm.get('portfolioId')?.touched && orderForm.get('portfolioId')?.invalid) {
  <small class="text-error">Portfolio is required</small>
  }
+ @if (orderForm.get('portfolioId')?.touched && orderForm.get('portfolioId')?.invalid) {
+ <small class="text-error">
+ {{ orderForm.get('portfolioId')?.errors?.['message'] }}
+ </small>
+ }
  </div>
  <div>
  <label for="stock" class="label text-sm">Stock</label>
@@ -36,6 +41,11 @@ <h2 class="card-title">Place Order</h2>
  <option value="ORCL">Oracle</option>
  <option value="AMZN">Amazon</option>
  </select>
+ @if (orderForm.get('ticker')?.touched && orderForm.get('ticker')?.invalid) {
+ <small class="text-error">
+ {{ orderForm.get('ticker')?.errors?.['message'] }}
+ </small>
+ }
  </div>
  <div>
  <label for="tradeType" class="label text-sm">Order Type</label>
@@ -47,6 +57,11 @@ <h2 class="card-title">Place Order</h2>
  <option value="MARKET">Market</option>
  <option value="LIMIT">Limit</option>
  </select>
+ @if (orderForm.get('orderType')?.touched && orderForm.get('orderType')?.invalid) {
+ <small class="text-error">
+ {{ orderForm.get('orderType')?.errors?.['message'] }}
+ </small>
+ }
  </div>
  <div>
  <label for="side" class="label text-sm">Side</label>
@@ -58,6 +73,11 @@ <h2 class="card-title">Place Order</h2>
  <option value="BUY">Buy</option>
  <option value="SELL">Sell</option>
  </select>
+ @if (orderForm.get('side')?.touched && orderForm.get('side')?.invalid) {
+ <small class="text-error">
+ {{ orderForm.get('side')?.errors?.['message'] }}
+ </small>
+ }
  </div>
  <div>
  <label for="price" class="label text-sm">Price</label>
@@ -70,9 +90,7 @@ <h2 class="card-title">Place Order</h2>
  />
  @if (orderForm.get('unitPrice')?.touched && orderForm.get('unitPrice')?.invalid) {
  <small class="text-error">
- {{ orderForm.get('unitPrice')?.errors?.['required']
- ? 'Price is required'
- : 'Price must be a number' }}
+ {{ orderForm.get('unitPrice')?.errors?.['message'] }}
  </small>
  }
  </div>

frontend/src/app/shared/components/order-form/order-form.component.ts

@@ -16,7 +16,12 @@ import {
 import * as v from 'valibot';
 import { PortfolioService } from '../../../core/services/portfolio.service';
 import { PortfolioListResponse } from '../../models/portfolio.model';
-import { OrderRequest, OrderRequestSchema, OrderType } from '../../models/order.model';
+import {
+ OrderRequest,
+ OrderRequestSchema,
+ OrderType,
+} from '../../models/order.model';
+import { validateField } from '../../../core/validators/validate';
 
 @Component({
  selector: 'app-order-form',
@@ -40,41 +45,56 @@ export class OrderFormComponent implements OnInit {
  defaultside = input<'BUY' | 'SELL' | undefined | null>('BUY');
 
  orderForm: FormGroup = new FormGroup({
- portfolioId: new FormControl('', Validators.required),
- ticker: new FormControl('', Validators.required),
- orderType: new FormControl('MARKET', Validators.required),
- side: new FormControl('', Validators.required),
- unitPrice: new FormControl('', [
- Validators.required,
- Validators.pattern(/^[0-9]+(\.[0-9]{1,2})?$/),
- ]),
- quantity: new FormControl('', [
- Validators.required,
- Validators.pattern(/^[0-9]+$/),
- ]),
+ portfolioId: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.portfolioId)
+ ),
+ ticker: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.ticker)
+ ),
+ orderType: new FormControl(
+ 'MARKET',
+ validateField(OrderRequestSchema.entries.orderType)
+ ),
+ side: new FormControl('', validateField(OrderRequestSchema.entries.side)),
+ unitPrice: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.unitPrice)
+ ),
+ quantity: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.quantity)
+ ),
  });
 
  constructor(private portfolioService: PortfolioService) {
  effect(() => {
  this.orderForm = new FormGroup({
  portfolioId: new FormControl(
  this.defaultportfolio() || undefined,
- Validators.required
+ validateField(OrderRequestSchema.entries.portfolioId)
  ),
  ticker: new FormControl(
  this.defaultstock() || 'MSFT',
- Validators.required
+ validateField(OrderRequestSchema.entries.ticker)
+ ),
+ orderType: new FormControl(
+ 'MARKET',
+ validateField(OrderRequestSchema.entries.orderType)
+ ),
+ side: new FormControl(
+ this.defaultside() || 'BUY',
+ validateField(OrderRequestSchema.entries.side)
+ ),
+ unitPrice: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.unitPrice)
+ ),
+ quantity: new FormControl(
+ '',
+ validateField(OrderRequestSchema.entries.quantity)
  ),
- orderType: new FormControl('MARKET', Validators.required),
- side: new FormControl(this.defaultside() || 'BUY', Validators.required),
- unitPrice: new FormControl('', [
- Validators.required,
- Validators.pattern(/^[0-9]+(\.[0-9]{1,2})?$/),
- ]),
- quantity: new FormControl('', [
- Validators.required,
- Validators.pattern(/^[0-9]+$/),
- ]),
  });
  });
  }
@@ -106,6 +126,7 @@ export class OrderFormComponent implements OnInit {
  this.orderForm.reset();
  } else {
  console.error(result.issues);
+ console.log(this.orderForm.value);
  }
  }
 }

frontend/src/app/shared/models/order.model.ts

@@ -35,15 +35,18 @@ export const TradeSchema = v.object({
 export type Trade = v.InferOutput<typeof TradeSchema>;
 
 export const OrderRequestSchema = v.object({
- portfolioId: v.pipe(v.string(), v.transform(Number.parseInt)),
+ portfolioId: v.pipe(
+ v.union([v.number(), v.string()]),
+ v.transform(Number.parseInt)
+ ),
  ticker: v.enum(StockSymbol),
  quantity: v.pipe(
  v.union([v.number(), v.string()]),
  v.transform(Number.parseInt)
  ),
  orderType: v.enum(OrderType),
  side: v.enum(OrderSide),
- unitPrice: v.pipe(v.string(), v.transform(parseFloat)),
+ unitPrice: v.pipe(v.string(), v.nonEmpty(), v.transform(parseFloat)),
 });
 
 export type OrderRequest = v.InferOutput<typeof OrderRequestSchema>;