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

Author: hejieehe

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/ScmApiException.java

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

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

@@ -25,11 +25,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 +34,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,11 +45,7 @@ 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);
         }
     }
 
@@ -66,8 +54,16 @@ private static ScmApiException translateException(TGitApiException e) {
             case 404:
                 return new NotFoundScmApiException(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);
+        }
+    }
 }