fix: favorite

.env.docker.compose

@@ -3,7 +3,7 @@
 CONSUL_ADDR=consul:8500
 CONSUL_ANONYMITY_NAME=paraparty.
 # Configure logger level, support: DEBUG, INFO, WARN (WARNING), ERROR, FATAL
-LOGGER_LEVEL=DEBUG
+LOGGER_LEVEL=INFO
 # Cofigure logger integrated with otel, support: enable, disable
 # If this setting is enable, you will see log in the OTEL Export with possible runtime waste
 LOGGER_OUT_TRACING=enable
@@ -44,14 +44,14 @@ REDIS_MASTER=
 # Config state, if use `disable` the sampler will be closed. use `enable` to enable
 TRACING_STATE=enable
 # Config tracing sampler, suggest 0.01
-TRACING_SAMPLER=1
+TRACING_SAMPLER=0.01
 TRACING_ENDPOINT=jaeger:4318
 # Optional: Config Pyroscope
 # Decide whether to enable the service, support : enable, disable.
 # If you enable this service, you must provide Pyroscope server environment
 # This profiling is ONLY designed for DEBUGGING
 # SO, PLEASE DO NOT ENABLE THIS SERVICE IN YOUR PRODUCTION ENVIRONMENT, OR IT MAY TAKE MUCH RUNTIME COST.
-PYROSCOPE_STATE=enable
+PYROSCOPE_STATE=disbale
 PYROSCOPE_ADDR=http://pyroscope:4040/
 # Configure RabbitMQ
 # Optional: `RABBITMQ_VHOST_PREFIX`: If you provide this config, the service will use value as the rabbit mq vhost prefix.

src/services/relation/handler.go

@@ -837,7 +837,7 @@ func (r RelationServiceImpl) GetFollowList(ctx context.Context, request *relatio
 		}
 	}
 
-	rFollowList, err := r.idList2UserList(ctx, followIdListInt, request.UserId, logger, span)
+	rFollowList, err := r.idList2UserList(ctx, followIdListInt, request.ActorId, logger, span)
 	if err != nil {
 		resp = &relation.FollowListResponse{
 			StatusCode: strings.UnableToGetFollowListErrorCode,
@@ -917,7 +917,7 @@ func (r RelationServiceImpl) GetFollowerList(ctx context.Context, request *relat
 		}
 	}
 
-	rFollowerList, err := r.idList2UserList(ctx, followerIdListInt, request.UserId, logger, span)
+	rFollowerList, err := r.idList2UserList(ctx, followerIdListInt, request.ActorId, logger, span)
 	if err != nil {
 		resp = &relation.FollowerListResponse{
 			StatusCode: strings.UnableToGetFollowerListErrorCode,

test/k6/favorite.js

@@ -0,0 +1,28 @@
+import { sleep, check } from 'k6';
+import http from 'k6/http';
+
+export const options = {
+    scenarios: {
+        Scenario_1: {
+            executor: 'ramping-vus',
+            gracefulStop: '30s',
+            stages: [
+                { target: 1000, duration: '15s' },
+                { target: 1500, duration: '30s' },
+                { target: 1000, duration: '15s' },
+            ],
+            gracefulRampDown: '30s',
+            exec: 'favorite',
+        },
+    },
+}
+
+export function favorite() {
+    let res = http.post('http://127.0.0.1:37000/douyin/favorite/action/?token=e75fae76-6a4e-4fa8-9b60-230e5d4f6b29&video_id=3048003698&action_type=1')
+
+    let jsonResponse = JSON.parse(res.body);
+    check(jsonResponse, {
+        'status_code is 0': (json) => json.status_code === 10008,
+    });
+    sleep(3)
+}

test/k6/login.js → test/k6/favorite_random.js

@@ -1,5 +1,5 @@
-import { sleep } from 'k6'
-import http from 'k6/http'
+import { sleep, check } from 'k6';
+import http from 'k6/http';
 
 export const options = {
     scenarios: {
@@ -12,13 +12,14 @@ export const options = {
                 { target: 1000, duration: '15s' },
             ],
             gracefulRampDown: '30s',
-            exec: 'login',
+            exec: 'favorite',
         },
     },
 }
 
-export function login() {
-    http.post('http://localhost:37000/douyin/user/login?username=epicmo&password=epicmo')
+export function favorite() {
+    let actionType = Math.random() < 0.5 ? 1 : 2;
+    let res = http.post(`http://127.0.0.1:37000/douyin/favorite/action/?token=e75fae76-6a4e-4fa8-9b60-230e5d4f6b29&video_id=3048003698&action_type=${actionType}`)
 
     sleep(3)
 }

test/k6/feed.js

@@ -1,13 +1,16 @@
-import { sleep } from 'k6'
-import http from 'k6/http'
+import { sleep, check } from 'k6';
+import http from 'k6/http';
 
 export const options = {
     scenarios: {
-        Scenario_1: {
+        feed: {
             executor: 'ramping-vus',
+            startVUs: 0,
             gracefulStop: '30s',
             stages: [
-                { target: 1000, duration: '60s' },
+                { target: 1000, duration: '20s' },
+                { target: 2000, duration: '20s' },
+                { target: 1000, duration: '20s' },
             ],
             gracefulRampDown: '30s',
             exec: 'feed',
@@ -16,7 +19,12 @@ export const options = {
 }
 
 export function feed() {
-    http.get('https://gugotik.endymx.qzwxsaedc.cn/douyin/feed?')
+    let res = http.get('http://127.0.0.1:37000/douyin/feed?');
 
-    sleep(3)
+    let jsonResponse = JSON.parse(res.body);
+    check(jsonResponse, {
+        'status_code is 0': (json) => json.status_code === 0,
+    });
+
+    sleep(3);
 }