// Code generated by protoc-gen-grpc-ts. DO NOT EDIT.
// Generated from: object/service.proto
// Target: nodejs

import * as grpc from '@grpc/grpc-js';
import { DeleteRequest, DeleteResponse, GetRangeHashRequest, GetRangeHashResponse, GetRangeRequest, GetRangeResponse, GetRequest, GetResponse, HeadRequest, HeadResponse, PutRequest, PutResponse, ReplicateRequest, ReplicateResponse, SearchRequest, SearchResponse, SearchV2Request, SearchV2Response } from './service_pb';

export class ObjectServiceClient {
  private client: grpc.Client;

  constructor(address: string, credentials: grpc.ChannelCredentials, options?: grpc.ChannelOptions) {
    this.client = new grpc.Client(address, credentials, options);
  }

  get(request: GetRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<GetResponse> {
    return this.client.makeServerStreamRequest<GetRequest, GetResponse>(
      '/neo.fs.v2.object.ObjectService/Get',
      (arg) => Buffer.from(arg.serializeBinary()),
      (buf) => GetResponse.deserializeBinary(new Uint8Array(buf)),
      request,
      metadata || new grpc.Metadata(),
      options || {}
    );
  }

  put(metadata?: grpc.Metadata, options?: grpc.CallOptions, callback?: (error: grpc.ServiceError | null, response?: PutResponse) => void): grpc.ClientWritableStream<PutRequest> {
    // Default to no-op callback if not provided
    const finalCallback = callback || ((err, response) => {
      if (err) {
        console.error('Client stream error:', err);
      }
    });

    return this.client.makeClientStreamRequest<PutRequest, PutResponse>(
      '/neo.fs.v2.object.ObjectService/Put',
      (arg) => Buffer.from(arg.serializeBinary()),
      (buf) => PutResponse.deserializeBinary(new Uint8Array(buf)),
      metadata || new grpc.Metadata(),
      options || {},
      finalCallback
    );
  }

  delete(request: DeleteRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): Promise<DeleteResponse> {
    return new Promise((resolve, reject) => {
      this.client.makeUnaryRequest<DeleteRequest, DeleteResponse>(
        '/neo.fs.v2.object.ObjectService/Delete',
        (arg) => Buffer.from(arg.serializeBinary()),
        (buf) => DeleteResponse.deserializeBinary(new Uint8Array(buf)),
        request,
        metadata || new grpc.Metadata(),
        options || {},
        (err, response) => {
          if (err) {
            reject(err);
          } else {
            resolve(response!);
          }
        }
      );
    });
  }

  head(request: HeadRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): Promise<HeadResponse> {
    return new Promise((resolve, reject) => {
      this.client.makeUnaryRequest<HeadRequest, HeadResponse>(
        '/neo.fs.v2.object.ObjectService/Head',
        (arg) => Buffer.from(arg.serializeBinary()),
        (buf) => HeadResponse.deserializeBinary(new Uint8Array(buf)),
        request,
        metadata || new grpc.Metadata(),
        options || {},
        (err, response) => {
          if (err) {
            reject(err);
          } else {
            resolve(response!);
          }
        }
      );
    });
  }

  search(request: SearchRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<SearchResponse> {
    return this.client.makeServerStreamRequest<SearchRequest, SearchResponse>(
      '/neo.fs.v2.object.ObjectService/Search',
      (arg) => Buffer.from(arg.serializeBinary()),
      (buf) => SearchResponse.deserializeBinary(new Uint8Array(buf)),
      request,
      metadata || new grpc.Metadata(),
      options || {}
    );
  }

  searchV2(request: SearchV2Request, metadata?: grpc.Metadata, options?: grpc.CallOptions): Promise<SearchV2Response> {
    return new Promise((resolve, reject) => {
      this.client.makeUnaryRequest<SearchV2Request, SearchV2Response>(
        '/neo.fs.v2.object.ObjectService/SearchV2',
        (arg) => Buffer.from(arg.serializeBinary()),
        (buf) => SearchV2Response.deserializeBinary(new Uint8Array(buf)),
        request,
        metadata || new grpc.Metadata(),
        options || {},
        (err, response) => {
          if (err) {
            reject(err);
          } else {
            resolve(response!);
          }
        }
      );
    });
  }

  getRange(request: GetRangeRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): grpc.ClientReadableStream<GetRangeResponse> {
    return this.client.makeServerStreamRequest<GetRangeRequest, GetRangeResponse>(
      '/neo.fs.v2.object.ObjectService/GetRange',
      (arg) => Buffer.from(arg.serializeBinary()),
      (buf) => GetRangeResponse.deserializeBinary(new Uint8Array(buf)),
      request,
      metadata || new grpc.Metadata(),
      options || {}
    );
  }

  getRangeHash(request: GetRangeHashRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): Promise<GetRangeHashResponse> {
    return new Promise((resolve, reject) => {
      this.client.makeUnaryRequest<GetRangeHashRequest, GetRangeHashResponse>(
        '/neo.fs.v2.object.ObjectService/GetRangeHash',
        (arg) => Buffer.from(arg.serializeBinary()),
        (buf) => GetRangeHashResponse.deserializeBinary(new Uint8Array(buf)),
        request,
        metadata || new grpc.Metadata(),
        options || {},
        (err, response) => {
          if (err) {
            reject(err);
          } else {
            resolve(response!);
          }
        }
      );
    });
  }

  replicate(request: ReplicateRequest, metadata?: grpc.Metadata, options?: grpc.CallOptions): Promise<ReplicateResponse> {
    return new Promise((resolve, reject) => {
      this.client.makeUnaryRequest<ReplicateRequest, ReplicateResponse>(
        '/neo.fs.v2.object.ObjectService/Replicate',
        (arg) => Buffer.from(arg.serializeBinary()),
        (buf) => ReplicateResponse.deserializeBinary(new Uint8Array(buf)),
        request,
        metadata || new grpc.Metadata(),
        options || {},
        (err, response) => {
          if (err) {
            reject(err);
          } else {
            resolve(response!);
          }
        }
      );
    });
  }

  close(): void {
    this.client.close();
  }
}