// @generated by protobuf-ts 2.9.0
// @generated from protobuf file "log_record.proto" (package "pb", syntax proto3)
// tslint:disable
import type { BinaryWriteOptions } from "@protobuf-ts/runtime";
import type { IBinaryWriter } from "@protobuf-ts/runtime";
import { WireType } from "@protobuf-ts/runtime";
import type { BinaryReadOptions } from "@protobuf-ts/runtime";
import type { IBinaryReader } from "@protobuf-ts/runtime";
import { UnknownFieldHandler } from "@protobuf-ts/runtime";
import type { PartialMessage } from "@protobuf-ts/runtime";
import { reflectionMergePartial } from "@protobuf-ts/runtime";
import { MESSAGE_TYPE } from "@protobuf-ts/runtime";
import { MessageType } from "@protobuf-ts/runtime";
import { Query } from "./query";
import { Signature } from "./signature";
/**
 *
 * A log record is a record for logging activity of each request to node.
 *
 * @generated from protobuf message pb.LogRecord
 */
export interface LogRecord {
    /**
     * @generated from protobuf oneof: request
     */
    request: {
        oneofKind: "writeRequest";
        /**
         * write request metadata
         *
         * @generated from protobuf field: pb.WriteRequest writeRequest = 1;
         */
        writeRequest: WriteRequest;
    } | {
        oneofKind: "readRequest";
        /**
         * read request metadata
         *
         * @generated from protobuf field: pb.ReadRequest readRequest = 2;
         */
        readRequest: ReadRequest;
    } | {
        oneofKind: "queryRequest";
        /**
         * search request metadata
         *
         * @generated from protobuf field: pb.QueryRequest queryRequest = 3;
         */
        queryRequest: QueryRequest;
    } | {
        oneofKind: undefined;
    };
    /**
     * timestamp of request in UNIX nanoseconds.
     *
     * @generated from protobuf field: uint64 timestamp = 4 [jstype = JS_STRING];
     */
    timestamp: string;
    /**
     * ip address of user who sent request
     *
     * @generated from protobuf field: string address = 5;
     */
    address: string;
    /**
     * number of used gas for processing request
     *
     * @generated from protobuf field: uint32 gas = 6;
     */
    gas: number;
    /**
     * users publicKey
     *
     * @generated from protobuf field: bytes publicKey = 7;
     */
    publicKey: Uint8Array;
    /**
     * session id
     *
     * @generated from protobuf field: bytes sessionId = 9;
     */
    sessionId: Uint8Array;
    /**
     * request id
     *
     * @generated from protobuf field: string requestId = 10;
     */
    requestId: string;
    /**
     * list of pieces returned by request
     *
     * @generated from protobuf field: repeated pb.ResponsePiece responsePieces = 12;
     */
    responsePieces: ResponsePiece[];
}
/**
 *
 * A log records list
 *
 * @generated from protobuf message pb.LogRecordList
 */
export interface LogRecordList {
    /**
     * @generated from protobuf field: repeated pb.LogRecord logRecords = 1;
     */
    logRecords: LogRecord[];
}
/**
 *
 * A write request is a container of metadata for upload piece requests
 *
 * @generated from protobuf message pb.WriteRequest
 */
export interface WriteRequest {
    /**
     * CID of saved piece
     *
     * @generated from protobuf field: string cid = 1;
     */
    cid: string;
    /**
     * bucket identifier where was stored piece
     *
     * @generated from protobuf field: uint32 bucketId = 2;
     */
    bucketId: number;
    /**
     * size of stored piece
     *
     * @generated from protobuf field: uint32 size = 3;
     */
    size: number;
    /**
     * piece signature
     *
     * @generated from protobuf field: pb.Signature signature = 4;
     */
    signature?: Signature;
}
/**
 *
 * A read request is a container of metadata for download piece requests
 *
 * @generated from protobuf message pb.ReadRequest
 */
export interface ReadRequest {
    /**
     * CID of requested piece
     *
     * @generated from protobuf field: string cid = 1;
     */
    cid: string;
    /**
     * bucket identifier of requested piece
     *
     * @generated from protobuf field: uint32 bucketId = 2;
     */
    bucketId: number;
    /**
     * piece signature
     *
     * @generated from protobuf field: pb.Signature signature = 3;
     */
    signature?: Signature;
}
/**
 *
 * A query request is a container of metadata for search requests
 *
 * @generated from protobuf message pb.QueryRequest
 */
