Skip to content

Commit e23bb56

Browse files
committed
renamed PeerNode to MeshNode
1 parent a6c7c3b commit e23bb56

File tree

3 files changed

+12
-12
lines changed

3 files changed

+12
-12
lines changed

src/mesh/service.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
export { Mesh, PeerGroupInfo, SyncMode } from './service/Mesh';
22
export { MeshHost, MeshCommand, CommandStreamedReply} from './service/remoting/MeshHost';
33
export { MeshProxy } from './service/remoting/MeshProxy';
4+
export { MeshNode } from './service/MeshNode';
45
export { AgentPod, AgentEvent, AgentSetChangeEvent, AgentSetChange } from './service/AgentPod';
56
export { Agent } from './service/Agent';
67
export { PeerGroup } from './service/PeerGroup';
7-
export { PeerNode } from './service/PeerNode';
88
export { WebWorkerMeshHost } from './service/webworker/WebWorkerMeshHost';
9-
export { WebWorkerMeshProxy } from './service/webworker/WebWorkerMeshProxy';
9+
export { WebWorkerMeshProxy } from './service/webworker/WebWorkerMeshProxy';

src/mesh/service/PeerNode.ts renamed to src/mesh/service/MeshNode.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import { PeerGroupInfo, SyncMode, UsageToken } from './Mesh';
88

99
type Key = string;
1010

11-
class PeerNode {
11+
class MeshNode {
1212

1313
resources: Resources;
1414

@@ -62,7 +62,7 @@ class PeerNode {
6262
peerGroup = await this.discoveryPeerGroupInfo(obj);
6363
}
6464

65-
const peerGroupKey = PeerNode.generateKey([peerGroup.id]);
65+
const peerGroupKey = MeshNode.generateKey([peerGroup.id]);
6666

6767
let peerGroupToken = this.peerGroupTokens.get(peerGroupKey);
6868

@@ -71,7 +71,7 @@ class PeerNode {
7171
this.peerGroupTokens.set(peerGroupKey, peerGroupToken);
7272
}
7373

74-
const syncKey = PeerNode.generateKey([obj.hash(), peerGroup.id, gossipId]);
74+
const syncKey = MeshNode.generateKey([obj.hash(), peerGroup.id, gossipId]);
7575

7676
let syncToken = this.syncTokens.get(syncKey);
7777

@@ -84,18 +84,18 @@ class PeerNode {
8484

8585
async stopSync(obj: HashedObject, peerGroupId?: string, gossipId?: string) : Promise<void> {
8686
if (peerGroupId === undefined) {
87-
peerGroupId = PeerNode.discoveryPeerGroupInfoId(obj);
87+
peerGroupId = MeshNode.discoveryPeerGroupInfoId(obj);
8888
}
8989

90-
const syncKey = PeerNode.generateKey([obj.hash(), peerGroupId, gossipId]);
90+
const syncKey = MeshNode.generateKey([obj.hash(), peerGroupId, gossipId]);
9191
const syncToken = this.syncTokens.get(syncKey);
9292

9393
if (syncToken !== undefined) {
9494

9595
this.resources.mesh.stopSyncObjectWithPeerGroup(syncToken);
9696
this.syncTokens.delete(syncKey);
9797

98-
const peerGroupKey = PeerNode.generateKey([peerGroupId]);
98+
const peerGroupKey = MeshNode.generateKey([peerGroupId]);
9999
const peerGroupToken = this.peerGroupTokens.get(peerGroupKey)
100100

101101
if (peerGroupToken !== undefined) {
@@ -113,7 +113,7 @@ class PeerNode {
113113
let peerSource = new ObjectDiscoveryPeerSource(this.resources.mesh, obj, this.resources.config.linkupServers, LinkupAddress.fromURL(localPeer.endpoint, localPeer.identity), this.resources.getEndointParserForDiscovery());
114114

115115
return {
116-
id: PeerNode.discoveryPeerGroupInfoId(obj),
116+
id: MeshNode.discoveryPeerGroupInfoId(obj),
117117
localPeer: localPeer,
118118
peerSource: peerSource
119119
};
@@ -158,4 +158,4 @@ class PeerNode {
158158

159159
}
160160

161-
export { PeerNode }
161+
export { MeshNode }

src/net/linkup/LinkupManager.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@ class LinkupManager {
1111

1212
static logger = new Logger(LinkupManager.name, LogLevel.INFO);
1313

14-
static defaultLinkupServer = 'wrtc+wss://mypeer.net:443';
15-
//static defaultLinkupServer = 'wrtc+ws://localhost:8765';
14+
//static defaultLinkupServer = 'wrtc+wss://mypeer.net:443';
15+
static defaultLinkupServer = 'wrtc+ws://localhost:3002';
1616
//static defaultLinkupServer = 'wrtc+ws://192.168.0.105:8765';
1717

1818
serverConnections : Map<string, LinkupServer>;

0 commit comments

Comments
 (0)