@textile/buckets-grpc - npm Package Compare versions

Comparing version 1.0.3 to 1.0.4-rc1

buckets_pb_service.d.ts

@@ -79,2 +79,38 @@ // package: buckets.pb
 
+type APIArchive = {
+  readonly methodName: string;
+  readonly service: typeof API;
+  readonly requestStream: false;
+  readonly responseStream: false;
+  readonly requestType: typeof buckets_pb.ArchiveRequest;
+  readonly responseType: typeof buckets_pb.ArchiveReply;
+};
+
+type APIArchiveStatus = {
+  readonly methodName: string;
+  readonly service: typeof API;
+  readonly requestStream: false;
+  readonly responseStream: false;
+  readonly requestType: typeof buckets_pb.ArchiveStatusRequest;
+  readonly responseType: typeof buckets_pb.ArchiveStatusReply;
+};
+
+type APIArchiveInfo = {
+  readonly methodName: string;
+  readonly service: typeof API;
+  readonly requestStream: false;
+  readonly responseStream: false;
+  readonly requestType: typeof buckets_pb.ArchiveInfoRequest;
+  readonly responseType: typeof buckets_pb.ArchiveInfoReply;
+};
+
+type APIArchiveWatch = {
+  readonly methodName: string;
+  readonly service: typeof API;
+  readonly requestStream: false;
+  readonly responseStream: true;
+  readonly requestType: typeof buckets_pb.ArchiveWatchRequest;
+  readonly responseType: typeof buckets_pb.ArchiveWatchReply;
+};
+
 export class API {
@@ -90,2 +126,6 @@ static readonly serviceName: string;
   static readonly RemovePath: APIRemovePath;
+  static readonly Archive: APIArchive;
+  static readonly ArchiveStatus: APIArchiveStatus;
+  static readonly ArchiveInfo: APIArchiveInfo;
+  static readonly ArchiveWatch: APIArchiveWatch;
 }
@@ -181,3 +221,31 @@
   ): UnaryResponse;
+  archive(
+    requestMessage: buckets_pb.ArchiveRequest,
+    metadata: grpc.Metadata,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveReply|null) => void
+  ): UnaryResponse;
+  archive(
+    requestMessage: buckets_pb.ArchiveRequest,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveReply|null) => void
+  ): UnaryResponse;
+  archiveStatus(
+    requestMessage: buckets_pb.ArchiveStatusRequest,
+    metadata: grpc.Metadata,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveStatusReply|null) => void
+  ): UnaryResponse;
+  archiveStatus(
+    requestMessage: buckets_pb.ArchiveStatusRequest,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveStatusReply|null) => void
+  ): UnaryResponse;
+  archiveInfo(
+    requestMessage: buckets_pb.ArchiveInfoRequest,
+    metadata: grpc.Metadata,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveInfoReply|null) => void
+  ): UnaryResponse;
+  archiveInfo(
+    requestMessage: buckets_pb.ArchiveInfoRequest,
+    callback: (error: ServiceError|null, responseMessage: buckets_pb.ArchiveInfoReply|null) => void
+  ): UnaryResponse;
+  archiveWatch(requestMessage: buckets_pb.ArchiveWatchRequest, metadata?: grpc.Metadata): ResponseStream<buckets_pb.ArchiveWatchReply>;
 }
 

buckets_pb_service.js

@@ -85,2 +85,38 @@ // package: buckets.pb
 
+API.Archive = {
+  methodName: "Archive",
+  service: API,
+  requestStream: false,
+  responseStream: false,
+  requestType: buckets_pb.ArchiveRequest,
+  responseType: buckets_pb.ArchiveReply
+};
+
+API.ArchiveStatus = {
+  methodName: "ArchiveStatus",
+  service: API,
+  requestStream: false,
+  responseStream: false,
+  requestType: buckets_pb.ArchiveStatusRequest,
+  responseType: buckets_pb.ArchiveStatusReply
+};
+
+API.ArchiveInfo = {
+  methodName: "ArchiveInfo",
+  service: API,
+  requestStream: false,
+  responseStream: false,
+  requestType: buckets_pb.ArchiveInfoRequest,
+  responseType: buckets_pb.ArchiveInfoReply
+};
+
+API.ArchiveWatch = {
+  methodName: "ArchiveWatch",
+  service: API,
+  requestStream: false,
+  responseStream: true,
+  requestType: buckets_pb.ArchiveWatchRequest,
+  responseType: buckets_pb.ArchiveWatchReply
+};
+
 exports.API = API;
