blob: 15548f4acdd910368260e6cc4f475447b4b81a43 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
import { SessionMiddleware } from "tabby-terminal";
import { Observable, Subject } from "rxjs";
const oscPrefix = Buffer.from("\x1b]");
const oscSuffix = Buffer.from("\x07");
export default class OscNotifyMiddleware extends SessionMiddleware {
tabTitle: string;
constructor(tabTitle: string) {
super();
this.tabTitle = tabTitle;
}
get cwdReported$(): Observable<string> {
return this.cwdReported;
}
get copyRequested$(): Observable<string> {
return this.copyRequested;
}
private cwdReported = new Subject<string>();
private copyRequested = new Subject<string>();
feedFromSession(data: Buffer): void {
let startIndex = 0;
while (data.includes(oscPrefix, startIndex) && data.includes(oscSuffix, startIndex)) {
const params = data.subarray(data.indexOf(oscPrefix, startIndex) + oscPrefix.length);
const oscString = params.subarray(0, params.indexOf(oscSuffix)).toString();
startIndex = data.indexOf(oscSuffix, startIndex) + oscSuffix.length;
const [ oscCodeString, ...oscParams ] = oscString.split(";");
const oscCode = parseInt(oscCodeString);
if (oscCode === 9) {
// TODO: onclick switch to tab
new Notification(this.tabTitle, {
body: oscParams[0]
});
} else {
continue;
}
}
super.feedFromSession(data);
}
close(): void {
this.cwdReported.complete();
this.copyRequested.complete();
super.close();
}
}
|
