Skip to content

Commit 853fd6a

Browse files
committed
Initial commit
0 parents  commit 853fd6a

File tree

127 files changed

+10731
-0
lines changed

Some content is hidden

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

127 files changed

+10731
-0
lines changed

.gitignore

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
*.iml
2+
.gradle
3+
/local.properties
4+
/.idea
5+
.DS_Store
6+
/build
7+
/captures
8+
.externalNativeBuild
9+
.cxx
10+
local.properties
11+
.idea

app/.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
/build

app/build.gradle

Lines changed: 74 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
1+
plugins {
2+
id 'com.android.application'
3+
}
4+
5+
android {
6+
compileSdkVersion build_versions.target_sdk
7+
buildToolsVersion build_versions.build_tools
8+
9+
defaultConfig {
10+
applicationId "com.shiyinghan.mqttdemo"
11+
minSdkVersion build_versions.min_sdk
12+
targetSdkVersion build_versions.target_sdk
13+
versionCode 1
14+
versionName "0.1"
15+
16+
testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
17+
}
18+
19+
buildTypes {
20+
release {
21+
minifyEnabled false
22+
proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
23+
}
24+
}
25+
compileOptions {
26+
sourceCompatibility JavaVersion.VERSION_1_8
27+
targetCompatibility JavaVersion.VERSION_1_8
28+
}
29+
30+
viewBinding {
31+
enabled = true
32+
}
33+
}
34+
35+
dependencies {
36+
implementation fileTree(dir: 'libs', include: ['*.jar'])
37+
38+
implementation deps.support.v4
39+
implementation deps.support.multidex
40+
41+
//support
42+
implementation deps.support.app_compat
43+
implementation deps.support.recyclerview
44+
implementation deps.support.design
45+
implementation deps.support.v4
46+
implementation deps.support.constraint_layout
47+
implementation deps.support.fragment
48+
//room
49+
implementation deps.room.runtime
50+
annotationProcessor deps.room.compiler
51+
implementation deps.room.rxjava2
52+
//rxJava
53+
implementation deps.rxjava2
54+
implementation deps.rx_android
55+
implementation deps.rx_lifecycle
56+
implementation deps.rx_lifecycle_components
57+
implementation deps.rx_lifecycle_android_lifecycle
58+
implementation deps.rx_relay
59+
//eventbus
60+
implementation deps.eventbus
61+
//autosize
62+
implementation deps.autosize
63+
//BaseRecyclerViewAdapterHelper
64+
implementation deps.BaseRecyclerViewAdapterHelper
65+
66+
annotationProcessor deps.room.compiler
67+
68+
// test
69+
testImplementation deps.junit
70+
androidTestImplementation deps.extjunit
71+
androidTestImplementation deps.espresso
72+
73+
implementation project(path: ':mqtt')
74+
}

app/proguard-rules.pro

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
# Add project specific ProGuard rules here.
2+
# You can control the set of applied configuration files using the
3+
# proguardFiles setting in build.gradle.
4+
#
5+
# For more details, see
6+
# http://developer.android.com/guide/developing/tools/proguard.html
7+
8+
# If your project uses WebView with JS, uncomment the following
9+
# and specify the fully qualified class name to the JavaScript interface
10+
# class:
11+
#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
12+
# public *;
13+
#}
14+
15+
# Uncomment this to preserve the line number information for
16+
# debugging stack traces.
17+
#-keepattributes SourceFile,LineNumberTable
18+
19+
# If you keep the line number information, uncomment this to
20+
# hide the original source file name.
21+
#-renamesourcefileattribute SourceFile
Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
package com.shiyinghan.mqttdemo;
2+
3+
import android.content.Context;
4+
5+
import androidx.test.platform.app.InstrumentationRegistry;
6+
import androidx.test.ext.junit.runners.AndroidJUnit4;
7+
8+
import org.junit.Test;
9+
import org.junit.runner.RunWith;
10+
11+
import static org.junit.Assert.*;
12+
13+
/**
14+
* Instrumented test, which will execute on an Android device.
15+
*
16+
* @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
17+
*/
18+
@RunWith(AndroidJUnit4.class)
19+
public class ExampleInstrumentedTest {
20+
@Test
21+
public void useAppContext() {
22+
// Context of the app under test.
23+
Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
24+
assertEquals("com.shiyinghan.demo", appContext.getPackageName());
25+
}
26+
}