@@ -363,3 +399,135 @@
 
+APIClient.prototype.archive = function archive(requestMessage, metadata, callback) {
+  if (arguments.length === 2) {
+    callback = arguments[1];
+  }
+  var client = grpc.unary(API.Archive, {
+    request: requestMessage,
+    host: this.serviceHost,
+    metadata: metadata,
+    transport: this.options.transport,
+    debug: this.options.debug,
+    onEnd: function (response) {
+      if (callback) {
+        if (response.status !== grpc.Code.OK) {
+          var err = new Error(response.statusMessage);
+          err.code = response.status;
+          err.metadata = response.trailers;
+          callback(err, null);
+        } else {
+          callback(null, response.message);
+        }
+      }
+    }
+  });
+  return {
+    cancel: function () {
+      callback = null;
+      client.close();
+    }
+  };
+};
+
+APIClient.prototype.archiveStatus = function archiveStatus(requestMessage, metadata, callback) {
+  if (arguments.length === 2) {
+    callback = arguments[1];
+  }
+  var client = grpc.unary(API.ArchiveStatus, {
+    request: requestMessage,
+    host: this.serviceHost,
+    metadata: metadata,
+    transport: this.options.transport,
+    debug: this.options.debug,
+    onEnd: function (response) {
+      if (callback) {
+        if (response.status !== grpc.Code.OK) {
+          var err = new Error(response.statusMessage);
+          err.code = response.status;
+          err.metadata = response.trailers;
+          callback(err, null);
+        } else {
+          callback(null, response.message);
+        }
+      }
+    }
+  });
+  return {
+    cancel: function () {
+      callback = null;
+      client.close();
+    }
+  };
+};
+
+APIClient.prototype.archiveInfo = function archiveInfo(requestMessage, metadata, callback) {
+  if (arguments.length === 2) {
+    callback = arguments[1];
+  }
+  var client = grpc.unary(API.ArchiveInfo, {
+    request: requestMessage,
+    host: this.serviceHost,
+    metadata: metadata,
+    transport: this.options.transport,
+    debug: this.options.debug,
+    onEnd: function (response) {
+      if (callback) {
+        if (response.status !== grpc.Code.OK) {
+          var err = new Error(response.statusMessage);
+          err.code = response.status;
+          err.metadata = response.trailers;
+          callback(err, null);
+        } else {
+          callback(null, response.message);
+        }
+      }
+    }
+  });
+  return {
+    cancel: function () {
+      callback = null;
+      client.close();
+    }
+  };
+};
+
+APIClient.prototype.archiveWatch = function archiveWatch(requestMessage, metadata) {
+  var listeners = {
+    data: [],
+    end: [],
+    status: []
+  };
+  var client = grpc.invoke(API.ArchiveWatch, {
+    request: requestMessage,
+    host: this.serviceHost,
+    metadata: metadata,
+    transport: this.options.transport,
+    debug: this.options.debug,
+    onMessage: function (responseMessage) {
+      listeners.data.forEach(function (handler) {
+        handler(responseMessage);
+      });
+    },
+    onEnd: function (status, statusMessage, trailers) {
+      listeners.status.forEach(function (handler) {
+        handler({ code: status, details: statusMessage, metadata: trailers });
+      });
+      listeners.end.forEach(function (handler) {
+        handler({ code: status, details: statusMessage, metadata: trailers });
+      });
+      listeners = null;
+    }
+  });
+  return {
+    on: function (type, handler) {
+      listeners[type].push(handler);
+      return this;
+    },
+    cancel: function () {
+      listeners = null;
+      client.close();
+    }
+  };
+};
+
 exports.APIClient = APIClient;
 

buckets_pb.d.ts

@@ -37,2 +37,7 @@ // package: buckets.pb
 
+  getSeed(): Uint8Array | string;
+  getSeed_asU8(): Uint8Array;
+  getSeed_asB64(): string;
+  setSeed(value: Uint8Array | string): void;
+
   serializeBinary(): Uint8Array;
@@ -52,2 +57,3 @@ toObject(includeInstance?: boolean): InitReply.AsObject;
     links?: LinksReply.AsObject,
+    seed: Uint8Array | string,
   }
