Skip to content

Commit d5824f0

Browse files
RakambdaRakambda
committed
Rename package
1 parent 5277790 commit d5824f0

153 files changed

Lines changed: 432 additions & 432 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/ITwitchPubSubMessageListener.java‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub;
2+
3+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.IPubSubMessage;
4+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.topic.Topic;
5+
import org.jetbrains.annotations.NotNull;
6+
7+
public interface ITwitchPubSubMessageListener{
8+
void onTwitchMessage(@NotNull Topic topic, @NotNull IPubSubMessage message);
9+
}

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/ITwitchPubSubWebSocketListener.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/ITwitchPubSubWebSocketListener.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub;
22

3-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.ITwitchWebSocketResponse;
3+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.ITwitchWebSocketResponse;
44
import org.jetbrains.annotations.NotNull;
55
import org.jetbrains.annotations.Nullable;
66

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/TwitchPubSubWebSocketClient.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/TwitchPubSubWebSocketClient.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,18 +1,18 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub;
22

33
import com.fasterxml.jackson.core.JsonProcessingException;
44
import com.fasterxml.jackson.core.type.TypeReference;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.ITwitchWebSocketRequest;
6-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.ListenTopicRequest;
7-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.PingRequest;
8-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.UnlistenTopicRequest;
9-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.topic.Topic;
10-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.topic.Topics;
11-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.ITwitchWebSocketResponse;
12-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.MessageResponse;
13-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.PongResponse;
14-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.ReconnectResponse;
15-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.ResponseResponse;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.ITwitchWebSocketRequest;
6+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.ListenTopicRequest;
7+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.PingRequest;
8+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.UnlistenTopicRequest;
9+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.topic.Topic;
10+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.topic.Topics;
11+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.ITwitchWebSocketResponse;
12+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.MessageResponse;
13+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.PongResponse;
14+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.ReconnectResponse;
15+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.ResponseResponse;
1616
import fr.rakambda.channelpointsminer.miner.factory.TimeFactory;
1717
import fr.rakambda.channelpointsminer.miner.log.LogContext;
1818
import fr.rakambda.channelpointsminer.miner.util.json.JacksonUtils;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/TwitchPubSubWebSocketPool.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/TwitchPubSubWebSocketPool.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub;
22

3-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.topic.Topic;
4-
import fr.rakambda.channelpointsminer.miner.api.ws.data.request.topic.Topics;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.ITwitchWebSocketResponse;
6-
import fr.rakambda.channelpointsminer.miner.api.ws.data.response.MessageResponse;
3+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.topic.Topic;
4+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.request.topic.Topics;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.ITwitchWebSocketResponse;
6+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.response.MessageResponse;
77
import fr.rakambda.channelpointsminer.miner.factory.TimeFactory;
88
import fr.rakambda.channelpointsminer.miner.factory.TwitchWebSocketClientFactory;
99
import lombok.extern.log4j.Log4j2;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/ClaimAvailable.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/ClaimAvailable.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.claimavailable.ClaimAvailableData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.claimavailable.ClaimAvailableData;
66
import lombok.AllArgsConstructor;
77
import lombok.Builder;
88
import lombok.EqualsAndHashCode;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/CommunityMomentStart.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/CommunityMomentStart.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.communitymoment.CommunityMomentStartData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.communitymoment.CommunityMomentStartData;
66
import lombok.AllArgsConstructor;
77
import lombok.Builder;
88
import lombok.EqualsAndHashCode;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/CreateNotification.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/CreateNotification.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.createnotification.CreateNotificationData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.createnotification.CreateNotificationData;
66
import lombok.AllArgsConstructor;
77
import lombok.Builder;
88
import lombok.EqualsAndHashCode;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/DropClaim.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/DropClaim.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.dropclaim.DropClaimData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.dropclaim.DropClaimData;
66
import lombok.AllArgsConstructor;
77
import lombok.Builder;
88
import lombok.EqualsAndHashCode;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/DropProgress.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/DropProgress.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.dropprogress.DropProgressData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.dropprogress.DropProgressData;
66
import lombok.AllArgsConstructor;
77
import lombok.Builder;
88
import lombok.EqualsAndHashCode;

miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/ws/data/message/EventCreated.java renamed to miner/src/main/java/fr/rakambda/channelpointsminer/miner/api/pubsub/data/message/EventCreated.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
package fr.rakambda.channelpointsminer.miner.api.ws.data.message;
1+
package fr.rakambda.channelpointsminer.miner.api.pubsub.data.message;
22

33
import com.fasterxml.jackson.annotation.JsonProperty;
44
import com.fasterxml.jackson.annotation.JsonTypeName;
5-
import fr.rakambda.channelpointsminer.miner.api.ws.data.message.eventcreated.EventCreatedData;
5+
import fr.rakambda.channelpointsminer.miner.api.pubsub.data.message.eventcreated.EventCreatedData;
66
import lombok.EqualsAndHashCode;
77
import lombok.Getter;
88
import lombok.ToString;

0 commit comments

Comments
 (0)