rpc.proto

// Copyright (c) 2019 Perlin
//
// Permission is hereby granted, free of charge, to any person obtaining a copy of
// this software and associated documentation files (the "Software"), to deal in
// the Software without restriction, including without limitation the rights to
// use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of
// the Software, and to permit persons to whom the Software is furnished to do so,
// subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
// FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
// COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
// IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
// CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

syntax = "proto3";

package wavelet;

import "google/protobuf/empty.proto";

message QueryRequest {
    uint64 block_index = 1;
    bytes cache_block_id = 2;
}

message QueryResponse {
    bytes block = 1;
    bool cache_valid = 2;
}

message OutOfSyncRequest {
    uint64 block_index = 1;
}

message OutOfSyncResponse {
    bool out_of_sync = 1;
}

message SyncInfo {
    bytes block = 1;
    repeated bytes checksums = 2;
}

message SyncRequest {
    oneof Data {
        uint64 block_id = 1;
        bytes checksum = 2;
    }
}

message SyncResponse {
    oneof Data {
        SyncInfo header = 1;
        bytes chunk = 2;
    }
}

message GossipRequest {
    repeated bytes transactions = 1;
}

message TransactionsSyncRequest {
    oneof Data {
        bytes filter = 1;
        uint64 chunk_size = 2;
    }
}

message TransactionsSyncPart {
    repeated bytes transactions = 1;
}

message TransactionsSyncResponse {
    oneof Data {
        uint64 transactions_num = 1;
        TransactionsSyncPart transactions = 2;
    }
}

message TransactionPullRequest {
    repeated bytes transaction_ids = 1;
}

message TransactionPullResponse {
    repeated bytes transactions = 1;
}

service Wavelet {
    rpc Gossip (GossipRequest) returns (google.protobuf.Empty) {}
    rpc Query (QueryRequest) returns (QueryResponse) {}

    rpc CheckOutOfSync (OutOfSyncRequest) returns (OutOfSyncResponse) {}
    rpc Sync (stream SyncRequest) returns (stream SyncResponse) {}

    rpc PullTransactions (TransactionPullRequest) returns (TransactionPullResponse) {}
    rpc SyncTransactions (stream TransactionsSyncRequest) returns (stream TransactionsSyncResponse) {}
}