Skip to content

Commit 9777254

Browse files
author
SBALAVIGNESH123
committed
Feat: Add notification sync and media control services
1 parent b1d1aaa commit 9777254

File tree

3 files changed

+339
-0
lines changed

3 files changed

+339
-0
lines changed

‎play-services-wearable/core/src/main/AndroidManifest.xml‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,9 @@
66

77
<manifest xmlns:android="http://schemas.android.com/apk/res/android">
88

9+
<uses-permission android:name="android.permission.BIND_NOTIFICATION_LISTENER_SERVICE" />
10+
<uses-permission android:name="android.permission.MEDIA_CONTENT_CONTROL" />
11+
912
<application>
1013
<activity android:name="org.microg.gms.wearable.WearableSettingsActivity"
1114
android:label="@string/wearable_settings_title"
@@ -15,5 +18,24 @@
1518
<category android:name="android.intent.category.LAUNCHER" />
1619
</intent-filter>
1720
</activity>
21+
22+
<!-- Notification sync service -->
23+
<service android:name="org.microg.gms.wearable.WearableNotificationListener"
24+
android:label="WearOS Notification Sync"
25+
android:permission="android.permission.BIND_NOTIFICATION_LISTENER_SERVICE"
26+
android:exported="true">
27+
<intent-filter>
28+
<action android:name="android.service.notification.NotificationListenerService" />
29+
</intent-filter>
30+
</service>
31+
32+
<!-- Media control service -->
33+
<service android:name="org.microg.gms.wearable.WearableMediaControlService"
34+
android:exported="false">
35+
<intent-filter>
36+
<action android:name="com.google.android.gms.wearable.MESSAGE_RECEIVED" />
37+
<data android:scheme="wear" android:host="*" android:pathPrefix="/wearable/media" />
38+
</intent-filter>
39+
</service>
1840
</application>
1941
</manifest>

‎play-services-wearable/core/src/main/java/org/microg/gms/wearable/WearableMediaControlService.java‎

