dist/rpc.d.ts

@@ -27,6 +27,16 @@ export interface RPCCacheItem extends RPCResponse {
   value: RPCResponse;
   signature: string;
 }
+export interface RPCClearCacheRequest {
+  request: string;
+  relays?: string[];
+}
+export declare type RPCClearCacheResponseRelayList = {
+  [relay: string]: RPCClearCacheResponse;
+};
+export interface RPCClearCacheResponse extends RPCResponse {
+  relays?: RPCClearCacheResponseRelayList;
+}
 export interface RPCBroadcastRequest {
   request: RPCRequest;
   relays: string[];
@@ -51,6 +61,7 @@ export declare class RPCServer extends EventEmitter {
 export declare class RPCCache extends EventEmitter {
   get data(): RPCCacheData;
   constructor(server: RPCServer);
+  getNodeQuery(node: string, queryHash: string): Promise<boolean | RPCResponse>;
   signResponse(item: RPCCacheItem): any;
   verifyResponse(pubkey: Buffer, item: RPCCacheItem): boolean | Buffer;
   addItem(query: RPCRequest, response: RPCResponse): void;

dist/rpc.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"rpc.d.ts","sourceRoot":"","sources":["../src/rpc.ts"],"names":[],"mappings":";;AAAA,OAAO,KAAK,YAAY,MAAM,QAAQ,CAAC;AAEvC,MAAM,WAAW,UAAU;IACzB,MAAM,EAAE,MAAM,CAAC;IACf,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,GAAG,CAAC;CACX;AAED,MAAM,WAAW,gBAAiB,SAAQ,UAAU;IAClD,WAAW,CAAC,EAAE,OAAO,CAAC;CACvB;AAED,MAAM,WAAW,WAAW;IAC1B,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,IAAI,CAAC,EAAE,GAAG,GAAG,WAAW,CAAC;IACzB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,MAAM,WAAW,SAAS;IACxB,SAAS,EAAE,OAAO,CAAC;IACnB,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,KAAK,OAAO,CAAC,GAAG,CAAC,CAAC;CACrC;AAED,MAAM,WAAW,YAAY;IAC3B,CAAC,KAAK,EAAE,MAAM,GAAG,YAAY,GAAG,IAAI,CAAC;CACtC;AAED,MAAM,WAAW,YAAa,SAAQ,WAAW;IAC/C,KAAK,EAAE,WAAW,CAAC;IACnB,SAAS,EAAE,MAAM,CAAC;CACnB;AAED,MAAM,WAAW,mBAAmB;IAClC,OAAO,EAAE,UAAU,CAAC;IACpB,MAAM,EAAE,MAAM,EAAE,CAAC;CAClB;AAED,MAAM,WAAW,oBAAqB,SAAQ,WAAW;IACvD,MAAM,EAAE;QAAE,CAAC,KAAK,EAAE,MAAM,GAAG,WAAW,CAAA;KAAE,CAAC;CAC1C;AAED,MAAM,CAAC,OAAO,OAAO,SAAU,SAAQ,YAAY;IACjD,IAAI,KAAK,IAAI,QAAQ,CAAC;IACtB,cAAc,CACZ,UAAU,EAAE,MAAM,EAClB,UAAU,EAAE,MAAM,EAClB,OAAO,EAAE,SAAS,GACjB,IAAI;IACA,UAAU,IAAI,MAAM,EAAE;IACtB,KAAK,CAAC,MAAM,EAAE,GAAG,GAAG,GAAG;IACvB,QAAQ,CAAC,IAAI,EAAE,GAAG,GAAG,MAAM;WACpB,SAAS,CAAC,KAAK,EAAE,UAAU,GAAG,MAAM;CACnD;AACD,MAAM,CAAC,OAAO,OAAO,QAAS,SAAQ,YAAY;IAChD,IAAI,IAAI,IAAI,YAAY,CAAC;gBACb,MAAM,EAAE,SAAS;IACtB,YAAY,CAAC,IAAI,EAAE,YAAY,GAAG,GAAG;IACrC,cAAc,CAAC,MAAM,EAAE,MAAM,EAAE,IAAI,EAAE,YAAY,GAAG,OAAO,GAAG,MAAM;IACpE,OAAO,CAAC,KAAK,EAAE,UAAU,EAAE,QAAQ,EAAE,WAAW,GAAG,IAAI;IACvD,UAAU,CAAC,SAAS,EAAE,MAAM,GAAG,OAAO;CAC9C"}
+{"version":3,"file":"rpc.d.ts","sourceRoot":"","sources":["../src/rpc.ts"],"names":[],"mappings":";;AAAA,OAAO,KAAK,YAAY,MAAM,QAAQ,CAAC;AAEvC,MAAM,WAAW,UAAU;IACzB,MAAM,EAAE,MAAM,CAAC;IACf,MAAM,EAAE,MAAM,CAAC;IACf,IAAI,EAAE,GAAG,CAAC;CACX;AAED,MAAM,WAAW,gBAAiB,SAAQ,UAAU;IAClD,WAAW,CAAC,EAAE,OAAO,CAAC;CACvB;AAED,MAAM,WAAW,WAAW;IAC1B,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,IAAI,CAAC,EAAE,GAAG,GAAG,WAAW,CAAC;IACzB,KAAK,CAAC,EAAE,MAAM,CAAC;IACf,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,WAAW,CAAC,EAAE,MAAM,CAAC;CACtB;AAED,MAAM,WAAW,SAAS;IACxB,SAAS,EAAE,OAAO,CAAC;IACnB,OAAO,EAAE,CAAC,GAAG,EAAE,GAAG,KAAK,OAAO,CAAC,GAAG,CAAC,CAAC;CACrC;AAED,MAAM,WAAW,YAAY;IAC3B,CAAC,KAAK,EAAE,MAAM,GAAG,YAAY,GAAG,IAAI,CAAC;CACtC;AAED,MAAM,WAAW,YAAa,SAAQ,WAAW;IAC/C,KAAK,EAAE,WAAW,CAAC;IACnB,SAAS,EAAE,MAAM,CAAC;CACnB;AAED,MAAM,WAAW,oBAAoB;IACnC,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC;CACnB;AAED,oBAAY,8BAA8B,GAAG;IAC3C,CAAC,KAAK,EAAE,MAAM,GAAG,qBAAqB,CAAC;CACxC,CAAC;AAEF,MAAM,WAAW,qBAAsB,SAAQ,WAAW;IACxD,MAAM,CAAC,EAAE,8BAA8B,CAAC;CACzC;AAED,MAAM,WAAW,mBAAmB;IAClC,OAAO,EAAE,UAAU,CAAC;IACpB,MAAM,EAAE,MAAM,EAAE,CAAC;CAClB;AAED,MAAM,WAAW,oBAAqB,SAAQ,WAAW;IACvD,MAAM,EAAE;QAAE,CAAC,KAAK,EAAE,MAAM,GAAG,WAAW,CAAA;KAAE,CAAC;CAC1C;AAED,MAAM,CAAC,OAAO,OAAO,SAAU,SAAQ,YAAY;IACjD,IAAI,KAAK,IAAI,QAAQ,CAAC;IACtB,cAAc,CACZ,UAAU,EAAE,MAAM,EAClB,UAAU,EAAE,MAAM,EAClB,OAAO,EAAE,SAAS,GACjB,IAAI;IACA,UAAU,IAAI,MAAM,EAAE;IACtB,KAAK,CAAC,MAAM,EAAE,GAAG,GAAG,GAAG;IACvB,QAAQ,CAAC,IAAI,EAAE,GAAG,GAAG,MAAM;WACpB,SAAS,CAAC,KAAK,EAAE,UAAU,GAAG,MAAM;CACnD;AACD,MAAM,CAAC,OAAO,OAAO,QAAS,SAAQ,YAAY;IAChD,IAAI,IAAI,IAAI,YAAY,CAAC;gBACb,MAAM,EAAE,SAAS;IACtB,YAAY,CACjB,IAAI,EAAE,MAAM,EACZ,SAAS,EAAE,MAAM,GAChB,OAAO,CAAC,OAAO,GAAG,WAAW,CAAC;IAC1B,YAAY,CAAC,IAAI,EAAE,YAAY,GAAG,GAAG;IACrC,cAAc,CAAC,MAAM,EAAE,MAAM,EAAE,IAAI,EAAE,YAAY,GAAG,OAAO,GAAG,MAAM;IACpE,OAAO,CAAC,KAAK,EAAE,UAAU,EAAE,QAAQ,EAAE,WAAW,GAAG,IAAI;IACvD,UAAU,CAAC,SAAS,EAAE,MAAM,GAAG,OAAO;CAC9C"}

src/rpc.ts

@@ -32,6 +32,19 @@ export interface RPCCacheItem extends RPCResponse {
   signature: string;
 }
 
+export interface RPCClearCacheRequest {
+  request: string;
+  relays?: string[];
+}
+
+export type RPCClearCacheResponseRelayList = {
+  [relay: string]: RPCClearCacheResponse;
+};
+
+export interface RPCClearCacheResponse extends RPCResponse {
+  relays?: RPCClearCacheResponseRelayList;
+}
+
 export interface RPCBroadcastRequest {
   request: RPCRequest;
   relays: string[];
@@ -56,6 +69,10 @@ export declare class RPCServer extends EventEmitter {
 export declare class RPCCache extends EventEmitter {
   get data(): RPCCacheData;
   constructor(server: RPCServer);
+  public getNodeQuery(
+    node: string,
+    queryHash: string
+  ): Promise<boolean | RPCResponse>;
   public signResponse(item: RPCCacheItem): any;
   public verifyResponse(pubkey: Buffer, item: RPCCacheItem): boolean | Buffer;
   public addItem(query: RPCRequest, response: RPCResponse): void;