fix: progressing with port

Author: ivelin

src/api.py

@@ -0,0 +1,90 @@
+import { util } from "./util";
+import logger from "./logger";
+
+export class API {
+ constructor(private readonly _options: any) { }
+
+ private _buildUrl(method: string): string {
+ const protocol = this._options.secure ? "https://" : "http://";
+ let url =
+ protocol +
+ this._options.host +
+ ":" +
+ this._options.port +
+ this._options.path +
+ this._options.key +
+ "/" +
+ method;
+ const queryString = "?ts=" + new Date().getTime() + "" + Math.random();
+ url += queryString;
+
+ return url;
+ }
+
+ /** Get a unique ID from the server via XHR and initialize with it. */
+ async retrieveId(): Promise<string> {
+ const url = this._buildUrl("id");
+
+ try {
+ const response = await fetch(url);
+
+ if (response.status !== 200) {
+ throw new Error(`Error. Status:${response.status}`);
+ }
+
+ return response.text();
+ } catch (error) {
+ logger.error("Error retrieving ID", error);
+
+ let pathError = "";
+
+ if (
+ this._options.path === "/" &&
+ this._options.host !== util.CLOUD_HOST
+ ) {
+ pathError =
+ " If you passed in a `path` to your self-hosted PeerServer, " +
+ "you'll also need to pass in that same path when creating a new " +
+ "Peer.";
+ }
+
+ throw new Error("Could not get an ID from the server." + pathError);
+ }
+ }
+
+ /** @deprecated */
+ async listAllPeers(): Promise<any[]> {
+ const url = this._buildUrl("peers");
+
+ try {
+ const response = await fetch(url);
+
+ if (response.status !== 200) {
+ if (response.status === 401) {
+ let helpfulError = "";
+
+ if (this._options.host === util.CLOUD_HOST) {
+ helpfulError =
+ "It looks like you're using the cloud server. You can email " +
+ "team@peerjs.com to enable peer listing for your API key.";
+ } else {
+ helpfulError =
+ "You need to enable `allow_discovery` on your self-hosted " +
+ "PeerServer to use this feature.";
+ }
+
+ throw new Error("It doesn't look like you have permission to list peers IDs. " +
+ helpfulError);
+ }
+
+ throw new Error(`Error. Status:${response.status}`);
+ }
+
+ return response.json();
+ } catch (error) {
+ logger.error("Error retrieving list peers", error);
+
+ throw new Error("Could not get list peers from the server." + error);
+ }
+ }
+}

src/baseconnection.py

@@ -0,0 +1,41 @@
+"""Base abstractions for peer to peer connections."""
+from pyee import AsyncIOEventEmitter
+from ..peer import Peer
+from servermessage import ServerMessage
+from enums import ConnectionType
+from abc import abstractmethod
+from aiortc import RTCPeerConnection
+
+
+class BaseConnection(AsyncIOEventEmitter):
+ """Base abstract class for peer to peer connections."""
+
+ @abstractmethod
+ def type() -> ConnectionType:
+ """Return connection type."""
+
+ @property
+ def open(self):
+ """Return True if this connection is open."""
+ return self._open
+
+ def __init__(
+ self,
+ peer: str = None,
+ provider: Peer = None,
+ options: any = None
+ ):
+ """Create connection construct."""
+ super()
+ self.metadata = options.metadata
+ self._open = False
+ self.connectionId: str = None
+ self.peerConnection: RTCPeerConnection = None
+
+ @abstractmethod
+ def close(self) -> None:
+ """Close this connection."""
+
+ @abstractmethod
+ def handleMessage(self, message: ServerMessage) -> None:
+ """Handle incoming message."""