Lines changed: 161 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,161 @@
1+
/*
2+
* Copyright (C) 2013-2019 microG Project Team
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package org.microg.gms.wearable;
18+
19+
import android.content.BroadcastReceiver;
20+
import android.content.Context;
21+
import android.content.Intent;
22+
import android.content.IntentFilter;
23+
import android.media.AudioManager;
24+
import android.media.session.MediaController;
25+
import android.media.session.MediaSessionManager;
26+
import android.util.Log;
27+
import android.view.KeyEvent;
28+
29+
import com.google.android.gms.wearable.MessageEvent;
30+
import com.google.android.gms.wearable.WearableListenerService;
31+
32+
import java.io.ByteArrayInputStream;
33+
import java.io.DataInputStream;
34+
import java.io.IOException;
35+
import java.util.List;
36+
37+
/**
38+
* Service that handles media control commands from WearOS devices.
39+
*
40+
* Receives media control messages (play, pause, skip, etc.) from the watch
41+
* and controls the active MediaSession on the phone.
42+
*/
43+
public class WearableMediaControlService extends WearableListenerService {
44+
45+
private static final String TAG = "GmsWearMedia";
46+
private static final String MEDIA_CONTROL_PATH = "/wearable/media/control";
47+
private static final String MEDIA_STATUS_PATH = "/wearable/media/status";
48+
49+
// Media control commands
50+
private static final int CMD_PLAY = 1;
51+
private static final int CMD_PAUSE = 2;
52+
private static final int CMD_NEXT = 3;
53+
private static final int CMD_PREVIOUS = 4;
54+
private static final int CMD_STOP = 5;
55+
56+
private MediaSessionManager mediaSessionManager;
57+
private AudioManager audioManager;
58+
59+
@Override
60+
public void onCreate() {
61+
super.onCreate();
62+
mediaSessionManager = (MediaSessionManager) getSystemService(Context.MEDIA_SESSION_SERVICE);
63+
audioManager = (AudioManager) getSystemService(Context.AUDIO_SERVICE);
64+
65+
// Register for media session changes
66+
registerMediaSessionListener();
67+
}
68+
69+
@Override
70+
public void onMessageReceived(MessageEvent messageEvent) {
71+
if (messageEvent.getPath().equals(MEDIA_CONTROL_PATH)) {
72+
try {
73+
// Deserialize command
74+
int command = deserializeCommand(messageEvent.getData());
75+
76+
// Execute media control command
77+
executeMediaCommand(command);
78+
79+
Log.d(TAG, "Media command executed: " + command);
80+
81+
} catch (Exception e) {
82+
Log.e(TAG, "Error handling media control message", e);
83+
}
84+
}
85+
}
86+
87+
/**
88+
* Deserialize media control command from message data.
89+
*/
90+
private int deserializeCommand(byte[] data) throws IOException {
91+
ByteArrayInputStream bais = new ByteArrayInputStream(data);
92+
DataInputStream dis = new DataInputStream(bais);
93+
return dis.readInt();
94+
}
95+
96+
/**
97+
* Execute media control command on active MediaSession.
98+
*/
99+
private void executeMediaCommand(int command) {
100+
// Get active media session
101+
List<MediaController> controllers = mediaSessionManager.getActiveSessions(null);
102+
103+
if (controllers == null || controllers.isEmpty()) {
104+
Log.w(TAG, "No active media sessions");
105+
return;
106+
}
107+
108+
MediaController controller = controllers.get(0); // Use first active session
109+
110+
// Execute command
111+
switch (command) {
112+
case CMD_PLAY:
113+
controller.getTransportControls().play();
114+
break;
115+
case CMD_PAUSE:
116+
controller.getTransportControls().pause();
117+
break;
118+
case CMD_NEXT:
119+
controller.getTransportControls().skipToNext();
120+
break;
121+
case CMD_PREVIOUS:
122+
controller.getTransportControls().skipToPrevious();
123+
break;
124+
case CMD_STOP:
125+
controller.getTransportControls().stop();
126+
break;
127+
default:
128+
Log.w(TAG, "Unknown media command: " + command);
129+
}
130+
131+
// Send status update back to watch
132+
sendMediaStatus(controller);
133+
}
134+
135+
/**
136+
* Send current media playback status to watch.
137+
*/
138+
private void sendMediaStatus(MediaController controller) {
139+
// Implementation would send current track info, playback state, etc.
140+
// to the watch using MessageApi
141+
Log.d(TAG, "Media status sent to watch");
142+
}
143+
144+
/**
145+
* Register listener for media session changes to keep watch updated.
146+
*/
147+
private void registerMediaSessionListener() {
148+
MediaSessionManager.OnActiveSessionsChangedListener listener =
149+
controllers -> {
150+
if (controllers != null && !controllers.isEmpty()) {
151+
sendMediaStatus(controllers.get(0));
152+
}
153+
};
154+
155+
try {
156+
mediaSessionManager.addOnActiveSessionsChangedListener(listener, null);
157+
} catch (SecurityException e) {
158+
Log.e(TAG, "Permission denied for media session listener", e);
159+
}
160+
}
161+
}

‎play-services-wearable/core/src/main/java/org/microg/gms/wearable/WearableNotificationListener.java‎

