Skip to content

Commit

Permalink
remove unused
Browse files Browse the repository at this point in the history
  • Loading branch information
anhnd350309 committed Feb 18, 2025
1 parent 51f688c commit e993e0b
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 20 deletions.
3 changes: 0 additions & 3 deletions packages/network/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -51,9 +51,6 @@
"@libp2p/webtransport": "^5.0.9",
"@multiformats/multiaddr": "^12.3.1",
"@multiformats/multiaddr-matcher": "^1.6.0",
"@opentelemetry/exporter-prometheus": "^0.57.2",
"@opentelemetry/exporter-trace-otlp-http": "^0.57.1",
"@opentelemetry/sdk-node": "^0.57.2",
"@ts-drp/logger": "^0.7.0",
"it-length-prefixed": "^10.0.0",
"it-map": "^3.1.1",
Expand Down
3 changes: 0 additions & 3 deletions packages/node/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -47,9 +47,6 @@
"@libp2p/crypto": "^5.0.5",
"@libp2p/interface": "^2.1.3",
"@libp2p/opentelemetry-metrics": "^1.0.0",
"@opentelemetry/exporter-prometheus": "^0.57.2",
"@opentelemetry/exporter-trace-otlp-http": "^0.57.1",
"@opentelemetry/sdk-node": "^0.57.2",
"@ts-drp/blueprints": "0.7.0",
"@ts-drp/logger": "0.7.0",
"@ts-drp/network": "0.7.0",
Expand Down
5 changes: 0 additions & 5 deletions packages/node/src/operations.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,8 @@ import { drpMessagesHandler, drpObjectChangesHandler } from "./handlers.js";
import { type DRPNode, log } from "./index.js";

export function createObject(node: DRPNode, object: DRPObject) {
console.log("Creating object", object.id);
node.objectStore.put(object.id, object);
object.subscribe((obj, originFn, vertices) => {
console.log("Perform", Date.now());
drpObjectChangesHandler(node, obj, originFn, vertices);
});
}
Expand Down Expand Up @@ -46,7 +44,6 @@ export async function connectObject(

/* data: { id: string } */
export async function subscribeObject(node: DRPNode, objectId: string) {
console.log("Subscribing to object", objectId);
node.networkNode.subscribe(objectId);
node.networkNode.addGroupMessageHandler(
objectId,
Expand All @@ -60,7 +57,6 @@ export function unsubscribeObject(node: DRPNode, objectId: string, purge?: boole
}

export async function fetchState(node: DRPNode, objectId: string, peerId?: string) {
console.log("fetching state", objectId);
const data = NetworkPb.FetchState.create({
objectId,
vertexHash: HashGraph.rootHash,
Expand All @@ -82,7 +78,6 @@ export async function fetchState(node: DRPNode, objectId: string, peerId?: strin
data: { vertex_hashes: string[] }
*/
export async function syncObject(node: DRPNode, objectId: string, peerId?: string) {
console.log("Syncing object", objectId);
const object: DRPObject | undefined = node.objectStore.get(objectId);
if (!object) {
log.error("::syncObject: Object not found");
Expand Down
9 changes: 0 additions & 9 deletions pnpm-lock.yaml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

0 comments on commit e993e0b

Please sign in to comment.