Skip to content

Commit e9dc790

Browse files
authored
Read Receipts (#101)
* add api client with grpc kotlin * add read receipt content type to kotlin
1 parent cc04c43 commit e9dc790

File tree

2 files changed

+73
-0
lines changed

2 files changed

+73
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
package org.xmtp.android.library
2+
3+
import androidx.test.ext.junit.runners.AndroidJUnit4
4+
import org.junit.Assert.assertEquals
5+
import org.junit.Test
6+
import org.junit.runner.RunWith
7+
import org.xmtp.android.library.codecs.ContentTypeReadReceipt
8+
import org.xmtp.android.library.codecs.ReadReceipt
9+
import org.xmtp.android.library.codecs.ReadReceiptCodec
10+
import org.xmtp.android.library.messages.walletAddress
11+
12+
@RunWith(AndroidJUnit4::class)
13+
class ReadReceiptTest {
14+
15+
@Test
16+
fun testCanUseReadReceiptCodec() {
17+
Client.register(codec = ReadReceiptCodec())
18+
19+
val fixtures = fixtures()
20+
val aliceClient = fixtures.aliceClient
21+
val aliceConversation =
22+
aliceClient.conversations.newConversation(fixtures.bob.walletAddress)
23+
24+
aliceConversation.send(text = "hey alice 2 bob")
25+
26+
val readReceipt = ReadReceipt(timestamp = "2019-09-26T07:58:30.996+0200")
27+
28+
aliceConversation.send(
29+
content = readReceipt,
30+
options = SendOptions(contentType = ContentTypeReadReceipt),
31+
)
32+
val messages = aliceConversation.messages()
33+
assertEquals(messages.size, 2)
34+
if (messages.size == 2) {
35+
val content: ReadReceipt? = messages.first().content()
36+
assertEquals("2019-09-26T07:58:30.996+0200", content?.timestamp)
37+
}
38+
}
39+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
package org.xmtp.android.library.codecs
2+
3+
import com.google.protobuf.ByteString
4+
import org.xmtp.android.library.XMTPException
5+
6+
val ContentTypeReadReceipt = ContentTypeIdBuilder.builderFromAuthorityId(
7+
"xmtp.org",
8+
"readReceipt",
9+
versionMajor = 1,
10+
versionMinor = 0
11+
)
12+
13+
data class ReadReceipt(
14+
// The timestamp the read receipt was sent, in ISO 8601 format
15+
val timestamp: String,
16+
)
17+
18+
data class ReadReceiptCodec(override var contentType: ContentTypeId = ContentTypeReadReceipt) :
19+
ContentCodec<ReadReceipt> {
20+
21+
override fun encode(content: ReadReceipt): EncodedContent {
22+
return EncodedContent.newBuilder().also {
23+
it.type = ContentTypeReadReceipt
24+
it.putParameters("timestamp", content.timestamp)
25+
it.content = ByteString.EMPTY
26+
}.build()
27+
}
28+
29+
override fun decode(content: EncodedContent): ReadReceipt {
30+
val timestamp = content.parametersMap["timestamp"] ?: throw XMTPException("Invalid Content")
31+
32+
return ReadReceipt(timestamp = timestamp)
33+
}
34+
}

0 commit comments

Comments
 (0)