chore(test): use parallel

Author: duanhongyi

charts/controller/templates/_helpers.tpl

@@ -126,7 +126,7 @@ env:
       key: victoriametrics-url
 {{- else if .Values.victoriametrics.enabled }}
 - name: "DRYCC_VICTORIAMETRICS_URL"
-  value: "http://drycc-victoriametrics-vmselect:8481"
+  value: "http://drycc-victoriametrics-vmselect:8481/select/multitenant/prometheus"
 {{- end }}
 {{- if .Values.passport.enabled }}
 - name: "DRYCC_PASSPORT_URL"

charts/controller/templates/metric/controller-metric-service.yaml

@@ -14,7 +14,7 @@ spec:
   clusterIP: None
   ports:
     - name: http
-      port: 80
+      port: 8000
       targetPort: 8000
   selector:
     app: drycc-controller

rootfs/api/views.py

@@ -1325,7 +1325,7 @@ async def authenticate(self, request, username):
         if self.permission.has_permission(request, None):
             if username != "drycc":
                 return None, {'error': 'Access denied', "status_code": 403}
-            return -1, None
+            return 0, None
         auth = await database_sync_to_async(self.authentication.authenticate)(request)
         if not auth or len(auth) != 2:
             return None, {'error': 'Unauthorized', "status_code": 401}
@@ -1448,15 +1448,13 @@ async def proxy(self, request, username, path):
         user_id, message = await self.authenticate(request, username)
         if user_id is None and message is not None:
             return JsonResponse(message, status=message["status_code"])
-        if username == "drycc":
-            path = f"/select/0/prometheus/{path}"
-        else:
-            path = f"/select/{user_id}/prometheus/{path}"
+        data = dict(request.GET) if request.method == "GET" else dict(request.POST)
+        data['extra_filters[]'] = '{vm_account_id="%s"}' % user_id
         try:
             async with aiohttp.ClientSession() as session:
                 async with session.post(
-                    urljoin(settings.DRYCC_VICTORIAMETRICS_URL, path),
-                    data=dict(request.GET) if request.method == "GET" else dict(request.POST),
+                    f"{settings.DRYCC_VICTORIAMETRICS_URL.rstrip("/")}/{path}",
+                    data=data,
                     headers={"Content-Type": "application/x-www-form-urlencoded"},
                     timeout=self.timeout
                 ) as response:

rootfs/bin/test-unit

@@ -15,4 +15,4 @@ function start_valkey() {
 gosu postgres pg_ctl -D "$PGDATA" start && ln -s /tmp/.s.PGSQL.5432 /var/run/postgresql/.s.PGSQL.5432
 start_valkey
 python3 manage.py check
-coverage run --source=api,scheduler manage.py test --settings=api.settings.testing --noinput api scheduler.tests --exclude-tag=auth
+coverage run --source=api,scheduler manage.py test --settings=api.settings.testing --noinput api scheduler.tests --exclude-tag=auth --parallel="${TEST_PARALLEL:-8}"