Changes between Initial Version and Version 1 of appdevelopment

Timestamp:

03/02/26 00:10:56 (2 weeks ago)

Author:

231020

Comment:

--

appdevelopment

@@ +1 @@
+= Напреден развој на апликацијата =
+
+== Трансакции ==
+
+=== Купување на акција (buyStock) ===
+'''Опис:''' Методот `buyStock` во `PortfolioService` извршува повеќе зависни операции:
+ * Намалување на балансот на портфолиото за вкупната вредност на купените акции
+ * Ажурирање на постоечко холдинг (или креирање на нов) со новата количина и пресметана weighted average цена
+ * Зачувување на трансакцискиот запис
+
+Доколку кој било чекор не успее (на пр. акцијата не постои, портфолиото не е пронајдено), целата операција се откажува и балансот останува непроменет.
+{{{
+@Transactional
+    public void buyStock(Long portfolioId, String stockSymbol, int quantity, BigDecimal pricePerUnit) {
+        Portfolio portfolio = portfolioRepository.findById(portfolioId)
+                .orElseThrow(() -> new RuntimeException("Portfolio not found"));
+
+
+        //multiply for how much stocks are bught
+        BigDecimal totalCost = pricePerUnit.multiply(BigDecimal.valueOf(quantity));
+
+//        if (portfolio.getBalance().compareTo(totalCost) < 0) {
+//            throw new RuntimeException("not enough balance to buy stock");
+//        }
+        //TODO - > BRING BACK , JUST FOR TESTING !!
+
+        portfolio.setBalance(portfolio.getBalance().subtract(totalCost));
+
+        Stock stock1 = stockRepository.findBySymbol(stockSymbol)
+                .orElseThrow(() -> new RuntimeException("Stock not found"));
+
+        PortfolioHolding holding = holdingRepository
+                .findByPortfolioIdAndStock_Symbol(portfolioId, stockSymbol)
+                .orElse(PortfolioHolding.builder()
+                        .portfolio(portfolio)
+                        .stock(stock1)
+                        .quantity(0)
+                        .avgPrice(BigDecimal.ZERO)
+                        .build());
+
+        // avg price bought
+        // alkaloid 2 x 22.000 + alkaloid 3x 28.000 average od ova
+        BigDecimal currentTotalValue = holding.getAvgPrice().multiply(BigDecimal.valueOf(holding.getQuantity()));
+        BigDecimal newTotalValue = currentTotalValue.add(totalCost);
+        int newQuantity = holding.getQuantity() + quantity;
+        BigDecimal newAvgPrice = newTotalValue.divide(BigDecimal.valueOf(newQuantity), BigDecimal.ROUND_HALF_UP);
+
+        holding.setQuantity(newQuantity);
+        holding.setAvgPrice(newAvgPrice);
+
+        holdingRepository.save(holding);
+        portfolioRepository.save(portfolio);
+
+
+        //sava a transaction
+        Transaction transaction = new Transaction();
+        transaction.setUser(portfolio.getUser());
+
+        Stock stock = stockRepository.findBySymbol(stockSymbol)
+                .orElseThrow(() -> new RuntimeException("stock not found: " + stockSymbol));
+        transaction.setStock(stock);
+/*        transaction.setStock(stockRepository.findBySymbol(stockSymbol)
+                .orElseThrow(() -> new RuntimeException("Stock not found")));*/
+        transaction.setType("BUY");
+        transaction.setQuantity(quantity);
+        transaction.setPrice(pricePerUnit.doubleValue());
+        transaction.setTimestamp(LocalDateTime.now());
+
+        transactionRepository.save(transaction);
+    }
+}}}
+
+
+=== Продавање на акција (sellStock) ===
+
+'''Опис:''' Методот `sellStock`:
+ * Проверка дека корисникот поседува доволно акции
+ * Намалување на количината во холдингот (или бришење ако достигне 0)
+ * Зголемување на балансот за приходот од продажбата
+ * Зачувување на трансакцискиот запис
+
+{{{
+@Transactional
+    public void sellStock(Long portfolioId, String stockSymbol, int quantity, BigDecimal pricePerUnit) {
+        Portfolio portfolio = portfolioRepository.findById(portfolioId)
+                .orElseThrow(() -> new RuntimeException("portfolio not found"));
+
+        PortfolioHolding holding = holdingRepository
+                .findByPortfolioIdAndStock_Symbol(portfolioId, stockSymbol)
+                .orElseThrow(() -> new RuntimeException("stock not found in portfolio"));
+
+
+        // checks
+        if (holding.getQuantity() < quantity) {
+            throw new RuntimeException("not enough shares to sell");
+        }
+
+        if (pricePerUnit == null) {
+            // fallback: get latest price from stock history or live API
+            Stock stock = stockRepository.findBySymbol(stockSymbol)
+                    .orElseThrow(() -> new RuntimeException("stock not found: " + stockSymbol));
+            pricePerUnit = BigDecimal.valueOf(stock.getCurrentPrice());
+        }
+
+        // gain from the sale made
+        BigDecimal totalGain = pricePerUnit.multiply(BigDecimal.valueOf(quantity));
+
+
+        holding.setQuantity(holding.getQuantity() - quantity);
+
+        // if holding is zero ==== remove it from database
+        if (holding.getQuantity() == 0) {
+            holdingRepository.delete(holding);
+        } else {
+            holdingRepository.save(holding);
+        }
+
+        // update
+        portfolio.setBalance(portfolio.getBalance().add(totalGain));
+        portfolioRepository.save(portfolio);
+
+
+        Stock stock = stockRepository.findBySymbol(stockSymbol)
+                .orElseThrow(() -> new RuntimeException("stock not found: " + stockSymbol));
+
+        Transaction transaction = new Transaction();
+        transaction.setUser(portfolio.getUser());
+        transaction.setStock(stock);
+        transaction.setType("SELL");
+        transaction.setQuantity(quantity);
+        transaction.setPrice(pricePerUnit.doubleValue());
+        transaction.setTimestamp(LocalDateTime.now());
+
+        transactionRepository.save(transaction);
+
+        System.out.println("saved sell");
+    }
+}}}
+
+=== Поврзување на Google OAuth акаунт (confirmLink) ===
+
+'''Опис:''' Методот `confirmLink` во `AuthLinkController` поврзува Google OAuth акаунт со постоечки интерен акаунт. Операцијата вклучува:
+ * Верификација и читање на pending OAuth токенот
+ * Автентикација на интерните credentials на корисникот
+ * Додавање на `GOOGLE` провајдер во множеството на auth провајдери на корисникот
+ * Зачувување на корисникот
+ * Бришење на pending токенот
+
+{{{
+    @PostMapping("/confirm")
+    @Transactional 
+    public ResponseEntity<?> confirmLink(@RequestBody Map<String, String> body) {
+        String pendingToken = body.get("pendingToken");
+        String usernameOrEmail = body.get("username");
+        String password = body.get("password");
+
+        if (pendingToken == null || usernameOrEmail == null || password == null) {
+            return ResponseEntity.badRequest().body("missing fields");
+        }
+
+        PendingLink pending = pendingLinkRepository.findByToken(pendingToken).orElse(null);
+        if (pending == null || pending.getExpiresAt().isBefore(Instant.now())) {
+            return ResponseEntity.status(410).body("pending token invalid or expired");
+        }
+
+        // auth internal credentials
+        try {
+            Authentication auth = authenticationManager.authenticate(
+                    new UsernamePasswordAuthenticationToken(usernameOrEmail, password)
+            );
+        } catch (Exception ex) {
+            return ResponseEntity.status(401).body("Invalid internal credentials");
+        }
+
+        // load user
+        User user = userRepository.findByUsername(usernameOrEmail)
+                .orElseGet(() -> userRepository.findByEmail(usernameOrEmail).orElse(null));
+        if (user == null) {
+            return ResponseEntity.status(404).body("User not found");
+        }
+
+        // verufy
+//        if (!user.getEmail().equalsIgnoreCase(pending.getEmail())) {
+//            return ResponseEntity.status(403).body("Pending link does not match authenticated user");
+//        }
+        if (!pending.getUser().getId().equals(user.getId())) {
+            return ResponseEntity.status(403).body("Pending link does not belong to user");
+        }
+
+
+
+        Set<AuthProvider> providers = user.getAuthProviders();
+        providers.add(AuthProvider.GOOGLE);
+        user.setAuthProviders(providers);
+        userRepository.save(user);
+
+        // delete pending
+        pendingLinkRepository.deleteByToken(pendingToken);
+
+        // generate token
+        String jwt = userService.generateToken(user);
+
+        Map<String, Object> resp = new HashMap<>();
+        resp.put("token", jwt);
+        resp.put("message", "Google account linked and logged in");
+
+        return ResponseEntity.ok(resp);
+    }
+}}}
+
+
+----
+
+== Database Connection Pooling ==
+
+Spring Boot автоматски го вклучува **HikariCP** connection pool-от.
+
+=== Конфигурација ===
+
+Тековната конфигурација во `application.yml` го користи HikariCP со стандардните вредности:
+
+{{{
+# application.yml
+spring:
+  datasource:
+    url: jdbc:postgresql://localhost:9999/db_202526z_va_prj_tradingmk
+    username: db_202526z_va_prj_tradingmk_owner
+    password: ••••••••
+  jpa:
+    hibernate:
+      ddl-auto: create-drop
+    show-sql: true
+    properties:
+      hibernate.dialect: org.hibernate.dialect.PostgreSQLDialect
+}}}
+
+
+=== Пример на користење на конекција од pool-от ===
+
+Секој повик кон repository методите автоматски зема конекција од HikariCP pool-от и ја враќа по завршување. Следниот пример го прикажува текот при `buyStock`:
+
+{{{
+// При повик на buyStock(), HikariCP управува со конекциите:
+
+@Transactional                          // <-- Spring отвора трансакција, HikariCP дава конекција
+public void buyStock(...) {
+    portfolioRepository.findById(...)   // конекција од pool-от се користи
+    stockRepository.findBySymbol(...)   // истата конекција 
+    holdingRepository.save(...)         // истата конекција
+    portfolioRepository.save(...)       // истата конекција
+    transactionRepository.save(...)     // истата конекција
+}                                       // <-- COMMIT, конекцијата се враќа во pool-от
+}}}
+
+Без connection pooling, секој од овие повици би отворал и затворал посебна TCP конекција кон PostgreSQL - операција која трае ~50-100ms. Со HikariCP, конекцијата е веќе отворена и чека во pool-от.