app/src/main/AndroidManifest.xml

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
<?xml version="1.0" encoding="utf-8"?>
2+
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
3+
package="com.shiyinghan.mqttdemo">
4+
5+
<!-- Permissions the Application Requires -->
6+
<uses-permission android:name="android.permission.WAKE_LOCK" />
7+
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />
8+
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
9+
10+
<!--<uses-permission android:name="android.permission.READ_PHONE_STATE" />-->
11+
<uses-permission android:name="android.permission.READ_EXTERNAL_STORAGE" />
12+
<uses-permission android:name="android.permission.INTERNET" />
13+
14+
<application
15+
android:name=".common.MyApplication"
16+
android:allowBackup="false"
17+
android:icon="@mipmap/ic_launcher"
18+
android:label="@string/app_name"
19+
android:roundIcon="@mipmap/ic_launcher_round"
20+
android:supportsRtl="true"
21+
android:theme="@style/Theme.MqttAndroid">
22+
23+
<activity
24+
android:name=".module.activity.ConnectionListActivity"
25+
android:launchMode="singleTask">
26+
<intent-filter>
27+
<action android:name="android.intent.action.MAIN" />
28+
29+
<category android:name="android.intent.category.LAUNCHER" />
30+
</intent-filter>
31+
</activity>
32+
<activity
33+
android:name=".module.activity.ConnectionEditActivity"
34+
android:windowSoftInputMode="stateHidden|adjustResize" />
35+
<activity
36+
android:name=".module.activity.ConnectionPortalActivity"
37+
android:windowSoftInputMode="stateHidden|adjustResize" />
38+
</application>
39+
40+
</manifest>
Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
package com.shiyinghan.mqttdemo.adapter;
2+
3+
import android.widget.ImageView;
4+
import android.widget.TextView;
5+
6+
import com.chad.library.adapter.base.BaseQuickAdapter;
7+
import com.chad.library.adapter.base.viewholder.BaseViewHolder;
8+
import com.shiyinghan.mqttdemo.R;
9+
import com.shiyinghan.mqttdemo.mqtt.entity.ConnectionEntity;
10+
11+
import org.jetbrains.annotations.NotNull;
12+
13+
public class ConnectionListRecyclerViewAdapter extends BaseQuickAdapter<ConnectionEntity, BaseViewHolder> {
14+
15+
private ConnectionListClickListener mListener;
16+
17+
public void setListener(ConnectionListClickListener mListener) {
18+
this.mListener = mListener;
19+
}
20+
21+
public ConnectionListRecyclerViewAdapter() {
22+
super(R.layout.list_item_connection);
23+
}
24+
25+
@Override
26+
protected void convert(@NotNull BaseViewHolder baseViewHolder, ConnectionEntity connectionEntity) {
27+
TextView tvConnectionRowTitle = baseViewHolder.getView(R.id.tvConnectionRowTitle);
28+
tvConnectionRowTitle.setText(connectionEntity.getClientId());
29+
30+
ImageView ivConnectionRowDeleteIcon = baseViewHolder.getView(R.id.ivConnectionRowDeleteIcon);
31+
ImageView ivConnectionRowEditIcon = baseViewHolder.getView(R.id.ivConnectionRowEditIcon);
32+
33+
baseViewHolder.itemView.setOnClickListener(v -> mListener.onClickItem(connectionEntity));
34+
ivConnectionRowDeleteIcon.setOnClickListener(v -> mListener.onClickDeleteIcon(connectionEntity));
35+
ivConnectionRowEditIcon.setOnClickListener(v -> mListener.onClickEditIcon(connectionEntity));
36+
}
37+
38+
public interface ConnectionListClickListener {
39+
void onClickItem(ConnectionEntity entity);
40+
41+
void onClickEditIcon(ConnectionEntity entity);
42+
43+
void onClickDeleteIcon(ConnectionEntity entity);
44+
}
45+
}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
package com.shiyinghan.mqttdemo.adapter;
2+
3+
import android.content.res.Resources;
4+
import android.widget.TextView;
5+
6+
import com.chad.library.adapter.base.BaseQuickAdapter;
7+
import com.chad.library.adapter.base.viewholder.BaseViewHolder;
8+
import com.shiyinghan.mqttdemo.R;
9+
import com.shiyinghan.mqttdemo.mqtt.entity.ReceivedMessageEntity;
10+
11+
import org.jetbrains.annotations.NotNull;
12+
13+
import java.text.DateFormat;
14+
import java.text.SimpleDateFormat;
15+
16+
public class HistoryListRecyclerViewAdapter extends BaseQuickAdapter<ReceivedMessageEntity, BaseViewHolder> {
17+
18+
private DateFormat mDateFormat = SimpleDateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.SHORT);
19+
20+
public HistoryListRecyclerViewAdapter() {
21+
super(R.layout.list_item_history);
22+
}
23+
24+
@Override
25+
protected void convert(@NotNull BaseViewHolder baseViewHolder, ReceivedMessageEntity entity) {
26+
Resources resources = getRecyclerView().getResources();
27+
28+
TextView tvHistoryItemTopic = baseViewHolder.getView(R.id.tvHistoryItemTopic);
29+
tvHistoryItemTopic.setText(resources.getString(R.string.history_list_topic_fmt, entity.getTopic()));
30+
31+
TextView tvHistoryItemMessage = baseViewHolder.getView(R.id.tvHistoryItemMessage);
32+
tvHistoryItemMessage.setText(new String(entity.getMessage().getPayload()));
33+
34+
TextView tvHistoryItemTime = baseViewHolder.getView(R.id.tvHistoryItemTime);
35+
tvHistoryItemTime.setText(resources.getString(R.string.history_list_time_fmt, mDateFormat.format(entity.getTimestamp())));
36+
}
37+
}
Lines changed: 52 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,52 @@
1+
package com.shiyinghan.mqttdemo.adapter;
2+
3+
import android.content.res.Resources;
4+
import android.widget.ImageView;
5+
import android.widget.TextView;
6+
7+
import com.chad.library.adapter.base.BaseQuickAdapter;
8+
import com.chad.library.adapter.base.viewholder.BaseViewHolder;
9+
import com.shiyinghan.mqttdemo.R;
10+
import com.shiyinghan.mqttdemo.mqtt.entity.SubscriptionEntity;
11+
12+
import org.jetbrains.annotations.NotNull;
13+
14+
public class SubscriptionListRecyclerViewAdapter extends BaseQuickAdapter<SubscriptionEntity, BaseViewHolder> {
15+
16+
private SubscriptionListClickListener mListener;
17+
18+
public void setListener(SubscriptionListClickListener mListener) {
19+
this.mListener = mListener;
20+
}
21+
22+
public SubscriptionListRecyclerViewAdapter() {
23+
super(R.layout.list_item_subscription);
24+
}
25+
26+
@Override
27+
protected void convert(@NotNull BaseViewHolder baseViewHolder, SubscriptionEntity entity) {
28+
Resources resources = getRecyclerView().getResources();
29+
30+
TextView tvSubscriptionItemTopic = baseViewHolder.getView(R.id.tvSubscriptionItemTopic);
31+
tvSubscriptionItemTopic.setText(resources.getString(R.string.subscription_list_topic_text, entity.getTopic()));
32+
33+
TextView tvSubscriptionItemQos = baseViewHolder.getView(R.id.tvSubscriptionItemQos);
34+
tvSubscriptionItemQos.setText(resources.getString(R.string.subscription_list_qos_text, entity.getQos()));
35+
36+
TextView tvSubscriptionItemShowNotification = baseViewHolder.getView(R.id.tvSubscriptionItemShowNotification);
37+
tvSubscriptionItemShowNotification.setText(
38+
resources.getString(
39+
R.string.subscription_list_notify_text,
40+
entity.isEnableNotification() ? resources.getString(R.string.enabled) : resources.getString(R.string.disabled)));
41+
42+
ImageView ivSubscriptionItemDelete = baseViewHolder.getView(R.id.ivSubscriptionItemDelete);
43+
ivSubscriptionItemDelete.setOnClickListener(v -> {
44+
mListener.onClickDeleteIcon(entity);
45+
});
46+
}
47+
48+
public interface SubscriptionListClickListener {
49+
50+
void onClickDeleteIcon(SubscriptionEntity entity);
51+
}
52+
}

0 commit comments

Comments
 (0)