Merge pull request #20 from hejieehe/perf_11694

perf: 优化代码源webhook解析流程 #11694

Author: mingshewhe

buildSrc/src/main/kotlin/Versions.kt

@@ -1,6 +1,6 @@
 object Release {
     const val Group = "com.tencent.bk.devops.scm"
-    const val Version = "1.0.2"
+    const val Version = "1.0.3"
 }
 
 object Versions {

devops-scm-api/src/main/java/com/tencent/devops/scm/api/exception/NotFoundScmApiException.java

@@ -1,13 +1,16 @@
 package com.tencent.devops.scm.api.exception;
 
+import lombok.Getter;
+
 /**
  * 资源不存在（HTTP 404）
  * 用于处理404异常
  */
+@Getter
 public class NotFoundScmApiException extends ScmApiException {
-
     public NotFoundScmApiException(String message) {
         super(message);
+        this.statusCode = 404;
     }
 
     public NotFoundScmApiException(String message, Throwable cause) {

devops-scm-api/src/main/java/com/tencent/devops/scm/api/exception/ScmApiException.java

@@ -1,9 +1,18 @@
 package com.tencent.devops.scm.api.exception;
 
+import lombok.Getter;
+
 /**
  * scm api异常基类
  */
+@Getter
 public class ScmApiException extends RuntimeException {
+    Integer statusCode;
+
+    public ScmApiException(String message, int code) {
+        super(message);
+        this.statusCode = code;
+    }
 
     public ScmApiException(String message) {
         super(message);

devops-scm-api/src/main/java/com/tencent/devops/scm/api/exception/UnAuthorizedScmApiException.java

@@ -9,9 +9,9 @@
  * 4. 权限范围不足
  */
 public class UnAuthorizedScmApiException extends ScmApiException {
-
     public UnAuthorizedScmApiException(String message) {
         super(message);
+        this.statusCode = 401;
     }
 
     public UnAuthorizedScmApiException(String message, Throwable cause) {

devops-scm-provider/devops-scm-provider-git/devops-scm-provider-tgit/src/main/java/com/tencent/devops/scm/provider/git/tgit/TGitApiTemplate.java

@@ -2,6 +2,7 @@
 
 import com.tencent.devops.scm.api.exception.NotFoundScmApiException;
 import com.tencent.devops.scm.api.exception.ScmApiException;
+import com.tencent.devops.scm.api.exception.UnAuthorizedScmApiException;
 import com.tencent.devops.scm.api.pojo.auth.IScmAuth;
 import com.tencent.devops.scm.api.pojo.repository.ScmProviderRepository;
 import com.tencent.devops.scm.api.pojo.repository.git.GitScmProviderRepository;
@@ -25,11 +26,7 @@ public static <R> R execute(ScmProviderRepository repository, TGitApiFactory api
             TGitApi tGitApi = apiFactory.fromAuthProvider(TGitAuthProviderFactory.create(repo.getAuth()));
             return apiFunction.apply(repo, tGitApi);
         } catch (Throwable t) {
-            if (t instanceof TGitApiException) {
-                throw translateException((TGitApiException) t);
-            } else {
-                throw new ScmApiException(t);
-            }
+            throw handleThrowable(t);
         }
     }
 
@@ -38,11 +35,7 @@ public static <R> R execute(IScmAuth auth, TGitApiFactory apiFactory, Function<T
             TGitApi tGitApi = apiFactory.fromAuthProvider(TGitAuthProviderFactory.create(auth));
             return apiFunction.apply(tGitApi);
         } catch (Throwable t) {
-            if (t instanceof TGitApiException) {
-                throw translateException((TGitApiException) t);
-            } else {
-                throw new ScmApiException(t);
-            }
+            throw handleThrowable(t);
         }
     }
 
@@ -53,21 +46,26 @@ public static void execute(ScmProviderRepository repository, TGitApiFactory apiF
             TGitApi tGitApi = apiFactory.fromAuthProvider(TGitAuthProviderFactory.create(repo.getAuth()));
             apiConsumer.accept(repo, tGitApi);
         } catch (Throwable t) {
-            if (t instanceof TGitApiException) {
-                throw translateException((TGitApiException) t);
-            } else {
-                throw new ScmApiException(t);
-            }
+            throw handleThrowable(t);
         }
     }
 
     private static ScmApiException translateException(TGitApiException e) {
         switch (e.getStatusCode()) {
             case 404:
                 return new NotFoundScmApiException(e.getMessage());
+            case 401, 403:
+                return new UnAuthorizedScmApiException(e.getMessage());
             default:
-                return new ScmApiException(e);
+                return new ScmApiException(e.getMessage(), e.getStatusCode());
+        }
+    }
 
+    private static ScmApiException handleThrowable(Throwable t) {
+        if (t instanceof TGitApiException) {
+            return translateException((TGitApiException) t);
+        } else {
+            return new ScmApiException(t);
         }
     }
 }