feat: k6 test

k6-test/ec-simple-test.js

+import {check, group, sleep} from 'k6';
+import {Rate, Trend} from 'k6/metrics';
+import http from 'k6/http';
+
+export const options = {
+    vus: 1, // 1 user looping for 10 secend
+    scenarios: {
+        contacts: {
+            executor: 'constant-vus',
+            vus: 10,
+            duration: '1s',
+        },
+    },
+    // scenarios: {
+    //     contacts: {
+    //         executor: 'per-vu-iterations',
+    //         vus: 2,
+    //         iterations: 1,
+    //         maxDuration: '30s',
+    //     },
+    // },
+    thresholds: {
+        http_req_duration: ['p(99)<1500'], // 99% of requests must complete below 1.5s
+    },
+};
+
+const URL = 'http://localhost:7168/api';
+const USERNAME = 'user1';
+const PASSWORD = '1234';
+const PRODUCTID = '70d2d54e-1030-4a17-94b4-348713bf9631';
+const TAGLIST = ["tag2"];
+
+export default function () {
+    let token;
+    const loginRes = http.post(http.url`${URL}/login`,
+        JSON.stringify({
+            "username": USERNAME,
+            "password": PASSWORD
+        }))
+
+    check(loginRes, {
+        'logged in successfully': (resp) => !!resp.body,
+    });
+
+    const authHeaders = {
+        headers: {
+            Authorization: `${loginRes.body}`,
+            'Content-Type': 'application/json'
+        },
+    };
+
+    const product = http.get(http.url`${URL}/product/${PRODUCTID}`, authHeaders).json();
+    check(product, {'retrieved product': (obj) => !!obj});
+
+    const productByTag = http.post(http.url`${URL}/product`, JSON.stringify(TAGLIST), authHeaders).json();
+    check(productByTag, {'retrieved productByTag': (obj) => !!obj});
+
+    const checkout = http.post(http.url`${URL}/checkout`, JSON.stringify({
+        "lineItems": [
+            {
+                "sku": PRODUCTID,
+                "quantity": 1
+            }
+        ],
+        "email": "[email protected]",
+        "creditCard": "test_card"
+    }), authHeaders)
+    check(checkout, {'checkout order': (obj) => !!obj});
+
+}
\ No newline at end of file

src/main/java/edu/prlab/ecsimple/config/DefaultDataBean.java

@@ -33,12 +33,12 @@ public class DefaultDataBean implements ApplicationRunner {
         productService.create(Product.builder()
                 .name("product1")
                 .tags(List.of("tag1", "tag2"))
-                .quantity(10)
+                .quantity(1000)
                 .build());
         productService.create(Product.builder()
                 .name("product2")
                 .tags(List.of("tag2", "tag3"))
-                .quantity(20)
+                .quantity(2000)
                 .build());
     }
 }

src/main/java/edu/prlab/ecsimple/config/SecurityConfig.java

@@ -55,7 +55,7 @@ public class SecurityConfig {
                 .sessionCreationPolicy(SessionCreationPolicy.STATELESS)
                 .and()
                 .authorizeRequests()
-                .antMatchers("/h2**").permitAll()
+                .antMatchers("/h2-console/**").permitAll()
                 .and()
                 .addFilterBefore(jwtAuthorizationFilter(), UsernamePasswordAuthenticationFilter.class)
                 .addFilter(new JwtAuthorizationFilter(authenticationManager, jwtTokenProvider))

src/main/java/edu/prlab/ecsimple/service/OrderServiceImpl.java

@@ -9,6 +9,7 @@ import edu.prlab.ecsimple.repo.ItemRepo;
 import edu.prlab.ecsimple.repo.OrderRepo;
 import edu.prlab.ecsimple.repo.ProductRepo;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -17,6 +18,7 @@ import java.util.Collection;
 import java.util.Optional;
 import java.util.stream.Collectors;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 @Transactional
@@ -43,6 +45,7 @@ public class OrderServiceImpl implements OrderService {
                                 throw new BusinessException("There is not enough stock with product: " + product.getSku());
                             }
                             product.setQuantity(leftQty);
+                            log.info("save product sku: " + product.getSku() + "qty: " + product.getQuantity());
                             return itemRepo.save(lineItem);
                         })
                         .orElseThrow(() -> new EntityNotFoundException("Not found Product: " + it.getSku())));
@@ -73,6 +76,7 @@ public class OrderServiceImpl implements OrderService {
                                     .orElseThrow(() -> new BusinessException("Save lineItem error")))
                             .peek(it -> addItemToOrder(order.getIid(), it.getSku()))
                             .collect(Collectors.toList());
+                    lineItems.forEach(it -> log.info("sku : " + it.getSku() + " : qty: " + it.getQuantity()));
                     order.setLineItems(lineItems);
                     return order;
                 });

src/main/java/edu/prlab/ecsimple/service/ProductService.java

@@ -8,7 +8,6 @@ import java.util.Optional;
 public interface ProductService {
     Optional<Product> create(Product product);
     Optional<Product>  getProduct(String sku);
-
     List<Product> getProductsByTags(List<String> tags);
     List<Product> getProducts();
 }