mirror of
https://github.com/corda/corda.git
synced 2024-12-23 23:02:29 +00:00
7b308eb45f
The Blob Writer is a small kotlin app that allows arbitrary things to be serialized and then those bytes written to a file, quite useful for working on non JVM parsing of such things. Along a similar vein, add a schema dumper alongside the blob-inspector to highlight the contents of the header
93 lines
2.1 KiB
C++
93 lines
2.1 KiB
C++
#include <iostream>
|
|
#include <iomanip>
|
|
#include <fstream>
|
|
#include <cstddef>
|
|
|
|
#include <assert.h>
|
|
#include <string.h>
|
|
#include <proton/types.h>
|
|
#include <proton/codec.h>
|
|
#include <sys/stat.h>
|
|
#include <sstream>
|
|
|
|
#import "debug.h"
|
|
|
|
#include "proton/proton_wrapper.h"
|
|
|
|
#include "amqp/AMQPHeader.h"
|
|
#include "amqp/AMQPSectionId.h"
|
|
#include "amqp/descriptors/AMQPDescriptorRegistory.h"
|
|
|
|
#include "amqp/schema/Envelope.h"
|
|
#include "amqp/CompositeFactory.h"
|
|
|
|
/******************************************************************************/
|
|
|
|
void
|
|
printNode (pn_data_t * d_) {
|
|
std::stringstream ss;
|
|
|
|
if (pn_data_is_described (d_)) {
|
|
amqp::AMQPDescriptorRegistory[22UL]->read (d_, ss);
|
|
}
|
|
|
|
std::cout << ss.str() << std::endl;
|
|
}
|
|
|
|
|
|
/******************************************************************************/
|
|
|
|
void
|
|
data_and_stop(std::ifstream & f_, ssize_t sz) {
|
|
char * blob = new char[sz];
|
|
memset (blob, 0, sz);
|
|
f_.read(blob, sz);
|
|
|
|
pn_data_t * d = pn_data(sz);
|
|
|
|
// returns how many bytes we processed which right now we don't care
|
|
// about but I assume there is a case where it doesn't process the
|
|
// entire file
|
|
auto rtn = pn_data_decode (d, blob, sz);
|
|
assert (rtn == sz);
|
|
|
|
printNode (d);
|
|
|
|
}
|
|
|
|
/******************************************************************************/
|
|
|
|
int
|
|
main (int argc, char **argv) {
|
|
struct stat results { };
|
|
|
|
if (stat(argv[1], &results) != 0) {
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
std::ifstream f (argv[1], std::ios::in | std::ios::binary);
|
|
std::array<char, 7> header { };
|
|
f.read(header.data(), 7);
|
|
|
|
if (header != amqp::AMQP_HEADER) {
|
|
std::cerr << "Bad Header in blob" << std::endl;
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
amqp::amqp_section_id_t encoding;
|
|
f.read((char *)&encoding, 1);
|
|
|
|
if (encoding == amqp::DATA_AND_STOP) {
|
|
data_and_stop(f, results.st_size - 8);
|
|
} else {
|
|
std::cerr << "BAD ENCODING " << encoding << " != "
|
|
<< amqp::DATA_AND_STOP << std::endl;
|
|
|
|
return EXIT_FAILURE;
|
|
}
|
|
|
|
return EXIT_SUCCESS;
|
|
}
|
|
|
|
/******************************************************************************/
|