Skip to content
This repository was archived by the owner on Aug 18, 2020. It is now read-only.

Commit d8e8a2f

Browse files
committed
Merge branch 'MelanX-master' into develop
2 parents cd2b82f + 1e7a141 commit d8e8a2f

File tree

3 files changed

+7
-6
lines changed

3 files changed

+7
-6
lines changed

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/tipeeestream/TipeeestreamConnector.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@ class TipeeestreamConnector(override val sourceIdentifier: String) extends Conne
3535
val thread = Thread.currentThread
3636
socket = Some(IO.socket(SOCKET_URL).connect())
3737
socket.get.on(Socket.EVENT_CONNECT, (_: Any) => {
38-
logger info "Connected to TipeeStream Socket.io"
38+
logger info "Connected to TipeeeStream Socket.io"
3939
socket.get.emit("join-room", AUTH_OBJECT)
40-
logger info "emitted credentials to TipeeSetream Socket.io api"
40+
logger info "emitted credentials to TipeeeStream Socket.io api"
4141
socket.get.on("new-event", (objects: Array[AnyRef]) => {
4242
tipeeeStreamListener.onSocketEvent(objects)
4343
})
Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,15 +7,15 @@ import java.util.Currency
77
import org.codeoverflow.chatoverflow.WithLogger
88
import org.codeoverflow.chatoverflow.api.io.dto.User
99
import org.codeoverflow.chatoverflow.api.io.dto.stat.stream.tipeeestream.{TipeeestreamDonation, TipeeestreamFollow, TipeeestreamProvider, TipeeestreamSubscription}
10-
import org.codeoverflow.chatoverflow.api.io.event.stream.tipeeestream.{TipeeestramFollowEvent, TipeeestreamDonationEvent, TipeeestreamEvent, TipeeestreamSubscriptionEvent}
10+
import org.codeoverflow.chatoverflow.api.io.event.stream.tipeeestream.{TipeeestreamFollowEvent, TipeeestreamDonationEvent, TipeeestreamEvent, TipeeestreamSubscriptionEvent}
1111
import org.codeoverflow.chatoverflow.api.io.input.event.TipeeestreamEventInput
1212
import org.codeoverflow.chatoverflow.registry.Impl
1313
import org.codeoverflow.chatoverflow.requirement.impl.EventInputImpl
1414
import org.codeoverflow.chatoverflow.requirement.service.tipeeestream.TipeeestreamConnector
1515
import org.json.{JSONException, JSONObject}
1616

1717
@Impl(impl = classOf[TipeeestreamEventInput], connector = classOf[TipeeestreamConnector])
18-
class TipeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, TipeeestreamConnector] with TipeeestreamEventInput with WithLogger {
18+
class TipeeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, TipeeestreamConnector] with TipeeestreamEventInput with WithLogger {
1919
private val DATE_FORMATTER = new DateTimeFormatterBuilder()
2020
.parseCaseInsensitive().append(DateTimeFormatter.ISO_LOCAL_DATE_TIME).appendOffset("+HHMM", "Z").toFormatter
2121

@@ -72,7 +72,7 @@ class TipeestreamEventInputImpl extends EventInputImpl[TipeeestreamEvent, Tipeee
7272
val time = OffsetDateTime.parse(event.getString("created_at"), DATE_FORMATTER)
7373
val provider = TipeeestreamProvider.parse(event.getString("origin"))
7474
val follow = new TipeeestreamFollow(user, time, provider)
75-
call(new TipeeestramFollowEvent(follow))
75+
call(new TipeeestreamFollowEvent(follow))
7676
} catch {
7777
case e: JSONException =>
7878
logger warn "Error while parsing follow json:"

src/main/scala/org/codeoverflow/chatoverflow/requirement/service/twitch/chat/impl/TwitchChatInputImpl.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,8 @@ class TwitchChatInputImpl extends EventInputImpl[TwitchEvent, chat.TwitchChatCon
4545
val moderator = event.getV3Tags.get("mod") == "1"
4646
val broadcaster = event.getV3Tags.get("badges").contains("broadcaster/1")
4747
val turbo = event.getV3Tags.get("badges").contains("turbo/1")
48-
val author = new TwitchChatMessageAuthor(event.getUser.getNick, color, broadcaster, moderator, subscriber, turbo)
48+
val vip = event.getV3Tags.get("badges").contains("vip/1")
49+
val author = new TwitchChatMessageAuthor(event.getUser.getNick, color, broadcaster, moderator, subscriber, turbo, vip)
4950
val time = OffsetDateTime.ofInstant(Instant.ofEpochMilli(event.getTimestamp), ZoneOffset.UTC)
5051
val channel = new TextChannel(event.getChannelSource)
5152
val emoticons = new java.util.ArrayList[ChatEmoticon]()

0 commit comments

Comments
 (0)