(() => {
- const persistedNick = window.localStorage.getItem("nick");
- return persistedNick !== null ? persistedNick : generate();
- });
- const [historicalMessagesRetrieved, setHistoricalMessagesRetrieved] =
- useState(false);
-
- useEffect(() => {
- localStorage.setItem("nick", nick);
- }, [nick]);
-
- useEffect(() => {
- initWaku(setWaku)
- .then(() => console.log("Waku init done"))
- .catch((e) => console.log("Waku init failed ", e));
- }, []);
-
- useEffect(() => {
- if (!waku) return;
- // Let's retrieve previous messages before listening to new messages
- if (!historicalMessagesRetrieved) return;
-
- const handleRelayMessage = (wakuMsg: WakuMessage) => {
- console.log("Message received: ", wakuMsg);
- const msg = Message.fromWakuMessage(wakuMsg);
- if (msg) {
- dispatchMessages([msg]);
- }
- };
-
- waku.relay.addObserver(handleRelayMessage, [ChatContentTopic]);
-
- return function cleanUp() {
- waku?.relay.deleteObserver(handleRelayMessage, [ChatContentTopic]);
- };
- }, [waku, historicalMessagesRetrieved]);
-
- useEffect(() => {
- if (!waku) return;
- if (historicalMessagesRetrieved) return;
-
- const retrieveMessages = async () => {
- await waku.waitForRemotePeer();
- console.log(`Retrieving archived messages`);
-
- try {
- retrieveStoreMessages(waku, dispatchMessages).then((length) => {
- console.log(`Messages retrieved:`, length);
- setHistoricalMessagesRetrieved(true);
- });
- } catch (e) {
- console.log(`Error encountered when retrieving archived messages`, e);
- }
- };
-
- retrieveMessages();
- }, [waku, historicalMessagesRetrieved]);
-
- return (
-
-
-
- {
- handleCommand(input, waku, setNick).then(
- ({ command, response }) => {
- const commandMessages = response.map((msg) => {
- return Message.fromUtf8String(command, msg);
- });
- dispatchMessages(commandMessages);
- }
- );
- }}
- />
-
-
-
- );
-}
-
-async function initWaku(setter: (waku: Waku) => void) {
- try {
- const waku = await Waku.create({
- libp2p: {
- config: {
- pubsub: {
- enabled: true,
- emitSelf: true,
- },
- },
- },
- bootstrap: {
- peers: getPredefinedBootstrapNodes(selectFleetEnv()),
- },
- });
-
- setter(waku);
- } catch (e) {
- console.log("Issue starting waku ", e);
- }
-}
-
-function selectFleetEnv() {
- // Works with react-scripts
- if (process?.env?.NODE_ENV === "development") {
- return discovery.predefined.Fleet.Test;
- } else {
- return discovery.predefined.Fleet.Prod;
- }
-}
-
-function reduceMessages(state: Message[], newMessages: Message[]) {
- return state.concat(newMessages);
-}
diff --git a/examples/web-chat/src/ChatList.tsx b/examples/web-chat/src/ChatList.tsx
deleted file mode 100644
index 76fee78a14..0000000000
--- a/examples/web-chat/src/ChatList.tsx
+++ /dev/null
@@ -1,61 +0,0 @@
-import { memo, useEffect, useRef } from "react";
-import {
- Message as LiveMessage,
- MessageText,
- MessageList,
-} from "@livechat/ui-kit";
-import { Message } from "./Message";
-
-interface Props {
- messages: Message[];
-}
-
-memo(ChatList);
-
-export default function ChatList(props: Props) {
- const renderedMessages = props.messages.map((message) => (
-
- {message.payloadAsUtf8}
-
- ));
-
- return (
-
- {renderedMessages}
-
-
- );
-}
-
-function formatDisplayDate(message: Message): string {
- return message.timestamp.toLocaleString([], {
- month: "short",
- day: "numeric",
- hour: "numeric",
- minute: "2-digit",
- hour12: false,
- });
-}
-
-const AlwaysScrollToBottom = (props: { messages: Message[] }) => {
- const elementRef = useRef();
-
- useEffect(() => {
- // @ts-ignore
- elementRef.current.scrollIntoView();
- }, [props.messages]);
-
- // @ts-ignore
- return ;
-};
diff --git a/examples/web-chat/src/Message.ts b/examples/web-chat/src/Message.ts
deleted file mode 100644
index 36407e4fda..0000000000
--- a/examples/web-chat/src/Message.ts
+++ /dev/null
@@ -1,44 +0,0 @@
-import { WakuMessage } from "js-waku";
-import { ChatMessage } from "./chat_message";
-
-export class Message {
- public chatMessage: ChatMessage;
- // WakuMessage timestamp
- public sentTimestamp: Date | undefined;
-
- constructor(chatMessage: ChatMessage, sentTimestamp: Date | undefined) {
- this.chatMessage = chatMessage;
- this.sentTimestamp = sentTimestamp;
- }
-
- static fromWakuMessage(wakuMsg: WakuMessage): Message | undefined {
- if (wakuMsg.payload) {
- try {
- const chatMsg = ChatMessage.decode(wakuMsg.payload);
- if (chatMsg) {
- return new Message(chatMsg, wakuMsg.timestamp);
- }
- } catch (e) {
- console.error("Failed to decode chat message", e);
- }
- }
- return;
- }
-
- static fromUtf8String(nick: string, text: string): Message {
- const now = new Date();
- return new Message(ChatMessage.fromUtf8String(now, nick, text), now);
- }
-
- get nick() {
- return this.chatMessage.nick;
- }
-
- get timestamp() {
- return this.chatMessage.timestamp;
- }
-
- get payloadAsUtf8() {
- return this.chatMessage.payloadAsUtf8;
- }
-}
diff --git a/examples/web-chat/src/MessageInput.tsx b/examples/web-chat/src/MessageInput.tsx
deleted file mode 100644
index f944f0eac8..0000000000
--- a/examples/web-chat/src/MessageInput.tsx
+++ /dev/null
@@ -1,63 +0,0 @@
-import { ChangeEvent, KeyboardEvent, useState } from "react";
-import { useWaku } from "./WakuContext";
-import {
- TextInput,
- TextComposer,
- Row,
- Fill,
- Fit,
- SendButton,
-} from "@livechat/ui-kit";
-
-interface Props {
- sendMessage: ((msg: string) => Promise) | undefined;
-}
-
-export default function MessageInput(props: Props) {
- const [inputText, setInputText] = useState("");
- const { waku } = useWaku();
-
- const sendMessage = async () => {
- if (props.sendMessage) {
- await props.sendMessage(inputText);
- setInputText("");
- }
- };
-
- const messageHandler = (event: ChangeEvent) => {
- setInputText(event.target.value);
- };
-
- const keyPressHandler = async (event: KeyboardEvent) => {
- if (
- event.key === "Enter" &&
- !event.altKey &&
- !event.ctrlKey &&
- !event.shiftKey
- ) {
- await sendMessage();
- }
- };
-
- // Enable the button if there are relay peers available or the user is sending a command
- const activeButton =
- (waku && waku.relay.getPeers().size !== 0) || inputText.startsWith("/");
-
- return (
-
-
-
-
-
-
-
-
-
-
- );
-}
diff --git a/examples/web-chat/src/Room.tsx b/examples/web-chat/src/Room.tsx
deleted file mode 100644
index f1255f48e9..0000000000
--- a/examples/web-chat/src/Room.tsx
+++ /dev/null
@@ -1,92 +0,0 @@
-import { WakuMessage } from "js-waku";
-import { ChatContentTopic } from "./App";
-import ChatList from "./ChatList";
-import MessageInput from "./MessageInput";
-import { useWaku } from "./WakuContext";
-import { TitleBar } from "@livechat/ui-kit";
-import { Message } from "./Message";
-import { ChatMessage } from "./chat_message";
-import { useEffect, useState } from "react";
-
-interface Props {
- messages: Message[];
- commandHandler: (cmd: string) => void;
- nick: string;
-}
-
-export default function Room(props: Props) {
- const { waku } = useWaku();
-
- const [storePeers, setStorePeers] = useState(0);
- const [relayPeers, setRelayPeers] = useState(0);
-
- useEffect(() => {
- if (!waku) return;
-
- // Update relay peer count on heartbeat
- waku.relay.on("gossipsub:heartbeat", () => {
- setRelayPeers(waku.relay.getPeers().size);
- });
- }, [waku]);
-
- useEffect(() => {
- if (!waku) return;
-
- // Update store peer when new peer connected & identified
- waku.libp2p.peerStore.on("change:protocols", async () => {
- let counter = 0;
- // eslint-disable-next-line @typescript-eslint/no-unused-vars
- for await (const _peer of waku.store.peers) {
- counter++;
- }
- setStorePeers(counter);
- });
- }, [waku]);
-
- return (
-
-
-
- {
- return handleMessage(
- messageToSend,
- props.nick,
- props.commandHandler,
- waku.relay.send.bind(waku.relay)
- );
- }
- : undefined
- }
- />
-
- );
-}
-
-async function handleMessage(
- message: string,
- nick: string,
- commandHandler: (cmd: string) => void,
- messageSender: (msg: WakuMessage) => Promise
-) {
- if (message.startsWith("/")) {
- commandHandler(message);
- } else {
- const timestamp = new Date();
- const chatMessage = ChatMessage.fromUtf8String(timestamp, nick, message);
- const wakuMsg = await WakuMessage.fromBytes(
- chatMessage.encode(),
- ChatContentTopic,
- { timestamp }
- );
- return messageSender(wakuMsg);
- }
-}
diff --git a/examples/web-chat/src/WakuContext.ts b/examples/web-chat/src/WakuContext.ts
deleted file mode 100644
index 86a6a7c172..0000000000
--- a/examples/web-chat/src/WakuContext.ts
+++ /dev/null
@@ -1,9 +0,0 @@
-import { createContext, useContext } from "react";
-import { Waku } from "js-waku";
-
-export type WakuContextType = {
- waku?: Waku;
-};
-
-export const WakuContext = createContext({ waku: undefined });
-export const useWaku = () => useContext(WakuContext);
diff --git a/examples/web-chat/src/WakuMock.test.ts b/examples/web-chat/src/WakuMock.test.ts
deleted file mode 100644
index 81d87d0559..0000000000
--- a/examples/web-chat/src/WakuMock.test.ts
+++ /dev/null
@@ -1,30 +0,0 @@
-import WakuMock, { Message } from "./WakuMock";
-
-test("Messages are emitted", async () => {
- const wakuMock = await WakuMock.create();
-
- let message: Message;
- wakuMock.on("message", (msg) => {
- message = msg;
- });
-
- await new Promise((resolve) => setTimeout(resolve, 2000));
- // @ts-ignore
- expect(message.message).toBeDefined();
-});
-
-test("Messages are sent", async () => {
- const wakuMock = await WakuMock.create();
-
- const text = "This is a message.";
-
- let message: Message;
- wakuMock.on("message", (msg) => {
- message = msg;
- });
-
- await wakuMock.send(text);
-
- // @ts-ignore
- expect(message.message).toEqual(text);
-});
diff --git a/examples/web-chat/src/WakuMock.ts b/examples/web-chat/src/WakuMock.ts
deleted file mode 100644
index d887d88866..0000000000
--- a/examples/web-chat/src/WakuMock.ts
+++ /dev/null
@@ -1,69 +0,0 @@
-class EventEmitter {
- public callbacks: { [key: string]: Array<(data: T) => void> };
-
- constructor() {
- this.callbacks = {};
- }
-
- on(event: string, cb: (data: T) => void) {
- if (!this.callbacks[event]) this.callbacks[event] = [];
- this.callbacks[event].push(cb);
- }
-
- emit(event: string, data: T) {
- let cbs = this.callbacks[event];
- if (cbs) {
- cbs.forEach((cb) => cb(data));
- }
- }
-}
-
-export interface Message {
- timestamp: Date;
- handle: string;
- message: string;
-}
-
-export default class WakuMock extends EventEmitter {
- index: number;
- intervalId?: number | NodeJS.Timeout;
-
- private constructor() {
- super();
- this.index = 0;
- }
-
- public static async create(): Promise {
- await new Promise((resolve) => setTimeout(resolve, 500));
-
- const wakuMock = new WakuMock();
- wakuMock.startInterval();
- return wakuMock;
- }
-
- public async send(message: string): Promise {
- const timestamp = new Date();
- const handle = "me";
- this.emit("message", {
- timestamp,
- handle,
- message,
- });
- }
-
- private startInterval() {
- if (this.intervalId === undefined) {
- this.intervalId = setInterval(this.emitMessage.bind(this), 1000);
- }
- }
-
- private emitMessage() {
- const handle = "you";
- const timestamp = new Date();
- this.emit("message", {
- timestamp,
- handle,
- message: `This is message #${this.index++}.`,
- });
- }
-}
diff --git a/examples/web-chat/src/chat_message.ts b/examples/web-chat/src/chat_message.ts
deleted file mode 100644
index 757059dde8..0000000000
--- a/examples/web-chat/src/chat_message.ts
+++ /dev/null
@@ -1,65 +0,0 @@
-import { Reader } from "protobufjs/minimal";
-
-import * as proto from "./proto/chat_message";
-
-/**
- * ChatMessage is used by the various show case waku apps that demonstrates
- * waku used as the network layer for chat group applications.
- *
- * This is included to help building PoC and MVPs. Apps that aim to be
- * production ready should use a more appropriate data structure.
- */
-export class ChatMessage {
- public constructor(public proto: proto.ChatMessage) {}
-
- /**
- * Create Chat Message with a utf-8 string as payload.
- */
- static fromUtf8String(
- timestamp: Date,
- nick: string,
- text: string
- ): ChatMessage {
- const timestampNumber = Math.floor(timestamp.valueOf() / 1000);
- const payload = Buffer.from(text, "utf-8");
-
- return new ChatMessage({
- timestamp: timestampNumber,
- nick,
- payload,
- });
- }
-
- /**
- * Decode a protobuf payload to a ChatMessage.
- * @param bytes The payload to decode.
- */
- static decode(bytes: Uint8Array): ChatMessage {
- const protoMsg = proto.ChatMessage.decode(Reader.create(bytes));
- return new ChatMessage(protoMsg);
- }
-
- /**
- * Encode this ChatMessage to a byte array, to be used as a protobuf payload.
- * @returns The encoded payload.
- */
- encode(): Uint8Array {
- return proto.ChatMessage.encode(this.proto).finish();
- }
-
- get timestamp(): Date {
- return new Date(this.proto.timestamp * 1000);
- }
-
- get nick(): string {
- return this.proto.nick;
- }
-
- get payloadAsUtf8(): string {
- if (!this.proto.payload) {
- return "";
- }
-
- return Buffer.from(this.proto.payload).toString("utf-8");
- }
-}
diff --git a/examples/web-chat/src/command.ts b/examples/web-chat/src/command.ts
deleted file mode 100644
index cd7b1beb41..0000000000
--- a/examples/web-chat/src/command.ts
+++ /dev/null
@@ -1,148 +0,0 @@
-import { multiaddr } from "multiaddr";
-import PeerId from "peer-id";
-import { Waku } from "js-waku";
-
-function help(): string[] {
- return [
- "/nick : set a new nickname",
- "/info: some information about the node",
- "/connect : connect to the given peer",
- "/help: Display this help",
- ];
-}
-
-function nick(
- nick: string | undefined,
- setNick: (nick: string) => void
-): string[] {
- if (!nick) {
- return ["No nick provided"];
- }
- setNick(nick);
- return [`New nick: ${nick}`];
-}
-
-function info(waku: Waku | undefined): string[] {
- if (!waku) {
- return ["Waku node is starting"];
- }
- return [`PeerId: ${waku.libp2p.peerId.toString()}`];
-}
-
-function connect(peer: string | undefined, waku: Waku | undefined): string[] {
- if (!waku) {
- return ["Waku node is starting"];
- }
- if (!peer) {
- return ["No peer provided"];
- }
- try {
- const peerMultiaddr = multiaddr(peer);
- const peerId = peerMultiaddr.getPeerId();
- if (!peerId) {
- return ["Peer Id needed to dial"];
- }
- waku.addPeerToAddressBook(PeerId.createFromB58String(peerId), [
- peerMultiaddr,
- ]);
- return [
- `${peerId}: ${peerMultiaddr.toString()} added to address book, autodial in progress`,
- ];
- } catch (e) {
- return ["Invalid multiaddr: " + e];
- }
-}
-
-async function peers(waku: Waku | undefined): Promise {
- if (!waku) {
- return ["Waku node is starting"];
- }
- let response: string[] = [];
- const peers = [];
-
- for await (const peer of waku.libp2p.peerStore.getPeers()) {
- peers.push(peer);
- }
- Array.from(peers).forEach((peer) => {
- response.push(peer.id.toString() + ":");
- let addresses = " addresses: [";
- peer.addresses.forEach(({ multiaddr }) => {
- addresses += " " + multiaddr.toString() + ",";
- });
- addresses = addresses.replace(/,$/, "");
- addresses += "]";
- response.push(addresses);
- let protocols = " protocols: [";
- protocols += peer.protocols;
- protocols += "]";
- response.push(protocols);
- });
- if (response.length === 0) {
- response.push("Not connected to any peer.");
- }
- return response;
-}
-
-function connections(waku: Waku | undefined): string[] {
- if (!waku) {
- return ["Waku node is starting"];
- }
- let response: string[] = [];
- waku.libp2p.connections.forEach(
- (
- connections: import("libp2p-interfaces/src/connection/connection")[],
- peerId
- ) => {
- response.push(peerId + ":");
- let strConnections = " connections: [";
- connections.forEach((connection) => {
- strConnections += JSON.stringify(connection.stat);
- strConnections += "; " + JSON.stringify(connection.streams);
- });
- strConnections += "]";
- response.push(strConnections);
- }
- );
- if (response.length === 0) {
- response.push("Not connected to any peer.");
- }
- return response;
-}
-
-export default async function handleCommand(
- input: string,
- waku: Waku | undefined,
- setNick: (nick: string) => void
-): Promise<{ command: string; response: string[] }> {
- let response: string[] = [];
- const args = parseInput(input);
- const command = args.shift()!;
- switch (command) {
- case "/help":
- help().map((str) => response.push(str));
- break;
- case "/nick":
- nick(args.shift(), setNick).map((str) => response.push(str));
- break;
- case "/info":
- info(waku).map((str) => response.push(str));
- break;
- case "/connect":
- connect(args.shift(), waku).map((str) => response.push(str));
- break;
- case "/peers":
- (await peers(waku)).map((str) => response.push(str));
- break;
- case "/connections":
- connections(waku).map((str) => response.push(str));
- break;
- default:
- response.push(`Unknown Command '${command}'`);
- }
- return { command, response };
-}
-
-export function parseInput(input: string): string[] {
- const clean = input.trim().replaceAll(/\s\s+/g, " ");
- return clean.split(" ");
-}
diff --git a/examples/web-chat/src/index.css b/examples/web-chat/src/index.css
deleted file mode 100644
index a16a6141ff..0000000000
--- a/examples/web-chat/src/index.css
+++ /dev/null
@@ -1,30 +0,0 @@
-@import-normalize; /* bring in normalize.css styles */
-
-body {
- margin: 0;
- font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'Roboto', 'Oxygen',
- 'Ubuntu', 'Cantarell', 'Fira Sans', 'Droid Sans', 'Helvetica Neue',
- sans-serif;
- -webkit-font-smoothing: antialiased;
- -moz-osx-font-smoothing: grayscale;
-}
-
-code {
- font-family: source-code-pro, Menlo, Monaco, Consolas, 'Courier New',
- monospace;
-}
-
-.room-row {
- text-align: left;
- margin-left: 20px;
-}
-
-.room-row:after {
- clear: both;
- content: "";
- display: table;
-}
-
-.chat-room{
- margin: 2px;
-}
diff --git a/examples/web-chat/src/index.tsx b/examples/web-chat/src/index.tsx
deleted file mode 100644
index 846ed2ced3..0000000000
--- a/examples/web-chat/src/index.tsx
+++ /dev/null
@@ -1,11 +0,0 @@
-import React from "react";
-import ReactDOM from "react-dom";
-import "./index.css";
-import App from "./App";
-
-ReactDOM.render(
-
-
- ,
- document.getElementById("root")
-);
diff --git a/examples/web-chat/src/proto/chat_message.proto b/examples/web-chat/src/proto/chat_message.proto
deleted file mode 100644
index 666e094ad7..0000000000
--- a/examples/web-chat/src/proto/chat_message.proto
+++ /dev/null
@@ -1,7 +0,0 @@
-syntax = "proto3";
-
-message ChatMessage {
- uint64 timestamp = 1;
- string nick = 2;
- bytes payload = 3;
-}
diff --git a/examples/web-chat/src/proto/chat_message.ts b/examples/web-chat/src/proto/chat_message.ts
deleted file mode 100644
index 4a0621b896..0000000000
--- a/examples/web-chat/src/proto/chat_message.ts
+++ /dev/null
@@ -1,169 +0,0 @@
-/* eslint-disable */
-import Long from "long";
-import _m0 from "protobufjs/minimal";
-
-export const protobufPackage = "";
-
-export interface ChatMessage {
- timestamp: number;
- nick: string;
- payload: Uint8Array;
-}
-
-function createBaseChatMessage(): ChatMessage {
- return { timestamp: 0, nick: "", payload: new Uint8Array() };
-}
-
-export const ChatMessage = {
- encode(
- message: ChatMessage,
- writer: _m0.Writer = _m0.Writer.create()
- ): _m0.Writer {
- if (message.timestamp !== 0) {
- writer.uint32(8).uint64(message.timestamp);
- }
- if (message.nick !== "") {
- writer.uint32(18).string(message.nick);
- }
- if (message.payload.length !== 0) {
- writer.uint32(26).bytes(message.payload);
- }
- return writer;
- },
-
- decode(input: _m0.Reader | Uint8Array, length?: number): ChatMessage {
- const reader = input instanceof _m0.Reader ? input : new _m0.Reader(input);
- let end = length === undefined ? reader.len : reader.pos + length;
- const message = createBaseChatMessage();
- while (reader.pos < end) {
- const tag = reader.uint32();
- switch (tag >>> 3) {
- case 1:
- message.timestamp = longToNumber(reader.uint64() as Long);
- break;
- case 2:
- message.nick = reader.string();
- break;
- case 3:
- message.payload = reader.bytes();
- break;
- default:
- reader.skipType(tag & 7);
- break;
- }
- }
- return message;
- },
-
- fromJSON(object: any): ChatMessage {
- const message = createBaseChatMessage();
- message.timestamp =
- object.timestamp !== undefined && object.timestamp !== null
- ? Number(object.timestamp)
- : 0;
- message.nick =
- object.nick !== undefined && object.nick !== null
- ? String(object.nick)
- : "";
- message.payload =
- object.payload !== undefined && object.payload !== null
- ? bytesFromBase64(object.payload)
- : new Uint8Array();
- return message;
- },
-
- toJSON(message: ChatMessage): unknown {
- const obj: any = {};
- message.timestamp !== undefined &&
- (obj.timestamp = Math.round(message.timestamp));
- message.nick !== undefined && (obj.nick = message.nick);
- message.payload !== undefined &&
- (obj.payload = base64FromBytes(
- message.payload !== undefined ? message.payload : new Uint8Array()
- ));
- return obj;
- },
-
- fromPartial, I>>(
- object: I
- ): ChatMessage {
- const message = createBaseChatMessage();
- message.timestamp = object.timestamp ?? 0;
- message.nick = object.nick ?? "";
- message.payload = object.payload ?? new Uint8Array();
- return message;
- },
-};
-
-declare var self: any | undefined;
-declare var window: any | undefined;
-declare var global: any | undefined;
-var globalThis: any = (() => {
- if (typeof globalThis !== "undefined") return globalThis;
- if (typeof self !== "undefined") return self;
- if (typeof window !== "undefined") return window;
- if (typeof global !== "undefined") return global;
- throw "Unable to locate global object";
-})();
-
-const atob: (b64: string) => string =
- globalThis.atob ||
- ((b64) => globalThis.Buffer.from(b64, "base64").toString("binary"));
-function bytesFromBase64(b64: string): Uint8Array {
- const bin = atob(b64);
- const arr = new Uint8Array(bin.length);
- for (let i = 0; i < bin.length; ++i) {
- arr[i] = bin.charCodeAt(i);
- }
- return arr;
-}
-
-const btoa: (bin: string) => string =
- globalThis.btoa ||
- ((bin) => globalThis.Buffer.from(bin, "binary").toString("base64"));
-function base64FromBytes(arr: Uint8Array): string {
- const bin: string[] = [];
- for (const byte of arr) {
- bin.push(String.fromCharCode(byte));
- }
- return btoa(bin.join(""));
-}
-
-type Builtin =
- | Date
- | Function
- | Uint8Array
- | string
- | number
- | boolean
- | undefined;
-
-export type DeepPartial = T extends Builtin
- ? T
- : T extends Array
- ? Array>
- : T extends ReadonlyArray
- ? ReadonlyArray>
- : T extends {}
- ? { [K in keyof T]?: DeepPartial }
- : Partial;
-
-type KeysOfUnion = T extends T ? keyof T : never;
-export type Exact = P extends Builtin
- ? P
- : P & { [K in keyof P]: Exact } & Record<
- Exclude>,
- never
- >;
-
-function longToNumber(long: Long): number {
- if (long.gt(Number.MAX_SAFE_INTEGER)) {
- throw new globalThis.Error("Value is larger than Number.MAX_SAFE_INTEGER");
- }
- return long.toNumber();
-}
-
-if (_m0.util.Long !== Long) {
- _m0.util.Long = Long as any;
- _m0.configure();
-}
diff --git a/examples/web-chat/src/react-app-env.d.ts b/examples/web-chat/src/react-app-env.d.ts
deleted file mode 100644
index 6431bc5fc6..0000000000
--- a/examples/web-chat/src/react-app-env.d.ts
+++ /dev/null
@@ -1 +0,0 @@
-///
diff --git a/examples/web-chat/src/setupTests.ts b/examples/web-chat/src/setupTests.ts
deleted file mode 100644
index 1dd407a63e..0000000000
--- a/examples/web-chat/src/setupTests.ts
+++ /dev/null
@@ -1,5 +0,0 @@
-// jest-dom adds custom jest matchers for asserting on DOM nodes.
-// allows you to do things like:
-// expect(element).toHaveTextContent(/react/i)
-// learn more: https://github.com/testing-library/jest-dom
-import "@testing-library/jest-dom";
diff --git a/examples/web-chat/src/types/types.d.ts b/examples/web-chat/src/types/types.d.ts
deleted file mode 100644
index 6109448386..0000000000
--- a/examples/web-chat/src/types/types.d.ts
+++ /dev/null
@@ -1 +0,0 @@
-declare module "@livechat/ui-kit";
diff --git a/examples/web-chat/tsconfig.json b/examples/web-chat/tsconfig.json
deleted file mode 100644
index 637a5aa4ad..0000000000
--- a/examples/web-chat/tsconfig.json
+++ /dev/null
@@ -1,24 +0,0 @@
-{
- "compilerOptions": {
- "incremental": true,
- "target": "es2020",
- "lib": ["dom", "dom.iterable", "esnext"],
- "allowJs": true,
- "skipLibCheck": true,
- "esModuleInterop": true,
- "allowSyntheticDefaultImports": true,
- "strict": true,
- "forceConsistentCasingInFileNames": true,
- "noUnusedLocals": true,
- "noUnusedParameters": true,
- "noFallthroughCasesInSwitch": true,
- "module": "esnext",
- "moduleResolution": "node",
- "resolveJsonModule": true,
- "isolatedModules": true,
- "noEmit": true,
- "jsx": "react-jsx",
- "typeRoots": ["node_modules/@types", "src/types"]
- },
- "include": ["src"]
-}
diff --git a/package.json b/package.json
index 9e80fce25e..7bc0a3bf60 100644
--- a/package.json
+++ b/package.json
@@ -60,7 +60,6 @@
"pretest": "run-s pretest:*",
"pretest:1-init-git-submodules": "[ -f './nwaku/build/wakunode2' ] || git submodule update --init --recursive",
"pretest:2-build-nwaku": "[ -f './nwaku/build/wakunode2' ] || run-s nwaku:build",
- "examples:pretest": "for d in examples/*/; do (cd $d && npm ci); done",
"nwaku:build": "(cd nwaku; NIMFLAGS=\"-d:chronicles_colors=off -d:chronicles_sinks=textlines -d:chronicles_log_level=TRACE\" make -j$(nproc --all 2>/dev/null || echo 2) wakunode2)",
"nwaku:force-build": "(cd nwaku && rm -rf ./build/ ./vendor && make -j$(nproc --all 2>/dev/null || echo 2) update) && run-s nwaku:build",
"test": "run-s test:*",
@@ -70,17 +69,15 @@
"test:tsc": "tsc -p tsconfig.dev.json",
"test:node": "TS_NODE_PROJECT=./tsconfig.dev.json mocha",
"test:browser": "karma start karma.conf.cjs",
- "examples:test": "run-s examples:pretest; for d in examples/*/; do (cd $d && npm test;); done",
"proto": "rimraf src/proto/*.ts; protons src/proto/*.proto",
"watch:build": "tsc -p tsconfig.json -w",
"watch:test": "mocha --watch",
"doc": "run-s doc:*",
"doc:html": "typedoc --treatWarningsAsErrors",
"doc:cname": "echo 'js-waku.wakuconnect.dev' > build/docs/CNAME",
- "doc:examples": "mkdir -p build/docs/examples",
"prepublish": "npm run build",
"deploy": "node ci/deploy.js",
- "reset-hard": "git clean -dfx && git reset --hard && npm i && npm run build && for d in examples/*/; do (cd $d; npm i); done"
+ "reset-hard": "git clean -dfx -e .idea && git reset --hard && npm i && npm run build"
},
"browser": {
"crypto": false