logos-messaging/examples.waku.org
1
0
Fork 0
mirror of https://github.com/logos-messaging/examples.waku.org.git synced 2026-01-16 19:53:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

bump to @waku/core 0.0.10

Browse Source
This commit is contained in:
danisharora099 2023-02-01 13:17:58 +05:30
parent 362e307594
commit 1c14b35f66
No known key found for this signature in database
GPG Key ID: FBD2BF500037F135
4 changed files with 1216 additions and 696 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1878
examples/relay-angular-chat/package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

6
examples/relay-angular-chat/package.json
View File

@ -21,9 +21,9 @@
"@angular/platform-browser": "~14.2.11",
"@angular/platform-browser-dynamic": "~14.2.11",
"@angular/router": "~14.2.11",
"@waku/core": "^0.0.6",
"@waku/create": "^0.0.4",
"@waku/interfaces": "^0.0.5",
"@waku/core": "^0.0.10",
"@waku/create": "^0.0.6",
"@waku/interfaces": "^0.0.7",
"protobufjs": "^7.1.2",
"rxjs": "~7.5.7",
"tslib": "^2.4.1",

18
examples/relay-angular-chat/src/app/messages/messages.component.ts
View File

@ -1,9 +1,9 @@
import { Component, OnInit } from "@angular/core";
import { WakuService } from "../waku.service";
import type { WakuPrivacy } from "@waku/interfaces";
import type { RelayNode } from "@waku/interfaces";
import protobuf from "protobufjs";
import { DecoderV0, EncoderV0 } from "@waku/core/lib/waku_message/version_0";
import type { MessageV0 } from "@waku/core/lib/waku_message/version_0";
import { Decoder, Encoder } from "@waku/core/lib/message/version_0";
import type { DecodedMessage } from "@waku/core/lib/message/version_0";
const ProtoChatMessage = new protobuf.Type("ChatMessage")
.add(new protobuf.Field("timestamp", 1, "uint32"))
@ -21,17 +21,17 @@ interface MessageInterface {
})
export class MessagesComponent implements OnInit {
contentTopic: string = `/js-waku-examples/1/chat/proto`;
decoder: DecoderV0;
encoder: EncoderV0;
decoder: Decoder;
encoder: Encoder;
messages: MessageInterface[] = [];
messageCount: number = 0;
waku!: WakuPrivacy;
waku!: RelayNode;
wakuStatus!: string;
deleteObserver?: () => void;
constructor(private wakuService: WakuService) {
this.decoder = new DecoderV0(this.contentTopic);
this.encoder = new EncoderV0(this.contentTopic);
this.decoder = new Decoder(this.contentTopic);
this.encoder = new Encoder(this.contentTopic);
}
ngOnInit(): void {
@ -69,7 +69,7 @@ export class MessagesComponent implements OnInit {
});
}
processIncomingMessages = (wakuMessage: MessageV0) => {
processIncomingMessages = (wakuMessage: DecodedMessage) => {
if (!wakuMessage.payload) return;
const { text, timestamp } = ProtoChatMessage.decode(

10
examples/relay-angular-chat/src/app/waku.service.ts
View File

@ -1,14 +1,14 @@
import { Injectable } from "@angular/core";
import { BehaviorSubject, Subject } from "rxjs";
import { createPrivacyNode } from "@waku/create";
import { waitForRemotePeer } from "@waku/core/lib/wait_for_remote_peer";
import type { WakuPrivacy } from "@waku/interfaces";
import { createRelayNode } from "@waku/create";
import { waitForRemotePeer } from "@waku/core";
import type { RelayNode } from "@waku/interfaces";
@Injectable({
providedIn: "root",
})
export class WakuService {
private wakuSubject = new Subject<WakuPrivacy>();
private wakuSubject = new Subject<RelayNode>();
public waku = this.wakuSubject.asObservable();
private wakuStatusSubject = new BehaviorSubject("");
@ -17,7 +17,7 @@ export class WakuService {
constructor() {}
init() {
createPrivacyNode({ defaultBootstrap: true }).then((waku) => {
createRelayNode({ defaultBootstrap: true }).then((waku) => {
waku.start().then(() => {
this.wakuSubject.next(waku);
this.wakuStatusSubject.next("Connecting...");