protobuf = require("protobufjs@7.1.2/dist/protobuf.min.js")
root = protobuf.parse(SOURCE).root
User = root.lookupType("profile.User")
UserStatus = root.lookupEnum("profile.UserStatus")
Address = root.lookupType("profile.Address")
payload = ({
id: "4b2e6f31-5035-4864-8e38-e012fd9dc04d",
age: 28,
height: 1.73,
name: "Max Bo",
isVerified: true,
status: UserStatus.values.STATUS_ACTIVE,
address: {
street: "Kippax St",
city: "Sydney",
country: "Australia",
postalCode: "2010"
},
emailAddresses: ["max+observable@maxbo.me", "dontcontactme@example.com"],
metadata: {
blood: "O-"
}
})
// Answer an error message if verification fails, or null if it succeeds.
User.verify(payload)
message = User.create(payload)
buffer = User.encode(message).finish()
binary = new TextDecoder().decode(buffer)
decodedMessage = User.decode(buffer)
object = User.toObject(message)
awesomeProto = protobuf.Root.fromJSON(JSON.parse(AWESOME_DESCRIPTOR))
protoViz(awesomeProto)
function protoViz(root) {
const collector = [];
const drawArrows = (parent) => {
const branches = [
...Object.values(parent.nested || {}),
...Object.values(parent.fields || {}),
...Object.values(parent.values || {}),
...Object.values(parent.oneofs || {}),
...Object.values(parent.methods || {}),
...(parent.type ? [{ name: parent.type }] : []),
...(parent.requestType ? [{ name: parent.requestType }] : []),
...(parent.responseType ? [{ name: parent.responseType }] : []),
...(parent.oneof || []).map((name) => ({
name
}))
];
for (const child of branches) {
if (parent.name) {
collector.push(`${parent.name} -> ${child.name}`);
}
drawArrows(child);
}
};
drawArrows(root);
return dot`digraph {
rankdir=LR;
${collector.join(";\n")}
}`;
}
serviceProto = protobuf.parse(SOURCE)
protoViz(serviceProto.root)
function getEncoding(messageSyntax, messageType, payload) {
const source = `syntax = "proto2";
package default_package;
${messageSyntax}`;
const root = protobuf.parse(source).root;
const topLevelTypes = root.nested.default_package.nested;
const type = topLevelTypes[messageType];
const error = type.verify(payload);
if (error !== null) {
throw new Error(error);
}
const message = type.create(payload);
const buffer = type.encode(message).finish();
console.log(buffer);
return [...buffer].map((n) => n.toString(16).padStart(2, "0")).join(" ");
}
getEncoding(withoutOneOf, "Top", { type: 0 })
getEncoding(withOneOf, "Top", { case: {} })
getEncoding(any, "DocumentStateProto", { subtype: {} })
getEncoding(web2, "DocumentStateProto", { schema: "web-2" })
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
