删除不必要的字段和操作

PBH-BTN · Oct 9, 2024 · b1afb15 · b1afb15
1 parent 4d0ebe1
commit b1afb15
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 12 deletions.
diff --git a/src/main/java/com/ghostchu/btn/sparkle/module/tracker/TrackerController.java b/src/main/java/com/ghostchu/btn/sparkle/module/tracker/TrackerController.java
@@ -1,7 +1,6 @@
 package com.ghostchu.btn.sparkle.module.tracker;
 
 import com.ghostchu.btn.sparkle.controller.SparkleController;
-import com.ghostchu.btn.sparkle.module.audit.AuditService;
 import com.ghostchu.btn.sparkle.module.tracker.internal.PeerEvent;
 import com.ghostchu.btn.sparkle.util.BencodeUtil;
 import com.ghostchu.btn.sparkle.util.IPUtil;
@@ -42,8 +41,6 @@ public class TrackerController extends SparkleController {
     @Value("${service.tracker.announce-random}")
     private long announceRandomOffset;
     @Autowired
-    private AuditService auditService;
-    @Autowired
     private MeterRegistry meterRegistry;
     @Autowired
     private StringRedisTemplate redisStringTemplate;

diff --git a/src/main/java/com/ghostchu/btn/sparkle/module/tracker/TrackerService.java b/src/main/java/com/ghostchu/btn/sparkle/module/tracker/TrackerService.java
@@ -116,8 +116,7 @@ public void executeAnnounce(PeerAnnounce announce) {
                         ByteUtil.filterUTF8(announce.userAgent()),
                         OffsetDateTime.now(),
                         jacksonObjectMapper.writeValueAsString(geoIPManager.geoData(announce.peerIp())),
-                        jacksonObjectMapper.writeValueAsString(geoIPManager.geoData(announce.reqIp())),
-                        0
+                        jacksonObjectMapper.writeValueAsString(geoIPManager.geoData(announce.reqIp()))
                 );
             }
         } catch (InterruptedException e) {

diff --git a/src/main/java/com/ghostchu/btn/sparkle/module/tracker/internal/TrackedPeer.java b/src/main/java/com/ghostchu/btn/sparkle/module/tracker/internal/TrackedPeer.java
@@ -64,7 +64,4 @@ public class TrackedPeer {
     @Type(JsonType.class)
     @Basic(fetch = FetchType.LAZY)
     private IPGeoData requestGeoIP;
-    @Column(nullable = false)
-    @Version
-    private Integer version;
 }
diff --git a/src/main/java/com/ghostchu/btn/sparkle/module/tracker/internal/TrackedPeerRepository.java b/src/main/java/com/ghostchu/btn/sparkle/module/tracker/internal/TrackedPeerRepository.java
@@ -40,8 +40,7 @@ ON CONFLICT (peer_id, torrent_info_hash) DO UPDATE SET \
             user_agent = EXCLUDED.user_agent, \
             last_time_seen = EXCLUDED.last_time_seen, \
             peer_geoip = CAST(EXCLUDED.peer_geoip AS jsonb), \
-            request_geoip = CAST(EXCLUDED.request_geoip AS jsonb), \
-            version = EXCLUDED.version""",
+            request_geoip = CAST(EXCLUDED.request_geoip AS jsonb)""",
             nativeQuery = true)
     void upsertTrackedPeer(@Param("reqIp") InetAddress reqIp,
                            @Param("peerId") String peerId,
@@ -56,8 +55,7 @@ void upsertTrackedPeer(@Param("reqIp") InetAddress reqIp,
                            @Param("userAgent") String userAgent,
                            @Param("lastTimeSeen") OffsetDateTime lastTimeSeen,
                            @Param("peerGeoIP") String peerGeoIP,
-                           @Param("requestGeoIP") String requestGeoIP,
-                           @Param("version") Integer version);
+                           @Param("requestGeoIP") String requestGeoIP);
 
     void deleteByPk_PeerIdAndPk_TorrentInfoHash(String peerId, String infoHash);