@@ -230,2 +236,5 @@ }
   export class Item extends jspb.Message {
+    getCid(): string;
+    setCid(value: string): void;
+
     getName(): string;
@@ -260,2 +269,3 @@ setName(value: string): void;
     export type AsObject = {
+      cid: string,
       name: string,
@@ -307,2 +317,5 @@ path: string,
 
+    getRoot(): string;
+    setRoot(value: string): void;
+
     serializeBinary(): Uint8Array;
@@ -322,2 +335,3 @@ toObject(includeInstance?: boolean): Header.AsObject;
       path: string,
+      root: string,
     }
@@ -495,2 +509,5 @@ }
 
+  getRoot(): string;
+  setRoot(value: string): void;
+
   serializeBinary(): Uint8Array;
@@ -510,2 +527,3 @@ toObject(includeInstance?: boolean): RemovePathRequest.AsObject;
     path: string,
+    root: string,
   }
@@ -515,2 +533,7 @@ }
 export class RemovePathReply extends jspb.Message {
+  hasRoot(): boolean;
+  clearRoot(): void;
+  getRoot(): Root | undefined;
+  setRoot(value?: Root): void;
+
   serializeBinary(): Uint8Array;
@@ -528,4 +551,234 @@ toObject(includeInstance?: boolean): RemovePathReply.AsObject;
   export type AsObject = {
+    root?: Root.AsObject,
   }
 }
 
