Autoformat

import javax.inject.Inject

class MessagesAdapter @Inject constructor(

    subscriptionManager: SubscriptionManagerCompat,

    private val context: Context,

    private val colors: Colors,

    private val dateFormatter: DateFormatter,

    private val navigator: Navigator,

    private val prefs: Preferences,

    private val subscriptionManager: SubscriptionManagerCompat

    private val prefs: Preferences

) : QkRealmAdapter<Message>() {

    companion object {

        private const val VIEW_TYPE_MESSAGE_OUT = 1

    }

    val clicks: Subject<Message> = PublishSubject.create<Message>()

    val cancelSending: Subject<Message> = PublishSubject.create<Message>()

    val clicks: Subject<Message> = PublishSubject.create()

    val cancelSending: Subject<Message> = PublishSubject.create()

    var data: Pair<Conversation, RealmResults<Message>>? = null

        set(value) {

        val next = if (position == itemCount - 1) null else getItem(position + 1)

        val view = viewHolder.containerView

        // Update the selected state

        view.isActivated = isSelected(message.id) || highlight == message.id

        // Bind the cancel view

        view.findViewById<ProgressBar>(R.id.cancel)?.let { cancel ->

            val isCancellable = message.isSending() && message.date > System.currentTimeMillis()

            }

        }

        // Bind the message status

        bindStatus(viewHolder, message, next)

        // Bind the timestamp

        val timeSincePrevious = TimeUnit.MILLISECONDS.toMinutes(message.date - (previous?.date ?: 0))

        val simIndex = subs.takeIf { it.size > 1 }?.indexOfFirst { it.subscriptionId == message.subId } ?: -1

        view.timestamp.text = dateFormatter.getMessageTimestamp(message.date)

        view.simIndex.text = "${simIndex + 1}"

        view.timestamp.setVisible(timeSincePrevious >= BubbleUtils.TIMESTAMP_THRESHOLD || message.subId != previous?.subId && simIndex != -1)

        view.timestamp.setVisible(timeSincePrevious >= BubbleUtils.TIMESTAMP_THRESHOLD

                || message.subId != previous?.subId && simIndex != -1)

        view.sim.setVisible(message.subId != previous?.subId && simIndex != -1)

        view.simIndex.setVisible(message.subId != previous?.subId && simIndex != -1)

        // Bind the grouping

        val media = message.parts.filter { it.isImage() || it.isVideo() || it.isVCard() }

        view.setPadding(bottom = if (canGroup(message, next)) 0 else 16.dpToPx(context))

        // Bind the avatar

        if (!message.isMe()) {

            view.avatar.threadId = conversation?.id ?: 0

            view.avatar.setVisible(!canGroup(message, next), View.INVISIBLE)

        }

        // Bind the body text

        view.body.text = when (message.isSms()) {

            true -> message.body

                when {

                    subject.isNotBlank() -> {

                        val spannable = SpannableString(if (body.isNotBlank()) "$subject\n$body" else subject)

                        spannable.setSpan(StyleSpan(Typeface.BOLD), 0, subject.length, Spannable.SPAN_INCLUSIVE_EXCLUSIVE)

                        spannable.setSpan(StyleSpan(Typeface.BOLD), 0, subject.length,

                                Spannable.SPAN_INCLUSIVE_EXCLUSIVE)

                        spannable

                    }

                    else -> body

                canGroupWithNext = canGroup(message, next),

                isMe = message.isMe()))

        // Bind the attachments

        val partsAdapter = view.attachments.adapter as PartsAdapter

        partsAdapter.setData(message, previous, next, view)

        view.status.text = when {

            message.isSending() -> context.getString(R.string.message_status_sending)

            message.isDelivered() -> context.getString(R.string.message_status_delivered, dateFormatter.getTimestamp(message.dateSent))

            message.isDelivered() -> context.getString(R.string.message_status_delivered,

                    dateFormatter.getTimestamp(message.dateSent))

            message.isFailedMessage() -> context.getString(R.string.message_status_failed)

            // Incoming group message