📦 hook sevice onServerExited

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>io.github.lunasaw</groupId>
     <artifactId>zlm-spring-boot-starter</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.1</version>
 
     <name>zlm-spring-boot-starter</name>
     <description>ZLMediaKit restful api and hook starter</description>
@@ -17,11 +17,11 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <spring-boot.version>2.7.18</spring-boot.version>
-        <luna-common.version>2.5.2</luna-common.version>
+        <luna-common.version>2.5.3</luna-common.version>
         <httpclient5.version>5.2.1</httpclient5.version>
         <github.username>lunasaw</github.username>
         <app.profiles>${project.name}</app.profiles>
-        <zlm-spring-boot-starter.version>1.0.0</zlm-spring-boot-starter.version>
+        <zlm-spring-boot-starter.version>1.0.1</zlm-spring-boot-starter.version>
     </properties>
 
     <developers>

src/main/java/io/github/lunasaw/zlm/hook/controller/ZlmHookController.java

@@ -5,6 +5,7 @@
 import io.github.lunasaw.zlm.entity.ServerNodeConfig;
 import io.github.lunasaw.zlm.hook.param.*;
 import io.github.lunasaw.zlm.hook.service.ZlmHookService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.core.task.AsyncTaskExecutor;
@@ -16,6 +17,7 @@
  * @date 2023/12/3
  * @description: ZLM钩子控制器
  */
+@Slf4j
 @RestController
 @RequestMapping("/index/hook/")
 public class ZlmHookController {
@@ -98,10 +100,18 @@ public HookResult onStreamNotFound(@RequestBody OnStreamNotFoundHookParam param)
     @ResponseBody
     @PostMapping(value = "/on_server_started", produces = "application/json;charset=UTF-8")
     public HookResult onServerStarted(@RequestBody JSONObject param) {
+        log.info("onServerStarted::param = {}", param);
         executor.execute(() -> zlmHookService.onServerStarted(JSON.parseObject(param.toJSONString(), ServerNodeConfig.class)));
         return HookResult.SUCCESS();
     }
 
+    @ResponseBody
+    @PostMapping(value = "/on_server_exited", produces = "application/json;charset=UTF-8")
+    public HookResult onServerExited(@RequestBody HookParam param) {
+        executor.execute(() -> zlmHookService.onServerExited(param));
+        return HookResult.SUCCESS();
+    }
+
     /**
      * 发送rtp(startSendRtp)被动关闭时回调
      */

src/main/java/io/github/lunasaw/zlm/hook/service/AbstractZlmHookService.java

@@ -73,4 +73,9 @@ public HookResultForOnRtspAuth onRtspAuth(OnRtspAuthHookParam param) {
     public void onFlowReport(OnFlowReportHookParam param) {
 
     }
+
+    @Override
+    public void onServerExited(HookParam param) {
+
+    }
 }

src/main/java/io/github/lunasaw/zlm/hook/service/ZlmHookService.java

@@ -36,4 +36,6 @@ public interface ZlmHookService {
     HookResultForOnRtspAuth onRtspAuth(OnRtspAuthHookParam param);
 
     void onFlowReport(OnFlowReportHookParam param);
+
+    void onServerExited(HookParam param);
 }

zlm-spring-boot-starter-test/pom.xml

@@ -40,7 +40,7 @@
         <dependency>
             <groupId>io.github.lunasaw</groupId>
             <artifactId>zlm-spring-boot-starter</artifactId>
-            <version>1.0.0</version>
+            <version>1.0.1</version>
         </dependency>
 
         <dependency>

zlm-spring-boot-starter-test/src/main/java/io/github/lunasaw/zlm/service/LocalZlmHookService.java

@@ -83,4 +83,9 @@ public HookResultForOnRtspAuth onRtspAuth(OnRtspAuthHookParam param) {
     public void onFlowReport(OnFlowReportHookParam param) {
         log.info("onFlowReport::param = {}", JSON.toJSONString(param));
     }
+
+    @Override
+    public void onServerExited(HookParam param) {
+        log.info("onServerExited::param = {}", param);
+    }
 }