export interface QueryRequest {
    /**
     * query for search
     *
     * @generated from protobuf field: pb.Query query = 1;
     */
    query?: Query;
}
/**
 * @generated from protobuf message pb.ResponsePiece
 */
export interface ResponsePiece {
    /**
     * CID of piece
     *
     * @generated from protobuf field: string cid = 1;
     */
    cid: string;
    /**
     * size of piece
     *
     * @generated from protobuf field: uint32 size = 3;
     */
    size: number;
}
// @generated message type with reflection information, may provide speed optimized methods
class LogRecord$Type extends MessageType<LogRecord> {
    constructor() {
        super("pb.LogRecord", [
            { no: 1, name: "writeRequest", kind: "message", oneof: "request", T: () => WriteRequest },
            { no: 2, name: "readRequest", kind: "message", oneof: "request", T: () => ReadRequest },
            { no: 3, name: "queryRequest", kind: "message", oneof: "request", T: () => QueryRequest },
            { no: 4, name: "timestamp", kind: "scalar", T: 4 /*ScalarType.UINT64*/ },
            { no: 5, name: "address", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
            { no: 6, name: "gas", kind: "scalar", T: 13 /*ScalarType.UINT32*/ },
            { no: 7, name: "publicKey", kind: "scalar", T: 12 /*ScalarType.BYTES*/ },
            { no: 9, name: "sessionId", kind: "scalar", T: 12 /*ScalarType.BYTES*/ },
            { no: 10, name: "requestId", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
            { no: 12, name: "responsePieces", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: () => ResponsePiece }
        ]);
    }
    create(value?: PartialMessage<LogRecord>): LogRecord {
        const message = { request: { oneofKind: undefined }, timestamp: "0", address: "", gas: 0, publicKey: new Uint8Array(0), sessionId: new Uint8Array(0), requestId: "", responsePieces: [] };
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<LogRecord>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: LogRecord): LogRecord {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* pb.WriteRequest writeRequest */ 1:
                    message.request = {
                        oneofKind: "writeRequest",
                        writeRequest: WriteRequest.internalBinaryRead(reader, reader.uint32(), options, (message.request as any).writeRequest)
                    };
                    break;
                case /* pb.ReadRequest readRequest */ 2:
                    message.request = {
                        oneofKind: "readRequest",
                        readRequest: ReadRequest.internalBinaryRead(reader, reader.uint32(), options, (message.request as any).readRequest)
                    };
                    break;
                case /* pb.QueryRequest queryRequest */ 3:
                    message.request = {
                        oneofKind: "queryRequest",
                        queryRequest: QueryRequest.internalBinaryRead(reader, reader.uint32(), options, (message.request as any).queryRequest)
                    };
                    break;
                case /* uint64 timestamp = 4 [jstype = JS_STRING];*/ 4:
                    message.timestamp = reader.uint64().toString();
                    break;
                case /* string address */ 5:
                    message.address = reader.string();
                    break;
                case /* uint32 gas */ 6:
                    message.gas = reader.uint32();
                    break;
                case /* bytes publicKey */ 7:
                    message.publicKey = reader.bytes();
                    break;
                case /* bytes sessionId */ 9:
                    message.sessionId = reader.bytes();
                    break;
                case /* string requestId */ 10:
                    message.requestId = reader.string();
                    break;
                case /* repeated pb.ResponsePiece responsePieces */ 12:
                    message.responsePieces.push(ResponsePiece.internalBinaryRead(reader, reader.uint32(), options));
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: LogRecord, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* pb.WriteRequest writeRequest = 1; */
        if (message.request.oneofKind === "writeRequest")
            WriteRequest.internalBinaryWrite(message.request.writeRequest, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
        /* pb.ReadRequest readRequest = 2; */
        if (message.request.oneofKind === "readRequest")
            ReadRequest.internalBinaryWrite(message.request.readRequest, writer.tag(2, WireType.LengthDelimited).fork(), options).join();
        /* pb.QueryRequest queryRequest = 3; */
        if (message.request.oneofKind === "queryRequest")
            QueryRequest.internalBinaryWrite(message.request.queryRequest, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
        /* uint64 timestamp = 4 [jstype = JS_STRING]; */
        if (message.timestamp !== "0")
            writer.tag(4, WireType.Varint).uint64(message.timestamp);
        /* string address = 5; */
        if (message.address !== "")
            writer.tag(5, WireType.LengthDelimited).string(message.address);
        /* uint32 gas = 6; */
        if (message.gas !== 0)
            writer.tag(6, WireType.Varint).uint32(message.gas);
        /* bytes publicKey = 7; */
        if (message.publicKey.length)
            writer.tag(7, WireType.LengthDelimited).bytes(message.publicKey);
        /* bytes sessionId = 9; */
        if (message.sessionId.length)
            writer.tag(9, WireType.LengthDelimited).bytes(message.sessionId);
        /* string requestId = 10; */
        if (message.requestId !== "")
            writer.tag(10, WireType.LengthDelimited).string(message.requestId);
        /* repeated pb.ResponsePiece responsePieces = 12; */
        for (let i = 0; i < message.responsePieces.length; i++)
            ResponsePiece.internalBinaryWrite(message.responsePieces[i], writer.tag(12, WireType.LengthDelimited).fork(), options).join();
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.LogRecord
 */
export const LogRecord = new LogRecord$Type();
// @generated message type with reflection information, may provide speed optimized methods
class LogRecordList$Type extends MessageType<LogRecordList> {
    constructor() {
        super("pb.LogRecordList", [
            { no: 1, name: "logRecords", kind: "message", repeat: 1 /*RepeatType.PACKED*/, T: () => LogRecord }
        ]);
    }
    create(value?: PartialMessage<LogRecordList>): LogRecordList {
        const message = { logRecords: [] };
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<LogRecordList>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: LogRecordList): LogRecordList {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* repeated pb.LogRecord logRecords */ 1:
                    message.logRecords.push(LogRecord.internalBinaryRead(reader, reader.uint32(), options));
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: LogRecordList, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* repeated pb.LogRecord logRecords = 1; */
        for (let i = 0; i < message.logRecords.length; i++)
            LogRecord.internalBinaryWrite(message.logRecords[i], writer.tag(1, WireType.LengthDelimited).fork(), options).join();
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.LogRecordList
 */
export const LogRecordList = new LogRecordList$Type();
// @generated message type with reflection information, may provide speed optimized methods
class WriteRequest$Type extends MessageType<WriteRequest> {
    constructor() {
        super("pb.WriteRequest", [
            { no: 1, name: "cid", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
            { no: 2, name: "bucketId", kind: "scalar", T: 13 /*ScalarType.UINT32*/ },
            { no: 3, name: "size", kind: "scalar", T: 13 /*ScalarType.UINT32*/ },
            { no: 4, name: "signature", kind: "message", T: () => Signature }
        ]);
    }
    create(value?: PartialMessage<WriteRequest>): WriteRequest {
        const message = { cid: "", bucketId: 0, size: 0 };
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<WriteRequest>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: WriteRequest): WriteRequest {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* string cid */ 1:
                    message.cid = reader.string();
                    break;
                case /* uint32 bucketId */ 2:
                    message.bucketId = reader.uint32();
                    break;
                case /* uint32 size */ 3:
                    message.size = reader.uint32();
                    break;
                case /* pb.Signature signature */ 4:
                    message.signature = Signature.internalBinaryRead(reader, reader.uint32(), options, message.signature);
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: WriteRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* string cid = 1; */
        if (message.cid !== "")
            writer.tag(1, WireType.LengthDelimited).string(message.cid);
        /* uint32 bucketId = 2; */
        if (message.bucketId !== 0)
            writer.tag(2, WireType.Varint).uint32(message.bucketId);
        /* uint32 size = 3; */
        if (message.size !== 0)
            writer.tag(3, WireType.Varint).uint32(message.size);
        /* pb.Signature signature = 4; */
        if (message.signature)
            Signature.internalBinaryWrite(message.signature, writer.tag(4, WireType.LengthDelimited).fork(), options).join();
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.WriteRequest
 */
export const WriteRequest = new WriteRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ReadRequest$Type extends MessageType<ReadRequest> {
    constructor() {
        super("pb.ReadRequest", [
            { no: 1, name: "cid", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
            { no: 2, name: "bucketId", kind: "scalar", T: 13 /*ScalarType.UINT32*/ },
            { no: 3, name: "signature", kind: "message", T: () => Signature }
        ]);
    }
    create(value?: PartialMessage<ReadRequest>): ReadRequest {
        const message = { cid: "", bucketId: 0 };
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<ReadRequest>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ReadRequest): ReadRequest {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* string cid */ 1:
                    message.cid = reader.string();
                    break;
                case /* uint32 bucketId */ 2:
                    message.bucketId = reader.uint32();
                    break;
                case /* pb.Signature signature */ 3:
                    message.signature = Signature.internalBinaryRead(reader, reader.uint32(), options, message.signature);
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: ReadRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* string cid = 1; */
        if (message.cid !== "")
            writer.tag(1, WireType.LengthDelimited).string(message.cid);
        /* uint32 bucketId = 2; */
        if (message.bucketId !== 0)
            writer.tag(2, WireType.Varint).uint32(message.bucketId);
        /* pb.Signature signature = 3; */
        if (message.signature)
            Signature.internalBinaryWrite(message.signature, writer.tag(3, WireType.LengthDelimited).fork(), options).join();
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.ReadRequest
 */
export const ReadRequest = new ReadRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class QueryRequest$Type extends MessageType<QueryRequest> {
    constructor() {
        super("pb.QueryRequest", [
            { no: 1, name: "query", kind: "message", T: () => Query }
        ]);
    }
    create(value?: PartialMessage<QueryRequest>): QueryRequest {
        const message = {};
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<QueryRequest>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: QueryRequest): QueryRequest {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* pb.Query query */ 1:
                    message.query = Query.internalBinaryRead(reader, reader.uint32(), options, message.query);
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: QueryRequest, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* pb.Query query = 1; */
        if (message.query)
            Query.internalBinaryWrite(message.query, writer.tag(1, WireType.LengthDelimited).fork(), options).join();
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.QueryRequest
 */
export const QueryRequest = new QueryRequest$Type();
// @generated message type with reflection information, may provide speed optimized methods
class ResponsePiece$Type extends MessageType<ResponsePiece> {
    constructor() {
        super("pb.ResponsePiece", [
            { no: 1, name: "cid", kind: "scalar", T: 9 /*ScalarType.STRING*/ },
            { no: 3, name: "size", kind: "scalar", T: 13 /*ScalarType.UINT32*/ }
        ]);
    }
    create(value?: PartialMessage<ResponsePiece>): ResponsePiece {
        const message = { cid: "", size: 0 };
        globalThis.Object.defineProperty(message, MESSAGE_TYPE, { enumerable: false, value: this });
        if (value !== undefined)
            reflectionMergePartial<ResponsePiece>(this, message, value);
        return message;
    }
    internalBinaryRead(reader: IBinaryReader, length: number, options: BinaryReadOptions, target?: ResponsePiece): ResponsePiece {
        let message = target ?? this.create(), end = reader.pos + length;
        while (reader.pos < end) {
            let [fieldNo, wireType] = reader.tag();
            switch (fieldNo) {
                case /* string cid */ 1:
                    message.cid = reader.string();
                    break;
                case /* uint32 size */ 3:
                    message.size = reader.uint32();
                    break;
                default:
                    let u = options.readUnknownField;
                    if (u === "throw")
                        throw new globalThis.Error(`Unknown field ${fieldNo} (wire type ${wireType}) for ${this.typeName}`);
                    let d = reader.skip(wireType);
                    if (u !== false)
                        (u === true ? UnknownFieldHandler.onRead : u)(this.typeName, message, fieldNo, wireType, d);
            }
        }
        return message;
    }
    internalBinaryWrite(message: ResponsePiece, writer: IBinaryWriter, options: BinaryWriteOptions): IBinaryWriter {
        /* string cid = 1; */
        if (message.cid !== "")
            writer.tag(1, WireType.LengthDelimited).string(message.cid);
        /* uint32 size = 3; */
        if (message.size !== 0)
            writer.tag(3, WireType.Varint).uint32(message.size);
        let u = options.writeUnknownFields;
        if (u !== false)
            (u == true ? UnknownFieldHandler.onWrite : u)(this.typeName, message, writer);
        return writer;
    }
}
/**
 * @generated MessageType for protobuf message pb.ResponsePiece
 */
export const ResponsePiece = new ResponsePiece$Type();