mirror of
https://github.com/tauri-apps/plugins-workspace.git
synced 2026-06-06 13:53:54 +02:00
chore: adjust prettier config, .gitignore and use taplo to format toml files (#1728)
* chore: adjust prettier config, .gitignore and use taplo to format toml files This brings the plugins-workspace repository to the same code style of the main tauri repo * format toml * ignore examples gen dir * add .vscode/extensions.json * remove packageManager field * fmt * fix audit * taplo ignore permissions autogenerated files * remove create dummy dist * fix prettier workflow * install fmt in prettier workflow --------- Co-authored-by: Lucas Nogueira <lucas@tauri.app>
This commit is contained in:
@@ -2,97 +2,97 @@
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
// SPDX-License-Identifier: MIT
|
||||
|
||||
import { invoke, Channel } from "@tauri-apps/api/core";
|
||||
import { invoke, Channel } from '@tauri-apps/api/core'
|
||||
|
||||
export interface ConnectionConfig {
|
||||
writeBufferSize?: number;
|
||||
maxWriteBufferSize?: number;
|
||||
maxMessageSize?: number;
|
||||
maxFrameSize?: number;
|
||||
acceptUnmaskedFrames?: boolean;
|
||||
headers?: HeadersInit;
|
||||
writeBufferSize?: number
|
||||
maxWriteBufferSize?: number
|
||||
maxMessageSize?: number
|
||||
maxFrameSize?: number
|
||||
acceptUnmaskedFrames?: boolean
|
||||
headers?: HeadersInit
|
||||
}
|
||||
|
||||
export interface MessageKind<T, D> {
|
||||
type: T;
|
||||
data: D;
|
||||
type: T
|
||||
data: D
|
||||
}
|
||||
|
||||
export interface CloseFrame {
|
||||
code: number;
|
||||
reason: string;
|
||||
code: number
|
||||
reason: string
|
||||
}
|
||||
|
||||
export type Message =
|
||||
| MessageKind<"Text", string>
|
||||
| MessageKind<"Binary", number[]>
|
||||
| MessageKind<"Ping", number[]>
|
||||
| MessageKind<"Pong", number[]>
|
||||
| MessageKind<"Close", CloseFrame | null>;
|
||||
| MessageKind<'Text', string>
|
||||
| MessageKind<'Binary', number[]>
|
||||
| MessageKind<'Ping', number[]>
|
||||
| MessageKind<'Pong', number[]>
|
||||
| MessageKind<'Close', CloseFrame | null>
|
||||
|
||||
export default class WebSocket {
|
||||
id: number;
|
||||
private readonly listeners: Array<(arg: Message) => void>;
|
||||
id: number
|
||||
private readonly listeners: Array<(arg: Message) => void>
|
||||
|
||||
constructor(id: number, listeners: Array<(arg: Message) => void>) {
|
||||
this.id = id;
|
||||
this.listeners = listeners;
|
||||
this.id = id
|
||||
this.listeners = listeners
|
||||
}
|
||||
|
||||
static async connect(
|
||||
url: string,
|
||||
config?: ConnectionConfig,
|
||||
config?: ConnectionConfig
|
||||
): Promise<WebSocket> {
|
||||
const listeners: Array<(arg: Message) => void> = [];
|
||||
const listeners: Array<(arg: Message) => void> = []
|
||||
|
||||
const onMessage = new Channel<Message>();
|
||||
const onMessage = new Channel<Message>()
|
||||
onMessage.onmessage = (message: Message): void => {
|
||||
listeners.forEach((l) => {
|
||||
l(message);
|
||||
});
|
||||
};
|
||||
|
||||
if (config?.headers) {
|
||||
config.headers = Array.from(new Headers(config.headers).entries());
|
||||
l(message)
|
||||
})
|
||||
}
|
||||
|
||||
return await invoke<number>("plugin:websocket|connect", {
|
||||
if (config?.headers) {
|
||||
config.headers = Array.from(new Headers(config.headers).entries())
|
||||
}
|
||||
|
||||
return await invoke<number>('plugin:websocket|connect', {
|
||||
url,
|
||||
onMessage,
|
||||
config,
|
||||
}).then((id) => new WebSocket(id, listeners));
|
||||
config
|
||||
}).then((id) => new WebSocket(id, listeners))
|
||||
}
|
||||
|
||||
addListener(cb: (arg: Message) => void): void {
|
||||
this.listeners.push(cb);
|
||||
this.listeners.push(cb)
|
||||
}
|
||||
|
||||
async send(message: Message | string | number[]): Promise<void> {
|
||||
let m: Message;
|
||||
if (typeof message === "string") {
|
||||
m = { type: "Text", data: message };
|
||||
} else if (typeof message === "object" && "type" in message) {
|
||||
m = message;
|
||||
let m: Message
|
||||
if (typeof message === 'string') {
|
||||
m = { type: 'Text', data: message }
|
||||
} else if (typeof message === 'object' && 'type' in message) {
|
||||
m = message
|
||||
} else if (Array.isArray(message)) {
|
||||
m = { type: "Binary", data: message };
|
||||
m = { type: 'Binary', data: message }
|
||||
} else {
|
||||
throw new Error(
|
||||
"invalid `message` type, expected a `{ type: string, data: any }` object, a string or a numeric array",
|
||||
);
|
||||
'invalid `message` type, expected a `{ type: string, data: any }` object, a string or a numeric array'
|
||||
)
|
||||
}
|
||||
await invoke("plugin:websocket|send", {
|
||||
await invoke('plugin:websocket|send', {
|
||||
id: this.id,
|
||||
message: m,
|
||||
});
|
||||
message: m
|
||||
})
|
||||
}
|
||||
|
||||
async disconnect(): Promise<void> {
|
||||
await this.send({
|
||||
type: "Close",
|
||||
type: 'Close',
|
||||
data: {
|
||||
code: 1000,
|
||||
reason: "Disconnected by client",
|
||||
},
|
||||
});
|
||||
reason: 'Disconnected by client'
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user