fluencelabs/fluence-js
1
0
Fork 0
mirror of https://github.com/fluencelabs/fluence-js.git synced 2025-06-28 15:21:33 +00:00
Code Issues Projects Releases Wiki Activity

Fix client SDK TypeScript compilation (#942)

Browse Source
This commit is contained in:
Dima
2020-08-26 18:48:17 +03:00
committed by GitHub
parent 2277a3584c
commit 9617a646ec
5 changed files with 785 additions and 112 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/fluenceConnection.ts
View File

@ -23,8 +23,7 @@ import {
makeProvideMessage,
parseFunctionCall
} from "./functionCall";
import * as PeerId from "peer-id";
import * as PeerInfo from "peer-info";
import Websockets from "libp2p-websockets";
import Mplex from "libp2p-mplex";
import SECIO from "libp2p-secio";
@ -32,6 +31,7 @@ import Peer from "libp2p";
import {decode, encode} from "it-length-prefixed";
import pipe from "it-pipe";
import Multiaddr from "multiaddr";
import PeerId from "peer-id";
export const PROTOCOL_NAME = '/fluence/faas/1.0.0';
@ -43,18 +43,18 @@ enum Status {
export class FluenceConnection {
private readonly selfPeerInfo: PeerInfo;
private readonly selfPeerId: PeerId;
readonly sender: Address;
private node: LibP2p;
private readonly address: Multiaddr;
readonly nodePeerId: PeerId;
private readonly selfPeerId: string;
private readonly selfPeerIdStr: string;
private readonly handleCall: (call: FunctionCall) => FunctionCall | undefined;
constructor(multiaddr: Multiaddr, hostPeerId: PeerId, selfPeerInfo: PeerInfo, sender: Address, handleCall: (call: FunctionCall) => FunctionCall | undefined) {
this.selfPeerInfo = selfPeerInfo;
constructor(multiaddr: Multiaddr, hostPeerId: PeerId, selfPeerId: PeerId, sender: Address, handleCall: (call: FunctionCall) => FunctionCall | undefined) {
this.selfPeerId = selfPeerId;
this.handleCall = handleCall;
this.selfPeerId = selfPeerInfo.id.toB58String();
this.selfPeerIdStr = selfPeerId.toB58String();
this.address = multiaddr;
this.nodePeerId = hostPeerId;
this.sender = sender
@ -71,9 +71,9 @@ export class FluenceConnection {
}
async connect() {
let peerInfo = this.selfPeerInfo;
let peerInfo = this.selfPeerId;
this.node = await Peer.create({
peerInfo,
peerId: peerInfo,
config: {},
modules: {
transport: [Websockets],
@ -97,7 +97,7 @@ export class FluenceConnection {
if (this.status === Status.Initializing) {
await this.node.start();
console.log("dialing to the node with address: " + this.node.peerInfo.id.toB58String());
console.log("dialing to the node with address: " + this.node.peerId.toB58String());
await this.node.dial(this.address);
@ -110,7 +110,7 @@ export class FluenceConnection {
async function (source: AsyncIterable<string>) {
for await (const msg of source) {
try {
console.log(_this.selfPeerId);
console.log(_this.selfPeerIdStr);
let call = parseFunctionCall(msg);
let response = _this.handleCall(call);