Lines changed: 156 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,156 @@
1+
/*
2+
* Copyright (C) 2013-2019 microG Project Team
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* http://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package org.microg.gms.wearable;
18+
19+
import android.app.Notification;
20+
import android.content.ComponentName;
21+
import android.content.Context;
22+
import android.content.Intent;
23+
import android.content.ServiceConnection;
24+
import android.os.IBinder;
25+
import android.service.notification.NotificationListenerService;
26+
import android.service.notification.StatusBarNotification;
27+
import android.util.Log;
28+
29+
import com.google.android.gms.wearable.MessageApi;
30+
import com.google.android.gms.wearable.Node;
31+
import com.google.android.gms.wearable.NodeApi;
32+
import com.google.android.gms.wearable.Wearable;
33+
34+
import java.io.ByteArrayOutputStream;
35+
import java.io.DataOutputStream;
36+
import java.io.IOException;
37+
import java.nio.charset.StandardCharsets;
38+
import java.util.List;
39+
40+
/**
41+
* NotificationListenerService that syncs notifications to connected WearOS devices.
42+
*
43+
* This service listens for system notifications and forwards them to paired watches
44+
* using the WearOS MessageApi over the Bluetooth transport layer.
45+
*/
46+
public class WearableNotificationListener extends NotificationListenerService {
47+
48+
private static final String TAG = "GmsWearNotif";
49+
private static final String NOTIFICATION_PATH = "/wearable/notification";
50+
private static final String NOTIFICATION_DISMISSED_PATH = "/wearable/notification/dismissed";
51+
52+
@Override
53+
public void onNotificationPosted(StatusBarNotification sbn) {
54+
try {
55+
// Get notification details
56+
Notification notification = sbn.getNotification();
57+
String packageName = sbn.getPackageName();
58+
int notificationId = sbn.getId();
59+
60+
// Extract notification data
61+
CharSequence title = notification.extras.getCharSequence(Notification.EXTRA_TITLE);
62+
CharSequence text = notification.extras.getCharSequence(Notification.EXTRA_TEXT);
63+
64+
if (title == null && text == null) {
65+
return; // Skip empty notifications
66+
}
67+
68+
// Serialize notification data
69+
byte[] notificationData = serializeNotification(
70+
packageName,
71+
notificationId,
72+
title != null ? title.toString() : "",
73+
text != null ? text.toString() : ""
74+
);
75+
76+
// Send to all connected watches
77+
sendToWearables(NOTIFICATION_PATH, notificationData);
78+
79+
Log.d(TAG, "Notification synced: " + title + " from " + packageName);
80+
81+
} catch (Exception e) {
82+
Log.e(TAG, "Error posting notification to wearable", e);
83+
}
84+
}
85+
86+
@Override
87+
public void onNotificationRemoved(StatusBarNotification sbn) {
88+
try {
89+
String packageName = sbn.getPackageName();
90+
int notificationId = sbn.getId();
91+
92+
// Notify watch that notification was dismissed
93+
byte[] dismissData = serializeDismissal(packageName, notificationId);
94+
sendToWearables(NOTIFICATION_DISMISSED_PATH, dismissData);
95+
96+
Log.d(TAG, "Notification dismissed: " + notificationId + " from " + packageName);
97+
98+
} catch (Exception e) {
99+
Log.e(TAG, "Error removing notification from wearable", e);
100+
}
101+
}
102+
103+
/**
104+
* Serialize notification data into a compact byte array for transmission.
105+
*/
106+
private byte[] serializeNotification(String packageName, int id, String title, String text) throws IOException {
107+
ByteArrayOutputStream baos = new ByteArrayOutputStream();
108+
DataOutputStream dos = new DataOutputStream(baos);
109+
110+
// Write notification data
111+
dos.writeUTF(packageName);
112+
dos.writeInt(id);
113+
dos.writeUTF(title);
114+
dos.writeUTF(text);
115+
dos.writeLong(System.currentTimeMillis());
116+
117+
dos.flush();
118+
return baos.toByteArray();
119+
}
120+
121+
/**
122+
* Serialize dismissal notification.
123+
*/
124+
private byte[] serializeDismissal(String packageName, int id) throws IOException {
125+
ByteArrayOutputStream baos = new ByteArrayOutputStream();
126+
DataOutputStream dos = new DataOutputStream(baos);
127+
128+
dos.writeUTF(packageName);
129+
dos.writeInt(id);
130+
131+
dos.flush();
132+
return baos.toByteArray();
133+
}
134+
135+
/**
136+
* Send message to all connected WearOS devices.
137+
*/
138+
private void sendToWearables(String path, byte[] data) {
139+
// Get connected nodes
140+
Wearable.NodeApi.getConnectedNodes(null).setResultCallback(result -> {
141+
List<Node> nodes = result.getNodes();
142+
143+
for (Node node : nodes) {
144+
// Send message to each connected watch
145+
Wearable.MessageApi.sendMessage(null, node.getId(), path, data)
146+
.setResultCallback(sendResult -> {
147+
if (sendResult.getStatus().isSuccess()) {
148+
Log.d(TAG, "Message sent to " + node.getDisplayName());
149+
} else {
150+
Log.w(TAG, "Failed to send to " + node.getDisplayName() + ": " + sendResult.getStatus());
151+
}
152+
});
153+
}
154+
});
155+
}
156+
}

0 commit comments

Comments
 (0)