//
//  RiakProtobuf.h
//  riak_pb-objc
//
//  Created by Scott Gonyea on 9/1/10.
//  Copyright (c) 2010 Inherently Lame Inc. All rights reserved.
//
#import <ObjFW/ObjFW.h>
#import <stdint.h>
#import "MessageCodes.h"

@interface RiakProtobuf : OFObject {
@private
}
- (id)init;
- (void)dealloc;

- (OFDictionary *)errorResponse:(char *)response;

// Message Code Only
- (void)pingRequest;
- (BOOL)pingResponse; // Message Code Only

// Message Code Only
- (void)getClientIdRequest;
- (uint32_t)getClientIdResponse:(char *)response;

- (void)setClientIdRequest:(char *)request clientId:(uint32_t)clientId;
- (BOOL)setClientIdResponse; // Message Code Only

// Message Code Only
- (void)getServerInfoRequest;
- (OFDictionary *)getServerInfoResponse:(char *)response;

- (void)getRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key;
- (void)getRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key quorum:(uint32_t)quorum;
- (OFDictionary *)getResponse:(char *)response;

- (void)putRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key content:(OFDictionary *)content withBody:(BOOL)body;
- (void)putRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key content:(OFDictionary *)content withBody:(BOOL)body quorum:(uint32_t)quorum commit:(uint32_t)commit;
- (OFDictionary *)putResponse:(char *)response;

- (void)delRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key;
- (void)delRequest:(char *)request bucket:(OFString *)bucket key:(OFString *)key replicas:(uint32_t)replicas;
- (BOOL)delResponse; // Message Code Only

// Message Code Only
- (void)listBucketsRequest;
- (OFArray *)listBucketsResponse:(char *)response;

- (void)listKeysRequest:(char *)request bucket:(OFString *)bucket;
- (OFArray *)listKeysResponse: (char *)response;

- (void)getBucketRequest:(char *)request bucket:(OFString *)bucket;
- (OFDictionary *)getBucketResponse:(char *)response;

- (void)setBucketRequest:(char *)request bucket:(OFString *)bucket nVal:(uint32_t)nVal isMult:(BOOL)isMult;
- (BOOL)setBucketResponse; // Message Code Only

- (void)mapReduceRequest:(char *)request bucket:(OFString *)bucket contentType:(OFString *)contentType;
- (OFDictionary *)mapReduceResponse:(char *)response;

@end