+export class ArchiveRequest extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveRequest): ArchiveRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveRequest;
+  static deserializeBinaryFromReader(message: ArchiveRequest, reader: jspb.BinaryReader): ArchiveRequest;
+}
+
+export namespace ArchiveRequest {
+  export type AsObject = {
+    key: string,
+  }
+}
+
+export class ArchiveReply extends jspb.Message {
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveReply.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveReply): ArchiveReply.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveReply, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveReply;
+  static deserializeBinaryFromReader(message: ArchiveReply, reader: jspb.BinaryReader): ArchiveReply;
+}
+
+export namespace ArchiveReply {
+  export type AsObject = {
+  }
+}
+
+export class ArchiveStatusRequest extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveStatusRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveStatusRequest): ArchiveStatusRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveStatusRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveStatusRequest;
+  static deserializeBinaryFromReader(message: ArchiveStatusRequest, reader: jspb.BinaryReader): ArchiveStatusRequest;
+}
+
+export namespace ArchiveStatusRequest {
+  export type AsObject = {
+    key: string,
+  }
+}
+
+export class ArchiveStatusReply extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  getStatus(): ArchiveStatusReply.StatusMap[keyof ArchiveStatusReply.StatusMap];
+  setStatus(value: ArchiveStatusReply.StatusMap[keyof ArchiveStatusReply.StatusMap]): void;
+
+  getFailedmsg(): string;
+  setFailedmsg(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveStatusReply.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveStatusReply): ArchiveStatusReply.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveStatusReply, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveStatusReply;
+  static deserializeBinaryFromReader(message: ArchiveStatusReply, reader: jspb.BinaryReader): ArchiveStatusReply;
+}
+
+export namespace ArchiveStatusReply {
+  export type AsObject = {
+    key: string,
+    status: ArchiveStatusReply.StatusMap[keyof ArchiveStatusReply.StatusMap],
+    failedmsg: string,
+  }
+
+  export interface StatusMap {
+    EXECUTING: 0;
+    FAILED: 1;
+    DONE: 2;
+    CANCELED: 3;
+  }
+
+  export const Status: StatusMap;
+}
+
+export class ArchiveInfoRequest extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveInfoRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveInfoRequest): ArchiveInfoRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveInfoRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveInfoRequest;
+  static deserializeBinaryFromReader(message: ArchiveInfoRequest, reader: jspb.BinaryReader): ArchiveInfoRequest;
+}
+
+export namespace ArchiveInfoRequest {
+  export type AsObject = {
+    key: string,
+  }
+}
+
+export class ArchiveInfoReply extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  hasArchive(): boolean;
+  clearArchive(): void;
+  getArchive(): ArchiveInfoReply.Archive | undefined;
+  setArchive(value?: ArchiveInfoReply.Archive): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveInfoReply.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveInfoReply): ArchiveInfoReply.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveInfoReply, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveInfoReply;
+  static deserializeBinaryFromReader(message: ArchiveInfoReply, reader: jspb.BinaryReader): ArchiveInfoReply;
+}
+
+export namespace ArchiveInfoReply {
+  export type AsObject = {
+    key: string,
+    archive?: ArchiveInfoReply.Archive.AsObject,
+  }
+
+  export class Archive extends jspb.Message {
+    getCid(): string;
+    setCid(value: string): void;
+
+    clearDealsList(): void;
+    getDealsList(): Array<ArchiveInfoReply.Archive.Deal>;
+    setDealsList(value: Array<ArchiveInfoReply.Archive.Deal>): void;
+    addDeals(value?: ArchiveInfoReply.Archive.Deal, index?: number): ArchiveInfoReply.Archive.Deal;
+
+    serializeBinary(): Uint8Array;
+    toObject(includeInstance?: boolean): Archive.AsObject;
+    static toObject(includeInstance: boolean, msg: Archive): Archive.AsObject;
+    static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+    static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+    static serializeBinaryToWriter(message: Archive, writer: jspb.BinaryWriter): void;
+    static deserializeBinary(bytes: Uint8Array): Archive;
+    static deserializeBinaryFromReader(message: Archive, reader: jspb.BinaryReader): Archive;
+  }
+
+  export namespace Archive {
+    export type AsObject = {
+      cid: string,
+      dealsList: Array<ArchiveInfoReply.Archive.Deal.AsObject>,
+    }
+
+    export class Deal extends jspb.Message {
+      getProposalcid(): string;
+      setProposalcid(value: string): void;
+
+      getMiner(): string;
+      setMiner(value: string): void;
+
+      serializeBinary(): Uint8Array;
+      toObject(includeInstance?: boolean): Deal.AsObject;
+      static toObject(includeInstance: boolean, msg: Deal): Deal.AsObject;
+      static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+      static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+      static serializeBinaryToWriter(message: Deal, writer: jspb.BinaryWriter): void;
+      static deserializeBinary(bytes: Uint8Array): Deal;
+      static deserializeBinaryFromReader(message: Deal, reader: jspb.BinaryReader): Deal;
+    }
+
+    export namespace Deal {
+      export type AsObject = {
+        proposalcid: string,
+        miner: string,
+      }
+    }
+  }
+}
+
+export class ArchiveWatchRequest extends jspb.Message {
+  getKey(): string;
+  setKey(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveWatchRequest.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveWatchRequest): ArchiveWatchRequest.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveWatchRequest, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveWatchRequest;
+  static deserializeBinaryFromReader(message: ArchiveWatchRequest, reader: jspb.BinaryReader): ArchiveWatchRequest;
+}
+
+export namespace ArchiveWatchRequest {
+  export type AsObject = {
+    key: string,
+  }
+}
+
+export class ArchiveWatchReply extends jspb.Message {
+  getMsg(): string;
+  setMsg(value: string): void;
+
+  serializeBinary(): Uint8Array;
+  toObject(includeInstance?: boolean): ArchiveWatchReply.AsObject;
+  static toObject(includeInstance: boolean, msg: ArchiveWatchReply): ArchiveWatchReply.AsObject;
+  static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+  static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+  static serializeBinaryToWriter(message: ArchiveWatchReply, writer: jspb.BinaryWriter): void;
+  static deserializeBinary(bytes: Uint8Array): ArchiveWatchReply;
+  static deserializeBinaryFromReader(message: ArchiveWatchReply, reader: jspb.BinaryReader): ArchiveWatchReply;
+}
+
+export namespace ArchiveWatchReply {
+  export type AsObject = {
+    msg: string,
+  }
+}
+

package.json

 {
   "name": "@textile/buckets-grpc",
-  "version": "1.0.3",
+  "version": "1.0.4-rc1",
   "description": "A client for interacting with the Textile Buckets gRPC API.",
@@ -20,3 +20,3 @@ "repository": {
     "@types/google-protobuf": "^3.7.2",
-    "google-protobuf": "^3.11.2"
+    "google-protobuf": "^3.12.1"
   },
@@ -23,0 +23,0 @@ "devDependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

227009

increased by48.92%

Lines of code

6455

increased by47.51%

Worsened metrics

Number of low quality alerts

2

increased by100%

Number of medium supply chain risk alerts

2

increased by100%

Dependency changes

• Updatedgoogle-protobuf@^3.12.1